구독 가이드

async generateLink(name: string, plan: Plan, userId: number): Promise<string> {
    const user = await this.userService.getUser(userId)

    // Retrieves the StepPay product/price code corresponding to the plan selected by the customer.
    let planItem = this.PLAN[plan]

    // StepPay order creation
    const order = await this.steppayService.createOrder(
            user.steppayId,
            planItem, // { productCode: string, priceCode: string }[]
    )

    // Mapping of the payment entity in the system and the StepPay order number
    await this.organizationRepository.save({
        name,
        plan,
        owner: user,
        steppayOrderId: order.data.orderId
    })

    return this.steppayService.generateLink(order.data.orderId) // redirection
}

// Payment completion redirection
async processPayment(order: SteppayOrder): Promise<OrganizationEntity> {
    // Find the payment entity by the redirected order number
    const organization = await this.organizationRepository.findOne({ where: { steppayOrderId: order.orderId } })
    if (!organization) {
        throw new NotFoundException()
    }

    // Map all subscription numbers created by the order
    organization.subscriptions = order.subscriptions.map(subscription => new SubscriptionEntity(
            organization,
            subscription.id,
    ))

    // Retrieve subscription item number and product code for usage tracking
    const items = order.subscriptions.flatMap(subscription => subscription.items)
            .map(item => ({ id: item.id, productCode: item.productCode }))

    // Map the detailed metering items of the payment entity and the StepPay subscription item number
    organization.items = new ItemEmbedable(
            items.find(items => items.productCode === this.PRODUCT_CODE).id
    )

    organization.status = 'ACTIVE'

    await this.organizationRepository.save(organization)

    return organization
}

@Get()
async
handleSubscriptionWebhook(
    @Body() body: {
      id: number,
      status : string
    }
) {
    this.organizationService.updateStatus(body)
}