Recevoir un webhook à chaque variation de prix (et republication / dépublication) sur un périmètre d’annonces, parser le payload, persister un historique advert_id → (price, occurred_at) exploitable pour calculer des tendances ou alerter sur les baisses.
Un chasseur immobilier intelligent (ou une fintech / un CRM agence) veut être notifié dès qu’une annonce déjà découverte baisse son prix, est republiée, ou disparaît. L’objectif : déclencher une action métier (notif client, re-scoring d’opportunité) dans la minute qui suit le changement, sans poller l’API.
Seules les alertes adverts émettent des events PRICE, REPUBLISHED et UNPUBLISHED. Les alertes properties ne reçoivent que CREATED (nouvelle property découverte) et MERGED (uniquement quand une nouvelle advert est fusionnée). Si le besoin est price tracking, il faut obligatoirement raisonner au niveau advert.Voir Property vs Advert et Match types & cycle alerte pour la liste exhaustive des events.
2
2. Créer l'alerte advert avec events
Combiner ALERT_MATCH_CREATED (première découverte) et ALERT_MATCH_ADVERT_EVENT (cycle de vie). Sans ALERT_MATCH_CREATED, vous ne recevriez jamais d’events car aucune advert n’aurait été matchée historiquement par cette alerte.
3. Parser le webhook (canonique : data.created + data.updated)
Le webhook a la shape canonique { data: { created: [{adverts, alert_id}], updated: [{adverts, alert_id}] } }. Les events PRICE / REPUBLISHED / UNPUBLISHED ne sont pas émis explicitement par le serveur — ils se dérivent côté client en comparant les adverts de la branche updated avec votre état stocké local. Le DTO réduit côté updated ne contient que flxId, currentPrice {value, valuePerArea}, isOnline.
# Pseudocode handleron POST /webhooks/fluximmo: body = parse(body) # Branche CREATED — AdvertDto complet for entry in body.data.created or []: for advert in entry.adverts: on_new_advert(advert.flxId, advert) store(advert.flxId, price = advert.currentPrice.value, online = advert.isOnline) # Branche UPDATED — DTO minimal, event dérivé client-side for entry in body.data.updated or []: for advert in entry.adverts: prev = load(advert.flxId) # état local stocké new_price = advert.currentPrice.value new_online = advert.isOnline if prev is None: # advert pas encore vue : traiter comme CREATED partiel store(advert.flxId, price = new_price, online = new_online) continue if new_price != prev.price: on_price_change(advert.flxId, prev.price, new_price) # event PRICE dérivé if new_online and not prev.online: on_republished(advert.flxId, advert) # event REPUBLISHED dérivé if not new_online and prev.online: on_unpublished(advert.flxId) # event UNPUBLISHED dérivé store(advert.flxId, price = new_price, online = new_online) return 200
Idempotence : dédup côté client avec une clé stable comme (advert.flxId, alert_id, currentPrice.value, isOnline). Vous recevrez parfois le même webhook deux fois sur retry réseau.
4
4. Stocker l'historique des prix
Une table append-only par (flx_id, occurred_at) suffit. Chaque event PRICE ajoute une ligne.
CREATE TABLE advert_price_history ( flx_id TEXT NOT NULL, price INTEGER NOT NULL, occurred_at TIMESTAMP NOT NULL DEFAULT NOW(), source TEXT NOT NULL, -- 'CREATED' | 'PRICE_DERIVED' | 'REPUBLISHED_DERIVED' PRIMARY KEY (flx_id, occurred_at));CREATE INDEX idx_price_history_flx ON advert_price_history (flx_id, occurred_at DESC);
À chaque webhook (CREATED ou PRICE), insérer une ligne avec le prix courant. Pour UNPUBLISHED, marquer dans une table séparée advert_lifecycle plutôt que de polluer l’historique de prix.
5
5. Calculer une tendance + alerter sur les baisses
# Pseudocodetrend(flx_id): rows = SELECT price, occurred_at FROM advert_price_history WHERE flx_id = ? ORDER BY occurred_at if rows.length < 2: return null first = rows.first.price last = rows.last.price return { first, last, delta_pct: round((last - first) / first * 100, 2) }on_price_change(flx_id, old_price, new_price): if old_price > 0: delta_pct = (new_price - old_price) / old_price * 100 if delta_pct <= -5: # baisse de 5 % ou plus notify_client(flx_id, old_price, new_price, delta_pct) insert_price_history(flx_id, new_price, source = "PRICE_DERIVED")
Confondre Properties et Adverts. Les alertes properties ne reçoivent pas d’events PRICE. Si vous ne recevez jamais de variation de prix, vérifiez que vous utilisez bien PUT /v2/protected/adverts/search/alerts (pas /properties/search/alerts).
Oublier le diff client-side. La branche data.updated[] ne porte qu’un DTO réduit (flxId, currentPrice, isOnline) — pas de event_type, pas de previous. Sans diff vs votre état local, vous mélangerez prix, republications et dépublications. Stockez systématiquement (price, isOnline) par flxId pour pouvoir comparer.
Recréer l’alerte au lieu de la modifier. Les events ne s’appliquent qu’aux adverts historiquement matchées par cette alerte précise. DELETE + PUT repart de zéro. Utiliser PATCH /alerts/{flxId} pour préserver l’historique.
Filtrage trop strict côté UI. Une variation de 1 € déclenche un webhook PRICE. Si vous affichez chaque event au client final, prévoyez un seuil minimum (ex. abs(delta_pct) >= 1) côté UI — pas côté ingestion (gardez tout en BDD).
