Skip to content

Commit ed70708

Browse files
Successfulyl implemented Redis session deletion for Expire Key
1 parent b3a9840 commit ed70708

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

internal/session/interact.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ func (m *Manager) CreateSession(username, ipAddress, userAgent string) error {
5454
m.sessionsMap[username] = session
5555

5656
/* store session to Redis */
57-
m.saveSessionRedis(username)
57+
m.saveSessionRedis(session)
5858

5959
return nil
6060
}
@@ -117,6 +117,12 @@ func (m *Manager) ExpireSession(username string) {
117117
/* store session to the archive */
118118
if err == nil { m.archivalPQ.StoreSessionPQ(context.Background(), *archive) }
119119

120+
key := fmt.Sprintf("session:%s", session.ID)
121+
if err := m.redis.Del(context.Background(), key).Err(); err != nil {
122+
/* session deletion from redis failed, leave it in good faith */
123+
/* handle err later */
124+
}
125+
120126
/* remove session from sessionsMap */
121127
delete(m.sessionsMap, username)
122128
}

0 commit comments

Comments
 (0)