a6b35dfe7a
Migrations :
- relance_tasks (uuid id, organization_id FK CASCADE [scope direct sans join], invoice_id FK CASCADE, plan_step_id FK RESTRICT, send_at, status ENUM scheduled/sent/cancelled/failed, sent_at, queue_job_id pour cancel via BullMQ.remove). Indexes (org,status), (invoice_id), (send_at).
- checkin_tasks (uuid id, org_id, invoice_id, send_at, token_hash unique [SHA-256 du HMAC, TTL 24h], status ENUM scheduled/sent/answered/expired, answer 'paid'|'still_pending'). Pas encore branché — flow check-in arrivera dans un commit séparé (cf. backend.md §13.3).
Schema rules : status enums + answer typés.
Models RelanceTask + CheckinTask avec belongsTo Invoice / PlanStep.
Service relance_scheduler.ts :
- scheduleRelancesForInvoice(invoice) : pour chaque step du plan, calcule sendAt = dueDate + offsetDays. Si sendAt < now (facture importée en retard), on programme à `now + 1min` plutôt que skip — l'utilisateur "rattrape" une dette de relance, l'envoi immédiat est cohérent. Crée la RelanceTask + enqueue BullMQ avec delay, retry 5x exponential, jobId = `relance:<taskId>` pour idempotency. Cancelle les tasks scheduled existantes avant de re-programmer (gestion changement de plan).
- cancelFutureRelances(invoiceId, trx) : appelé par mark-paid pour stopper la chaîne.
Service queue.ts :
- getQueue(name) singleton lazy par queue
- registerWorker(name, handler) avec concurrency 5, log failed/completed
- shutdownQueue() pour le terminating hook Adonis
start/queue.ts (preload) : registerWorker('relances', sendRelanceJob) seulement quand `app.getEnvironment() === 'web'` (pas en tests/REPL — pas de connexion Redis pendant Japa).
Job send_relance_job.ts :
- Idempotent : si task.status !== 'scheduled', no-op
- Hook critique : si invoice paid/cancelled entre-temps, task.status = cancelled
- Mise en demeure (step.requiresManualValidation) : on n'envoie PAS, on log un activity_event 'warning_drafted' (cf. CLAUDE.md → Principes : validation manuelle obligatoire)
- Sinon : sendRelanceEmail + task.status=sent + invoice.rubisEarned+1 + organizations.rubis_count+1 + activity_event 'relance_sent'. Si invoice.status='pending', passe en 'in_relance' (sortie de l'état silencieux).
Service mail_dispatcher.ts : sendRelanceEmail interpole step.subject/body via mini moteur Mustache-like (renderTemplate, services/template.ts) avec {{client.name}}/{{numero}}/{{amount}}/{{dueDate}}/{{signature}}, puis @adonisjs/mail.use(MAIL_DRIVER) → Mailpit en dev, Resend en prod. Texte brut V1.
Triggers branchés :
- InvoicesController.store : si planId, scheduleRelancesForInvoice après création
- ImportBatchesController.validateDraft : pareil
- InvoicesController.markPaid : cancelFutureRelances dans la même tx que le paiement
#jobs/* ajouté aux imports package.json. Adonisrc preload start/queue.ts.
Bruno : doc 05-Invoices/04 Create maj avec instructions pour tester l'envoi immédiat (dueDate dans le passé → relance à now+1min → email visible dans Mailpit http://localhost:8025).
125 lines
3.7 KiB
TypeScript
125 lines
3.7 KiB
TypeScript
import { indexEntities } from '@adonisjs/core'
|
|
import { defineConfig } from '@adonisjs/core/app'
|
|
import { generateRegistry } from '@tuyau/core/hooks'
|
|
import { indexPolicies } from '@adonisjs/bouncer'
|
|
|
|
export default defineConfig({
|
|
/*
|
|
|--------------------------------------------------------------------------
|
|
| Experimental flags
|
|
|--------------------------------------------------------------------------
|
|
|
|
|
| The following features will be enabled by default in the next major release
|
|
| of AdonisJS. You can opt into them today to avoid any breaking changes
|
|
| during upgrade.
|
|
|
|
|
*/
|
|
experimental: {},
|
|
|
|
/*
|
|
|--------------------------------------------------------------------------
|
|
| Commands
|
|
|--------------------------------------------------------------------------
|
|
|
|
|
| List of ace commands to register from packages. The application commands
|
|
| will be scanned automatically from the "./commands" directory.
|
|
|
|
|
*/
|
|
commands: [
|
|
() => import('@adonisjs/core/commands'),
|
|
() => import('@adonisjs/lucid/commands'),
|
|
() => import('@adonisjs/session/commands'),
|
|
() => import('@adonisjs/bouncer/commands')
|
|
],
|
|
|
|
/*
|
|
|--------------------------------------------------------------------------
|
|
| Service providers
|
|
|--------------------------------------------------------------------------
|
|
|
|
|
| List of service providers to import and register when booting the
|
|
| application
|
|
|
|
|
*/
|
|
providers: [
|
|
() => import('@adonisjs/core/providers/app_provider'),
|
|
() => import('@adonisjs/core/providers/hash_provider'),
|
|
{
|
|
file: () => import('@adonisjs/core/providers/repl_provider'),
|
|
environment: ['repl', 'test'],
|
|
},
|
|
() => import('@adonisjs/core/providers/vinejs_provider'),
|
|
() => import('@adonisjs/session/session_provider'),
|
|
() => import('@adonisjs/shield/shield_provider'),
|
|
() => import('@adonisjs/lucid/database_provider'),
|
|
() => import('@adonisjs/cors/cors_provider'),
|
|
() => import('@adonisjs/auth/auth_provider'),
|
|
() => import('#providers/api_provider'),
|
|
() => import('@adonisjs/bouncer/bouncer_provider'),
|
|
() => import('@adonisjs/limiter/limiter_provider'),
|
|
() => import('@adonisjs/mail/mail_provider'),
|
|
() => import('@adonisjs/drive/drive_provider'),
|
|
],
|
|
|
|
/*
|
|
|--------------------------------------------------------------------------
|
|
| Preloads
|
|
|--------------------------------------------------------------------------
|
|
|
|
|
| List of modules to import before starting the application.
|
|
|
|
|
*/
|
|
preloads: [
|
|
() => import('#start/routes'),
|
|
() => import('#start/kernel'),
|
|
() => import('#start/validator'),
|
|
() => import('#start/queue'),
|
|
],
|
|
|
|
/*
|
|
|--------------------------------------------------------------------------
|
|
| Tests
|
|
|--------------------------------------------------------------------------
|
|
|
|
|
| List of test suites to organize tests by their type. Feel free to remove
|
|
| and add additional suites.
|
|
|
|
|
*/
|
|
tests: {
|
|
suites: [
|
|
{
|
|
files: ['tests/unit/**/*.spec.{ts,js}'],
|
|
name: 'unit',
|
|
timeout: 2000,
|
|
},
|
|
{
|
|
files: ['tests/functional/**/*.spec.{ts,js}'],
|
|
name: 'functional',
|
|
timeout: 30000,
|
|
},
|
|
],
|
|
forceExit: false,
|
|
},
|
|
|
|
/*
|
|
|--------------------------------------------------------------------------
|
|
| Metafiles
|
|
|--------------------------------------------------------------------------
|
|
|
|
|
| A collection of files you want to copy to the build folder when creating
|
|
| the production build.
|
|
|
|
|
*/
|
|
metaFiles: [],
|
|
|
|
hooks: {
|
|
init: [
|
|
indexEntities({
|
|
transformers: { enabled: true },
|
|
}),
|
|
generateRegistry(),
|
|
indexPolicies()
|
|
],
|
|
},
|
|
})
|