feat(billing): implement billing repository and related types

- Added PaddleHttpClient module for handling HTTP requests.
- Introduced types for customer, product, transaction, and charge requests.
- Replaced payment module with billing module in index.
- Added new mail templates for invoice reminders and overages notifications.
- Created billing repository with methods for invoice and subscription management.
- Implemented queries for invoice and subscription operations.
- Updated project repository to handle project metadata and subscription queries.

Author: laken11

package-lock.json

@@ -29,6 +29,7 @@
   "dependencies": {
     "@bonadocs/di": "^1.0.0",
     "@bonadocs/logger": "^1.0.0",
+    "@paddle/paddle-node-sdk": "^2.7.0",
     "axios": "^1.7.9",
     "body-parser": "^1.20.3",
     "class-transformer": "^0.5.1",

package.json

@@ -12,9 +12,9 @@ import { rootLoggerMiddleware } from '@bonadocs/logger';
 import { AppErrorHandler, AuthMiddleware, healthcheckMiddleware, useCors } from './middleware';
 import {
   AuthController,
+  BillingController,
   ContractController,
   getConfigService,
-  PaymentController,
   ProjectController,
   SubscriptionController,
   TenderlyController,
@@ -83,7 +83,7 @@ useExpressServer(app, {
     SubscriptionController,
     ContractController,
     TenderlyController,
-    PaymentController,
+    BillingController,
   ],
   middlewares: [AppErrorHandler, AuthMiddleware],
 });

src/app.ts

@@ -0,0 +1,85 @@
+import { EventName, Paddle } from '@paddle/paddle-node-sdk';
+import { Request } from 'express';
+import { Body, JsonController, Post, Req } from 'routing-controllers';
+import { Inject, Service } from 'typedi';
+
+import { diConstants } from '@bonadocs/di';
+import { BonadocsLogger } from '@bonadocs/logger';
+
+import { ConfigService, Paddle as PaddleConfig } from '../configuration';
+import { JsonResponse } from '../shared';
+
+import { BillingSubscriptionResponse } from './billing.interface';
+import { BillingService } from './billing.service';
+import { GeneratePaymentLinkDto } from './dto/generate-payment-link.dto';
+
+@Service()
+@JsonController('/billing')
+export class BillingController {
+  constructor(
+    @Inject(diConstants.logger) private readonly logger: BonadocsLogger,
+    @Inject() private readonly billingService: BillingService,
+    @Inject() private readonly configService: ConfigService,
+  ) {}
+
+  @Post('/upgrade')
+  async create(
+    @Body({ validate: true }) payload: GeneratePaymentLinkDto,
+    @Req() request: Request,
+  ): Promise<JsonResponse<BillingSubscriptionResponse>> {
+    const authData = request.auth;
+    await this.billingService.upgradePlan(authData.projectId!, payload.planId);
+    return {
+      status: 'successful',
+      message: 'Subscription plan upgraded successfully',
+    };
+  }
+
+  @Post('/webhook')
+  async webhook(@Req() request: Request): Promise<JsonResponse<string> | void> {
+    const paddleConfigs = this.configService.getTransformed<PaddleConfig>('paddle');
+    const paddle = new Paddle(paddleConfigs.apiKey);
+    const signature = request.headers['paddle-signature'] as string;
+    const rawBody = request.body.toString();
+    const secretKey = paddleConfigs.webhookSecretKey;
+    try {
+      if (signature && rawBody) {
+        const eventData = await paddle.webhooks.unmarshal(rawBody, secretKey, signature);
+        switch (eventData.eventType) {
+          case EventName.TransactionPaid:
+            this.billingService.handleTransactionPaidWebhook(eventData.data);
+            this.logger.info(
+              `Handle transaction paid webhook event: ${eventData.notificationId} occurred at ${eventData.occurredAt}`,
+            );
+            return {
+              status: 'successful',
+              message: 'Webhook event handled successfully',
+            };
+          case EventName.SubscriptionCanceled:
+            this.billingService.handleSubscriptionCreatedWebhook(eventData.data);
+            this.logger.info(
+              `Handle subscription canceled webhook event: ${eventData.notificationId} occurred at ${eventData.occurredAt}`,
+            );
+            return {
+              status: 'successful',
+              message: 'Webhook event handled successfully',
+            };
+          default:
+            this.logger.warn(`Unhandled event type: ${eventData.eventType}`);
+            return {
+              status: 'error',
+              message: 'Webhook event could not be handled',
+            };
+        }
+      }
+    } catch (error) {
+      this.logger.info(
+        `An error occurred while handling webhook event: ${error} occurred at ${new Date().toISOString()}`,
+      );
+    }
+    return {
+      status: 'error',
+      message: 'Webhook event could not be handled',
+    };
+  }
+}

src/modules/billing/billing.controller.ts

@@ -1,11 +1,11 @@
 import { SubscriptionPlan } from '../shared/types/subscriptions';
 
-export interface PayForSubscriptionRequest {
+export interface BillingSubscriptionRequest {
   plan: SubscriptionPlan;
   user_id: number;
   project_id: number;
 }
 
-export interface PayForSubscriptionResponse {
+export interface BillingSubscriptionResponse {
   url: string;
 }