Class SomethingRepo

packages/infra/test/rawQuery.test.ts:66–120

// @effect-diagnostics-next-line missingEffectServiceDependency:off
class SomethingRepo extends Context.Service<SomethingRepo>()(
  "SomethingRepo",
  {
    make: Effect.gen(function*() {
      const partitionKey = "test-" + new Date().getTime()
      return yield* makeRepo("Something", Something, { config: { partitionValue: () => partitionKey } })
    })
  }
) {
  static readonly layer = Layer
    .effect(
      SomethingRepo,
      Effect.gen(function*() {
        const partitionKey = "test-" + new Date().getTime()
        const repo = SomethingRepo.of(
          yield* makeRepo("Something", Something, {
            config: { partitionValue: () => partitionKey }
          })
        )
        // not using makeInitial, because it will prevent inserting the various partitionkeyed items
        yield* repo.saveAndPublish(items).pipe(setupRequestContextFromCurrent("init"))
        return repo
      })
    )
  static readonly Test = this
    .layer
    .pipe(
      Layer.provide(Layer.merge(MemoryStoreLive, RepositoryRegistryLive))
    )

  static readonly TestCosmos = this
    .layer
    .pipe(
      Layer.provide(
        Effect
          .gen(function*() {
            const url = yield* Config.redacted("STORAGE_URL").pipe(
              Config.withDefault(
                Redacted.make(
                  // the emulator doesn't implement array projections :/ so you need an actual cloud instance!
                  "AccountEndpoint=http://localhost:8081/;AccountKey=C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw=="
                )
              )
            )
            return CosmosStoreLayer({
              dbName: "test",
              prefix: "",
              url
            })
              .pipe(Layer.merge(RepositoryRegistryLive))
          })
          .pipe(Layer.unwrap)
      )
    )
}

describe("select first-level array fields", () => {
  const test = Effect