Mirroristas/pockethost
2
0
Fork 0
mirror of https://github.com/pockethost/pockethost.git synced 2025-10-14 00:59:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove unused mothership function

Browse Source
This commit is contained in:
Ben Allfree 2023-12-24 05:58:20 -08:00
parent 3c1789927f
commit cc8f9892fe
1 changed files with 0 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/services/MothershipAdmimClientService/InstanceMIxin.ts
View File

@ -6,8 +6,6 @@ import {
InstanceStatus, InstanceStatus,
WithUser, WithUser,
} from '$shared' } from '$shared'
import { reduce } from '@s-libs/micro-dash'
import Bottleneck from 'bottleneck'
import { MixinContext } from '.' import { MixinContext } from '.'
export type InstanceApi = ReturnType<typeof createInstanceMixin> export type InstanceApi = ReturnType<typeof createInstanceMixin>
@ -64,30 +62,6 @@ export const createInstanceMixin = (context: MixinContext) => {
return client.collection(INSTANCE_COLLECTION).getFullList<InstanceFields>() return client.collection(INSTANCE_COLLECTION).getFullList<InstanceFields>()
} }
const updateInstances = async (
cb: (rec: InstanceFields) => Partial<InstanceFields>,
) => {
const res = await client
.collection(INSTANCE_COLLECTION)
.getFullList<InstanceFields>(200)
const limiter = new Bottleneck({ maxConcurrent: 1 })
const promises = reduce(
res,
(c, r) => {
c.push(
limiter.schedule(() => {
const toUpdate = cb(r)
dbg(`Updating instance ${r.id} with ${JSON.stringify(toUpdate)}`)
return client.collection(INSTANCE_COLLECTION).update(r.id, toUpdate)
}),
)
return c
},
[] as Promise<void>[],
)
await Promise.all(promises)
}
return { return {
getInstanceById, getInstanceById,
getInstances, getInstances,
@ -95,7 +69,6 @@ export const createInstanceMixin = (context: MixinContext) => {
updateInstanceStatus, updateInstanceStatus,
getInstanceBySubdomain, getInstanceBySubdomain,
getInstance, getInstance,
updateInstances,
createInstance, createInstance,
} }
} }