X-Git-Url: http://git.squeep.com/?p=squeep-indie-auther;a=blobdiff_plain;f=bin%2FpublishTickets.js;fp=bin%2FpublishTickets.js;h=c8de1f856080b42b2a95a95ff2a0e93112512679;hp=0000000000000000000000000000000000000000;hb=726cd980f0ed5588cfe8cbb2d994d5e4aef6e292;hpb=3c145bc590577c738df4d279744f3e2f9a250294 diff --git a/bin/publishTickets.js b/bin/publishTickets.js new file mode 100644 index 0000000..c8de1f8 --- /dev/null +++ b/bin/publishTickets.js @@ -0,0 +1,30 @@ +'use strict'; + +const DB = require('../src/db'); +const Logger = require('../src/logger'); +const Config = require('../config'); +const config = new Config(process.env.NODE_ENV, false); +const Chores = require('../src/chores'); +const { Publisher: QueuePublisher } = require('@squeep/amqp-helper'); + +const logger = new Logger(config); +const db = new DB(logger, config); + +(async () => { + if (!config.queues.amqp.url) { + console.log('no queue configured, nothing to do'); + return; + } + await db.initialize(); + const queuePublisher = new QueuePublisher(logger, config.queues.amqp); + // no automatic chores + config.chores.tokenCleanupMs = 0; + config.chores.scopeCleanupMs = 0; + config.chores.publishTicketsMs = 0; + const chores = new Chores(logger, db, queuePublisher, config); + + await chores.publishTickets(); + + console.log('done'); + await db._closeConnection(); +})();