medplum / medplum / 29034873815

92%

push

github

feat(agent): auto-retry of messages already committed but failed (#9491)

* feat(agent): add durable queue

Signed-off-by: Derrick Farris <derrick@medplum.com>

* test(hl7): update new tests to use `vitest`

Signed-off-by: Derrick Farris <derrick@medplum.com>

* [autofix.ci] apply automated fixes

* tmp: swap to local mock server url

Signed-off-by: Derrick Farris <derrick@medplum.com>

* test(agent): convert new durable queue tests to `vitest`

Signed-off-by: Derrick Farris <derrick@medplum.com>

* test(agent): fix type of `process.exit` mock

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): fix regression after merge

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): flush WAL on queue teardown

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): separate retention/checkpoints, sweep at startup

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): requeue when message has not been sent yet

Signed-off-by: Derrick Farris <derrick@medplum.com>

* [autofix.ci] apply automated fixes

* feat(agent): auto-retry for HL7 messages

Signed-off-by: Derrick Farris <derrick@medplum.com>

* feat(agent): add `guaranteedDelivery` config

Signed-off-by: Derrick Farris <derrick@medplum.com>

* [autofix.ci] apply automated fixes

* feat(agent): add `errorCode` and error classification

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): fix dedupe logic, and store seq nos atomically

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): ensure storage error (CE/AE) can be retried

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): split channel -> queue from queue -> Bot status

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): make `guaranteedDelivery` the default

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): don't discard late ACKs

Signed-off-by: Derrick Farris <derrick@medplum.com>

* fix(agent): suppress app-level ACK ... (continued)

21955 of 24941 branches covered (88.03%)

Branch coverage included in aggregate %.

204 of 226 new or added lines in 7 files covered. (90.27%)

39104 of 41479 relevant lines covered (94.27%)

12421.95 hits per line