Update media-service.js
This commit is contained in:
@@ -1,10 +1,9 @@
|
|||||||
module.exports = (srv) => {
|
module.exports = (srv) => {
|
||||||
|
|
||||||
var loki = require('lokijs');
|
const loki = require('lokijs');
|
||||||
var db = new loki('DB');
|
const db = new loki('DB');
|
||||||
var mediaDB= db.addCollection("Media");
|
const mediaDB= db.addCollection("Media");
|
||||||
var Readable = require('stream').Readable;
|
const { Readable, PassThrough } = require('stream')
|
||||||
var PassThroughStream = require('stream').PassThrough;
|
|
||||||
|
|
||||||
srv.before('CREATE', 'Media', (req) => {
|
srv.before('CREATE', 'Media', (req) => {
|
||||||
var obj = mediaDB.insert({media: ""});
|
var obj = mediaDB.insert({media: ""});
|
||||||
@@ -21,7 +20,7 @@ module.exports = (srv) => {
|
|||||||
req.reject(404,"No record found for the ID");
|
req.reject(404,"No record found for the ID");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
var stream = new PassThroughStream();
|
var stream = new PassThrough();
|
||||||
let chunks = [];
|
let chunks = [];
|
||||||
stream.on('data', (chunk) => {
|
stream.on('data', (chunk) => {
|
||||||
chunks.push(chunk);
|
chunks.push(chunk);
|
||||||
@@ -80,4 +79,4 @@ module.exports = (srv) => {
|
|||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user