mirror of
https://gitlab.com/MrFry/mrfrys-node-server
synced 2025-04-01 20:24:18 +02:00
393 lines
11 KiB
JavaScript
393 lines
11 KiB
JavaScript
/* ----------------------------------------------------------------------------
|
|
|
|
Question Server
|
|
GitLab: <https://gitlab.com/MrFry/mrfrys-node-server>
|
|
|
|
This program is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program. If not, see <https://www.gnu.org/licenses/>.
|
|
|
|
------------------------------------------------------------------------- */
|
|
|
|
const express = require('express')
|
|
const bodyParser = require('body-parser')
|
|
const busboy = require('connect-busboy')
|
|
const cookieParser = require('cookie-parser')
|
|
const fs = require('fs')
|
|
const app = express()
|
|
|
|
// const http = require('http')
|
|
// const https = require('https')
|
|
|
|
const logger = require('../../utils/logger.js')
|
|
const utils = require('../../utils/utils.js')
|
|
const actions = require('../../utils/actions.js')
|
|
const dbtools = require('../../utils/dbtools.js')
|
|
const auth = require('../../modules/api/auth.middleware.js')
|
|
|
|
const recivedFiles = 'public/recivedfiles'
|
|
const uloadFiles = 'public/f'
|
|
const dataFile = 'public/data.json'
|
|
const msgFile = 'stats/msgs'
|
|
const motdFile = 'public/motd'
|
|
const versionFile = 'public/version'
|
|
const passwordFile = 'data/dataEditorPasswords.json'
|
|
const dataEditsLog = 'stats/dataEdits'
|
|
const dailyDataCountFile = 'stats/dailyDataCount'
|
|
const usersDBPath = 'data/dbs/users.db'
|
|
const dbStructPath = './modules/api/apiDBStruct.json'
|
|
|
|
let authDB
|
|
function CreateDB () {
|
|
const dbStruct = utils.ReadJSON(dbStructPath)
|
|
// TODO: check if path exists, create it if not
|
|
authDB = dbtools.GetDB(usersDBPath)
|
|
|
|
Object.keys(dbStruct).forEach((tableName) => {
|
|
const tableData = dbStruct[tableName]
|
|
dbtools.CreateTable(authDB, tableName, tableData.tableStruct)
|
|
})
|
|
}
|
|
CreateDB()
|
|
|
|
app.use(cookieParser())
|
|
app.set('view engine', 'ejs')
|
|
app.set('views', [
|
|
'./modules/api/views',
|
|
'./sharedViews'
|
|
])
|
|
app.use(auth({
|
|
debugLog: true,
|
|
authDB: authDB
|
|
}))
|
|
app.use(express.static('public'))
|
|
app.use(busboy({
|
|
limits: {
|
|
fileSize: 50000 * 1024 * 1024
|
|
}
|
|
}))
|
|
app.use(bodyParser.urlencoded({
|
|
limit: '10mb',
|
|
extended: true
|
|
}))
|
|
app.use(bodyParser.json({
|
|
limit: '10mb'
|
|
}))
|
|
|
|
var data = actions.LoadJSON(dataFile)
|
|
var version = ''
|
|
var motd = ''
|
|
|
|
function LoadVersion () {
|
|
version = utils.ReadFile(versionFile)
|
|
}
|
|
|
|
function LoadMOTD () {
|
|
motd = utils.ReadFile(motdFile)
|
|
}
|
|
|
|
function Load () {
|
|
utils.WatchFile(motdFile, (newData) => {
|
|
logger.Log(`Motd changed: ${newData.replace(/\/n/g, '')}`)
|
|
LoadMOTD()
|
|
})
|
|
utils.WatchFile(versionFile, (newData) => {
|
|
logger.Log(`Version changed: ${newData.replace(/\/n/g, '')}`)
|
|
LoadVersion()
|
|
})
|
|
|
|
LoadVersion()
|
|
LoadMOTD()
|
|
}
|
|
|
|
Load()
|
|
|
|
// -------------------------------------------------------------
|
|
|
|
app.get('/login', (req, res) => {
|
|
logger.LogReq(req)
|
|
// FIXME: redirect to original url
|
|
// TODO: check if pw is correct
|
|
res.cookie('pw', req.query.pw).redirect('/')
|
|
// TODO: create session
|
|
})
|
|
|
|
app.get('/logout', (req, res) => {
|
|
logger.LogReq(req)
|
|
// FIXME: redirect to original url
|
|
// TODO: destroy session
|
|
res.clearCookie('pw').redirect('/')
|
|
})
|
|
|
|
// --------------------------------------------------------------
|
|
|
|
app.get('/', function (req, res) {
|
|
logger.LogReq(req)
|
|
res.redirect('https://www.youtube.com/watch?v=ieqGJgqiXFk')
|
|
})
|
|
|
|
app.post('/postfeedbackfile', function (req, res) {
|
|
UploadFile(req, res, uloadFiles, (fn) => {
|
|
res.json({ success: true })
|
|
})
|
|
|
|
logger.LogReq(req)
|
|
logger.Log('New feedback file', logger.GetColor('bluebg'), true)
|
|
})
|
|
|
|
app.post('/postfeedback', function (req, res) {
|
|
logger.LogReq(req)
|
|
logger.Log('New feedback message', logger.GetColor('bluebg'), true)
|
|
utils.AppendToFile(logger.GetDateString() + ':\n' + JSON.stringify(req.body), msgFile)
|
|
res.json({ success: true })
|
|
})
|
|
|
|
function UploadFile (req, res, path, next) {
|
|
try {
|
|
var fstream
|
|
req.pipe(req.busboy)
|
|
req.busboy.on('file', function (fieldname, file, filename) {
|
|
logger.Log('Uploading: ' + filename, logger.GetColor('blue'))
|
|
|
|
utils.CreatePath(path, true)
|
|
let d = new Date()
|
|
let fn = d.getHours() + '' + d.getMinutes() + '' + d.getSeconds() + '_' + filename
|
|
|
|
fstream = fs.createWriteStream(path + '/' + fn)
|
|
file.pipe(fstream)
|
|
fstream.on('close', function () {
|
|
logger.Log('Upload Finished of ' + path + '/' + fn, logger.GetColor('blue'))
|
|
next(fn)
|
|
})
|
|
fstream.on('error', function (err) {
|
|
console.log(err)
|
|
res.end('something bad happened :s')
|
|
})
|
|
})
|
|
} catch (e) {
|
|
logger.Log(`Unable to upload file!`, logger.GetColor('redbg'))
|
|
console.log(e)
|
|
}
|
|
}
|
|
|
|
app.route('/fosuploader').post(function (req, res, next) {
|
|
UploadFile(req, res, uloadFiles, (fn) => {
|
|
res.redirect('/f/' + fn)
|
|
})
|
|
})
|
|
|
|
app.route('/badtestsender').post(function (req, res, next) {
|
|
UploadFile(req, res, recivedFiles, (fn) => {
|
|
res.redirect('back')
|
|
})
|
|
logger.LogReq(req)
|
|
})
|
|
|
|
app.get('/allqr.txt', function (req, res) {
|
|
res.set('Content-Type', 'text/plain')
|
|
res.send(data.toString())
|
|
res.end()
|
|
logger.LogReq(req)
|
|
})
|
|
|
|
// -------------------------------------------------------------------------------------------
|
|
// API
|
|
|
|
app.post('/uploaddata', (req, res) => {
|
|
// body: JSON.stringify({
|
|
// newData: data,
|
|
// count: getCount(data),
|
|
// initialCount: initialCount,
|
|
// password: password,
|
|
// editedQuestions: editedQuestions
|
|
// })
|
|
|
|
const { count, initialCount, editedQuestions, password, newData } = req.body
|
|
const respStatuses = {
|
|
invalidPass: 'invalidPass',
|
|
ok: 'ok',
|
|
error: 'error'
|
|
}
|
|
|
|
logger.LogReq(req)
|
|
|
|
try {
|
|
// finding user
|
|
const pwds = JSON.parse(utils.ReadFile(passwordFile))
|
|
let user = Object.keys(pwds).find((key) => {
|
|
const u = pwds[key]
|
|
return u.password === password
|
|
})
|
|
user = pwds[user]
|
|
|
|
// logging and stuff
|
|
logger.Log(`Data upload`, logger.GetColor('bluebg'))
|
|
logger.Log(`PWD: ${password}`, logger.GetColor('bluebg'))
|
|
// returning if user password is not ok
|
|
if (!user) {
|
|
logger.Log(`Data upload: invalid password ${password}`, logger.GetColor('red'))
|
|
utils.AppendToFile(logger.GetDateString() + '\n' + password + '(FAILED PASSWORD)\n' + JSON.stringify(editedQuestions) + '\n\n', dataEditsLog)
|
|
res.json({ status: respStatuses.invalidPass })
|
|
return
|
|
}
|
|
|
|
logger.Log(`Password accepted for ${user.name}`, logger.GetColor('bluebg'))
|
|
logger.Log(`Old Subjects/Questions: ${initialCount.subjectCount} / ${initialCount.questionCount} | New: ${count.subjectCount} / ${count.questionCount} | Edited question count: ${Object.keys(editedQuestions).length}`, logger.GetColor('bluebg'))
|
|
// saving detailed editedCount
|
|
utils.AppendToFile(logger.GetDateString() + '\n' + JSON.stringify(user) + '\n' + JSON.stringify(editedQuestions) + '\n\n', dataEditsLog)
|
|
|
|
// making backup
|
|
utils.CopyFile('./' + dataFile, `./public/backs/data_before_${user.name}_${new Date().toString().replace(/ /g, '_')}`)
|
|
logger.Log('Backup made')
|
|
// writing data
|
|
utils.WriteFile(JSON.stringify(newData), dataFile)
|
|
logger.Log('New data file written')
|
|
// reloading data file
|
|
data = actions.LoadJSON(dataFile)
|
|
// data = newData
|
|
logger.Log('Data set to newData')
|
|
|
|
res.json({
|
|
status: respStatuses.ok,
|
|
user: user.name
|
|
})
|
|
logger.Log('Data updating done!', logger.GetColor('bluebg'))
|
|
} catch (e) {
|
|
logger.Log(`Data upload error! `, logger.GetColor('redbg'))
|
|
console.error(e)
|
|
res.json({ status: respStatuses.error, msg: e.message })
|
|
}
|
|
})
|
|
|
|
app.post('/isAdding', function (req, res) {
|
|
logger.LogReq(req)
|
|
|
|
// automatically saves to dataFile every n write
|
|
// FIXME: req.body.datatoadd is for backwards compatibility, remove this sometime in the future
|
|
let result = actions.ProcessIncomingRequest(
|
|
req.body.datatoadd || req.body,
|
|
data,
|
|
{ motd, version }
|
|
)
|
|
|
|
res.json({
|
|
success: result !== -1,
|
|
newQuestions: result
|
|
})
|
|
})
|
|
|
|
app.get('/ask', function (req, res) {
|
|
if (Object.keys(req.query).length === 0) {
|
|
logger.DebugLog(`No query params`, 'ask', 1)
|
|
res.json({
|
|
message: `ask something! ?q=[question]&subj=[subject]&data=[question data]. 'subj' is optimal for faster result`,
|
|
result: [],
|
|
recievedData: JSON.stringify(req.query),
|
|
success: false
|
|
})
|
|
} else {
|
|
if (req.query.q && req.query.data) {
|
|
let subj = req.query.subj || ''
|
|
let question = req.query.q
|
|
let recData = {}
|
|
try {
|
|
recData = JSON.parse(req.query.data)
|
|
} catch (e) {
|
|
logger.Log(`Unable to parse recieved question data! '${req.query.data}'`, logger.GetColor('redbg'))
|
|
}
|
|
let r = data.Search(question, subj, recData)
|
|
|
|
res.json({
|
|
result: r,
|
|
success: true
|
|
})
|
|
logger.DebugLog(`Question result length: ${r.length}`, 'ask', 1)
|
|
logger.DebugLog(r, 'ask', 2)
|
|
} else {
|
|
logger.DebugLog(`Invalid question`, 'ask', 1)
|
|
res.json({
|
|
message: `Invalid question :(`,
|
|
result: [],
|
|
recievedData: JSON.stringify(req.query),
|
|
success: false
|
|
})
|
|
}
|
|
}
|
|
})
|
|
|
|
function getSimplreRes () {
|
|
return {
|
|
subjects: data.length,
|
|
questions: data.Subjects.reduce((acc, subj) => {
|
|
return acc + subj.length
|
|
}, 0)
|
|
}
|
|
}
|
|
function getDetailedRes () {
|
|
return data.Subjects.map((subj) => {
|
|
return {
|
|
name: subj.Name,
|
|
count: subj.length
|
|
}
|
|
})
|
|
}
|
|
|
|
app.get('/datacount', function (req, res) {
|
|
logger.LogReq(req)
|
|
if (req.query.detailed === 'all') {
|
|
res.json({
|
|
detailed: getDetailedRes(),
|
|
simple: getSimplreRes()
|
|
})
|
|
} else if (req.query.detailed) {
|
|
res.json(getDetailedRes())
|
|
} else {
|
|
res.json(getSimplreRes())
|
|
}
|
|
})
|
|
|
|
app.get('/infos', function (req, res) {
|
|
let result = {}
|
|
if (req.query.subjinfo) {
|
|
result.subjinfo = getSimplreRes()
|
|
}
|
|
if (req.query.version) {
|
|
result.version = version
|
|
}
|
|
if (req.query.motd) {
|
|
result.motd = motd
|
|
}
|
|
res.json(result)
|
|
})
|
|
|
|
// -------------------------------------------------------------------------------------------
|
|
|
|
app.get('*', function (req, res) {
|
|
res.status(404).render('404')
|
|
})
|
|
|
|
app.post('*', function (req, res) {
|
|
res.status(404).render('404')
|
|
})
|
|
|
|
exports.app = app
|
|
exports.dailyAction = () => {
|
|
utils.AppendToFile(JSON.stringify({
|
|
date: new Date(),
|
|
subjectCount: data.Subjects.length,
|
|
questionCOunt: data.Subjects.reduce((acc, subj) => {
|
|
return acc + subj.Questions.length
|
|
}, 0)
|
|
}), dailyDataCountFile)
|
|
}
|
|
|
|
logger.Log('API module started', logger.GetColor('yellow'))
|