projects
/
websub-hub
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix sqlite subscription data to return native dates
[websub-hub]
/
src
/
manager.js
diff --git
a/src/manager.js
b/src/manager.js
index b3aff45da975952ea8ad27d51aa058823348cbdd..fddc8e45ae6f272a346c2131a05d909c190d03d9 100644
(file)
--- a/
src/manager.js
+++ b/
src/manager.js
@@
-40,7
+40,7
@@
class Manager {
* @param {http.ServerResponse} res
* @param {object} ctx
*/
* @param {http.ServerResponse} res
* @param {object} ctx
*/
-
async getHealthcheck(res, ctx) {
+ async getHealthcheck(res, ctx) {
const _scope = _fileScope('getHealthcheck');
const health = 'happy';
const _scope = _fileScope('getHealthcheck');
const health = 'happy';
@@
-342,7
+342,7
@@
class Manager {
let fn, info, id;
try {
if (data.mode === Enum.Mode.Publish) {
let fn, info, id;
try {
if (data.mode === Enum.Mode.Publish) {
- fn = 'topic
Publish
';
+ fn = 'topic
FetchRequested
';
info = await this.db.topicFetchRequested(dbCtx, data.topicId);
id = data.topicId;
} else {
info = await this.db.topicFetchRequested(dbCtx, data.topicId);
id = data.topicId;
} else {
@@
-366,7
+366,7
@@
class Manager {
fn = 'topicFetchClaimAndProcessById';
await this.communication.topicFetchClaimAndProcessById(dbCtx, id, requestId);
} else {
fn = 'topicFetchClaimAndProcessById';
await this.communication.topicFetchClaimAndProcessById(dbCtx, id, requestId);
} else {
- fn = '
processVerification
';
+ fn = '
verificationClaimAndProcessById
';
await this.communication.verificationClaimAndProcessById(dbCtx, id, requestId);
}
} catch (e) {
await this.communication.verificationClaimAndProcessById(dbCtx, id, requestId);
}
} catch (e) {
@@
-666,7
+666,9
@@
class Manager {
this.logger.debug(_scope, 'called', { ctx });
// N.B. no await on this
this.logger.debug(_scope, 'called', { ctx });
// N.B. no await on this
- this.communication.worker.process();
+ this.communication.worker.process().catch((e) => {
+ this.logger.error(_scope, 'failed', { error: e, ctx });
+ });
res.end();
this.logger.info(_scope, 'invoked worker process', { ctx });
res.end();
this.logger.info(_scope, 'invoked worker process', { ctx });