feat: Toggle button for user to reassign replies to conversations if they are away, user status now actually affects the conversation workflow.

Online: Conversations are auto-assigned.
Auto-away (inactivity in browser): Marks agent as away without stopping assignment (nothing changes for agent).
Manual away: Prevents new conversations from being assigned. (option available in the sidebar)
Reassign replies: Customer replies unassigns the conversation, returning it to the team inbox / unassigned inbox.

Author: abhinavxd

cmd/handlers.go

@@ -98,6 +98,7 @@ func initHandlers(g *fastglue.Fastglue, hub *ws.Hub) {
 	g.PUT("/api/v1/users/me", auth(handleUpdateCurrentUser))
 	g.GET("/api/v1/users/me/teams", auth(handleGetCurrentUserTeams))
 	g.PUT("/api/v1/users/me/availability", auth(handleUpdateUserAvailability))
+	g.PUT("/api/v1/users/me/reassign-replies/toggle", auth(handleToggleReassignReplies))
 	g.DELETE("/api/v1/users/me/avatar", auth(handleDeleteAvatar))
 	g.GET("/api/v1/users/compact", auth(handleGetUsersCompact))
 	g.GET("/api/v1/users", perm(handleGetUsers, "users:manage"))

cmd/middlewares.go

@@ -11,8 +11,8 @@ import (
 	"github.com/zerodha/simplesessions/v3"
 )
 
-// tryAuth is a middleware that attempts to authenticate the user and add them to the context
-// but doesn't enforce authentication. Handlers can check if user exists in context optionally.
+// tryAuth attempts to authenticate the user and add them to the context but doesn't enforce authentication.
+// Handlers can check if user exists in context optionally.
 func tryAuth(handler fastglue.FastRequestHandler) fastglue.FastRequestHandler {
 	return func(r *fastglue.Request) error {
 		app := r.Context.(*App)
@@ -41,7 +41,7 @@ func tryAuth(handler fastglue.FastRequestHandler) fastglue.FastRequestHandler {
 	}
 }
 
-// auth makes sure the user is logged in.
+// auth validates the session and adds the user to the request context.
 func auth(handler fastglue.FastRequestHandler) fastglue.FastRequestHandler {
 	return func(r *fastglue.Request) error {
 		var app = r.Context.(*App)
@@ -69,7 +69,8 @@ func auth(handler fastglue.FastRequestHandler) fastglue.FastRequestHandler {
 	}
 }
 
-// perm does session validation, CSRF, and permission enforcement.
+// perm matches the CSRF token and checks if the user has the required permission to access the endpoint.
+// and sets the user in the request context.
 func perm(handler fastglue.FastRequestHandler, perm string) fastglue.FastRequestHandler {
 	return func(r *fastglue.Request) error {
 		var (

cmd/upgrade.go

@@ -33,6 +33,7 @@ var migList = []migFunc{
 	{"v0.3.0", migrations.V0_3_0},
 	{"v0.4.0", migrations.V0_4_0},
 	{"v0.5.0", migrations.V0_5_0},
+	{"v0.6.0", migrations.V0_6_0},
 }
 
 // upgrade upgrades the database to the current version by running SQL migration files

cmd/users.go

@@ -76,6 +76,19 @@ func handleUpdateUserAvailability(r *fastglue.Request) error {
 	return r.SendEnvelope(true)
 }
 
+// handleToggleReassignReplies toggles the reassign replies setting for the current user.
+func handleToggleReassignReplies(r *fastglue.Request) error {
+	var (
+		app     = r.Context.(*App)
+		auser   = r.RequestCtx.UserValue("user").(amodels.User)
+		enabled = r.RequestCtx.PostArgs().GetBool("enabled")
+	)
+	if err := app.user.ToggleReassignReplies(auser.ID, enabled); err != nil {
+		return sendErrorEnvelope(r, err)
+	}
+	return r.SendEnvelope(true)
+}
+
 // handleGetCurrentUserTeams returns the teams of a user.
 func handleGetCurrentUserTeams(r *fastglue.Request) error {
 	var (

frontend/src/api/index.js

@@ -276,6 +276,7 @@ const deleteView = (id) => http.delete(`/api/v1/views/me/${id}`)
 const getAiPrompts = () => http.get('/api/v1/ai/prompts')
 const aiCompletion = (data) => http.post('/api/v1/ai/completion', data)
 const updateAIProvider = (data) => http.put('/api/v1/ai/provider', data)
+const toggleReassignReplies = (data) => http.put('/api/v1/users/me/reassign-replies/toggle', data)
 
 export default {
   login,
@@ -390,4 +391,5 @@ export default {
   searchMessages,
   searchContacts,
   removeAssignee,
+  toggleReassignReplies,
 }

frontend/src/components/sidebar/SidebarNavUser.vue

@@ -46,17 +46,27 @@
             <span class="truncate text-xs">{{ userStore.email }}</span>
           </div>
         </div>
-        <div class="flex items-center gap-2 px-1 py-1.5 text-left text-sm justify-between">
-          <span class="text-muted-foreground">
-            {{ t('navigation.away') }}
-          </span>
-          <Switch
-            :checked="
-              userStore.user.availability_status === 'away' ||
-              userStore.user.availability_status === 'away_manual'
-            "
-            @update:checked="(val) => userStore.updateUserAvailability(val ? 'away' : 'online')"
-          />
+        <div class="space-y-2">
+          <template
+            v-for="(item, index) in [
+              {
+                label: t('navigation.away'),
+                checked: userStore.user.availability_status === 'away_manual',
+                action: (val) => userStore.updateUserAvailability(val ? 'away' : 'online')
+              },
+              {
+                label: t('navigation.reassign_replies'),
+                checked: userStore.user.reassign_replies,
+                action: (val) => userStore.toggleAssignReplies(val)
+              }
+            ]"
+            :key="index"
+          >
+            <div class="flex items-center gap-2 px-1 text-left text-sm justify-between">
+              <span class="text-muted-foreground">{{ item.label }}</span>
+              <Switch :checked="item.checked" @update:checked="item.action" />
+            </div>
+          </template>
         </div>
       </DropdownMenuLabel>
       <DropdownMenuSeparator />

frontend/src/stores/user.js

@@ -17,7 +17,8 @@ export const useUserStore = defineStore('user', () => {
     email: '',
     teams: [],
     permissions: [],
-    availability_status: 'offline'
+    availability_status: 'offline',
+    reassign_replies: false
   })
   const emitter = useEmitter()
 
@@ -105,6 +106,22 @@ export const useUserStore = defineStore('user', () => {
     }
   }
 
+  const toggleAssignReplies = async (enabled) => {
+    const prev = user.value.reassign_replies
+    user.value.reassign_replies = enabled
+    try {
+      await api.toggleReassignReplies({
+        enabled: enabled
+      })
+    } catch (error) {
+      user.value.reassign_replies = prev
+      emitter.emit(EMITTER_EVENTS.SHOW_TOAST, {
+        variant: 'destructive',
+        description: handleHTTPError(error).message
+      })
+    }
+  }
+
   return {
     user,
     userID,
@@ -123,6 +140,7 @@ export const useUserStore = defineStore('user', () => {
     clearAvatar,
     setAvatar,
     updateUserAvailability,
+    toggleAssignReplies,
     can
   }
 })

i18n/en.json

@@ -236,6 +236,7 @@
   "navigation.views": "Views",
   "navigation.edit": "Edit",
   "navigation.delete": "Delete",
+  "navigation.reassign_replies": "Reassign replies",
   "form.field.name": "Name",
   "form.field.inbox": "Inbox",
   "form.field.provider": "Provider",

i18n/mr.json

@@ -236,6 +236,7 @@
     "navigation.views": "दृश्ये",
     "navigation.edit": "संपादित करा",
     "navigation.delete": "हटवा",
+    "navigation.reassign_replies": "प्रतिसाद पुन्हा नियुक्त करा",
     "form.field.name": "नाव",
     "form.field.inbox": "इनबॉक्स",
     "form.field.provider": "प्रदाता",

internal/autoassigner/autoassigner.go

@@ -64,16 +64,12 @@ func New(teamStore teamStore, conversationStore conversationStore, systemUser um
 		teamMaxAutoAssignments: make(map[int]int),
 		roundRobinBalancer:     make(map[int]*balance.Balance),
 	}
-	if err := e.populateTeamBalancer(); err != nil {
-		return nil, err
-	}
 	return &e, nil
 }
 
 // Run initiates the conversation assignment process and is to be invoked as a goroutine.
 // This function continuously assigns unassigned conversations to agents at regular intervals.
 func (e *Engine) Run(ctx context.Context, autoAssignInterval time.Duration) {
-	time.Sleep(2 * time.Second)
 	ticker := time.NewTicker(autoAssignInterval)
 	defer ticker.Stop()
 
@@ -159,8 +155,14 @@ func (e *Engine) populateTeamBalancer() error {
 
 		balancer := e.roundRobinBalancer[team.ID]
 		existingUsers := make(map[string]struct{})
-
 		for _, user := range users {
+			// Skip user if availability status is `away_manual`
+			if user.AvailabilityStatus == umodels.AwayManual {
+				e.lo.Debug("skipping user with away_manual status", "user_id", user.ID)
+				continue
+			}
+
+			// Add user to the balancer pool
 			uid := strconv.Itoa(user.ID)
 			existingUsers[uid] = struct{}{}
 			if err := balancer.Add(uid, 1); err != nil {
@@ -227,7 +229,7 @@ func (e *Engine) assignConversations() error {
 
 		teamMaxAutoAssignments := e.teamMaxAutoAssignments[conversation.AssignedTeamID.Int]
 		// Check if user has reached the max auto assigned conversations limit,
-		// If the limit is set to 0, it means there is no limit.
+		// 0 is unlimited.
 		if teamMaxAutoAssignments != 0 {
 			if activeConversationsCount >= teamMaxAutoAssignments {
 				e.lo.Debug("user has reached max auto assigned conversations limit, skipping auto assignment", "user_id", userID,