chore(release): 1.0.2

feat/arm-architecture

.github/workflows/docker.yml

@@ -37,6 +37,12 @@ jobs:
         with:
           fetch-depth: 0
 
+      - name: Set up QEMU (enables multi-arch emulation)
+        uses: docker/setup-qemu-action@v3
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v3
+
       - name: Log in to Docker Hub
         uses: docker/login-action@f4ef78c080cd8ba55a85445d5b36e214a81df20a
         with:
@@ -58,6 +64,7 @@ jobs:
         with:
           context: .
           file: ${{ inputs.dockerfile }}
+          platforms: linux/amd64,linux/arm64
           push: true
           tags: ${{ steps.set-tags.outputs.tags }}
           target: ${{ inputs.target }}

.gitignore

@@ -4,3 +4,4 @@
 
 .DS_Store
 
+.env

CITATION.cff

@@ -22,5 +22,5 @@ keywords:
   - self-hosted
   - portabase
 license: Apache-2.0
-version: 1.0.1-rc.1
-date-released: "2026-01-12"
+version: 1.0.2
+date-released: "2026-01-22"

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "portabase-agent"
-version = "1.0.1-rc.1"
+version = "1.0.2"
 edition = "2024"
 
 [dependencies]
@@ -31,6 +31,7 @@ futures = "0.3.31"
 tracing-log = "0.2.0"
 tracing-appender = "0.2.4"
 time = { version = "0.3.44", features = ["macros"] }
+mongodb = "3.5.0"
 
 [[bin]]
 name = "app"

Makefile

@@ -0,0 +1,29 @@
+include .env
+export $(shell sed 's/=.*//' .env)
+
+.PHONY: seed-mongo seed-mysql seed-postgres
+
+seed-mongo:
+	@echo "Seeding MongoDB..."
+	bash ./scripts/mongo/seed-mongo.sh
+
+seed-mongo-auth:
+	@echo "Seeding MongoDB with auth..."
+	bash ./scripts/mongo/seed-mongo.sh auth
+
+seed-mysql:
+	@echo "Seeding MySQL..."
+	mysql -h 127.0.0.1 -P "$$MYSQL_PORT" -u "$$MYSQL_USER" -p"$$MYSQL_PASSWORD" "$$MYSQL_DB" < ./scripts/mysql/seed-mysql.sql
+
+
+seed-postgres:
+	@echo "Seeding Postgres..."
+	docker exec -i -e PGPASSWORD=$$PG_PASSWORD $$PG_CONTAINER \
+		psql -U $$PG_USER -d $$PG_DB < ./scripts/postgres/seed.sql
+
+seed-postgres-1gb:
+	@echo "Seeding Postgres..."
+	docker exec -i -e PGPASSWORD=$$PG_PASSWORD $$PG_CONTAINER \
+		psql -U $$PG_USER -d $$PG_DB < ./scripts/postgres/seed-1gb.sql
+
+seed-all: seed-mongo seed-mysql seed-postgres seed-postgres-1gb

README.md

@@ -12,13 +12,15 @@
   </p>
 
 [![License: Apache](https://img.shields.io/badge/License-apache-yellow.svg)](LICENSE)
-[![Docker Pulls](https://img.shields.io/docker/pulls/solucetechnologies/agent-portabase-rust?color=brightgreen)](https://hub.docker.com/r/solucetechnologies/agent-portabase)
+[![Docker Pulls](https://img.shields.io/docker/pulls/portabase/agent?color=brightgreen)](https://hub.docker.com/r/portabase/agent)
 [![Platform](https://img.shields.io/badge/platform-linux%20%7C%20macos%20%7C%20windows-lightgrey)](https://github.com/Portabase/portabase)
+[![Support Portabase](https://img.shields.io/badge/Support-Portabase-orange)](https://www.buymeacoffee.com/portabase)
 
 [![PostgreSQL](https://img.shields.io/badge/python-3.13-blue.svg)](https://www.python.org/downloads/release/python-3120/)
 [![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/)
 [![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)
 [![Open Source](https://img.shields.io/badge/open%20source-❤️-red)](https://github.com/Portabase/portabase)
 
@@ -53,9 +55,9 @@ You have 4 ways to install Portabase Agent:
 
 ## Contributors
 
-<a href="https://github.com/Portabase/agent-portabase/graphs/contributors">
-  <img src="https://contrib.rocks/image?repo=Portabase/agent-portabase" alt="contrib.rocks image" />
-</a>
+[![Contributors](https://contrib.rocks/image?repo=Portabase/agent-rust)](https://github.com/Portabase/agent-rust/graphs/contributors)
+
+[!["Support Portabase"](https://www.buymeacoffee.com/assets/img/custom_images/orange_img.png)](https://www.buymeacoffee.com/portabase)
 
 ## License
 

databases.json

@@ -1,34 +1,44 @@
 {
   "databases": [
     {
-      "name": "Test database 1 - rust",
+      "name": "Test database 1 - PostgreSQL",
       "database": "devdb",
       "type": "postgresql",
       "username": "devuser",
       "password": "changeme",
       "port": 5432,
-      "host": "db",
+      "host": "db-postgres",
       "generated_id": "16678159-ff7e-4c97-8c83-0adeff214681"
     },
     {
-      "name": "Test database 2 - rust",
-      "database": "devdb",
-      "type": "postgresql",
-      "username": "devuser",
-      "password": "changeme",
-      "port": 5432,
-      "host": "db",
-      "generated_id": "16678156-ff7e-4c97-8c83-0adeff214681"
-    },
-    {
-      "name": "Test database 3 - rust",
+      "name": "Test database 2 - MariaDB",
       "database": "mariadb",
       "type": "mysql",
       "username": "mariadb",
       "password": "changeme",
       "port": 3306,
-      "host": "db2",
+      "host": "db-mariadb",
       "generated_id": "16678124-ff7e-4c97-8c83-0adeff214681"
+    },
+    {
+      "name": "Test database 4 - MongoDB Auth",
+      "database": "testdbauth",
+      "type": "mongodb",
+      "username": "root",
+      "password": "rootpassword",
+      "port": 27017,
+      "host": "db-mongodb-auth",
+      "generated_id": "16678145-ff7e-4c97-8c83-0adeff214681"
+    },
+    {
+      "name": "Test database 5 - MongoDB",
+      "database": "testdb",
+      "type": "mongodb",
+      "username": "",
+      "password": "",
+      "port": 27017,
+      "host": "db-mongodb",
+      "generated_id": "16678147-ff7e-4c97-8c83-0adeff214681"
     }
   ]
 }

databases.toml

@@ -1,29 +1,39 @@
 [[databases]]
-name = "Test database 1 - rust"
+name = "Test database 1 - PostgreSQL"
 database = "devdb"
 type = "postgresql"
 username = "devuser"
 password = "changeme"
 port = 5432
-host = "db"
+host = "db-postgres"
 generated_id = "16678159-ff7e-4c97-8c83-0adeff214689"
 
 [[databases]]
-name = "Test database 2 - rust"
-database = "devdb"
-type = "postgresql"
-username = "devuser"
-password = "changeme"
-port = 5432
-host = "db"
-generated_id = "16678156-ff7e-4c97-8c83-0adeff214654"
-
-[[databases]]
-name = "Test database 3 - rust"
+name = "Test database 2 - MariaDB"
 database = "mariadb"
 type = "mysql"
 username = "mariadb"
 password = "changeme"
 port = 3306
-host = "db1"
+host = "db-mariadb"
 generated_id = "16678124-ff7e-4c97-8c83-0adeff214667"
+
+[[databases]]
+name = "Test database 3 - MongoDB Auth"
+database = "testdbauth"
+type = "mongodb"
+username = "root"
+password = "rootpassword"
+port = 27017
+host = "db-mongodb-auth"
+generated_id = "16678145-ff7e-4c97-8c83-0adeff214681"
+
+[[databases]]
+name = "Test database 3 - MongoDB"
+database = "testdb"
+type = "mongodb"
+username = ""
+password = ""
+port = 27017
+host = "db-mongodb"
+generated_id = "16678147-ff7e-4c97-8c83-0adeff214681"

docker-compose.prod.yml

@@ -1,53 +1,24 @@
 services:
   rust-app:
-    build:
-      context: .
-      dockerfile: docker/Dockerfile
-      target: prod
+    #    build:
+    #      context: .
+    #      dockerfile: docker/Dockerfile
+    #      target: prod
+    image: portabase/agent:latest
     container_name: rust-prod
     volumes:
-      - ./databases.toml:/config/config.toml
+      - ./databases.json:/config/config.json
     environment:
-#      APP_ENV: production
+      #      APP_ENV: production
       LOG: info
       TZ: "Europe/Paris"
-      DATABASES_CONFIG_FILE: "config.toml"
-      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiOThlZmY1YjEtMDQyZC00MDkxLWJkYjctZTgzYmM0YjczNjAxIiwicHVibGljS2V5IjoiLS0tLS1CRUdJTiBSU0EgUFVCTElDIEtFWS0tLS0tXG5NSUlCQ2dLQ0FRRUFuYUVKdnVBSExlNGF5d0RmNGplelVobm45VXRkdksyZ3pEMEg2cERJYXczYkJKRkpwVnVDXG5uVFV3MXA3Q2RnOXBzdjZhRnpyOXZPd0J2MjMzckxpdVpCT2lCb2p2Q0QrSlZid3hyTzBRRW5hN2dmaHV1ZGYwXG5VVlJOMkxmK1g1aTkvZzJTNm5xcExoTm1DaGFJNk8ybktYZUNlRmtubEErRUJrNnFoV1FCVGozb05TYTFTOFY1XG40UFRTT2I4NUo3a2k5YllEbXRiNWxrU3dCNXdXOTdtQjg0ZzI2WHAvU3FFcmhKc0NGK3YrN09vTWYzTzJqTTNoXG5XMUQ0MzBPRitWaklwUGdoV09rZy96NXZQUWFHRzhqQ0h4VDlJR0Q0bjhyS05LQ3FTOGNyN2diTGU0cWpNdmhvXG5BQVVvaHpHR2FRNkhlWlJ4S0UvM3J1a2JldnY5dnJ2TTNRSURBUUFCXG4tLS0tLUVORCBSU0EgUFVCTElDIEtFWS0tLS0tXG4ifQ"
+      #      DATABASES_CONFIG_FILE: "config.toml"
+      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiY2VlZmNmNDQtOGE0YS00NjZlLTkwNDEtN2QzNDMzZjRjOTJkIiwicHVibGljS2V5IjoiLS0tLS1CRUdJTiBSU0EgUFVCTElDIEtFWS0tLS0tXG5NSUlCQ2dLQ0FRRUFuYUVKdnVBSExlNGF5d0RmNGplelVobm45VXRkdksyZ3pEMEg2cERJYXczYkJKRkpwVnVDXG5uVFV3MXA3Q2RnOXBzdjZhRnpyOXZPd0J2MjMzckxpdVpCT2lCb2p2Q0QrSlZid3hyTzBRRW5hN2dmaHV1ZGYwXG5VVlJOMkxmK1g1aTkvZzJTNm5xcExoTm1DaGFJNk8ybktYZUNlRmtubEErRUJrNnFoV1FCVGozb05TYTFTOFY1XG40UFRTT2I4NUo3a2k5YllEbXRiNWxrU3dCNXdXOTdtQjg0ZzI2WHAvU3FFcmhKc0NGK3YrN09vTWYzTzJqTTNoXG5XMUQ0MzBPRitWaklwUGdoV09rZy96NXZQUWFHRzhqQ0h4VDlJR0Q0bjhyS05LQ3FTOGNyN2diTGU0cWpNdmhvXG5BQVVvaHpHR2FRNkhlWlJ4S0UvM3J1a2JldnY5dnJ2TTNRSURBUUFCXG4tLS0tLUVORCBSU0EgUFVCTElDIEtFWS0tLS0tXG4ifQ"
     extra_hosts:
       - "localhost:host-gateway"
     networks:
       - portabase
 
-  db:
-    image: postgres:17-alpine
-    ports:
-      - "5413:5432"
-    volumes:
-      - postgres-data:/var/lib/postgresql/data
-    environment:
-      - POSTGRES_DB=devdb
-      - POSTGRES_USER=devuser
-      - POSTGRES_PASSWORD=changeme
-    networks:
-      - portabase
-
-  db2:
-    image: mariadb:latest
-    ports:
-      - "3313:3306"
-    environment:
-      - MYSQL_DATABASE=mariadb
-      - MYSQL_USER=mariadb
-      - MYSQL_PASSWORD=changeme
-      - MYSQL_RANDOM_ROOT_PASSWORD=yes
-    volumes:
-      - mariadb-data:/var/lib/mysql
-    networks:
-      - portabase
-
-volumes:
-  postgres-data:
-  mariadb-data:
 
 
 networks:

docker-compose.yml

@@ -14,16 +14,17 @@ services:
     environment:
       APP_ENV: development
       LOG: debug
-#      POOLING: 1
       TZ: "Europe/Paris"
-      #      DATABASES_CONFIG_FILE: "config.toml"
-      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiOWU0NjE0YTEtMjJkMi00NWJlLTgyZWEtMTI4MzQ1OGU0YjUwIiwicHVibGljS2V5IjoiLS0tLS1CRUdJTiBSU0EgUFVCTElDIEtFWS0tLS0tXG5NSUlCQ2dLQ0FRRUFuYUVKdnVBSExlNGF5d0RmNGplelVobm45VXRkdksyZ3pEMEg2cERJYXczYkJKRkpwVnVDXG5uVFV3MXA3Q2RnOXBzdjZhRnpyOXZPd0J2MjMzckxpdVpCT2lCb2p2Q0QrSlZid3hyTzBRRW5hN2dmaHV1ZGYwXG5VVlJOMkxmK1g1aTkvZzJTNm5xcExoTm1DaGFJNk8ybktYZUNlRmtubEErRUJrNnFoV1FCVGozb05TYTFTOFY1XG40UFRTT2I4NUo3a2k5YllEbXRiNWxrU3dCNXdXOTdtQjg0ZzI2WHAvU3FFcmhKc0NGK3YrN09vTWYzTzJqTTNoXG5XMUQ0MzBPRitWaklwUGdoV09rZy96NXZQUWFHRzhqQ0h4VDlJR0Q0bjhyS05LQ3FTOGNyN2diTGU0cWpNdmhvXG5BQVVvaHpHR2FRNkhlWlJ4S0UvM3J1a2JldnY5dnJ2TTNRSURBUUFCXG4tLS0tLUVORCBSU0EgUFVCTElDIEtFWS0tLS0tXG4ifQ"
+      EDGE_KEY: "eyJzZXJ2ZXJVcmwiOiJodHRwOi8vbG9jYWxob3N0Ojg4ODciLCJhZ2VudElkIjoiM2Y4ZDBiMmMtYThjYi00MWIzLTk0NjAtZGMxMGE0N2E2NzlmIiwicHVibGljS2V5IjoiLS0tLS1CRUdJTiBSU0EgUFVCTElDIEtFWS0tLS0tXG5NSUlCQ2dLQ0FRRUE5TWV4M2pmdnVLdFB5YU1ERnh2Ulp2dmd3YkRJQ2JzQi81Wll5NDNSVVRBaXZRYjJiSDdYXG5qRHBQd1lJeCs4UFBrbHlRbDVMQzV1UWZEaCs4SVd4OG1LZ3FvMXpWMkdiZXdGbEdEWFYxVEdyU1ZEU25aSWR4XG52bWdYc29EeXhVMlJvWUFUMS9YMWxuc2YxenZKdkFMTkhXdEhRdk42SjVDZTFSMmFsendVRGFEVXlJNzRmSldQXG5tNTh0SDMrYklXL0VVTXdjaWNxM0oySWw3Vm9KNkZNUHJQL1ZSOWEvdFF1SU1qa200MXpFY2NscExPa2luRkxuXG54NmVUWkFSZUpya2UrbnRvZ2t4TGEyRWV5a1lUNzB4V3hKNWp5ZExBVnRvNkkyQlVLVVJoTkowTUFaU29NYUtvXG5iMGJRcnY1UzExZWllMnMrT2I3aTYzSFpkVUx0UmV1MVJ3SURBUUFCXG4tLS0tLUVORCBSU0EgUFVCTElDIEtFWS0tLS0tXG4ifQ"
+      #POOLING: 1
+      #DATABASES_CONFIG_FILE: "config.toml"
     extra_hosts:
       - "localhost:host-gateway"
     networks:
       - portabase
 
-  db:
+  db-postgres:
+    container_name: db-postgres
     image: postgres:17-alpine
     ports:
       - "5436:5432"
@@ -36,7 +37,8 @@ services:
     networks:
       - portabase
 
-  db2:
+  db-mariadb:
+    container_name: db-mariadb
     image: mariadb:latest
     ports:
       - "3311:3306"
@@ -50,15 +52,56 @@ services:
     networks:
       - portabase
 
+
+  db-mongodb-auth:
+    container_name: db-mongodb-auth
+    image: mongo:latest
+    ports:
+      - "27082:27017"
+    environment:
+      MONGO_INITDB_ROOT_USERNAME: root
+      MONGO_INITDB_ROOT_PASSWORD: rootpassword
+      MONGO_INITDB_DATABASE: testdbauth
+    command: mongod --auth
+    networks:
+      - portabase
+    volumes:
+      - mongodb-data-auth:/data/db
+    healthcheck:
+      test: [ "CMD", "mongo", "--eval", "db.adminCommand('ping')" ]
+      interval: 5s
+      timeout: 5s
+      retries: 10
+
+  db-mongodb:
+    container_name: db-mongodb
+    image: mongo:latest
+    ports:
+      - "27083:27017"
+    volumes:
+      - mongodb-data:/data/db
+    healthcheck:
+      test: [ "CMD", "mongosh", "--eval", "db.adminCommand('ping')" ]
+      interval: 5s
+      timeout: 5s
+      retries: 10
+    environment:
+      MONGO_INITDB_DATABASE: testdb
+    networks:
+      - portabase
+
 volumes:
   cargo-registry:
   cargo-git:
 
   postgres-data:
   mariadb-data:
-
+  mongodb-data:
+  mongodb-data-auth:
 
 networks:
   portabase:
     name: portabase_network
-    external: true
+    external: true
+
+# docker network create portabase_network

docker/Dockerfile

@@ -45,8 +45,28 @@ RUN if [ "$TARGETARCH" = "amd64" ]; then \
     chmod +x /usr/lib/postgresql/*/bin/*
 
 
-
-
+# =========================
+# MongoDB client binaries
+# =========================
+RUN apt-get update && \
+    if [ "$TARGETARCH" = "amd64" ]; then \
+        wget -q https://fastdl.mongodb.org/tools/db/mongodb-database-tools-debian12-x86_64-100.10.0.deb \
+            -O /tmp/mongodb-database-tools.deb; \
+    elif [ "$TARGETARCH" = "arm64" ]; then \
+        wget -q https://fastdl.mongodb.org/tools/db/mongodb-database-tools-ubuntu2204-arm64-100.10.0.deb \
+            -O /tmp/mongodb-database-tools.deb; \
+    fi && \
+    dpkg -i /tmp/mongodb-database-tools.deb || \
+        apt-get install -f -y --no-install-recommends && \
+    rm -f /tmp/mongodb-database-tools.deb && \
+    rm -rf /var/lib/apt/lists/* && \
+    mkdir -p /usr/local/mongodb/bin && \
+    if [ -f /usr/bin/mongodump ]; then \
+        ln -sf /usr/bin/mongodump /usr/local/mongodb/bin/mongodump; \
+    fi && \
+    if [ -f /usr/bin/mongorestore ]; then \
+        ln -sf /usr/bin/mongorestore /usr/local/mongodb/bin/mongorestore; \
+    fi
 
 WORKDIR /app
 

scripts/README.md

@@ -0,0 +1,12 @@
+# Seed instructions
+
+## MongoDB 
+
+```bash
+make seed-mongo     
+make seed-mongo-auth  
+make seed-mysql      
+make seed-postgres      
+make seed-postgres-1gb  
+make seed-all      
+```

scripts/mongo/seed-mongo.sh

@@ -0,0 +1,71 @@
+#!/usr/bin/env bash
+
+# Usage:
+# ./seed-mongo.sh           -> no auth
+# ./seed-mongo.sh auth      -> with auth
+
+MODE=${1:-noauth}  # default: noauth
+
+# Default values (can be overridden via .env)
+MONGO_DB=${MONGO_DB:-testdb}
+MONGO_PORT=${MONGO_PORT:-27017}
+
+# Auth variables
+MONGO_AUTH_USERNAME=${MONGO_AUTH_USERNAME:-root}
+MONGO_AUTH_PASSWORD=${MONGO_AUTH_PASSWORD:-rootpassword}
+MONGO_AUTH_DB=${MONGO_AUTH_DB:-testdbauth}
+
+NUM_USERS=${NUM_USERS:-5000}
+
+# Build connection string
+if [ "$MODE" = "auth" ]; then
+    MONGO_CONTAINER=${MONGO_AUTH_CONTAINER:-db-mongodb-auth}
+    URI="mongodb://$MONGO_AUTH_USERNAME:$MONGO_AUTH_PASSWORD@localhost:$MONGO_PORT/$MONGO_AUTH_DB?authSource=admin"
+    echo "Using authenticated MongoDB..."
+else
+    MONGO_CONTAINER=${MONGO_CONTAINER:-db-mongodb}
+    URI="mongodb://localhost:$MONGO_PORT/$MONGO_DB"
+    echo "Using non-authenticated MongoDB..."
+fi
+
+# Create temp JS seed file
+SEED_FILE=$(mktemp /tmp/seed.XXXX.js)
+
+cat <<EOF > "$SEED_FILE"
+db = connect("$URI");
+
+// Drop collections if exist
+if (db.users) db.users.drop();
+if (db.products) db.products.drop();
+
+// Generate users
+const users = [];
+for (let i = 1; i <= $NUM_USERS; i++) {
+    users.push({
+        username: "user" + i,
+        email: "user" + i + "@example.com",
+        age: Math.floor(Math.random() * 60) + 18,
+        active: Math.random() > 0.5,
+        createdAt: new Date()
+    });
+}
+db.users.insertMany(users);
+
+// Generate products
+const products = [];
+for (let i = 1; i <= Math.floor($NUM_USERS/10); i++) {
+    products.push({
+        name: "Product " + i,
+        price: parseFloat((Math.random()*100).toFixed(2)),
+        stock: Math.floor(Math.random()*500),
+        createdAt: new Date()
+    });
+}
+db.products.insertMany(products);
+
+print("Seed complete: " + users.length + " users, " + products.length + " products.");
+EOF
+
+docker cp "$SEED_FILE" "$MONGO_CONTAINER:/seed.js"
+docker exec -it "$MONGO_CONTAINER" mongosh /seed.js
+rm "$SEED_FILE"

src/domain/factory.rs

@@ -1,5 +1,4 @@
-#![allow(dead_code)]
-
+use crate::domain::mogodb::database::MongoDatabase;
 use crate::domain::mysql::database::MySQLDatabase;
 use crate::domain::postgres::database::PostgresDatabase;
 use crate::domain::postgres::{detect_format_from_file, detect_format_from_size};
@@ -11,7 +10,6 @@ use std::sync::Arc;
 #[async_trait::async_trait]
 pub trait Database: Send + Sync {
     fn file_extension(&self) -> &'static str;
-
     async fn ping(&self) -> Result<bool>;
     async fn backup(&self, backup_dir: &Path) -> Result<PathBuf>;
     async fn restore(&self, restore_file: &Path) -> Result<()>;
@@ -28,6 +26,7 @@ impl DatabaseFactory {
             }
             DbType::Mysql => Arc::new(MySQLDatabase::new(cfg)),
             DbType::Mariadb => Arc::new(MySQLDatabase::new(cfg)),
+            DbType::MongoDB => Arc::new(MongoDatabase::new(cfg)),
         }
     }
 
@@ -39,6 +38,7 @@ impl DatabaseFactory {
             }
             DbType::Mysql => Arc::new(MySQLDatabase::new(cfg)),
             DbType::Mariadb => Arc::new(MySQLDatabase::new(cfg)),
+            DbType::MongoDB => Arc::new(MongoDatabase::new(cfg)),
         }
     }
 }

src/domain/mod.rs

@@ -1,4 +1,5 @@
 pub mod factory;
 pub mod postgres;
 pub mod mysql;
+mod mogodb;
 

src/domain/mogodb/backup.rs

@@ -0,0 +1,36 @@
+use crate::domain::mogodb::connection::{get_mongo_uri, select_mongo_path};
+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 MongoDB backup for database {}", cfg.name);
+
+        let file_path = backup_dir.join(format!("{}{}", cfg.generated_id, file_extension));
+        let mongodump = select_mongo_path().join("mongodump");
+        let uri = get_mongo_uri(cfg.clone());
+
+        let output = Command::new(mongodump)
+            .arg(format!("--uri={}", uri))
+            .arg(format!("--archive={}", file_path.display()))
+            .arg("--gzip")
+            .output()
+            .context("MongoDB backup failed")?;
+
+        if !output.status.success() {
+            let stderr = String::from_utf8_lossy(&output.stderr);
+            error!("MongoDB backup failed for {}: {}", cfg.name, stderr);
+            anyhow::bail!("MongoDB backup failed for {}: {}", cfg.name, stderr);
+        }
+        info!("MongoDB backup completed for {}", cfg.name);
+        Ok(file_path)
+    })
+    .await?
+}

src/domain/mogodb/connection.rs

@@ -0,0 +1,28 @@
+use crate::services::config::DatabaseConfig;
+use anyhow::Result;
+use mongodb::Client;
+
+pub async fn connect(cfg: DatabaseConfig) -> Result<Client> {
+    let uri = get_mongo_uri(cfg);
+    let mut options = mongodb::options::ClientOptions::parse(&uri).await?;
+    options.server_selection_timeout = Some(std::time::Duration::from_secs(3));
+    options.connect_timeout = Some(std::time::Duration::from_secs(3));
+    let client = Client::with_options(options)?;
+    Ok(client)
+}
+
+pub fn select_mongo_path() -> std::path::PathBuf {
+    "/usr/local/mongodb/bin".to_string().into()
+}
+
+pub fn get_mongo_uri(cfg: DatabaseConfig) -> String {
+    if cfg.username.is_empty() {
+        format!("mongodb://{}:{}/{}", cfg.host, cfg.port, cfg.database)
+
+    } else {
+        format!(
+            "mongodb://{}:{}@{}:{}/{}?authSource=admin",
+            cfg.username, cfg.password, cfg.host, cfg.port, cfg.database
+        )
+    }
+}

src/domain/mogodb/database.rs

@@ -0,0 +1,48 @@
+use anyhow::Result;
+use async_trait::async_trait;
+use std::path::{Path, PathBuf};
+
+use super::{backup, ping, restore};
+use crate::domain::factory::Database;
+use crate::services::config::DatabaseConfig;
+use crate::utils::locks::{DbOpLock, FileLock};
+
+pub struct MongoDatabase {
+    cfg: DatabaseConfig,
+}
+
+impl MongoDatabase {
+    pub fn new(cfg: DatabaseConfig) -> Self {
+        Self { cfg }
+    }
+}
+
+#[async_trait]
+impl Database for MongoDatabase {
+    fn file_extension(&self) -> &'static str {
+        ".archive.gz"
+    }
+
+    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<()> {
+        FileLock::acquire(&self.cfg.generated_id, DbOpLock::Restore.as_str()).await?;
+        let res = restore::run(self.cfg.clone(), file.to_path_buf()).await;
+        FileLock::release(&self.cfg.generated_id).await?;
+        res
+    }
+}

src/domain/mogodb/mod.rs

@@ -0,0 +1,5 @@
+mod backup;
+mod restore;
+pub mod database;
+mod ping;
+mod connection;

src/domain/mogodb/ping.rs

@@ -0,0 +1,24 @@
+#![allow(dead_code)]
+
+use crate::services::config::DatabaseConfig;
+use anyhow::Result;
+use mongodb::bson::doc;
+use tracing::{error};
+use crate::domain::mogodb::connection::connect;
+
+pub async fn run(cfg: DatabaseConfig) -> Result<bool> {
+    let client = connect(cfg.clone()).await?;
+    let db_name = if cfg.username.is_empty() { &cfg.database } else { "admin" };
+    match client.database(db_name).run_command(doc! {"ping": 1}).await {
+        Ok(_) => Ok(true),
+        Err(e) => {
+            error!("--- MongoDB Connection Error Details ---");
+            error!("Target Host: {}:{}", cfg.host, cfg.port);
+            error!("Error Kind: {:?}", e.kind);
+            error!("Full Error: {}", e);
+            error!("Check you database network connectivity");
+            error!("----------------------------------------");
+            Err(anyhow::anyhow!("Ping failed for {}: {}", cfg.name, e))
+        }
+    }
+}

src/domain/mogodb/restore.rs

@@ -0,0 +1,33 @@
+use crate::domain::mogodb::connection::{get_mongo_uri, select_mongo_path};
+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, restore_file: PathBuf) -> Result<()> {
+    tokio::task::spawn_blocking(move || -> Result<()> {
+        debug!("Starting MongoDB restore for database {}", cfg.name);
+
+        let mongorestore = select_mongo_path().join("mongorestore");
+        let uri = get_mongo_uri(cfg.clone());
+
+        let output = Command::new(mongorestore)
+            .arg(format!("--uri={}", uri))
+            .arg(format!("--archive={}", restore_file.display()))
+            .arg("--gzip")
+            .arg("--drop")
+            .output()
+            .with_context(|| format!("Failed to run mongorestore for {}", cfg.name))?;
+
+        if !output.status.success() {
+            let stderr = String::from_utf8_lossy(&output.stderr);
+            error!("MongoDB restore failed for {}: {}", cfg.name, stderr);
+            anyhow::bail!("MongoDB restore failed for : {}", cfg.name);
+        }
+
+        info!("MongoDB restore completed for {}", cfg.name);
+        Ok(())
+    })
+    .await?
+}

src/services/backup.rs

@@ -7,7 +7,6 @@ use crate::utils::common::BackupMethod;
 use crate::utils::file::full_extension;
 use anyhow::Result;
 use hex;
-use tracing::{error, info};
 use openssl::encrypt::Encrypter;
 use openssl::hash::MessageDigest;
 use openssl::pkey::PKey;
@@ -19,6 +18,7 @@ use std::path::{Path, PathBuf};
 use std::sync::Arc;
 use tempfile::TempDir;
 use tokio::fs;
+use tracing::{error, info};
 
 #[derive(Debug)]
 pub struct BackupResult {

src/services/config.rs

@@ -16,6 +16,7 @@ pub enum DbType {
     Mysql,
     Mariadb,
     Postgresql,
+    MongoDB
     // Sqlite,
     // Add other DB types if needed
 }
@@ -26,6 +27,7 @@ impl DbType {
             DbType::Mysql => "mysql",
             DbType::Mariadb => "mysql",
             DbType::Postgresql => "postgresql",
+            DbType::MongoDB => "mongodb",
             // DbType::Sqlite => "sqlite",
         }
     }

src/services/restore.rs

@@ -101,6 +101,7 @@ impl RestoreService {
 
         let db_instance = DatabaseFactory::create_for_restore(cfg.clone(), &backup_file_path).await;
         let reachable = db_instance.ping().await.unwrap_or(false);
+        info!("Reachable: {}", reachable);
         if !reachable {
             return Ok(RestoreResult {
                 generated_id,

src/services/status.rs

@@ -91,7 +91,7 @@ impl StatusService {
             })
             .collect();
 
-        let version_str = format!("{}-rust", CONFIG.app_version);
+        let version_str = CONFIG.app_version.as_str();
 
         let body = StatusRequestBody {
             version: &version_str,