(accountID: AccountID, orgID: Option.Option<OrgID>)
| 57 | }) |
| 58 | |
| 59 | const state = (accountID: AccountID, orgID: Option.Option<OrgID>) => { |
| 60 | const id = Option.getOrNull(orgID) |
| 61 | return db |
| 62 | .insert(AccountStateTable) |
| 63 | .values({ id: ACCOUNT_STATE_ID, active_account_id: accountID, active_org_id: id }) |
| 64 | .onConflictDoUpdate({ |
| 65 | target: AccountStateTable.id, |
| 66 | set: { active_account_id: accountID, active_org_id: id }, |
| 67 | }) |
| 68 | .run() |
| 69 | } |
| 70 | |
| 71 | const active = Effect.fn("AccountRepo.active")(() => |
| 72 | query(current()).pipe(Effect.map((row) => (row ? Option.some(decode(row)) : Option.none()))), |
no test coverage detected