k-space/log-viewer
11
0
Fork 0
Code Issues 6 Pull Requests Projects Activity

Put back event array on React side
All checks were successful
continuous-integration/drone Build is passing
Details

Browse Source
This commit is contained in:
Léo Carpentier
2022-02-15 10:55:59 +02:00
parent b90ae0c18d
commit 4c77fb127d
3 changed files with 32 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
backend/server.js
View File

@@ -2,7 +2,7 @@ const { MongoClient } = require("mongodb");
const express = require('express');
const minio = require('minio');
/*============== VARIABLE DECLARATION ==============*/
/*============== VARIABLE DECLARATION ==============*/
// Mongo set-up variables
const mongoCollection = process.env.MONGO_COLLECTION || 'eventlog';
const mongoUri = process.env.MONGO_URI || 'mongodb://127.0.0.1:27017/default?replicaSet=rs0';
@@ -10,6 +10,7 @@ const mongoUri = process.env.MONGO_URI || 'mongodb://127.0.0.1:27017/default?rep
// Minio set-up variables
const minioURI = new URL(process.env.MINIO_URI || 'http://kspace-mugshot:2mSI6HdbJ8@127.0.0.1:9000/kspace-mugshot');
const minioBucket = minioURI.pathname.substring(1);
const historyNumber = process.env.HISTORY_AMOUNT || 10;
// Stream set-up variables
let changeStream;
@@ -31,13 +32,13 @@ async function run() {
await mongoClient.connect();
const collection = mongoClient.db().collection(mongoCollection);
let eventArray = [];
// Opening event listener on the database
changeStream = collection.watch(pipeline, options);
console.log("Started watching changes in database");
app.get('/events', async function (request, response) {
let eventArray = [];
let minioClient = new minio.Client({
endPoint: minioURI.hostname,
port: parseInt(minioURI.port) || (minioURI.protocol == 'https' ? 443 : 80),
@@ -46,9 +47,6 @@ async function run() {
secretKey: minioURI.password
});
// notifies GET requests
console.log('/events was requested');
// Setting the header to event-stream for Server Sent Events (Eventsource)
const header = { 'Content-Type': 'text/event-stream', 'Connection': 'keep-alive' };
response.writeHead(200, "OK", header);
@@ -59,15 +57,19 @@ async function run() {
// Retrieves modified document on the db and stores it
let document = JSON.stringify(data.fullDocument);
eventArray = [document, ...eventArray];
eventArray = [document];
// Fetch screenshot if there is one
if (data.fullDocument.screenshot_count) {
minioClient.presignedUrl('GET', minioBucket, `${data.fullDocument.camera}/${data.fullDocument._id}/1.jpg`, 60 * 60, (err, presignedUrl) => {
if (err) { return console.log(err) };
const realURL = JSON.stringify({ picUrl: presignedUrl });
eventArray = [realURL, ...eventArray];
})
for (let i = 1; i <= data.fullDocument.screenshot_count ; i++) {
minioClient.presignedUrl('GET', minioBucket, `${data.fullDocument.camera}/${data.fullDocument._id}/${i}.jpg`, 60 * 60, (err, presignedUrl) => {
if (err) { return console.log(err) };
const realURL = JSON.stringify({ picUrl: presignedUrl });
eventArray = [realURL, ...eventArray];
})
}
};
// sends updated array