feat: switch to lexoffice

Author: jroehl

.github/workflows/deploy.yml

@@ -58,7 +58,7 @@ jobs:
           echo "Running ${{ env.ENV }} mode (${{ github.ref }})"
 
           echo "TOGGL_API_TOKEN=${{ secrets.TOGGL_API_TOKEN }}" >> ${GITHUB_ENV}
-          echo "DEBITOOR_API_TOKEN=${{ secrets.DEBITOOR_API_TOKEN }}" >> ${GITHUB_ENV}
+          echo "LEXOFFICE_API_TOKEN=${{ secrets.LEXOFFICE_API_TOKEN }}" >> ${GITHUB_ENV}
           echo "CONTENTFUL_ACCESS_TOKEN=${{ secrets.CONTENTFUL_ACCESS_TOKEN }}" >> ${GITHUB_ENV}
           echo "CONTENTFUL_SPACE_ID=${{ secrets.CONTENTFUL_SPACE_ID }}" >> ${GITHUB_ENV}
 

serverless.ts

@@ -31,7 +31,7 @@ const serverlessConfiguration: AWS = {
       AWS_NODEJS_CONNECTION_REUSE_ENABLED: '1',
       STAGE: '${self:provider.stage}',
       TOGGL_API_TOKEN: '${env:TOGGL_API_TOKEN}',
-      DEBITOOR_API_TOKEN: '${env:DEBITOOR_API_TOKEN}',
+      LEXOFFICE_API_TOKEN: '${env:LEXOFFICE_API_TOKEN}',
       CONTENTFUL_SPACE_ID: '${env:CONTENTFUL_SPACE_ID}',
       CONTENTFUL_ACCESS_TOKEN: '${env:CONTENTFUL_ACCESS_TOKEN}',
       CONTENTFUL_ENVIRONMENT_ID: '${env:CONTENTFUL_ENVIRONMENT_ID, "master"}',

src/functions/debitoor/handler.ts

@@ -1,3 +1,3 @@
-export { default as debitoor } from './debitoor';
+export { default as invoicing } from './invoicing';
 export { default as sheet } from './sheet';
 export { default as syncContentful } from './sync-contentful';

src/functions/index.ts

@@ -0,0 +1,92 @@
+import {
+  httpResponse,
+  ValidatedEventAPIGatewayProxyEvent,
+} from '@libs/apiGateway';
+import { LABEL_BILLED } from '@libs/constants';
+import { middyfy } from '@libs/lambda';
+import { createInvoices, isErrorResponse } from '@libs/lexoffice';
+import {
+  bulkAddBilledTag,
+  enrichTimeEntries,
+  fetchTimeEntriesBetween,
+  filterClientTimeEntriesByCustomer,
+  filterTimeEntriesByLabel,
+  sanitizeTimeEntries,
+} from '@libs/toggl';
+import { clearCaches, getConfig, Logger } from '@libs/utils';
+import 'source-map-support/register';
+import { ErrorResponse, Invoice } from '../../libs/lexoffice-types';
+import schema from '../schema';
+
+const handler: ValidatedEventAPIGatewayProxyEvent<typeof schema> = async (
+  event
+) => {
+  try {
+    const config = getConfig(event.body, (event as any).usePreviousMonth);
+    const {
+      dryRun,
+      setBilled,
+      labelWhitelist,
+      labelBlacklist,
+      customerWhitelist,
+      customerBlacklist,
+      time,
+    } = config;
+
+    const timeEntries = await fetchTimeEntriesBetween(
+      time.fromAsISO,
+      time.toAsISO
+    );
+
+    const billableTimeEntries = filterTimeEntriesByLabel(
+      timeEntries,
+      labelWhitelist,
+      [...(labelBlacklist || []), LABEL_BILLED]
+    );
+    const sanitizedTimeEntries = sanitizeTimeEntries(billableTimeEntries);
+
+    let customerTimeEntries = await enrichTimeEntries(sanitizedTimeEntries);
+    customerTimeEntries = filterClientTimeEntriesByCustomer(
+      customerTimeEntries,
+      customerWhitelist,
+      customerBlacklist
+    );
+
+    let invoices: Invoice[] = [];
+    let erroneous: ErrorResponse[] = [];
+    if (!dryRun) {
+      const results = await createInvoices(customerTimeEntries, config);
+
+      erroneous = (results.filter(
+        isErrorResponse
+      ) as unknown) as ErrorResponse[];
+      invoices = (results.filter(
+        (draftInvoice) => !isErrorResponse(draftInvoice)
+      ) as unknown) as Invoice[];
+
+      if (setBilled) {
+        await bulkAddBilledTag(sanitizedTimeEntries);
+      }
+    }
+
+    delete config.time;
+
+    return httpResponse(
+      200,
+      `Created billing task with ${customerTimeEntries.length} subtask(s)`,
+      {
+        config,
+        invoices: invoices,
+        customerTimeEntries: dryRun ? customerTimeEntries : null,
+        erroneous,
+      }
+    );
+  } catch (error) {
+    Logger.error(error);
+    return httpResponse(error.statusCode, error.message, error);
+  } finally {
+    clearCaches();
+  }
+};
+
+export const main = middyfy(handler);

src/functions/invoicing/handler.ts

@@ -8,7 +8,7 @@ export default {
     {
       http: {
         method: 'post',
-        path: 'debitoor',
+        path: 'invoicing',
         request: {
           schemas: {
             'application/json': schema,

src/functions/debitoor/index.ts renamed to src/functions/invoicing/index.ts

@@ -2,23 +2,22 @@ import {
   httpResponse,
   ValidatedEventAPIGatewayProxyEvent,
 } from '@libs/apiGateway';
-import {
-  updateDebitoorCustomers,
-  updateDebitoorProducts,
-} from '@libs/debitoor';
 import { middyfy } from '@libs/lambda';
-import { updateTogglClients, updateTogglProjects } from '@libs/toggl';
+import * as lexoffice from '@libs/lexoffice';
+import * as toggl from '@libs/toggl';
 import { clearCaches, Logger } from '@libs/utils';
 import 'source-map-support/register';
 
 const handler: ValidatedEventAPIGatewayProxyEvent<unknown> = async () => {
   try {
-    await updateDebitoorProducts();
-    await updateDebitoorCustomers();
-    await updateTogglClients();
-    await updateTogglProjects();
+    await lexoffice.updateCustomers();
+    await toggl.updateClients();
+    await toggl.updateProjects();
 
-    return httpResponse(200, `Updated debitoor and toggl with contentful data`);
+    return httpResponse(
+      200,
+      `Updated lexoffice and toggl with contentful data`
+    );
   } catch (error) {
     Logger.error(error);
     return httpResponse(error.statusCode, error.message, error);