One-Click & One-Confirm
Upsell

Copiar// Ao iniciar sessão de checkout — ANTES do comprador pagar async function initCheckout(customerData, sessionId) { // 1. Criar ou recuperar cliente Stripe let customer = await stripe.customers.list({ email: customerData.email, limit: 1 }); if (!customer.data.length) { customer = await stripe.customers.create({ email: customerData.email, name: customerData.name, metadata: { funnel_session_id: sessionId }, }); } else { customer = customer.data[0]; } // 2. Criar SetupIntent para guardar cartão para upsells futuros const setupIntent = await stripe.setupIntents.create({ customer: customer.id, usage: 'off_session', // permite cobrar sem o cliente presente payment_method_types: ['card'], metadata: { funnel_session_id: sessionId }, }); // 3. Criar PaymentIntent para o produto principal const paymentIntent = await stripe.paymentIntents.create({ amount: product.price_cents, currency: 'mzn', customer: customer.id, setup_future_usage: 'off_session', // guarda o cartão automaticamente ao pagar metadata: { funnel_session_id: sessionId }, }); // 4. Guardar na sessão de funil await db.funnel_sessions.update(sessionId, { stripe_customer_id: customer.id, stripe_setup_intent_id: setupIntent.id, payment_context_expires: new Date(Date.now() + 30 * 60 * 1000), }); return { payment_client_secret: paymentIntent.client_secret, stripe_customer_id: customer.id, }; }

Copiar// Webhook Stripe — verificar assinatura HMAC antes de processar router.post('/webhook/stripe', express.raw({type:'*/*'}), async (req, res) => { const sig = req.headers['stripe-signature']; const event = stripe.webhooks.constructEvent(req.body, sig, process.env.STRIPE_WEBHOOK_SECRET); res.status(200).send('OK'); // responder imediatamente — processar assíncrono if (event.type === 'payment_intent.succeeded') { const pi = event.data.object; const sessionId = pi.metadata.funnel_session_id; if (!sessionId) return; // Idempotência — não processar o mesmo evento duas vezes const already = await redis.set(`stripe:evt:${event.id}`,'1','NX','EX',604800); if (!already) return; // Guardar token do cartão na sessão await db.funnel_sessions.update(sessionId, { payment_method_type: 'card', stripe_payment_method_id: pi.payment_method, // pm_abc123 — o token }); // Avançar sessão para o primeiro upsell await funnelEngine.advance(sessionId, 'accept', pi.id); } });

Copiarasync function chargeCardOneClick(session, step) { // Verificar que temos o token e que o contexto não expirou if (!session.stripe_payment_method_id) throw new Error('Token de cartão não encontrado'); if (new Date() > new Date(session.payment_context_expires)) { return { status: 'context_expired' }; // pedir dados de cartão novamente } try { const pi = await stripe.paymentIntents.create({ amount: step.price_cents, currency: 'mzn', customer: session.stripe_customer_id, payment_method: session.stripe_payment_method_id, confirm: true, // confirmar imediatamente off_session: true, // sem presença do cliente idempotency_key: `upsell_${session.id}_${step.id}`, }); if (pi.status === 'succeeded') { return { status: 'paid', payment_id: pi.id }; } // 3DS necessário — raro em off_session mas possível if (pi.status === 'requires_action') { return { status: 'requires_3ds', client_secret: pi.client_secret }; } } catch (err) { // Cartão recusado — sugerir M-Pesa/e-Mola como alternativa if (err.code === 'card_declined' || err.code === 'insufficient_funds') { return { status: 'declined', suggest_alternative: true }; } throw err; } }

Copiar/** * Aceita qualquer formato moçambicano e retorna 258XXXXXXXXX * Testa: +258841234567 | 258841234567 | 841234567 | 84 123-4567 */ function normalizePhone(raw) { let d = String(raw).replace(/\D/g, ''); // só dígitos if (d.startsWith('258258')) d = d.slice(3); // duplicado if (d.startsWith('258')) d = d.slice(3); // prefixo if (d.startsWith('00258')) d = d.slice(5); // alternativo if (d.length !== 9) throw new Error('Número inválido'); return '258' + d; } /** Detectar operador pelo prefixo do número */ function detectOperator(normalizedPhone) { const prefix = normalizedPhone.slice(3, 5); // dígitos 4 e 5 if (['84','85'].includes(prefix)) return 'mpesa'; if (['86','87'].includes(prefix)) return 'emola'; return null; } /** Mascarar número para mostrar na UI — nunca expor completo */ function maskPhone(normalizedPhone) { return '●●●● ' + normalizedPhone.slice(-4); } module.exports = { normalizePhone, detectOperator, maskPhone };

Copiarrouter.post('/webhook/mpesa', express.raw({type:'*/*'}), async (req, res) => { // Verificar assinatura HMAC — obrigatório if (!verifyMpesaSignature(req.body, req.headers)) { return res.status(401).send('Assinatura inválida'); } res.status(200).send('OK'); // responder imediatamente const payload = JSON.parse(req.body); const sessionId = payload.reference.split(':')[0]; // Idempotência const lock = await redis.set(`mpesa:evt:${payload.transaction_id}`,'1','NX','EX',604800); if (!lock) return; if (payload.result_code === 'SUCCESS') { const phone = normalizePhone(payload.msisdn); const operator = detectOperator(phone); // Guardar número normalizado + operador + máscara na sessão await db.funnel_sessions.update(sessionId, { payment_method_type: operator, // 'mpesa' | 'emola' payment_phone: phone, // '258841234567' payment_phone_masked: maskPhone(phone), // '●●●● 4567' payment_context_expires: new Date(Date.now() + 30 * 60 * 1000), }); await funnelEngine.advance(sessionId, 'accept', payload.transaction_id); } });

Copiarasync function chargeOneConfirm(session, step) { // Verificar contexto válido if (!session.payment_phone) throw new Error('Número de telefone não encontrado'); if (new Date() > new Date(session.payment_context_expires)) { return { status: 'context_expired' }; } const reference = `${session.id}:${step.id}`; const idempotency = `upsell_${session.id}_${step.id}_v1`; if (session.payment_method_type === 'mpesa') { // M-Pesa C2B — iniciar com número da sessão const tx = await mpesaSDK.c2b.initiate({ msisdn: session.payment_phone, // ← número da sessão, não do frontend amount: Math.round(step.price_cents / 100), reference, description: 'Opsellio Upsell', }); return { transaction_id: tx.conversation_id, status: 'awaiting_ussd' }; } if (session.payment_method_type === 'emola') { // e-Mola — payment request com número da sessão const tx = await emolaSDK.paymentRequest({ phone: session.payment_phone, // ← número da sessão amount: step.price_cents / 100, externalId: idempotency, }); return { transaction_id: tx.transactionId, status: 'awaiting_ussd' }; } } // Endpoint central — decide automaticamente qual método usar router.get('/funnel/accept', async (req, res) => { const { session, step } = await validateToken(req.query.t); // Lock Redis — prevenir double-pay const lockKey = `pay_lock:${session.id}:${step.id}`; const lock = await redis.set(lockKey, '1', 'NX', 'EX', 30); if (!lock) return res.redirect('/waiting?already=true'); let tx; if (session.payment_method_type === 'card') { tx = await chargeCardOneClick(session, step); if (tx.status === 'paid') return res.redirect(await getNextStepUrl(session)); if (tx.status === 'declined') return res.redirect(`/upsell-fail?suggest=mpesa&s=${session.id}`); } else { tx = await chargeOneConfirm(session, step); return res.redirect(`/waiting?tx=${tx.transaction_id}&s=${session.id}`); } });

Copiarasync function pollUpsellPayment(txId, sessionId, maskedPhone, operator) { const MAX_ATTEMPTS = 24; // 24 × 5s = 120s let attempts = 0; // Mostrar instrução específica por operador const instruction = { mpesa: `Vai receber uma mensagem M-Pesa em ${maskedPhone}. Confirma com o teu PIN M-Pesa.`, emola: `Vai receber uma mensagem e-Mola em ${maskedPhone}. Confirma com o teu PIN e-Mola.`, }[operator]; document.getElementById('instruction').textContent = instruction; document.getElementById('phone-display').textContent = maskedPhone; const poll = setInterval(async () => { attempts++; if (attempts >= MAX_ATTEMPTS) { clearInterval(poll); // Timeout — estado ambíguo, não erro definitivo showAmbiguous('Ainda a verificar. Se confirmaste, aguarda mais 5 minutos.'); return; } const { data } = await api.get(`/funnel/tx-status/${txId}?s=${sessionId}`); if (data.status === 'paid') { clearInterval(poll); window.location.href = data.next_step_url; // avançar para próximo upsell } if (data.status === 'failed') { clearInterval(poll); showError(data.error_message, data.suggest_alternative); } // 'pending' — continuar polling updateCountdown(MAX_ATTEMPTS - attempts); }, 5000); } // Fallback por WhatsApp se USSD não confirmado em 5 min function sendWhatsAppRecovery(sessionId, stepId, phone) { // Disparar após timeout — mensagem automática com token válido api.post('/funnel/recovery/whatsapp', { session_id: sessionId, step_id: stepId }); // A API envia: "O teu bónus expira em 30 min — clica aqui para activar" // com link que contém um token de accept válido }