](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/configs.png){kind=link}
](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/devices-grid.png){kind=link}
](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/devices-table.png){kind=link}
](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/devices-manage.png){kind=link}
](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/schedules.png){kind=link}
](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/settings.png){kind=link}
](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/admin-users.png){kind=link}
](https://raw.githubusercontent.com/versx/DeviceConfigManager/react/.github/images/admin-settings.png){kind=link}
+
+ {crumb.text}
+
+ ) : (
+
+ {crumb.text}
+
+ ))}
+
+
+ );
+};
\ No newline at end of file
diff --git a/src/components/CardDisplay.tsx b/src/components/CardDisplay.tsx
new file mode 100644
index 0000000..808c28c
--- /dev/null
+++ b/src/components/CardDisplay.tsx
@@ -0,0 +1,84 @@
+import React, { ReactElement } from 'react';
+import {
+ Container,
+ Paper,
+ Typography,
+} from '@mui/material';
+import { Theme, useTheme } from '@mui/material/styles';
+
+const useStyles: any = (theme: Theme, height: string = '130px', width: string = '220px') => ({
+ cardContainer: {
+ //border: '1px solid rgb(224, 224, 224)', //#e0e0e0
+ border: '1px solid grey', //#e0e0e0
+ borderRadius: '8px',
+ padding: '16px',
+ display: 'flex',
+ flexDirection: 'column',
+ alignItems: 'stretch',
+ width: width ?? '220px', // fixed width
+ height: height ?? '130px', // fixed height
+ },
+ iconAndTextContainer: {
+ display: 'flex',
+ alignItems: 'center',
+ justifyContent: 'space-between', // This pushes the items to the far ends
+ marginBottom: '8px',
+ },
+ icon: {
+ marginRight: '8px',
+ },
+ value: {
+ alignSelf: 'flex-end',
+ flexGrow: 1, // this will push the value to the bottom of the container
+ display: 'flex',
+ alignItems: 'flex-end',
+ },
+});
+
+export interface CardDisplayProps {
+ text: string;
+ icon: ReactElement;
+ value: string | number;
+ href?: string;
+ valueSize?: number;
+ height?: string;
+ width?: string;
+ elevation?: number;
+};
+
+export const CardDisplay = (props: CardDisplayProps) => {
+ const {
+ text, icon, value, href,
+ valueSize = 20, elevation = 3,
+ height = '120px', width = '220px',
+ } = props;
+ const theme = useTheme();
+ const classes = useStyles(theme, height, width);
+
+ const Card = () => (
+
+ {icon}
+ {text}
+
+ + {config.backendUrl} +
+ {config.dataEndpoints.map((endpoint: string, index: number) => ( + endpoint.split(',').map((e: string, i: number) => ( + {e}
+ )) + ))} +
+
+ onView(config)}
+ >
+
+
+
+ onEdit(config)}
+ >
+
+
+
+ onDelete(config.name)}
+ >
+
+
+
+
+
+ Config: {device.config ?? NotAssigned}
+
+
+ IP Address: {device.ipAddr ?? '--'}
+
+
+
+
+ iOS Version: {device.iosVersion ?? '--'}
+
+
+ IPA Version: {device.ipaVersion ?? '--'}
+
+
+
+
+ Restarts: {restarts.toLocaleString()}
+
+
+ Enabled: {device.enabled ? 'Yes' : 'No'}
+
+
+
+
+ handleDeviceDisplayChange('grid')}
+ style={{backgroundColor: alignment === 'left' ? ActiveMenuItemColor : 'inherit'}}
+ >
+
+ handleDeviceDisplayChange('table')}
+ style={{backgroundColor: alignment === 'right' ? ActiveMenuItemColor : 'inherit'}}
+ >
+
+
+
+
+ +
-
+ {archives?.length > 0 ? archives?.map((archive, index) => (
+
+ {/*
+
+ */}
+
+ {logMessage}
+
+ {/*
*/}
+
+ );
+};
\ No newline at end of file
diff --git a/src/components/Logs/LogViewer.tsx b/src/components/Logs/LogViewer.tsx
new file mode 100644
index 0000000..c44592f
--- /dev/null
+++ b/src/components/Logs/LogViewer.tsx
@@ -0,0 +1,162 @@
+import React, { useCallback, useEffect, useMemo, useState } from 'react';
+import {
+ Button,
+ Container,
+ Paper,
+ TextField,
+ Tooltip,
+} from '@mui/material';
+import { useTheme } from '@mui/material/styles';
+import {
+ ArrowUpward as ArrowUpIcon,
+ ArrowDownward as ArrowDownIcon,
+} from '@mui/icons-material';
+import { enqueueSnackbar } from 'notistack';
+
+import { LogArchiveList, LogDetails, useStyles } from '..';
+import { DefaultLogsReloadInterval } from '../../consts';
+import { LogService } from '../../services';
+import { Log, LogArchive } from '../../types';
+
+interface LogViewerProps {
+ uuid: string;
+ logs: Log[];
+ archives: LogArchive[];
+ onReload: () => void;
+};
+
+interface LogViewerState {
+ key: keyof Log;
+ direction: 'asc' | 'desc';
+};
+
+export const LogViewer = (props: LogViewerProps) => {
+ const { uuid, logs, archives, onReload } = props;
+ const [searchTerm, setSearchTerm] = useState('');
+ const theme = useTheme();
+ const classes = useStyles(theme);
+
+ const [sortConfig, setSortConfig] = useState
+ setSearchTerm(e.target.value)}
+ />
+
+
+
+
+
+
+
+
+
+
+
+ +
+
+ {Title}
+
+ -
+ {navItems.map((item: DropdownItem, index: number) => item.text === 'divider' ? (
+
-
+ {adminItems.map((item: DropdownItem, index: number) => (item.text === 'divider' ? (
+
+
+ {schedule.name}
+
+
+
+
+ Config: {schedule.config}
+
+
+ Next Config: {schedule.nextConfig}
+
+
+ -
+ {schedule.uuids.map((uuid: string, index: number) => (
+
- {uuid} + ))} +
+
+ onEdit(schedule)}>
+
+
+
+ onDelete(schedule.name)}>
+
+
+
+
+ {
+ const newUrls = [...urls];
+ newUrls[index] = e.target.value;
+ setUrls(newUrls);
+ }}
+ />
+ removeUrlField(index)}
+ >
+
+
+ ))}
+ }
+ onClick={addUrlField}
+ >
+ Add URL
+
+
+
+
+
+
+
+
+
+ +
+ + +
+
+ User account registration has been disabled by the administrator.
+
+
+
+ ) : (
+ <>
+
+
+
+ Theme
+
+
+
+
+
+ Change Password
+
+
+
+ -
- ${lastModifiedFormatted}
-
`;
- device.last_seen = utils.getDateTime(device.last_seen * 1000);
- device.buttons = `
-
-
-
-
`;
- device.exclude_reboots = device.exclude_reboots ? 'Yes' : 'No';
- device.enabled = device.enabled ? 'Yes' : 'No';
- const date = utils.convertTz(new Date());
- const today = date.format('YYYY-M-D');
- device.game_restarts_today = await Stats.getAll(device.uuid + '-' + today + '-gamerestarts');
- device.uuid = `${device.uuid}`;
- }
- }
- res.json({
- data: {
- devices: devices
- }
- });
- } catch (e) {
- console.log(e);
- logger('dcm').error(`Devices error: ${e}`);
- }
-});
-
-router.post('/devices/mass_action', async (req, res) => {
- const type = req.body.type;
- let endpoint = '';
- switch (type) {
- case 'screenshot':
- logger('dcm').info('Received screenshot mass action');
- res.send('Received screenshot');
- endpoint = 'screen';
- break;
- case 'restart':
- logger('dcm').info('Received restart mass action');
- res.send('Received restart');
- endpoint = 'restart';
- break;
- case 'restart_config':
- logger('dcm').info('Received restart by config mass action');
- endpoint = 'restart';
- break;
- case 'brightness':
- logger('dcm').info('Received brightness mass action');
- endpoint = 'brightness?value=0';
- break;
- default:
- res.send('Error Occurred');
- }
- if (endpoint !== '') {
- let devices = await Device.getAll();
- if (devices) {
- const config = req.body.config;
- // If config was included then filter devices based on config assigned
- if (config) {
- logger('dcm').info(`Filtering devices based on config ${config}`);
- devices = devices.filter(x => x.config === config);
- }
- devices.forEach((device) => {
- const ip = device.clientip;
- if (ip) {
- const host = `http://${ip}:${device.webserver_port}/${endpoint}`;
- get(device.uuid, host);
- }
- });
- }
- }
-});
-
-router.post('/device/new', async (req, res) => {
- const data = req.body;
- const result = await Device.create(
- data.uuid,
- null,
- data.config || null,
- null,
- data.clientip || null,
- 8080,
- null,
- data.notes || null,
- data.exclude_reboots === 'on',
- data.enabled === 'on'
- );
- if (result) {
- // Success
- }
- logger('dcm').info(`New device result: ${result}`);
- res.redirect('/devices');
-});
-
-router.post('/device/edit/:uuid', async (req, res) => {
- const {
- uuid,
- config,
- clientip,
- notes,
- exclude_reboots,
- enabled
- } = req.body;
- let device = await Device.getByName(uuid);
- if (device) {
- device.config = config || null;
- device.clientip = clientip || null;
- device.notes = notes || null;
- device.excludeReboots = exclude_reboots === 'on';
- device.enabled = enabled === 'on';
- const result = await device.save();
- if (!result) {
- logger('dcm').error(`Failed to update device ${uuid}`);
- return;
- }
- logger('dcm').info(`Device ${uuid} updated`);
- // Success
- }
- res.redirect('/devices');
-});
-
-// Kevin screenshot support
-router.post('/device/:uuid/screen', AuthTokenMiddleware, upload.single('file'), (req, res) => {
- const uuid = req.params.uuid;
- const fileName = uuid + '.png';
- const tempPath = req.file.path;
- const targetPath = path.join(screenshotsDir, fileName);
- if (!fs.existsSync(screenshotsDir)) {
- fs.mkdirSync(screenshotsDir);
- }
- //console.log('File:', req.file);
- //console.log('Temp Path:', tempPath, 'Target Path:', targetPath, 'Original FileName:', req.file.originalname);
- if (path.extname(req.file.originalname).toLowerCase() === '.png' ||
- path.extname(req.file.originalname).toLowerCase() === '.jpg' ||
- path.extname(req.file.originalname).toLowerCase() === '.jpeg') {
- fs.rename(tempPath, targetPath, (err) => {
- if (err) {
- logger('dcm').error(err);
- res.status(500)
- .contentType('text/plain')
- .end('ERROR');
- return;
- }
- res.status(200)
- .contentType('text/plain')
- .end('OK');
- });
- } else {
- fs.unlink(tempPath, (err) => {
- if (err) {
- logger('dcm').error(err);
- }
- res.status(200)
- .contentType('text/plain')
- .end('ERROR');
- });
- }
-});
-
-router.post('/device/screen/:uuid', AuthTokenMiddleware, (req, res) => {
- const uuid = req.params.uuid;
- logger('dcm').info(`Received screen ${uuid}`);
- const data = Buffer.from(req.body.body, 'base64');
- const screenshotFile = path.resolve(__dirname, '../../screenshots/' + uuid + '.png');
- fs.writeFile(screenshotFile, data, (err) => {
- if (err) {
- logger('dcm').error('Failed to save screenshot');
- }
- });
- res.sendStatus(200).end();
-});
-
-router.post('/device/delete/:uuid', async (req, res) => {
- console.log('Encoded:', req.params.uuid);
- const uuid = req.params.uuid;
- console.log('Decoded:', uuid);
- const result = await Device.delete(uuid);
- if (result) {
- // Success
- }
- res.redirect('/devices');
-});
-
-
-// Config API requests
-router.get('/configs', async (req, res) => {
- try {
- let configs = await Config.getAll();
- configs.forEach((config) => {
- config.is_default = config.is_default ? 'Yes' : 'No';
- config.buttons = `
-
-
-
-
- `;
- });
- res.send({
- data: {
- configs: configs
- }
- });
- } catch (e) {
- logger('dcm').error(`Configs error: ${e}`);
- }
-});
-
-router.post('/config', AuthTokenMiddleware, async (req, res) => {
- const { uuid, ios_version, ipa_version, model, webserver_port } = req.body;
- let device = await Device.getByName(uuid);
- let noConfig = false;
- let assignDefault = false;
- // Check for a proxied IP before the normal IP and set the first one that exists
- const clientip = ((req.headers['x-forwarded-for'] || '').split(', ')[0]) || (req.connection.remoteAddress || req.connection.localAddress).match('[0-9]+.[0-9].+[0-9]+.[0-9]+$')[0];
- logger('dcm').info(`Client ${uuid} at ${clientip} is requesting a config.`);
-
- // Check if device config is empty, if not provide it as json response
- if (device) {
- // Device exists
- device.lastSeen = utils.convertTz(new Date()) / 1000;
- // Only update client IP if it hasn't been set yet or if auto sync is enabled while IP doesn't match
- if (device.clientip === null || (device.clientip !== clientip && config.autoSyncIP)) {
- device.clientip = clientip;
- }
- device.iosVersion = ios_version;
- device.ipaVersion = ipa_version;
- device.webserverPort = webserver_port;
- if (device.model === null) {
- device.model = model;
- }
- device.save();
- if (device.config) {
- // Nothing to do besides respond with config
- } else {
- logger('dcm').info(`Device ${uuid} not assigned a config, attempting to assign the default config if one is set...`);
- // Not assigned a config
- assignDefault = true;
- }
- } else {
- logger('dcm').info('Device does not exist, creating...');
- // Device doesn't exist, create db entry
- const ts = utils.convertTz(new Date()) / 1000;
- device = await Device.create(uuid, model, null, ts, clientip, ios_version, ipa_version, webserver_port);
- if (device) {
- // Success, assign default config if there is one.
- assignDefault = true;
- } else {
- // Failed to create device so don't give config response
- noConfig = true;
- }
- }
-
- if (!device.enabled) {
- logger('dcm').error(`Device ${uuid} not enabled!`);
- res.json({
- status: 'error',
- error: 'Device not enabled!'
- });
- return;
- }
-
- if (assignDefault) {
- const defaultConfig = await Config.getDefault();
- if (defaultConfig !== null) {
- logger('dcm').info(`Assigning device ${uuid} default config ${defaultConfig.name}`);
- device.config = defaultConfig.name;
- device.save();
- } else {
- // No default config so don't give config response
- noConfig = true;
- }
- }
-
- if (noConfig) {
- logger('dcm').error(`No config assigned to device ${uuid} and no default config to assign!`);
- res.json({
- status: 'error',
- error: 'Device not assigned to config!'
- });
- return;
- }
-
- const c = await Config.getByName(device.config);
- if (c === null) {
- logger('dcm').error(`Failed to grab config ${device.config}`);
- res.json({
- status: 'error',
- error: 'Device not assigned to config!'
- });
- return;
- }
-
- // Build json config
- const json = utils.buildConfig(
- // TODO: Use spread operator and pass in just one object
- c.provider,
- c.backendUrl,
- c.dataEndpoints,
- c.token,
- device.webserverPort,
- c.heartbeatMaxTime,
- c.minDelayLogout,
- c.loggingUrl,
- c.loggingPort,
- c.accountManager,
- c.deployEggs,
- c.nearbyTracker,
- c.autoLogin,
- c.isDefault
- );
- logger('dcm').info(`${uuid} config response: ${json}`);
- res.send(json);
-});
-
-router.post('/config/new', async (req, res) => {
- const data = req.body;
- const cfg = await Config.create(
- data.name,
- data.provider,
- data.backend_url,
- data.data_endpoints,
- data.token,
- data.heartbeat_max_time,
- data.min_delay_logout,
- data.logging_url,
- data.logging_port,
- data.account_manager === 'on' ? 1 : 0,
- data.deploy_eggs === 'on' ? 1 : 0,
- data.nearby_tracker === 'on' ? 1 : 0,
- data.auto_login === 'on' ? 1 : 0,
- data.is_default === 'on' ? 1 : 0
- );
- if (cfg) {
- logger('dcm').info('Config inserted');
- if (cfg.isDefault) {
- logger('dcm').info(`Setting default config: ${data.name}`);
- await Config.setDefault(data.name);
- }
- } else {
- logger('dcm').error('Failed to create new config');
- }
- res.redirect('/configs');
-});
-
-router.post('/config/edit/:name', async (req, res) => {
- const oldName = req.params.name;
- const data = req.body;
- const c = await Config.getByName(oldName);
- c.name = data.name;
- c.provider = data.provider;
- c.backendUrl = data.backend_url;
- c.dataEndpoints = data.data_endpoints;
- c.token = data.token;
- c.heartbeatMaxTime = data.heartbeat_max_time;
- c.minDelayLogout = data.min_delay_logout;
- c.loggingUrl = data.logging_url;
- c.loggingPort = data.logging_port;
- c.accountManager = data.account_manager === 'on' ? 1 : 0;
- c.deployEggs = data.deploy_eggs === 'on' ? 1 : 0;
- c.nearbyTracker = data.nearby_tracker === 'on' ? 1 : 0;
- c.autoLogin = data.auto_login === 'on' ? 1 : 0;
- c.isDefault = data.is_default === 'on' ? 1 : 0;
- if (await c.save(oldName)) {
- logger('dcm').info('Config saved');
- // Success
- if (c.isDefault) {
- logger('dcm').info(`Setting default config: ${c.name}`);
- await Config.setDefault(c.name);
- }
- }
- res.redirect('/configs');
-});
-
-router.post('/config/delete/:name', async (req, res) => {
- const name = req.params.name;
- const result = await Config.delete(name);
- if (result) {
- // Success
- }
- res.redirect('/configs');
-});
-
-
-// Schedule API requests
-router.get('/schedules', async (req, res) => {
- let schedules = ScheduleManager.getAll();
- const list = Object.values(schedules);
- if (list) {
- list.forEach((schedule) => {
- schedule.uuids = (schedule.uuids || []).join(',');
- schedule.buttons = `
- `;
- schedule.enabled ? 'Yes' : 'No'; // TODO: Fix yes/no doesn't get set
- });
- }
- res.json({ data: { schedules: list } });
-});
-
-router.post('/schedule/new', (req, res) => {
- const data = req.body;
- const result = ScheduleManager.create(
- data.name,
- data.config,
- data.devices,
- data.start_time,
- data.end_time,
- data.timezone,
- data.next_config,
- data.enabled === 'on' ? 1 : 0
- );
- if (result) {
- logger('dcm').info('Schedule inserted');
- } else {
- logger('dcm').error('Failed to create new schedule');
- }
- res.redirect('/schedules');
-});
-
-router.post('/schedule/edit/:name', (req, res) => {
- const data = req.body;
- const oldName = req.params.name;
- const result = ScheduleManager.update(
- oldName,
- data.name,
- data.config,
- data.devices,
- data.start_time,
- data.end_time,
- data.timezone,
- data.next_config,
- data.enabled === 'on' ? 1 : 0
- );
- if (result) {
- logger('dcm').info('Schedule', data.name, 'updated');
- } else {
- logger('dcm').error(`Failed to update schedule ${oldName}`);
- }
- res.redirect('/schedules');
-});
-
-router.post('/schedule/delete/:name', (req, res) => {
- const name = req.params.name;
- const result = ScheduleManager.delete(name);
- if (result) {
- // Success
- logger('dcm').info(`Schedule ${name} deleted`);
- }
- res.redirect('/schedules');
-});
-
-router.get('/schedule/delete_all', (req, res) => {
- const result = ScheduleManager.deleteAll();
- if (result) {
- // Success
- logger('dcm').info('All schedules deleted');
- }
- res.redirect('/schedules');
-});
-
-
-router.get('/stats/delete_all', (req, res) => {
- const result = Stats.deleteAll();
- if (result) {
- // Success
- }
- res.redirect('/utilities');
-});
-
-// Logging API requests
-router.get('/logs/delete_all', (req, res) => {
- const result = Log.deleteAll();
- if (result) {
- // Success
- }
- res.redirect('/utilities');
-});
-
-router.get('/logs/:uuid', async (req, res) => {
- const uuid = req.params.uuid;
- const logs = uuid === 'all' ?
- await Log.getAll() :
- await Log.getByDevice(uuid);
- res.send({
- data: {
- logs: logs || []
- }
- });
-});
-
-router.post('/log/new', AuthTokenMiddleware, async (req, res) => {
- if (!config.logging.enabled) {
- // Logs are disabled
- res.send('OK');
- return;
- }
-
- // REVIEW: Update device last_seen?
- const { uuid, messages } = req.body;
- if (messages) {
- for (let i = messages.length - 1; i >= 0; i--) {
- logger(uuid).info(messages[i]);
- if (messages[i].includes('Initializing')) {
- const date = utils.convertTz(new Date());
- const today = date.format('YYYY-M-D');
- const result = await Stats.counter(uuid + '-' + today + '-gamerestarts');
- if (result) {
- // Success
- }
- //console.log('[RESTART]', messages[i]);
- }
- //console.log('[SYSLOG]', messages[i]);
- }
- }
- res.send('OK');
-});
-
-router.get('/log/delete/:uuid', async (req, res) => {
- const uuid = req.params.uuid;
- const result = await Log.delete(uuid);
- if (result) {
- // Success
- }
- res.redirect('/device/logs/' + uuid);
-});
-
-router.get('/log/export/:uuid', async (req, res) => {
- const uuid = req.params.uuid;
- let logText = '';
- const logs = await Log.getByDevice(uuid);
- if (logs) {
- logs.forEach((log) => {
- logText += `${log.timestamp} ${log.uuid} ${log.message}\n`;
- });
- }
- res.send(logText);
-});
-
-
-router.get('/utilities/clear_device_ips', async (req, res) => {
- const result = await Device.clearIPAddresses();
- if (result) {
- // Success
- }
- res.redirect('/utilities');
-});
-
-const get = async (uuid, url) => {
- const isScreen = url.includes('/screen');
- const isBrightness = url.includes('/brightness');
- if (isScreen) {
- const screenshotFile = path.resolve(__dirname, '../../screenshots/' + uuid + '.png');
- const fileStream = fs.createWriteStream(screenshotFile);
- request
- .get(url)
- .on('error', (err) => {
- logger('dcm').error(`Failed to get screenshot for ${uuid} at ${url}. Are you sure the device is up? ${err.code}`);
- })
- .pipe(fileStream);
- } else if (isBrightness) {
- request.post(url, (err) => {
- if (err) {
- logger('dcm').error(`Error: ${err}`);
- }
- }).on('error', (err) => {
- logger('dcm').error(`Error occurred: ${err}`);
- });
- } else {
- request.get(url, (err) => {
- if (err) {
- logger('dcm').error(`Error: ${err}`);
- }
- }).on('error', (err) => {
- logger('dcm').error(`Error occurred: ${err}`);
- });
- }
-};
-
-module.exports = router;
diff --git a/src/routes/ui.js b/src/routes/ui.js
deleted file mode 100644
index 353e67a..0000000
--- a/src/routes/ui.js
+++ /dev/null
@@ -1,312 +0,0 @@
-'use strict';
-
-const express = require('express');
-const router = express.Router();
-
-const config = require('../config.json');
-const defaultData = require('../data/default.js');
-const Config = require('../models/config.js');
-const Device = require('../models/device.js');
-const Stats = require('../models/stats.js');
-const Log = require('../models/log.js');
-const ScheduleManager = require('../models/schedule-manager.js');
-const logger = require('../services/logger.js');
-const Migrator = require('../services/migrator.js');
-const utils = require('../services/utils.js');
-
-const timezones = require('../../static/data/timezones.json');
-
-const providers = [
- { name: 'GoCheats' },
- { name: 'Kevin' },
- { name: 'AI' }
-];
-
-// UI Routes
-router.get(['/', '/index'], async (req, res) => {
- if (req.session.loggedin) {
- const username = req.session.username;
- const devices = await Device.getAll();
- const configs = await Config.getAll();
- const schedules = ScheduleManager.getAll();
- const metadata = await Migrator.getEntries();
- const logsSize = await Log.getTotalSize();
- const delta = 15 * 60;
- const data = defaultData;
- data.logged_in = true; // TODO: Workaround
- data.metadata = metadata;
- data.devices = devices.length;
- data.configs = configs.length;
- data.schedules = Object.keys(schedules).length;
- data.username = username;
- data.devices_offline = devices.filter(x => x.last_seen < (Math.round(utils.convertTz(new Date()).format('x') / 1000) - delta));
- data.devices_offline.forEach((device) => {
- device.last_seen = utils.getDateTime(device.last_seen * 1000);
- device.buttons = ``; // TODO: Localize
- device.uuid = `${device.uuid}`;
- });
- data.devices_online_count = devices.filter(x => x.last_seen >= (Math.round(utils.convertTz(new Date()).format('x') / 1000) - delta)).length;
- data.devices_offline_count = data.devices_offline.length;
- const date = utils.convertTz(new Date());
- const today = date.format('YYYY-M-D');
- data.game_restarts_today = await Stats.getAll(today + '-gamerestarts');
- data.logs_size = utils.formatBytes(logsSize);
- data.listeners = config.listeners;
- data.version = require('../../package.json').version;
- res.render('index', data);
- }
-});
-
-router.get('/register', async (req, res) => {
- if (await Migrator.getValueForKey('SETUP')) {
- res.redirect('/');
- return;
- }
- res.render('register', defaultData);
-});
-
-router.get('/login', (req, res) => {
- const data = defaultData;
- data.logged_in = false;
- data.username = null;
- res.render('login', data);
-});
-
-router.get('/logout', (req, res) => {
- req.session.destroy((err) => {
- if (err) throw err;
- res.redirect('/login');
- });
-});
-
-router.get('/account', (req, res) => {
- const data = defaultData;
- data.username = req.session.username;
- res.render('account', data);
-});
-
-// Device UI Routes
-router.get('/devices', (req, res) => {
- res.render('devices', defaultData);
-});
-
-router.get('/device/new', async (req, res) => {
- const data = defaultData;
- data.configs = await Config.getAll();
- res.render('device-new', defaultData);
-});
-
-router.get('/device/edit/:uuid', async (req, res) => {
- const uuid = decodeURIComponent(req.params.uuid);
- const data = defaultData;
- const configs = await Config.getAll();
- const device = await Device.getByName(uuid);
- if (device.config) {
- configs.forEach((config) => {
- config.selected = config.name === device.config;
- });
- } else {
- data.nothing_selected = true;
- }
- data.configs = configs;
- data.uuid = device.uuid;
- data.model = device.model;
- data.old_uuid = device.uuid;
- data.config = device.config;
- data.clientip = device.clientip;
- data.webserver_port = device.webserverPort;
- data.notes = device.notes;
- data.exclude_reboots = device.excludeReboots ? 'checked' : '';
- data.enabled = device.enabled ? 'checked' : '';
- res.render('device-edit', data);
-});
-
-router.get('/device/logs/:uuid', async (req, res) => {
- const uuid = req.params.uuid;
- const data = defaultData;
- data.uuid = uuid;
- res.render('device-logs', data);
-});
-
-router.get('/device/delete/:uuid', async (req, res) => {
- const data = defaultData;
- data.uuid = decodeURIComponent(req.params.uuid);
- res.render('device-delete', data);
-});
-
-router.get('/device/manage/:uuid', async (req, res) => {
- const uuid = req.params.uuid;
- const device = await Device.getByName(uuid);
- const data = defaultData;
- data.name = uuid;
- data.listeners = config.listeners;
- if (device) {
- if (device.clientip) {
- data.clientip = device.clientip;
- } else {
- logger('dcm').error(`Failed to get IP address for device ${uuid}`);
- }
- data.webserver_port = device.webserverPort;
- data.exclude_reboots = device.excludeReboots;
- const config = await Config.getByName(device.config);
- data.providers = providers;
- data.kevin_selected = config.provider === data.providers[1].name;
- }
- res.render('device-manage', data);
-});
-
-// Config UI Routes
-router.get('/configs', (req, res) => {
- res.render('configs', defaultData);
-});
-
-router.get('/config/new', (req, res) => {
- const data = defaultData;
- data.providers = providers;
- res.render('config-new', data);
-});
-
-router.get('/config/edit/:name', async (req, res) => {
- const name = req.params.name;
- const c = await Config.getByName(name);
- const data = defaultData;
- data.title = config.title;
- data.old_name = name;
- data.name = c.name;
- data.providers = providers;
- data.providers.forEach((provider) => {
- provider.selected = provider.name === c.provider;
- });
- // TODO: Better way
- data.gocheats_selected = c.provider === data.providers[0].name;
- data.kevin_selected = c.provider === data.providers[1].name;
- data.ai_selected = c.provider === data.providers[2].name;
- data.backend_url = c.backendUrl;
- data.data_endpoints = c.dataEndpoints;
- data.token = c.token;
- data.heartbeat_max_time = c.heartbeatMaxTime;
- data.min_delay_logout = c.minDelayLogout;
- data.logging_url = c.loggingUrl;
- data.logging_port = c.loggingPort;
- data.account_manager = c.accountManager === 1 ? 'checked' : '';
- data.deploy_eggs = c.deployEggs === 1 ? 'checked' : '';
- data.nearby_tracker = c.nearbyTracker === 1 ? 'checked' : '';
- data.auto_login = c.autoLogin === 1 ? 'checked' : '';
- data.is_default = c.isDefault === 1 ? 'checked' : '';
- res.render('config-edit', data);
-});
-
-router.get('/config/delete/:name', (req, res) => {
- const data = defaultData;
- data.name = req.params.name;
- res.render('config-delete', data);
-});
-
-// Schedule UI Routes
-router.get('/schedules', (req, res) => {
- res.render('schedules', defaultData);
-});
-
-router.get('/schedule/new', async (req, res) => {
- const data = defaultData;
- const configs = await Config.getAll();
- const devices = await Device.getAll();
- data.configs = configs;
- data.devices = devices;
- data.timezones = timezones;
- res.render('schedule-new', data);
-});
-
-router.get('/schedule/edit/:name', async (req, res) => {
- const name = req.params.name;
- const data = defaultData;
- const configs = await Config.getAll();
- const devices = await Device.getAll();
- const schedule = ScheduleManager.getByName(name);
- if (configs) {
- configs.forEach((cfg) => {
- cfg.selected = cfg.name === schedule.config;
- cfg.next_config_selected = cfg.name === schedule.next_config;
- });
- }
- if (devices) {
- devices.forEach((device) => {
- device.selected = schedule.uuids.includes(device.uuid);
- });
- }
- data.old_name = name;
- data.name = schedule.name;
- data.configs = configs;
- data.devices = devices;
- data.start_time = schedule.start_time;
- data.end_time = schedule.end_time;
- data.timezone = schedule.timezone;
- data.next_config = schedule.next_config;
- data.enabled = schedule.enabled === 1 ? 'checked' : '';
- timezones.forEach((timezone) => {
- timezone.selected = timezone.value === schedule.timezone;
- });
- data.timezones = timezones;
- res.render('schedule-edit', data);
-});
-
-router.get('/schedule/delete/:name', (req, res) => {
- const data = defaultData;
- data.name = req.params.name;
- res.render('schedule-delete', data);
-});
-
-router.get('/logs', (req, res) => {
- const data = defaultData;
- data.uuid = 'all';
- res.render('logs', data);
-});
-
-// Settings UI Routes
-router.get('/settings', (req, res) => {
- const data = defaultData;
- data.title = config.title;
- data.host = config.db.host;
- data.port = config.db.port;
- data.db_username = config.db.username;
- data.db_password = config.db.password;
- data.database = config.db.database;
- data.charset = config.db.charset;
- data.styles = [
- { 'name': 'dark' },
- { 'name': 'light' }
- ];
- data.styles.forEach((style) => {
- style.selected = style.name === config.style;
- });
- data.languages = [
- { 'name': 'en' },
- { 'name': 'es' },
- { 'name': 'de' }
- ];
- data.languages.forEach((locale) => {
- locale.selected = locale.name === config.locale;
- });
- data.timezone = config.timezone || 'America/Denver';
- data.listeners = (config.listeners || '').join(',');
- data.monitor_enabled = config.monitor.enabled ? 'checked' : '';
- data.monitor_interval = config.monitor.interval;
- data.monitor_threshold = config.monitor.threshold;
- data.monitor_webhooks = (config.monitor.webhooks || '').join(',');
- data.monitor_reboot = config.monitor.reboot ? 'checked' : '';
- data.monitor_max_reboot_count = config.monitor.maxRebootCount;
- data.logging = config.logging.enabled ? 'checked' : '';
- data.max_size = config.logging.max_size;
- data.log_format = config.logging.format || 'YYYY-MM-DD hh:mm:ss A';
- res.render('settings', data);
-});
-
-router.get('/utilities', (req, res) => {
- res.render('utilities', defaultData);
-});
-
-router.get('/dcm-logs', (req, res) => {
- res.render('dcm-logs', defaultData);
-});
-
-module.exports = router;
diff --git a/src/services/AuthService.ts b/src/services/AuthService.ts
new file mode 100644
index 0000000..9c01452
--- /dev/null
+++ b/src/services/AuthService.ts
@@ -0,0 +1,38 @@
+import { Routes } from '../consts';
+import { http } from '../modules';
+import { setUserToken } from '../stores';
+
+const register = async (username: string, password: string) => {
+ const response = await http()
+ .post('auth/register', {
+ username,
+ password,
+ });
+ return response.data;
+};
+
+const login = async (username: string, password: string) => {
+ const response = await http()
+ .post('auth/login', {
+ username,
+ password,
+ });
+
+ const data = response.data;
+ const user = data?.user;
+ if (user) {
+ setUserToken(user);
+ }
+ return data;
+};
+
+const logout = () => {
+ localStorage.clear();
+ window.location.href = Routes.login;
+};
+
+export const AuthService = {
+ register,
+ login,
+ logout,
+};
\ No newline at end of file
diff --git a/src/services/ConfigService.ts b/src/services/ConfigService.ts
new file mode 100644
index 0000000..a65177b
--- /dev/null
+++ b/src/services/ConfigService.ts
@@ -0,0 +1,60 @@
+import { http } from '../modules';
+import { Config } from '../types';
+
+const getConfigs = async () => {
+ try {
+ const response = await http()
+ .get('configs');
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const createConfig = async (payload: Config) => {
+ try {
+ const response = await http()
+ .post(`configs`, { config: payload });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const updateConfig = async (name: string, payload: Config) => {
+ try {
+ const response = await http()
+ .put(`configs?name=${name}`, { config: payload });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const deleteConfig = async (name: string) => {
+ try {
+ const response = await http()
+ .delete(`configs?name=${name}`);
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const setDefaultConfig = async (name: string) => {
+ try {
+ const response = await http()
+ .put(`configs/default?name=${name}`);
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+export const ConfigService = {
+ getConfigs,
+ createConfig,
+ updateConfig,
+ deleteConfig,
+ setDefaultConfig,
+};
\ No newline at end of file
diff --git a/src/services/DeviceService.ts b/src/services/DeviceService.ts
new file mode 100644
index 0000000..56a4ba3
--- /dev/null
+++ b/src/services/DeviceService.ts
@@ -0,0 +1,130 @@
+import { Base64ImageHeader } from '../consts';
+import { http } from '../modules';
+import { Device } from '../types';
+
+const assignConfig = async (deviceUuid: string, configName: string | null) => {
+ try {
+ const response = await http()
+ .post('devices/assign', { deviceUuid, configName });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const getDevices = async () => {
+ try {
+ const response = await http()
+ .get('devices');
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const createDevice = async (payload: Device) => {
+ try {
+ const response = await http()
+ .post(`devices`, { device: payload });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const updateDevice = async (uuid: string, payload: Device) => {
+ try {
+ const response = await http()
+ .put(`devices?uuid=${uuid}`, { device: payload });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const deleteDevice = async (uuid: string) => {
+ try {
+ const response = await http()
+ .delete(`devices?uuid=${uuid}`);
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const getDeviceStats = async (uuid: string, date?: string) => {
+ try {
+ const response = await http()
+ .get(`devices/stats?uuid=${uuid}&date=${date}`);
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const sendDeviceRequest = async (ipAddr: string, port: number = 8080, actionType: string) => {
+ try {
+ const url = `http://${ipAddr}:${port}/${actionType}`;
+ const response = await fetch(url, {
+ method: 'GET',
+ headers: {
+ 'Content-Type': 'text/plain; charset=x-user-defined',
+ },
+ });
+
+ let responseData: string = '';
+ switch (actionType) {
+ case 'screen':
+ const arrayBuffer = await response.arrayBuffer();
+ if (arrayBuffer.byteLength <= 0) {
+ return { error: false, data: Base64ImageHeader };
+ }
+
+ const base64 = Base64ImageHeader + Buffer.from(arrayBuffer).toString('base64');
+ // TODO: Send screenshot to backend to save
+ return { error: false, data: base64 };
+ case 'restart':
+ responseData = await response.text();
+ break;
+ default:
+ responseData = await response.json();
+ break;
+ }
+ return { error: false, data: responseData };
+ } catch (err: any) {
+ return { error: true, message: err.message };
+ }
+};
+
+const sendAgentRequest = async (payload: any, remoteAgentUrls: string[]) => {
+ if (remoteAgentUrls.length === 0) {
+ return;
+ }
+
+ try {
+ for (const remoteAgentUrl of remoteAgentUrls) {
+ const response = await fetch(remoteAgentUrl, {
+ method: 'POST',
+ body: JSON.stringify(payload),
+ headers: {
+ 'Content-Type': 'application/json',
+ },
+ });
+ console.log('response', response);
+ }
+ } catch (err: any) {
+ console.error(err);
+ }
+};
+
+export const DeviceService = {
+ assignConfig,
+ getDevices,
+ createDevice,
+ updateDevice,
+ deleteDevice,
+ getDeviceStats,
+
+ sendDeviceRequest,
+ sendAgentRequest,
+};
\ No newline at end of file
diff --git a/src/services/LogService.ts b/src/services/LogService.ts
new file mode 100644
index 0000000..a900f09
--- /dev/null
+++ b/src/services/LogService.ts
@@ -0,0 +1,26 @@
+import { http } from "../modules";
+
+const getLogs = async (uuid: string) => {
+ try {
+ const response = await http()
+ .get(`logs?uuid=${uuid}`);
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const deleteLogs = async (uuid: string, archive: string) => {
+ try {
+ const response = await http()
+ .delete(`logs?uuid=${uuid}&archive=${archive}`);
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+export const LogService = {
+ getLogs,
+ deleteLogs,
+};
\ No newline at end of file
diff --git a/src/services/ScheduleService.ts b/src/services/ScheduleService.ts
new file mode 100644
index 0000000..247ca65
--- /dev/null
+++ b/src/services/ScheduleService.ts
@@ -0,0 +1,49 @@
+import { http } from '../modules';
+import { Schedule } from '../types';
+
+const getSchedules = async () => {
+ try {
+ const response = await http()
+ .get('schedules');
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const createSchedule = async (payload: Schedule) => {
+ try {
+ const response = await http()
+ .post(`schedules`, { schedule: payload });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const updateSchedule = async (name: string, payload: Schedule) => {
+ try {
+ const response = await http()
+ .put(`schedules?name=${name}`, { schedule: payload });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const deleteSchedule = async (name: string) => {
+ try {
+ const response = await http()
+ .delete(`schedules?name=${name}`);
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+export const ScheduleService = {
+ getSchedules,
+ createSchedule,
+ updateSchedule,
+ deleteSchedule,
+};
\ No newline at end of file
diff --git a/src/services/SettingsService.ts b/src/services/SettingsService.ts
new file mode 100644
index 0000000..3fec571
--- /dev/null
+++ b/src/services/SettingsService.ts
@@ -0,0 +1,27 @@
+import { http } from '../modules';
+import { Setting } from '../types';
+
+const getSettings = async () => {
+ try {
+ const response = await http()
+ .get('settings');
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+const setSettings = async (settings: Setting[]) => {
+ try {
+ const response = await http()
+ .put('settings', { settings });
+ return response.data;
+ } catch (err) {
+ console.error(err);
+ }
+};
+
+export const SettingsService = {
+ getSettings,
+ setSettings,
+};
\ No newline at end of file
diff --git a/src/services/UserService.ts b/src/services/UserService.ts
new file mode 100644
index 0000000..f5ee241
--- /dev/null
+++ b/src/services/UserService.ts
@@ -0,0 +1,40 @@
+import { http } from '../modules';
+import { User } from '../types';
+
+const getUsers = async () => {
+ const response = await http()
+ .get('users');
+ return response.data;
+};
+
+const createAccount = async (user: User) => {
+ const response = await http()
+ .post('users', user);
+ return response.data;
+};
+
+const updateAccount = async (userId: number, user: User) => {
+ const response = await http()
+ .put(`users?userId=${userId}`, user);
+ return response.data;
+};
+
+const changePassword = async (userId: number, oldPassword: string, newPassword: string) => {
+ const response = await http()
+ .post(`users/${userId}/password/reset`, { oldPassword, newPassword });
+ return response.data;
+};
+
+const deleteAccount = async (userId: number) => {
+ const response = await http()
+ .delete(`users?userId=${userId}`);
+ return response.data;
+};
+
+export const UserService = {
+ getUsers,
+ createAccount,
+ updateAccount,
+ changePassword,
+ deleteAccount,
+};
\ No newline at end of file
diff --git a/src/services/db.js b/src/services/db.js
deleted file mode 100644
index 78378ff..0000000
--- a/src/services/db.js
+++ /dev/null
@@ -1,57 +0,0 @@
-'use strict';
-
-const mysql = require('mysql');
-const logger = require('./logger.js');
-const config = require('../config.json');
-
-const getConnection = () => {
- const conn = mysql.createConnection({
- host: config.db.host,
- port: config.db.port,
- user: config.db.username,
- password: config.db.password,
- database: config.db.database,
- charset: config.db.charset
- });
-
- conn.connect((err) => {
- if (err) {
- console.error('Failed to connect to the database:', config.db);
- logger('dcm').info('Error connecting to database');
- return;
- }
- });
-
- conn.on('error', (err) => {
- console.error(`Mysql error: ${err}`);
- logger('dcm').error(`Mysql error: ${err}`);
- });
- return conn;
-};
-
-const query = async (sql, args) => {
- return new Promise((resolve, reject) => {
- // The Promise constructor should catch any errors thrown on
- // this tick. Alternately, try/catch and reject(err) on catch.
- const conn = getConnection();
- /* eslint-disable no-unused-vars */
- conn.query(sql, args, (err, rows, fields) => {
- /* eslint-enable no-unused-vars */
- // Call reject on error states,
- // call resolve with results
- if (err) {
- return reject(err);
- }
- resolve(rows);
- conn.end((err, args) => {
- if (err) {
- console.error(`Failed to close mysql connection: ${args}`);
- logger('dcm').error(`Failed to close mysql connection: ${args}`);
- return;
- }
- });
- });
- });
-};
-
-module.exports = query;
\ No newline at end of file
diff --git a/src/services/device-monitor.js b/src/services/device-monitor.js
deleted file mode 100644
index 2ede6a0..0000000
--- a/src/services/device-monitor.js
+++ /dev/null
@@ -1,104 +0,0 @@
-'use strict';
-
-const request = require('request');
-
-const logger = require('./logger.js');
-const config = require('../config.json');
-const Device = require('../models/device.js');
-const { DiscordMessage, DiscordEmbed, DiscordColors } = require('../models/discord.js');
-const utils = require('./utils.js');
-const devicesCheckInterval = (config.monitor.interval || 5) * 60 * 1000; // Check every 5 minutes
-const delta = (config.monitor.threshold || 15) * 60; // Amount of time in seconds before rendered offline
-const maxRebootCount = config.monitor.maxRebootCount || 10;
-const devicesRebooted = {};
-const deviceWebhooksSent = {};
-
-const start = () => {
- // Only start the device monitor if it's enabled in the config
- if (config.monitor.enabled) {
- logger('dcm').info(`Enabling device monitor every ${devicesCheckInterval / 1000} seconds`);
- setInterval(checkDevices, devicesCheckInterval);
- }
-};
-
-const checkDevices = async () => {
- const devices = await Device.getAll();
- if (!(devices && devices.length > 0)) {
- return;
- }
-
- for (let i = 0; i < devices.length; i++) {
- const device = devices[i];
- const isOffline = device.last_seen > (Math.round(utils.convertTz(new Date()).format('x') / 1000) - delta) ? 0 : 1;
- if (!isOffline || !device.enabled || device.exclude_reboots) {
- continue;
- }
-
- // If restart for device monitor is enabled, automatically send restart device command if offline.
- if (config.monitor.reboot && config.listeners.length > 0) {
- const listeners = config.listeners;
- for (let i = 0; i < listeners.length; i++) {
- if (devicesRebooted[device.uuid] && devicesRebooted[device.uuid] > maxRebootCount) {
- // Skip rebooting devices we've already rebooted passed the maximum count
- continue;
- }
- const url = listeners[i];
- const options = {
- url: url,
- json: true,
- method: 'POST',
- body: { 'type': 'restart', 'device': device.uuid },
- headers: { 'Accept': 'application/json', 'Content-Type': 'application/json' },
- };
- logger('dcm').info(`Sending reboot request for ${device.uuid} to remote listener at ${url}`);
- /* eslint-disable no-unused-vars */
- request(options, (err, res, body) => {
- /* eslint-enable no-unused-vars */
- if (err) {
- logger('dcm').error(`Failed to send restart command to remote listener ${url}`);
- } else {
- logger('dcm').info(`Sent restart command for ${device.uuid} to remote listener ${url}`);
- }
- });
- if (devicesRebooted[device.uuid]) {
- devicesRebooted[device.uuid]++;
- } else {
- devicesRebooted[device.uuid] = 1;
- }
- }
- }
-
- if (config.monitor.webhooks.length === 0) {
- return;
- }
-
- sendOfflineMessage(device);
- }
-
- await utils.snooze(5000);
-};
-
-const sendOfflineMessage = (device) => {
- const webhooks = config.monitor.webhooks;
- const payload = createPayload(device);
- for (let i = 0; i < webhooks.length; i++) {
- const webhook = webhooks[i];
- sendWebhook(webhook, payload);
- }
- deviceWebhooksSent[device.uuid] = new Date();
-};
-
-const sendWebhook = (url, payload) => {
- utils.postRequest(url, payload);
-};
-
-const createPayload = (device) => {
- const time = delta / 60;
- const date = utils.convertTz(new Date()).format(config.logging.format);
- const message = `[${date}] Device **${device.uuid}** has not requested config **${device.config}** in over **${time}** minutes`;
- const embed = DiscordEmbed.createAdvancedEmbed(null, message, null, null, DiscordColors.Red);
- const discordMessage = new DiscordMessage(null, config.title || 'DeviceConfigManager', null, [embed]);
- return discordMessage;
-};
-
-module.exports = { start, sendOfflineMessage };
diff --git a/src/services/index.ts b/src/services/index.ts
new file mode 100644
index 0000000..5b55780
--- /dev/null
+++ b/src/services/index.ts
@@ -0,0 +1,7 @@
+export * from './AuthService';
+export * from './ConfigService';
+export * from './DeviceService';
+export * from './LogService';
+export * from './ScheduleService';
+export * from './SettingsService';
+export * from './UserService';
\ No newline at end of file
diff --git a/src/services/logger.js b/src/services/logger.js
deleted file mode 100644
index 2102f93..0000000
--- a/src/services/logger.js
+++ /dev/null
@@ -1,52 +0,0 @@
-'use strict';
-
-const pino = require('pino');
-const path = require('path');
-const logrotate = require('logrotator');
-const config = require('../config.json');
-const logsDir = path.resolve(__dirname, '../../logs');
-
-// Global log rotator
-const rotator = logrotate.rotator;
-const loggers = {};
-
-const getLogger = (name) => {
- // Logger with name was already created, no need to create another.
- if (loggers[name]) {
- return loggers[name];
- }
-
- const logFilePath = path.resolve(logsDir, name + '.log');
- const logger = pino(pino.destination({
- dest: logFilePath,
- //minLength: 4096, // Buffer before writing
- sync: false,
- formatters: {
- /* eslint-disable no-unused-vars */
- level: (label, number) => {
- /* eslint-enable no-unused-vars */
- return { level: label };
- }
- }
- }));
-
- // Check file rotation every 5 minutes, and rotate the file if its size exceeds max log size in mb, keep only 3 rotated files
- rotator.register(logFilePath, {
- schedule: '5m',
- size: config.logging.max_size + 'm',
- compress: false,
- count: 3
- });
- rotator.on('error', (err) => {
- console.log('Log rotate error:', err);
- });
- // 'rotate' event is invoked whenever a registered file gets rotated
- rotator.on('rotate', (file) => {
- console.log('Log file rotated:', file);
- });
-
- loggers[name] = logger;
- return logger;
-};
-
-module.exports = getLogger;
\ No newline at end of file
diff --git a/src/services/migrator.js b/src/services/migrator.js
deleted file mode 100644
index 07191e1..0000000
--- a/src/services/migrator.js
+++ /dev/null
@@ -1,270 +0,0 @@
-'use strict';
-
-const path = require('path');
-const fs = require('fs');
-const query = require('./db.js');
-const logger = require('./logger.js');
-const utils = require('./utils.js');
-
-const migrationsDir = path.resolve(__dirname, '../../migrations');
-
-class Migrator {
- constructor() {
- this.done = false;
- }
- async load() {
- let count = 1;
- let done = false;
- while (!done) {
- if (query === undefined || query === null) {
- logger('dcm').error(`[DBController] Failed to connect to database (as root) while initializing. Try: ${count}/10`);
- if (count === 10) {
- process.exit(-1);
- }
- count++;
- await utils.snooze(2500);
- continue;
- }
- done = true;
- }
-
- let version = 0;
- const createMetadataTableSQL = `
- CREATE TABLE IF NOT EXISTS metadata (
- \`key\` VARCHAR(50) PRIMARY KEY NOT NULL,
- \`value\` VARCHAR(50) DEFAULT NULL
- );`;
- await query(createMetadataTableSQL)
- .then(x => x)
- .catch(err => {
- logger('dcm').error(`[DBController] Failed to create metadata table: (${err})`);
- process.exit(-1);
- });
-
- const getDBVersionSQL = `
- SELECT \`value\`
- FROM metadata
- WHERE \`key\` = "DB_VERSION"
- LIMIT 1;`;
- const results = await query(getDBVersionSQL)
- .then(x => x)
- .catch(err => {
- logger('dcm').error(`[DBController] Failed to get current database version: (${err})`);
- process.exit(-1);
- });
- if (results.length > 0) {
- version = parseInt(results[0].value);
- } else {
- version = 0;
- }
-
- const newestVersion = this.getNewestDbVersion();
- logger('dcm').info(`[DBController] Current: ${version}, Latest: ${newestVersion}`);
- console.log(`[DBController] Current: ${version}, Latest: ${newestVersion}`);
- if (version < newestVersion) {
- // Wait 30 seconds and let user know we are about to migrate the database and for them to make a backup until we handle backups and rollbacks.
- logger('dcm').info('[DBController] MIGRATION IS ABOUT TO START IN 30 SECONDS, PLEASE MAKE SURE YOU HAVE A BACKUP!!!');
- console.log('[DBController] MIGRATION IS ABOUT TO START IN 30 SECONDS, PLEASE MAKE SURE YOU HAVE A BACKUP!!!');
- await utils.snooze(30 * 1000);
- }
- this.migrate(version, newestVersion);
- }
- static async getEntries() {
- const sql = 'SELECT `key`, `value` FROM metadata';
- const results = await query(sql, []);
- return results;
- }
- async migrate(fromVersion, toVersion) {
- if (fromVersion < toVersion) {
- logger('dcm').info(`[DBController] Migrating database to version ${(fromVersion + 1)}`);
- console.log(`[DBController] Migrating database to version ${(fromVersion + 1)}`);
- await utils.snooze(5 * 1000);
- let migrateSQL;
- try {
- const sqlFile = `${migrationsDir}${path.sep}${fromVersion + 1}.sql`;
- migrateSQL = await utils.readFile(sqlFile);
- migrateSQL.replace('\r', '').replace('\n', '');
- } catch (err) {
- logger('dcm').error(`[DBController] Migration failed: ${err}`);
- console.error(`[DBController] Migration failed: ${err}`);
- process.exit(-1);
- }
- const sqlSplit = migrateSQL.split(';');
- //sqlSplit.forEach(async sql => {
- for (let i = 0; i < sqlSplit.length; i++) {
- const sql = sqlSplit[i];
- const msql = sql.replace('&semi', ';').trim();
- if (msql !== '') {
- //logger('dcm').info(`[DBController] Executing: ${msql}`);
- //console.log(`[DBController] Executing: ${msql}`);
- await query(msql)
- .then(x => x)
- .catch(async err => {
- logger('dcm').error(`[DBController] Migration failed: ${err}`);
- console.error(`[DBController] Migration failed: ${err}`);
- });
- //await utils.snooze(2000);
- }
- }
-
- const newVersion = fromVersion + 1;
- const updateVersionSQL = `
- INSERT INTO metadata (\`key\`, \`value\`)
- VALUES("DB_VERSION", ${newVersion})
- ON DUPLICATE KEY UPDATE \`value\` = ${newVersion};`;
- await query(updateVersionSQL)
- .then(x => x)
- .catch(err => {
- logger('dcm').error(`[DBController] Migration failed: ${err}`);
- process.exit(-1);
- });
- logger('dcm').info('[DBController] Migration successful');
- this.migrate(newVersion, toVersion);
- }
- if (fromVersion === toVersion) {
- logger('dcm').info('[DBController] Migration done');
- this.done = true;
- }
- }
- backup() {
- // TODO: Migrator backup
- /*
- let backupFileSchema: fs.WriteStream;
- let backupFileTrigger: fs.WriteStream;
- let backupFileData: fs.WriteStream;
- let uuidString = uuid.v4();
- let backupsDir = fs.opendirSync(backupsRoot);
- backupFileSchema = fs.createWriteStream(backupsDir.path + path.sep + uuidString + ".schema.sql");
- backupFileTrigger = fs.createWriteStream(backupsDir.path + path.sep + uuidString + ".trigger.sql");
- backupFileData = fs.createWriteStream(backupsDir.path + path.sep + uuidString + ".data.sql");
- let noBackup = process.env["NO_BACKUP"] || config.db.noBackup || false;
- if (noBackup === undefined || noBackup === null || noBackup === false) {
- let allTables = {
- account: true,
- assignment: true,
- device: true,
- device_group: true,
- discord_rule: true,
- group: true,
- gym: true,
- instance: true,
- metadata: true,
- pokemon: true,
- pokemon_stats: false,
- pokemon_shiny_stats: false,
- pokestop: true,
- quest_stats: false,
- raid_stats: false,
- invasion_stats: false,
- s2cell: true,
- spawnpoint: true,
- token: true,
- user: true,
- weather: true,
- web_session: true,
- };
- let tablesShema = "";
- let tablesData = "";
- let allTablesSQL = `
- SHOW TABLES
- `;
- let results = await query(allTablesSQL)
- .then(x => x)
- .catch(err => {
- let message = `Failed to execute query. (${err})`
- logger('dcm').error(`[DBController] ${message}`);
- process.exit(-1);
- });
- let tableKeys = Object.keys(results);
- tableKeys.forEach(key => {
- let withData = allTables[key];
- tablesShema += ` ${key}`;
- if (withData) {
- tablesData += ` ${key}`;
- }
- });
-
- logger('dcm').info(`[DBController] Creating backup ${uuidString}`);
- let mysqldumpCommand;
- if (os.type().toLowerCase() === "darwin") {
- mysqldumpCommand = "/usr/local/opt/mysql@5.7/bin/mysqldump"
- } else {
- mysqldumpCommand = "/usr/bin/mysqldump"
- }
-
- // Schema
- let args = ["-c", mysqldumpCommand + ` --set-gtid-purged=OFF --skip-triggers --add-drop-table --skip-routines --no-data ${database} ${tablesShema} -h ${host} -P ${port} -u ${rootUsername} -p${rootPassword.replace("\"", "\\\"") || ""} > ${backupFileSchema.path}`];
- let cmd = executeCommand("bash", args);
- if (cmd) {
- logger('dcm').error(`[DBController] Failed to create Command Backup: ${cmd}`);
- process.exit(-1);
- }
- // Trigger
- args = ["-c", mysqldumpCommand + ` --set-gtid-purged=OFF --triggers --no-create-info --no-data --skip-routines ${database} ${tablesShema} -h ${host} -P ${port} -u ${rootUsername} -p${rootPassword.replace("\"", "\\\"") || ""} > ${backupFileTrigger.path}`];
- cmd = executeCommand("bash", args);
- if (cmd) {
- logger('dcm').error(`[DBController] Failed to create Command Backup: ${cmd}`);
- process.exit(-1);
- }
- // Data
- args = ["-c", mysqldumpCommand + ` --set-gtid-purged=OFF --skip-triggers --skip-routines --no-create-info --skip-routines ${database} ${tablesData} -h ${host} -P ${port} -u ${rootUsername} -p${rootPassword.replace("\"", "\\\"") || ""} > ${backupFileData.path}`];
- cmd = executeCommand("bash", args);
- if (cmd) {
- logger('dcm').error(`[DBController] Failed to create Data Backup: ${cmd}`);
- process.exit(-1);
- }
- }
- */
- }
- rollback() {
- // TODO: Migrator rollback
- }
- getNewestDbVersion() {
- let current = 0;
- let keepChecking = true;
- while (keepChecking) {
- if (fs.existsSync(`${migrationsDir}${path.sep}${current + 1}.sql`)) {
- current++;
- } else {
- keepChecking = false;
- }
- }
- return current;
- }
- static async getValueForKey(key) {
- const sql = `
- SELECT value
- FROM metadata
- WHERE \`key\` = ?
- LIMIT 1;`;
- const args = [key];
- const results = await query(sql, args)
- .then(x => x)
- .catch(err => {
- logger('dcm').error(`[DbController] Error: ${err}`);
- return null;
- });
- if (results.length === 0) {
- return null;
- }
- const result = results[0];
- return result.value;
- }
- static async setValueForKey(key, value) {
- const sql = `
- INSERT INTO metadata (\`key\`, \`value\`)
- VALUES(?, ?)
- ON DUPLICATE KEY UPDATE
- value=VALUES(value);`;
- const args = [key, value];
- const results = await query(sql, args)
- .then(x => x)
- .catch(err => {
- logger('dcm').error(`[DbController] Error: ${err}`);
- return null;
- });
- logger('dcm').info(`[DbController] SetValueForKey: ${results}`);
- }
-}
-
-module.exports = Migrator;
\ No newline at end of file
diff --git a/src/services/utils.js b/src/services/utils.js
deleted file mode 100644
index 09340e0..0000000
--- a/src/services/utils.js
+++ /dev/null
@@ -1,193 +0,0 @@
-'use strict';
-
-const request = require('request');
-const fs = require('fs');
-const moment = require('moment-timezone');
-const bcrypt = require('bcrypt');
-const rounds = 10;
-const config = require('../config.json');
-
-const readFile = async (path, encoding = 'utf8') => {
- return new Promise((resolve, reject) => {
- fs.readFile(path, (err, data) => {
- if (err) {
- return reject(err);
- }
- resolve(data.toString(encoding));
- });
- });
-};
-
-const fileExists = async (path) => {
- return new Promise((resolve, reject) => {
- try {
- fs.exists(path, (exists) => {
- resolve(exists);
- });
- } catch (e) {
- return reject(e);
- }
- });
-};
-
-const fileLastModifiedTime = async (path) => {
- return new Promise((resolve, reject) => {
- try {
- fs.stat(path, (err, stats) => {
- if (err) {
- return reject(err);
- }
- resolve(convertTz(stats.mtime));
- });
- } catch (e) {
- return reject(e);
- }
- });
-};
-
-const snooze = async (ms) => {
- return new Promise(resolve => setTimeout(resolve, ms));
-};
-
-const getDateTime = (date) => {
- const momentDate = convertTz(date);//moment(date).tz(config.timezone);
- const formatted = momentDate.format(config.logging.format);
- return formatted;
-};
-
-const buildConfig = (provider, backendUrl, dataEndpoints, token, webserverPort, heartbeatMaxTime, minDelayLogout,
- loggingUrl, loggingPort, accountManager, deployEggs, nearbyTracker, autoLogin) => {
- let obj = {};
- switch (provider) {
- case 'GoCheats':
- obj = {
- 'backend_url': backendUrl,
- 'data_endpoints': (dataEndpoints || '').split(',') || [],
- 'backend_secret_token': token,
- 'webserver_port': webserverPort || 8080
- };
- break;
- case 'Kevin':
- obj = {
- 'backend_url': backendUrl,
- 'data_endpoints': (dataEndpoints || '').split(',') || [],
- 'backend_secret_token': token,
- 'webserver_port': webserverPort || 8080,
- 'heartbeat_max_time': heartbeatMaxTime,
- 'min_delay_logout': minDelayLogout,
- 'account_manager': accountManager,
- 'deploy_eggs': deployEggs,
- 'nearby_tracker': nearbyTracker,
- 'auto_login': autoLogin
- };
- break;
- case 'AI':
- obj = {
- 'backend_url': backendUrl,
- 'data_endpoints': (dataEndpoints || '').split(',') || [],
- 'backend_secret_token': token,
- 'webserver_port': webserverPort || 8080,
- 'min_delay_logout': minDelayLogout,
- 'logging_url': loggingUrl,
- 'logging_port': loggingPort,
- 'account_manager': accountManager,
- 'deploy_eggs': deployEggs,
- 'nearby_tracker': nearbyTracker
- };
- }
- const json = JSON.stringify(obj);
- return json;
-};
-
-const formatBytes = (bytes) => {
- const sizes = ['Bytes', 'KB', 'MB', 'GB', 'TB'];
- if (bytes === 0) {
- return 0;
- }
- const index = parseInt(Math.floor(Math.log(bytes) / Math.log(1024)));
- if (index == 0) {
- return bytes + ' ' + sizes[index];
- }
- return (bytes / Math.pow(1024, index)).toFixed(1) + ' ' + sizes[index];
-};
-
-const timeToSeconds = (time) => {
- if (time) {
- const split = time.split(':');
- if (split.length === 3) {
- const hours = parseInt(split[0]);
- const minutes = parseInt(split[1]);
- const seconds = parseInt(split[2]);
- const timeNew = parseInt(hours * 3600 + minutes * 60 + seconds);
- return timeNew;
- }
- }
- return 0;
-};
-
-const todaySeconds = () => {
- const date = moment().tz(config.timezone);
- const formattedDate = date.format('HH:mm:ss');
- const split = formattedDate.split(':');
- if (split.length >= 3) {
- const hour = parseInt(split[0]) || 0;
- const minute = parseInt(split[1]) || 0;
- const second = parseInt(split[2]) || 0;
- return hour * 3600 + minute * 60 + second;
- } else {
- return 0;
- }
-};
-
-const convertTz = (date) => {
- const momentDate = moment(date).tz(config.timezone);
- return momentDate;
-};
-
-const encrypt = (data) => {
- const encrypted = bcrypt.hashSync(data, rounds);
- return encrypted;
-};
-
-const verify = (data, verifyHash) => {
- const result = bcrypt.compareSync(data, verifyHash);
- return result;
-};
-
-const generateString = () => {
- return Math.random().toString(36).substring(2, 15) + Math.random().toString(36).substring(2, 15);
-};
-
-const postRequest = (url, data) => {
- const options = {
- url: url,
- json: true,
- method: 'POST',
- body: data,
- headers: { 'Accept': 'application/json', 'Content-Type': 'application/json' },
- };
- request(options)
- .on('error', err => {
- if (err) {
- console.error(err);
- return;
- }
- });
-};
-
-module.exports = {
- readFile,
- fileExists,
- fileLastModifiedTime,
- snooze,
- getDateTime,
- buildConfig,
- formatBytes,
- timeToSeconds,
- todaySeconds,
- convertTz,
- encrypt,
- verify,
- generateString,
- postRequest
-};
\ No newline at end of file
diff --git a/src/stores/index.ts b/src/stores/index.ts
new file mode 100644
index 0000000..421fb94
--- /dev/null
+++ b/src/stores/index.ts
@@ -0,0 +1 @@
+export * from './tokens';
\ No newline at end of file
diff --git a/src/stores/tokens/index.ts b/src/stores/tokens/index.ts
new file mode 100644
index 0000000..0f1bef9
--- /dev/null
+++ b/src/stores/tokens/index.ts
@@ -0,0 +1,8 @@
+import { StorageKeys } from '../../consts';
+import { clear, get, set } from '../../modules';
+
+export const getUserToken = () => get(StorageKeys.User);
+
+export const setUserToken = (data: any) => set(StorageKeys.User, data);
+
+export const clearUserToken = () => clear(StorageKeys.User);
\ No newline at end of file
diff --git a/src/types.d.ts b/src/types.d.ts
new file mode 100644
index 0000000..f1de66f
--- /dev/null
+++ b/src/types.d.ts
@@ -0,0 +1,94 @@
+export type Config = {
+ name: string;
+ provider: string;
+ backendUrl: string;
+ dataEndpoints: string[];
+ bearerToken: string | null;
+ default: boolean;
+ enabled: boolean;
+
+ createdAt?: Date;
+ updatedAt?: Date;
+};
+
+export type Device = {
+ uuid: string;
+ config: string | null;
+ model: string | null;
+ ipAddr: string | null;
+ iosVersion: string | null;
+ ipaVersion: string | null;
+ notes?: string | null;
+ lastSeen: Date | null;
+ webserverPort: number;
+ enabled: boolean;
+
+ createdAt?: Date;
+ updatedAt?: Date;
+
+ config?: ConfigModel | null;
+ deviceStats?: DeviceStat[];
+};
+
+export type DeviceStat = {
+ uuid: string;
+ date: Date;
+ restarts: number;
+
+ createdAt?: Date;
+ updatedAt?: Date;
+};
+
+export type Log = {
+ uuid: string;
+ message: string;
+ logLevel: string;
+ date: Date;
+};
+
+export type LogArchive = {
+ path: string;
+ fileName: string;
+ data: string;
+ date: Date;
+ compressed: boolean;
+ size: number;
+};
+
+export type Schedule = {
+ name: string;
+ config: string;
+ uuids: string[];
+ startTime: Date | string;
+ endTime: Date | string;
+ timezoneOffset: number;
+ nextConfig: string;
+ enabled: boolean;
+
+ createdAt?: Date;
+ updatedAt?: Date;
+};
+
+export type Setting = {
+ name: string;
+ value: string | number | boolean | any;
+
+ createdAt?: Date | null;
+ updatedAt?: Date | null;
+};
+
+export type User = {
+ id?: number;
+ username: string;
+ password: string;
+ enabled?: boolean;
+ root?: boolean;
+
+ createdAt?: Date;
+ updatedAt?: Date;
+};
+
+export interface ServerSettings extends Record-
{{username}} {{Account Profile}}
--
-
-
-
-
- {{Change Password}}
-
-
-
-
-
-