@mojaloop/accounts-and-balances-bc-builtin-ledger-grpc-client-lib
v0.6.1
Published
Accounts and Balances BC - gRPC Client Library
Downloads
47
Keywords
Readme
Accounts and Balances gRPC Client Library
This is the gRPC client library for the Accounts and Balances bounded context.
It allows for the following operations:
- Create account: create a single account.
- Create journal entries: create 1 or more journal entries.
- Get account by id: get an account by id.
- Get accounts by external id: get all the accounts with a specific external id.
- Get journal entries by account id: get all the journal entries with a specific account id - either the debited account id or the credited account id.
Install
$ npm install @mojaloop/accounts-and-balances-bc-grpc-client-lib @mojaloop/logging-bc-client-lib
Usage
Configure and Initialize
import {ILogger} from "@mojaloop/logging-bc-public-types-lib";
import {DefaultLogger} from "@mojaloop/logging-bc-client-lib";
import {GrpcClient} from "@mojaloop/accounts-and-balances-bc-grpc-client-lib";
const BOUNDED_CONTEXT_NAME: string = "some-bc";
const SERVICE_NAME: string = "some-svc";
const SERVICE_VERSION: string = "0.0.1";
const ACCOUNTS_AND_BALANCES_GRPC_SERVICE_HOST: string = "localhost";
const ACCOUNTS_AND_BALANCES_GRPC_SERVICE_PORT_NO: number = 5678;
const ACCOUNTS_AND_BALANCES_GRPC_CLIENT_TIMEOUT_MS: number = 5000;
const logger: ILogger = new DefaultLogger(BOUNDED_CONTEXT_NAME, SERVICE_NAME, SERVICE_VERSION);
const grpcClient: GrpcClient = new GrpcClient(
logger,
ACCOUNTS_AND_BALANCES_GRPC_SERVICE_HOST,
ACCOUNTS_AND_BALANCES_GRPC_SERVICE_PORT_NO,
ACCOUNTS_AND_BALANCES_GRPC_CLIENT_TIMEOUT_MS
);
await grpcClient.init();
Destroy
await grpcClient.destroy();
Create Account
const accountDto: IAccountDto = {
id: null,
externalId: null,
state: AccountState.ACTIVE,
type: AccountType.POSITION,
currencyCode: "EUR",
currencyDecimals: null,
debitBalance: "0",
creditBalance: "0",
timestampLastJournalEntry: null
};
try {
const accountId: string = await grpcClient.createAccount(accountDto);
} catch (error: unknown) {
logger.error(error);
}
Create Journal Entries
// Before creating a journal entry, the respective accounts need to be created.
// Account A.
const accountDtoA: IAccountDto = {
id: null,
externalId: null,
state: AccountState.ACTIVE,
type: AccountType.POSITION,
currencyCode: "EUR",
currencyDecimals: null,
debitBalance: "0",
creditBalance: "0",
timestampLastJournalEntry: null
};
const idAccountA: string = await grpcClient.createAccount(accountDtoA);
// Account B.
const accountDtoB: IAccountDto = {
id: null,
externalId: null,
state: AccountState.ACTIVE,
type: AccountType.POSITION,
currencyCode: "EUR",
currencyDecimals: null,
debitBalance: "0",
creditBalance: "0",
timestampLastJournalEntry: null
};
const idAccountB: string = await grpcClient.createAccount(accountDtoB);
// TODO: credit accounts A and B with an hub account.
// Journal entry A.
const journalEntryDtoA: IJournalEntryDto = {
id: null,
externalId: null,
externalCategory: null,
currencyCode: "EUR",
currencyDecimals: null,
amount: "5",
debitedAccountId: idAccountA,
creditedAccountId: idAccountB,
timestamp: null
};
// Journal entry B.
const journalEntryDtoB: IJournalEntryDto = {
id: null,
externalId: null,
externalCategory: null,
currencyCode: "EUR",
currencyDecimals: null,
amount: "5",
debitedAccountId: idAccountB,
creditedAccountId: idAccountA,
timestamp: null
};
try {
const idsJournalEntries: string[] = await grpcClient.createJournalEntries([journalEntryDtoA, journalEntryDtoB]);
} catch (error: unknown) {
logger.error(error);
}
Get Account by Id
const accountId: string = "a";
try {
const accountDto: IAccountDto | null = await grpcClient.getAccountById(accountId);
} catch (error: unknown) {
logger.error(error);
}
Get Accounts by External Id
const externalId: string = "a";
try {
const accountDtos: IAccountDto[] = await grpcClient.getAccountsByExternalId(externalId);
} catch (error: unknown) {
logger.error(error);
}
Get Journal Entries by Account Id
const accountId: string = "a";
try {
const journalEntryDtos: IJournalEntryDto[] = await grpcClient.getJournalEntriesByAccountId(accountId);
} catch (error: unknown) {
logger.error(error);
}