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

chore: refactor client from rpcService

Browse Source
This commit is contained in:
Ben Allfree 2022-12-31 06:30:51 -08:00
parent 9afabf9067
commit 31abcb7a21
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
packages/daemon/src/server.ts
View File

@ -35,7 +35,7 @@ global.EventSource = require('eventsource')
const client = await clientService(url) const client = await clientService(url)
ftpService({}) ftpService({})
const rpcService = await createRpcService({ client }) const rpcService = await createRpcService({})
const instanceService = await createInstanceService({ client, rpcService }) const instanceService = await createInstanceService({ client, rpcService })
const proxyService = await createProxyService({ const proxyService = await createProxyService({
instanceManager: instanceService, instanceManager: instanceService,

7
packages/daemon/src/services/RpcService.ts
View File

@ -12,7 +12,7 @@ import Bottleneck from 'bottleneck'
import { default as knexFactory } from 'knex' import { default as knexFactory } from 'knex'
import pocketbaseEs from 'pocketbase' import pocketbaseEs from 'pocketbase'
import { AsyncReturnType, JsonObject } from 'type-fest' import { AsyncReturnType, JsonObject } from 'type-fest'
import { PocketbaseClientApi } from '../db/PbClient' import { clientService } from '../db/PbClient'
export type RpcServiceApi = AsyncReturnType<typeof createRpcService> export type RpcServiceApi = AsyncReturnType<typeof createRpcService>
@ -28,12 +28,11 @@ export type RpcRunner<
TResult extends JsonObject TResult extends JsonObject
> = (job: RpcFields<TPayload, TResult>) => Promise<TResult> > = (job: RpcFields<TPayload, TResult>) => Promise<TResult>
export type RpcServiceConfig = { client: PocketbaseClientApi } export type RpcServiceConfig = {}
export const createRpcService = async (config: RpcServiceConfig) => { export const createRpcService = async (config: RpcServiceConfig) => {
const { dbg, error } = logger().create('RpcService') const { dbg, error } = logger().create('RpcService')
const client = await clientService()
const { client } = config
const limiter = new Bottleneck({ maxConcurrent: 1 }) const limiter = new Bottleneck({ maxConcurrent: 1 })