如何在NestJS中实现iOS应用的订阅功能？

Question

我使用nestjs开发ios端app的后端.现在有一个订阅功能.
我查到的资料是, 支付前业务服务端需要调苹果的接口, 验证客户端传过来的票据.如果票据验证通过则客户端支付, 并且在数据库添加交易记录.支付后苹果支付中心会调用业务服务端的接口, 在这个接口里, 可以更新交易记录的状态, 并且更新用户的会员权限.

我不确定这个逻辑是否正确.
有没有那个大佬可以详细说说.
我使用了@apple/app-store-server-library这包, 但是这个包似乎只有回调相关的逻辑

Answer 1

安装依赖项 ↓

npm install @nestjs/common @nestjs/core @nestjs/platform-express axios

简单的实现代码（注释为文件名）：

// subscription.service.ts
import { Injectable, HttpService } from '@nestjs/common';

@Injectable()
export class SubscriptionService {
    constructor(private readonly httpService: HttpService) {}

    async verifyReceipt(receipt: string): Promise<any> {
        const url = 'https://buy.itunes.apple.com/verifyReceipt';
        const response = await this.httpService.post(url, {
            'receipt-data': receipt,
            'password': 'your_shared_secret'
        }).toPromise();
        return response.data;
    }

    async handleSubscription(data: any) {
    }
}

// subscription.controller.ts
import { Controller, Post, Body } from '@nestjs/common';
import { SubscriptionService } from './subscription.service';

@Controller('subscription')
export class SubscriptionController {
    constructor(private readonly subscriptionService: SubscriptionService) {}

    @Post('verify')
    async verify(@Body() body: { receipt: string }) {
        const verificationResult = await this.subscriptionService.verifyReceipt(body.receipt);
        
        if (verificationResult.status === 0) {
            await this.subscriptionService.handleSubscription(verificationResult);
            return { success: true, message: 'Subscription verified successfully.' };
        } else {
            return { success: false, message: 'Invalid receipt.' };
        }
    }
}

// webhook.controller.ts
import { Controller, Post, Body } from '@nestjs/common';
import { SubscriptionService } from './subscription.service';

@Controller('webhook')
export class WebhookController {
    constructor(private readonly subscriptionService: SubscriptionService) {}

    @Post('apple')
    async handleAppleWebhook(@Body() body: any) {
        const { notificationType, data } = body;

        if (notificationType === 'RENEWAL') {
            await this.subscriptionService.handleSubscription(data);
        }
        
        return { success: true };
    }
}

// app.module.ts
import { Module, HttpModule } from '@nestjs/common';
import { SubscriptionController } from './subscription.controller';
import { SubscriptionService } from './subscription.service';
import { WebhookController } from './webhook.controller';

@Module({
    imports: [HttpModule],
    controllers: [SubscriptionController, WebhookController],
    providers: [SubscriptionService],
})
export class AppModule {}

// main.ts
import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';

async function bootstrap() {
    const app = await NestFactory.create(AppModule);
    await app.listen(3000);
}
bootstrap();