Feature/autoreply modes

API.md

@@ -705,6 +705,64 @@ curl -s -X POST -H 'Token: 1234ABCD' -H 'Content-Type: application/json' --data
 
 ---
 
+### Add/Update Auto-Reply
+* **Method:** `POST`
+* **Path:** `/chat/autoreply`
+* **Description:** Sets up an auto-reply for a specific phone number. If an auto-reply for the given phone number already exists for the user, it will be updated. If not, a new one will be created.
+* **Authentication:** Requires user token.
+* **Request Body (JSON):**
+  ```json
+  {
+    "Phone": "1234567890", // Target phone number (normalized, e.g., digits only or international format used by the system)
+    "Body": "Hello! I am currently unavailable and will get back to you soon."
+  }
+  ```
+* **Responses:**
+  * `201 Created`: If a new auto-reply was successfully created.
+    ```json
+    {
+      "code": 201,
+      "data": {
+        "detail": "Auto-reply added successfully",
+        "id": "generated-unique-id-for-the-rule"
+      },
+      "success": true
+    }
+    ```
+  * `400 Bad Request`: If `Phone` or `Body` is missing or invalid.
+  * `409 Conflict`: If an auto-reply for this phone number already exists for the user.
+  * `500 Internal Server Error`: For other server-side errors.
+
+---
+
+### Delete Auto-Reply
+* **Method:** `DELETE`
+* **Path:** `/chat/autoreply`
+* **Description:** Deletes an existing auto-reply for a specific phone number for the authenticated user.
+* **Authentication:** Requires user token.
+* **Request Body (JSON):**
+  ```json
+  {
+    "Phone": "1234567890" // Target phone number whose auto-reply rule should be deleted.
+  }
+  ```
+* **Responses:**
+  * `200 OK`: If the auto-reply was successfully deleted.
+    ```json
+    {
+      "code": 200,
+      "data": {
+        "detail": "Auto-reply deleted successfully"
+      },
+      "success": true
+    }
+    ```
+  * `400 Bad Request`: If `Phone` is missing or invalid.
+  * `404 Not Found`: If no auto-reply rule exists for the given phone number for this user.
+  * `500 Internal Server Error`: For other server-side errors.
+
+---
+
 ## Download Document
 
 Downloads a Document from a message and retrieves it Base64 media encoded. Required request parameters are: Url, MediaKey, Mimetype, FileSHA256 and FileLength

Dockerfile

@@ -21,7 +21,7 @@ RUN apk update && apk add --no-cache \
     ffmpeg \
     tzdata
 
-ENV TZ="America/Sao_Paulo"
+ENV TZ="Asia/Kolkata"
 WORKDIR /app
 
 COPY --from=builder /app/wuzapi         /app/
@@ -34,4 +34,4 @@ RUN chown -R root:root /app
 
 VOLUME [ "/app/dbdata", "/app/files" ]
 
-ENTRYPOINT ["/app/wuzapi", "--logtype=console", "--color=true"]
+ENTRYPOINT ["/app/wuzapi", "--logtype=console", "--color=true"]

adduser.sh

@@ -0,0 +1,22 @@
+#!/bin/bash
+
+# Script to create a user via curl
+
+# Validate the number of arguments
+if [ "$#" -ne 3 ]; then
+    echo "Usage: $0 <adminpass> <username> <passwd>"
+    exit 1
+fi
+
+# Assign arguments to variables
+ADMIN_PASS="$1"
+USERNAME="$2"
+USER_PASSWD="$3"
+
+# Execute the curl command
+curl -X POST http://localhost:8089/admin/users \
+-H "Authorization: ${ADMIN_PASS}" \
+-H "Content-Type: application/json" \
+-d "{\"name\": \"${USERNAME}\", \"token\": \"${USER_PASSWD}\"}"
+
+echo # Add a newline for cleaner output

db.go

@@ -24,9 +24,101 @@ func InitializeDatabase(exPath string) (*sqlx.DB, error) {
 	config := getDatabaseConfig(exPath)
 
 	if config.Type == "postgres" {
-		return initializePostgres(config)
+		db, err := initializePostgres(config)
+		if err != nil {
+			return nil, err
+		}
+		// Create tables for postgres
+		if err := createTables(db, "postgres"); err != nil {
+			return nil, fmt.Errorf("failed to create tables for postgres: %w", err)
+		}
+		return db, nil
+	}
+
+	// Default to SQLite
+	db, err := initializeSQLite(config)
+	if err != nil {
+		return nil, err
 	}
-	return initializeSQLite(config)
+	// Create tables for sqlite
+	if err := createTables(db, "sqlite"); err != nil {
+		return nil, fmt.Errorf("failed to create tables for sqlite: %w", err)
+	}
+	return db, nil
+}
+
+func createTables(db *sqlx.DB, dbType string) error {
+	// SQL for creating autoreply_modes table
+	autoreplyModesTableSQL := `
+	CREATE TABLE IF NOT EXISTS autoreply_modes (
+		user_id TEXT NOT NULL,
+		mode_name TEXT NOT NULL,
+		phone_number TEXT NOT NULL,
+		message TEXT NOT NULL,
+		UNIQUE (user_id, mode_name, phone_number)
+	);`
+
+	// SQL for creating active_mode table
+	activeModeTableSQL := `
+	CREATE TABLE IF NOT EXISTS active_mode (
+		user_id TEXT PRIMARY KEY NOT NULL,
+		current_mode_name TEXT NULLABLE
+	);`
+
+	// Execute table creation statements
+	if _, err := db.Exec(autoreplyModesTableSQL); err != nil {
+		return fmt.Errorf("failed to create autoreply_modes table: %w", err)
+	}
+	if _, err := db.Exec(activeModeTableSQL); err != nil {
+		return fmt.Errorf("failed to create active_mode table: %w", err)
+	}
+
+	// No initial data for active_mode as it's user-specific and populated on demand.
+
+	// Alter users table to add google_contacts_auth_token column
+	alterUsersTableSQL := ""
+	if dbType == "postgres" {
+		alterUsersTableSQL = `ALTER TABLE users ADD COLUMN IF NOT EXISTS google_contacts_auth_token TEXT;`
+	} else { // sqlite
+		// Check if column exists first for older SQLite versions.
+		// For newer SQLite (3.16.0+), ADD COLUMN is idempotent if the column exists.
+		// However, to be safe and support potentially older versions, we can check.
+		// A simpler approach for tests or if newer SQLite is guaranteed is just:
+		// alterUsersTableSQL = `ALTER TABLE users ADD COLUMN google_contacts_auth_token TEXT;`
+		// For robustness in a production-like environment, checking PRAGMA is better.
+
+		// Let's use the simpler ALTER TABLE for now, assuming modern SQLite.
+		// If this causes issues, a PRAGMA check can be added.
+		alterUsersTableSQL = `ALTER TABLE users ADD COLUMN google_contacts_auth_token TEXT;`
+
+		// Check if column exists to avoid error on re-run with older SQLite
+		var columnName string
+		query := "SELECT name FROM pragma_table_info('users') WHERE name = 'google_contacts_auth_token';"
+		err := db.Get(&columnName, query)
+		if err == nil && columnName == "google_contacts_auth_token" {
+			// Column already exists, no need to alter
+			alterUsersTableSQL = ""
+		} else if err != nil && err.Error() != "sql: no rows in result set" {
+            // An actual error occurred querying pragma_table_info
+            return fmt.Errorf("failed to check users table schema: %w", err)
+        }
+        // If err is "sql: no rows in result set", column doesn't exist, proceed with ALTER.
+	}
+
+	if alterUsersTableSQL != "" {
+		if _, err := db.Exec(alterUsersTableSQL); err != nil {
+			// For SQLite, if the column already exists, this might return an error "duplicate column name"
+			// We'll log it and continue if it's that specific error for SQLite.
+			if dbType == "sqlite" && strings.Contains(err.Error(), "duplicate column name") {
+				// log.Warn().Msg("Column google_contacts_auth_token already exists in users table (SQLite).")
+			} else {
+				return fmt.Errorf("failed to alter users table to add google_contacts_auth_token: %w", err)
+			}
+		}
+	}
+
+
+	return nil
 }
 
 func getDatabaseConfig(exPath string) DatabaseConfig {
@@ -70,7 +162,6 @@ func initializePostgres(config DatabaseConfig) (*sqlx.DB, error) {
 	if err := db.Ping(); err != nil {
 		return nil, fmt.Errorf("failed to ping postgres database: %w", err)
 	}
-
 	return db, nil
 }
 
@@ -89,6 +180,5 @@ func initializeSQLite(config DatabaseConfig) (*sqlx.DB, error) {
 	if err := db.Ping(); err != nil {
 		return nil, fmt.Errorf("failed to ping sqlite database: %w", err)
 	}
-
 	return db, nil
 }