| 150 | |
| 151 | export const makeFumaClient = (db: FumaDb, options: MakeFumaClientOptions = {}): IFumaClient => { |
| 152 | const use: IFumaClient["use"] = (label, fn) => |
| 153 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => |
| 154 | fumaEffect(label, () => fn(makeSafeFumaQuery(active ?? db, options))), |
| 155 | ).pipe(Effect.withSpan(`fumadb.${label}`)); |
| 156 | |
| 157 | const transaction = <A, E>(effect: Effect.Effect<A, E>): Effect.Effect<A, E | StorageFailure> => |
| 158 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => { |