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