Function makeSQLiteStorePerNs

packages/infra/src/Store/SQL.ts:393–715

(
  withNsSql: WithNsSqlFn,
  { prefix }: StorageConfig
)

        // Eagerly seed primary namespace on initialization. A seed failure at
        // construction is fatal (orDie); the per-call `seedNamespace` still
        // surfaces DatabaseError to callers.
        yield* seedNamespace("primary").pipe(Effect.orDie)

        return s
      })
    }
  })
}

type WithNsSqlFn = <A, E2, R2>(
  ns: string,
  f: (sql: SqlClient.SqlClient) => Effect.Effect<A, E2, R2>
) => Effect.Effect<A, E2, R2>

function makeSQLiteStorePerNs(
  withNsSql: WithNsSqlFn,
  { prefix }: StorageConfig
) {
  return {
    make: Effect.fnUntraced(function*<IdKey extends keyof Encoded, Encoded extends FieldValues, R = never, E = never>(
      name: string,
      idKey: IdKey,
      seed?: Effect.Effect<Iterable<Encoded>, E, R>,
      config?: StoreConfig<Encoded>
    ) {
      type PM = PersistenceModelType<Encoded>
      const tableName = `${prefix}${name}`
      const defaultValues = config?.defaultValues ?? {}

      const resolveNamespace = !config?.allowNamespace
        ? Effect.succeed("primary")
        : storeId.pipe(Effect.map((namespace) => {
          if (namespace !== "primary" && !config.allowNamespace!(namespace)) {
            throw new Error(`Namespace ${namespace} not allowed!`)
          }
          return namespace
        }))

      const toRow = (e: PM) => {
        const newE = makeETag(e)
        const id = newE[idKey] as string
        const { _etag, [idKey]: _id, ...rest } = newE as any
        const data = JSON.stringify(rest)
        return { id, _etag: newE._etag!, data, item: newE }
      }

      const exec = (ns: string, query: string, params?: readonly unknown[]) =>
        withNsSql(ns, (sql) => sql.unsafe(query, params as any).pipe(Effect.mapError(toDatabaseError)))

      const ensureTable = (ns: string) =>
        withNsSql(ns, (sql) =>
          sql
            .unsafe(
              `CREATE TABLE IF NOT EXISTS "${tableName}" (id TEXT NOT NULL PRIMARY KEY, _etag TEXT, data JSON NOT NULL)`
            )
            .pipe(
              Effect.andThen(