diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2017-07-19 00:50:05 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2017-07-19 00:50:05 +0200 |
| commit | 64e8c03dea044752bf3f2f228462721fe565f950 (patch) | |
| tree | 41b48b67f69979bfc97be166129ee41c8dcb0c7f /lib/worker/processFiles.js | |
| parent | 11a70bc347587219b2ec7b63cf4a6ff69bb4199b (diff) | |
refactor all the worker stuff
Diffstat (limited to 'lib/worker/processFiles.js')
| -rw-r--r-- | lib/worker/processFiles.js | 5 |
1 files changed, 3 insertions, 2 deletions
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 |
