import { Parser, string } from "ts-matches" import * as T from "../types" import FileHelper from "./fileHelper" import nullIfEmpty from "./nullIfEmpty" import { GetWrapperData, getWrapperData } from "./getWrapperData" import { CheckResult, checkPortListening, checkWebUrl, } from "../health/checkFns" import { ExtractWrapperData } from "../types" import { GetSystemSmtp } from "./GetSystemSmtp" import "./nullIfEmpty" import "./fileHelper" import "./getWrapperData" import "./deepEqual" import "./deepMerge" import "./once" import { LocalBinding } from "../mainFn/LocalBinding" import { LocalPort } from "../mainFn/LocalPort" import { NetworkBuilder } from "../mainFn/NetworkBuilder" import { TorHostname } from "../mainFn/TorHostname" import { DefaultString } from "../config/configTypes" import { getDefaultString } from "./getDefaultString" // prettier-ignore export type FlattenIntersection = T extends ArrayLike ? T : T extends object ? {} & {[P in keyof T]: T[P]} : T; export type _ = FlattenIntersection export const isKnownError = (e: unknown): e is T.KnownError => e instanceof Object && ("error" in e || "error-code" in e) declare const affine: unique symbol export type WrapperDataOptionals = { validator?: Parser> /** Defaults to what ever the package currently in */ packageId?: string | undefined } export type Utils = { createOrUpdateVault: (opts: { key: string value: string | null | undefined generator: DefaultString }) => Promise readFile: (fileHelper: FileHelper) => ReturnType["read"]> writeFile: ( fileHelper: FileHelper, data: A, ) => ReturnType["write"]> getSystemSmtp: () => GetSystemSmtp & WrapperOverWrite getWrapperData: ( packageId: string, path: T.EnsureWrapperDataPath, ) => GetWrapperData & WrapperOverWrite getOwnWrapperData: ( path: T.EnsureWrapperDataPath, ) => GetWrapperData & WrapperOverWrite setOwnWrapperData: ( path: T.EnsureWrapperDataPath, value: ExtractWrapperData, ) => Promise checkPortListening( port: number, options: { errorMessage: string successMessage: string timeoutMessage?: string timeout?: number }, ): Promise checkWebUrl( url: string, options?: { timeout?: number successMessage?: string errorMessage?: string }, ): Promise bindLan: (port: number) => Promise networkBuilder: () => NetworkBuilder torHostName: (id: string) => TorHostname nullIfEmpty: typeof nullIfEmpty } export const utils = ( effects: T.Effects, ): Utils => ({ createOrUpdateVault: async ({ key, value, generator, }: { key: string value: string | null | undefined generator: DefaultString }) => { if (value) { await effects.vault.set({ key, value }) return value } if (await effects.vault.get({ key })) { return null } const newValue = getDefaultString(generator) await effects.vault.set({ key, value: newValue }) return newValue }, getSystemSmtp: () => new GetSystemSmtp(effects) as GetSystemSmtp & WrapperOverWrite, readFile: (fileHelper: FileHelper) => fileHelper.read(effects), writeFile: (fileHelper: FileHelper, data: A) => fileHelper.write(data, effects), nullIfEmpty, getWrapperData: ( packageId: string, path: T.EnsureWrapperDataPath, ) => getWrapperData(effects, path as any, { packageId, }) as any, getOwnWrapperData: ( path: T.EnsureWrapperDataPath, ) => getWrapperData(effects, path as any) as any, setOwnWrapperData: ( path: T.EnsureWrapperDataPath, value: ExtractWrapperData, ) => effects.setWrapperData({ value, path: path as any }), checkPortListening: checkPortListening.bind(null, effects), checkWebUrl: checkWebUrl.bind(null, effects), bindLan: async (port: number) => LocalPort.bindLan(effects, port), networkBuilder: () => NetworkBuilder.of(effects), torHostName: (id: string) => TorHostname.of(effects, id), }) type NeverPossible = { [affine]: string } export type NoAny = NeverPossible extends A ? keyof NeverPossible extends keyof A ? never : A : A