feat(payment): add cryptocurrency support

Author: TeaCoder52

src/api/payment/payment.service.ts

@@ -22,6 +22,8 @@ import { InitPaymentRequest } from './dto'
 @Injectable()
 export class PaymentService {
 	private readonly HOSTS_APP: string
+	private readonly HOSTS_REST: string
+
 	private readonly SUBSCRIPTION_PRICE = 349
 
 	public constructor(
@@ -31,6 +33,7 @@ export class PaymentService {
 		private readonly heleketService: HeleketService
 	) {
 		this.HOSTS_APP = this.configService.getOrThrow<string>('HOSTS_APP')
+		this.HOSTS_REST = this.configService.getOrThrow<string>('HOSTS_REST')
 	}
 
 	public async create(dto: InitPaymentRequest, user: User) {
@@ -80,19 +83,15 @@ export class PaymentService {
 				)
 				break
 			case PaymentMethod.CRYPTO:
-				// providerResponse = await this.heleketService.createPayment({
-				// 	// amount: String(this.SUBSCRIPTION_PRICE),
-				// 	amount: '40',
-				// 	currency: 'RUB',
-				// 	order_id: payment.id,
-				// 	url_return: 'http://localhost:14701/premium',
-				// 	url_success: 'http://localhost:14701/payment/success',
-				// 	url_callback:
-				// 		'https://72263b5f4671.ngrok-free.app/webhook/crypto'
-				// })
-				throw new BadRequestException(
-					'This payment method is not available yet'
-				)
+				providerResponse = await this.heleketService.createPayment({
+					amount: String(this.SUBSCRIPTION_PRICE),
+					currency: 'RUB',
+					order_id: payment.id,
+					url_return: `${this.HOSTS_APP}/payment/success`,
+					url_success: `${this.HOSTS_APP}/premium`,
+					url_callback: `${this.HOSTS_REST}/webhook/crypto`
+				})
+				break
 			default:
 				throw new BadRequestException('Unsupported payment provider')
 		}

src/api/payment/scheduler/scheduler.service.ts

@@ -1,6 +1,6 @@
 import { Injectable, Logger } from '@nestjs/common'
 import { Cron, CronExpression } from '@nestjs/schedule'
-import { PaymentStatus } from '@prisma/generated'
+import { PaymentMethod, PaymentStatus } from '@prisma/generated'
 import { CurrencyEnum, YookassaService } from 'nestjs-yookassa'
 import { VatCodesEnum } from 'nestjs-yookassa/dist/interfaces/receipt-details.interface'
 
@@ -65,7 +65,10 @@ export class SchedulerService {
 				const lastSuccess = await this.prismaService.payment.findFirst({
 					where: {
 						userId: user.id,
-						status: PaymentStatus.SUCCESS
+						status: PaymentStatus.SUCCESS,
+						method: {
+							not: PaymentMethod.CRYPTO
+						}
 					},
 					orderBy: {
 						createdAt: 'desc'

src/api/payment/webhook/webhook.controller.ts

@@ -8,8 +8,6 @@ import {
 } from '@nestjs/common'
 import { ApiOkResponse, ApiOperation } from '@nestjs/swagger'
 
-import { ClientIp } from '@/common/decorators'
-
 import { WebhookService } from './webhook.service'
 
 @Controller('webhook')
@@ -29,20 +27,20 @@ export class WebhookController {
 	@Post('yookassa')
 	@HttpCode(HttpStatus.OK)
 	public async yookassaWebhook(@Body() payload: any, @Ip() ip: string) {
-		console.log('YOOKASSA WEBHOOK IP: ', ip)
-
 		this.webhookService.verifyWebhook(ip)
 
 		await this.webhookService.handleYookassa(payload)
 
 		return { ok: true }
 	}
 
-	// @Post('crypto')
-	// @HttpCode(HttpStatus.OK)
-	// public async cryptoWebhook(@Body() payload: any) {
-	// 	await this.webhookService.handleCrypto(payload)
+	@Post('crypto')
+	@HttpCode(HttpStatus.OK)
+	public async cryptoWebhook(@Body() payload: any) {
+		console.log(payload)
+
+		await this.webhookService.handleCrypto(payload)
 
-	// 	return { ok: true }
-	// }
+		return { ok: true }
+	}
 }

src/api/payment/webhook/webhook.service.ts

@@ -44,8 +44,6 @@ export class WebhookService {
 	}
 
 	public async handleYookassa(payload: any) {
-		console.log('YOOKASSA WEBHOOK: ', JSON.stringify(payload))
-
 		if (payload.event === 'payment.waiting_for_capture') {
 			return await this.yookassaService.capturePayment(payload.object.id)
 		} else if (payload.event === 'payment.succeeded') {
@@ -120,6 +118,13 @@ export class WebhookService {
 			}
 		})
 
+		if (provider === 'yookassa') {
+			await this.savePaymentMethod(
+				payment.user.id,
+				paymentData.payment_method
+			)
+		}
+
 		const now = new Date()
 
 		let expiresAt = payment.user.subscription?.expiresAt ?? now
@@ -147,11 +152,6 @@ export class WebhookService {
 				}
 			}
 		})
-
-		await this.savePaymentMethod(
-			payment.user.id,
-			paymentData.payment_method
-		)
 	}
 
 	private async savePaymentMethod(userId: string, metadata: any) {