Function batchSet

packages/infra/src/Store/Cosmos.ts:304–375

(items: NonEmptyReadonlyArray<PM>)

        resolveNamespace.pipe(Effect.flatMap((ns) => bulkSetInternal(items, ns)))

      const batchSet = (items: NonEmptyReadonlyArray<PM>) => {
        return resolveNamespace
          .pipe(Effect.flatMap((ns) =>
            Effect
              .suspend(() => {
                const batch = [...items].map(
                  (x) =>
                    [
                      x,
                      Option.match(Option.fromNullishOr(x._etag), {
                        onNone: () => ({
                          operationType: "Create" as const,
                          resourceBody: {
                            ...Struct.omit(x, ["_etag", idKey]),
                            id: x[idKey],
                            _partitionKey: nsPartitionValue(ns, x)
                          }
                          // don't use this or we get an error that the request and some item partition key dont match - makese no sense
                          // partitionKey: config?.partitionValue(x)
                        }),
                        onSome: (eTag) => ({
                          operationType: "Replace" as const,
                          id: x[idKey],
                          resourceBody: {
                            ...Struct.omit(x, ["_etag", idKey]),
                            id: x[idKey],
                            _partitionKey: nsPartitionValue(ns, x)
                          },
                          // don't use this or we get an error that the request and some item partition key dont match - makese no sense
                          // partitionKey: config?.partitionValue(x)
                          ifMatch: eTag
                        })
                      })
                    ] as const
                )

                const ex = batch.map(([, c]) => c)

                return tryCosmos(() => execBatch(ex, ex[0]?.resourceBody._partitionKey))
                  .pipe(Effect.flatMap(Effect.fnUntraced(function*(x) {
                    const result = x.result ?? []
                    const firstFailed = result.find(
                      (x: any) => x.statusCode > 299 || x.statusCode < 200
                    )
                    if (firstFailed) {
                      const code = firstFailed.statusCode ?? 0
                      if (code === 412 || code === 404 || code === 409) {
                        return yield* new OptimisticConcurrencyException({ type: name, id: "batch", code })
                      }

                      return yield* new DatabaseError({
                        message: "not able to update record: " + code,
                        transient: statusIsTransient(code),
                        cause: x
                      })
                    }

                    return batch.map(([e], i) => ({