Function makeStorage

packages/sql/src/SqlEventLogServer.ts:24–204

(options?: {
  readonly entryTablePrefix?: string
  readonly remoteIdTable?: string
  readonly insertBatchSize?: number
})

 * @category constructors
 */
export const makeStorage = (options?: {
  readonly entryTablePrefix?: string
  readonly remoteIdTable?: string
  readonly insertBatchSize?: number
}): Effect.Effect<
  typeof EventLogServer.Storage.Service,
  SqlError,
  SqlClient.SqlClient | EventLogEncryption | Scope
> =>
  Effect.gen(function*() {
    const encryptions = yield* EventLogEncryption
    const sql = yield* SqlClient.SqlClient

    const tablePrefix = options?.entryTablePrefix ?? "effect_events"
    const remoteIdTable = options?.remoteIdTable ?? "effect_remote_id"
    const insertBatchSize = options?.insertBatchSize ?? 200

    yield* sql.onDialectOrElse({
      pg: () =>
        sql`CREATE TABLE IF NOT EXISTS ${sql(remoteIdTable)} (
            remote_id BYTEA PRIMARY KEY
          )`.withoutTransform,
      mysql: () =>
        sql`
          CREATE TABLE IF NOT EXISTS ${sql(remoteIdTable)} (
            remote_id BINARY(16) PRIMARY KEY
          )`.withoutTransform,
      mssql: () =>
        sql`
          CREATE TABLE IF NOT EXISTS ${sql(remoteIdTable)} (
            remote_id VARBINARY(16) PRIMARY KEY
          )`.withoutTransform,
      orElse: () =>
        sql`
          CREATE TABLE IF NOT EXISTS ${sql(remoteIdTable)} (
            remote_id BLOB PRIMARY KEY
          )`.withoutTransform
    })
    const remoteId = yield* sql<{ remote_id: Uint8Array }>`SELECT remote_id FROM ${sql(remoteIdTable)}`.pipe(
      Effect.flatMap((results) => {
        if (results.length > 0) {
          return Effect.succeed(RemoteId.make(results[0].remote_id))
        }
        const newRemoteId = makeRemoteId()
        return Effect.as(
          sql`INSERT INTO ${sql(remoteIdTable)} (remote_id) VALUES (${newRemoteId})`,
          RemoteId.make(newRemoteId)
        )
      })
    )

    const resources = yield* RcMap.make({
      lookup: (publicKey: string) =>
        Effect.gen(function*() {
          const publicKeyHash = (yield* encryptions.sha256String(new TextEncoder().encode(publicKey))).slice(0, 16)
          const table = `${tablePrefix}_${publicKeyHash}`

          yield* sql.onDialectOrElse({