X-Git-Url: http://git.squeep.com/?p=squeep-indie-auther;a=blobdiff_plain;f=src%2Fmanager.js;fp=src%2Fmanager.js;h=ecec13491dee05fd13b7f32a92129331b4871609;hp=01a941643e093ba10a17dd86b5cd39c700214b3b;hb=11160730c4e424bbb6f90b62a674cab522620192;hpb=8ed17e3fb2fe838398036aef5b2a9398fd608375 diff --git a/src/manager.js b/src/manager.js index 01a9416..ecec134 100644 --- a/src/manager.js +++ b/src/manager.js @@ -1527,7 +1527,7 @@ class Manager { } try { - const result = await this.queuePublisher.publish(queueName, { ticket, resource, subject }); + const result = await this.queuePublisher.publish(queueName, { ticket, resource, subject, epochMs: Date.now() }); this.logger.debug(_scope, 'accepted ticket offer', { queueName, ticket, resource, subject, ctx, result }); } catch (e) { this.logger.error(_scope, 'failed to publish ticket to queue', { error: e, queueName, ticket, resource, subject, ctx }); @@ -1934,7 +1934,7 @@ class Manager { try { const result = await this.communication.deliverTicket(ctx.ticketEndpointUrl, ctx.ticketResourceUrl, ctx.ticketSubjectUrl, ticket); - ctx.notifications.push(`Success! Ticket was delivered. (${result?.statusText})`); + ctx.notifications.push(`Success! Ticket was delivered. (${result?.statusMessage})`); this.logger.info(_scope, 'ticket delivered', { ctx, result }); } catch (e) { this.logger.error(_scope, 'failed to deliver ticket', { ctx, error: e });