Function tryCosmos

packages/infra/src/Store/Cosmos.ts:51–60

(f: () => Promise<A>)

// `DatabaseError` (transient-classified) instead of a bare-`Error` defect — the
// latter both bypasses retry and breaks JSON encoding of the failure channel.
const tryCosmos = <A>(f: () => Promise<A>): Effect.Effect<A, DatabaseError> =>
  Effect.tryPromise({
    try: f,
    catch: (e) =>
      new DatabaseError({
        message: `Cosmos request failed: ${e instanceof Error ? e.message : String(e)}`,
        transient: thrownIsTransient(e),
        cause: e
      })
  })

const respBytes = (
  resp: { diagnostics?: { clientSideRequestStatistics?: { totalResponsePayloadLengthInBytes?: number } } }