@@ -30,14 +30,14 @@ public bool AutoDownload
30
30
taskCompletionSource . SetResult ( ( bool ) result ) ;
31
31
} ) ;
32
32
33
- BridgeConnector . Socket . Emit ( "autoUpdater-autoDownload-get" ) ;
33
+ BridgeConnector . Socket . Emit ( "autoUpdater-autoDownload-get" ) . FireAndForget ( ) ;
34
34
35
35
return taskCompletionSource . Task ;
36
36
} ) . Result ;
37
37
}
38
38
set
39
39
{
40
- BridgeConnector . Socket . Emit ( "autoUpdater-autoDownload-set" , value ) ;
40
+ BridgeConnector . Socket . Emit ( "autoUpdater-autoDownload-set" , value ) . FireAndForget ( ) ;
41
41
}
42
42
}
43
43
@@ -60,14 +60,13 @@ public bool AutoInstallOnAppQuit
60
60
taskCompletionSource . SetResult ( ( bool ) result ) ;
61
61
} ) ;
62
62
63
- BridgeConnector . Socket . Emit ( "autoUpdater-autoInstallOnAppQuit-get" ) ;
64
-
63
+ BridgeConnector . Socket . Emit ( "autoUpdater-autoInstallOnAppQuit-get" ) . FireAndForget ( ) ;
65
64
return taskCompletionSource . Task ;
66
65
} ) . Result ;
67
66
}
68
67
set
69
68
{
70
- BridgeConnector . Socket . Emit ( "autoUpdater-autoInstallOnAppQuit-set" , value ) ;
69
+ BridgeConnector . Socket . Emit ( "autoUpdater-autoInstallOnAppQuit-set" , value ) . FireAndForget ( ) ;
71
70
}
72
71
}
73
72
@@ -91,14 +90,14 @@ public bool AllowPrerelease
91
90
taskCompletionSource . SetResult ( ( bool ) result ) ;
92
91
} ) ;
93
92
94
- BridgeConnector . Socket . Emit ( "autoUpdater-allowPrerelease-get" ) ;
93
+ BridgeConnector . Socket . Emit ( "autoUpdater-allowPrerelease-get" ) . FireAndForget ( ) ;
95
94
96
95
return taskCompletionSource . Task ;
97
96
} ) . Result ;
98
97
}
99
98
set
100
99
{
101
- BridgeConnector . Socket . Emit ( "autoUpdater-allowPrerelease-set" , value ) ;
100
+ BridgeConnector . Socket . Emit ( "autoUpdater-allowPrerelease-set" , value ) . FireAndForget ( ) ;
102
101
}
103
102
}
104
103
@@ -120,14 +119,14 @@ public bool FullChangelog
120
119
taskCompletionSource . SetResult ( ( bool ) result ) ;
121
120
} ) ;
122
121
123
- BridgeConnector . Socket . Emit ( "autoUpdater-fullChangelog-get" ) ;
122
+ BridgeConnector . Socket . Emit ( "autoUpdater-fullChangelog-get" ) . FireAndForget ( ) ;
124
123
125
124
return taskCompletionSource . Task ;
126
125
} ) . Result ;
127
126
}
128
127
set
129
128
{
130
- BridgeConnector . Socket . Emit ( "autoUpdater-fullChangelog-set" , value ) ;
129
+ BridgeConnector . Socket . Emit ( "autoUpdater-fullChangelog-set" , value ) . FireAndForget ( ) ;
131
130
}
132
131
}
133
132
@@ -150,14 +149,14 @@ public bool AllowDowngrade
150
149
taskCompletionSource . SetResult ( ( bool ) result ) ;
151
150
} ) ;
152
151
153
- BridgeConnector . Socket . Emit ( "autoUpdater-allowDowngrade-get" ) ;
152
+ BridgeConnector . Socket . Emit ( "autoUpdater-allowDowngrade-get" ) . FireAndForget ( ) ;
154
153
155
154
return taskCompletionSource . Task ;
156
155
} ) . Result ;
157
156
}
158
157
set
159
158
{
160
- BridgeConnector . Socket . Emit ( "autoUpdater-allowDowngrade-set" , value ) ;
159
+ BridgeConnector . Socket . Emit ( "autoUpdater-allowDowngrade-set" , value ) . FireAndForget ( ) ;
161
160
}
162
161
}
163
162
@@ -178,7 +177,7 @@ public string UpdateConfigPath
178
177
taskCompletionSource . SetResult ( result . ToString ( ) ) ;
179
178
} ) ;
180
179
181
- BridgeConnector . Socket . Emit ( "autoUpdater-updateConfigPath-get" ) ;
180
+ BridgeConnector . Socket . Emit ( "autoUpdater-updateConfigPath-get" ) . FireAndForget ( ) ;
182
181
183
182
return taskCompletionSource . Task ;
184
183
} ) . Result ;
@@ -195,15 +194,14 @@ public Task<SemVer> CurrentVersionAsync
195
194
return Task . Run < SemVer > ( ( ) =>
196
195
{
197
196
var taskCompletionSource = new TaskCompletionSource < SemVer > ( ) ;
198
-
199
197
BridgeConnector . Socket . On ( "autoUpdater-currentVersion-get-reply" , ( result ) =>
200
198
{
201
199
BridgeConnector . Socket . Off ( "autoUpdater-currentVersion-get-reply" ) ;
202
200
SemVer version = ( ( JObject ) result ) . ToObject < SemVer > ( ) ;
203
201
taskCompletionSource . SetResult ( version ) ;
204
202
} ) ;
205
- BridgeConnector . Socket . Emit ( "autoUpdater-currentVersion-get" ) ;
206
203
204
+ BridgeConnector . Socket . Emit ( "autoUpdater-currentVersion-get" ) . FireAndForget ( ) ;
207
205
return taskCompletionSource . Task ;
208
206
} ) ;
209
207
}
@@ -239,8 +237,8 @@ public Task<string> ChannelAsync
239
237
BridgeConnector . Socket . Off ( "autoUpdater-channel-get-reply" ) ;
240
238
taskCompletionSource . SetResult ( result . ToString ( ) ) ;
241
239
} ) ;
242
- BridgeConnector . Socket . Emit ( "autoUpdater-channel-get" ) ;
243
240
241
+ BridgeConnector . Socket . Emit ( "autoUpdater-channel-get" ) . FireAndForget ( ) ;
244
242
return taskCompletionSource . Task ;
245
243
} ) ;
246
244
}
@@ -264,7 +262,8 @@ public Task<Dictionary<string, string>> RequestHeadersAsync
264
262
Dictionary < string , string > result = ( ( JObject ) headers ) . ToObject < Dictionary < string , string > > ( ) ;
265
263
taskCompletionSource . SetResult ( result ) ;
266
264
} ) ;
267
- BridgeConnector . Socket . Emit ( "autoUpdater-requestHeaders-get" ) ;
265
+
266
+ BridgeConnector . Socket . Emit ( "autoUpdater-requestHeaders-get" ) . FireAndForget ( ) ;
268
267
return taskCompletionSource . Task ;
269
268
} ) ;
270
269
}
@@ -277,7 +276,7 @@ public Dictionary<string, string> RequestHeaders
277
276
{
278
277
set
279
278
{
280
- BridgeConnector . Socket . Emit ( "autoUpdater-requestHeaders-set" , JObject . FromObject ( value , _jsonSerializer ) ) ;
279
+ BridgeConnector . Socket . Emit ( "autoUpdater-requestHeaders-set" , JObject . FromObject ( value , _jsonSerializer ) ) . FireAndForget ( ) ;
281
280
}
282
281
}
283
282
@@ -295,7 +294,7 @@ public event Action<string> OnError
295
294
_error ( message . ToString ( ) ) ;
296
295
} ) ;
297
296
298
- BridgeConnector . Socket . Emit ( "register-autoUpdater-error-event" , GetHashCode ( ) ) ;
297
+ BridgeConnector . Socket . Emit ( "register-autoUpdater-error-event" , GetHashCode ( ) ) . FireAndForget ( ) ;
299
298
}
300
299
_error += value ;
301
300
}
@@ -304,7 +303,9 @@ public event Action<string> OnError
304
303
_error -= value ;
305
304
306
305
if ( _error == null )
306
+ {
307
307
BridgeConnector . Socket . Off ( "autoUpdater-error" + GetHashCode ( ) ) ;
308
+ }
308
309
}
309
310
}
310
311
@@ -324,7 +325,7 @@ public event Action OnCheckingForUpdate
324
325
_checkingForUpdate ( ) ;
325
326
} ) ;
326
327
327
- BridgeConnector . Socket . Emit ( "register-autoUpdater-checking-for-update-event" , GetHashCode ( ) ) ;
328
+ BridgeConnector . Socket . Emit ( "register-autoUpdater-checking-for-update-event" , GetHashCode ( ) ) . FireAndForget ( ) ;
328
329
}
329
330
_checkingForUpdate += value ;
330
331
}
@@ -354,7 +355,7 @@ public event Action<UpdateInfo> OnUpdateAvailable
354
355
_updateAvailable ( JObject . Parse ( updateInfo . ToString ( ) ) . ToObject < UpdateInfo > ( ) ) ;
355
356
} ) ;
356
357
357
- BridgeConnector . Socket . Emit ( "register-autoUpdater-update-available-event" , GetHashCode ( ) ) ;
358
+ BridgeConnector . Socket . Emit ( "register-autoUpdater-update-available-event" , GetHashCode ( ) ) . FireAndForget ( ) ;
358
359
}
359
360
_updateAvailable += value ;
360
361
}
@@ -363,7 +364,9 @@ public event Action<UpdateInfo> OnUpdateAvailable
363
364
_updateAvailable -= value ;
364
365
365
366
if ( _updateAvailable == null )
367
+ {
366
368
BridgeConnector . Socket . Off ( "autoUpdater-update-available" + GetHashCode ( ) ) ;
369
+ }
367
370
}
368
371
}
369
372
@@ -383,7 +386,7 @@ public event Action<UpdateInfo> OnUpdateNotAvailable
383
386
_updateNotAvailable ( JObject . Parse ( updateInfo . ToString ( ) ) . ToObject < UpdateInfo > ( ) ) ;
384
387
} ) ;
385
388
386
- BridgeConnector . Socket . Emit ( "register-autoUpdater-update-not-available-event" , GetHashCode ( ) ) ;
389
+ BridgeConnector . Socket . Emit ( "register-autoUpdater-update-not-available-event" , GetHashCode ( ) ) . FireAndForget ( ) ;
387
390
}
388
391
_updateNotAvailable += value ;
389
392
}
@@ -392,7 +395,9 @@ public event Action<UpdateInfo> OnUpdateNotAvailable
392
395
_updateNotAvailable -= value ;
393
396
394
397
if ( _updateNotAvailable == null )
398
+ {
395
399
BridgeConnector . Socket . Off ( "autoUpdater-update-not-available" + GetHashCode ( ) ) ;
400
+ }
396
401
}
397
402
}
398
403
@@ -412,7 +417,7 @@ public event Action<ProgressInfo> OnDownloadProgress
412
417
_downloadProgress ( JObject . Parse ( progressInfo . ToString ( ) ) . ToObject < ProgressInfo > ( ) ) ;
413
418
} ) ;
414
419
415
- BridgeConnector . Socket . Emit ( "register-autoUpdater-download-progress-event" , GetHashCode ( ) ) ;
420
+ BridgeConnector . Socket . Emit ( "register-autoUpdater-download-progress-event" , GetHashCode ( ) ) . FireAndForget ( ) ;
416
421
}
417
422
_downloadProgress += value ;
418
423
}
@@ -421,7 +426,9 @@ public event Action<ProgressInfo> OnDownloadProgress
421
426
_downloadProgress -= value ;
422
427
423
428
if ( _downloadProgress == null )
429
+ {
424
430
BridgeConnector . Socket . Off ( "autoUpdater-download-progress" + GetHashCode ( ) ) ;
431
+ }
425
432
}
426
433
}
427
434
@@ -441,7 +448,7 @@ public event Action<UpdateInfo> OnUpdateDownloaded
441
448
_updateDownloaded ( JObject . Parse ( updateInfo . ToString ( ) ) . ToObject < UpdateInfo > ( ) ) ;
442
449
} ) ;
443
450
444
- BridgeConnector . Socket . Emit ( "register-autoUpdater-update-downloaded-event" , GetHashCode ( ) ) ;
451
+ BridgeConnector . Socket . Emit ( "register-autoUpdater-update-downloaded-event" , GetHashCode ( ) ) . FireAndForget ( ) ;
445
452
}
446
453
_updateDownloaded += value ;
447
454
}
@@ -450,7 +457,9 @@ public event Action<UpdateInfo> OnUpdateDownloaded
450
457
_updateDownloaded -= value ;
451
458
452
459
if ( _updateDownloaded == null )
460
+ {
453
461
BridgeConnector . Socket . Off ( "autoUpdater-update-downloaded" + GetHashCode ( ) ) ;
462
+ }
454
463
}
455
464
}
456
465
@@ -506,14 +515,17 @@ public Task<UpdateCheckResult> CheckForUpdatesAsync()
506
515
{
507
516
BridgeConnector . Socket . Off ( "autoUpdaterCheckForUpdatesComplete" + guid ) ;
508
517
BridgeConnector . Socket . Off ( "autoUpdaterCheckForUpdatesError" + guid ) ;
509
- string message = "An error occurred in CheckForUpdatesAsync" ;
518
+ var message = "An error occurred in CheckForUpdatesAsync" ;
519
+
510
520
if ( error != null && ! string . IsNullOrEmpty ( error . ToString ( ) ) )
521
+ {
511
522
message = JsonConvert . SerializeObject ( error ) ;
523
+ }
524
+
512
525
taskCompletionSource . SetException ( new Exception ( message ) ) ;
513
526
} ) ;
514
527
515
- BridgeConnector . Socket . Emit ( "autoUpdaterCheckForUpdates" , guid ) ;
516
-
528
+ BridgeConnector . Socket . Emit ( "autoUpdaterCheckForUpdates" , guid ) . FireAndForget ( ) ;
517
529
return taskCompletionSource . Task ;
518
530
}
519
531
@@ -534,10 +546,15 @@ public Task<UpdateCheckResult> CheckForUpdatesAndNotifyAsync()
534
546
{
535
547
BridgeConnector . Socket . Off ( "autoUpdaterCheckForUpdatesAndNotifyComplete" + guid ) ;
536
548
BridgeConnector . Socket . Off ( "autoUpdaterCheckForUpdatesAndNotifyError" + guid ) ;
549
+
537
550
if ( updateCheckResult == null )
551
+ {
538
552
taskCompletionSource . SetResult ( null ) ;
553
+ }
539
554
else
555
+ {
540
556
taskCompletionSource . SetResult ( JObject . Parse ( updateCheckResult . ToString ( ) ) . ToObject < UpdateCheckResult > ( ) ) ;
557
+ }
541
558
}
542
559
catch ( Exception ex )
543
560
{
@@ -548,14 +565,17 @@ public Task<UpdateCheckResult> CheckForUpdatesAndNotifyAsync()
548
565
{
549
566
BridgeConnector . Socket . Off ( "autoUpdaterCheckForUpdatesAndNotifyComplete" + guid ) ;
550
567
BridgeConnector . Socket . Off ( "autoUpdaterCheckForUpdatesAndNotifyError" + guid ) ;
551
- string message = "An error occurred in autoUpdaterCheckForUpdatesAndNotify" ;
568
+ var message = "An error occurred in autoUpdaterCheckForUpdatesAndNotify" ;
569
+
552
570
if ( error != null )
571
+ {
553
572
message = JsonConvert . SerializeObject ( error ) ;
573
+ }
574
+
554
575
taskCompletionSource . SetException ( new Exception ( message ) ) ;
555
576
} ) ;
556
577
557
- BridgeConnector . Socket . Emit ( "autoUpdaterCheckForUpdatesAndNotify" , guid ) ;
558
-
578
+ BridgeConnector . Socket . Emit ( "autoUpdaterCheckForUpdatesAndNotify" , guid ) . FireAndForget ( ) ;
559
579
return taskCompletionSource . Task ;
560
580
}
561
581
@@ -570,7 +590,7 @@ public Task<UpdateCheckResult> CheckForUpdatesAndNotifyAsync()
570
590
/// <param name="isForceRunAfter">Run the app after finish even on silent install. Not applicable for macOS. Ignored if `isSilent` is set to `false`.</param>
571
591
public void QuitAndInstall ( bool isSilent = false , bool isForceRunAfter = false )
572
592
{
573
- BridgeConnector . Socket . Emit ( "autoUpdaterQuitAndInstall" , isSilent , isForceRunAfter ) ;
593
+ BridgeConnector . Socket . Emit ( "autoUpdaterQuitAndInstall" , isSilent , isForceRunAfter ) . FireAndForget ( ) ;
574
594
}
575
595
576
596
/// <summary>
@@ -580,16 +600,15 @@ public void QuitAndInstall(bool isSilent = false, bool isForceRunAfter = false)
580
600
public Task < string > DownloadUpdateAsync ( )
581
601
{
582
602
var taskCompletionSource = new TaskCompletionSource < string > ( ) ;
583
- string guid = Guid . NewGuid ( ) . ToString ( ) ;
603
+ var guid = Guid . NewGuid ( ) . ToString ( ) ;
584
604
585
605
BridgeConnector . Socket . On ( "autoUpdaterDownloadUpdateComplete" + guid , ( downloadedPath ) =>
586
606
{
587
607
BridgeConnector . Socket . Off ( "autoUpdaterDownloadUpdateComplete" + guid ) ;
588
608
taskCompletionSource . SetResult ( downloadedPath . ToString ( ) ) ;
589
609
} ) ;
590
610
591
- BridgeConnector . Socket . Emit ( "autoUpdaterDownloadUpdate" , guid ) ;
592
-
611
+ BridgeConnector . Socket . Emit ( "autoUpdaterDownloadUpdate" , guid ) . FireAndForget ( ) ;
593
612
return taskCompletionSource . Task ;
594
613
}
595
614
@@ -600,16 +619,15 @@ public Task<string> DownloadUpdateAsync()
600
619
public Task < string > GetFeedURLAsync ( )
601
620
{
602
621
var taskCompletionSource = new TaskCompletionSource < string > ( ) ;
603
- string guid = Guid . NewGuid ( ) . ToString ( ) ;
622
+ var guid = Guid . NewGuid ( ) . ToString ( ) ;
604
623
605
624
BridgeConnector . Socket . On ( "autoUpdaterGetFeedURLComplete" + guid , ( downloadedPath ) =>
606
625
{
607
626
BridgeConnector . Socket . Off ( "autoUpdaterGetFeedURLComplete" + guid ) ;
608
627
taskCompletionSource . SetResult ( downloadedPath . ToString ( ) ) ;
609
628
} ) ;
610
629
611
- BridgeConnector . Socket . Emit ( "autoUpdaterGetFeedURL" , guid ) ;
612
-
630
+ BridgeConnector . Socket . Emit ( "autoUpdaterGetFeedURL" , guid ) . FireAndForget ( ) ;
613
631
return taskCompletionSource . Task ;
614
632
}
615
633
0 commit comments