feat(billing): fix comments

Author: Sourav-kashyap

services/subscription-service/src/controllers/billing-service.controller.ts

@@ -15,14 +15,12 @@ import {
   TInvoicePdf,
   TInvoicePaymentDetails,
   TPaymentIntent,
-  TCustomer,
   TPaymentSource,
   TInvoice,
   Transaction,
 } from 'loopback4-billing';
 import {getModelSchemaRefSF, STATUS_CODE} from '@sourceloop/core';
 import {
-  BillingCustomerBody,
   BillingPaymentSourceBody,
   BillingPaymentMethodBody,
   BillingInvoiceBody,
@@ -44,117 +42,7 @@ export class BillingServiceController {
     private readonly billingService: IService,
   ) {}
 
-  // -------------------------------------------------------------------------
-  // CUSTOMER
-  // -------------------------------------------------------------------------
-
-  /**
-   * Create a new customer in Stripe.
-   *
-   * Example body:
-   * ```json
-   * {
-   *   "firstName": "John",
-   *   "lastName": "Doe",
-   *   "email": "john.doe@example.com",
-   *   "phone": "+1234567890"
-   * }
-   * ```
-   */
-  @authorize({permissions: ['*']})
-  @post(`${BASE}/customers`, {
-    summary: 'Create a new customer',
-    responses: {
-      [STATUS_CODE.OK]: {
-        description: 'Created customer object',
-        content: {'application/json': {schema: {type: 'object'}}},
-      },
-    },
-  })
-  async createCustomer(
-    @requestBody({
-      content: {
-        'application/json': {
-          schema: {...getModelSchemaRefSF(BillingCustomerBody)},
-        },
-      },
-    })
-    customerDto: BillingCustomerBody,
-  ): Promise<TCustomer> {
-    return this.billingService.createCustomer(customerDto as TCustomer);
-  }
-
-  /**
-   * Get a customer by external ID (Stripe customer ID, e.g. cus_XXXXX).
-   */
-  @authorize({permissions: ['*']})
-  @get(`${BASE}/customers/{customerId}`, {
-    summary: 'Get a customer by ID',
-    responses: {
-      [STATUS_CODE.OK]: {
-        description: 'Customer object',
-        content: {'application/json': {schema: {type: 'object'}}},
-      },
-    },
-  })
-  async getCustomer(
-    @param.path.string('customerId') customerId: string,
-  ): Promise<TCustomer> {
-    return this.billingService.getCustomers(customerId);
-  }
-
-  /**
-   * Update an existing customer (email, phone, billing address, etc.).
-   *
-   * Example body:
-   * ```json
-   * {
-   *   "email": "new.email@example.com",
-   *   "billingAddress": { "city": "New York", "country": "US" }
-   * }
-   * ```
-   */
-  @authorize({permissions: ['*']})
-  @put(`${BASE}/customers/{customerId}`, {
-    summary: 'Update a customer',
-    responses: {
-      [STATUS_CODE.NO_CONTENT]: {description: 'Customer updated'},
-    },
-  })
-  async updateCustomer(
-    @param.path.string('customerId') customerId: string,
-    @requestBody({
-      content: {
-        'application/json': {
-          schema: {...getModelSchemaRefSF(BillingCustomerBody)},
-        },
-      },
-    })
-    customerDto: Partial<BillingCustomerBody>,
-  ): Promise<void> {
-    await this.billingService.updateCustomerById(
-      customerId,
-      customerDto as Partial<TCustomer>,
-    );
-  }
-
-  /**
-   * Delete (permanently remove) a customer from Stripe.
-   */
-  @authorize({permissions: ['*']})
-  @del(`${BASE}/customers/{customerId}`, {
-    summary: 'Delete a customer',
-    responses: {
-      [STATUS_CODE.NO_CONTENT]: {description: 'Customer deleted'},
-    },
-  })
-  async deleteCustomer(
-    @param.path.string('customerId') customerId: string,
-  ): Promise<void> {
-    await this.billingService.deleteCustomer(customerId);
-  }
-
-  // -------------------------------------------------------------------------
+  // ------------------------------------------------------------------------
   // PAYMENT SOURCE
   // -------------------------------------------------------------------------
 

services/subscription-service/src/controllers/billing-webhook.controller.ts

@@ -6,10 +6,8 @@ import {
   ISubscriptionService,
   TSubscriptionResult,
 } from 'loopback4-billing';
-import {repository} from '@loopback/repository';
 import {WEBHOOK_VERIFIER} from '../keys';
-import {InvoiceRepository} from '../repositories';
-import {IContent, IPayload, IWebhookPayload, IWebhookContent} from '../types';
+import {IWebhookPayload, IWebhookContent} from '../types';
 
 /**
  * Chargebee webhook event types handled by this controller.
@@ -43,13 +41,11 @@ export class BillingWebhookController {
   constructor(
     @inject(BillingComponentBindings.SDKProvider)
     private readonly billingService: ISubscriptionService,
-    @repository(InvoiceRepository)
-    public invoiceRepository: InvoiceRepository,
   ) {}
 
   @authorize({permissions: ['*']})
   @intercept(WEBHOOK_VERIFIER)
-  @post('/webhooks/billing-payment', {
+  @post('/webhooks/chargebee', {
     summary: 'Chargebee webhook receiver',
     description:
       'Register this URL in Chargebee Settings → API Keys → Webhooks. ' +
@@ -119,20 +115,6 @@ export class BillingWebhookController {
     return {received: true, event: eventType};
   }
 
-  /**
-   * Legacy webhook handler for backward compatibility.
-   * Handles payment status updates.
-   */
-  @authorize({
-    permissions: ['*'],
-  })
-  @intercept(WEBHOOK_VERIFIER)
-  @post('/webhooks/billing-payment/legacy')
-  async handleWebhookLegacy(@requestBody() payload: IPayload): Promise<void> {
-    const content = payload.content;
-    await this.handlePayment(content);
-  }
-
   /**
    * Fired when a subscription is first created in Chargebee.
    * The subscription may be in `in_trial` or `active` state.
@@ -253,16 +235,4 @@ export class BillingWebhookController {
       cancelAtPeriodEnd: raw?.cancel_at_period_end ?? false,
     };
   }
-
-  /**
-   * Legacy payment handler for backward compatibility.
-   */
-  private async handlePayment(content: IContent): Promise<void> {
-    const invoice = await this.invoiceRepository.find({
-      where: {invoiceId: content.invoice.id},
-    });
-    await this.invoiceRepository.updateById(invoice[0].id, {
-      invoiceStatus: content.invoice.status,
-    });
-  }
 }