chore: refactor includes

This commit is contained in:
Ben Allfree 2023-10-20 01:35:16 -07:00
parent d1c25e0d47
commit f4be4318c4
14 changed files with 37 additions and 31 deletions

View File

@ -7,19 +7,19 @@ import {
TRACE, TRACE,
} from '$constants' } from '$constants'
import { import {
centralDbService,
clientService, clientService,
ftpService, ftpService,
instanceService, instanceService,
ipWhitelistService,
pocketbaseService, pocketbaseService,
proxyService, proxyService,
realtimeLog, realtimeLog,
rpcService, rpcService,
sqliteService, sqliteService,
updaterService,
} from '$services' } from '$services'
import { LoggerService } from '@pockethost/common' import { LoggerService } from '@pockethost/common'
import { centralDbService } from './services/CentralDbService'
import { ipWhitelistService } from './services/IpWhitelistService'
import { updaterService } from './services/UpdaterService/UpdaterService'
// gen:import // gen:import
const [major, minor, patch] = process.versions.node.split('.').map(Number) const [major, minor, patch] = process.versions.node.split('.').map(Number)

View File

@ -1,4 +1,5 @@
import { DAEMON_PB_DATA_DIR } from '$constants' import { DAEMON_PB_DATA_DIR } from '$constants'
import { PocketbaseClientApi } from '$services'
import { assert } from '$util' import { assert } from '$util'
import { InstanceFields, Logger } from '@pockethost/common' import { InstanceFields, Logger } from '@pockethost/common'
import { compact, map } from '@s-libs/micro-dash' import { compact, map } from '@s-libs/micro-dash'
@ -13,13 +14,12 @@ import {
import { FileStat, FileSystem, FtpConnection } from 'ftp-srv' import { FileStat, FileSystem, FtpConnection } from 'ftp-srv'
import { customAlphabet } from 'nanoid' import { customAlphabet } from 'nanoid'
import { isAbsolute, join, normalize, resolve, sep } from 'path' import { isAbsolute, join, normalize, resolve, sep } from 'path'
import { PocketbaseClientApi } from '../clientService/PbClient'
import { import {
FolderNames, FolderNames,
INSTANCE_ROOT_FOLDER_NAMES, INSTANCE_ROOT_FOLDER_NAMES,
MAINTENANCE_ONLY_FOLDER_NAMES, MAINTENANCE_ONLY_FOLDER_NAMES,
isInstanceRootFolder, isInstanceRootFolder,
} from './FtpService' } from '.'
import * as fsAsync from './fs-async' import * as fsAsync from './fs-async'
const nanoid = customAlphabet(`abcdefghijklmnop`) const nanoid = customAlphabet(`abcdefghijklmnop`)

View File

@ -4,7 +4,13 @@ import {
mkDocUrl, mkDocUrl,
PUBLIC_MOTHERSHIP_NAME, PUBLIC_MOTHERSHIP_NAME,
} from '$constants' } from '$constants'
import { clientService, proxyService } from '$services' import {
clientService,
InstanceLogger,
pocketbaseService,
port,
proxyService,
} from '$services'
import { mkInternalUrl, now } from '$util' import { mkInternalUrl, now } from '$util'
import { import {
assertTruthy, assertTruthy,
@ -22,9 +28,6 @@ import { map, values } from '@s-libs/micro-dash'
import Bottleneck from 'bottleneck' import Bottleneck from 'bottleneck'
import { ClientResponseError } from 'pocketbase' import { ClientResponseError } from 'pocketbase'
import { AsyncReturnType } from 'type-fest' import { AsyncReturnType } from 'type-fest'
import { InstanceLogger } from '../InstanceLoggerService'
import { pocketbaseService } from '../PocketBaseService/PocketBaseService'
import { port } from '../PortManager'
enum InstanceApiStatus { enum InstanceApiStatus {
Starting = 'starting', Starting = 'starting',

View File

@ -1,4 +1,5 @@
import { DAEMON_IPCIDR_LIST } from '$constants' import { DAEMON_IPCIDR_LIST } from '$constants'
import { proxyService } from '$services'
import { assert } from '$util' import { assert } from '$util'
import { import {
LoggerService, LoggerService,
@ -6,7 +7,6 @@ import {
SingletonBaseConfig, SingletonBaseConfig,
} from '@pockethost/common' } from '@pockethost/common'
import IPCIDR from 'ip-cidr' import IPCIDR from 'ip-cidr'
import { proxyService } from '../ProxyService'
export type IpWhitelistServiceConfig = SingletonBaseConfig & { export type IpWhitelistServiceConfig = SingletonBaseConfig & {
ipRanges: string[] ipRanges: string[]
} }

View File

@ -4,17 +4,15 @@ import {
mkInstanceDataPath, mkInstanceDataPath,
PUBLIC_DEBUG, PUBLIC_DEBUG,
} from '$constants' } from '$constants'
import { port as getPort } from '$services' import { port as getPort, InstanceLogger, updaterService } from '$services'
import { assert, mkInternalUrl, tryFetch } from '$util' import { assert, AsyncContext, mkInternalUrl, tryFetch } from '$util'
import { import {
createCleanupManager, createCleanupManager,
createTimerManager, createTimerManager,
InvocationPid, InvocationPid,
} from '@pockethost/common'
import {
mkSingleton, mkSingleton,
SingletonBaseConfig, SingletonBaseConfig,
} from '@pockethost/common/src/mkSingleton' } from '@pockethost/common'
import { map } from '@s-libs/micro-dash' import { map } from '@s-libs/micro-dash'
import Docker, { Container, ContainerCreateOptions } from 'dockerode' import Docker, { Container, ContainerCreateOptions } from 'dockerode'
import { existsSync } from 'fs' import { existsSync } from 'fs'
@ -22,9 +20,6 @@ import MemoryStream from 'memorystream'
import { dirname } from 'path' import { dirname } from 'path'
import { gte } from 'semver' import { gte } from 'semver'
import { AsyncReturnType } from 'type-fest' import { AsyncReturnType } from 'type-fest'
import { AsyncContext } from '../../util/AsyncContext'
import { InstanceLogger } from '../InstanceLoggerService'
import { updaterService } from '../UpdaterService/UpdaterService'
export type PocketbaseCommand = 'serve' | 'migrate' export type PocketbaseCommand = 'serve' | 'migrate'
export type Env = { [_: string]: string } export type Env = { [_: string]: string }

View File

@ -1,3 +1,9 @@
import {
clientService,
instanceService,
rpcService,
updaterService,
} from '$services'
import { import {
CreateInstancePayload, CreateInstancePayload,
CreateInstancePayloadSchema, CreateInstancePayloadSchema,
@ -20,10 +26,6 @@ import {
type SetInstanceMaintenanceResult, type SetInstanceMaintenanceResult,
} from '@pockethost/common' } from '@pockethost/common'
import { valid, validRange } from 'semver' import { valid, validRange } from 'semver'
import { instanceService } from '../InstanceService/InstanceService'
import { updaterService } from '../UpdaterService/UpdaterService'
import { clientService } from '../clientService/clientService'
import { rpcService } from './RpcService'
export const registerRpcCommands = async (logger: Logger) => { export const registerRpcCommands = async (logger: Logger) => {
const { client } = await clientService() const { client } = await clientService()

View File

@ -1,3 +1,5 @@
import { MixinContext } from '$services'
import { AsyncContext } from '$util'
import { import {
INSTANCE_COLLECTION, INSTANCE_COLLECTION,
InstanceFields, InstanceFields,
@ -9,8 +11,6 @@ import {
} from '@pockethost/common' } from '@pockethost/common'
import { reduce } from '@s-libs/micro-dash' import { reduce } from '@s-libs/micro-dash'
import Bottleneck from 'bottleneck' import Bottleneck from 'bottleneck'
import { AsyncContext } from '../../util/AsyncContext'
import { MixinContext } from './PbClient'
export type InstanceApi = ReturnType<typeof createInstanceMixin> export type InstanceApi = ReturnType<typeof createInstanceMixin>

View File

@ -0,0 +1,2 @@
export * from './PbClient'
export * from './clientService'

View File

@ -1,10 +1,13 @@
export * from './FtpService/FtpService' export * from './CentralDbService'
export * from './InstanceService/InstanceService' export * from './FtpService'
export * from './PocketBaseService/PocketBaseService' export * from './InstanceLoggerService'
export * from './InstanceService'
export * from './IpWhitelistService'
export * from './PocketBaseService'
export * from './PortManager' export * from './PortManager'
export * from './ProxyService' export * from './ProxyService'
export * from './RealtimeLog' export * from './RealtimeLog'
export * from './RpcService/RpcService' export * from './RpcService'
export * from './SqliteService/SqliteService' export * from './SqliteService'
export * from './clientService/PbClient' export * from './UpdaterService'
export * from './clientService/clientService' export * from './clientService'

View File

@ -1,3 +1,4 @@
export * from './AsyncContext'
export * from './PromiseAllocator' export * from './PromiseAllocator'
export * from './assert' export * from './assert'
export * from './downloadAndExtract' export * from './downloadAndExtract'