| 348 | |
| 349 | export const makeFumaClient = (db: FumaDb, options: MakeFumaClientOptions = {}): IFumaClient => { |
| 350 | const use: IFumaClient["use"] = (label, fn) => |
| 351 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => |
| 352 | fumaEffect(label, () => fn(makeSafeFumaQuery(active ?? db, options))), |
| 353 | ).pipe(Effect.withSpan(`fumadb.${label}`)); |
| 354 | |
| 355 | const transaction = <A, E>(effect: Effect.Effect<A, E>): Effect.Effect<A, E | StorageFailure> => |
| 356 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => { |