Function createContainer

packages/infra/src/ClusterCosmos.ts:347–360

(prefix: string)

const machineIdCounterDocId = cosmosId("machine-id-counter")

const createContainer = (prefix: string) =>
  Effect.fnUntraced(function*() {
    const { db } = yield* CosmosClient
    const containerId = `${prefix}cluster`
    yield* Effect
      .tryPromise(() =>
        db.containers.create({
          id: containerId,
          partitionKey: { paths: ["/_partitionKey"], version: 2 }
        })
      )
      .pipe(Effect.catchIf(isConflict, () => Effect.void))
    return db.container(containerId)
  })

export const makeMessageStorage = Effect.fnUntraced(function*(options?: {
  readonly prefix?: string | undefined