diff --git a/apps/frontend/src/components/billing/purchase.crypto.tsx b/apps/frontend/src/components/billing/purchase.crypto.tsx
new file mode 100644
index 00000000..6e38842b
--- /dev/null
+++ b/apps/frontend/src/components/billing/purchase.crypto.tsx
@@ -0,0 +1,24 @@
+import { FC, useCallback, useState } from 'react';
+import { useFetch } from '@gitroom/helpers/utils/custom.fetch';
+import { Button } from '@gitroom/react/form/button';
+
+export const PurchaseCrypto: FC = () => {
+ const fetch = useFetch();
+ const [loading, setLoading] = useState(false);
+ const load = useCallback(async () => {
+ setLoading(true);
+ const data = await (await fetch('/billing/crypto')).json();
+ window.location.href = data.invoice_url;
+ }, []);
+
+ return (
+
+
Purchase a Life-time PRO account with SOL ($199)
+
+
+
+
+ );
+};
diff --git a/apps/frontend/src/components/layout/top.menu.tsx b/apps/frontend/src/components/layout/top.menu.tsx
index 264fb2d4..c84ba34e 100644
--- a/apps/frontend/src/components/layout/top.menu.tsx
+++ b/apps/frontend/src/components/layout/top.menu.tsx
@@ -79,6 +79,9 @@ export const TopMenu: FC = () => {
if (f.requireBilling && !billingEnabled) {
return false;
}
+ if (f.name === 'Billing' && user?.isLifetime) {
+ return false;
+ }
if (f.role) {
return f.role.includes(user?.role!);
}
diff --git a/libraries/nestjs-libraries/src/crypto/nowpayments.ts b/libraries/nestjs-libraries/src/crypto/nowpayments.ts
new file mode 100644
index 00000000..47e18aa2
--- /dev/null
+++ b/libraries/nestjs-libraries/src/crypto/nowpayments.ts
@@ -0,0 +1,78 @@
+import { Injectable } from '@nestjs/common';
+import { makeId } from '@gitroom/nestjs-libraries/services/make.is';
+import { AuthService } from '@gitroom/helpers/auth/auth.service';
+import { SubscriptionService } from '@gitroom/nestjs-libraries/database/prisma/subscriptions/subscription.service';
+
+export interface ProcessPayment {
+ payment_id: number;
+ payment_status: string;
+ pay_address: string;
+ price_amount: number;
+ price_currency: string;
+ pay_amount: number;
+ actually_paid: number;
+ pay_currency: string;
+ order_id: string;
+ order_description: string;
+ purchase_id: string;
+ created_at: string;
+ updated_at: string;
+ outcome_amount: number;
+ outcome_currency: string;
+}
+
+@Injectable()
+export class Nowpayments {
+ constructor(private _subscriptionService: SubscriptionService) {}
+
+ async processPayment(path: string, body: ProcessPayment) {
+ const decrypt = AuthService.verifyJWT(path) as any;
+ if (!decrypt || !decrypt.order_id) {
+ return;
+ }
+
+ if (
+ decrypt.payment_status !== 'confirmed' &&
+ decrypt.payment_status !== 'finished'
+ ) {
+ return;
+ }
+
+ const [org, make] = body.order_id.split('_');
+ await this._subscriptionService.lifeTime(org, make, 'PRO');
+ return body;
+ }
+
+ async createPaymentPage(orgId: string) {
+ const onlyId = makeId(5);
+ const make = orgId + '_' + onlyId;
+ const signRequest = AuthService.signJWT({ order_id: make });
+
+ const { id, invoice_url } = await (
+ await fetch('https://api.nowpayments.io/v1/invoice', {
+ method: 'POST',
+ headers: {
+ 'Content-Type': 'application/json',
+ 'x-api-key': process.env.NOWPAYMENTS_API_KEY!,
+ },
+ body: JSON.stringify({
+ price_amount: process.env.NOWPAYMENTS_AMOUNT,
+ price_currency: 'USD',
+ order_id: make,
+ pay_currency: 'SOL',
+ order_description: 'Lifetime deal account for Postiz',
+ ipn_callback_url:
+ process.env.NEXT_PUBLIC_BACKEND_URL +
+ `/public/crypto/${signRequest}`,
+ success_url: process.env.FRONTEND_URL + `/launches?check=${onlyId}`,
+ cancel_url: process.env.FRONTEND_URL,
+ }),
+ })
+ ).json();
+
+ return {
+ id,
+ invoice_url,
+ };
+ }
+}
diff --git a/libraries/nestjs-libraries/src/database/prisma/subscriptions/subscription.service.ts b/libraries/nestjs-libraries/src/database/prisma/subscriptions/subscription.service.ts
index 6b5ae00d..e7bb98fa 100644
--- a/libraries/nestjs-libraries/src/database/prisma/subscriptions/subscription.service.ts
+++ b/libraries/nestjs-libraries/src/database/prisma/subscriptions/subscription.service.ts
@@ -13,7 +13,7 @@ export class SubscriptionService {
constructor(
private readonly _subscriptionRepository: SubscriptionRepository,
private readonly _integrationService: IntegrationService,
- private readonly _organizationService: OrganizationService,
+ private readonly _organizationService: OrganizationService
) {}
getSubscriptionByOrganizationId(organizationId: string) {
@@ -188,6 +188,19 @@ export class SubscriptionService {
};
}
+ async lifeTime(orgId: string, identifier: string, subscription: any) {
+ return this.createOrUpdateSubscription(
+ identifier,
+ identifier,
+ pricing[subscription].channel!,
+ subscription,
+ 'YEARLY',
+ null,
+ identifier,
+ orgId
+ );
+ }
+
async addSubscription(orgId: string, userId: string, subscription: any) {
await this._subscriptionRepository.setCustomerId(orgId, orgId);
return this.createOrUpdateSubscription(