From 2f5e0362d6fc9fbd4856838c9dd7667f34378117 Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 4 Apr 2017 16:16:42 +0200 Subject: small syntax fix --- worker.js | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/worker.js b/worker.js index a2287b9..9aad2fe 100644 --- a/worker.js +++ b/worker.js @@ -8,8 +8,8 @@ var amqp = require("amqplib"), item_name_map = require("../orm/items"), sleep = require("sleep-promise"); -var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", - DATABASE_URI = process.env.DATABASE_URI || "sqlite:///db.sqlite", +var RABBITMQ_URI = process.env.RABBITMQ_URI, + DATABASE_URI = process.env.DATABASE_URI, BATCHSIZE = process.env.PROCESSOR_BATCH || 50 * (6 + 5), // objects IDLE_TIMEOUT = process.env.PROCESSOR_IDLETIMEOUT || 500; // ms @@ -18,8 +18,8 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", while (true) { try { - seq = new Seq(DATABASE_URI, { logging: () => {} }), - rabbit = await amqp.connect(RABBITMQ_URI), + seq = new Seq(DATABASE_URI, { logging: () => {} }); + rabbit = await amqp.connect(RABBITMQ_URI); ch = await rabbit.createChannel(); await ch.assertQueue("process", {durable: true}); await ch.assertQueue("compile", {durable: true}); @@ -231,7 +231,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", updateOnDuplicate: [], // all transaction: transaction }), - model.ParticipantItemUse.bulkCreate(participant_item_records, { + model.ItemParticipant.bulkCreate(participant_item_records, { include: [ model.Participant ], updateOnDuplicate: [], // all transaction: transaction -- cgit v1.3.1