summaryrefslogtreecommitdiff
path: root/lib/worker/processFiles.js
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2017-07-19 00:50:05 +0200
committerJules Laplace <julescarbon@gmail.com>2017-07-19 00:50:05 +0200
commit64e8c03dea044752bf3f2f228462721fe565f950 (patch)
tree41b48b67f69979bfc97be166129ee41c8dcb0c7f /lib/worker/processFiles.js
parent11a70bc347587219b2ec7b63cf4a6ff69bb4199b (diff)
refactor all the worker stuff
Diffstat (limited to 'lib/worker/processFiles.js')
-rw-r--r--lib/worker/processFiles.js5
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