Function makeStore

packages/effect-app/src/Model/Repository/internal/internal.ts:644–707

()

                Effect.annotateCurrentSpan({
                  "app.query.ttype": a.ttype,
                  "app.query.mode": a.mode,
                  "db.response.returned_rows": Array.isArray(r) ? r.length : 1
                })
              ),
              Effect.tap(() => recordQueryRead),
              Effect.withSpan("Repository.query", {
                kind: "client",
                attributes: { "app.entity": name }
              }, { captureStackTrace: false })
            )
          }) as any

          const validateSample = Effect.fn("Repository.validateSample", { attributes: { "app.entity": name } })(
            function*(options?: {
              percentage?: number
              maxItems?: number
            }) {
              const percentage = options?.percentage ?? 0.1 // default 10%
              const maxItems = options?.maxItems

              // 1. get all IDs with projection (bypasses main schema decode)
              const allIds = yield* store
                .filter({
                  t: null as unknown as Encoded,
                  select: [idKey as keyof Encoded]
                })
                .pipe(Effect.withSpan("Repository.filter", {
                  kind: "client",
                  attributes: { "app.entity": name }
                }, { captureStackTrace: false }))

              // 2. random subset
              const shuffled = [...allIds].sort(() => Math.random() - 0.5)
              const sampleSize = Math.min(
                maxItems ?? Infinity,
                Math.ceil(allIds.length * percentage)
              )
              const sample = shuffled.slice(0, sampleSize)

              // 3. validate each item
              const errors: ValidationError[] = []

              for (const item of sample) {
                const id = item[idKey]
                const rawResult = yield* store.find(id).pipe(
                  Effect.withSpan("Repository.find", {
                    kind: "client",
                    attributes: { "app.entity": name, "app.entity.id": id }
                  }, { captureStackTrace: false })
                )

                if (Option.isNone(rawResult)) continue

                const rawData = rawResult.value as Encoded
                const jitMResult = mapFrom(rawData) // apply jitM

                const decodeResult = yield* S.decodeEffectConcurrently(schema)(jitMResult).pipe(
                  Effect.result,