Function makeSeedEffect

packages/infra/src/Store/Cosmos.ts:141–183

(ns: string)

      const ctx = yield* Effect.context<R>()
      const seedCache = new Map<string, Effect.Effect<void>>()
      const makeSeedEffect = (ns: string) => {
        const markerId = ns === "primary" ? importedMarkerId : `${importedMarkerId}::${ns}`
        return Effect
          .promise(() =>
            container
              .item(markerId, markerId)
              .read<{ id: string }>()
              .then(({ resource }) => Option.fromNullishOr(resource))
          )
          .pipe(
            Effect.flatMap((marker) => {
              if (Option.isSome(marker)) return Effect.void
              return InfraLogger.logInfo(`Creating mock data for ${name} (namespace: ${ns})`).pipe(
                Effect.andThen(seed!),
                Effect.flatMap((m) =>
                  Effect.flatMapOption(
                    Effect.succeed(toNonEmptyArray([...m])),
                    (a) => bulkSetInternal(a, ns).pipe(Effect.orDie)
                  )
                ),
                Effect.andThen(
                  Effect.promise(() =>
                    container.items.create({
                      _partitionKey: markerId,
                      id: markerId,
                      ttl: -1
                    })
                  )
                ),
                Effect.provide(ctx),
                Effect.orDie
              )
            }),
            Effect.withLogSpan(`Cosmos.seedCheck ${name} in ${ns} [effect-app/infra/Store]`),
            annotateDb({
              operation: "seed",
              system: "cosmosdb",
              collection: containerId,
              namespace: ns,
              entity: name
            })
          )
      }
      const seedNamespace = Effect.fn("seedNamespace")(function*(ns: string) {
        if (!seed) return
        let cached = seedCache.get(ns)