ToDashboardView function added

Author: PythonHacker24

internal/session/manager.go

@@ -69,9 +69,12 @@ func (m *Manager) CreateSession(username, ipAddress, userAgent string) error {
 
 /* for expiring a session */
 func (m *Manager) ExpireSession(username string) {
+	/* thread safety for the manager */
 	m.mutex.Lock()
 	defer m.mutex.Unlock()
 
+	/* TODO: Add expired session to REDIS for persistent logging */
+
 	/* check if user exists in active sessions */
 	session, ok := m.sessionsMap[username]
 	if !ok {
@@ -121,6 +124,10 @@ func (m *Manager) RefreshTimer(username string) error {
 		return fmt.Errorf("Session not found")
 	}
 
+	/* thread safety for the session */
+	session.Mutex.Lock()
+	defer session.Mutex.Unlock()
+
 	/* reset the expiry time and last active time */
 	session.Expiry = time.Now().Add(time.Duration(config.BackendConfig.AppInfo.SessionTimeout) * time.Hour)
 	session.LastActiveAt = time.Now()
@@ -137,3 +144,34 @@ func (m *Manager) RefreshTimer(username string) error {
 
 	return nil
 }
+
+/* convert session information into frontend safe structure */
+func (m *Manager) ToDashboardView(username string) (SessionView, error) {
+	/* thread safety for the manager */
+	m.mutex.Lock()
+	defer m.mutex.Unlock()
+
+	/* get session from sessionMap */
+	session, exists := m.sessionsMap[username]
+	if !exists {
+		return SessionView{}, fmt.Errorf("Session not found")
+	}
+
+	/* thread safety for the session */
+	session.Mutex.Lock()
+	defer session.Mutex.Unlock()
+	
+	/* can be directly served as JSON in handler */
+	return SessionView{
+		ID:             session.ID,
+		Username:       session.Username,
+		IP:             session.IP,
+		UserAgent:      session.UserAgent,
+		CreatedAt:      session.CreatedAt,
+		LastActiveAt:   session.LastActiveAt,
+		Expiry:         session.Expiry,
+		CompletedCount: session.CompletedCount,
+		FailedCount:    session.FailedCount,
+		PendingCount:   session.TransactionQueue.Len(),
+	}, nil
+} 

internal/session/model.go

@@ -38,12 +38,27 @@ type Session struct {
 	/* transactions issued by the user */
 	TransactionQueue  *list.List
 
-	/* mutex for thread safety */
-	Mutex             sync.Mutex
-
 	/* 
 		listElem stores it's node address in sessionOrder 
 		this is done to maintain O(1) runtime performance while deleting session
 	*/
 	listElem 		  *list.Element
+
+	/* mutex for thread safety */
+	Mutex             sync.Mutex
+}
+
+/* sessionView is a frontend-safe representation of a session */
+type SessionView struct {
+	CompletedCount  int       `json:"completedCount"`
+	FailedCount     int       `json:"failedCount"`
+	PendingCount    int       `json:"pendingCount"`
+	ID              string    `json:"id"`
+	Username        string    `json:"username"`
+	IP              string    `json:"ip"`
+	UserAgent       string    `json:"userAgent"`
+	Status          string    `json:"status"`
+	CreatedAt       time.Time `json:"createdAt"`
+	LastActiveAt    time.Time `json:"lastActiveAt"`
+	Expiry          time.Time `json:"expiry"`
 }