mirror of
https://github.com/xtr-dev/payload-billing.git
synced 2025-12-10 10:53:23 +00:00
Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| bf6f546371 | |||
| 7e4ec86e00 | |||
| 79de7910d4 | |||
| bb5ba83bc3 | |||
| 79166f7edf | |||
| 6de405d07f | |||
| 7c0b42e35d | |||
| 25b340d818 | |||
| 46bec6bd2e | |||
| 4fde492e0f | |||
| a37757ffa1 | |||
| 1867bb2f96 |
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@xtr-dev/payload-billing",
|
"name": "@xtr-dev/payload-billing",
|
||||||
"version": "0.1.14",
|
"version": "0.1.23",
|
||||||
"description": "PayloadCMS plugin for billing and payment provider integrations with tracking and local testing",
|
"description": "PayloadCMS plugin for billing and payment provider integrations with tracking and local testing",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
|
|||||||
@@ -4,6 +4,14 @@ import { useBillingPlugin } from '../plugin/index'
|
|||||||
|
|
||||||
export const initProviderPayment = async (payload: Payload, payment: Partial<Payment>): Promise<Partial<Payment>> => {
|
export const initProviderPayment = async (payload: Payload, payment: Partial<Payment>): Promise<Partial<Payment>> => {
|
||||||
const billing = useBillingPlugin(payload)
|
const billing = useBillingPlugin(payload)
|
||||||
|
|
||||||
|
if (!billing) {
|
||||||
|
throw new Error(
|
||||||
|
'Billing plugin not initialized. Make sure the billingPlugin is properly configured in your Payload config and that Payload has finished initializing. ' +
|
||||||
|
'If you are calling this from a Next.js API route or Server Component, ensure you are using getPayload() with the same config instance used in your Payload configuration.'
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
if (!payment.provider || !billing.providerConfig[payment.provider]) {
|
if (!payment.provider || !billing.providerConfig[payment.provider]) {
|
||||||
throw new Error(`Provider ${payment.provider} not found.`)
|
throw new Error(`Provider ${payment.provider} not found.`)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -78,6 +78,21 @@ export function createPaymentsCollection(pluginConfig: BillingPluginConfig): Col
|
|||||||
description: 'Payment description',
|
description: 'Payment description',
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
name: 'checkoutUrl',
|
||||||
|
type: 'text',
|
||||||
|
admin: {
|
||||||
|
description: 'Checkout URL where user can complete payment (if applicable)',
|
||||||
|
readOnly: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'redirectUrl',
|
||||||
|
type: 'text',
|
||||||
|
admin: {
|
||||||
|
description: 'URL to redirect user after payment completion',
|
||||||
|
},
|
||||||
|
},
|
||||||
{
|
{
|
||||||
name: 'invoice',
|
name: 'invoice',
|
||||||
type: 'relationship',
|
type: 'relationship',
|
||||||
@@ -136,6 +151,18 @@ export function createPaymentsCollection(pluginConfig: BillingPluginConfig): Col
|
|||||||
useAsTitle: 'id',
|
useAsTitle: 'id',
|
||||||
},
|
},
|
||||||
fields,
|
fields,
|
||||||
|
defaultPopulate: {
|
||||||
|
id: true,
|
||||||
|
provider: true,
|
||||||
|
status: true,
|
||||||
|
amount: true,
|
||||||
|
currency: true,
|
||||||
|
description: true,
|
||||||
|
checkoutUrl: true,
|
||||||
|
providerId: true,
|
||||||
|
metadata: true,
|
||||||
|
providerData: true,
|
||||||
|
},
|
||||||
hooks: {
|
hooks: {
|
||||||
afterChange: [
|
afterChange: [
|
||||||
async ({ doc, operation, req, previousDoc }) => {
|
async ({ doc, operation, req, previousDoc }) => {
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ import type { Config, Payload } from 'payload'
|
|||||||
import { createSingleton } from './singleton'
|
import { createSingleton } from './singleton'
|
||||||
import type { PaymentProvider } from '../providers/index'
|
import type { PaymentProvider } from '../providers/index'
|
||||||
|
|
||||||
const singleton = createSingleton(Symbol('billingPlugin'))
|
const singleton = createSingleton(Symbol.for('@xtr-dev/payload-billing'))
|
||||||
|
|
||||||
type BillingPlugin = {
|
type BillingPlugin = {
|
||||||
config: BillingPluginConfig
|
config: BillingPluginConfig
|
||||||
@@ -13,7 +13,7 @@ type BillingPlugin = {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export const useBillingPlugin = (payload: Payload) => singleton.get(payload) as BillingPlugin
|
export const useBillingPlugin = (payload: Payload) => singleton.get(payload) as BillingPlugin | undefined
|
||||||
|
|
||||||
export const billingPlugin = (pluginConfig: BillingPluginConfig = {}) => (config: Config): Config => {
|
export const billingPlugin = (pluginConfig: BillingPluginConfig = {}) => (config: Config): Config => {
|
||||||
if (pluginConfig.disabled) {
|
if (pluginConfig.disabled) {
|
||||||
|
|||||||
@@ -22,6 +22,14 @@ export interface Payment {
|
|||||||
* Payment description
|
* Payment description
|
||||||
*/
|
*/
|
||||||
description?: string | null;
|
description?: string | null;
|
||||||
|
/**
|
||||||
|
* Checkout URL where user can complete payment (if applicable)
|
||||||
|
*/
|
||||||
|
checkoutUrl?: string | null;
|
||||||
|
/**
|
||||||
|
* URL to redirect user after payment completion
|
||||||
|
*/
|
||||||
|
redirectUrl?: string | null;
|
||||||
invoice?: (Id | null) | Invoice;
|
invoice?: (Id | null) | Invoice;
|
||||||
/**
|
/**
|
||||||
* Additional metadata for the payment
|
* Additional metadata for the payment
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ import {
|
|||||||
import { formatAmountForProvider, isValidAmount, isValidCurrencyCode } from './currency'
|
import { formatAmountForProvider, isValidAmount, isValidCurrencyCode } from './currency'
|
||||||
import { createContextLogger } from '../utils/logger'
|
import { createContextLogger } from '../utils/logger'
|
||||||
|
|
||||||
const symbol = Symbol('mollie')
|
const symbol = Symbol.for('@xtr-dev/payload-billing/mollie')
|
||||||
export type MollieProviderConfig = Parameters<typeof createMollieClient>[0]
|
export type MollieProviderConfig = Parameters<typeof createMollieClient>[0]
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -85,11 +85,15 @@ export const mollieProvider = (mollieConfig: MollieProviderConfig & {
|
|||||||
const status = mapMollieStatusToPaymentStatus(molliePayment.status)
|
const status = mapMollieStatusToPaymentStatus(molliePayment.status)
|
||||||
|
|
||||||
// Update the payment status and provider data
|
// Update the payment status and provider data
|
||||||
|
// Use toPlainObject if available, otherwise spread the object
|
||||||
|
const providerData = typeof molliePayment.toPlainObject === 'function'
|
||||||
|
? molliePayment.toPlainObject()
|
||||||
|
: { ...molliePayment }
|
||||||
const updateSuccess = await updatePaymentStatus(
|
const updateSuccess = await updatePaymentStatus(
|
||||||
payload,
|
payload,
|
||||||
payment.id,
|
payment.id,
|
||||||
status,
|
status,
|
||||||
molliePayment.toPlainObject(),
|
providerData,
|
||||||
pluginConfig
|
pluginConfig
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -134,11 +138,24 @@ export const mollieProvider = (mollieConfig: MollieProviderConfig & {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Setup URLs with development defaults
|
// Setup URLs with development defaults
|
||||||
|
// Only use localhost fallbacks in non-production environments
|
||||||
const isProduction = process.env.NODE_ENV === 'production'
|
const isProduction = process.env.NODE_ENV === 'production'
|
||||||
const redirectUrl = mollieConfig.redirectUrl ||
|
const serverUrl = process.env.NEXT_PUBLIC_SERVER_URL || process.env.PAYLOAD_PUBLIC_SERVER_URL || process.env.SERVER_URL
|
||||||
(!isProduction ? 'https://localhost:3000/payment/success' : undefined)
|
|
||||||
const webhookUrl = mollieConfig.webhookUrl ||
|
// Priority: payment.redirectUrl > config.redirectUrl > dev fallback
|
||||||
`${process.env.PAYLOAD_PUBLIC_SERVER_URL || (!isProduction ? 'https://localhost:3000' : '')}/api/payload-billing/mollie/webhook`
|
let redirectUrl = payment.redirectUrl || mollieConfig.redirectUrl
|
||||||
|
if (!redirectUrl && !isProduction) {
|
||||||
|
redirectUrl = 'https://localhost:3000/payment/success'
|
||||||
|
}
|
||||||
|
|
||||||
|
let webhookUrl = mollieConfig.webhookUrl
|
||||||
|
if (!webhookUrl) {
|
||||||
|
if (serverUrl) {
|
||||||
|
webhookUrl = `${serverUrl}/api/payload-billing/mollie/webhook`
|
||||||
|
} else if (!isProduction) {
|
||||||
|
webhookUrl = 'https://localhost:3000/api/payload-billing/mollie/webhook'
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// Validate URLs for production
|
// Validate URLs for production
|
||||||
validateProductionUrl(redirectUrl, 'Redirect')
|
validateProductionUrl(redirectUrl, 'Redirect')
|
||||||
@@ -154,7 +171,11 @@ export const mollieProvider = (mollieConfig: MollieProviderConfig & {
|
|||||||
webhookUrl,
|
webhookUrl,
|
||||||
});
|
});
|
||||||
payment.providerId = molliePayment.id
|
payment.providerId = molliePayment.id
|
||||||
payment.providerData = molliePayment.toPlainObject()
|
// Use toPlainObject if available, otherwise spread the object (for compatibility with different Mollie client versions)
|
||||||
|
payment.providerData = typeof molliePayment.toPlainObject === 'function'
|
||||||
|
? molliePayment.toPlainObject()
|
||||||
|
: { ...molliePayment }
|
||||||
|
payment.checkoutUrl = molliePayment._links?.checkout?.href || null
|
||||||
return payment
|
return payment
|
||||||
},
|
},
|
||||||
} satisfies PaymentProvider
|
} satisfies PaymentProvider
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ import {
|
|||||||
import { isValidAmount, isValidCurrencyCode } from './currency'
|
import { isValidAmount, isValidCurrencyCode } from './currency'
|
||||||
import { createContextLogger } from '../utils/logger'
|
import { createContextLogger } from '../utils/logger'
|
||||||
|
|
||||||
const symbol = Symbol('stripe')
|
const symbol = Symbol.for('@xtr-dev/payload-billing/stripe')
|
||||||
|
|
||||||
export interface StripeProviderConfig {
|
export interface StripeProviderConfig {
|
||||||
secretKey: string
|
secretKey: string
|
||||||
@@ -234,6 +234,9 @@ export const stripeProvider = (stripeConfig: StripeProviderConfig) => {
|
|||||||
|
|
||||||
const stripe = singleton.get(payload)
|
const stripe = singleton.get(payload)
|
||||||
|
|
||||||
|
// Priority: payment.redirectUrl > config.returnUrl
|
||||||
|
const returnUrl = payment.redirectUrl || stripeConfig.returnUrl
|
||||||
|
|
||||||
// Create a payment intent
|
// Create a payment intent
|
||||||
const paymentIntent = await stripe.paymentIntents.create({
|
const paymentIntent = await stripe.paymentIntents.create({
|
||||||
amount: payment.amount, // Stripe handles currency conversion internally
|
amount: payment.amount, // Stripe handles currency conversion internally
|
||||||
@@ -250,6 +253,7 @@ export const stripeProvider = (stripeConfig: StripeProviderConfig) => {
|
|||||||
automatic_payment_methods: {
|
automatic_payment_methods: {
|
||||||
enabled: true,
|
enabled: true,
|
||||||
},
|
},
|
||||||
|
...(returnUrl && { return_url: returnUrl }),
|
||||||
})
|
})
|
||||||
|
|
||||||
payment.providerId = paymentIntent.id
|
payment.providerId = paymentIntent.id
|
||||||
|
|||||||
@@ -1,12 +1,12 @@
|
|||||||
import type { Payment } from '../plugin/types/payments'
|
import type { Payment } from '../plugin/types/payments'
|
||||||
import type { PaymentProvider, ProviderData } from '../plugin/types/index'
|
import type { PaymentProvider, ProviderData } from '../plugin/types/index'
|
||||||
import type { BillingPluginConfig } from '../plugin/config'
|
import type { BillingPluginConfig } from '../plugin/config'
|
||||||
import type { Payload } from 'payload'
|
import type { CollectionSlug, Payload } from 'payload'
|
||||||
import { handleWebhookError, logWebhookEvent } from './utils'
|
import { handleWebhookError, logWebhookEvent } from './utils'
|
||||||
import { isValidAmount, isValidCurrencyCode } from './currency'
|
import { isValidAmount, isValidCurrencyCode } from './currency'
|
||||||
import { createContextLogger } from '../utils/logger'
|
import { createContextLogger } from '../utils/logger'
|
||||||
|
|
||||||
const TestModeWarningSymbol = Symbol('TestModeWarning')
|
const TestModeWarningSymbol = Symbol.for('@xtr-dev/payload-billing/test-mode-warning')
|
||||||
const hasGivenTestModeWarning = () => TestModeWarningSymbol in globalThis
|
const hasGivenTestModeWarning = () => TestModeWarningSymbol in globalThis
|
||||||
const setTestModeWarning = () => ((<any>globalThis)[TestModeWarningSymbol] = true)
|
const setTestModeWarning = () => ((<any>globalThis)[TestModeWarningSymbol] = true)
|
||||||
|
|
||||||
@@ -160,6 +160,7 @@ export interface TestPaymentSession {
|
|||||||
method?: PaymentMethod
|
method?: PaymentMethod
|
||||||
createdAt: Date
|
createdAt: Date
|
||||||
status: PaymentOutcome
|
status: PaymentOutcome
|
||||||
|
redirectUrl?: string
|
||||||
}
|
}
|
||||||
|
|
||||||
// Use the proper BillingPluginConfig type
|
// Use the proper BillingPluginConfig type
|
||||||
@@ -228,7 +229,7 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const scenarios = testConfig.scenarios || DEFAULT_SCENARIOS
|
const scenarios = testConfig.scenarios || DEFAULT_SCENARIOS
|
||||||
const baseUrl = testConfig.baseUrl || (process.env.PAYLOAD_PUBLIC_SERVER_URL || 'http://localhost:3000')
|
const baseUrl = testConfig.baseUrl || process.env.NEXT_PUBLIC_SERVER_URL || process.env.PAYLOAD_PUBLIC_SERVER_URL || process.env.SERVER_URL || 'http://localhost:3000'
|
||||||
const uiRoute = testConfig.customUiRoute || '/test-payment'
|
const uiRoute = testConfig.customUiRoute || '/test-payment'
|
||||||
|
|
||||||
// Test mode warnings will be logged in onInit when payload is available
|
// Test mode warnings will be logged in onInit when payload is available
|
||||||
@@ -242,10 +243,15 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
{
|
{
|
||||||
path: '/payload-billing/test/payment/:id',
|
path: '/payload-billing/test/payment/:id',
|
||||||
method: 'get',
|
method: 'get',
|
||||||
handler: (req) => {
|
handler: async (req) => {
|
||||||
// Extract payment ID from URL path
|
// Extract payment ID from URL path
|
||||||
const urlParts = req.url?.split('/') || []
|
const urlParts = req.url?.split('/') || []
|
||||||
const paymentId = urlParts[urlParts.length - 1]
|
let paymentId = urlParts[urlParts.length - 1]
|
||||||
|
|
||||||
|
// Remove query parameters if present
|
||||||
|
if (paymentId?.includes('?')) {
|
||||||
|
paymentId = paymentId.split('?')[0]
|
||||||
|
}
|
||||||
|
|
||||||
if (!paymentId) {
|
if (!paymentId) {
|
||||||
return new Response(JSON.stringify({ error: 'Payment ID required' }), {
|
return new Response(JSON.stringify({ error: 'Payment ID required' }), {
|
||||||
@@ -263,7 +269,41 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
const session = testPaymentSessions.get(paymentId)
|
// Try to get session from memory first (for backward compatibility)
|
||||||
|
let session = testPaymentSessions.get(paymentId)
|
||||||
|
|
||||||
|
// If not in memory, fetch from database
|
||||||
|
if (!session && req.payload) {
|
||||||
|
try {
|
||||||
|
const paymentsConfig = pluginConfig.collections?.payments
|
||||||
|
const paymentSlug = typeof paymentsConfig === 'string' ? paymentsConfig : (paymentsConfig?.slug || 'payments')
|
||||||
|
const result = await req.payload.find({
|
||||||
|
collection: paymentSlug as CollectionSlug,
|
||||||
|
where: {
|
||||||
|
providerId: {
|
||||||
|
equals: paymentId
|
||||||
|
}
|
||||||
|
},
|
||||||
|
limit: 1
|
||||||
|
})
|
||||||
|
|
||||||
|
if (result.docs && result.docs.length > 0) {
|
||||||
|
const payment = result.docs[0] as Payment
|
||||||
|
// Create session from database payment
|
||||||
|
session = {
|
||||||
|
id: paymentId,
|
||||||
|
payment: payment,
|
||||||
|
createdAt: new Date(payment.createdAt || Date.now()),
|
||||||
|
status: 'pending' as PaymentOutcome
|
||||||
|
}
|
||||||
|
// Store in memory for future requests
|
||||||
|
testPaymentSessions.set(paymentId, session)
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error('Error fetching payment from database:', error)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (!session) {
|
if (!session) {
|
||||||
return new Response(JSON.stringify({ error: 'Payment session not found' }), {
|
return new Response(JSON.stringify({ error: 'Payment session not found' }), {
|
||||||
status: 404,
|
status: 404,
|
||||||
@@ -271,8 +311,11 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Determine redirect URL: session.redirectUrl > payment.redirectUrl > default
|
||||||
|
const redirectUrl = session.redirectUrl || (session.payment as Payment)?.redirectUrl || `${baseUrl}/payment/success`
|
||||||
|
|
||||||
// Generate test payment UI
|
// Generate test payment UI
|
||||||
const html = generateTestPaymentUI(session, scenarios, uiRoute, baseUrl, testConfig)
|
const html = generateTestPaymentUI(session, scenarios, uiRoute, baseUrl, testConfig, redirectUrl)
|
||||||
return new Response(html, {
|
return new Response(html, {
|
||||||
headers: { 'Content-Type': 'text/html' }
|
headers: { 'Content-Type': 'text/html' }
|
||||||
})
|
})
|
||||||
@@ -322,7 +365,41 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
|
|
||||||
const { paymentId, scenarioId, method } = validation.data!
|
const { paymentId, scenarioId, method } = validation.data!
|
||||||
|
|
||||||
const session = testPaymentSessions.get(paymentId)
|
// Try to get session from memory first
|
||||||
|
let session = testPaymentSessions.get(paymentId)
|
||||||
|
|
||||||
|
// If not in memory, fetch from database
|
||||||
|
if (!session && req.payload) {
|
||||||
|
try {
|
||||||
|
const paymentsConfig = pluginConfig.collections?.payments
|
||||||
|
const paymentSlug = typeof paymentsConfig === 'string' ? paymentsConfig : (paymentsConfig?.slug || 'payments')
|
||||||
|
const result = await req.payload.find({
|
||||||
|
collection: paymentSlug as CollectionSlug,
|
||||||
|
where: {
|
||||||
|
providerId: {
|
||||||
|
equals: paymentId
|
||||||
|
}
|
||||||
|
},
|
||||||
|
limit: 1
|
||||||
|
})
|
||||||
|
|
||||||
|
if (result.docs && result.docs.length > 0) {
|
||||||
|
const payment = result.docs[0] as Payment
|
||||||
|
// Create session from database payment
|
||||||
|
session = {
|
||||||
|
id: paymentId,
|
||||||
|
payment: payment,
|
||||||
|
createdAt: new Date(payment.createdAt || Date.now()),
|
||||||
|
status: 'pending' as PaymentOutcome
|
||||||
|
}
|
||||||
|
// Store in memory for future requests
|
||||||
|
testPaymentSessions.set(paymentId, session)
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error('Error fetching payment from database:', error)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (!session) {
|
if (!session) {
|
||||||
return new Response(JSON.stringify({ error: 'Payment session not found' }), {
|
return new Response(JSON.stringify({ error: 'Payment session not found' }), {
|
||||||
status: 404,
|
status: 404,
|
||||||
@@ -398,10 +475,15 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
{
|
{
|
||||||
path: '/payload-billing/test/status/:id',
|
path: '/payload-billing/test/status/:id',
|
||||||
method: 'get',
|
method: 'get',
|
||||||
handler: (req) => {
|
handler: async (req) => {
|
||||||
// Extract payment ID from URL path
|
// Extract payment ID from URL path
|
||||||
const urlParts = req.url?.split('/') || []
|
const urlParts = req.url?.split('/') || []
|
||||||
const paymentId = urlParts[urlParts.length - 1]
|
let paymentId = urlParts[urlParts.length - 1]
|
||||||
|
|
||||||
|
// Remove query parameters if present
|
||||||
|
if (paymentId?.includes('?')) {
|
||||||
|
paymentId = paymentId.split('?')[0]
|
||||||
|
}
|
||||||
|
|
||||||
if (!paymentId) {
|
if (!paymentId) {
|
||||||
return new Response(JSON.stringify({ error: 'Payment ID required' }), {
|
return new Response(JSON.stringify({ error: 'Payment ID required' }), {
|
||||||
@@ -419,7 +501,41 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
const session = testPaymentSessions.get(paymentId)
|
// Try to get session from memory first
|
||||||
|
let session = testPaymentSessions.get(paymentId)
|
||||||
|
|
||||||
|
// If not in memory, fetch from database
|
||||||
|
if (!session && req.payload) {
|
||||||
|
try {
|
||||||
|
const paymentsConfig = pluginConfig.collections?.payments
|
||||||
|
const paymentSlug = typeof paymentsConfig === 'string' ? paymentsConfig : (paymentsConfig?.slug || 'payments')
|
||||||
|
const result = await req.payload.find({
|
||||||
|
collection: paymentSlug,
|
||||||
|
where: {
|
||||||
|
providerId: {
|
||||||
|
equals: paymentId
|
||||||
|
}
|
||||||
|
},
|
||||||
|
limit: 1
|
||||||
|
})
|
||||||
|
|
||||||
|
if (result.docs && result.docs.length > 0) {
|
||||||
|
const payment = result.docs[0] as Payment
|
||||||
|
// Create session from database payment
|
||||||
|
session = {
|
||||||
|
id: paymentId,
|
||||||
|
payment: payment,
|
||||||
|
createdAt: new Date(payment.createdAt || Date.now()),
|
||||||
|
status: 'pending' as PaymentOutcome
|
||||||
|
}
|
||||||
|
// Store in memory for future requests
|
||||||
|
testPaymentSessions.set(paymentId, session)
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error('Error fetching payment from database:', error)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (!session) {
|
if (!session) {
|
||||||
return new Response(JSON.stringify({ error: 'Payment session not found' }), {
|
return new Response(JSON.stringify({ error: 'Payment session not found' }), {
|
||||||
status: 404,
|
status: 404,
|
||||||
@@ -480,18 +596,23 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
// Generate unique test payment ID
|
// Generate unique test payment ID
|
||||||
const testPaymentId = `test_pay_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`
|
const testPaymentId = `test_pay_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`
|
||||||
|
|
||||||
// Create test payment session
|
// Create test payment session with redirect URL
|
||||||
const session = {
|
const session: TestPaymentSession = {
|
||||||
id: testPaymentId,
|
id: testPaymentId,
|
||||||
payment: { ...payment },
|
payment: { ...payment },
|
||||||
createdAt: new Date(),
|
createdAt: new Date(),
|
||||||
status: 'pending' as PaymentOutcome
|
status: 'pending' as PaymentOutcome,
|
||||||
|
redirectUrl: payment.redirectUrl || undefined
|
||||||
}
|
}
|
||||||
|
|
||||||
testPaymentSessions.set(testPaymentId, session)
|
testPaymentSessions.set(testPaymentId, session)
|
||||||
|
|
||||||
// Set provider ID and data
|
// Set provider ID and data
|
||||||
payment.providerId = testPaymentId
|
payment.providerId = testPaymentId
|
||||||
|
// Use custom UI route if specified, otherwise use built-in UI endpoint
|
||||||
|
const paymentUrl = testConfig.customUiRoute
|
||||||
|
? `${baseUrl}${testConfig.customUiRoute}/${testPaymentId}`
|
||||||
|
: `${baseUrl}/api/payload-billing/test/payment/${testPaymentId}`
|
||||||
const providerData: ProviderData = {
|
const providerData: ProviderData = {
|
||||||
raw: {
|
raw: {
|
||||||
id: testPaymentId,
|
id: testPaymentId,
|
||||||
@@ -500,7 +621,7 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
description: payment.description,
|
description: payment.description,
|
||||||
status: 'pending',
|
status: 'pending',
|
||||||
testMode: true,
|
testMode: true,
|
||||||
paymentUrl: `${baseUrl}/api/payload-billing/test/payment/${testPaymentId}`,
|
paymentUrl,
|
||||||
scenarios: scenarios.map(s => ({ id: s.id, name: s.name, description: s.description })),
|
scenarios: scenarios.map(s => ({ id: s.id, name: s.name, description: s.description })),
|
||||||
methods: Object.entries(PAYMENT_METHODS).map(([key, value]) => ({
|
methods: Object.entries(PAYMENT_METHODS).map(([key, value]) => ({
|
||||||
id: key,
|
id: key,
|
||||||
@@ -512,6 +633,7 @@ export const testProvider = (testConfig: TestProviderConfig) => {
|
|||||||
provider: 'test'
|
provider: 'test'
|
||||||
}
|
}
|
||||||
payment.providerData = providerData
|
payment.providerData = providerData
|
||||||
|
payment.checkoutUrl = paymentUrl
|
||||||
|
|
||||||
return payment
|
return payment
|
||||||
},
|
},
|
||||||
@@ -599,7 +721,8 @@ function generateTestPaymentUI(
|
|||||||
scenarios: PaymentScenario[],
|
scenarios: PaymentScenario[],
|
||||||
uiRoute: string,
|
uiRoute: string,
|
||||||
baseUrl: string,
|
baseUrl: string,
|
||||||
testConfig: TestProviderConfig
|
testConfig: TestProviderConfig,
|
||||||
|
redirectUrl: string
|
||||||
): string {
|
): string {
|
||||||
const payment = session.payment
|
const payment = session.payment
|
||||||
const testModeIndicators = testConfig.testModeIndicators || {}
|
const testModeIndicators = testConfig.testModeIndicators || {}
|
||||||
@@ -913,9 +1036,9 @@ function generateTestPaymentUI(
|
|||||||
|
|
||||||
if (result.status === 'paid') {
|
if (result.status === 'paid') {
|
||||||
status.className = 'status success';
|
status.className = 'status success';
|
||||||
status.textContent = '✅ Payment successful!';
|
status.textContent = '✅ Payment successful! Redirecting...';
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
window.location.href = '${baseUrl}/success';
|
window.location.href = '${redirectUrl}';
|
||||||
}, 2000);
|
}, 2000);
|
||||||
} else if (result.status === 'failed' || result.status === 'cancelled' || result.status === 'expired') {
|
} else if (result.status === 'failed' || result.status === 'cancelled' || result.status === 'expired') {
|
||||||
status.className = 'status error';
|
status.className = 'status error';
|
||||||
|
|||||||
Reference in New Issue
Block a user