| 173 | |
| 174 | export const makeFumaClient = (db: FumaDb, options: MakeFumaClientOptions = {}): IFumaClient => { |
| 175 | const use: IFumaClient["use"] = (label, fn) => |
| 176 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => |
| 177 | fumaEffect(label, () => fn(makeSafeFumaQuery(active ?? db, options))), |
| 178 | ).pipe(Effect.withSpan(`fumadb.${label}`)); |
| 179 | |
| 180 | const transaction = <A, E>(effect: Effect.Effect<A, E>): Effect.Effect<A, E | StorageFailure> => |
| 181 | Effect.flatMap(Effect.service(activeFumaDbRef), (active) => { |