Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

253 implement fault tolerance mechanisms eg retries dead letter queues circuit breakers e5 #280

Merged
Changes from 1 commit
Commits
Show all changes
37 commits
Select commit Hold shift + click to select a range
68241da
adding the retry logic on the database
ndefokou Dec 3, 2024
be8b064
adding the retry logic on the different protocols
ndefokou Dec 4, 2024
e472be9
fixe(): formating files
ndefokou Dec 5, 2024
3384fc3
implementing the circuit breaker
ndefokou Dec 11, 2024
ffc396b
implementing the circuit breaker
ndefokou Dec 11, 2024
3539283
implementing the circuit breaker
ndefokou Dec 11, 2024
124547c
fixe() test
ndefokou Dec 11, 2024
ae52335
fixe() file formating
ndefokou Dec 11, 2024
6c1b4be
fixe() removing tuples
ndefokou Dec 12, 2024
6bc341b
fixe() removing un use crate
ndefokou Dec 16, 2024
3885322
fixe()integrating the circuit breaker on the different protocols
ndefokou Dec 18, 2024
8bf79d9
fixe()formating files
ndefokou Dec 18, 2024
01d5d36
fixe()Removing code duplication
ndefokou Dec 19, 2024
2a729e0
fixe() Resolving conflicts
ndefokou Dec 20, 2024
9eff984
fixe():forward protocol
ndefokou Jan 9, 2025
2faec2c
feat: implement and integrate circuit breaker logic across all handlers
Hermann-Core Jan 24, 2025
fd655be
Merge remote-tracking branch 'origin/main' into 253-implement-fault-t…
Hermann-Core Jan 24, 2025
dc7f5b4
fix(breaker): fix code documentation test
Hermann-Core Jan 24, 2025
527b15c
doc(breaker): added public documentation to call method of the Circui…
Hermann-Core Jan 24, 2025
be6ee4c
updated breaker impl
Hermann-Core Jan 28, 2025
313c72e
writing tests
Hermann-Core Jan 28, 2025
713cbfa
refactored breaker implementation
Hermann-Core Jan 28, 2025
b72b083
fix cargo clippy complains
Hermann-Core Jan 29, 2025
3e7f695
tests(breaker): write tests to validate circuit breaker behavior
Hermann-Core Jan 29, 2025
ad68d94
refactor circuit breaker implementation and integration
Hermann-Core Jan 29, 2025
c875859
Merge remote-tracking branch 'origin/main' into 253-implement-fault-t…
Hermann-Core Jan 29, 2025
96bb600
remove unused dependencies to the project
Hermann-Core Jan 29, 2025
28ff978
Replace HashMap with DashMap to improve concurrent access in circuit …
Hermann-Core Jan 29, 2025
749e3d2
refinement(breaker): cleaning up the implementation
Hermann-Core Jan 30, 2025
a6c2eed
fix(breaker): fix failing test
Hermann-Core Jan 30, 2025
965133a
feat(breaker): add configurable failure threshold for half-open state
Hermann-Core Jan 30, 2025
899cc0c
feat(breaker): add configurable failure threshold for half-open state
Hermann-Core Jan 30, 2025
e7f3d78
Merge branch '253-implement-fault-tolerance-mechanisms-eg-retries-dea…
Hermann-Core Jan 30, 2025
85b06f4
Merge remote-tracking branch 'origin/main' into 253-implement-fault-t…
Hermann-Core Jan 31, 2025
3a51221
fix merge errors
Hermann-Core Jan 31, 2025
136585f
Merge remote-tracking branch 'origin/main' into 253-implement-fault-t…
Hermann-Core Feb 4, 2025
ffd93cf
fix clippy lints
Hermann-Core Feb 4, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix cargo clippy complains
Hermann-Core committed Jan 29, 2025
commit b72b083428f30cb836b24ac768cff374e0267e31
2 changes: 1 addition & 1 deletion crates/web-plugins/didcomm-messaging/src/error.rs
Original file line number Diff line number Diff line change
@@ -14,7 +14,7 @@ pub(crate) enum Error {
#[error("unsupported content-type, only accept application/didcomm-encrypted+json")]
NotDidcommEncryptedPayload,
#[error("Could not unpack message")]
UnpackingError,
CouldNotUnpack,
}

impl Error {
4 changes: 2 additions & 2 deletions crates/web-plugins/didcomm-messaging/src/midlw.rs
Original file line number Diff line number Diff line change
@@ -121,9 +121,9 @@ async fn unpack_payload(

let (plain_message, metadata) = res.map_err(|err| {
error!("Failed to unpack message: {}, {}", err.kind(), err.source);
let response = (StatusCode::BAD_REQUEST, Error::UnpackingError.json());
let response = (StatusCode::BAD_REQUEST, Error::CouldNotUnpack.json());

return response.into_response();
response.into_response()
})?;

if !metadata.encrypted {