Function make

packages/effect-app/src/Model/Repository/internal/internal.ts:71–628

(
      args: [Evt] extends [never] ? {
          schemaContext?: Context.Context<RCtx>
          makeInitial?: Effect.Effect<readonly T[], E, RInitial> | undefined
          config?: Omit<StoreConfig<Encoded>, "partitionValue"> & {
            partitionValue?: (e?: Encoded) => string
          }
        }
        : {
          schemaContext?: Context.Context<RCtx>
          publishEvents: (evt: NonEmptyReadonlyArray<Evt>) => Effect.Effect<void, never, RPublish>
          makeInitial?: Effect.Effect<readonly T[], E, RInitial> | undefined
          config?: Omit<StoreConfig<Encoded>, "partitionValue"> & {
            partitionValue?: (e?: Encoded) => string
          }
        }
    )

})

const entityStateFromItems = (items: readonly unknown[]): string | undefined => {
  const first = items[0]
  if (first === null || typeof first !== "object" || !("_tag" in first)) return undefined
  const tag = (first as { readonly _tag: unknown })._tag
  return typeof tag === "string" ? tag : undefined
}

const timeSchema = (
  operation: "decode" | "encode",
  entity: string,
  queryMode: "aggregate" | "collect" | "project" | "transform" | undefined,
  itemCount: number,
  entityState?: string
) =>
<A, E, R>(self: Effect.Effect<A, E, R>): Effect.Effect<A, E, R> =>
  Effect.clockWith((clock) => {
    const startedAt = clock.currentTimeNanosUnsafe()
    const attributes = {
      "app.entity": entity,
      "app.schema.operation": operation,
      ...(queryMode !== undefined && { "app.query.mode": queryMode }),
      ...(entityState !== undefined && { "app.entity.state": entityState })
    }
    return Effect.onExit(self, () => {
      const durationMs = Number(clock.currentTimeNanosUnsafe() - startedAt) / 1_000_000
      const slow = durationMs >= SCHEMA_SLOW_MS
      return Effect.all([
        Effect.annotateCurrentSpan({
          [`app.schema.${operation}.duration_ms`]: durationMs,
          "app.schema.item_count": itemCount,
          "app.schema.slow": slow,
          ...(queryMode !== undefined && { "app.query.mode": queryMode }),
          ...(entityState !== undefined && { "app.entity.state": entityState })
        }),
        Metric.update(
          Metric.withAttributes(
            operation === "decode" ? schemaDecodeDuration : schemaEncodeDuration,
            attributes
          ),
          durationMs
        ),
        Metric.update(Metric.withAttributes(schemaItemCount, attributes), itemCount),
        ...(slow
          ? [Metric.update(Metric.withAttributes(schemaSlow, attributes), 1)] as const
          : [])
      ], { discard: true })
    })
  })

/**
 * A base implementation to create a repository.
 */
export function makeRepoInternal<
  Evt = never
>() {
  return <
    ItemType extends string,
    R,