b0e6f83655
Implémente le chantier #6 de docs/tech/landing-optimisations.md. Le funnel signup propose maintenant un essai 14 j Pro avec carte demandée mais non prélevée — prélèvement automatique à J+14 avec rappel à J+11 (webhook customer.subscription.trial_will_end de Stripe). Couverture tests : 60 tests unitaires sur la couche billing - billing.spec.ts (25) — quota Free, bypass trial, inTrial state - stripe_billing.spec.ts (24) — handlers webhook, idempotence, dispatcher - trial_recap_job.spec.ts (11) — stats aggregation, formatRubisToHoursFr + 3 nouveaux tests vitest côté SPA (useTrialDaysRemaining, useIsAtFreeLimit bypass trial). Backend : - Migration 1779000000000_add_trial_ends_at_to_organizations - PLAN_CAPS bypass quand status=trialing AND trial_ends_at futur - getOrgSubscriptionState expose inTrial + trialEndsAt - Refactor handlers webhook en service stripe_billing.ts (pures, testables) — extraction depuis le controller. dispatchWebhookEvent routeur typé également extrait pour les tests. - createTrialCheckoutSession avec subscription_data.trial_period_days=14, garde-fou TrialAlreadyConsumedError contre re-trial. - handleTrialWillEnd → enqueue job recap (BullMQ jobId déterministe basé sur subscriptionId, idempotent contre re-delivery Stripe). - Endpoint POST /api/v1/billing/start-trial. - Email template trial_recap (React Email, branding Rubis figé) avec stats: factures importées, relances envoyées, € récupérés, rubis + heures libérées. Infra de test : - tests/helpers/stripe_mock.ts : __setStripeForTests injection + factories fakeSubscription / fakeCheckoutSession / fakeInvoice. - __setTrialRecapEnqueueForTests : permet de spy l'enqueue sans Redis. Frontend : - /onboarding/billing.tsx (opt-in, pas encore forcé dans le flow) : bouton primaire essai 14j + fallback "Free 2 factures". - PlanLimitBanner : nouveau état "Essai Pro · X jours restants" qui prime sur les autres bandeaux. Discret rubis-glow, non blocant. - useStartTrial hook + useTrialDaysRemaining (arrondi sup). - SubscriptionState typé avec inTrial + trialEndsAt. Landing : - Sous-texte CTA réactivé : « CB demandée, non prélevée avant J+14 » (Hero + FinalCTA), maintenant promesse véridique. Notes ouvertes (à décider ultérieurement) : - Tunnel /onboarding/billing FORCÉ entre signup et /onboarding/compte : guard reste à activer (risque cassage du signup actuel sinon). Pour l'instant l'écran est accessible mais opt-in. - Cron de redondance trial-recap : pas encore implémenté (le jobId déterministe BullMQ couvre déjà la double-livraison Stripe). À ajouter si on observe des trial sans recap en prod. - Tests E2E avec Stripe test mode à faire avant le go-live (cartes 3DS 4000 0027 6000 3184, declined 4000 0000 0000 0341). Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
59 lines
2.0 KiB
TypeScript
59 lines
2.0 KiB
TypeScript
/*
|
|
|--------------------------------------------------------------------------
|
|
| Queue workers
|
|
|--------------------------------------------------------------------------
|
|
|
|
|
| Boot des workers BullMQ. V1 : on les démarre dans le même process que
|
|
| l'API HTTP (simple, suffisant tant que le volume reste petit). En prod
|
|
| K3s on les extraira dans un Deployment séparé (cf. backend.md §13.4).
|
|
|
|
|
| Tolérance Redis : si Redis n'est pas joignable au boot, on log un
|
|
| warning et l'API HTTP démarre quand même. Les jobs ne tourneront pas
|
|
| mais le reste de l'app reste utilisable (utile en dev quand docker-
|
|
| compose n'est pas up).
|
|
|
|
|
*/
|
|
|
|
import app from '@adonisjs/core/services/app'
|
|
import logger from '@adonisjs/core/services/logger'
|
|
import { registerWorker, shutdownQueue } from '#services/queue'
|
|
import { sendRelanceJob } from '#jobs/send_relance_job'
|
|
import { sendCheckinJob } from '#jobs/send_checkin_job'
|
|
import { sendPaymentThanksJob } from '#jobs/send_payment_thanks_job'
|
|
import {
|
|
sendTrialRecapEmailJob,
|
|
type TrialRecapJobData,
|
|
} from '#jobs/send_trial_recap_email_job'
|
|
|
|
if (app.getEnvironment() === 'web') {
|
|
try {
|
|
registerWorker<{ taskId: string }>('relances', async (job) => {
|
|
await sendRelanceJob(job.data)
|
|
})
|
|
|
|
registerWorker<{ taskId: string; plain: string }>('checkins', async (job) => {
|
|
await sendCheckinJob(job.data)
|
|
})
|
|
|
|
registerWorker<{ invoiceId: string }>('payment-thanks', async (job) => {
|
|
await sendPaymentThanksJob(job.data)
|
|
})
|
|
|
|
registerWorker<TrialRecapJobData>('trial-recap', async (job) => {
|
|
await sendTrialRecapEmailJob(job.data)
|
|
})
|
|
|
|
logger.info('BullMQ workers ready (relances, checkins, payment-thanks, trial-recap)')
|
|
|
|
app.terminating(async () => {
|
|
logger.info('shutting down BullMQ workers')
|
|
await shutdownQueue()
|
|
})
|
|
} catch (err) {
|
|
logger.warn(
|
|
{ err },
|
|
"BullMQ workers couldn't start — Redis injoignable. L'API démarre quand même mais les jobs ne tourneront pas tant que Redis n'est pas up + serveur restart."
|
|
)
|
|
}
|
|
}
|