Delete videobrowser.js
Moe
parent
1bfff28763
commit
17c87dcd46
|
|
@ -1,278 +0,0 @@
|
|||
const knex = require('knex');
|
||||
const moment = require('moment');
|
||||
|
||||
const ENDPOINT_SECTION = "videoBrowser";
|
||||
|
||||
module.exports = (s, shinobiConfig, lang, app, io) => {
|
||||
const instance = {
|
||||
db: null,
|
||||
timeZoneOffest: 0
|
||||
};
|
||||
|
||||
const setOkResponse = (response, data, message) => {
|
||||
console.debug(message);
|
||||
|
||||
response.send({
|
||||
ok: true,
|
||||
data: data
|
||||
});
|
||||
};
|
||||
|
||||
const setErrorResponse = (response, error, flowName) => {
|
||||
console.error(`Failed to ${flowName}, Error: ${error}`);
|
||||
|
||||
response.status(500).send();
|
||||
};
|
||||
|
||||
const getISODateTime = (date) => {
|
||||
const dateTime = moment(date).add(instance.timeZoneOffest, "minutes");
|
||||
const dateTimeISO = dateTime.toISOString();
|
||||
const dateTimeISOParts = dateTimeISO.split(".");
|
||||
const result = dateTimeISOParts[0];
|
||||
|
||||
return result;
|
||||
};
|
||||
|
||||
const getISODate = (dateStr) => {
|
||||
const dateTimeISO = getISODateTime(dateStr);
|
||||
const dateTimeISOParts = dateTimeISO.split("T");
|
||||
const dateISO = dateTimeISOParts[0];
|
||||
|
||||
return dateISO;
|
||||
};
|
||||
|
||||
const fixItemsDate = (dataItems) => {
|
||||
dataItems.forEach(i => {
|
||||
i.date = getISODate(i.date);
|
||||
});
|
||||
};
|
||||
|
||||
const getMonitorsList = (requestParams, response) => {
|
||||
const groupKey = requestParams.ke;
|
||||
|
||||
instance.db
|
||||
.select('ke', 'mid')
|
||||
.from('Videos')
|
||||
.where('ke', '=', groupKey)
|
||||
.groupBy('ke')
|
||||
.groupBy('mid')
|
||||
.then(data => {
|
||||
setOkResponse(
|
||||
response,
|
||||
data,
|
||||
`Reterived ${data.length} monitors with videos, Group ID: ${groupKey}`
|
||||
);
|
||||
|
||||
})
|
||||
.catch(error => {
|
||||
setErrorResponse(
|
||||
response,
|
||||
error,
|
||||
`reterive monitors list, Group ID: ${groupKey}`
|
||||
);
|
||||
});
|
||||
};
|
||||
|
||||
const setResponseForMonitorDatesList = (response, videoItems, imageItems) => {
|
||||
const firstVideoItem = videoItems[0];
|
||||
const groupKey = firstVideoItem.ke;
|
||||
const monitorId = firstVideoItem.mid;
|
||||
|
||||
fixItemsDate(imageItems);
|
||||
|
||||
videoItems.forEach(v => {
|
||||
const imagesOfVideo = imageItems.filter(i => i.date === v.date);
|
||||
|
||||
if (imagesOfVideo.length > 0) {
|
||||
const chosenImage = imagesOfVideo[0];
|
||||
|
||||
v.filename = chosenImage.filename;
|
||||
}
|
||||
});
|
||||
|
||||
setOkResponse(
|
||||
response,
|
||||
videoItems,
|
||||
`Reterived ${videoItems.length} videos and ${imageItems.length} images, Group ID: ${groupKey}, Monitor ID: ${monitorId}`
|
||||
);
|
||||
};
|
||||
|
||||
const loadImagesForMonitorDatesList = (response, videoItems) => {
|
||||
const firstVideoItem = videoItems[0];
|
||||
const groupKey = firstVideoItem.ke;
|
||||
const monitorId = firstVideoItem.mid;
|
||||
|
||||
fixItemsDate(videoItems);
|
||||
|
||||
instance.db
|
||||
.select('ke', 'mid', 'filename', instance.db.raw("CAST(time AS DATE) as date"))
|
||||
.from('Timelapse Frames')
|
||||
.where('ke', '=', groupKey)
|
||||
.andWhere('mid', '=', monitorId)
|
||||
.groupBy('ke')
|
||||
.groupBy('mid')
|
||||
.groupByRaw('CAST(time AS DATE)')
|
||||
.orderBy("time", "desc")
|
||||
.then(imageItems => {
|
||||
setResponseForMonitorDatesList(response, videoItems, imageItems);
|
||||
})
|
||||
.catch(error => {
|
||||
setErrorResponse(
|
||||
response,
|
||||
error,
|
||||
`reterive monitor dates list, Group ID: ${groupKey}, Monitor ID: ${monitorId}`
|
||||
);
|
||||
});
|
||||
};
|
||||
|
||||
const getMonitorDatesList = (requestParams, response) => {
|
||||
const groupKey = requestParams.ke;
|
||||
const monitorId = requestParams.id;
|
||||
|
||||
instance.db
|
||||
.select('ke', 'mid', instance.db.raw("CAST(time AS DATE) as date"))
|
||||
.from('Videos')
|
||||
.where('ke', '=', groupKey)
|
||||
.andWhere('mid', '=', monitorId)
|
||||
.groupBy('ke')
|
||||
.groupBy('mid')
|
||||
.groupByRaw('CAST(time AS DATE)')
|
||||
.orderBy("time", "desc")
|
||||
.then(videoItems => {
|
||||
loadImagesForMonitorDatesList(response, videoItems);
|
||||
})
|
||||
.catch(error => {
|
||||
setErrorResponse(
|
||||
response,
|
||||
error,
|
||||
`reterive monitor dates list, Group ID: ${groupKey}, Monitor ID: ${monitorId}`
|
||||
);
|
||||
});
|
||||
};
|
||||
|
||||
const setResponseForMonitorVideosList = (response, videoItems, imageItems) => {
|
||||
const firstVideoItem = videoItems[0];
|
||||
const monitorId = firstVideoItem.mid;
|
||||
const videoDate = getISODate(firstVideoItem.date);
|
||||
|
||||
videoItems.forEach(v => {
|
||||
const imagesOfVideo = imageItems.filter(i => i.time >= v.time && i.time <= v.end);
|
||||
|
||||
if (imagesOfVideo.length > 0) {
|
||||
const chosenImage = imagesOfVideo[0];
|
||||
|
||||
v.time = getISODateTime(v.time);
|
||||
v.filename = chosenImage.filename;
|
||||
|
||||
delete v.end;
|
||||
}
|
||||
});
|
||||
|
||||
setOkResponse(
|
||||
response,
|
||||
videoItems,
|
||||
`Reterived ${videoItems.length} videos and ${imageItems.length} images, Monitor ID: ${monitorId}, Date: ${videoDate}`
|
||||
);
|
||||
};
|
||||
|
||||
const loadImagesForMonitorVideosList = (requestParams, response, videoItems) => {
|
||||
const groupKey = requestParams.ke;
|
||||
const monitorId = requestParams.id;
|
||||
const videoDate = requestParams.date;
|
||||
|
||||
instance.db
|
||||
.select('ke', 'mid', 'time', 'filename')
|
||||
.from('Timelapse Frames')
|
||||
.where('ke', '=', groupKey)
|
||||
.andWhere('mid', '=', monitorId)
|
||||
.andWhere('time', '>=', `${videoDate} 00:00:00.000`)
|
||||
.andWhere('time', '<=', `${videoDate} 23:59:59.999`)
|
||||
.orderBy("time", "desc")
|
||||
.then(imageItems => {
|
||||
setResponseForMonitorVideosList(response, videoItems, imageItems);
|
||||
})
|
||||
.catch(error => {
|
||||
setErrorResponse(
|
||||
response,
|
||||
error,
|
||||
`reterive monitor videos list, Group ID: ${groupKey}, Monitor ID: ${monitorId}, Date: ${videoDate}`
|
||||
);
|
||||
});
|
||||
};
|
||||
|
||||
const getMonitorVideosList = (requestParams, response) => {
|
||||
const groupKey = requestParams.ke;
|
||||
const monitorId = requestParams.id;
|
||||
const videoDate = requestParams.date;
|
||||
|
||||
instance.db
|
||||
.select('ke', 'mid', 'time', 'end', 'ext')
|
||||
.from('Videos')
|
||||
.where('ke', '=', groupKey)
|
||||
.andWhere('mid', '=', monitorId)
|
||||
.andWhere('time', '>=', `${videoDate} 00:00:00.000`)
|
||||
.andWhere('time', '<=', `${videoDate} 23:59:59.999`)
|
||||
.orderBy("time", "desc")
|
||||
.then(videoItems => {
|
||||
loadImagesForMonitorVideosList(requestParams, response, videoItems);
|
||||
})
|
||||
.catch(error => {
|
||||
setErrorResponse(
|
||||
response,
|
||||
error,
|
||||
`reterive monitor videos list, Group ID: ${groupKey}, Monitor ID: ${monitorId}, Date: ${videoDate}`
|
||||
);
|
||||
});
|
||||
};
|
||||
|
||||
const initialize = () => {
|
||||
const apiPrefix = `${shinobiConfig.webPaths.apiPrefix}:auth/${ENDPOINT_SECTION}`;
|
||||
|
||||
const apiSettings = [
|
||||
{
|
||||
suffix: `/:ke`,
|
||||
callback: getMonitorsList
|
||||
},
|
||||
{
|
||||
suffix: `/:ke/:id`,
|
||||
callback: getMonitorDatesList
|
||||
},
|
||||
{
|
||||
suffix:`/:ke/:id/:date`,
|
||||
callback: getMonitorVideosList
|
||||
}
|
||||
];
|
||||
|
||||
apiSettings.forEach(endpointSettings => {
|
||||
const endpointSuffix = endpointSettings.suffix;
|
||||
const endpointCallback = endpointSettings.callback;
|
||||
|
||||
const endpointRoute = `${apiPrefix}${endpointSuffix}`
|
||||
|
||||
app.get(endpointRoute, (req, res) => {
|
||||
s.auth(req.params, user => {
|
||||
endpointCallback(req.params, res);
|
||||
}, res, req);
|
||||
});
|
||||
});
|
||||
|
||||
const dbConfig = {
|
||||
client: shinobiConfig.databaseType,
|
||||
connection: shinobiConfig.db
|
||||
};
|
||||
|
||||
if(dbConfig.client.indexOf('sqlite')>-1){
|
||||
dbConfig.client = 'sqlite3';
|
||||
dbConfig.useNullAsDefault = true;
|
||||
}
|
||||
|
||||
if(dbConfig.client === 'sqlite3' && dbConfig.connection.filename === undefined){
|
||||
dbConfig.connection.filename = `${__dirname}/shinobi.sqlite`;
|
||||
}
|
||||
|
||||
instance.db = knex(dbConfig);
|
||||
instance.timeZoneOffest = new Date().getTimezoneOffset() * -1;
|
||||
};
|
||||
|
||||
initialize();
|
||||
};
|
||||
Loading…
Reference in New Issue