You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

88 lines
2.2 KiB

import { Target } from '../types/target';
import { exporterFactory } from '../services/exporter.factory';
import { EXPORTED_PATH } from '../config';
6 years ago
import { Datasource } from '@corpglory/tsdb-kit';
import * as express from 'express';
import * as path from 'path';
import * as fs from 'fs';
6 years ago
type TRequest = {
body: {
from: string,
to: string,
data: Array<{
panelUrl: string,
panelTitle: string,
panelId: number,
datasourceRequest: Datasource,
datasourceName: string,
target: object,
}>,
user: string,
}
};
6 years ago
async function getTasks(req, res) {
res.status(200).send([{
timestamp: 12343567,
user: 'admin',
datasource: 'postgres',
rowsCount: 2345,
progress: 100,
status: 'Success',
}]);
}
async function addTask(req: TRequest, res) {
const body = req.body;
const from = parseInt(body.from);
const to = parseInt(body.to);
const data = body.data;
const user = body.user;
6 years ago
if(isNaN(from) || isNaN(to)) {
res.status(400).send('Range error: please fill both "from" and "to" fields');
6 years ago
} else if(from >= to) {
res.status(400).send('Range error: "from" should be less than "to"');
6 years ago
} else {
const names = data.map(item => item.datasourceName).join(', ');
res.status(200).send(`Exporting ${names} data from ${new Date(from).toLocaleString()} to ${new Date(to).toLocaleString()}`);
const targets = data.map(item => new Target(
item.panelUrl,
item.panelTitle,
item.panelId,
item.datasourceRequest,
[item.target],
item.datasourceName,
));
const exporter = exporterFactory.getExporter();
exporter.export(targets, user, from, to);
6 years ago
}
}
async function deleteTask(req, res) {
let filename = req.query.filename;
let csvFilePath = path.join(EXPORTED_PATH, `${filename}.csv`);
let jsonFilePath = path.join(EXPORTED_PATH, `${filename}.json`);
if(fs.existsSync(csvFilePath)) {
fs.unlink(csvFilePath, err => console.error(err));
}
if(fs.existsSync(jsonFilePath)) {
fs.unlink(jsonFilePath, err => console.error(err));
}
res.status(200).send({ status: 'OK' });
}
6 years ago
export const router = express.Router();
router.get('/', getTasks);
6 years ago
router.post('/', addTask);
router.delete('/', deleteTask);