fix: make conversation last seen timestamp and unread counts per agent, right now its global.

abhinavxd · abhinavxd · commit 59dd3dcda7d0 · 2025-12-13T01:22:59.000+05:30
adds new table `conversation_last_seen`
Migrations for v0.8.5

Remove col `assignee_last_seen_at` from schema
diff --git a/cmd/conversation.go b/cmd/conversation.go
@@ -56,6 +56,7 @@ type createConversationRequest struct {
 func handleGetAllConversations(r *fastglue.Request) error {
 	var (
 		app         = r.Context.(*App)
+		user        = r.RequestCtx.UserValue("user").(amodels.User)
 		order       = string(r.RequestCtx.QueryArgs().Peek("order"))
 		orderBy     = string(r.RequestCtx.QueryArgs().Peek("order_by"))
 		page, _     = strconv.Atoi(string(r.RequestCtx.QueryArgs().Peek("page")))
@@ -64,7 +65,7 @@ func handleGetAllConversations(r *fastglue.Request) error {
 		total       = 0
 	)
 
-	conversations, err := app.conversation.GetAllConversationsList(order, orderBy, filters, page, pageSize)
+	conversations, err := app.conversation.GetAllConversationsList(user.ID, order, orderBy, filters, page, pageSize)
 	if err != nil {
 		return sendErrorEnvelope(r, err)
 	}
@@ -94,7 +95,7 @@ func handleGetAssignedConversations(r *fastglue.Request) error {
 		pageSize, _ = strconv.Atoi(string(r.RequestCtx.QueryArgs().Peek("page_size")))
 		total       = 0
 	)
-	conversations, err := app.conversation.GetAssignedConversationsList(user.ID, order, orderBy, filters, page, pageSize)
+	conversations, err := app.conversation.GetAssignedConversationsList(user.ID, user.ID, order, orderBy, filters, page, pageSize)
 	if err != nil {
 		return sendErrorEnvelope(r, err)
 	}
@@ -115,6 +116,7 @@ func handleGetAssignedConversations(r *fastglue.Request) error {
 func handleGetUnassignedConversations(r *fastglue.Request) error {
 	var (
 		app         = r.Context.(*App)
+		user        = r.RequestCtx.UserValue("user").(amodels.User)
 		order       = string(r.RequestCtx.QueryArgs().Peek("order"))
 		orderBy     = string(r.RequestCtx.QueryArgs().Peek("order_by"))
 		filters     = string(r.RequestCtx.QueryArgs().Peek("filters"))
@@ -123,7 +125,7 @@ func handleGetUnassignedConversations(r *fastglue.Request) error {
 		total       = 0
 	)
 
-	conversations, err := app.conversation.GetUnassignedConversationsList(order, orderBy, filters, page, pageSize)
+	conversations, err := app.conversation.GetUnassignedConversationsList(user.ID, order, orderBy, filters, page, pageSize)
 	if err != nil {
 		return sendErrorEnvelope(r, err)
 	}
@@ -194,7 +196,7 @@ func handleGetViewConversations(r *fastglue.Request) error {
 		return r.SendErrorEnvelope(fasthttp.StatusForbidden, app.i18n.Ts("globals.messages.denied", "name", "{globals.terms.permission}"), nil, envelope.PermissionError)
 	}
 
-	conversations, err := app.conversation.GetViewConversationsList(user.ID, user.Teams.IDs(), lists, order, orderBy, string(view.Filters), page, pageSize)
+	conversations, err := app.conversation.GetViewConversationsList(user.ID, user.ID, user.Teams.IDs(), lists, order, orderBy, string(view.Filters), page, pageSize)
 	if err != nil {
 		return sendErrorEnvelope(r, err)
 	}
@@ -239,7 +241,7 @@ func handleGetTeamUnassignedConversations(r *fastglue.Request) error {
 		return sendErrorEnvelope(r, envelope.NewError(envelope.PermissionError, app.i18n.T("conversation.notMemberOfTeam"), nil))
 	}
 
-	conversations, err := app.conversation.GetTeamUnassignedConversationsList(teamID, order, orderBy, filters, page, pageSize)
+	conversations, err := app.conversation.GetTeamUnassignedConversationsList(auser.ID, teamID, order, orderBy, filters, page, pageSize)
 	if err != nil {
 		return sendErrorEnvelope(r, err)
 	}
@@ -279,7 +281,7 @@ func handleGetConversation(r *fastglue.Request) error {
 	return r.SendEnvelope(conv)
 }
 
-// handleUpdateConversationAssigneeLastSeen updates the assignee's last seen timestamp for a conversation.
+// handleUpdateConversationAssigneeLastSeen updates the current user's last seen timestamp for a conversation.
 func handleUpdateConversationAssigneeLastSeen(r *fastglue.Request) error {
 	var (
 		app   = r.Context.(*App)
@@ -294,7 +296,8 @@ func handleUpdateConversationAssigneeLastSeen(r *fastglue.Request) error {
 	if err != nil {
 		return sendErrorEnvelope(r, err)
 	}
-	if err = app.conversation.UpdateConversationAssigneeLastSeen(uuid); err != nil {
+
+	if err = app.conversation.UpdateUserLastSeen(uuid, auser.ID); err != nil {
 		return sendErrorEnvelope(r, err)
 	}
 	return r.SendEnvelope(true)
diff --git a/cmd/upgrade.go b/cmd/upgrade.go
@@ -36,6 +36,7 @@ var migList = []migFunc{
 	{"v0.6.0", migrations.V0_6_0},
 	{"v0.7.0", migrations.V0_7_0},
 	{"v0.7.4", migrations.V0_7_4},
+	{"v0.8.5", migrations.V0_8_5},
 }
 
 // upgrade upgrades the database to the current version by running SQL migration files
diff --git a/internal/conversation/conversation.go b/internal/conversation/conversation.go
@@ -206,7 +206,7 @@ type queries struct {
 	UpdateConversationFirstReplyAt     *sqlx.Stmt `query:"update-conversation-first-reply-at"`
 	UpdateConversationLastReplyAt      *sqlx.Stmt `query:"update-conversation-last-reply-at"`
 	UpdateConversationWaitingSince     *sqlx.Stmt `query:"update-conversation-waiting-since"`
-	UpdateConversationAssigneeLastSeen *sqlx.Stmt `query:"update-conversation-assignee-last-seen"`
+	UpsertUserLastSeen                 *sqlx.Stmt `query:"upsert-user-last-seen"`
 	UpdateConversationAssignedUser     *sqlx.Stmt `query:"update-conversation-assigned-user"`
 	UpdateConversationAssignedTeam     *sqlx.Stmt `query:"update-conversation-assigned-team"`
 	UpdateConversationCustomAttributes *sqlx.Stmt `query:"update-conversation-custom-attributes"`
@@ -300,15 +300,12 @@ func (c *Manager) GetConversationsCreatedAfter(time time.Time) ([]models.Convers
 	return conversations, nil
 }
 
-// UpdateConversationAssigneeLastSeen updates the last seen timestamp of assignee.
-func (c *Manager) UpdateConversationAssigneeLastSeen(uuid string) error {
-	if _, err := c.q.UpdateConversationAssigneeLastSeen.Exec(uuid); err != nil {
-		c.lo.Error("error updating conversation", "error", err)
+// UpdateUserLastSeen updates the last seen timestamp for a specific user on a conversation.
+func (c *Manager) UpdateUserLastSeen(uuid string, userID int) error {
+	if _, err := c.q.UpsertUserLastSeen.Exec(userID, uuid); err != nil {
+		c.lo.Error("error upserting user last seen", "user_id", userID, "conversation_uuid", uuid, "error", err)
 		return envelope.NewError(envelope.GeneralError, c.i18n.Ts("globals.messages.errorUpdating", "name", "{globals.terms.conversation}"), nil)
 	}
-
-	// Broadcast the property update to all subscribers.
-	c.BroadcastConversationUpdate(uuid, "assignee_last_seen_at", time.Now().Format(time.RFC3339))
 	return nil
 }
 
@@ -348,35 +345,36 @@ func (c *Manager) GetConversationUUID(id int) (string, error) {
 }
 
 // GetAllConversationsList retrieves all conversations with optional filtering, ordering, and pagination.
-func (c *Manager) GetAllConversationsList(order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
-	return c.GetConversations(0, []int{}, []string{models.AllConversations}, order, orderBy, filters, page, pageSize)
+func (c *Manager) GetAllConversationsList(viewingUserID int, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
+	return c.GetConversations(viewingUserID, 0, []int{}, []string{models.AllConversations}, order, orderBy, filters, page, pageSize)
 }
 
 // GetAssignedConversationsList retrieves conversations assigned to a specific user with optional filtering, ordering, and pagination.
-func (c *Manager) GetAssignedConversationsList(userID int, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
-	return c.GetConversations(userID, []int{}, []string{models.AssignedConversations}, order, orderBy, filters, page, pageSize)
+func (c *Manager) GetAssignedConversationsList(viewingUserID, userID int, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
+	return c.GetConversations(viewingUserID, userID, []int{}, []string{models.AssignedConversations}, order, orderBy, filters, page, pageSize)
 }
 
 // GetUnassignedConversationsList retrieves conversations assigned to a team the user is part of with optional filtering, ordering, and pagination.
-func (c *Manager) GetUnassignedConversationsList(order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
-	return c.GetConversations(0, []int{}, []string{models.UnassignedConversations}, order, orderBy, filters, page, pageSize)
+func (c *Manager) GetUnassignedConversationsList(viewingUserID int, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
+	return c.GetConversations(viewingUserID, 0, []int{}, []string{models.UnassignedConversations}, order, orderBy, filters, page, pageSize)
 }
 
 // GetTeamUnassignedConversationsList retrieves conversations assigned to a team with optional filtering, ordering, and pagination.
-func (c *Manager) GetTeamUnassignedConversationsList(teamID int, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
-	return c.GetConversations(0, []int{teamID}, []string{models.TeamUnassignedConversations}, order, orderBy, filters, page, pageSize)
+func (c *Manager) GetTeamUnassignedConversationsList(viewingUserID, teamID int, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
+	return c.GetConversations(viewingUserID, 0, []int{teamID}, []string{models.TeamUnassignedConversations}, order, orderBy, filters, page, pageSize)
 }
 
-func (c *Manager) GetViewConversationsList(userID int, teamIDs []int, listType []string, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
-	return c.GetConversations(userID, teamIDs, listType, order, orderBy, filters, page, pageSize)
+func (c *Manager) GetViewConversationsList(viewingUserID, userID int, teamIDs []int, listType []string, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
+	return c.GetConversations(viewingUserID, userID, teamIDs, listType, order, orderBy, filters, page, pageSize)
 }
 
 // GetConversations retrieves conversations list based on user ID, type, and optional filtering, ordering, and pagination.
-func (c *Manager) GetConversations(userID int, teamIDs []int, listTypes []string, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
+// viewingUserID is used to calculate per-agent unread counts.
+func (c *Manager) GetConversations(viewingUserID, userID int, teamIDs []int, listTypes []string, order, orderBy, filters string, page, pageSize int) ([]models.ConversationListItem, error) {
 	var conversations = make([]models.ConversationListItem, 0)
 
 	// Make the query.
-	query, qArgs, err := c.makeConversationsListQuery(userID, teamIDs, listTypes, c.q.GetConversations, order, orderBy, page, pageSize, filters)
+	query, qArgs, err := c.makeConversationsListQuery(viewingUserID, userID, teamIDs, listTypes, c.q.GetConversations, order, orderBy, page, pageSize, filters)
 	if err != nil {
 		c.lo.Error("error making conversations query", "error", err)
 		return conversations, envelope.NewError(envelope.GeneralError, c.i18n.Ts("globals.messages.errorFetching", "name", "{globals.terms.conversation}"), nil)
@@ -1068,8 +1066,9 @@ func (c *Manager) getConversationTags(uuid string) ([]string, error) {
 }
 
 // makeConversationsListQuery prepares a SQL query string for conversations list
-func (c *Manager) makeConversationsListQuery(userID int, teamIDs []int, listTypes []string, baseQuery, order, orderBy string, page, pageSize int, filtersJSON string) (string, []interface{}, error) {
-	var qArgs []interface{}
+// viewingUserID is used as $1 for per-agent unread count calculation
+func (c *Manager) makeConversationsListQuery(viewingUserID, userID int, teamIDs []int, listTypes []string, baseQuery, order, orderBy string, page, pageSize int, filtersJSON string) (string, []interface{}, error) {
+	qArgs := []any{viewingUserID}
 
 	// Set defaults
 	if orderBy == "" {
diff --git a/internal/conversation/models/models.go b/internal/conversation/models/models.go
@@ -60,7 +60,6 @@ type ConversationListItem struct {
 	UpdatedAt          time.Time               `db:"updated_at" json:"updated_at"`
 	UUID               string                  `db:"uuid" json:"uuid"`
 	WaitingSince       null.Time               `db:"waiting_since" json:"waiting_since"`
-	AssigneeLastSeenAt null.Time               `db:"assignee_last_seen_at" json:"assignee_last_seen_at"`
 	Contact            ConversationListContact `db:"contact" json:"contact"`
 	InboxChannel       string                  `db:"inbox_channel" json:"inbox_channel"`
 	InboxName          string                  `db:"inbox_name" json:"inbox_name"`
@@ -111,7 +110,6 @@ type Conversation struct {
 	LastReplyAt           null.Time              `db:"last_reply_at" json:"last_reply_at"`
 	AssignedUserID        null.Int               `db:"assigned_user_id" json:"assigned_user_id"`
 	AssignedTeamID        null.Int               `db:"assigned_team_id" json:"assigned_team_id"`
-	AssigneeLastSeenAt    null.Time              `db:"assignee_last_seen_at" json:"assignee_last_seen_at"`
 	WaitingSince          null.Time              `db:"waiting_since" json:"waiting_since"`
 	Subject               null.String            `db:"subject" json:"subject"`
 	InboxMail             string                 `db:"inbox_mail" json:"inbox_mail"`
diff --git a/internal/conversation/queries.sql b/internal/conversation/queries.sql
@@ -29,19 +29,19 @@ VALUES(
 RETURNING id, uuid;
 
 -- name: get-conversations
+-- $1 = viewing user ID for per-agent unread count
 SELECT
     COUNT(*) OVER() as total,
     conversations.id,
     conversations.created_at,
     conversations.updated_at,
     conversations.uuid,
     conversations.waiting_since,
-    conversations.assignee_last_seen_at,
     users.created_at as "contact.created_at",
     users.updated_at as "contact.updated_at",
     users.first_name as "contact.first_name",
     users.last_name as "contact.last_name",
-    users.avatar_url as "contact.avatar_url", 
+    users.avatar_url as "contact.avatar_url",
     inboxes.channel as inbox_channel,
     inboxes.name as inbox_name,
     conversations.sla_policy_id,
@@ -57,9 +57,13 @@ SELECT
     (
     SELECT CASE WHEN COUNT(*) > 9 THEN 10 ELSE COUNT(*) END
     FROM (
-        SELECT 1 FROM conversation_messages 
-        WHERE conversation_id = conversations.id 
-        AND created_at > conversations.assignee_last_seen_at
+        SELECT 1 FROM conversation_messages
+        WHERE conversation_id = conversations.id
+        AND created_at > COALESCE(
+            (SELECT last_seen_at FROM conversation_last_seen
+             WHERE conversation_id = conversations.id AND user_id = $1),
+            '1970-01-01'::TIMESTAMPTZ
+        )
         LIMIT 10
     ) t
     ) as unread_message_count,
@@ -99,7 +103,6 @@ SELECT
    c.closed_at,
    c.resolved_at,
    c.inbox_id,
-   c.assignee_last_seen_at,
    inb.name as inbox_name,
    COALESCE(inb.from, '') as inbox_mail,
    COALESCE(inb.channel::TEXT, '') as inbox_channel,
@@ -207,8 +210,6 @@ SELECT uuid from conversations where id = $1;
 -- name: update-conversation-assigned-user
 UPDATE conversations
 SET assigned_user_id = $2,
--- Reset assignee_last_seen_at when assigned to a new user.
-assignee_last_seen_at = NULL,
 updated_at = NOW()
 WHERE uuid = $1;
 
@@ -236,11 +237,11 @@ SET priority_id = (SELECT id FROM conversation_priorities WHERE name = $2),
     updated_at = NOW()
 WHERE uuid = $1;
 
--- name: update-conversation-assignee-last-seen
-UPDATE conversations 
-SET assignee_last_seen_at = NOW(),
-    updated_at = NOW()
-WHERE uuid = $1;
+-- name: upsert-user-last-seen
+INSERT INTO conversation_last_seen (user_id, conversation_id, last_seen_at)
+VALUES ($1, (SELECT id FROM conversations WHERE uuid = $2), NOW())
+ON CONFLICT (conversation_id, user_id)
+DO UPDATE SET last_seen_at = NOW(), updated_at = NOW();
 
 -- name: update-conversation-last-message
 UPDATE conversations SET last_message = $3, last_message_sender = $4, last_message_at = $5, updated_at = NOW() WHERE CASE 
@@ -351,9 +352,8 @@ WHERE uuid = $1;
 
 -- name: remove-conversation-assignee
 UPDATE conversations
-SET 
+SET
     assigned_user_id = CASE WHEN $2 = 'user' THEN NULL ELSE assigned_user_id END,
-    assignee_last_seen_at = CASE WHEN $2 = 'user' THEN NULL ELSE assignee_last_seen_at END,
     assigned_team_id = CASE WHEN $2 = 'team' THEN NULL ELSE assigned_team_id END,
     updated_at = NOW()
 WHERE uuid = $1;
diff --git a/internal/migrations/v0.8.5.go b/internal/migrations/v0.8.5.go
@@ -0,0 +1,23 @@
+package migrations
+
+import (
+	"github.com/jmoiron/sqlx"
+	"github.com/knadh/koanf/v2"
+	"github.com/knadh/stuffbin"
+)
+
+func V0_8_5(db *sqlx.DB, fs stuffbin.FileSystem, ko *koanf.Koanf) error {
+	_, err := db.Exec(`
+		CREATE TABLE IF NOT EXISTS conversation_last_seen (
+			id BIGSERIAL PRIMARY KEY,
+			created_at TIMESTAMPTZ DEFAULT NOW(),
+			updated_at TIMESTAMPTZ DEFAULT NOW(),
+			user_id BIGINT REFERENCES users(id) ON DELETE CASCADE ON UPDATE CASCADE NOT NULL,
+			conversation_id BIGINT REFERENCES conversations(id) ON DELETE CASCADE ON UPDATE CASCADE NOT NULL,
+			last_seen_at TIMESTAMPTZ DEFAULT NOW() NOT NULL
+		);
+		CREATE UNIQUE INDEX IF NOT EXISTS index_unique_conversation_last_seen
+			ON conversation_last_seen (conversation_id, user_id);
+	`)
+	return err
+}
diff --git a/schema.sql b/schema.sql
@@ -229,7 +229,6 @@ CREATE TABLE conversations (
 
 	meta JSONB DEFAULT '{}'::jsonb NOT NULL,
 	custom_attributes JSONB DEFAULT '{}'::jsonb NOT NULL,
-    assignee_last_seen_at TIMESTAMPTZ DEFAULT NOW(),
     first_reply_at TIMESTAMPTZ NULL,
     last_reply_at TIMESTAMPTZ NULL,
     closed_at TIMESTAMPTZ NULL,
@@ -327,6 +326,17 @@ CREATE TABLE conversation_participants (
 );
 CREATE UNIQUE INDEX index_unique_conversation_participants_on_conversation_id_and_user_id ON conversation_participants (conversation_id, user_id);
 
+DROP TABLE IF EXISTS conversation_last_seen CASCADE;
+CREATE TABLE conversation_last_seen (
+	id BIGSERIAL PRIMARY KEY,
+	created_at TIMESTAMPTZ DEFAULT NOW(),
+	updated_at TIMESTAMPTZ DEFAULT NOW(),
+	user_id BIGINT REFERENCES users(id) ON DELETE CASCADE ON UPDATE CASCADE NOT NULL,
+	conversation_id BIGINT REFERENCES conversations(id) ON DELETE CASCADE ON UPDATE CASCADE NOT NULL,
+	last_seen_at TIMESTAMPTZ DEFAULT NOW() NOT NULL
+);
+CREATE UNIQUE INDEX index_unique_conversation_last_seen ON conversation_last_seen (conversation_id, user_id);
+
 DROP TABLE IF EXISTS media CASCADE;
 CREATE TABLE media (
 	id SERIAL PRIMARY KEY,

Original file line number	Diff line number	Diff line change
`@@ -56,6 +56,7 @@ type createConversationRequest struct {`
`56`	`56`	`func handleGetAllConversations(r *fastglue.Request) error {`
`57`	`57`	`var (`
`58`	`58`	`app = r.Context.(*App)`
	`59`	`+ user = r.RequestCtx.UserValue("user").(amodels.User)`
`59`	`60`	`order = string(r.RequestCtx.QueryArgs().Peek("order"))`
`60`	`61`	`orderBy = string(r.RequestCtx.QueryArgs().Peek("order_by"))`
`61`	`62`	`page, _ = strconv.Atoi(string(r.RequestCtx.QueryArgs().Peek("page")))`
`@@ -64,7 +65,7 @@ func handleGetAllConversations(r *fastglue.Request) error {`
`64`	`65`	`total = 0`
`65`	`66`	`)`
`66`	`67`
`67`		`- conversations, err := app.conversation.GetAllConversationsList(order, orderBy, filters, page, pageSize)`
	`68`	`+ conversations, err := app.conversation.GetAllConversationsList(user.ID, order, orderBy, filters, page, pageSize)`
`68`	`69`	`if err != nil {`
`69`	`70`	`return sendErrorEnvelope(r, err)`
`70`	`71`	`}`
`@@ -94,7 +95,7 @@ func handleGetAssignedConversations(r *fastglue.Request) error {`
`94`	`95`	`pageSize, _ = strconv.Atoi(string(r.RequestCtx.QueryArgs().Peek("page_size")))`
`95`	`96`	`total = 0`
`96`	`97`	`)`
`97`		`- conversations, err := app.conversation.GetAssignedConversationsList(user.ID, order, orderBy, filters, page, pageSize)`
	`98`	`+ conversations, err := app.conversation.GetAssignedConversationsList(user.ID, user.ID, order, orderBy, filters, page, pageSize)`
`98`	`99`	`if err != nil {`
`99`	`100`	`return sendErrorEnvelope(r, err)`
`100`	`101`	`}`
`@@ -115,6 +116,7 @@ func handleGetAssignedConversations(r *fastglue.Request) error {`
`115`	`116`	`func handleGetUnassignedConversations(r *fastglue.Request) error {`
`116`	`117`	`var (`
`117`	`118`	`app = r.Context.(*App)`
	`119`	`+ user = r.RequestCtx.UserValue("user").(amodels.User)`
`118`	`120`	`order = string(r.RequestCtx.QueryArgs().Peek("order"))`
`119`	`121`	`orderBy = string(r.RequestCtx.QueryArgs().Peek("order_by"))`
`120`	`122`	`filters = string(r.RequestCtx.QueryArgs().Peek("filters"))`
`@@ -123,7 +125,7 @@ func handleGetUnassignedConversations(r *fastglue.Request) error {`
`123`	`125`	`total = 0`
`124`	`126`	`)`
`125`	`127`
`126`		`- conversations, err := app.conversation.GetUnassignedConversationsList(order, orderBy, filters, page, pageSize)`
	`128`	`+ conversations, err := app.conversation.GetUnassignedConversationsList(user.ID, order, orderBy, filters, page, pageSize)`
`127`	`129`	`if err != nil {`
`128`	`130`	`return sendErrorEnvelope(r, err)`
`129`	`131`	`}`
`@@ -194,7 +196,7 @@ func handleGetViewConversations(r *fastglue.Request) error {`
`194`	`196`	`return r.SendErrorEnvelope(fasthttp.StatusForbidden, app.i18n.Ts("globals.messages.denied", "name", "{globals.terms.permission}"), nil, envelope.PermissionError)`
`195`	`197`	`}`
`196`	`198`
`197`		`- conversations, err := app.conversation.GetViewConversationsList(user.ID, user.Teams.IDs(), lists, order, orderBy, string(view.Filters), page, pageSize)`
	`199`	`+ conversations, err := app.conversation.GetViewConversationsList(user.ID, user.ID, user.Teams.IDs(), lists, order, orderBy, string(view.Filters), page, pageSize)`
`198`	`200`	`if err != nil {`
`199`	`201`	`return sendErrorEnvelope(r, err)`
`200`	`202`	`}`
`@@ -239,7 +241,7 @@ func handleGetTeamUnassignedConversations(r *fastglue.Request) error {`
`239`	`241`	`return sendErrorEnvelope(r, envelope.NewError(envelope.PermissionError, app.i18n.T("conversation.notMemberOfTeam"), nil))`
`240`	`242`	`}`
`241`	`243`
`242`		`- conversations, err := app.conversation.GetTeamUnassignedConversationsList(teamID, order, orderBy, filters, page, pageSize)`
	`244`	`+ conversations, err := app.conversation.GetTeamUnassignedConversationsList(auser.ID, teamID, order, orderBy, filters, page, pageSize)`
`243`	`245`	`if err != nil {`
`244`	`246`	`return sendErrorEnvelope(r, err)`
`245`	`247`	`}`
`@@ -279,7 +281,7 @@ func handleGetConversation(r *fastglue.Request) error {`
`279`	`281`	`return r.SendEnvelope(conv)`
`280`	`282`	`}`
`281`	`283`
`282`		`-// handleUpdateConversationAssigneeLastSeen updates the assignee's last seen timestamp for a conversation.`
	`284`	`+// handleUpdateConversationAssigneeLastSeen updates the current user's last seen timestamp for a conversation.`
`283`	`285`	`func handleUpdateConversationAssigneeLastSeen(r *fastglue.Request) error {`
`284`	`286`	`var (`
`285`	`287`	`app = r.Context.(*App)`
`@@ -294,7 +296,8 @@ func handleUpdateConversationAssigneeLastSeen(r *fastglue.Request) error {`
`294`	`296`	`if err != nil {`
`295`	`297`	`return sendErrorEnvelope(r, err)`
`296`	`298`	`}`
`297`		`- if err = app.conversation.UpdateConversationAssigneeLastSeen(uuid); err != nil {`
	`299`	`+`
	`300`	`+ if err = app.conversation.UpdateUserLastSeen(uuid, auser.ID); err != nil {`
`298`	`301`	`return sendErrorEnvelope(r, err)`
`299`	`302`	`}`
`300`	`303`	`return r.SendEnvelope(true)`
Original file line number	Diff line number	Diff line change
`@@ -36,6 +36,7 @@ var migList = []migFunc{`
`36`	`36`	`{"v0.6.0", migrations.V0_6_0},`
`37`	`37`	`{"v0.7.0", migrations.V0_7_0},`
`38`	`38`	`{"v0.7.4", migrations.V0_7_4},`
	`39`	`+ {"v0.8.5", migrations.V0_8_5},`
`39`	`40`	`}`
`40`	`41`
`41`	`42`	`// upgrade upgrades the database to the current version by running SQL migration files`