feat: add banking list categories endpoint

connectors/connector-qbo/index.ts

@@ -2,3 +2,4 @@
 export * from './def'
 export * from './server'
 // codegen:end
+export * from '@opensdks/sdk-qbo'

connectors/connector-qbo/server.ts

@@ -13,6 +13,8 @@ function initQBOSdk(options: QBOSDKTypes['options']) {
  return {realmId: options.realmId, ...sdk}
 }
 
+export type QBOSDK = ReturnType<typeof initQBOSdk>
+
 export const qboServer = {
  newInstance: ({config, settings, fetchLinks}) => {
  const qbo = initQBOSdk({

docs/samples/banking-test.ts

@@ -0,0 +1,20 @@
+import {createVeniceClient} from '@usevenice/sdk'
+
+const venice = createVeniceClient({
+ apiKey: process.env['_VENICE_API_KEY'],
+ apiHost: process.env['_VENICE_API_HOST'],
+ resourceId: process.env['_QBO_RESOURCE_ID'],
+})
+
+void venice.GET('/verticals/banking/category').then((r) => {
+ console.log(r.data)
+})
+
+// void venice
+// .POST('/core/resource/{id}/source_sync', {
+// params: {path: {id: process.env['_APOLLO_RESOURCE_ID']!}},
+// body: {streams: {contact: true}},
+// })
+// .then((r) => {
+// console.log(r.data)
+// })

packages/engine-backend/router/index.ts

@@ -4,10 +4,12 @@ import type {inferRouterInputs, inferRouterOutputs} from '@trpc/server'
 import {
  apolloAdapter,
  createAccountingRouter,
+ createBankingRouter,
  createInvestmentRouter,
  createPtaRouter,
  createSalesEngagementRouter,
  outreachAdapter,
+ qboAdapter,
  salesloftAdapter,
 } from '@usevenice/cdk/verticals'
 import {remoteProcedure, trpc} from './_base'
@@ -21,6 +23,11 @@ import {publicRouter} from './publicRouter'
 import {resourceRouter} from './resourceRouter'
 import {systemRouter} from './systemRouter'
 
+const bankingRouter = createBankingRouter({
+ trpc,
+ remoteProcedure,
+ adapterByName: {qbo: qboAdapter},
+})
 const accountingRouter = createAccountingRouter({
  trpc,
  remoteProcedure,
@@ -60,6 +67,7 @@ export const routers = {
  pta: ptaRouter,
  investment: investmentRouter,
  salesEngagement: salesEngagementRouter,
+ banking: bankingRouter,
 }
 
 // Which one is best?
@@ -81,6 +89,7 @@ export const flatRouter = trpc.mergeRouters(
  pta: ptaRouter,
  investment: investmentRouter,
  salesEngagement: salesEngagementRouter,
+ banking: bankingRouter,
  }),
  }),
 )

verticals/vertical-banking/adapters/qbo-adapter.ts

@@ -0,0 +1,32 @@
+import type {QBOSDK, QBOSDKTypes} from '@usevenice/connector-qbo'
+import type {StrictObj} from '@usevenice/vdk'
+import {mapper, z, zCast} from '@usevenice/vdk'
+import type {VerticalBanking} from '../banking'
+import {zBanking} from '../banking'
+
+type QBO = QBOSDKTypes['oas']['components']['schemas']
+
+const mappers = {
+ category: mapper(
+ zCast<StrictObj<QBO['Account']>>(),
+ zBanking.category.extend({_raw: z.unknown().optional()}),
+ {
+ id: 'Id',
+ name: 'FullyQualifiedName',
+ _raw: (a) => a,
+ },
+ ),
+}
+
+export const qboAdapter = {
+ listCategories: async ({instance}) => {
+ const res = await instance.query(
+ // QBO API does not support OR in SQL query...
+ "SELECT * FROM Account WHERE Classification IN ('Revenue', 'Expense')",
+ )
+ return {
+ hasNextPage: false,
+ items: (res.Account ?? []).map(mappers.category),
+ }
+ },
+} satisfies VerticalBanking<{instance: QBOSDK}>