| 292 | |
| 293 | export const makeFumaClient = (db: FumaDb, options: MakeFumaClientOptions = {}): IFumaClient => { |
| 294 | const use: IFumaClient["use"] = (label, fn) => |
| 295 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => |
| 296 | fumaEffect(label, () => fn(makeSafeFumaQuery(active ?? db, options))), |
| 297 | ).pipe(Effect.withSpan(`fumadb.${label}`)); |
| 298 | |
| 299 | const transaction = <A, E>(effect: Effect.Effect<A, E>): Effect.Effect<A, E | StorageFailure> => |
| 300 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => { |