chore: release 1.6.3

fix: tests (#47 )
* fix: s3 port type mismatch, add string_or_number_to_string deserializer * fix: adding some tests * fix: adding some tests * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline --------- Co-authored-by: charlesgauthereau <charles.gauthereau@soluce-technologies.com>
2026-09-11 02:27:10 +00:00 · 2026-03-27 21:27:23 +00:00 · 2026-03-27 22:24:59 +01:00 · 2026-03-21 07:53:35 +00:00 · 2026-03-21 08:51:15 +01:00 · 2026-03-18 18:42:23 +00:00
137 changed files with 1516 additions and 657 deletions
@@ -1,3 +1,86 @@
+#name: Codecov Rust
+#
+#on:
+#  push:
+#    branches: ["main"]
+#  pull_request:
+#    branches: ["main"]
+#
+#env:
+#  CARGO_TERM_COLOR: always
+#
+#jobs:
+#  coverage:
+#    runs-on: ubuntu-latest
+#    steps:
+#      - uses: actions/checkout@v4
+#
+#      - name: Install Rust toolchain
+#        uses: dtolnay/rust-toolchain@stable
+#        with:
+#          components: llvm-tools-preview
+#
+#      - name: Build test image (with grcov included)
+#        run: docker compose -f docker-compose.test.yml build agent-test
+#
+#      - name: Run tests in container
+#        env:
+#          CARGO_TARGET_DIR: /app/target
+#          CARGO_INCREMENTAL: 0
+#          RUSTFLAGS: "-C instrument-coverage -C link-dead-code"
+#          LLVM_PROFILE_FILE: "/app/coverage/cargo-test-%p-%m.profraw"
+#        run: |
+#          docker compose -f docker-compose.test.yml run \
+#            -e CARGO_TARGET_DIR \
+#            -e CARGO_INCREMENTAL \
+#            -e RUSTFLAGS \
+#            -e LLVM_PROFILE_FILE \
+#            agent-test bash -c "cargo clean && cargo test --verbose && sync"
+#
+#      - name: Verify profraw files exist
+#        run: |
+#          docker compose -f docker-compose.test.yml run agent-test \
+#            find /app/coverage -type f -name "*.profraw" | wc -l || true
+#
+#      - name: Generate coverage report inside container
+#        run: |
+#          docker compose -f docker-compose.test.yml run agent-test bash -c "
+#            rustup component add llvm-tools &&
+#            grcov /app/coverage \
+#              --binary-path /app/target/debug \
+#              -s /app \
+#              --llvm \
+#              -t lcov \
+#              --branch \
+#              --ignore-not-existing \
+#              --ignore '/app/target/*' \
+#              --ignore '/*' \
+#              -o /app/lcov.info
+#          "
+#
+#      - name: Copy lcov.info from container to host
+#        run: |
+#          docker compose -f docker-compose.test.yml cp agent-test:/app/lcov.info ./lcov.info
+#
+#      - name: Remove container
+#        run: |
+#          docker rm agent-test-run
+#
+#      - name: Show basic coverage report info (debug)
+#        run: |
+#          echo "lcov.info size:" $(wc -c ./lcov.info | awk '{print $1}')
+#          head -n 30 ./lcov.info || true
+#
+#      - name: Upload coverage to Codecov
+#        uses: codecov/codecov-action@v5
+#        with:
+#          files: ./lcov.info
+#          flags: unittests
+#          name: rust-unit-coverage
+#          verbose: true
+#          fail_ci_if_error: true
+#        env:
+#          CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
 name: Codecov Rust

 on:
@@ -8,51 +91,82 @@ on:

 env:
  CARGO_TERM_COLOR: always
+  CARGO_TARGET_DIR: /app/target
+  CARGO_INCREMENTAL: 0
+  RUSTFLAGS: "-C instrument-coverage -C link-dead-code"
+  LLVM_PROFILE_FILE: "/app/coverage/cargo-test-%p-%m.profraw"

 jobs:
-  build:
+  coverage:
    runs-on: ubuntu-latest
-
    steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4

-      - uses: actions-rs/toolchain@v1
+      - name: Install Rust toolchain
+        uses: dtolnay/rust-toolchain@stable
        with:
-          toolchain: stable
-          override: true
          components: llvm-tools-preview

-      - name: Install grcov
-        run: cargo install grcov
+      - name: Build test image (with grcov included)
+        run: docker compose -f docker-compose.test.yml build agent-test

-      - name: Install test requirements
-        run: bash scripts/tests/requirements.sh
+      - name: Start agent-test container
+        run: docker compose -f docker-compose.test.yml up -d agent-test

-      - name: Build
-        run: cargo build --verbose
-
-      - name: Run tests
-        env:
-          CARGO_INCREMENTAL: 0
-          RUSTFLAGS: "-C instrument-coverage"
-          LLVM_PROFILE_FILE: "cargo-test-%p-%m.profraw"
-        run: cargo test --verbose
-
-      - name: Generate coverage
+      - name: Run tests inside container
        run: |
-          grcov . \
-            --binary-path ./target/debug/ \
-            -s . \
-            -t lcov \
-            --branch \
-            --ignore-not-existing \
-            -o lcov.info
+          docker compose -f docker-compose.test.yml exec \
+            -e CARGO_TARGET_DIR \
+            -e CARGO_INCREMENTAL \
+            -e RUSTFLAGS \
+            -e LLVM_PROFILE_FILE \
+            agent-test bash -c "
+              cargo clean &&
+              cargo test --verbose &&
+              sync
+            "

-      - name: Upload to Codecov
+      - name: Verify profraw files exist
+        run: |
+          docker compose -f docker-compose.test.yml exec \
+            -e LLVM_PROFILE_FILE \
+            agent-test find /app/coverage -type f -name "*.profraw" | wc -l || true
+
+      - name: Generate coverage report inside container
+        run: |
+          docker compose -f docker-compose.test.yml exec \
+            agent-test bash -c "
+              rustup component add llvm-tools &&
+              grcov /app/coverage \
+                --binary-path /app/target/debug \
+                -s /app \
+                --llvm \
+                -t lcov \
+                --branch \
+                --ignore-not-existing \
+                --ignore '/app/target/*' \
+                --ignore '/*' \
+                -o /app/lcov.info
+            "
+
+      - name: Copy lcov.info from container to host
+        run: docker compose -f docker-compose.test.yml cp agent-test:/app/lcov.info ./lcov.info
+
+      - name: Show basic coverage report info (debug)
+        run: |
+          echo "lcov.info size:" $(wc -c ./lcov.info | awk '{print $1}')
+          head -n 30 ./lcov.info || true
+
+      - name: Upload coverage to Codecov
        uses: codecov/codecov-action@v5
        with:
-          files: lcov.info
+          files: ./lcov.info
+          flags: unittests
+          name: rust-unit-coverage
          verbose: true
          fail_ci_if_error: true
        env:
-          CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
+          CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
+
+      - name: Stop and remove container
+        run: docker compose -f docker-compose.test.yml down
@@ -27,5 +27,5 @@ keywords:
  - self-hosted
  - portabase
 license: Apache-2.0
-version: 1.5.0
+version: 1.6.3
 date-released: '2026-02-24'
@@ -82,9 +82,9 @@ dependencies = [

 [[package]]
 name = "anstyle"
-version = "1.0.13"
+version = "1.0.14"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5192cca8006f1fd4f7237516f40fa183bb07f8fbdfedaa0036de5ea9b0b45e78"
+checksum = "940b3a0ca603d1eade50a4846a2afffd5ef57a9feac2c0e2ec2e14f9ead76000"

 [[package]]
 name = "anyhow"
@@ -275,9 +275,9 @@ dependencies = [

 [[package]]
 name = "aws-sdk-s3"
-version = "1.125.0"
+version = "1.126.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "223f5c95650d9557925a91f4c2db3def189e8f659452134a29e5cd2d37d708ed"
+checksum = "7878050a2321d215eec9db8be09f8db59418b53860ae86cc7042b4094d6cb2bb"
 dependencies = [
 "aws-credential-types",
 "aws-runtime",
@@ -744,9 +744,9 @@ dependencies = [

 [[package]]
 name = "bollard"
-version = "0.20.1"
+version = "0.20.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "227aa051deec8d16bd9c34605e7aaf153f240e35483dd42f6f78903847934738"
+checksum = "ee04c4c84f1f811b017f2fbb7dd8815c976e7ca98593de9c1e2afad0f636bff4"
 dependencies = [
 "async-stream",
 "base64 0.22.1",
@@ -869,9 +869,9 @@ dependencies = [

 [[package]]
 name = "cc"
-version = "1.2.56"
+version = "1.2.57"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "aebf35691d1bfb0ac386a69bac2fde4dd276fb618cf8bf4f5318fe285e821bb2"
+checksum = "7a0dd1ca384932ff3641c8718a02769f1698e7563dc6974ffd03346116310423"
 dependencies = [
 "find-msvc-tools",
 "jobserver",
@@ -1199,9 +1199,9 @@ dependencies = [

 [[package]]
 name = "darling"
-version = "0.21.3"
+version = "0.23.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9cdf337090841a411e2a7f3deb9187445851f91b309c0c0a29e05f74a00a48c0"
+checksum = "25ae13da2f202d56bd7f91c25fba009e7717a1e4a1cc98a76d844b65ae912e9d"
 dependencies = [
 "darling_core",
 "darling_macro",
@@ -1209,11 +1209,10 @@ dependencies = [

 [[package]]
 name = "darling_core"
-version = "0.21.3"
+version = "0.23.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1247195ecd7e3c85f83c8d2a366e4210d588e802133e1e355180a9870b517ea4"
+checksum = "9865a50f7c335f53564bb694ef660825eb8610e0a53d3e11bf1b0d3df31e03b0"
 dependencies = [
- "fnv",
 "ident_case",
 "proc-macro2",
 "quote",
@@ -1223,9 +1222,9 @@ dependencies = [

 [[package]]
 name = "darling_macro"
-version = "0.21.3"
+version = "0.23.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d38308df82d1080de0afee5d069fa14b0326a88c14f15c5ccda35b4a6c414c81"
+checksum = "ac3984ec7bd6cfa798e62b4a642426a5be0e68f9401cfc2a01e3fa9ea2fcdb8d"
 dependencies = [
 "darling_core",
 "quote",
@@ -1289,9 +1288,9 @@ dependencies = [

 [[package]]
 name = "derive-where"
-version = "1.6.0"
+version = "1.6.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ef941ded77d15ca19b40374869ac6000af1c9f2a4c0f3d4c70926287e6364a8f"
+checksum = "d08b3a0bcc0d079199cd476b2cae8435016ec11d1c0986c6901c5ac223041534"
 dependencies = [
 "proc-macro2",
 "quote",
@@ -1450,7 +1449,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "39cab71617ae0d63f51a36d69f866391735b51691dbda63cf6f96d042b63efeb"
 dependencies = [
 "libc",
- "windows-sys 0.60.2",
+ "windows-sys 0.61.2",
 ]

 [[package]]
@@ -1957,9 +1956,9 @@ checksum = "df3b46402a9d5adb4c86a0cf463f42e19994e3ee891101b1841f30a545cb49a9"

 [[package]]
 name = "hybrid-array"
-version = "0.4.7"
+version = "0.4.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e1b229d73f5803b562cc26e4da0396c8610a4ee209f4fac8fa4f8d709166dc45"
+checksum = "8655f91cd07f2b9d0c24137bd650fe69617773435ee5ec83022377777ce65ef1"
 dependencies = [
 "typenum",
 ]
@@ -2089,7 +2088,7 @@ dependencies = [
 "libc",
 "percent-encoding",
 "pin-project-lite",
- "socket2 0.5.10",
+ "socket2 0.6.3",
 "system-configuration",
 "tokio",
 "tower-service",
@@ -2680,7 +2679,7 @@ version = "0.50.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7957b9740744892f114936ab4a57b3f487491bbeafaf8083688b16841a4240e5"
 dependencies = [
- "windows-sys 0.60.2",
+ "windows-sys 0.61.2",
 ]

 [[package]]
@@ -2821,9 +2820,9 @@ dependencies = [

 [[package]]
 name = "once_cell"
-version = "1.21.3"
+version = "1.21.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "42f5e15c9953c5e4ccceeb2e7382a716482c34515315f7b03532b8b4e8393d2d"
+checksum = "9f7c3e4beb33f85d45ae3e3a1792185706c8e16d043238c593331cc7cd313b50"
 dependencies = [
 "critical-section",
 "portable-atomic",
@@ -2831,9 +2830,9 @@ dependencies = [

 [[package]]
 name = "openssl"
-version = "0.10.75"
+version = "0.10.76"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "08838db121398ad17ab8531ce9de97b244589089e290a384c900cb9ff7434328"
+checksum = "951c002c75e16ea2c65b8c7e4d3d51d5530d8dfa7d060b4776828c88cfb18ecf"
 dependencies = [
 "bitflags 2.11.0",
 "cfg-if",
@@ -2863,9 +2862,9 @@ checksum = "7c87def4c32ab89d880effc9e097653c8da5d6ef28e6b539d313baaacfbafcbe"

 [[package]]
 name = "openssl-sys"
-version = "0.9.111"
+version = "0.9.112"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "82cab2d520aa75e3c58898289429321eb788c3106963d0dc886ec7a5f4adc321"
+checksum = "57d55af3b3e226502be1526dfdba67ab0e9c96fc293004e79576b2b9edb0dbdb"
 dependencies = [
 "cc",
 "libc",
@@ -3039,7 +3038,7 @@ dependencies = [

 [[package]]
 name = "portabase-agent"
-version = "1.5.0"
+version = "1.6.3"
 dependencies = [
 "aes",
 "aes-gcm",
@@ -3256,7 +3255,7 @@ dependencies = [
 "quinn-udp",
 "rustc-hash",
 "rustls 0.23.37",
- "socket2 0.5.10",
+ "socket2 0.6.3",
 "thiserror 2.0.18",
 "tokio",
 "tracing",
@@ -3265,9 +3264,9 @@ dependencies = [

 [[package]]
 name = "quinn-proto"
-version = "0.11.13"
+version = "0.11.14"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f1906b49b0c3bc04b5fe5d86a77925ae6524a19b816ae38ce1e426255f1d8a31"
+checksum = "434b42fec591c96ef50e21e886936e66d3cc3f737104fdb9b737c40ffb94c098"
 dependencies = [
 "aws-lc-rs",
 "bytes",
@@ -3294,7 +3293,7 @@ dependencies = [
 "cfg_aliases",
 "libc",
 "once_cell",
- "socket2 0.5.10",
+ "socket2 0.6.3",
 "tracing",
 "windows-sys 0.60.2",
 ]
@@ -3647,7 +3646,7 @@ dependencies = [
 "errno",
 "libc",
 "linux-raw-sys",
- "windows-sys 0.60.2",
+ "windows-sys 0.61.2",
 ]

 [[package]]
@@ -3718,7 +3717,7 @@ dependencies = [
 "security-framework",
 "security-framework-sys",
 "webpki-root-certs",
- "windows-sys 0.60.2",
+ "windows-sys 0.61.2",
 ]

 [[package]]
@@ -3772,9 +3771,9 @@ dependencies = [

 [[package]]
 name = "schannel"
-version = "0.1.28"
+version = "0.1.29"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "891d81b926048e76efe18581bf793546b4c0eaf8448d72be8de2bbee5fd166e1"
+checksum = "91c1b7e4904c873ef0710c1f407dde2e6287de2bebc1bbbf7d430bb7cbffd939"
 dependencies = [
 "windows-sys 0.61.2",
 ]
@@ -3961,9 +3960,9 @@ dependencies = [

 [[package]]
 name = "serde_with"
-version = "3.17.0"
+version = "3.18.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "381b283ce7bc6b476d903296fb59d0d36633652b633b27f64db4fb46dcbfc3b9"
+checksum = "dd5414fad8e6907dbdd5bc441a50ae8d6e26151a03b1de04d89a5576de61d01f"
 dependencies = [
 "base64 0.22.1",
 "chrono",
@@ -3980,9 +3979,9 @@ dependencies = [

 [[package]]
 name = "serde_with_macros"
-version = "3.17.0"
+version = "3.18.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a6d4e30573c8cb306ed6ab1dca8423eec9a463ea0e155f45399455e0368b27e0"
+checksum = "d3db8978e608f1fe7357e211969fd9abdcae80bac1ba7a3369bb7eb6b404eb65"
 dependencies = [
 "darling",
 "proc-macro2",
@@ -4094,7 +4093,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "3a766e1110788c36f4fa1c2b71b387a7815aa65f88ce0229841826633d93723e"
 dependencies = [
 "libc",
- "windows-sys 0.60.2",
+ "windows-sys 0.61.2",
 ]

 [[package]]
@@ -4248,15 +4247,15 @@ dependencies = [

 [[package]]
 name = "tempfile"
-version = "3.26.0"
+version = "3.27.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "82a72c767771b47409d2345987fda8628641887d5466101319899796367354a0"
+checksum = "32497e9a4c7b38532efcdebeef879707aa9f794296a4f0244f6f69e9bc8574bd"
 dependencies = [
 "fastrand",
 "getrandom 0.4.2",
 "once_cell",
 "rustix",
- "windows-sys 0.60.2",
+ "windows-sys 0.61.2",
 ]

 [[package]]
@@ -4408,9 +4407,9 @@ dependencies = [

 [[package]]
 name = "tinyvec"
-version = "1.10.0"
+version = "1.11.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "bfa5fdc3bce6191a1dbc8c02d5c8bffcf557bafa17c124c5264a458f1b0613fa"
+checksum = "3e61e67053d25a4e82c844e8424039d9745781b3fc4f32b8d55ed50f5f667ef3"
 dependencies = [
 "tinyvec_macros",
 ]
@@ -4720,9 +4719,9 @@ dependencies = [

 [[package]]
 name = "tracing-subscriber"
-version = "0.3.22"
+version = "0.3.23"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2f30143827ddab0d256fd843b7a66d164e9f271cfa0dde49142c5ca0ca291f1e"
+checksum = "cb7f578e5945fb242538965c2d0b04418d38ec25c79d160cd279bf0731c8d319"
 dependencies = [
 "chrono",
 "matchers",
@@ -5171,7 +5170,7 @@ version = "0.1.11"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c2a7b1c03c876122aa43f3020e6c3c3ee5c05081c9a00739faf7503aeba10d22"
 dependencies = [
- "windows-sys 0.48.0",
+ "windows-sys 0.61.2",
 ]

 [[package]]
@@ -5736,18 +5735,18 @@ dependencies = [

 [[package]]
 name = "zerocopy"
-version = "0.8.40"
+version = "0.8.42"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a789c6e490b576db9f7e6b6d661bcc9799f7c0ac8352f56ea20193b2681532e5"
+checksum = "f2578b716f8a7a858b7f02d5bd870c14bf4ddbbcf3a4c05414ba6503640505e3"
 dependencies = [
 "zerocopy-derive",
 ]

 [[package]]
 name = "zerocopy-derive"
-version = "0.8.40"
+version = "0.8.42"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f65c489a7071a749c849713807783f70672b28094011623e200cb86dcb835953"
+checksum = "7e6cc098ea4d3bd6246687de65af3f920c430e236bee1e3bf2e441463f08a02f"
 dependencies = [
 "proc-macro2",
 "quote",
@@ -1,6 +1,6 @@
 [package]
 name = "portabase-agent"
-version = "1.5.0"
+version = "1.6.3"
 edition = "2024"

 [dependencies]
@@ -30,7 +30,7 @@ tokio-postgres = "0.7.15"
 futures = "0.3.31"
 tracing-appender = "0.2.4"
 time = { version = "0.3.44", features = ["macros"] }
-mongodb = "3.5.0"
+mongodb = "3.5.1"
 rand = "0.9.2"
 bytes = "1.11.0"
 async-stream = "0.3.6"
@@ -49,7 +49,7 @@ tokio-stream = "0.1.18"
 aes = "0.9.0-rc.4"
 typenum = "1.19.0"
 testcontainers = "0.27.1"
-testcontainers-modules = { version = "0.15.0", features = ["postgres", "redis"] }
+testcontainers-modules = { version = "0.15.0", features = ["postgres", "redis", "valkey", "mysql", "mariadb", "mongo"] }
 postgres = "0.19.12"
 url = "2.5.8"

@@ -57,9 +57,13 @@ url = "2.5.8"
 tokio = { version = "1", features = ["full"] }
 mockall = "0.13"
 testcontainers = "0.27.1"
-testcontainers-modules = { version = "0.15.0", features = ["postgres", "redis"] }
+testcontainers-modules = { version = "0.15.0", features = ["postgres", "redis", "mysql", "mariadb", "mongo"] }
 wiremock = "0.6"

+[profile.release]
+lto = true
+codegen-units = 1
+strip = "debuginfo"

 [[bin]]
 name = "app"
@@ -19,6 +19,8 @@
 [![PostgreSQL](https://img.shields.io/badge/PostgreSQL-336791?logo=postgresql&logoColor=white)](https://www.postgresql.org/)
 [![MySQL](https://img.shields.io/badge/MySQL-4479A1?logo=mysql&logoColor=white)](https://www.mysql.com/)
 [![SQLite](https://img.shields.io/badge/-SQLite-blue?logo=sqlite&logoColor=white)](https://sqlite.org/)
+[![Redis](https://img.shields.io/badge/Redis-DC382D?style=flat&logo=Redis&logoColor=white)](https://redis.io/)
+[![Valkey](https://img.shields.io/badge/Valkey-6284fc?style=flat&logo=Valkey&logoColor=white)](https://valkey.io/)
 [![MariaDB](https://img.shields.io/badge/MariaDB-003545?logo=mariadb&logoColor=white)](https://mariadb.org/)
 [![MongoDB](https://img.shields.io/badge/-MongoDB-13aa52?logo=mongodb&logoColor=white)](https://www.mongodb.com/)
 [![Self Hosted](https://img.shields.io/badge/self--hosted-yes-brightgreen)](https://github.com/Portabase/portabase)
@@ -60,11 +60,27 @@
    {
      "name": "Test database 9 - Redis Auth",
      "type": "redis",
-      "password": "m6o2L0Ukw3Og5RJUKh",
+      "password": "supersecurepassword",
      "port": 6379,
      "username": "default",
      "host": "db-redis-auth",
      "generated_id": "16678160-ff7e-4c97-8c83-0adeff214681"
+    },
+    {
+      "name": "Test database 10 - Valkey",
+      "type": "valkey",
+      "port": 6379,
+      "host": "db-valkey",
+      "generated_id": "16678560-ff7e-4c97-8c83-0adeff214681"
+    },
+    {
+      "name": "Test database 11 - Valkey Auth",
+      "type": "valkey",
+      "password": "supersecurepassword",
+      "port": 6379,
+      "username": "default",
+      "host": "db-valkey-auth",
+      "generated_id": "16678561-ff7e-4c97-8c83-0adeff214681"
    }
  ]
 }
@@ -14,7 +14,7 @@ services:
      LOG: info
      TZ: "Europe/Paris"
      #      DATABASES_CONFIG_FILE: "config.toml"
-      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiOGZmMDE4NTQtYjJhMS00ZTE0LTkwMjctZTJiOWIxZjQ1YzdlIiwicHVibGljS2V5IjoiLS0tLS1CRUdJTiBSU0EgUFVCTElDIEtFWS0tLS0tXG5NSUlCQ2dLQ0FRRUE5TWV4M2pmdnVLdFB5YU1ERnh2Ulp2dmd3YkRJQ2JzQi81Wll5NDNSVVRBaXZRYjJiSDdYXG5qRHBQd1lJeCs4UFBrbHlRbDVMQzV1UWZEaCs4SVd4OG1LZ3FvMXpWMkdiZXdGbEdEWFYxVEdyU1ZEU25aSWR4XG52bWdYc29EeXhVMlJvWUFUMS9YMWxuc2YxenZKdkFMTkhXdEhRdk42SjVDZTFSMmFsendVRGFEVXlJNzRmSldQXG5tNTh0SDMrYklXL0VVTXdjaWNxM0oySWw3Vm9KNkZNUHJQL1ZSOWEvdFF1SU1qa200MXpFY2NscExPa2luRkxuXG54NmVUWkFSZUpya2UrbnRvZ2t4TGEyRWV5a1lUNzB4V3hKNWp5ZExBVnRvNkkyQlVLVVJoTkowTUFaU29NYUtvXG5iMGJRcnY1UzExZWllMnMrT2I3aTYzSFpkVUx0UmV1MVJ3SURBUUFCXG4tLS0tLUVORCBSU0EgUFVCTElDIEtFWS0tLS0tXG4ifQ"
+      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiNWU1OGU2MGEtODhiMy00YTBjLWI0NDktNTQ3OWZhOTQzZDBkIiwibWFzdGVyS2V5QjY0IjoiQlhWM1hvbEM2NTZTVjdkTmdjV1BHUWxrKytycExJNmxHRGk3Q1BCNWllbz0ifQ=="
    extra_hosts:
      - "localhost:host-gateway"
    networks:
@@ -63,7 +63,6 @@ volumes:
  mongodb-data:
  mongodb-data-auth:

-
 networks:
  portabase:
    name: portabase_network
@@ -0,0 +1,22 @@
+services:
+  agent-test:
+    build:
+      context: .
+      dockerfile: docker/Dockerfile
+      target: dev
+    working_dir: /app
+    container_name: agent-test
+    volumes:
+      - .:/app
+      - cargo-registry:/usr/local/cargo/registry
+      - cargo-git:/usr/local/cargo/git
+      - /var/run/docker.sock:/var/run/docker.sock
+    environment:
+      APP_ENV: test
+      LOG: debug
+      TZ: Europe/Paris
+      EDGE_KEY: ""
+
+volumes:
+  cargo-registry:
+  cargo-git:
@@ -11,14 +11,16 @@ services:
      #      - ./databases.toml:/config/config.toml
      - cargo-registry:/usr/local/cargo/registry
      - cargo-git:/usr/local/cargo/git
-      - cargo-target:/app/target
+      - /var/run/docker.sock:/var/run/docker.sock
+
+    #      - cargo-target:/app/target
    #      - sqlite-data:/sqlite-data/workspace/data
    #      - ./scripts/sqlite/test-db:/sqlite-data-2/workspace/data
    environment:
      APP_ENV: development
      LOG: debug
      TZ: "Europe/Paris"
-      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiOGYwMmExZTAtNDY0NC00MWFmLWIzYjctYjZkYWNjNzQ4OWVhIiwibWFzdGVyS2V5QjY0IjoiQlhWM1hvbEM2NTZTVjdkTmdjV1BHUWxrKytycExJNmxHRGk3Q1BCNWllbz0ifQ=="
+      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiNGI1OTM2MGItNTNkMi00ZTZmLWE1ODctODcyMmQ1NDc1MTNmIiwibWFzdGVyS2V5QjY0IjoiQlhWM1hvbEM2NTZTVjdkTmdjV1BHUWxrKytycExJNmxHRGk3Q1BCNWllbz0ifQ=="
      #POOLING: 1
      #DATABASES_CONFIG_FILE: "config.toml"
    extra_hosts:
@@ -122,16 +124,39 @@ services:
    volumes:
      - redis-data-auth:/data
    environment:
-      - REDIS_PASSWORD=m6o2L0Ukw3Og5RJUKh
-    command: [ "redis-server", "--requirepass", "m6o2L0Ukw3Og5RJUKh", "--appendonly", "yes" ]
+      - REDIS_PASSWORD=supersecurepassword
+    command: [ "redis-server", "--requirepass", "supersecurepassword", "--appendonly", "yes" ]
+    networks:
+      - portabase
+
+  db-valkey:
+    image: valkey/valkey
+    container_name: db-valkey
+    environment:
+      - ALLOW_EMPTY_PASSWORD=yes
+    ports:
+      - '6381:6379'
+    volumes:
+      - valkey-data:/data
+    networks:
+      - portabase
+
+  db-valkey-auth:
+    image: valkey/valkey
+    container_name: db-valkey-auth
+    command: >
+      --requirepass "supersecurepassword"
+    ports:
+      - '6382:6379'
+    volumes:
+      - valkey-data-auth:/data
    networks:
      - portabase

 volumes:
  cargo-registry:
  cargo-git:
-  cargo-target:
-
+#  cargo-target:
  postgres-data:
  #  mariadb-data:
  #  mongodb-data:
@@ -139,6 +164,8 @@ volumes:
  #  sqlite-data:
  redis-data:
  redis-data-auth:
+  valkey-data:
+  valkey-data-auth:

 networks:
  portabase:
@@ -1,7 +1,7 @@
 # =========================
 # Base image (shared)
 # =========================
-FROM rust:1.92.0 AS base
+FROM rust:1.94.0 AS base

 RUN apt-get update && DEBIAN_FRONTEND=noninteractive apt-get install -y \
    pkg-config \
@@ -17,6 +17,7 @@ RUN apt-get update && DEBIAN_FRONTEND=noninteractive apt-get install -y \
    mariadb-client \
    sqlite3 \
    redis-tools \
+    valkey \
    && apt-get clean \
    && rm -rf /var/lib/apt/lists/*

@@ -59,6 +60,7 @@ WORKDIR /app
 FROM base AS dev

 RUN cargo install cargo-watch
+RUN cargo install grcov --locked

 COPY Cargo.toml Cargo.lock ./
 RUN mkdir src && echo "fn main() {}" > src/main.rs
@@ -96,6 +98,7 @@ RUN apt-get update && apt-get install -y \
    mariadb-client \
    sqlite3 \
    redis-tools \
+    valkey \
    && rm -rf /var/lib/apt/lists/*


@@ -35,5 +35,5 @@ check_docker
 check_network

 echo "Starting docker-compose..."
-docker-compose -f ./docker-compose.yml up
+docker compose -f ./docker-compose.yml up
 echo "Docker-compose started successfully."
@@ -34,16 +34,23 @@ if [ -n "$TZ" ]; then
    fi
 fi

+REDIS_PORT=65515
 echo "[entrypoint] APP_ENV=$APP_ENV"
 echo "[entrypoint] Starting Redis..."
-redis-server --daemonize yes
+redis-server --port $REDIS_PORT --daemonize yes

 echo "[entrypoint] Waiting for Redis to be ready..."
-until redis-cli ping >/dev/null 2>&1; do
+MAX_RETRIES=20
+COUNT=0
+until redis-cli -h localhost -p "$REDIS_PORT" ping >/dev/null 2>&1 ; do
+    COUNT=$((COUNT+1))
+    if [ $COUNT -ge $MAX_RETRIES ]; then
+        echo "[ERROR] Redis did not start after $MAX_RETRIES attempts"
+        exit 1
+    fi
    echo "[entrypoint] Redis not ready, sleeping 1s..."
    sleep 1
 done
-
 echo "[entrypoint] Redis is ready"


@@ -24,3 +24,7 @@ docker exec -it db-sqlite sqlite3 /workspace/data/app.db "SELECT * FROM users LI
 ```bash
 docker exec -it db-sqlite sqlite3 /workspace/data/app.db "SELECT name FROM sqlite_master WHERE type='table';"
 ```
+
+```bash
+docker compose -f docker-compose.test.yml run agent-test bash -c "cargo clean && cargo test" 
+```
@@ -1,87 +0,0 @@
-#!/usr/bin/env bash
-set -e
-
-POSTGRES_BASE="/usr/local/postgresql"
-echo "Detecting OS and architecture..."
-OS_TYPE="$(uname -s)"
-ARCH="$(uname -m)"
-
-install_pg_binaries() {
-    echo "Installing PostgreSQL binaries for versions 12-18..."
-
-    for v in 12 13 14 15 16 17 18; do
-        TARGET_DIR="$POSTGRES_BASE/$v/bin"
-        sudo mkdir -p "$TARGET_DIR"
-
-        if [[ "$OS_TYPE" == "Linux" ]]; then
-            if [[ "$ARCH" == "x86_64" ]]; then
-                SRC_DIR="./assets/tools/amd64/postgresql/postgresql-$v/bin"
-            elif [[ "$ARCH" == "aarch64" ]]; then
-                SRC_DIR="./assets/tools/arm64/postgresql/postgresql-$v/bin"
-            else
-                echo "Unsupported architecture: $ARCH"
-                continue
-            fi
-
-            if [[ -d "$SRC_DIR" ]]; then
-                echo "Copying PostgreSQL $v binaries from $SRC_DIR to $TARGET_DIR"
-                sudo cp -r "$SRC_DIR"/* "$TARGET_DIR/"
-            else
-                echo "Binaries for PostgreSQL $v not found for Linux, skipping..."
-                continue
-            fi
-
-        elif [[ "$OS_TYPE" == "Darwin" ]]; then
-            PG_SRC="$(brew --prefix postgresql@$v)/bin" 2>/dev/null || true
-
-            if [[ ! -d "$PG_SRC" ]]; then
-                echo "PostgreSQL $v not installed via Homebrew. Trying to install..."
-                if ! brew install postgresql@$v; then
-                    echo "PostgreSQL $v not available, skipping..."
-                    continue
-                fi
-                PG_SRC="$(brew --prefix postgresql@$v)/bin"
-            fi
-
-            echo "Copying PostgreSQL $v binaries from $PG_SRC to $TARGET_DIR"
-            sudo cp -r "$PG_SRC"/* "$TARGET_DIR/"
-        fi
-
-        sudo chown -R "$(whoami)" "$TARGET_DIR"
-        chmod +x "$TARGET_DIR"/*
-    done
-
-    echo "PostgreSQL binaries installed under $POSTGRES_BASE"
-}
-
-if [[ "$OS_TYPE" == "Linux" ]]; then
-    if command -v apt >/dev/null 2>&1; then
-        echo "Linux detected with apt. Installing prerequisites..."
-        sudo apt update
-        sudo apt install -y wget gnupg lsb-release redis-tools
-        install_pg_binaries
-    else
-        echo "Unsupported Linux distribution. Only apt-based distros are supported."
-        exit 1
-    fi
-
-elif [[ "$OS_TYPE" == "Darwin" ]]; then
-    if command -v brew >/dev/null 2>&1; then
-        echo "macOS detected. Installing prerequisites..."
-        brew install redis
-
-        sudo mkdir -p "$POSTGRES_BASE"
-        sudo chown -R "$(whoami)" "$POSTGRES_BASE"
-
-        install_pg_binaries
-    else
-        echo "Homebrew not found. Please install Homebrew first: https://brew.sh/"
-        exit 1
-    fi
-
-else
-    echo "Unsupported OS: $OS_TYPE"
-    exit 1
-fi
-
-echo "Tools installation completed successfully."
@@ -4,11 +4,11 @@ use crate::core::context::Context;
 use crate::services::backup::BackupService;
 use crate::services::config::ConfigService;
 use crate::services::cron::CronService;
+use crate::services::restore::RestoreService;
 use crate::services::status::StatusService;
 use crate::utils::common::BackupMethod;
 use std::sync::Arc;
 use tracing::info;
-use crate::services::restore::RestoreService;

 pub struct Agent {
    ctx: Arc<Context>,
@@ -43,23 +43,30 @@ impl Agent {
        let ping_result = self.status_service.ping(&config.databases).await?;

        for db in ping_result.databases.iter() {
-            let database = config.databases.iter().find(|cfg_db|cfg_db.generated_id == db.generated_id).unwrap();
+            let database = config
+                .databases
+                .iter()
+                .find(|cfg_db| cfg_db.generated_id == db.generated_id)
+                .unwrap();
            info!(
                "Generated Id: {} | backup action: {} | restore action: {} | Database Name: {}",
-                 db.generated_id, db.data.backup.action, db.data.restore.action, database.name,
+                db.generated_id, db.data.backup.action, db.data.restore.action, database.name,
            );
            let _ = self.cron_service.sync(db).await;

            if db.data.backup.action {
                let _ = self
                    .backup_service
-                    .dispatch(&db.generated_id, &config, method.clone(), &db.storages, db.encrypt)
+                    .dispatch(
+                        &db.generated_id,
+                        &config,
+                        method.clone(),
+                        &db.storages,
+                        db.encrypt,
+                    )
                    .await;
            } else if db.data.restore.action {
-                let _ = self
-                    .restore_service
-                    .dispatch(db, &config)
-                    .await;
+                let _ = self.restore_service.dispatch(db, &config).await;
            }
        }

@@ -35,7 +35,7 @@ impl Context {
                panic!("Cannot initialize AgentContext due to invalid EDGE_KEY");
            }
        };
-        
+
        let server_url = format!("{}/api", edge_key.server_url);
        let api_client = ApiClient::new(server_url);

@@ -1,2 +1,2 @@
-pub mod context;
 pub mod agent;
+pub mod context;
@@ -4,6 +4,7 @@ use crate::domain::postgres::database::PostgresDatabase;
 use crate::domain::postgres::{detect_format_from_file, detect_format_from_size};
 use crate::domain::redis::database::RedisDatabase;
 use crate::domain::sqlite::database::SqliteDatabase;
+use crate::domain::valkey::database::ValkeyDatabase;
 use crate::services::config::{DatabaseConfig, DbType};
 use anyhow::Result;
 use std::path::{Path, PathBuf};
@@ -13,8 +14,8 @@ use std::sync::Arc;
 pub trait Database: Send + Sync {
    fn file_extension(&self) -> &'static str;
    async fn ping(&self) -> Result<bool>;
-    async fn backup(&self, backup_dir: &Path, is_test: Option<bool>) -> Result<PathBuf>;
-    async fn restore(&self, restore_file: &Path, is_test: Option<bool>) -> Result<()>;
+    async fn backup(&self, backup_dir: &Path) -> Result<PathBuf>;
+    async fn restore(&self, restore_file: &Path) -> Result<()>;
 }

 pub struct DatabaseFactory;
@@ -31,6 +32,7 @@ impl DatabaseFactory {
            DbType::MongoDB => Arc::new(MongoDatabase::new(cfg)),
            DbType::Sqlite => Arc::new(SqliteDatabase::new(cfg)),
            DbType::Redis => Arc::new(RedisDatabase::new(cfg)),
+            DbType::Valkey => Arc::new(ValkeyDatabase::new(cfg)),
        }
    }

@@ -45,6 +47,7 @@ impl DatabaseFactory {
            DbType::MongoDB => Arc::new(MongoDatabase::new(cfg)),
            DbType::Sqlite => Arc::new(SqliteDatabase::new(cfg)),
            DbType::Redis => Arc::new(RedisDatabase::new(cfg)),
+            DbType::Valkey => Arc::new(ValkeyDatabase::new(cfg)),
        }
    }
 }
@@ -1,7 +1,7 @@
 pub mod factory;
-pub mod postgres;
-pub mod mysql;
 mod mongodb;
-mod sqlite;
+pub mod mysql;
+pub mod postgres;
 mod redis;
-
+mod sqlite;
+mod valkey;
@@ -15,6 +15,7 @@ pub async fn run(

        let file_path = backup_dir.join(format!("{}{}", cfg.generated_id, file_extension));
        let mongodump = select_mongo_path().join("mongodump");
+        info!("{:?}", mongodump);
        let uri = get_mongo_uri(cfg.clone())?;

        let output = Command::new(mongodump)
@@ -16,9 +16,11 @@ pub fn select_mongo_path() -> std::path::PathBuf {
 }

 pub fn get_mongo_uri(cfg: DatabaseConfig) -> Result<String> {
-
    if cfg.username.is_empty() || cfg.password.is_empty() {
-        Ok(format!("mongodb://{}:{}/{}", cfg.host, cfg.port, cfg.database))
+        Ok(format!(
+            "mongodb://{}:{}/{}",
+            cfg.host, cfg.port, cfg.database
+        ))
    } else {
        Ok(format!(
            "mongodb://{}:{}@{}:{}/{}?authSource=admin",
@@ -26,5 +28,3 @@ pub fn get_mongo_uri(cfg: DatabaseConfig) -> Result<String> {
        ))
    }
 }
-
-
@@ -27,27 +27,17 @@ impl Database for MongoDatabase {
        ping::run(self.cfg.clone()).await
    }

-    async fn backup(&self, dir: &Path, is_test: Option<bool>) -> Result<PathBuf> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
-        }
+    async fn backup(&self, dir: &Path) -> Result<PathBuf> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
        let res = backup::run(self.cfg.clone(), dir.to_path_buf(), self.file_extension()).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }

-    async fn restore(&self, file: &Path,  is_test: Option<bool>) -> Result<()> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
-        }
+    async fn restore(&self, file: &Path) -> Result<()> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
        let res = restore::run(self.cfg.clone(), file.to_path_buf()).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }
 }
@@ -1,5 +1,5 @@
 mod backup;
-mod restore;
+mod connection;
 pub mod database;
 mod ping;
-mod connection;
+mod restore;
@@ -24,7 +24,7 @@ pub async fn run(cfg: DatabaseConfig) -> Result<bool> {
            error!("Full Error: {}", e);
            error!("Check you database network connectivity");
            error!("----------------------------------------");
-            Err(anyhow::anyhow!("Ping failed for {}: {}", cfg.name, e))
+            Ok(false)
        }
    }
 }
@@ -1,4 +1,4 @@
-use crate::domain::mysql::connection::{server_version};
+use crate::domain::mysql::connection::server_version;
 use crate::services::config::DatabaseConfig;
 use anyhow::{Context, Result};
 use std::collections::HashMap;
@@ -1,14 +1,17 @@
 use crate::services::config::DatabaseConfig;
-use std::process::Command;
 use anyhow::Result;
+use std::process::Command;

 pub async fn server_version(cfg: &DatabaseConfig) -> Result<String> {
-
    let output = Command::new("mysql")
-        .arg("--host").arg(&cfg.host)
-        .arg("--port").arg(cfg.port.to_string())
-        .arg("--user").arg(&cfg.username)
-        .arg("-e").arg("SELECT VERSION();")
+        .arg("--host")
+        .arg(&cfg.host)
+        .arg("--port")
+        .arg(cfg.port.to_string())
+        .arg("--user")
+        .arg(&cfg.username)
+        .arg("-e")
+        .arg("SELECT VERSION();")
        .env("MYSQL_PWD", &cfg.password)
        .output()?;

@@ -19,11 +22,10 @@ pub async fn server_version(cfg: &DatabaseConfig) -> Result<String> {

    let version = String::from_utf8_lossy(&output.stdout)
        .lines()
-        .nth(1) // skip column header
+        .nth(1)
        .unwrap_or_default()
        .trim()
        .to_string();

    Ok(version)
 }
-
@@ -1,14 +1,11 @@
-use std::collections::HashMap;
-use anyhow::Result;
-use async_trait::async_trait;
-use std::path::{Path, PathBuf};
-use super::{
-    backup,
-    ping, restore,
-};
+use super::{backup, ping, restore};
 use crate::domain::factory::Database;
 use crate::services::config::DatabaseConfig;
 use crate::utils::locks::{DbOpLock, FileLock};
+use anyhow::Result;
+use async_trait::async_trait;
+use std::collections::HashMap;
+use std::path::{Path, PathBuf};

 pub struct MySQLDatabase {
    cfg: DatabaseConfig,
@@ -36,28 +33,23 @@ impl Database for MySQLDatabase {
        ping::run(self.cfg.clone(), self.build_env().clone()).await
    }

-
-    async fn backup(&self, dir: &Path, is_test: Option<bool>) -> Result<PathBuf> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
-        }
-        let res = backup::run(self.cfg.clone(), dir.to_path_buf(), self.build_env().clone(), self.file_extension()).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+    async fn backup(&self, dir: &Path) -> Result<PathBuf> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
+        let res = backup::run(
+            self.cfg.clone(),
+            dir.to_path_buf(),
+            self.build_env().clone(),
+            self.file_extension(),
+        )
+        .await;
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }

-    async fn restore(&self, file: &Path, is_test: Option<bool>) -> Result<()> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
-        }
+    async fn restore(&self, file: &Path) -> Result<()> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
        let res = restore::run(self.cfg.clone(), file.to_path_buf()).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }
 }
@@ -1,5 +1,5 @@
 pub mod backup;
+mod connection;
 pub mod database;
-mod restore;
 mod ping;
-mod connection;
+mod restore;
@@ -4,7 +4,6 @@ use tokio::process::Command;
 use tokio::time::{Duration, timeout};

 pub async fn run(cfg: DatabaseConfig, env: HashMap<String, String>) -> anyhow::Result<bool> {
-
    let mut cmd = Command::new("mysqladmin");
    cmd.arg("--host")
        .arg(cfg.host)
@@ -11,7 +11,6 @@ pub async fn run(
    cfg: DatabaseConfig,
    format: PostgresDumpFormat,
    backup_dir: PathBuf,
-    is_test: Option<bool>
 ) -> Result<PathBuf> {
    tokio::task::spawn_blocking(move || -> Result<PathBuf> {
        debug!("Starting backup for database {}", cfg.name);
@@ -27,8 +26,8 @@ pub async fn run(
            }
        };

-        let pg_dump = select_pg_path(&version, is_test).join("pg_dump");
-        
+        let pg_dump = select_pg_path(&version).join("pg_dump");
+
        debug!("Using pg_dump at {:?}", pg_dump);

        match format {
@@ -28,14 +28,9 @@ pub async fn server_version(cfg: &DatabaseConfig) -> Result<String> {
    Ok(version)
 }

-pub fn select_pg_path(version: &str, is_test: Option<bool>) -> std::path::PathBuf {
+pub fn select_pg_path(version: &str) -> std::path::PathBuf {
    let major = version.split('.').next().unwrap_or("17");
-
-    if is_test.unwrap_or(false) {
-        format!("/usr/local/postgresql/{}/bin", major).into()
-    } else {
-        format!("/usr/lib/postgresql/{}/bin", major).into()
-    }
+    format!("/usr/lib/postgresql/{}/bin", major).into()
 }

 pub async fn terminate_connections(cfg: &DatabaseConfig) -> Result<()> {
@@ -31,27 +31,17 @@ impl Database for PostgresDatabase {
        ping::run(self.cfg.clone()).await
    }

-    async fn backup(&self, dir: &Path, is_test: Option<bool>) -> Result<PathBuf> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
-        }
-        let res = backup::run(self.cfg.clone(), self.format, dir.to_path_buf(), is_test).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+    async fn backup(&self, dir: &Path) -> Result<PathBuf> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
+        let res = backup::run(self.cfg.clone(), self.format, dir.to_path_buf()).await;
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }

-    async fn restore(&self, file: &Path, is_test: Option<bool>) -> Result<()> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
-        }
-        let res = restore::run(self.cfg.clone(), self.format, file.to_path_buf(), is_test).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+    async fn restore(&self, file: &Path) -> Result<()> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
+        let res = restore::run(self.cfg.clone(), self.format, file.to_path_buf()).await;
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }
 }
@@ -2,4 +2,4 @@
 pub enum PostgresDumpFormat {
    Fc,
    Fd,
-}
+}
@@ -1,8 +1,8 @@
 pub mod backup;
-pub mod database;
-mod restore;
 mod connection;
+pub mod database;
 mod format;
 mod ping;
+mod restore;

-pub use connection::{detect_format_from_size, detect_format_from_file};
+pub use connection::{detect_format_from_file, detect_format_from_size};
@@ -1,8 +1,6 @@
 use super::connection::connect;
 use crate::services::config::DatabaseConfig;

-pub async fn run(
-    cfg: DatabaseConfig,
-) -> anyhow::Result<bool> {
+pub async fn run(cfg: DatabaseConfig) -> anyhow::Result<bool> {
    Ok(connect(&cfg).await.is_ok())
-}
+}
@@ -11,7 +11,6 @@ pub async fn run(
    cfg: DatabaseConfig,
    format: PostgresDumpFormat,
    restore_file: PathBuf,
-    is_test: Option<bool>,
 ) -> Result<()> {
    tokio::task::spawn_blocking(move || -> Result<()> {
        debug!("Starting restore for database {}", cfg.name);
@@ -27,7 +26,7 @@ pub async fn run(
            }
        };

-        let pg_restore = select_pg_path(&version, is_test).join("pg_restore");
+        let pg_restore = select_pg_path(&version).join("pg_restore");

        debug!("Using pg_restore at {:?}", pg_restore);

@@ -27,19 +27,14 @@ impl Database for RedisDatabase {
        ping::run(self.cfg.clone()).await
    }

-    async fn backup(&self, dir: &Path, is_test: Option<bool>) -> Result<PathBuf> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
-        }
+    async fn backup(&self, dir: &Path) -> Result<PathBuf> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
        let res = backup::run(self.cfg.clone(), dir.to_path_buf(), self.file_extension()).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }

-    async fn restore(&self, _file: &Path, _is_test: Option<bool>) -> Result<()> {
+    async fn restore(&self, _file: &Path) -> Result<()> {
        bail!("Restore not supported for Redis databases")
    }
 }
@@ -1,8 +1,8 @@
-use tracing::{debug, info};
 use crate::services::config::DatabaseConfig;
+use anyhow::{Context, Result};
 use tokio::process::Command;
-use tokio::time::{timeout, Duration};
-use anyhow::{Result, Context};
+use tokio::time::{Duration, timeout};
+use tracing::{debug, info};

 pub async fn run(cfg: DatabaseConfig) -> Result<bool> {
    let mut cmd = Command::new("redis-cli");
@@ -23,7 +23,6 @@ pub async fn run(cfg: DatabaseConfig) -> Result<bool> {

    debug!("Command Ping: {:?}", cmd);

-
    let result = timeout(Duration::from_secs(10), cmd.output()).await;

    match result {
@@ -52,4 +51,4 @@ pub async fn run(cfg: DatabaseConfig) -> Result<bool> {
            Ok(false)
        }
    }
-}
+}
@@ -41,5 +41,5 @@ pub async fn run(
        info!("SQLite backup completed for {}", cfg.name);
        Ok(file_path)
    })
-        .await?
-}
+    .await?
+}
@@ -27,26 +27,16 @@ impl Database for SqliteDatabase {
        ping::run(self.cfg.clone()).await
    }

-    async fn backup(&self, dir: &Path, is_test: Option<bool>) -> Result<PathBuf> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
-        }
+    async fn backup(&self, dir: &Path) -> Result<PathBuf> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
        let res = backup::run(self.cfg.clone(), dir.to_path_buf(), self.file_extension()).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }
-    async fn restore(&self, file: &Path, is_test: Option<bool>) -> Result<()> {
-        let test_mode = is_test.unwrap_or(false);
-        if !test_mode {
-            FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
-        }
+    async fn restore(&self, file: &Path) -> Result<()> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
        let res = restore::run(self.cfg.clone(), file.to_path_buf()).await;
-        if !test_mode {
-            FileLock::release(&self.cfg.generated_id).await?;
-        }
+        FileLock::release(&self.cfg.generated_id).await?;
        res
    }
 }
@@ -1,4 +1,4 @@
 mod backup;
-mod restore;
+pub mod database;
 mod ping;
-pub mod database;
+mod restore;
@@ -0,0 +1,65 @@
+use crate::services::config::DatabaseConfig;
+use anyhow::{Context, Result};
+use std::path::PathBuf;
+use std::process::Command;
+use tracing::{debug, error, info};
+
+pub async fn run(
+    cfg: DatabaseConfig,
+    backup_dir: PathBuf,
+    file_extension: &'static str,
+) -> Result<PathBuf> {
+    tokio::task::spawn_blocking(move || -> Result<PathBuf> {
+        debug!("Starting Valkey backup for database {}", cfg.name);
+
+        let file_path = backup_dir.join(format!("{}{}", cfg.generated_id, file_extension));
+
+        let mut cmd = Command::new("valkey-cli");
+
+        cmd.arg("-h")
+            .arg(&cfg.host)
+            .arg("-p")
+            .arg(cfg.port.to_string());
+
+        if !cfg.username.is_empty() {
+            cmd.arg("--user").arg(&cfg.username);
+        }
+
+        if !cfg.password.is_empty() {
+            cmd.arg("-a").arg(&cfg.password);
+        }
+
+        cmd.arg("--rdb").arg(&file_path);
+
+        debug!("Command Backup: {:?}", cmd);
+
+        let output = cmd.output().context("Valkey backup command failed")?;
+
+        let stderr = String::from_utf8_lossy(&output.stderr);
+        let stdout = String::from_utf8_lossy(&output.stdout);
+
+        if !output.status.success() {
+            if stderr.contains("NOAUTH") {
+                error!(
+                    "Valkey backup failed for {}: Authentication required (NOAUTH)",
+                    cfg.name
+                );
+                anyhow::bail!(
+                    "Valkey backup failed for {}: Authentication required",
+                    cfg.name
+                );
+            } else {
+                error!("Valkey backup failed for {}: {}", cfg.name, stderr);
+                anyhow::bail!("Valkey backup failed for {}: {}", cfg.name, stderr);
+            }
+        }
+
+        info!(
+            "Valkey backup completed for {}. Output: {}",
+            cfg.name, stdout
+        );
+
+        Ok(file_path)
+    })
+    .await?
+}
@@ -0,0 +1,40 @@
+use anyhow::{Result, bail};
+use async_trait::async_trait;
+use std::path::{Path, PathBuf};
+
+use crate::domain::factory::Database;
+use crate::domain::valkey::{backup, ping};
+use crate::services::config::DatabaseConfig;
+use crate::utils::locks::{DbOpLock, FileLock};
+
+pub struct ValkeyDatabase {
+    cfg: DatabaseConfig,
+}
+
+impl ValkeyDatabase {
+    pub fn new(cfg: DatabaseConfig) -> Self {
+        Self { cfg }
+    }
+}
+
+#[async_trait]
+impl Database for ValkeyDatabase {
+    fn file_extension(&self) -> &'static str {
+        ".rdb"
+    }
+
+    async fn ping(&self) -> Result<bool> {
+        ping::run(self.cfg.clone()).await
+    }
+
+    async fn backup(&self, dir: &Path) -> Result<PathBuf> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Backup.as_str()).await?;
+        let res = backup::run(self.cfg.clone(), dir.to_path_buf(), self.file_extension()).await;
+        FileLock::release(&self.cfg.generated_id).await?;
+        res
+    }
+
+    async fn restore(&self, _file: &Path) -> Result<()> {
+        bail!("Restore not supported for Valkey databases")
+    }
+}
@@ -0,0 +1,3 @@
+mod backup;
+pub mod database;
+mod ping;
@@ -0,0 +1,54 @@
+use crate::services::config::DatabaseConfig;
+use anyhow::{Context, Result};
+use tokio::process::Command;
+use tokio::time::{Duration, timeout};
+use tracing::{debug, info};
+
+pub async fn run(cfg: DatabaseConfig) -> Result<bool> {
+    let mut cmd = Command::new("valkey-cli");
+    cmd.arg("-h")
+        .arg(&cfg.host)
+        .arg("-p")
+        .arg(cfg.port.to_string());
+
+    if !cfg.username.is_empty() {
+        cmd.arg("--user").arg(&cfg.username);
+    }
+
+    if !cfg.password.is_empty() {
+        cmd.arg("-a").arg(&cfg.password);
+    }
+
+    cmd.arg("PING");
+
+    debug!("Command Ping: {:?}", cmd);
+
+    let result = timeout(Duration::from_secs(10), cmd.output()).await;
+
+    match result {
+        Ok(output) => {
+            let output = output.context("Failed to execute redis-cli")?;
+            let stdout = String::from_utf8_lossy(&output.stdout);
+            let stderr = String::from_utf8_lossy(&output.stderr);
+
+            info!("Redis stdout: {}", stdout);
+            info!("Redis stderr: {}", stderr);
+
+            if stderr.contains("NOAUTH") {
+                info!("Redis authentication failed (NOAUTH required)");
+                return Ok(false);
+            }
+
+            if !output.status.success() {
+                info!("Redis command failed with status: {:?}", output.status);
+                return Ok(false);
+            }
+
+            Ok(stdout.contains("PONG"))
+        }
+        Err(_) => {
+            info!("Timeout connecting to Redis at {}:{}", cfg.host, cfg.port);
+            Ok(false)
+        }
+    }
+}
@@ -3,19 +3,18 @@ mod domain;
 mod services;
 mod settings;
 mod tasks;
-mod utils;
 #[cfg(test)]
 mod tests;
+mod utils;

 use crate::tasks::ping::ping_server;
 use crate::utils::locks::FileLock;
+use crate::utils::logging;
 use utils::redis_client;
 use utils::task_manager::scheduler;
-use crate::utils::logging;

 #[tokio::main]
 async fn main() {
-
    logging::init_logger();

    // Remove all locks on startup
@@ -1,9 +1,9 @@
 #![allow(dead_code)]

+use crate::services::api::ApiError;
 use reqwest::{Client, Method};
 use serde::de::DeserializeOwned;
 use std::time::Duration;
-use crate::services::api::ApiError;

 #[derive(Clone, Debug)]
 pub struct ApiClient {
@@ -57,12 +57,7 @@ impl ApiClient {
    {
        let url = format!("{}{}", self.base_url, path);

-        let res = self
-            .http
-            .request(method, &url)
-            .json(body)
-            .send()
-            .await?;
+        let res = self.http.request(method, &url).json(body).send().await?;

        let status = res.status();
        let body_text = res.text().await.unwrap_or_default();
@@ -23,7 +23,6 @@ pub struct BackupUpdateRequest {
    pub generated_id: String,
 }

-
 impl ApiClient {
    pub async fn backup_create(
        &self,
@@ -1,8 +1,8 @@
+use crate::services::api::models::agent::backup::BackupUploadResponse;
 use crate::services::api::{ApiClient, ApiError};
 use anyhow::Result;
 use reqwest::Method;
 use serde::Serialize;
-use crate::services::api::models::agent::backup::BackupUploadResponse;

 #[derive(Serialize)]
 pub struct InitUploadRequest {
@@ -1,2 +1,2 @@
 pub mod init;
-pub mod status;
+pub mod status;
@@ -1,3 +1,3 @@
-pub mod status;
 pub mod backup;
-pub mod restore;
+pub mod restore;
+pub mod status;
@@ -31,6 +31,7 @@ impl ApiClient {
        let agent_id = agent_id.into();
        let path = format!("/agent/{}/status", agent_id);

-        self.request_with_body(Method::POST, path.as_str(), &body).await
+        self.request_with_body(Method::POST, path.as_str(), &body)
+            .await
    }
-}
+}
@@ -1,3 +1,3 @@
 pub mod agent;

-pub use agent::status;
+pub use agent::status;
@@ -11,10 +11,7 @@ pub enum ApiError {
    Serialization(#[from] serde_json::Error),

    #[error("api error: status={status}, body={body}")]
-    HttpResponse {
-        status: StatusCode,
-        body: String,
-    },
+    HttpResponse { status: StatusCode, body: String },

    #[error("api returned unexpected response")]
    UnexpectedResponse,
@@ -1,8 +1,7 @@
 pub mod client;
+pub mod endpoints;
 pub mod error;
 pub mod models;
-pub mod endpoints;

 pub use client::ApiClient;
 pub use error::ApiError;
-
@@ -1,3 +1,3 @@
-pub mod status;
 pub mod backup;
-pub mod restore;
+pub mod restore;
+pub mod status;
@@ -4,4 +4,4 @@ use serde::{Deserialize, Serialize};
 pub struct ResultRestoreResponse {
    pub message: String,
    pub status: bool,
-}
+}
@@ -1,8 +1,8 @@
 #![allow(dead_code)]

+use crate::utils::deserializer::deserialize_snake_case;
 use serde::{Deserialize, Serialize};
 use toml::Value;
-use crate::utils::deserializer::deserialize_snake_case;

 #[derive(Debug, Deserialize)]
 pub struct PingResult {
@@ -1,2 +1 @@
 pub mod agent;
-
@@ -1,20 +1,14 @@
 use super::service::BackupService;
 use crate::utils::compress::compress_to_tar_gz_large;
-use std::path::PathBuf;
 use anyhow::Result;
+use std::path::PathBuf;

 impl BackupService {
-
-    pub async fn compress_backup(
-        &self,
-        backup_file: Option<PathBuf>,
-    ) -> Result<PathBuf> {
-
-        let file = backup_file
-            .ok_or_else(|| anyhow::anyhow!("No backup file generated"))?;
+    pub async fn compress_backup(&self, backup_file: Option<PathBuf>) -> Result<PathBuf> {
+        let file = backup_file.ok_or_else(|| anyhow::anyhow!("No backup file generated"))?;

        let compression = compress_to_tar_gz_large(&file).await?;

        Ok(compression.compressed_path)
    }
-}
+}
@@ -1,11 +1,10 @@
 use super::service::BackupService;
-use crate::services::config::DatabasesConfig;
 use crate::services::api::models::agent::status::DatabaseStorage;
+use crate::services::config::DatabasesConfig;
 use crate::utils::common::BackupMethod;
 use tracing::error;

 impl BackupService {
-
    pub async fn dispatch(
        &self,
        generated_id: &String,
@@ -14,7 +13,6 @@ impl BackupService {
        storages: &Vec<DatabaseStorage>,
        encrypt: bool,
    ) {
-
        let Some(cfg) = config
            .databases
            .iter()
@@ -41,4 +39,4 @@ impl BackupService {
            }
        });
    }
-}
+}
@@ -1,14 +1,13 @@
 use super::service::BackupService;
-use crate::services::config::DatabaseConfig;
 use crate::services::api::models::agent::status::DatabaseStorage;
+use crate::services::config::DatabaseConfig;
 use crate::utils::common::BackupMethod;
 use crate::utils::locks::FileLock;

-use tempfile::TempDir;
 use anyhow::Result;
+use tempfile::TempDir;

 impl BackupService {
-
    pub async fn execute_backup(
        &self,
        generated_id: String,
@@ -17,11 +16,10 @@ impl BackupService {
        storages: Vec<DatabaseStorage>,
        encrypt: bool,
    ) -> Result<()> {
-
        if FileLock::is_locked(&generated_id).await? {
            anyhow::bail!("backup already running");
        }
-        
+
        let backup = self.create_backup_record(&generated_id, &method).await?;
        let backup_id = backup.backup.id;

@@ -46,4 +44,4 @@ impl BackupService {

        Ok(())
    }
-}
+}
@@ -1,16 +1,14 @@
 use super::service::BackupService;
+use crate::services::api::models::agent::backup::BackupResponse;
 use crate::utils::common::BackupMethod;
 use anyhow::{Result, anyhow};
-use crate::services::api::models::agent::backup::BackupResponse;

 impl BackupService {
-
    pub async fn create_backup_record(
        &self,
        generated_id: &str,
        method: &BackupMethod,
    ) -> Result<BackupResponse> {
-
        let response = self
            .ctx
            .api
@@ -23,4 +21,4 @@ impl BackupService {

        response.ok_or_else(|| anyhow!("backup_create returned empty response"))
    }
-}
+}
@@ -1,11 +1,11 @@
-pub mod service;
+pub mod compressor;
 pub mod dispatcher;
 pub mod executor;
-pub mod compressor;
-pub mod uploader;
-pub mod result;
-pub mod models;
 pub mod helpers;
+pub mod models;
+pub mod result;
 pub mod runner;
+pub mod service;
+pub mod uploader;

-pub use service::BackupService;
+pub use service::BackupService;
@@ -1,7 +1,7 @@
 #![allow(dead_code)]

-use std::path::PathBuf;
 use crate::services::config::DbType;
+use std::path::PathBuf;

 #[derive(Debug, Clone)]
 pub struct BackupResult {
@@ -19,4 +19,4 @@ pub struct UploadResult {
    pub error: Option<String>,
    pub remote_file_path: Option<String>,
    pub total_size: Option<u64>,
-}
+}
@@ -9,12 +9,7 @@ use std::path::Path;
 use tracing::{error, info};

 impl BackupService {
-
-    pub async fn run(
-        cfg: DatabaseConfig,
-        tmp_path: &Path,
-    ) -> Result<BackupResult> {
-
+    pub async fn run(cfg: DatabaseConfig, tmp_path: &Path) -> Result<BackupResult> {
        let db = DatabaseFactory::create_for_backup(cfg.clone()).await;

        let generated_id = cfg.generated_id.clone();
@@ -40,8 +35,7 @@ impl BackupService {
            });
        }

-        match db.backup(tmp_path, Some(false)).await {
-
+        match db.backup(tmp_path).await {
            Ok(file) => Ok(BackupResult {
                generated_id,
                db_type,
@@ -67,4 +61,4 @@ impl BackupService {
            }),
        }
    }
-}
+}
@@ -1,5 +1,5 @@
-use std::sync::Arc;
 use crate::core::context::Context as CoreContext;
+use std::sync::Arc;

 pub struct BackupService {
    pub ctx: Arc<CoreContext>,
@@ -9,4 +9,4 @@ impl BackupService {
    pub fn new(ctx: Arc<CoreContext>) -> Self {
        Self { ctx }
    }
-}
+}
@@ -1,16 +1,15 @@
-use super::service::BackupService;
 use super::models::{BackupResult, UploadResult};
+use super::service::BackupService;

-use crate::services::storage;
 use crate::services::api::models::agent::status::DatabaseStorage;
+use crate::services::storage;
 use crate::utils::common::BackupMethod;

-use futures::future::join_all;
 use anyhow::{Result, bail};
-use tracing::{info, error};
+use futures::future::join_all;
+use tracing::{error, info};

 impl BackupService {
-
    pub async fn upload(
        &self,
        result: BackupResult,
@@ -19,7 +18,6 @@ impl BackupService {
        encrypt: bool,
        backup_id: &String,
    ) -> Result<Vec<UploadResult>> {
-
        if result.code.as_deref() == Some("backup_already_in_progress") {
            info!("Skipping send: backup already in progress");
            bail!("backup_already_in_progress");
@@ -28,7 +26,6 @@ impl BackupService {
        let ctx = self.ctx.clone();

        let futures = storages.into_iter().map(|storage| {
-
            let ctx_clone = ctx.clone();
            let result_clone = result.clone();
            let provider = storage::get_provider(&storage);
@@ -37,13 +34,16 @@ impl BackupService {
            let generated_id = result_clone.generated_id.clone();

            async move {
-
-                info!("Uploading storage -> {:?} for {:?}", storage.provider, storage_id);
+                info!(
+                    "Uploading storage -> {:?} for {:?}",
+                    storage.provider, storage_id
+                );

                /*
                 INIT STEP
                */
-                let init = match ctx_clone.api
+                let init = match ctx_clone
+                    .api
                    .backup_upload_init(
                        ctx_clone.edge_key.agent_id.clone(),
                        generated_id.clone(),
@@ -107,7 +107,11 @@ impl BackupService {
                    )
                    .await;

-                let status = if upload_result.success { "success" } else { "failed" };
+                let status = if upload_result.success {
+                    "success"
+                } else {
+                    "failed"
+                };

                if status != "success" {
                    return upload_result;
@@ -115,49 +119,48 @@ impl BackupService {

                info!(
                    "Storage {} uploaded to remote path {:?}",
-                    storage_id,
-                    upload_result.remote_file_path
+                    storage_id, upload_result.remote_file_path
                );

                /*
                 METADATA VALIDATION
                */
-                let (remote_path, total_size) = match (
-                    &upload_result.remote_file_path,
-                    upload_result.total_size,
-                ) {
-                    (Some(path), Some(size)) => (path.clone(), size),
-                    _ => {
-                        return UploadResult {
-                            storage_id,
-                            success: false,
-                            error: Some("remote_file_path or total_size missing".into()),
-                            remote_file_path: None,
-                            total_size: None,
-                        };
-                    }
-                };
+                let (remote_path, total_size) =
+                    match (&upload_result.remote_file_path, upload_result.total_size) {
+                        (Some(path), Some(size)) => (path.clone(), size),
+                        _ => {
+                            return UploadResult {
+                                storage_id,
+                                success: false,
+                                error: Some("remote_file_path or total_size missing".into()),
+                                remote_file_path: None,
+                                total_size: None,
+                            };
+                        }
+                    };

                /*
                 STATUS UPDATE
                */
-                match ctx_clone.api.backup_upload_status(
-                    ctx_clone.edge_key.agent_id.clone(),
-                    generated_id,
-                    backup_storage_id,
-                    status,
-                    remote_path,
-                    total_size,
-                    backup_id,
-                ).await {
-
+                match ctx_clone
+                    .api
+                    .backup_upload_status(
+                        ctx_clone.edge_key.agent_id.clone(),
+                        generated_id,
+                        backup_storage_id,
+                        status,
+                        remote_path,
+                        total_size,
+                        backup_id,
+                    )
+                    .await
+                {
                    Ok(_) => upload_result,

                    Err(err) => {
                        error!(
                            "backup_upload_status failed (storage_id={}): {}",
-                            storage_id,
-                            err
+                            storage_id, err
                        );

                        UploadResult {
@@ -178,4 +181,4 @@ impl BackupService {

        Ok(results)
    }
-}
+}
@@ -19,8 +19,8 @@ pub enum DbType {
    Postgresql,
    MongoDB,
    Sqlite,
-    Redis
-    // Add other DB types if needed
+    Redis,
+    Valkey,
 }

 impl DbType {
@@ -32,6 +32,7 @@ impl DbType {
            DbType::MongoDB => "mongodb",
            DbType::Sqlite => "sqlite",
            DbType::Redis => "redis",
+            DbType::Valkey => "valkey",
        }
    }
 }
@@ -57,7 +58,6 @@ pub struct DatabasesConfig {
    pub databases: Vec<DatabaseConfig>,
 }

-
 #[allow(dead_code)]
 #[derive(Debug, Deserialize, Clone)]
 pub struct InputDatabaseConfig {
@@ -79,7 +79,6 @@ pub struct InputDatabasesConfig {
    pub databases: Vec<InputDatabaseConfig>,
 }

-
 pub struct ConfigService {
    ctx: Arc<Context>,
 }
@@ -132,17 +131,27 @@ impl ConfigService {
            _ => return Err("Unsupported config file format. Use .json or .toml".to_string()),
        };

-        fn required<T: Clone>(opt: &Option<T>, db_name: &str, field_name: &str) -> Result<T, String> {
+        fn required<T: Clone>(
+            opt: &Option<T>,
+            db_name: &str,
+            field_name: &str,
+        ) -> Result<T, String> {
            match opt {
                Some(v) => Ok(v.clone()),
                None => {
-                    let msg = format!("Missing required field '{}' for database '{}'", field_name, db_name);
+                    let msg = format!(
+                        "Missing required field '{}' for database '{}'",
+                        field_name, db_name
+                    );
                    Err(msg)
                }
            }
        }

-        fn optional<T: Clone>(opt: &Option<T>) -> T where T: Default {
+        fn optional<T: Clone>(opt: &Option<T>) -> T
+        where
+            T: Default,
+        {
            opt.clone().unwrap_or_default()
        }

@@ -154,28 +163,42 @@ impl ConfigService {
            }

            let username = match db.db_type {
-                DbType::Postgresql | DbType::Mysql | DbType::Mariadb => required(&db.username, &db.name, "username")?,
+                DbType::Postgresql | DbType::Mysql | DbType::Mariadb => {
+                    required(&db.username, &db.name, "username")?
+                }
                _ => optional(&db.username),
            };

            let password = match db.db_type {
-                DbType::Postgresql | DbType::Mysql | DbType::Mariadb => required(&db.password, &db.name, "password")?,
+                DbType::Postgresql | DbType::Mysql | DbType::Mariadb => {
+                    required(&db.password, &db.name, "password")?
+                }
                _ => optional(&db.password),
            };

            let host = match db.db_type {
-                DbType::Postgresql | DbType::Mysql | DbType::Mariadb | DbType::MongoDB | DbType::Redis => required(&db.host, &db.name, "host")?,
+                DbType::Postgresql
+                | DbType::Mysql
+                | DbType::Mariadb
+                | DbType::MongoDB
+                | DbType::Redis
+                | DbType::Valkey => required(&db.host, &db.name, "host")?,
                DbType::Sqlite => optional(&db.host),
            };

            let port = match db.db_type {
-                DbType::Postgresql | DbType::Mysql | DbType::Mariadb | DbType::MongoDB | DbType::Redis => required(&db.port, &db.name, "port")?,
+                DbType::Postgresql
+                | DbType::Mysql
+                | DbType::Mariadb
+                | DbType::MongoDB
+                | DbType::Redis
+                | DbType::Valkey => required(&db.port, &db.name, "port")?,
                DbType::Sqlite => db.port.unwrap_or(0),
            };

            let database_name = match db.db_type {
-                DbType::Sqlite | DbType::Redis => optional(&db.database),
-                _ => required(&db.database, &db.name, "database")?
+                DbType::Sqlite | DbType::Redis | DbType::Valkey => optional(&db.database),
+                _ => required(&db.database, &db.name, "database")?,
            };

            let path_val = match db.db_type {
@@ -1,13 +1,13 @@
 #![allow(dead_code)]

 use crate::core::context::Context;
+use crate::services::api::models::agent::status::DatabaseStatus;
 use crate::utils::common::vec_to_option_json;
 use crate::utils::redis_client;
 use crate::utils::task_manager::cron::check_and_update_cron;
 use redis::aio::MultiplexedConnection;
 use serde_json::{Value, json};
 use std::sync::Arc;
-use crate::services::api::models::agent::status::DatabaseStatus;

 pub struct CronService {
    ctx: Arc<Context>,
@@ -1,7 +1,7 @@
+pub mod api;
+pub mod backup;
 pub mod config;
 pub mod cron;
-pub mod backup;
 pub mod restore;
+pub mod status;
 mod storage;
-pub mod api;
-pub mod status;
@@ -7,13 +7,11 @@ use anyhow::Result;
 use std::path::{Path, PathBuf};

 impl RestoreService {
-
    pub async fn prepare_archive(
        &self,
        downloaded_file: PathBuf,
        tmp_path: &Path,
    ) -> Result<PathBuf> {
-
        let filename = downloaded_file
            .file_name()
            .unwrap()
@@ -31,7 +29,6 @@ impl RestoreService {
        let mut archive = downloaded_file.clone();

        if encrypted {
-
            let new_name = filename.strip_suffix(".enc").unwrap();

            let decrypted = tmp_path.join(new_name);
@@ -41,7 +38,7 @@ impl RestoreService {
                decrypted.clone(),
                self.ctx.edge_key.master_key_b64.clone(),
            )
-                .await?;
+            .await?;

            archive = decrypted;
        }
@@ -58,4 +55,4 @@ impl RestoreService {
            Ok(archive)
        }
    }
-}
+}
@@ -1,13 +1,11 @@
 use super::service::RestoreService;
-use crate::services::config::DatabasesConfig;
 use crate::services::api::models::agent::status::DatabaseStatus;
+use crate::services::config::DatabasesConfig;

 use tracing::error;

 impl RestoreService {
-
    pub async fn dispatch(&self, db: &DatabaseStatus, config: &DatabasesConfig) {
-
        let Some(cfg) = config
            .databases
            .iter()
@@ -29,14 +27,9 @@ impl RestoreService {
        let db_cfg = cfg.clone();

        tokio::spawn(async move {
-
-            if let Err(e) = service
-                .execute_restore(db_cfg, file_to_restore)
-                .await
-            {
+            if let Err(e) = service.execute_restore(db_cfg, file_to_restore).await {
                error!("Restore failed: {}", e);
            }
-
        });
    }
-}
+}
@@ -1,18 +1,12 @@
 use super::service::RestoreService;

-use reqwest::{Client, Url};
 use anyhow::Result;
+use reqwest::{Client, Url};
 use std::path::{Path, PathBuf};
 use tracing::info;

 impl RestoreService {
-
-    pub async fn download_backup(
-        &self,
-        file_url: &str,
-        tmp_path: &Path,
-    ) -> Result<PathBuf> {
-
+    pub async fn download_backup(&self, file_url: &str, tmp_path: &Path) -> Result<PathBuf> {
        let client = Client::new();

        let response = client.get(file_url).send().await?;
@@ -28,7 +22,6 @@ impl RestoreService {
            .and_then(|s| s.split("filename=").nth(1))
            .map(|f| f.trim_matches('"').to_string());

-
        let filename_from_url = Url::parse(file_url).ok().and_then(|u| {
            u.path_segments()?
                .last()
@@ -50,4 +43,4 @@ impl RestoreService {

        Ok(path)
    }
-}
+}
@@ -1,17 +1,11 @@
 use super::service::RestoreService;
 use crate::services::config::DatabaseConfig;
-use tempfile::TempDir;
 use anyhow::Result;
+use tempfile::TempDir;
 use tracing::info;

 impl RestoreService {
-
-    pub async fn execute_restore(
-        &self,
-        cfg: DatabaseConfig,
-        file_url: String,
-    ) -> Result<()> {
-
+    pub async fn execute_restore(&self, cfg: DatabaseConfig, file_url: String) -> Result<()> {
        let temp_dir = TempDir::new()?;
        let tmp_path = temp_dir.path();

@@ -27,4 +21,4 @@ impl RestoreService {

        Ok(())
    }
-}
+}
@@ -1,10 +1,10 @@
-pub mod service;
-pub mod dispatcher;
-pub mod executor;
-pub mod downloader;
 pub mod archive;
-pub mod runner;
-pub mod result;
+pub mod dispatcher;
+pub mod downloader;
+pub mod executor;
 pub mod models;
+pub mod result;
+pub mod runner;
+pub mod service;

-pub use service::RestoreService;
+pub use service::RestoreService;
@@ -5,4 +5,4 @@ pub struct RestoreResult {
    #[serde(rename = "generatedId")]
    pub generated_id: String,
    pub status: String,
-}
+}
@@ -1,24 +1,25 @@
-use super::service::RestoreService;
 use super::models::RestoreResult;
+use super::service::RestoreService;

-use tracing::{info, error};
+use tracing::{error, info};

 impl RestoreService {
    pub async fn send_result(&self, result: RestoreResult) {
-
        info!(
            "[RestoreService] DB: {} | Status: {}",
            result.generated_id, result.status
        );

-        match self.ctx
+        match self
+            .ctx
            .api
            .restore_result(
                self.ctx.edge_key.agent_id.clone(),
                &result.generated_id,
                &result.status,
            )
-            .await {
+            .await
+        {
            Ok(_) => {
                info!("Restoration result sent successfully");
            }
@@ -27,4 +28,4 @@ impl RestoreService {
            }
        }
    }
-}
+}
@@ -1,21 +1,19 @@
-use super::service::RestoreService;
 use super::models::RestoreResult;
+use super::service::RestoreService;

 use crate::domain::factory::DatabaseFactory;
 use crate::services::config::DatabaseConfig;

 use anyhow::Result;
 use std::path::PathBuf;
-use tracing::{info, error};
+use tracing::{error, info};

 impl RestoreService {
-
    pub async fn run_restore(
        &self,
        cfg: DatabaseConfig,
        backup_file: PathBuf,
    ) -> Result<RestoreResult> {
-
        let generated_id = cfg.generated_id.clone();

        let db = DatabaseFactory::create_for_restore(cfg.clone(), &backup_file).await;
@@ -31,8 +29,7 @@ impl RestoreService {
            });
        }

-        match db.restore(&backup_file, Some(false)).await {
-
+        match db.restore(&backup_file).await {
            Ok(_) => Ok(RestoreResult {
                generated_id,
                status: "success".into(),
@@ -48,4 +45,4 @@ impl RestoreService {
            }
        }
    }
-}
+}
@@ -1,5 +1,5 @@
-use std::sync::Arc;
 use crate::core::context::Context;
+use std::sync::Arc;

 pub struct RestoreService {
    pub ctx: Arc<Context>,
@@ -9,4 +9,4 @@ impl RestoreService {
    pub fn new(ctx: Arc<Context>) -> Self {
        Self { ctx }
    }
-}
+}
@@ -1,13 +1,13 @@
 #![allow(dead_code)]

 use crate::core::context::Context;
+use crate::services::api::endpoints::status::DatabasePayload;
+use crate::services::api::models::agent::status::PingResult;
 use crate::services::config::DatabaseConfig;
 use crate::settings::CONFIG;
 use reqwest::Client;
 use std::error::Error;
 use std::sync::Arc;
-use crate::services::api::endpoints::status::DatabasePayload;
-use crate::services::api::models::agent::status::PingResult;

 pub struct StatusService {
    ctx: Arc<Context>,
@@ -35,7 +35,12 @@ impl StatusService {
            .collect();

        let version_str = CONFIG.app_version.as_str();
-        let result = self.ctx.api.agent_status(&edge_key.agent_id, &version_str, databases_payload).await?.unwrap();
+        let result = self
+            .ctx
+            .api
+            .agent_status(&edge_key.agent_id, &version_str, databases_payload)
+            .await?
+            .unwrap();
        Ok(result)
    }
 }
@@ -1,15 +1,15 @@
 pub mod providers;

 use crate::core::context::Context;
-use crate::utils::common::BackupMethod;
-use async_trait::async_trait;
-use providers::local;
-use providers::s3;
-use providers::google_drive;
-use std::sync::Arc;
-use tracing::{error, info};
 use crate::services::api::models::agent::status::DatabaseStorage;
 use crate::services::backup::models::{BackupResult, UploadResult};
+use crate::utils::common::BackupMethod;
+use async_trait::async_trait;
+use providers::google_drive;
+use providers::local;
+use providers::s3;
+use std::sync::Arc;
+use tracing::{error, info};

 #[async_trait]
 pub trait StorageProvider: Send + Sync {
@@ -1,15 +1,15 @@
+use crate::services::storage::providers::google_drive::models::GoogleDriveProviderConfig;
 use anyhow::{Context, Result, anyhow};
+use bytes::Bytes;
+use futures::Stream;
 use futures::StreamExt;
 use oauth2::{
    AuthUrl, ClientId, ClientSecret, RefreshToken, TokenResponse, TokenUrl, basic::BasicClient,
    reqwest::Client as OAuth2ReqwestClient,
 };
 use reqwest::{Client as ReqwestClient, StatusCode};
-use serde_json::{Value, json};
-use futures::{Stream};
-use bytes::Bytes;
 use reqwest::{Client, header};
-use crate::services::storage::providers::google_drive::models::GoogleDriveProviderConfig;
+use serde_json::{Value, json};

 pub async fn get_google_drive_token(config: &GoogleDriveProviderConfig) -> Result<String> {
    let http_client = OAuth2ReqwestClient::new();
@@ -34,7 +34,10 @@ pub async fn get_google_drive_token(config: &GoogleDriveProviderConfig) -> Resul
    Ok(token_result.access_token().secret().clone())
 }

-pub async fn ensure_folder_path(config: &GoogleDriveProviderConfig, path_parts: &[&str]) -> Result<String> {
+pub async fn ensure_folder_path(
+    config: &GoogleDriveProviderConfig,
+    path_parts: &[&str],
+) -> Result<String> {
    if path_parts.is_empty() {
        return Ok(config.folder_id.clone());
    }
@@ -152,7 +155,10 @@ pub async fn upload_stream_to_google_drive(

    let folder_id = ensure_folder_path(config, folder_path).await?;

-    if find_file_by_name(config, file_name, &folder_id).await?.is_some() {
+    if find_file_by_name(config, file_name, &folder_id)
+        .await?
+        .is_some()
+    {
        return Err(anyhow::anyhow!("File already exists: {}", full_path));
    }

@@ -172,7 +178,7 @@ pub async fn upload_stream_to_google_drive(
        .post("https://www.googleapis.com/upload/drive/v3/files?uploadType=resumable")
        .bearer_auth(&token)
        .header("X-Upload-Content-Type", mime)
-        .header("X-Upload-Content-Length", total_size.to_string())  // Helps a lot
+        .header("X-Upload-Content-Length", total_size.to_string()) // Helps a lot
        .json(&metadata)
        .send()
        .await
@@ -237,12 +243,15 @@ pub async fn upload_stream_to_google_drive(
                .put(&upload_url)
                .header("Content-Range", &content_range)
                .header("Content-Length", chunk_bytes.len().to_string())
-                .body(chunk_bytes.clone())  // clone is cheap if small; optimize later if needed
+                .body(chunk_bytes.clone()) // clone is cheap if small; optimize later if needed
                .send()
                .await;

            match res {
-                Ok(resp) if resp.status().is_success() || resp.status() == StatusCode::PERMANENT_REDIRECT => {
+                Ok(resp)
+                    if resp.status().is_success()
+                        || resp.status() == StatusCode::PERMANENT_REDIRECT =>
+                {
                    // 200 or 308 = good
                    uploaded += chunk_bytes.len() as u64;
                    tracing::info!("Uploaded {}/{} bytes", uploaded, total_size);
@@ -1,9 +1,12 @@
 mod helpers;
-mod models; 
+mod models;

 use crate::core::context::Context;
 use crate::services::api::models::agent::status::DatabaseStorage;
+use crate::services::backup::models::{BackupResult, UploadResult};
 use crate::services::storage::StorageProvider;
+use crate::services::storage::providers::google_drive::helpers::upload_stream_to_google_drive;
+use crate::services::storage::providers::google_drive::models::GoogleDriveProviderConfig;
 use crate::utils::common::BackupMethod;
 use crate::utils::file::{full_file_name, full_file_path};
 use crate::utils::stream::build_stream;
@@ -11,9 +14,6 @@ use async_trait::async_trait;
 use std::sync::Arc;
 use tokio::fs;
 use tracing::{error, info};
-use crate::services::backup::models::{BackupResult, UploadResult};
-use crate::services::storage::providers::google_drive::helpers::{upload_stream_to_google_drive};
-use crate::services::storage::providers::google_drive::models::GoogleDriveProviderConfig;

 pub struct GoogleDriveProvider {}

@@ -53,13 +53,7 @@ impl StorageProvider for GoogleDriveProvider {

        let encrypt = encrypt.unwrap_or(false);

-        let upload = match build_stream(
-            &file_path,
-            encrypt,
-            &ctx.edge_key.master_key_b64
-        )
-            .await
-        {
+        let upload = match build_stream(&file_path, encrypt, &ctx.edge_key.master_key_b64).await {
            Ok(u) => u,
            Err(e) => {
                error!("Stream build failed: {}", e);
@@ -86,7 +80,6 @@ impl StorageProvider for GoogleDriveProvider {
            }
        };

-
        let file_name = full_file_name(encrypt);

        info!("Uploading file {}", file_name);
@@ -96,12 +89,13 @@ impl StorageProvider for GoogleDriveProvider {
        match upload_stream_to_google_drive(
            &config,
            &remote_file_path,
-            upload.stream,   
+            upload.stream,
            total_size,
            Some("application/octet-stream"),
-        ).await {
+        )
+        .await
+        {
            Ok(_file_id) => {
-                
                info!("Google Drive upload successful");

                UploadResult {
@@ -124,6 +118,5 @@ impl StorageProvider for GoogleDriveProvider {
                }
            }
        }
-
    }
 }
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
github-actions[bot]	a1e18754b1	chore: release 1.6.3	2026-03-27 21:27:23 +00:00
Charles GTE	725312e1d5	fix: tests (#47 ) * fix: s3 port type mismatch, add string_or_number_to_string deserializer * fix: adding some tests * fix: adding some tests * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline * fix: working on pipeline --------- Co-authored-by: charlesgauthereau <charles.gauthereau@soluce-technologies.com>	2026-03-27 22:24:59 +01:00
github-actions[bot]	8e8ebb5920	chore: release 1.6.2	2026-03-21 07:53:35 +00:00
Charles GTE	8489a6f6e3	fix: adding retry config for s3 provider (#46 )	2026-03-21 08:51:15 +01:00
github-actions[bot]	3f5b9c91cc	chore: release 1.6.1	2026-03-18 18:42:23 +00:00
Charles GTE	1c52f298d2	fix: Enable Link-Time Optimization (LTO) and codegen-units = 1 for Release builds (#45 )	2026-03-18 19:39:49 +01:00
github-actions[bot]	e602c3540f	chore: release 1.6.0	2026-03-16 13:38:02 +00:00
Charles GTE	b5e8ccac1f	feat: add-valkey #43 feat: add-valkey	2026-03-16 14:35:31 +01:00
charles-gauthereau	f14a6dc318	fix: docker-compose.yml	2026-03-16 14:32:33 +01:00
charles-gauthereau	e1bc77e481	fix: valkey.rs	2026-03-16 14:31:11 +01:00
charles-gauthereau	cbc7517603	fix: README.md with Valkey content	2026-03-16 14:28:24 +01:00
charles-gauthereau	fc4e4e3881	fix: log in backup.rs	2026-03-16 12:32:57 +01:00
charles-gauthereau	5ec7bc9f28	fix: docker-compose.yml volume for valkey	2026-03-16 12:32:12 +01:00
charles-gauthereau	45c33dd031	feat: add valkey test sequences	2026-03-16 12:30:22 +01:00
charles-gauthereau	cddb9d78fa	fix: entrypoint.sh	2026-03-16 12:16:03 +01:00
charles-gauthereau	cf5de3115c	feat: add valkey database engine for backup	2026-03-16 12:11:01 +01:00
charles-gauthereau	d6d2ef18f8	fix: internal redis port	2026-03-16 11:24:30 +01:00
github-actions[bot]	987c630c73	chore: release 1.5.1	2026-03-16 07:59:25 +00:00
Charles GTE	e9147d6c60	fix: s3 port type mismatch, add string_or_number_to_string deserializer (#42 ) Co-authored-by: charlesgauthereau <charles.gauthereau@soluce-technologies.com>	2026-03-16 08:57:00 +01:00