Spaces:
Running
Running
| ; | |
| var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { | |
| var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d; | |
| if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc); | |
| else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r; | |
| return c > 3 && r && Object.defineProperty(target, key, r), r; | |
| }; | |
| var __metadata = (this && this.__metadata) || function (k, v) { | |
| if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v); | |
| }; | |
| var PaystackService_1; | |
| Object.defineProperty(exports, "__esModule", { value: true }); | |
| exports.PaystackService = void 0; | |
| const common_1 = require("@nestjs/common"); | |
| const config_1 = require("@nestjs/config"); | |
| let PaystackService = PaystackService_1 = class PaystackService { | |
| configService; | |
| logger = new common_1.Logger(PaystackService_1.name); | |
| secretKey; | |
| publicKey; | |
| baseUrl = 'https://api.paystack.co'; | |
| callbackUrl; | |
| constructor(configService) { | |
| this.configService = configService; | |
| this.secretKey = this.configService.get('PAYSTACK_SECRET_KEY') || ''; | |
| this.publicKey = this.configService.get('PAYSTACK_PUBLIC_KEY') || ''; | |
| this.callbackUrl = this.configService.get('PAYSTACK_CALLBACK_URL') || ''; | |
| if (!this.secretKey) { | |
| this.logger.warn('PAYSTACK_SECRET_KEY is not configured'); | |
| } | |
| } | |
| isConfigured() { | |
| return Boolean(this.secretKey); | |
| } | |
| getPublicKey() { | |
| return this.publicKey; | |
| } | |
| getHeaders() { | |
| return { | |
| Authorization: `Bearer ${this.secretKey}`, | |
| 'Content-Type': 'application/json', | |
| }; | |
| } | |
| async initializeTransaction(input) { | |
| if (!this.secretKey) { | |
| throw new Error('Paystack is not configured'); | |
| } | |
| const body = { | |
| email: input.email, | |
| amount: Math.round(input.amount), | |
| reference: input.reference, | |
| }; | |
| if (input.currency) | |
| body.currency = input.currency; | |
| if (input.callbackUrl) | |
| body.callback_url = input.callbackUrl; | |
| if (input.metadata) | |
| body.metadata = JSON.stringify(input.metadata); | |
| if (input.channels?.length) | |
| body.channels = input.channels; | |
| const response = await fetch(`${this.baseUrl}/transaction/initialize`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify(body), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack initialize failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to initialize Paystack transaction'); | |
| } | |
| return { | |
| authorizationUrl: payload.data.authorization_url, | |
| accessCode: payload.data.access_code, | |
| reference: payload.data.reference, | |
| }; | |
| } | |
| async createMobileMoneyCharge(input) { | |
| if (!this.secretKey) { | |
| throw new Error('Paystack is not configured'); | |
| } | |
| const body = { | |
| email: input.email, | |
| amount: Math.round(input.amount), | |
| reference: input.reference, | |
| mobile_money: { | |
| phone: this.normalizeMobileMoneyPhone(input.mobileMoney.phone), | |
| provider: input.mobileMoney.provider, | |
| }, | |
| }; | |
| if (input.currency) | |
| body.currency = input.currency; | |
| if (input.callbackUrl) | |
| body.callback_url = input.callbackUrl; | |
| if (input.metadata) | |
| body.metadata = JSON.stringify(input.metadata); | |
| const response = await fetch(`${this.baseUrl}/charge`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify(body), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack mobile money charge failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to initiate Paystack mobile money charge'); | |
| } | |
| return { | |
| status: payload.data.status, | |
| reference: payload.data.reference, | |
| displayMessage: payload.data.display_message, | |
| providerReference: payload.data.provider_reference, | |
| }; | |
| } | |
| async verifyTransaction(reference) { | |
| if (!this.secretKey) { | |
| throw new Error('Paystack is not configured'); | |
| } | |
| const response = await fetch(`${this.baseUrl}/transaction/verify/${encodeURIComponent(reference)}`, { method: 'GET', headers: this.getHeaders() }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack verify failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to verify Paystack transaction'); | |
| } | |
| return { | |
| status: payload.data.status, | |
| amount: payload.data.amount, | |
| currency: payload.data.currency, | |
| reference: payload.data.reference, | |
| channel: payload.data.channel, | |
| paidAt: payload.data.paid_at ?? null, | |
| gatewayResponse: payload.data.gateway_response, | |
| authorizationCode: payload.data.authorization?.authorization_code, | |
| }; | |
| } | |
| verifyWebhookSignature(rawBody, signatureHeader) { | |
| if (!this.secretKey || !signatureHeader) | |
| return false; | |
| const { createHmac } = require('crypto'); | |
| const expected = createHmac('sha512', this.secretKey).update(rawBody).digest('hex'); | |
| if (expected.length !== signatureHeader.length) | |
| return false; | |
| let mismatch = 0; | |
| for (let i = 0; i < expected.length; i++) { | |
| mismatch |= expected.charCodeAt(i) ^ signatureHeader.charCodeAt(i); | |
| } | |
| return mismatch === 0; | |
| } | |
| async createPlan(input) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const body = { | |
| name: input.name, | |
| amount: Math.round(input.amount), | |
| interval: input.interval, | |
| }; | |
| if (input.currency) | |
| body.currency = input.currency; | |
| if (input.description) | |
| body.description = input.description; | |
| if (input.planCode) | |
| body.plan_code = input.planCode; | |
| const response = await fetch(`${this.baseUrl}/plan`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify(body), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack plan creation failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to create Paystack plan'); | |
| } | |
| return payload.data; | |
| } | |
| async fetchPlan(idOrCode) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const response = await fetch(`${this.baseUrl}/plan/${encodeURIComponent(idOrCode)}`, { method: 'GET', headers: this.getHeaders() }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) | |
| return null; | |
| return payload.data; | |
| } | |
| async createSubscription(input) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const body = { | |
| customer: input.customerCode, | |
| plan: input.planCode, | |
| }; | |
| if (input.authorizationCode) | |
| body.authorization = input.authorizationCode; | |
| if (input.startDate) | |
| body.start_date = input.startDate; | |
| const response = await fetch(`${this.baseUrl}/subscription`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify(body), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack subscription creation failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to create Paystack subscription'); | |
| } | |
| return payload.data; | |
| } | |
| async fetchSubscription(idOrCode) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const response = await fetch(`${this.baseUrl}/subscription/${encodeURIComponent(idOrCode)}`, { method: 'GET', headers: this.getHeaders() }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) | |
| return null; | |
| return payload.data; | |
| } | |
| async disableSubscription(subscriptionCode, token) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const response = await fetch(`${this.baseUrl}/subscription/disable`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify({ | |
| code: subscriptionCode, | |
| token, | |
| }), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack subscription disable failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to disable Paystack subscription'); | |
| } | |
| return payload.data; | |
| } | |
| async enableSubscription(subscriptionCode, token) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const response = await fetch(`${this.baseUrl}/subscription/enable`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify({ | |
| code: subscriptionCode, | |
| token, | |
| }), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack subscription enable failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to enable Paystack subscription'); | |
| } | |
| return payload.data; | |
| } | |
| async refundTransaction(reference, amountInSubunits) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const body = { transaction: reference }; | |
| if (typeof amountInSubunits === 'number') | |
| body.amount = amountInSubunits; | |
| const response = await fetch(`${this.baseUrl}/refund`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify(body), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack refund failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to refund Paystack transaction'); | |
| } | |
| return payload.data; | |
| } | |
| async createCustomer(input) { | |
| if (!this.secretKey) | |
| throw new Error('Paystack is not configured'); | |
| const body = { email: input.email }; | |
| if (input.firstName) | |
| body.first_name = input.firstName; | |
| if (input.lastName) | |
| body.last_name = input.lastName; | |
| if (input.phone) | |
| body.phone = input.phone; | |
| if (input.metadata) | |
| body.metadata = input.metadata; | |
| const response = await fetch(`${this.baseUrl}/customer`, { | |
| method: 'POST', | |
| headers: this.getHeaders(), | |
| body: JSON.stringify(body), | |
| }); | |
| const payload = (await response.json()); | |
| if (!response.ok || !payload.status || !payload.data) { | |
| this.logger.error(`Paystack customer creation failed: ${JSON.stringify(payload)}`); | |
| throw new Error(payload.message || 'Failed to create Paystack customer'); | |
| } | |
| return payload.data; | |
| } | |
| normalizeMobileMoneyPhone(phone) { | |
| const digits = phone.replace(/\D/g, ''); | |
| if (digits.startsWith('254') && digits.length === 12) { | |
| return `0${digits.slice(3)}`; | |
| } | |
| if (digits.startsWith('0') && digits.length === 10) { | |
| return digits; | |
| } | |
| if (digits.length === 9) { | |
| return `0${digits}`; | |
| } | |
| throw new Error('Invalid phone number. Use 07XX, 01XX, or 2547XXXXXXXX format.'); | |
| } | |
| }; | |
| exports.PaystackService = PaystackService; | |
| exports.PaystackService = PaystackService = PaystackService_1 = __decorate([ | |
| (0, common_1.Injectable)(), | |
| __metadata("design:paramtypes", [config_1.ConfigService]) | |
| ], PaystackService); | |
| //# sourceMappingURL=paystack.service.js.map |