This commit is contained in:
Jonas L 2019-06-24 00:00:00 +00:00
parent 61d34c88f8
commit f94f801663
2 changed files with 4 additions and 4 deletions

View file

@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>. * along with this program. If not, see <https://www.gnu.org/licenses/>.
*/ */
import { json } from 'body-parser' import { urlencoded } from 'body-parser'
import * as escape from 'escape-html' import * as escape from 'escape-html'
import { Router } from 'express' import { Router } from 'express'
import { BadRequest } from 'http-errors' import { BadRequest } from 'http-errors'
@ -39,13 +39,13 @@ export const createAdminRouter = ({ database, websocket }: {
try { try {
const currentStatusMessage = await getStatusMessage({ database }) const currentStatusMessage = await getStatusMessage({ database })
res.send('<html><body><form action="/admin/status-message" method="post"><textarea>' + escape(currentStatusMessage) + '</textarea><input type="submit" value="Save"></form></body></html>') res.send('<html><body><form action="/admin/status-message" method="post"><textarea name="smessage" rows="20" cols="100">' + escape(currentStatusMessage) + '</textarea><input type="submit" value="Save"></form></body></html>')
} catch (ex) { } catch (ex) {
next(ex) next(ex)
} }
}) })
router.post('/status-message', json(), async (req, res, next) => { router.post('/status-message', urlencoded({ extended: false }), async (req, res, next) => {
try { try {
if (typeof req.body !== 'object' || typeof req.body.smessage !== 'string') { if (typeof req.body !== 'object' || typeof req.body.smessage !== 'string') {
throw new BadRequest() throw new BadRequest()

View file

@ -59,7 +59,7 @@ export const createWebsocketHandler = ({ connectedDevicesManager, database }: {
} }
events.on(eventTriggerImportantSyncForAll, importantSyncForAllListener) events.on(eventTriggerImportantSyncForAll, importantSyncForAllListener)
socket.on('disconnect', () => events.off(eventTriggerImportantSyncForAll, importantSyncForAllListener)) socket.on('disconnect', () => events.removeListener(eventTriggerImportantSyncForAll, importantSyncForAllListener))
;(async () => { ;(async () => {
const deviceEntryUnsafe = await database.device.findOne({ const deviceEntryUnsafe = await database.device.findOne({