Mirroristas/pockethost
2
0
Fork 0
mirror of https://github.com/pockethost/pockethost.git synced 2025-11-23 22:15:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

enh(pockethost): add daemon reset API

Browse Source
This commit is contained in:
Ben Allfree 2025-10-13 11:42:28 +00:00
parent a6e6f43fae
commit 9683f1b99b
1 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
packages/pockethost/src/cli/commands/FirewallCommand/ServeCommand/firewall/server.ts
View File

@ -10,6 +10,7 @@ import {
SSL_KEY,
} from '@'
import { forEach } from '@s-libs/micro-dash'
import { exec } from 'child_process'
import cors from 'cors'
import express, { ErrorRequestHandler } from 'express'
import 'express-async-errors'
@ -26,7 +27,7 @@ export type FirewallOptions = {
}
export const firewall = async ({ logger }: FirewallOptions) => {
const { dbg, error } = logger.create(`firewall`)
const { dbg, error, info } = logger.create(`firewall`)
const PROD_ROUTES = {
[`${MOTHERSHIP_NAME()}.${APEX_DOMAIN()}`]: `http://localhost:${MOTHERSHIP_PORT()}`,
@ -51,6 +52,34 @@ export const firewall = async ({ logger }: FirewallOptions) => {
res.end()
})
app.get(`/api/_private/reset`, (req, res, next) => {
dbg(`Reset password`)
const secretParam = Array.isArray((req.query as any)?.secret)
? (req.query as any).secret[0]
: (req.query as any)?.secret
if (!secretParam || secretParam !== process.env.PH_SECRET) {
res.status(401).json({ error: 'unauthorized', code: 401 })
res.end()
return
}
exec('pm2 restart edge-daemon', (err, stdout, stderr) => {
if (err) {
error(err)
res.status(500).json({ error: 'pm2 reset failed', code: 500 })
res.end()
return
}
info(stdout)
info(stderr)
res.json({ status: 'pm2 reset ok', code: 200 })
res.end()
})
})
// Use the IP blocker middleware
app.use(createIpWhitelistMiddleware(IPCIDR_LIST()))