Function makeSQLStoreInt

packages/infra/src/Store/SQL.ts:67–386

(system: DbSystem, dialect: SQLDialect, jsonColumnType: string)

      try {
        result[key] = JSON.parse(value)
      } catch {
        result[key] = value
      }
    } else {
      result[key] = value
    }
  }
  return result
}

function makeSQLStoreInt(system: DbSystem, dialect: SQLDialect, jsonColumnType: string) {
  return Effect.fnUntraced(function*({ prefix }: StorageConfig) {
    const sql = yield* SqlClient.SqlClient
    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 ensureTable = sql
          .unsafe(
            `CREATE TABLE IF NOT EXISTS "${tableName}" (id TEXT NOT NULL, _namespace TEXT NOT NULL DEFAULT 'primary', _etag TEXT, data ${jsonColumnType} NOT NULL, PRIMARY KEY (id, _namespace))`
          )
          .pipe(
            Effect.andThen(
              sql.unsafe(
                `CREATE TABLE IF NOT EXISTS "_migrations" (id TEXT NOT NULL, version TEXT NOT NULL, PRIMARY KEY (id, version))`
              )
            ),
            Effect.orDie,
            Effect.asVoid
          )

        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 = (query: string, params?: readonly unknown[]) =>
          sql.unsafe(query, params as any).pipe(Effect.mapError(toDatabaseError))