Add payment logs endpoint and improve CryptAPI callback handling

Author: ralyodio

src/routes/index.js

@@ -6,10 +6,11 @@ import { htmlToMarkdownRoute } from './html-to-markdown.js';
 import { markdownToHtmlRoute } from './markdown-to-html.js';
 import { htmlToEpubRoute } from './html-to-epub.js';
 import { documentHistoryRoute } from './document-history.js';
-import { 
-  subscriptionRoute, 
-  paymentCallbackRoute, 
-  subscriptionStatusRoute 
+import {
+  subscriptionRoute,
+  paymentCallbackRoute,
+  subscriptionStatusRoute,
+  paymentLogsRoute
 } from './subscription.js';
 import { apiKeyRoutes } from './api-keys.js';
 import { authMiddleware } from '../middleware/auth-middleware.js';
@@ -38,7 +39,8 @@ protectedRoutes.forEach(route => {
 const publicRoutes = [
   subscriptionRoute,
   paymentCallbackRoute,
-  subscriptionStatusRoute
+  subscriptionStatusRoute,
+  paymentLogsRoute
 ];
 
 /**

src/routes/subscription.js

@@ -72,28 +72,48 @@ export async function createSubscriptionHandler(c) {
 /**
  * Route handler for payment callback
  * @param {Object} c - Hono context
- * @returns {Response} - JSON response with status
+ * @returns {Response} - Plain text response with "ok" to acknowledge receipt
  */
 export async function paymentCallbackHandler(c) {
   try {
-    const callbackData = await c.req.json();
+    // Get callback data - could be JSON or query parameters
+    let callbackData;
+    const contentType = c.req.header('content-type');
+    
+    if (contentType && contentType.includes('application/json')) {
+      callbackData = await c.req.json();
+      console.log('Payment callback received (JSON):', JSON.stringify(callbackData));
+    } else {
+      // Get data from query parameters
+      const url = new URL(c.req.url);
+      callbackData = Object.fromEntries(url.searchParams.entries());
+      console.log('Payment callback received (Query):', JSON.stringify(callbackData));
+    }
+    
+    // Log important callback data
+    console.log(`Payment callback: uuid=${callbackData.uuid}, address_in=${callbackData.address_in}, txid_in=${callbackData.txid_in}`);
+    console.log(`Payment details: value_coin=${callbackData.value_coin}, pending=${callbackData.pending}, confirmations=${callbackData.confirmations}`);
+    
+    // Verify the callback signature if provided
+    const signature = c.req.header('x-ca-signature');
+    if (signature) {
+      console.log('Payment callback signature received:', signature);
+      // TODO: Implement signature verification
+    }
 
     // Process payment callback
     const subscription = await paymentService.processPaymentCallback(callbackData);
+    console.log(`Payment processed for subscription ${subscription.id}, status: ${subscription.status}`);
 
-    // Return success response
-    return c.json({
-      status: 'success',
-      subscription_id: subscription.id,
-      subscription_status: subscription.status
-    });
+    // Return plain text "ok" response as required by CryptAPI
+    return c.text('*ok*');
   } catch (error) {
     console.error('Error processing payment callback:', error);
-    // Always return 200 OK to CryptAPI, even if there's an error
-    return c.json({
-      status: 'error',
-      message: error.message
-    }, 200);
+    console.error('Error stack:', error.stack);
+    
+    // Always return 200 OK with "ok" to CryptAPI, even if there's an error
+    // This prevents CryptAPI from retrying the callback
+    return c.text('*ok*');
   }
 }
 
@@ -144,6 +164,31 @@ export async function subscriptionStatusHandler(c) {
   }
 }
 
+/**
+ * Route handler for checking payment logs
+ * @param {Object} c - Hono context
+ * @returns {Response} - JSON response with payment logs
+ */
+export async function paymentLogsHandler(c) {
+  try {
+    const { subscription_id } = await c.req.json();
+    
+    if (!subscription_id) {
+      return c.json({ error: 'Subscription ID is required' }, 400);
+    }
+    
+    // Get payment logs
+    const logs = await paymentService.checkPaymentLogs(subscription_id);
+    
+    return c.json({
+      subscription_id,
+      logs
+    });
+  } catch (error) {
+    return errorUtils.handleError(error, c);
+  }
+}
+
 /**
  * Route configuration for subscription endpoint
  */
@@ -155,11 +200,11 @@ export const subscriptionRoute = {
 };
 
 /**
- * Route configuration for payment callback endpoint
+ * Route configuration for CryptAPI payment callback endpoint
  */
 export const paymentCallbackRoute = {
   method: 'POST',
-  path: '/api/1/payment-callback',
+  path: '/api/1/payments/cryptapi/callback',
   middleware: [],
   handler: paymentCallbackHandler
 };
@@ -172,4 +217,14 @@ export const subscriptionStatusRoute = {
   path: '/api/1/subscription-status',
   middleware: [],
   handler: subscriptionStatusHandler
+};
+
+/**
+ * Route configuration for CryptAPI payment logs endpoint
+ */
+export const paymentLogsRoute = {
+  method: 'POST',
+  path: '/api/1/payments/cryptapi/logs',
+  middleware: [],
+  handler: paymentLogsHandler
 };