feat: tweaks in disconnecting bank account

This commit is contained in:
Ahmed Bouhuolia
2024-07-29 16:55:50 +02:00
parent 1a01461f5d
commit f6d4ec504f
4 changed files with 28 additions and 24 deletions

View File

@@ -7,6 +7,7 @@ import HasTenancyService from '@/services/Tenancy/TenancyService';
import UnitOfWork from '@/services/UnitOfWork';
import events from '@/subscribers/events';
import { ERRORS } from './types';
import { ACCOUNT_TYPE } from '@/data/AccountTypes';
@Service()
export class DisconnectBankAccount {
@@ -31,7 +32,7 @@ export class DisconnectBankAccount {
// Retrieve the bank account or throw not found error.
const account = await Account.query()
.findById(bankAccountId)
.whereIn('account_type', ['bank', 'cash'])
.whereIn('account_type', [ACCOUNT_TYPE.CASH, ACCOUNT_TYPE.BANK])
.throwIfNotFound();
const oldPlaidItem = await PlaidItem.query().findById(account.plaidItemId);

View File

@@ -1,19 +1,19 @@
import { Inject, Service } from 'typedi';
import { ServiceError } from '@/exceptions';
import { PlaidClientWrapper } from '@/lib/Plaid';
import HasTenancyService from '@/services/Tenancy/TenancyService';
import UnitOfWork from '@/services/UnitOfWork';
import { Inject } from 'typedi';
import { ERRORS } from './types';
@Service()
export class RefreshBankAccountService {
@Inject()
private tenancy: HasTenancyService;
@Inject()
private uow: UnitOfWork;
/**
*
* Asks Plaid to trigger syncing the given bank account.
* @param {number} tenantId
* @param {number} bankAccountId
* @returns {Promise<void>}
*/
public async refreshBankAccount(tenantId: number, bankAccountId: number) {
const { Account } = this.tenancy.models(tenantId);
@@ -23,17 +23,14 @@ export class RefreshBankAccountService {
.withGraphFetched('plaidItem')
.throwIfNotFound();
// Can't continue if the given account is not linked with Plaid item.
if (!bankAccount.plaidItem) {
throw new ServiceError('');
throw new ServiceError(ERRORS.BANK_ACCOUNT_NOT_CONNECTED);
}
const plaidInstance = new PlaidClientWrapper();
const data = await plaidInstance.transactionsRefresh({
await plaidInstance.transactionsRefresh({
access_token: bankAccount.plaidItem.plaidAccessToken,
});
await Account.query().findById(bankAccountId).patch({
isFeedsActive: true,
lastFeedsUpdatedAt: new Date(),
});
}
}

View File

@@ -1,8 +1,8 @@
import { Inject, Service } from 'typedi';
import { IAccountEventDeletedPayload } from '@/interfaces';
import { PlaidClientWrapper } from '@/lib/Plaid';
import HasTenancyService from '@/services/Tenancy/TenancyService';
import events from '@/subscribers/events';
import { Inject, Service } from 'typedi';
@Service()
export class DisconnectPlaidItemOnAccountDeleted {