This is the primary service of the control plane responsible for subscription and plan management.
A Microservice for handling subscription management operations. It provides -
- plan creations and management - plan includes plan tier - silo/pooled
- Add or Update Plan Items/Services/Resources to Plans - plan items are the offerings to user with in the selected plan
- Billing & Invoice Management.
we have created a package loopback4-billing that is designed to integrate billing functionality into LoopBack 4 applications. It provides an abstraction layer to work with billing services such as Chargebee, Stripe etc, offering common billing operations like creating and managing customers, invoices, payment sources, and transactions.
Install Subscription service using npm
;
$ [npm install | yarn add] @sourceloop/ctrl-plane-subscription-service
- Create a new Loopback4 Application (If you don't have one already)
lb4 testapp
- Install the subscription service
npm i @sourceloop/ctrl-plane-subscription-service
- Set the environment variables.
- Run the migrations.
- Add the
SubscriptionServiceComponent
to your Loopback4 Application (inapplication.ts
).// import the SubscriptionServiceComponent import {SubscriptionServiceComponent} from '@sourceloop/ctrl-plane-subscription-service'; // add Component for subscription-service this.component(SubscriptionServiceComponent);
- Set up a Loopback4 Datasource with
dataSourceName
property set toSubscriptionDB
. You can see an example datasource here. - Bind any of the custom providers you need.
We are leveraging the loopback4-billing package to integrate billing capabilities into our Subscription Service.
To include billing functionality, we integrate the BillingComponent into the SubscriptionServiceComponent as follows:
// import billing component from loopback4-billing
import {BillingComponent} from 'loopback4-billing';
// add Component for subscription-service component
this.application.component(BillingComponent);
We utilize the BillingProvider binding from loopback4-billing in our controllers as shown below:
// import billing component from loopback4-billing
import {BillingComponentBindings,IService} from 'loopback4-billing';
// add Component for subscription-service component
export class BillingInvoiceController {
constructor(
...
@inject(BillingComponentBindings.BillingProvider)
private readonly billingProvider: IService,
...
) {}
}
Depending on the billing provider, the setup process varies. Currently, we support Stripe and Chargebee.
To use Chargebee as the billing provider, you need to configure the Chargebee API keys and site URL in your application. You can set these values in the environment variables of your LoopBack 4 project.
API_KEY=your_chargebee_api_key
SITE=your_chargebee_site_url
Next, bind these values with ChargeBeeBindings.Config and register the Chargebee provider, as shown below:
import { ChargeBeeBindings,BillingComponentBindings } from 'loopback4-billing';
import {SubscriptionServiceComponent} from '@sourceloop/ctrl-plane-subscription-service';
export class YourApplication extends BootMixin(
ServiceMixin(RepositoryMixin(RestApplication)),
) {
constructor(options: ApplicationConfig = {}) {
super(options);
// Bind the config values
this.bind(ChargeBeeBindings.config).to({
site: process.env.SITE ?? '',
apiKey: process.env.API_KEY ?? '',
});
// Register Billing component
this.bind(BillingComponentBindings.SDKProvider).toProvider(
ChargeBeeServiceProvider,
);
this.component(SubscriptionServiceComponent);
// Other configurations
}
}
To use Stripe as the billing provider, you need to configure the Chargebee API keys and site URL in your application. You can set these values in the environment variables of your LoopBack 4 project.
STRIPE_SECRET=your_stripe_secret_key
Next, bind these values with StripeBindings.Config and register the Stripe provider, as shown below:
import { StripeBindings,BillingComponentBindings } from 'loopback4-billing';
import {SubscriptionServiceComponent} from '@sourceloop/ctrl-plane-subscription-service';
export class YourApplication extends BootMixin(
ServiceMixin(RepositoryMixin(RestApplication)),
) {
constructor(options: ApplicationConfig = {}) {
super(options);
// Bind the config values
this.bind(StripeBindings.config).to({
secretKey: process.env.STRIPE_SECRET ?? '',
});
// Register Billing component
this.bind(BillingComponentBindings.SDKProvider).toProvider(
StripeServiceProvider,
);
this.component(SubscriptionServiceComponent);
// Other configurations
}
}
Name | Required | Description | Default Value |
---|---|---|---|
NODE_ENV | Y | Node environment value, i.e. `dev`, `test`, `prod | |
LOG_LEVEL | Y | Log level value, i.e. `error`, `warn`, `info`, `verbose`, `debug` | |
DB_HOST | Y | Hostname for the database server. | |
DB_PORT | Y | Port for the database server. | |
DB_USER | Y | User for the database. | |
DB_PASSWORD | Y | Password for the database user. | |
DB_DATABASE | Y | Database to connect to on the database server. | |
DB_SCHEMA | Y | Database schema used for the data source. In PostgreSQL, this will be `public` unless a schema is made explicitly for the service. | |
REDIS_HOST | Y | Hostname of the Redis server. | |
REDIS_PORT | Y | Port to connect to the Redis server over. | |
REDIS_URL | Y | Fully composed URL for Redis connection. Used instead of other settings if set. | |
REDIS_PASSWORD | Y | Password for Redis if authentication is enabled. | |
REDIS_DATABASE | Y | Database within Redis to connect to. | |
JWT_SECRET | Y | Symmetric signing key of the JWT token. | |
JWT_ISSUER | Y | Issuer of the JWT token. |
Here is a sample Implementation DataSource
implementation using environment variables and PostgreSQL as the data source.
import {inject, lifeCycleObserver, LifeCycleObserver} from '@loopback/core';
import {juggler} from '@loopback/repository';
import {TenantManagementDbSourceName} from "@sourceloop/tenant-management-service";
const config = {
name: SubscriptionDbSourceName,
connector: 'postgresql',
url: '',
host: process.env.DB_HOST,
port: process.env.DB_PORT,
user: process.env.DB_USER,
password: process.env.DB_PASSWORD,
database: process.env.DB_DATABASE,
schema: process.env.DB_SCHEMA,
};
@lifeCycleObserver('datasource')
export class AuthenticationDbDataSource
extends juggler.DataSource
implements LifeCycleObserver
{
static dataSourceName = SubscriptionDbSourceName;
static readonly defaultConfig = config;
constructor(
// You need to set datasource configuration name as 'datasources.config.Authentication' otherwise you might get Errors
@inject(`datasources.config.${SubscriptionDbSourceName}`, {optional: true})
dsConfig: object = config,
) {
super(dsConfig);
}
}
The migrations required for this service can be copied from the service. You can customize or cherry-pick the migrations in the copied files according to your specific requirements and then apply them to the DB.