/*
 * @Author: i@rysa.cn
 * @Date: 2022-05-14 17:05:56
 * @LastEditTime: 2022-06-01 10:10:56
 * @LastEditors: i@rysa.cn
 * @Description:
 * @FilePath: \go-utils\wechat\pay\notify.go
 */
package pay

import (
	"context"
	"net/http"

	"github.com/wechatpay-apiv3/wechatpay-go/core/auth/verifiers"
	"github.com/wechatpay-apiv3/wechatpay-go/core/downloader"
	pay_notify "github.com/wechatpay-apiv3/wechatpay-go/core/notify"
	"github.com/wechatpay-apiv3/wechatpay-go/services/payments"
	"github.com/wechatpay-apiv3/wechatpay-go/utils"
)

type notify struct {
	*PayConfig
}

func NewNotify(cfg *PayConfig) *notify {
	return &notify{cfg}
}

func (p *notify) GetNotify(r *http.Request) (*payments.Transaction, error) {
	ctx := context.Background()
	mchPrivateKey, err := utils.LoadPrivateKeyWithPath(p.ApiclientKey)
	if err != nil {
		return nil, err
	}
	// 1. 使用 `RegisterDownloaderWithPrivateKey` 注册下载器
	err = downloader.MgrInstance().RegisterDownloaderWithPrivateKey(ctx, mchPrivateKey, p.MchCertificateSerialNumber, p.MchId, p.MchApiV3Key)
	if err != nil {
		return nil, err
	}
	// 2. 获取商户号对应的微信支付平台证书访问器
	certVisitor := downloader.MgrInstance().GetCertificateVisitor(p.MchId)
	// 3. 使用证书访问器初始化 `notify.Handler`
	handler := pay_notify.NewNotifyHandler(p.MchApiV3Key, verifiers.NewSHA256WithRSAVerifier(certVisitor))
	transaction := new(payments.Transaction)
	_, err = handler.ParseNotifyRequest(ctx, r, transaction)
	return transaction, err
}