@@ -46,6 +46,16 @@ export class IotShadowClient {
46
46
47
47
private decoder = new TextDecoder ( 'utf-8' ) ;
48
48
49
+ private static INVALID_PAYLOAD_PARSING_ERROR = "Invalid/unknown error parsing payload into response" ;
50
+
51
+ private static createClientError ( err : any , payload : ArrayBuffer ) : IotShadowError {
52
+ if ( err instanceof Error ) {
53
+ return new IotShadowError ( err . message , payload ) ;
54
+ } else {
55
+ return new IotShadowError ( IotShadowClient . INVALID_PAYLOAD_PARSING_ERROR , payload ) ;
56
+ }
57
+ }
58
+
49
59
constructor ( private connection : mqtt . MqttClientConnection ) {
50
60
}
51
61
@@ -87,7 +97,7 @@ export class IotShadowClient {
87
97
const payload_text = this . decoder . decode ( payload ) ;
88
98
response = JSON . parse ( payload_text ) as model . ErrorResponse ;
89
99
} catch ( err ) {
90
- error = new IotShadowError ( err . message , payload ) ;
100
+ error = IotShadowClient . createClientError ( err , payload ) ;
91
101
}
92
102
finally {
93
103
messageHandler ( error , response ) ;
@@ -135,7 +145,7 @@ export class IotShadowClient {
135
145
const payload_text = this . decoder . decode ( payload ) ;
136
146
response = JSON . parse ( payload_text ) as model . ShadowDeltaUpdatedEvent ;
137
147
} catch ( err ) {
138
- error = new IotShadowError ( err . message , payload ) ;
148
+ error = IotShadowClient . createClientError ( err , payload ) ;
139
149
}
140
150
finally {
141
151
messageHandler ( error , response ) ;
@@ -184,7 +194,7 @@ export class IotShadowClient {
184
194
const payload_text = this . decoder . decode ( payload ) ;
185
195
response = JSON . parse ( payload_text ) as model . ErrorResponse ;
186
196
} catch ( err ) {
187
- error = new IotShadowError ( err . message , payload ) ;
197
+ error = IotShadowClient . createClientError ( err , payload ) ;
188
198
}
189
199
finally {
190
200
messageHandler ( error , response ) ;
@@ -233,7 +243,7 @@ export class IotShadowClient {
233
243
const payload_text = this . decoder . decode ( payload ) ;
234
244
response = JSON . parse ( payload_text ) as model . ErrorResponse ;
235
245
} catch ( err ) {
236
- error = new IotShadowError ( err . message , payload ) ;
246
+ error = IotShadowClient . createClientError ( err , payload ) ;
237
247
}
238
248
finally {
239
249
messageHandler ( error , response ) ;
@@ -338,7 +348,7 @@ export class IotShadowClient {
338
348
const payload_text = this . decoder . decode ( payload ) ;
339
349
response = JSON . parse ( payload_text ) as model . DeleteShadowResponse ;
340
350
} catch ( err ) {
341
- error = new IotShadowError ( err . message , payload ) ;
351
+ error = IotShadowClient . createClientError ( err , payload ) ;
342
352
}
343
353
finally {
344
354
messageHandler ( error , response ) ;
@@ -386,7 +396,7 @@ export class IotShadowClient {
386
396
const payload_text = this . decoder . decode ( payload ) ;
387
397
response = JSON . parse ( payload_text ) as model . GetShadowResponse ;
388
398
} catch ( err ) {
389
- error = new IotShadowError ( err . message , payload ) ;
399
+ error = IotShadowClient . createClientError ( err , payload ) ;
390
400
}
391
401
finally {
392
402
messageHandler ( error , response ) ;
@@ -435,7 +445,7 @@ export class IotShadowClient {
435
445
const payload_text = this . decoder . decode ( payload ) ;
436
446
response = JSON . parse ( payload_text ) as model . GetShadowResponse ;
437
447
} catch ( err ) {
438
- error = new IotShadowError ( err . message , payload ) ;
448
+ error = IotShadowClient . createClientError ( err , payload ) ;
439
449
}
440
450
finally {
441
451
messageHandler ( error , response ) ;
@@ -484,7 +494,7 @@ export class IotShadowClient {
484
494
const payload_text = this . decoder . decode ( payload ) ;
485
495
response = JSON . parse ( payload_text ) as model . ShadowUpdatedEvent ;
486
496
} catch ( err ) {
487
- error = new IotShadowError ( err . message , payload ) ;
497
+ error = IotShadowClient . createClientError ( err , payload ) ;
488
498
}
489
499
finally {
490
500
messageHandler ( error , response ) ;
@@ -532,7 +542,7 @@ export class IotShadowClient {
532
542
const payload_text = this . decoder . decode ( payload ) ;
533
543
response = JSON . parse ( payload_text ) as model . ShadowUpdatedEvent ;
534
544
} catch ( err ) {
535
- error = new IotShadowError ( err . message , payload ) ;
545
+ error = IotShadowClient . createClientError ( err , payload ) ;
536
546
}
537
547
finally {
538
548
messageHandler ( error , response ) ;
@@ -610,7 +620,7 @@ export class IotShadowClient {
610
620
const payload_text = this . decoder . decode ( payload ) ;
611
621
response = JSON . parse ( payload_text ) as model . DeleteShadowResponse ;
612
622
} catch ( err ) {
613
- error = new IotShadowError ( err . message , payload ) ;
623
+ error = IotShadowClient . createClientError ( err , payload ) ;
614
624
}
615
625
finally {
616
626
messageHandler ( error , response ) ;
@@ -658,7 +668,7 @@ export class IotShadowClient {
658
668
const payload_text = this . decoder . decode ( payload ) ;
659
669
response = JSON . parse ( payload_text ) as model . ErrorResponse ;
660
670
} catch ( err ) {
661
- error = new IotShadowError ( err . message , payload ) ;
671
+ error = IotShadowClient . createClientError ( err , payload ) ;
662
672
}
663
673
finally {
664
674
messageHandler ( error , response ) ;
@@ -706,7 +716,7 @@ export class IotShadowClient {
706
716
const payload_text = this . decoder . decode ( payload ) ;
707
717
response = JSON . parse ( payload_text ) as model . ErrorResponse ;
708
718
} catch ( err ) {
709
- error = new IotShadowError ( err . message , payload ) ;
719
+ error = IotShadowClient . createClientError ( err , payload ) ;
710
720
}
711
721
finally {
712
722
messageHandler ( error , response ) ;
@@ -810,7 +820,7 @@ export class IotShadowClient {
810
820
const payload_text = this . decoder . decode ( payload ) ;
811
821
response = JSON . parse ( payload_text ) as model . UpdateShadowResponse ;
812
822
} catch ( err ) {
813
- error = new IotShadowError ( err . message , payload ) ;
823
+ error = IotShadowClient . createClientError ( err , payload ) ;
814
824
}
815
825
finally {
816
826
messageHandler ( error , response ) ;
@@ -859,7 +869,7 @@ export class IotShadowClient {
859
869
const payload_text = this . decoder . decode ( payload ) ;
860
870
response = JSON . parse ( payload_text ) as model . ErrorResponse ;
861
871
} catch ( err ) {
862
- error = new IotShadowError ( err . message , payload ) ;
872
+ error = IotShadowClient . createClientError ( err , payload ) ;
863
873
}
864
874
finally {
865
875
messageHandler ( error , response ) ;
@@ -937,7 +947,7 @@ export class IotShadowClient {
937
947
const payload_text = this . decoder . decode ( payload ) ;
938
948
response = JSON . parse ( payload_text ) as model . ShadowDeltaUpdatedEvent ;
939
949
} catch ( err ) {
940
- error = new IotShadowError ( err . message , payload ) ;
950
+ error = IotShadowClient . createClientError ( err , payload ) ;
941
951
}
942
952
finally {
943
953
messageHandler ( error , response ) ;
@@ -986,7 +996,7 @@ export class IotShadowClient {
986
996
const payload_text = this . decoder . decode ( payload ) ;
987
997
response = JSON . parse ( payload_text ) as model . UpdateShadowResponse ;
988
998
} catch ( err ) {
989
- error = new IotShadowError ( err . message , payload ) ;
999
+ error = IotShadowClient . createClientError ( err , payload ) ;
990
1000
}
991
1001
finally {
992
1002
messageHandler ( error , response ) ;
0 commit comments