redeem proffered tickets, db schema 1.1.0
[squeep-indie-auther] / bin / publishTickets.js
1 'use strict';
2
3 const DB = require('../src/db');
4 const Logger = require('../src/logger');
5 const Config = require('../config');
6 const config = new Config(process.env.NODE_ENV, false);
7 const Chores = require('../src/chores');
8 const { Publisher: QueuePublisher } = require('@squeep/amqp-helper');
9
10 const logger = new Logger(config);
11 const db = new DB(logger, config);
12
13 (async () => {
14 if (!config.queues.amqp.url) {
15 console.log('no queue configured, nothing to do');
16 return;
17 }
18 await db.initialize();
19 const queuePublisher = new QueuePublisher(logger, config.queues.amqp);
20 // no automatic chores
21 config.chores.tokenCleanupMs = 0;
22 config.chores.scopeCleanupMs = 0;
23 config.chores.publishTicketsMs = 0;
24 const chores = new Chores(logger, db, queuePublisher, config);
25
26 await chores.publishTickets();
27
28 console.log('done');
29 await db._closeConnection();
30 })();