refactor(queue): switch from rabbitmq to lavinmq

Author: nicotsx

internal/assets/docker-compose.yml

@@ -39,31 +39,36 @@ services:
 
   runtipi-queue:
     container_name: runtipi-queue
-    image: rabbitmq:4-alpine
+    image: cloudamqp/lavinmq
+    healthcheck:
+      test: ["CMD-SHELL", "lavinmqctl status"]
+      interval: 5s
+      timeout: 10s
+      retries: 20
+      start_period: 5s
     restart: unless-stopped
+    volumes:
+      - ./lavinmq.ini:/etc/lavinmq/lavinmq.ini
     ports:
       - 5672:5672
-    environment:
-      RABBITMQ_DEFAULT_USER: tipi
-      RABBITMQ_DEFAULT_PASS: ${RABBITMQ_PASSWORD}
     networks:
       - tipi_main_network
 
   runtipi:
     container_name: runtipi
     healthcheck:
-      start_period: 10s
       test: ["CMD", "curl", "-f", "http://localhost:3000/api/health"]
       interval: 5s
       timeout: 10s
       retries: 20
+      start_period: 10s
     image: ghcr.io/runtipi/runtipi:${TIPI_VERSION}
     restart: unless-stopped
     depends_on:
       runtipi-db:
         condition: service_healthy
       runtipi-queue:
-        condition: service_started
+        condition: service_healthy
     env_file:
       - .env
     volumes:

internal/utils/env.go

@@ -131,6 +131,17 @@ func GenerateEnvFile(customEnvFile string) error {
 		rabbitmqPassword = DeriveEntropy("rabbitmq_password", seed)
 	}
 
+	hashedPassword, err := HashPassword(rabbitmqPassword)
+	if err != nil {
+		return fmt.Errorf("failed to hash rabbitmq password: %w", err)
+	}
+
+	lavinmqIniPath := filepath.Join(config.RootFolder, "lavinmq.ini")
+	lavinmqIniContent := fmt.Sprintf("[main]\ndefault_user = tipi\ndefault_password = %s\n", hashedPassword)
+	if err := os.WriteFile(lavinmqIniPath, []byte(lavinmqIniContent), 0644); err != nil {
+		return fmt.Errorf("failed to write lavinmq.ini: %w", err)
+	}
+
 	// Handle app data path
 	appDataPath := settings.AppDataPath
 	if appDataPath == "" {

internal/utils/system_info.go

@@ -1,7 +1,9 @@
 package utils
 
 import (
+	"crypto/rand"
 	"crypto/sha256"
+	"encoding/base64"
 	"encoding/hex"
 	"net"
 	"os"
@@ -34,3 +36,21 @@ func DeriveEntropy(key, seed string) string {
 	hash := sha256.Sum256([]byte(key + seed))
 	return hex.EncodeToString(hash[:])[:32]
 }
+
+func HashPassword(password string) (string, error) {
+	salt := make([]byte, 4)
+	_, err := rand.Read(salt)
+	if err != nil {
+		return "", err
+	}
+
+	salted := append(salt, []byte(password)...)
+
+	hash := sha256.Sum256(salted)
+
+	final := append(salt, hash[:]...)
+
+	encoded := base64.StdEncoding.EncodeToString(final)
+
+	return encoded, nil
+}