function use<T>(f: (db: DB) => Promise<T>) {
return Effect.tryPromise({
try: () => f(db),
catch(error) {
if (error instanceof postgres.PostgresError) {
return new DbError({ pgError: error });
}
return new UnknownException(error);
},
});
}
function use<T>(f: (db: DB) => Promise<T>) {
return Effect.tryPromise({
try: () => f(db),
catch(error) {
if (error instanceof postgres.PostgresError) {
return new DbError({ pgError: error });
}
return new UnknownException(error);
},
});
}