diff --git a/Common/Server/Services/BillingService.ts b/Common/Server/Services/BillingService.ts index 69f96cfa90..62f01f2d70 100644 --- a/Common/Server/Services/BillingService.ts +++ b/Common/Server/Services/BillingService.ts @@ -1245,6 +1245,14 @@ export class BillingService extends BaseService { return "price_1OQ8j0ANuQdJ93r7WGzR0p6j"; } + if (productType === ProductType.Profiles) { + if (this.isTestEnvironment()) { + return "price_1TGwUpANuQdJ93r7b9qxa5Se"; + } + + return "price_1TGwTDANuQdJ93r7s0jKRxaT"; + } + throw new BadDataException( "Plan with productType " + productType + " not found", ); diff --git a/Worker/Jobs/MeteredPlan/ReportTelemetryMeteredPlan.ts b/Worker/Jobs/MeteredPlan/ReportTelemetryMeteredPlan.ts index 5364bdaf22..e69e301bf2 100644 --- a/Worker/Jobs/MeteredPlan/ReportTelemetryMeteredPlan.ts +++ b/Worker/Jobs/MeteredPlan/ReportTelemetryMeteredPlan.ts @@ -12,6 +12,7 @@ import { LogDataIngestMeteredPlan, MetricsDataIngestMeteredPlan, TracesDataIngestMetredPlan, + ProfilesDataIngestMeteredPlan, } from "Common/Server/Types/Billing/MeteredPlan/AllMeteredPlans"; import logger from "Common/Server/Utils/Logger"; import Project from "Common/Models/DatabaseModels/Project"; @@ -76,6 +77,12 @@ RunCron( ); await Sleep.sleep(1000); + + await ProfilesDataIngestMeteredPlan.reportQuantityToBillingProvider( + project.id, + ); + + await Sleep.sleep(1000); } } catch (error) { logger.error(