From 64e8c03dea044752bf3f2f228462721fe565f950 Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Wed, 19 Jul 2017 00:50:05 +0200 Subject: refactor all the worker stuff --- lib/worker/processFiles.js | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'lib/worker/processFiles.js') diff --git a/lib/worker/processFiles.js b/lib/worker/processFiles.js index 60e0ca5..c9b2724 100644 --- a/lib/worker/processFiles.js +++ b/lib/worker/processFiles.js @@ -1,11 +1,12 @@ const ipc = require('node-ipc') const db = require('../db') -const dbFile = db.crud(db.File) +const dbFile = db.models.file const path = require('path') const ffprobe = require('node-ffprobe') const execFile = require('child_process').execFile const mimeFromExtension = require('./mimeFromExtension') ffprobe.FFPROBE_PATH = process.env.FFPROBE_BINARY +const Loader = require('../vendor/Loader') let processing = false @@ -13,7 +14,7 @@ module.exports = function processFiles() { if (processing) return processing = true - dbFile.index({ processed: false }).then( (files) => { + dbFile.crud.index({ processed: false }).then( (files) => { console.log(files.length + ' files left to process') if (files.length === 0) { processing = false -- cgit v1.2.3-70-g09d2