Merge pull request #4 from enzodjabali/3-implementing-an-auto-reply-after-some-time

3 implementing an auto reply after some time

Author: enzodjabali

.github/CODEOWNERS

@@ -0,0 +1 @@
+* @enzodjabali

.github/workflows/build.yml

@@ -0,0 +1,47 @@
+name: Build and Publish to GitHub Packages on Tag
+
+on:
+  push:
+    tags:
+      - 'v*' # Matches any tag; adjust for specific patterns like 'v*'
+
+jobs:
+  build-and-publish:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      packages: write
+
+    steps:
+    # Step 1: Checkout the code
+    - name: Checkout code
+      uses: actions/checkout@v3
+
+    # Step 2: Log in to GitHub Packages container registry
+    - name: Log in to GitHub Container Registry
+      uses: docker/login-action@v2
+      with:
+        registry: ghcr.io
+        username: ${{ github.actor }}
+        password: ${{ secrets.GITHUB_TOKEN }}
+
+    # Step 3: Build and tag the Docker image with version tag and 'latest'
+    - name: Build and tag Docker image
+      run: |
+        TAG=$(echo ${GITHUB_REF#refs/tags/}) # Extract the tag
+        IMAGE=ghcr.io/enzodjabali/iosmb-router
+        docker build --build-arg VERSION=$TAG -t $IMAGE:$TAG .
+        docker tag $IMAGE:$TAG $IMAGE:latest
+
+    # Step 4: Push the Docker image with version tag
+    - name: Push Docker image with version tag
+      run: |
+        TAG=$(echo ${GITHUB_REF#refs/tags/}) # Extract the tag
+        IMAGE=ghcr.io/enzodjabali/iosmb-router
+        docker push $IMAGE:$TAG
+
+    # Step 5: Push the Docker image with 'latest' tag
+    - name: Push Docker image with 'latest' tag
+      run: |
+        IMAGE=ghcr.io/enzodjabali/iosmb-router
+        docker push $IMAGE:latest

.gitignore

@@ -27,6 +27,9 @@ go.work.sum
 # env file
 .env
 
+# Rules file
+rules.yaml
+
 # Editor/IDE
 # .idea/
 # .vscode/

main.go

@@ -31,12 +31,13 @@ type Rules struct {
 }
 
 type Rule struct {
-	Name        string   `yaml:"name"`
-	Type        string   `yaml:"type"` // "redirect" or "auto_reply"
-	FromSender  string   `yaml:"from_sender"`
-	ToReceivers []string `yaml:"to_receivers,omitempty"`
-	ReplyText   string   `yaml:"reply_text,omitempty"`
-	Enabled     bool     `yaml:"enabled"`
+	Name                string   `yaml:"name"`
+	Type                string   `yaml:"type"` // "redirect", "auto_reply", or "auto_reply_after_silence"
+	FromSender          string   `yaml:"from_sender"`
+	ToReceivers         []string `yaml:"to_receivers,omitempty"`
+	ReplyText           string   `yaml:"reply_text,omitempty"`
+	SilenceDurationSecs int      `yaml:"silence_duration_secs,omitempty"` // Time in seconds before auto-reply triggers
+	Enabled             bool     `yaml:"enabled"`
 }
 
 // WebSocket message structures
@@ -75,14 +76,20 @@ type OutgoingMessage struct {
 }
 
 var (
-	conn   *websocket.Conn
-	config Config
-	rules  Rules
+	conn                *websocket.Conn
+	config              Config
+	rules               Rules
+	lastConversationMap map[string]time.Time      // Tracks last message time per sender
+	autoReplyStatusMap  map[string]bool           // Tracks if auto-reply was already sent
 )
 
 func main() {
 	log.Println("iOSMB-Router starting...")
 
+	// Initialize tracking maps
+	lastConversationMap = make(map[string]time.Time)
+	autoReplyStatusMap = make(map[string]bool)
+
 	// Load configuration from environment or config file
 	loadConfig()
 
@@ -201,9 +208,21 @@ func processMessage(data interface{}) {
 
 	msg := msgData.Message[0]
 
+	// Get sender identifier (prefer ChatID, fallback to Author)
+	senderID := msg.ChatID
+	if senderID == "" {
+		senderID = msg.Author
+	}
+
+	// Update last conversation time for this sender
+	currentTime := time.Now()
+	lastConversationMap[senderID] = currentTime
+	
 	// Skip messages sent by you (sender == 1)
 	if msg.Sender == 1 {
 		log.Printf("Skipping own message")
+		// Reset auto-reply status when you send a message (conversation resumed)
+		autoReplyStatusMap[senderID] = false
 		return
 	}
 
@@ -231,6 +250,8 @@ func processMessage(data interface{}) {
 				handleRedirect(msg, rule)
 			case "auto_reply":
 				handleAutoReply(msg, rule)
+			case "auto_reply_after_silence":
+				handleAutoReplyAfterSilence(msg, rule, senderID)
 			default:
 				log.Printf("Unknown rule type: %s", rule.Type)
 			}
@@ -272,6 +293,48 @@ func handleAutoReply(msg MessageInfo, rule Rule) {
 	sendMessage(outMsg)
 }
 
+func handleAutoReplyAfterSilence(msg MessageInfo, rule Rule, senderID string) {
+	// Check if auto-reply was already sent during this silence period
+	if autoReplyStatusMap[senderID] {
+		log.Printf("Auto-reply already sent to %s during this silence period", msg.Author)
+		return
+	}
+
+	// Get last conversation time
+	lastTime, exists := lastConversationMap[senderID]
+	if !exists {
+		// First message from this sender, don't auto-reply yet
+		log.Printf("First message from %s, tracking conversation time", msg.Author)
+		return
+	}
+
+	// Calculate time since last conversation
+	timeSinceLastMsg := time.Since(lastTime)
+	requiredSilence := time.Duration(rule.SilenceDurationSecs) * time.Second
+
+	log.Printf("Time since last message from %s: %v (required: %v)", 
+		msg.Author, timeSinceLastMsg, requiredSilence)
+
+	// Check if enough time has passed
+	if timeSinceLastMsg >= requiredSilence {
+		log.Printf("Auto-replying to %s after %v of silence", msg.Author, timeSinceLastMsg)
+
+		outMsg := OutgoingMessage{
+			Address:     msg.ChatID,
+			Text:        rule.ReplyText,
+			Subject:     "",
+			Attachments: []interface{}{},
+		}
+
+		sendMessage(outMsg)
+		
+		// Mark that auto-reply was sent for this silence period
+		autoReplyStatusMap[senderID] = true
+	} else {
+		log.Printf("Not enough silence time for %s, skipping auto-reply", msg.Author)
+	}
+}
+
 func sendMessage(msg OutgoingMessage) {
 	// Use HTTP POST like the web client does
 	protocol := "http"

rules.example.yaml

@@ -11,9 +11,19 @@ rules:
       - "+33755442211"
     enabled: true
 
-  # Example: Auto-reply to a specific sender
+  # Example: Auto-reply to a specific sender (immediate reply)
   - name: "Auto reply example"
     type: auto_reply
     from_sender: "+33233556699"
     reply_text: "I will answer you shortly"
     enabled: true
+
+  # Example: Auto-reply after silence period (e.g., 1 hour)
+  # This will only reply if there hasn't been any conversation with the sender
+  # for the specified duration. The reply is sent only once per silence period.
+  - name: "Auto reply after 1 hour of silence"
+    type: auto_reply_after_silence
+    from_sender: "+33611223344"
+    reply_text: "I will reply you soon"
+    silence_duration_secs: 3600  # 1 hour = 3600 seconds (1h), 7200 = 2h, 1800 = 30mins
+    enabled: true