How to Integrate Replit with Payoneer

1// check-payoneer-secrets.js
2const required = ['PAYONEER_PARTNER_USERNAME', 'PAYONEER_API_PASSWORD',
3                  'PAYONEER_PROGRAM_ID', 'PAYONEER_API_BASE_URL'];
4for (const key of required) {
5  if (!process.env[key]) {
6    throw new Error(`Missing secret: ${key}. Set it in Replit Secrets (lock icon 🔒).`);
7  }
8}
9console.log('Payoneer secrets verified.');
10console.log('Program ID:', process.env.PAYONEER_PROGRAM_ID);
11console.log('API URL:', process.env.PAYONEER_API_BASE_URL);

1// payoneer.js — Payoneer Partner API for Node.js on Replit
2const axios = require('axios');
3const express = require('express');
4
5const app = express();
6app.use(express.json());
7
8// Build Basic Auth header
9const credentials = Buffer.from(
10  `${process.env.PAYONEER_PARTNER_USERNAME}:${process.env.PAYONEER_API_PASSWORD}`
11).toString('base64');
12
13const payoneerApi = axios.create({
14  baseURL: process.env.PAYONEER_API_BASE_URL,
15  headers: {
16    'Authorization': `Basic ${credentials}`,
17    'Content-Type': 'application/json'
18  }
19});
20
21// Register a payee (recipient must have or create a Payoneer account)
22app.post('/api/payees/register', async (req, res) => {
23  const { email, firstName, lastName } = req.body;
24  
25  if (!email) return res.status(400).json({ error: 'email required' });
26  
27  try {
28    const response = await payoneerApi.post('/payees/', {
29      payee_id: email,  // Use email as internal payee ID
30      type: 'individual',
31      registration_url_params: {
32        first_name: firstName,
33        last_name: lastName,
34        email
35      }
36    });
37    res.json({ success: true, payee: response.data });
38  } catch (err) {
39    res.status(err.response?.status || 500).json({ error: err.response?.data || err.message });
40  }
41});
42
43// Send a payment to a registered payee
44app.post('/api/payments/send', async (req, res) => {
45  const { payeeId, amount, currency = 'USD', description, internalRef } = req.body;
46  
47  if (!payeeId || !amount || !internalRef) {
48    return res.status(400).json({ error: 'payeeId, amount, and internalRef required' });
49  }
50  
51  try {
52    const response = await payoneerApi.post('/payments/', {
53      client_reference_id: internalRef,  // Your unique payment ID for idempotency
54      payee_id: payeeId,
55      amount: parseFloat(amount),
56      currency,
57      description: description || 'Payment'
58    });
59    res.json({
60      success: true,
61      transactionId: response.data.payment_id,
62      status: response.data.status,
63      amount: response.data.amount,
64      currency: response.data.currency
65    });
66  } catch (err) {
67    res.status(err.response?.status || 500).json({ error: err.response?.data || err.message });
68  }
69});
70
71// Check payment status
72app.get('/api/payments/:paymentId/status', async (req, res) => {
73  try {
74    const response = await payoneerApi.get(`/payments/${req.params.paymentId}`);
75    res.json({ paymentId: req.params.paymentId, status: response.data.status, details: response.data });
76  } catch (err) {
77    res.status(err.response?.status || 500).json({ error: err.response?.data || err.message });
78  }
79});
80
81// Get program balance
82app.get('/api/balance', async (req, res) => {
83  try {
84    const response = await payoneerApi.get('/balance/');
85    res.json({ balance: response.data });
86  } catch (err) {
87    res.status(err.response?.status || 500).json({ error: err.response?.data || err.message });
88  }
89});
90
91app.listen(3000, '0.0.0.0', () => console.log('Payoneer server running on port 3000'));

1# payoneer_api.py — Payoneer Partner API for Python on Replit
2import os
3import requests
4from flask import Flask, request, jsonify
5
6BASE_URL = os.environ['PAYONEER_API_BASE_URL']
7USERNAME = os.environ['PAYONEER_PARTNER_USERNAME']
8PASSWORD = os.environ['PAYONEER_API_PASSWORD']
9PROGRAM_ID = os.environ['PAYONEER_PROGRAM_ID']
10
11# requests handles Basic Auth encoding with the auth tuple
12session = requests.Session()
13session.auth = (USERNAME, PASSWORD)
14session.headers.update({'Content-Type': 'application/json'})
15
16app = Flask(__name__)
17
18@app.route('/api/balance')
19def get_balance():
20    resp = session.get(f'{BASE_URL}/balance/')
21    if not resp.ok:
22        return jsonify({'error': resp.text}), resp.status_code
23    return jsonify({'balance': resp.json()})
24
25@app.route('/api/payees/register', methods=['POST'])
26def register_payee():
27    data = request.get_json()
28    payload = {
29        'payee_id': data.get('email'),
30        'type': 'individual',
31        'registration_url_params': {
32            'first_name': data.get('firstName', ''),
33            'last_name': data.get('lastName', ''),
34            'email': data.get('email')
35        }
36    }
37    resp = session.post(f'{BASE_URL}/payees/', json=payload)
38    if not resp.ok:
39        return jsonify({'error': resp.json()}), resp.status_code
40    return jsonify({'success': True, 'payee': resp.json()})
41
42@app.route('/api/payments/send', methods=['POST'])
43def send_payment():
44    data = request.get_json()
45    payee_id = data.get('payeeId')
46    amount = data.get('amount')
47    internal_ref = data.get('internalRef')
48    
49    if not all([payee_id, amount, internal_ref]):
50        return jsonify({'error': 'payeeId, amount, and internalRef required'}), 400
51    
52    payload = {
53        'client_reference_id': internal_ref,
54        'payee_id': payee_id,
55        'amount': float(amount),
56        'currency': data.get('currency', 'USD'),
57        'description': data.get('description', 'Payment')
58    }
59    resp = session.post(f'{BASE_URL}/payments/', json=payload)
60    if not resp.ok:
61        return jsonify({'error': resp.json()}), resp.status_code
62    result = resp.json()
63    return jsonify({'success': True, 'transactionId': result.get('payment_id'), 'status': result.get('status')})
64
65@app.route('/api/payments/<payment_id>/status')
66def payment_status(payment_id):
67    resp = session.get(f'{BASE_URL}/payments/{payment_id}')
68    if not resp.ok:
69        return jsonify({'error': resp.text}), resp.status_code
70    return jsonify(resp.json())
71
72if __name__ == '__main__':
73    app.run(host='0.0.0.0', port=3000)