mirror of
https://github.com/pockethost/pockethost.git
synced 2025-03-30 15:08:30 +00:00
support instance names when requesting realtime log connection
This commit is contained in:
parent
a9d7aa2ebb
commit
b6311be872
@ -59,15 +59,14 @@ export const realtimeLog = mkSingleton(async (config: RealtimeLogConfig) => {
|
|||||||
/** Validate instance and ownership */
|
/** Validate instance and ownership */
|
||||||
dbg(`Got a log request for instance ID ${instanceId}`)
|
dbg(`Got a log request for instance ID ${instanceId}`)
|
||||||
const instance = await client
|
const instance = await client
|
||||||
.collection('instances')
|
.collection('instances').getFirstListItem<InstanceFields>(`id = '${instanceId}' || subdomain='${instanceId}'` )
|
||||||
.getOne<InstanceFields>(instanceId)
|
|
||||||
if (!instance) {
|
if (!instance) {
|
||||||
throw new Error(`instanceId ${instanceId} not found for user ${user.id}`)
|
throw new Error(`instanceId ${instanceId} not found for user ${user.id}`)
|
||||||
}
|
}
|
||||||
dbg(`Instance is `, instance)
|
dbg(`Instance is `, instance)
|
||||||
|
|
||||||
/** Get a database connection */
|
/** Get a database connection */
|
||||||
const instanceLogger = InstanceLogger(instanceId, `exec`)
|
const instanceLogger = InstanceLogger(instance.id, `exec`)
|
||||||
|
|
||||||
/** Start the stream */
|
/** Start the stream */
|
||||||
res.writeHead(200, {
|
res.writeHead(200, {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user