Skip to content

Commit ff973a7

Browse files
committed
feat:async channels
First version after refactoring with asynchronous channel communications between modules
1 parent 7f375cf commit ff973a7

10 files changed

+1110
-334
lines changed

dist/create-plugin.js

Lines changed: 329 additions & 70 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/create-plugin.js.map

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/create-plugin.min.js

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

es/daemon.js

Lines changed: 9 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,6 @@ var Daemon = /*#__PURE__*/function () {
5656
this.BOARDS_URL = boardsUrl;
5757
this.UPLOAD_NOPE = 'UPLOAD_NOPE';
5858
this.UPLOAD_DONE = 'UPLOAD_DONE';
59-
this.CDC_RESET_DONE = 'CDC_RESET_DONE';
6059
this.UPLOAD_ERROR = 'UPLOAD_ERROR';
6160
this.UPLOAD_IN_PROGRESS = 'UPLOAD_IN_PROGRESS';
6261
this.DOWNLOAD_DONE = 'DOWNLOAD_DONE';
@@ -76,22 +75,17 @@ var Daemon = /*#__PURE__*/function () {
7675
this.uploading = new BehaviorSubject({
7776
status: this.UPLOAD_NOPE
7877
});
78+
this.uploadInProgress = this.uploading.pipe(filter(function (upload) {
79+
return upload.status === _this.UPLOAD_IN_PROGRESS;
80+
}));
7981
this.uploadingDone = this.uploading.pipe(filter(function (upload) {
8082
return upload.status === _this.UPLOAD_DONE;
8183
})).pipe(first()).pipe(takeUntil(this.uploading.pipe(filter(function (upload) {
8284
return upload.status === _this.UPLOAD_ERROR;
8385
}))));
84-
this.cdcResetDone = this.uploading.pipe(filter(function (upload) {
85-
return upload.status === _this.CDC_RESET_DONE;
86-
}), first(), takeUntil(this.uploading.pipe(filter(function (upload) {
87-
return upload.status === _this.UPLOAD_ERROR || upload.status === _this.UPLOAD_DONE;
88-
}))));
8986
this.uploadingError = this.uploading.pipe(filter(function (upload) {
9087
return upload.status === _this.UPLOAD_ERROR;
9188
})).pipe(first()).pipe(takeUntil(this.uploadingDone));
92-
this.uploadInProgress = this.uploading.pipe(filter(function (upload) {
93-
return upload.status === _this.UPLOAD_IN_PROGRESS;
94-
}));
9589
this.devicesList = new BehaviorSubject({
9690
serial: [],
9791
network: []
@@ -148,13 +142,6 @@ var Daemon = /*#__PURE__*/function () {
148142
_this2.agentFound.next(false);
149143
}
150144
});
151-
} // eslint-disable-next-line class-methods-use-this
152-
153-
}, {
154-
key: "cdcReset",
155-
value: function cdcReset() {
156-
// It's a no-op for daemons different from web serial deamon
157-
return Promise.resolve(true);
158145
}
159146
/**
160147
* Upload a sketch to serial target
@@ -246,6 +233,12 @@ var Daemon = /*#__PURE__*/function () {
246233
});
247234

248235
var files = [].concat(_toConsumableArray(uploadCommandInfo.files || []), _toConsumableArray(compilationResult.files || []));
236+
console.dir('******** BEGIN: daemon:176 ********');
237+
console.dir(uploadPayload, {
238+
depth: null,
239+
colors: true
240+
});
241+
console.dir('******** END: daemon:176 ********');
249242

250243
_this3._upload(uploadPayload, _objectSpread(_objectSpread({}, uploadCommandInfo), {}, {
251244
files: files

0 commit comments

Comments
 (0)