7 commits

Author	SHA1	Message	Date
Adrià Casajús	3c13f1ce20	Have the dead letter also take events to avoid race conditions (#2267) ... * Have the dead letter also take events to avoid race conditions * Ensure we take the event * Tests for event taken * Rename	2024-10-17 09:16:33 +00:00
Adrià Casajús	df4c52815b	Add monitoring for app connections to the db (#2235)	2024-09-27 08:00:25 +02:00
Carlos Quintana	33c418d7c6	chore: allow to define a different DB_URI for event listener (#2189)	2024-08-20 14:01:48 +00:00
Adrià Casajús	8262390bf0	Close sessions between loops to make sure we leave no lock (#2162) ... * Close sessions between loops to make sure we leave no lock * Close at the end * Close before sleeps * Use python generic empty list in case the events is an iterator	2024-07-24 14:49:55 +00:00
Carlos Quintana	71ce0f6253	chore: add retry counter to event (#2159)	2024-07-23 14:11:16 +00:00
Carlos Quintana	6862ed3602	fix: event listener (#2119) ... * fix: commit transaction after taking event * feat: allow to reconnect to postgres for event listener * chore: log sync events pending to process to metrics * fix: make dead_letter runner able to process events without needing to have lock on the event * chore: close Session after reconnect * refactor: make EventSource emit only events that can be processed	2024-05-24 10:21:19 +02:00
Carlos Quintana	3e0b7bb369	Add sync events (#2113) ... * feat: add protocol buffers for events * chore: add EventDispatcher * chore: add WebhookEvent class * chore: emit events * feat: initial version of event listener * chore: emit user plan change with new timestamp * feat: emit metrics + add alias status to create event * chore: add newrelic decorator to functions * fix: event emitter fixes * fix: take null end_time into account * fix: avoid double-commits * chore: move UserDeleted event to User.delete method * db: add index to sync_event created_at and taken_time columns * chore: add index to model	2024-05-23 10:27:08 +02:00