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

enh(pockethost): add event handlers to MothershipMirrorService

Browse Source
This commit is contained in:
Ben Allfree 2025-07-22 08:14:50 -07:00
parent a3a8a215f2
commit 7d9ccf0639
1 changed files with 46 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
packages/pockethost/src/services/MothershipMirrorService/index.ts
View File

@ -1,4 +1,5 @@
import {
createEvent,
EDGE_APEX_DOMAIN,
InstanceFields,
InstanceId,
@ -18,6 +19,11 @@ export type MothershipMirrorServiceConfig = SingletonBaseConfig & {
export const MothershipMirrorService = mkSingleton(async (config: MothershipMirrorServiceConfig) => {
const { dbg, error } = (config.logger ?? LoggerService()).create(`MothershipMirrorService`)
const [onInstanceUpserted, fireInstanceUpserted] = createEvent<InstanceFields>()
const [onInstanceDeleted, fireInstanceDeleted] = createEvent<InstanceId>()
const [onUserUpserted, fireUserUpserted] = createEvent<UserFields>()
const [onUserDeleted, fireUserDeleted] = createEvent<UserId>()
const client = config.client
const mirror: {
@ -37,7 +43,7 @@ export const MothershipMirrorService = mkSingleton(async (config: MothershipMirr
}
const upsertInstance = (record: InstanceFields) => {
dbg(`upsertInstance`, { record })
dbg(`upsertInstance ${record.id}`)
deleteInstance(record.id)
const canonicalId = `${record.id}.${EDGE_APEX_DOMAIN()}`
const canonicalSubdomain = `${record.subdomain}.${EDGE_APEX_DOMAIN()}`
@ -64,7 +70,7 @@ export const MothershipMirrorService = mkSingleton(async (config: MothershipMirr
}
const upsertUser = (record: UserFields) => {
dbg(`upsertUser`, { record })
dbg(`upsertUser ${record.id}`)
deleteUser(record.id)
mirror.users[record.id] = record
}
@ -76,35 +82,39 @@ export const MothershipMirrorService = mkSingleton(async (config: MothershipMirr
}
}
client.collection(`instances`).subscribe<InstanceFields>(`*`, (e) => {
const { action, record } = e
if (action === `create` || action === `update`) {
dbg(`instance`, { action, record })
upsertInstance(record)
}
if (action === `delete`) {
dbg(`instance`, { action, record })
deleteInstance(record.id)
}
})
client.collection(`users`).subscribe<UserFields>(`*`, (e) => {
const deleteUser = (id: UserId) => {
const oldUser = mirror.users[id]
if (oldUser) {
delete mirror.users[oldUser.id]
client
.collection(`instances`)
.subscribe<InstanceFields>(`*`, (e) => {
const { action, record } = e
if (action === `create` || action === `update`) {
dbg(`instance`, { action, record })
upsertInstance(record)
fireInstanceUpserted(record)
}
}
const { action, record } = e
if (action === `create` || action === `update`) {
dbg(`user`, { action, record })
upsertUser(record)
}
if (action === `delete`) {
dbg(`user`, { action, record })
deleteUser(record.id)
}
})
if (action === `delete`) {
dbg(`instance`, { action, record })
deleteInstance(record.id)
fireInstanceDeleted(record.id)
}
})
.catch(error)
client
.collection(`users`)
.subscribe<UserFields>(`*`, (e) => {
const { action, record } = e
if (action === `create` || action === `update`) {
dbg(`user`, { action, record })
upsertUser(record)
fireUserUpserted(record)
}
if (action === `delete`) {
dbg(`user`, { action, record })
deleteUser(record.id)
fireUserDeleted(record.id)
}
})
.catch(error)
const init = async () => {
dbg(`init`)
@ -146,6 +156,12 @@ export const MothershipMirrorService = mkSingleton(async (config: MothershipMirr
async getUser(id: UserId) {
return mirror.users[id]
},
onInstanceUpserted,
onInstanceDeleted,
onUserDeleted,
onUserUpserted,
getInstances: () => Object.values(mirror.instancesById),
getUsers: () => Object.values(mirror.users),
}
return api
})