webapi_session.go 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803
  1. package state
  2. import (
  3. "bytes"
  4. "context"
  5. "crypto/rand"
  6. "encoding/hex"
  7. "errors"
  8. "log/slog"
  9. mrand "math/rand/v2"
  10. "strconv"
  11. "sync"
  12. "time"
  13. "github.com/mk6i/open-oscar-server/server/webapi/types"
  14. "github.com/mk6i/open-oscar-server/wire"
  15. )
  16. var (
  17. // ErrNoWebAPISession is returned when a WebAPI session is not found.
  18. ErrNoWebAPISession = errors.New("WebAPI session not found")
  19. // ErrWebAPISessionExpired is returned when a WebAPI session has expired.
  20. ErrWebAPISessionExpired = errors.New("WebAPI session expired")
  21. // ErrWebAPISessionManagerClosed is returned when a session is requested from
  22. // a manager that has been shut down.
  23. ErrWebAPISessionManagerClosed = errors.New("WebAPI session manager is shut down")
  24. )
  25. // Web API session lifecycle timeline.
  26. //
  27. // A web client keeps its session alive by long-polling GET /aim/fetchEvents.
  28. // Every authenticated request touches the session (middleware.RequireSession
  29. // calls TouchSession at request arrival), sliding expiry to now + the TTL. A
  30. // single poll blocks for up to 60s (the fetchEvents long-poll cap) and the
  31. // client waits ~500ms (TimeToNextFetch) before re-polling, so in steady state a
  32. // healthy client touches the session at worst every ~60-65s once jitter is
  33. // included. That worst-case touch interval is the floor the TTL must clear.
  34. //
  35. // If a client hangs up without calling endSession, its last touch was at its
  36. // last poll: the session then expires webAPISessionTTL later and the reaper
  37. // sweeps it within one webAPISessionReapInterval tick. So a silent client is
  38. // removed (and its OSCAR session closed) within TTL + tick of going quiet.
  39. const (
  40. // webAPISessionTTL bounds how long a session survives without a poll. It is
  41. // sized to absorb one missed poll cycle: ~60s for the normal cycle, ~60s for
  42. // the absorbed miss, plus ~20s of jitter margin. Two consecutive misses mean
  43. // the client is genuinely gone and the session is reaped.
  44. webAPISessionTTL = 150 * time.Second
  45. // webAPISessionReapInterval is how often the cleanup goroutine sweeps for
  46. // expired sessions (~TTL/5). A dead session lingers at most
  47. // webAPISessionTTL + webAPISessionReapInterval before removal.
  48. webAPISessionReapInterval = 30 * time.Second
  49. )
  50. // WebAPISession represents an active Web AIM API session.
  51. type WebAPISession struct {
  52. AimSID string // Unique session ID for web client
  53. ScreenName DisplayScreenName // User identity
  54. OSCARSession *SessionInstance // Bridge to existing OSCAR session
  55. OSCARCookie []byte // OSCAR auth cookie for the startOSCARSession handoff
  56. BOSHost string // BOS host advertised to the web client
  57. BOSPort int // BOS port advertised to the web client
  58. UseSSL bool // Whether the handoff advertised an SSL BOS connection
  59. BaseURL string // Web API base URL advertised to the web client, used to build absolute asset URLs
  60. Events []string // Subscribed event types
  61. EventQueue *types.EventQueue // Per-session event queue
  62. DevID string // Developer ID that created this session
  63. ClientName string // Client application name
  64. ClientVersion string // Client application version
  65. CreatedAt time.Time // SessionInstance creation time
  66. LastAccessed time.Time // Last activity time
  67. ExpiresAt time.Time // SessionInstance expiration time
  68. FetchTimeout int // Long-polling timeout in milliseconds
  69. TimeToNextFetch int // Suggested delay before next fetch
  70. RemoteAddr string // Client IP address
  71. TempBuddies map[string]bool // Temporary buddies for this session only
  72. BuddyListRefresher func(ctx context.Context) (interface{}, error) // Called on feedbag changes to push buddylist event
  73. PermitDenyRefresher func(ctx context.Context) (interface{}, error) // Called on feedbag changes to push permitDeny event
  74. MyInfoRefresher func(ctx context.Context) (interface{}, error) // Called on self user-info updates (e.g. icon change) to push myInfo event
  75. BuddyAliasLoader func(ctx context.Context) (map[string]string, error)
  76. // BuddyIconURL formats the absolute buddyIcon URL for a buddy from the icon
  77. // hash carried in a presence SNAC. Returns "" when no URL can be published.
  78. BuddyIconURL func(screenName IdentScreenName, hash []byte) string
  79. aliases map[string]string // cached BuddyAliasLoader result, nil when unloaded or invalidated
  80. aliasMu sync.Mutex
  81. imLog map[string][]WebAPIStoredIM
  82. imLogMu sync.Mutex
  83. // IMRateClassID is the rate class that sending an IM spends. The web client
  84. // renders any rate limit event as the IM banner, so only this class's updates
  85. // may reach it. Zero disables the alert.
  86. IMRateClassID wire.RateLimitClassID
  87. logger *slog.Logger // Logger for debugging
  88. listeners sync.WaitGroup
  89. ctx context.Context
  90. cancel context.CancelFunc
  91. closeMu sync.Mutex
  92. closed bool
  93. }
  94. // IsExpired checks if the session has expired.
  95. func (s *WebAPISession) IsExpired() bool {
  96. return time.Now().After(s.ExpiresAt)
  97. }
  98. // Aliases returns this session owner's private buddy aliases, keyed by normalized
  99. // screen name. Aliases live in the owner's feedbag, so the map is loaded once and
  100. // cached until a feedbag change invalidates it: a signon that brings a large buddy
  101. // list online costs one feedbag query instead of one per buddy.
  102. //
  103. // The map is owned by the session and must not be mutated by callers.
  104. //
  105. // aliasMu is deliberately held across the load rather than released while the
  106. // feedbag is queried. Another instance of the owner can rename a buddy mid-query,
  107. // and its FeedbagUpdateItem SNAC invalidates this cache; if the load ran outside
  108. // the lock, that query's pre-rename result could be stored *after* the
  109. // invalidation and serve the old alias until the next feedbag change. Holding the
  110. // lock makes the invalidation wait for the load and then win.
  111. func (s *WebAPISession) Aliases(ctx context.Context) map[string]string {
  112. s.aliasMu.Lock()
  113. defer s.aliasMu.Unlock()
  114. // The loader is wired after the session is created, so an event arriving in
  115. // that window has no way to resolve aliases.
  116. if s.BuddyAliasLoader == nil {
  117. return nil
  118. }
  119. if s.aliases == nil {
  120. aliases, err := s.BuddyAliasLoader(ctx)
  121. if err != nil {
  122. s.logger.Error("failed to load buddy aliases", "err", err.Error())
  123. return nil
  124. }
  125. s.aliases = aliases
  126. }
  127. return s.aliases
  128. }
  129. // InvalidateAliases drops the cached alias map so the next Aliases call reloads it.
  130. // Callers that change the owner's feedbag must call this: the feedbag service
  131. // relays FeedbagUpdateItem only to the owner's *other* instances, so a session
  132. // never sees a SNAC for its own writes.
  133. func (s *WebAPISession) InvalidateAliases() {
  134. s.aliasMu.Lock()
  135. defer s.aliasMu.Unlock()
  136. s.aliases = nil
  137. }
  138. // aliasFor returns this session owner's private alias for buddy, or "" when none is
  139. // set. The web client deletes the alias it holds whenever it merges a user map, so
  140. // every event naming a buddy has to repeat it.
  141. func (s *WebAPISession) aliasFor(buddy IdentScreenName) string {
  142. // Runs on the SNAC listener goroutine, which has no request context.
  143. return s.Aliases(s.ctx)[buddy.String()]
  144. }
  145. // Touch updates the last accessed time and extends expiration if needed.
  146. func (s *WebAPISession) Touch() {
  147. s.LastAccessed = time.Now()
  148. newExpiry := s.LastAccessed.Add(webAPISessionTTL)
  149. if newExpiry.After(s.ExpiresAt) {
  150. s.ExpiresAt = newExpiry
  151. }
  152. }
  153. // IsSubscribedTo checks if the session is subscribed to a specific event type.
  154. func (s *WebAPISession) IsSubscribedTo(eventType string) bool {
  155. for _, event := range s.Events {
  156. if event == eventType {
  157. return true
  158. }
  159. }
  160. return false
  161. }
  162. // StartListeningToOSCARSession starts a goroutine that listens to the OSCAR session's
  163. // message channel and converts SNAC messages into WebAPI events.
  164. func (s *WebAPISession) StartListeningToOSCARSession() {
  165. if s.OSCARSession == nil {
  166. return
  167. }
  168. s.closeMu.Lock()
  169. defer s.closeMu.Unlock()
  170. if s.closed {
  171. return
  172. }
  173. s.listeners.Add(1)
  174. go func() {
  175. defer s.listeners.Done()
  176. msgCh := s.OSCARSession.ReceiveMessage()
  177. for {
  178. select {
  179. case msg, ok := <-msgCh:
  180. if !ok {
  181. // Channel closed, OSCAR session ended
  182. return
  183. }
  184. s.handleSNACMessage(msg)
  185. case <-s.OSCARSession.Closed():
  186. // OSCAR session closed
  187. return
  188. }
  189. }
  190. }()
  191. }
  192. // Close tears down the session: it releases any parked event fetchers, closes
  193. // the OSCAR instance, and waits for the listener goroutine to unwind. Safe to
  194. // call more than once.
  195. func (s *WebAPISession) Close() {
  196. s.closeMu.Lock()
  197. if s.closed {
  198. s.closeMu.Unlock()
  199. return
  200. }
  201. s.closed = true
  202. s.closeMu.Unlock()
  203. s.EventQueue.Close()
  204. s.OSCARSession.CloseInstance()
  205. s.cancel()
  206. s.listeners.Wait()
  207. }
  208. // handleSNACMessage converts a SNAC message into WebAPI events and pushes them to the event queue.
  209. func (s *WebAPISession) handleSNACMessage(msg wire.SNACMessage) {
  210. if s.EventQueue == nil {
  211. return
  212. }
  213. // Convert SNAC message to WebAPI events based on food group and subgroup
  214. switch msg.Frame.FoodGroup {
  215. case wire.ICBM:
  216. s.handleICBMMessage(msg)
  217. case wire.Buddy:
  218. s.handleBuddyMessage(msg)
  219. case wire.Feedbag:
  220. s.handleFeedbagMessage(msg)
  221. case wire.OService:
  222. s.handleOServiceMessage(msg)
  223. }
  224. }
  225. // handleOServiceMessage handles OService SNAC messages relayed to the session's
  226. // own OSCAR instance.
  227. func (s *WebAPISession) handleOServiceMessage(msg wire.SNACMessage) {
  228. switch msg.Frame.SubGroup {
  229. case wire.OServiceUserInfoUpdate:
  230. s.handleUserInfoUpdate(msg)
  231. case wire.OServiceRateParamChange:
  232. s.handleRateLimitUpdate(msg)
  233. }
  234. }
  235. // handleUserInfoUpdate surfaces OServiceUserInfoUpdate, which the server relays to
  236. // a user when their own user info changes (notably a buddy icon upload or clear).
  237. // The client re-renders its identity badge from myInfo events only, so we
  238. // translate this into a fresh myInfo.
  239. func (s *WebAPISession) handleUserInfoUpdate(msg wire.SNACMessage) {
  240. if !s.IsSubscribedTo("myInfo") && !s.IsSubscribedTo("presence") {
  241. return
  242. }
  243. if s.MyInfoRefresher == nil {
  244. return
  245. }
  246. data, err := s.MyInfoRefresher(s.ctx)
  247. if err != nil {
  248. s.logger.Error("failed to refresh myInfo after user-info update", "err", err)
  249. return
  250. }
  251. s.EventQueue.Push(types.EventType("myInfo"), data)
  252. }
  253. // handleRateLimitUpdate translates a rate limit status change — broadcast by the
  254. // account's rate limit monitor — into a rateLimit event. Only the IM class is
  255. // surfaced, since the client feeds any rateLimit event into the
  256. // conversation-window alert. Code 1 is a class-params change, not a status
  257. // transition, and is ignored.
  258. func (s *WebAPISession) handleRateLimitUpdate(msg wire.SNACMessage) {
  259. if s.IMRateClassID == 0 {
  260. return
  261. }
  262. body, ok := msg.Body.(wire.SNAC_0x01_0x0A_OServiceRateParamsChange)
  263. if !ok {
  264. return
  265. }
  266. if wire.RateLimitClassID(body.Rate.ID) != s.IMRateClassID {
  267. return
  268. }
  269. var status string
  270. switch body.Code {
  271. case 2:
  272. status = "warn"
  273. case 3:
  274. status = "limit"
  275. case 4:
  276. status = "clear"
  277. default:
  278. return
  279. }
  280. s.EventQueue.Push(types.EventTypeRateLimit, types.RateLimitEvent{
  281. Classes: []types.RateLimitClass{
  282. {ID: int(body.Rate.ID), Status: status},
  283. },
  284. })
  285. }
  286. // handleICBMMessage handles ICBM (instant messaging) SNAC messages.
  287. func (s *WebAPISession) handleICBMMessage(msg wire.SNACMessage) {
  288. switch msg.Frame.SubGroup {
  289. case wire.ICBMChannelMsgToClient:
  290. s.handleIncomingIM(msg)
  291. case wire.ICBMClientEvent:
  292. s.handleTypingNotification(msg)
  293. }
  294. }
  295. // handleIncomingIM handles incoming instant messages.
  296. func (s *WebAPISession) handleIncomingIM(msg wire.SNACMessage) {
  297. if !s.IsSubscribedTo("im") {
  298. return
  299. }
  300. body, ok := msg.Body.(wire.SNAC_0x04_0x07_ICBMChannelMsgToClient)
  301. if !ok {
  302. return
  303. }
  304. // Extract message text from TLV data
  305. var messageText string
  306. if msgData, hasMsg := body.Bytes(wire.ICBMTLVAOLIMData); hasMsg {
  307. if text, err := wire.UnmarshalICBMMessageText(msgData); err == nil {
  308. messageText = text
  309. }
  310. }
  311. if messageText == "" {
  312. return
  313. }
  314. // Check if it's an auto-response (channel 2)
  315. autoResponse := body.ChannelID == 0x0002
  316. // msgId must be unique per delivered event. The OSCAR cookie is not a
  317. // reliable unique id (some clients reuse it across messages), and the web
  318. // client dedupes its conversation list by msgId, silently dropping any
  319. // collisions. Mint a fresh random id instead of reusing body.Cookie.
  320. msgID := strconv.FormatUint(mrand.Uint64(), 16)
  321. // SNAC user info carries the sender's display screen name. The web client
  322. // keys conversations and users by the normalized aimId and only renders
  323. // displayId, so the two forms must not be interchanged.
  324. partnerDisplay := body.ScreenName
  325. partnerAimID := NewIdentScreenName(partnerDisplay).String()
  326. nowSec := time.Now().Unix()
  327. s.AddStoredIM(partnerAimID, partnerAimID, messageText, msgID, nowSec)
  328. // Create IM event
  329. imEvent := types.IMEvent{
  330. Source: types.UserInfo{
  331. AimID: partnerAimID,
  332. DisplayID: partnerDisplay,
  333. Friendly: s.aliasFor(NewIdentScreenName(partnerAimID)),
  334. UserType: "aim",
  335. State: "online",
  336. },
  337. Message: messageText,
  338. MsgID: msgID,
  339. Timestamp: float64(time.Now().Unix()),
  340. AutoResp: autoResponse,
  341. }
  342. s.EventQueue.Push(types.EventTypeIM, imEvent)
  343. s.logger.Debug("delivered instant message",
  344. "from", partnerDisplay,
  345. "to", s.ScreenName)
  346. if s.IsSubscribedTo("conversation") {
  347. // unread is 0 here, not 1, because the "im" event pushed above already
  348. // causes the client to increment its own persisted per-buddy unread
  349. // tally. The "Recent chats" badge is the sum of that persisted tally and
  350. // this conversation's unreadCount, so sending 1 here would double-count
  351. // the message (badge shows 2 for the first IM). Mirrors the sent-IM path,
  352. // which also passes 0.
  353. s.EventQueue.Push(types.EventTypeConversation, types.ConversationEventData("update", []map[string]interface{}{
  354. types.ConversationEntry(
  355. partnerAimID,
  356. partnerDisplay,
  357. messageText,
  358. msgID,
  359. partnerAimID,
  360. false,
  361. 0,
  362. ),
  363. }))
  364. }
  365. }
  366. // handleTypingNotification handles typing notifications.
  367. func (s *WebAPISession) handleTypingNotification(msg wire.SNACMessage) {
  368. if !s.IsSubscribedTo("typing") {
  369. return
  370. }
  371. body, ok := msg.Body.(wire.SNAC_0x04_0x14_ICBMClientEvent)
  372. if !ok {
  373. return
  374. }
  375. // Event types: 0x0000=none, 0x0001=typed (paused), 0x0002=typing
  376. var typingStatus string
  377. switch body.Event {
  378. case 0x0002:
  379. typingStatus = "typing"
  380. case 0x0001:
  381. typingStatus = "typed"
  382. default:
  383. typingStatus = "none"
  384. }
  385. typingEvent := types.TypingEvent{
  386. AimID: NewIdentScreenName(body.ScreenName).String(),
  387. TypingStatus: typingStatus,
  388. }
  389. s.EventQueue.Push(types.EventTypeTyping, typingEvent)
  390. }
  391. // handleBuddyMessage handles buddy/presence SNAC messages.
  392. func (s *WebAPISession) handleBuddyMessage(msg wire.SNACMessage) {
  393. switch msg.Frame.SubGroup {
  394. case wire.BuddyArrived:
  395. s.handleBuddyArrived(msg)
  396. case wire.BuddyDeparted:
  397. s.handleBuddyDeparted(msg)
  398. }
  399. }
  400. // handleBuddyArrived handles when a buddy comes online.
  401. func (s *WebAPISession) handleBuddyArrived(msg wire.SNACMessage) {
  402. if !s.IsSubscribedTo("presence") {
  403. return
  404. }
  405. body, ok := msg.Body.(wire.SNAC_0x03_0x0B_BuddyArrived)
  406. if !ok {
  407. return
  408. }
  409. stateStr := "online"
  410. // For BuddyArrived updates, infer presence state from the TLVUserInfo.
  411. // Away and invisible transitions are typically broadcast using BuddyArrived
  412. // with updated user flags/status bits, not BuddyDeparted.
  413. if body.IsInvisible() {
  414. stateStr = "offline"
  415. } else if body.IsAway() {
  416. stateStr = "away"
  417. } else if mask, ok := body.Uint32BE(wire.OServiceUserInfoStatus); ok {
  418. if mask&wire.OServiceUserStatusDND == wire.OServiceUserStatusDND {
  419. stateStr = "dnd"
  420. } else if mask&wire.OServiceUserStatusAway == wire.OServiceUserStatusAway {
  421. stateStr = "away"
  422. }
  423. }
  424. buddy := NewIdentScreenName(body.ScreenName)
  425. presenceEvent := types.PresenceEvent{
  426. AimID: buddy.String(),
  427. Friendly: s.aliasFor(buddy),
  428. State: stateStr,
  429. UserType: "aim",
  430. }
  431. // A BuddyArrived carries the buddy's current icon in TLV 0x1D whenever they
  432. // have one, so an icon change (or clear, which arrives as the sentinel hash)
  433. // rides along on the presence broadcast. Publish the matching URL: with an
  434. // icon it is content-addressed; without one it is the placeholder URL, which
  435. // differs from any prior icon URL and so clears a removed icon under the
  436. // client's shallow merge. An empty result (no origin known) is omitted, which
  437. // preserves whatever icon the client already holds.
  438. if s.BuddyIconURL != nil {
  439. var hash []byte
  440. if b, ok := body.Bytes(wire.OServiceUserInfoBARTInfo); ok {
  441. var id wire.BARTID
  442. if err := wire.UnmarshalBE(&id, bytes.NewBuffer(b)); err == nil {
  443. hash = id.Hash
  444. }
  445. }
  446. presenceEvent.BuddyIcon = s.BuddyIconURL(buddy, hash)
  447. }
  448. s.EventQueue.Push(types.EventTypePresence, presenceEvent)
  449. }
  450. // handleBuddyDeparted handles when a buddy goes offline.
  451. func (s *WebAPISession) handleBuddyDeparted(msg wire.SNACMessage) {
  452. if !s.IsSubscribedTo("presence") {
  453. return
  454. }
  455. body, ok := msg.Body.(wire.SNAC_0x03_0x0C_BuddyDeparted)
  456. if !ok {
  457. return
  458. }
  459. buddy := NewIdentScreenName(body.ScreenName)
  460. // BuddyIcon is deliberately omitted: an offline buddy keeps their icon, and
  461. // omitting it lets the client's merge preserve the icon it already holds.
  462. presenceEvent := types.PresenceEvent{
  463. AimID: buddy.String(),
  464. Friendly: s.aliasFor(buddy),
  465. State: "offline",
  466. UserType: "aim",
  467. }
  468. s.EventQueue.Push(types.EventTypePresence, presenceEvent)
  469. }
  470. func (s *WebAPISession) handleFeedbagMessage(msg wire.SNACMessage) {
  471. switch msg.Frame.SubGroup {
  472. case wire.FeedbagInsertItem, wire.FeedbagUpdateItem, wire.FeedbagDeleteItem:
  473. // A buddy item carries its alias, so any feedbag write can change the map.
  474. s.InvalidateAliases()
  475. if s.BuddyListRefresher != nil {
  476. groups, err := s.BuddyListRefresher(s.ctx)
  477. if err != nil {
  478. s.logger.Error("failed to refresh buddy list after feedbag change", "err", err)
  479. } else {
  480. s.EventQueue.Push(types.EventTypeBuddyList, map[string]interface{}{"groups": groups})
  481. }
  482. }
  483. if s.PermitDenyRefresher != nil {
  484. // An insert and an update both relay an UpdateItem body; only a
  485. // delete carries a DeleteItem body.
  486. var items []wire.FeedbagItem
  487. switch body := msg.Body.(type) {
  488. case wire.SNAC_0x13_0x09_FeedbagUpdateItem:
  489. items = body.Items
  490. case wire.SNAC_0x13_0x0A_FeedbagDeleteItem:
  491. items = body.Items
  492. }
  493. for _, item := range items {
  494. if item.ClassID == wire.FeedbagClassIDPermit ||
  495. item.ClassID == wire.FeedbagClassIDDeny ||
  496. item.ClassID == wire.FeedbagClassIdPdinfo {
  497. pdd, err := s.PermitDenyRefresher(s.ctx)
  498. if err != nil {
  499. s.logger.Error("failed to refresh permit/deny after feedbag change", "err", err)
  500. } else {
  501. s.EventQueue.Push(types.EventTypePermitDeny, pdd)
  502. }
  503. break
  504. }
  505. }
  506. }
  507. }
  508. }
  509. // WebAPISessionManager manages Web API sessions with thread-safe operations.
  510. // Construct it with NewWebAPISessionManager and drive its reaper with Run.
  511. type WebAPISessionManager struct {
  512. sessions map[string]*WebAPISession // Keyed by aimsid
  513. mu sync.RWMutex
  514. closed bool // set by Shutdown; rejects new sessions and makes drain idempotent
  515. stopCh chan struct{} // closed by Shutdown to stop the reaper
  516. reaperWG sync.WaitGroup // tracks a running reaper so Shutdown can join it
  517. }
  518. // NewWebAPISessionManager creates a new WebAPI session manager. It does not start
  519. // any goroutines; call Run to start reaping expired sessions.
  520. func NewWebAPISessionManager() *WebAPISessionManager {
  521. return &WebAPISessionManager{
  522. sessions: make(map[string]*WebAPISession),
  523. stopCh: make(chan struct{}),
  524. }
  525. }
  526. // CreateSession creates a new WebAPI session.
  527. //
  528. // The session does not begin listening to its OSCAR instance yet: the caller
  529. // must wire the session's refresher callbacks (BuddyListRefresher, BuddyIconURL,
  530. // MyInfoRefresher, ...) and then call StartListeningToOSCARSession. Wiring them
  531. // after the listener starts would race the goroutine, which reads them as it
  532. // converts SNACs into events.
  533. func (m *WebAPISessionManager) CreateSession(screenName DisplayScreenName, devID string, events []string, oscarSession *SessionInstance, baseURL string, logger *slog.Logger) (*WebAPISession, error) {
  534. m.mu.Lock()
  535. defer m.mu.Unlock()
  536. // Refuse to create sessions once shut down: the reaper is stopped, so a
  537. // session added now would never be closed or reaped.
  538. if m.closed {
  539. return nil, ErrWebAPISessionManagerClosed
  540. }
  541. // Generate unique session ID
  542. aimsid, err := generateSessionID()
  543. if err != nil {
  544. return nil, err
  545. }
  546. now := time.Now()
  547. sessCtx, sessCancel := context.WithCancel(context.Background())
  548. session := &WebAPISession{
  549. ctx: sessCtx,
  550. cancel: sessCancel,
  551. AimSID: aimsid,
  552. ScreenName: screenName,
  553. OSCARSession: oscarSession,
  554. BaseURL: baseURL,
  555. Events: events,
  556. EventQueue: types.NewEventQueue(1000), // Max 1000 events per session
  557. DevID: devID,
  558. CreatedAt: now,
  559. LastAccessed: now,
  560. ExpiresAt: now.Add(webAPISessionTTL),
  561. FetchTimeout: 60000, // 60 seconds default for better stability
  562. TimeToNextFetch: 500, // 500ms suggested delay
  563. logger: logger,
  564. }
  565. m.sessions[aimsid] = session
  566. // The caller starts the OSCAR listener (StartListeningToOSCARSession) once it
  567. // has wired the session's refresher callbacks; starting it here would race
  568. // those assignments.
  569. return session, nil
  570. }
  571. // GetSession retrieves a session by aimsid.
  572. func (m *WebAPISessionManager) GetSession(ctx context.Context, aimsid string) (*WebAPISession, error) {
  573. m.mu.RLock()
  574. defer m.mu.RUnlock()
  575. session, exists := m.sessions[aimsid]
  576. if !exists {
  577. return nil, ErrNoWebAPISession
  578. }
  579. if session.IsExpired() {
  580. return nil, ErrWebAPISessionExpired
  581. }
  582. // A rate-limit disconnect (EvaluateRateLimit -> Session.CloseSession) closes
  583. // every instance for the account while this web session is still unexpired.
  584. // The aimsid must stop resolving at that point, otherwise a client told to
  585. // disconnect could keep issuing charged requests against a dead session (the
  586. // reaper only removes it on time expiry, up to a TTL later).
  587. if session.OSCARSession != nil && session.OSCARSession.IsClosed() {
  588. return nil, ErrWebAPISessionExpired
  589. }
  590. return session, nil
  591. }
  592. // RemoveSession removes a session by aimsid.
  593. func (m *WebAPISessionManager) RemoveSession(ctx context.Context, aimsid string) error {
  594. m.mu.Lock()
  595. session, exists := m.sessions[aimsid]
  596. if !exists {
  597. m.mu.Unlock()
  598. return ErrNoWebAPISession
  599. }
  600. delete(m.sessions, aimsid)
  601. m.mu.Unlock()
  602. // Tear down outside the lock: CloseInstance fans out to buddy-departed
  603. // broadcasts and signout, which we don't want to run under m.mu.
  604. session.Close()
  605. return nil
  606. }
  607. // TouchSession updates the last accessed time for a session.
  608. func (m *WebAPISessionManager) TouchSession(ctx context.Context, aimsid string) error {
  609. m.mu.Lock()
  610. defer m.mu.Unlock()
  611. session, exists := m.sessions[aimsid]
  612. if !exists {
  613. return ErrNoWebAPISession
  614. }
  615. session.Touch()
  616. return nil
  617. }
  618. // Run reaps expired sessions on a fixed interval until ctx is cancelled or
  619. // Shutdown is called. The caller owns the goroutine's lifecycle; typically
  620. // launch it under the server's errgroup:
  621. //
  622. // g.Go(func() error { mgr.Run(ctx); return nil })
  623. //
  624. // Run is a no-op once the manager is closed, so a reaper that loses the race
  625. // with Shutdown never starts reaping a drained manager.
  626. func (m *WebAPISessionManager) Run(ctx context.Context) {
  627. m.mu.Lock()
  628. if m.closed {
  629. m.mu.Unlock()
  630. return
  631. }
  632. // Registering under m.mu is what makes Shutdown's join sound: Shutdown flips
  633. // closed under the same lock, so a reaper either registers before Shutdown
  634. // waits or is turned away here.
  635. m.reaperWG.Add(1)
  636. m.mu.Unlock()
  637. defer m.reaperWG.Done()
  638. ticker := time.NewTicker(webAPISessionReapInterval)
  639. defer ticker.Stop()
  640. for {
  641. select {
  642. case <-ticker.C:
  643. m.reapExpired()
  644. case <-m.stopCh:
  645. return
  646. case <-ctx.Done():
  647. return
  648. }
  649. }
  650. }
  651. // reapExpired removes every dead session and tears it down. A session is dead
  652. // once it has passed its expiry, or once its underlying OSCAR session has been
  653. // closed out from under it (e.g. by a rate-limit disconnect) — the latter is
  654. // already rejected by GetSession, and reaping it here frees the entry promptly
  655. // rather than leaving it until time expiry.
  656. func (m *WebAPISessionManager) reapExpired() {
  657. m.mu.Lock()
  658. now := time.Now()
  659. var expired []*WebAPISession
  660. for aimsid, session := range m.sessions {
  661. if now.After(session.ExpiresAt) || (session.OSCARSession != nil && session.OSCARSession.IsClosed()) {
  662. delete(m.sessions, aimsid)
  663. expired = append(expired, session)
  664. }
  665. }
  666. m.mu.Unlock()
  667. // Tear down outside the lock: CloseInstance fans out to buddy-departed
  668. // broadcasts and signout, which we don't want to run under m.mu.
  669. for _, session := range expired {
  670. session.Close()
  671. }
  672. }
  673. // Shutdown drains and closes all sessions, stops the reaper started by Run, and
  674. // blocks further CreateSession calls. It does not depend on the caller
  675. // cancelling Run's context. Safe to call more than once, though only the first
  676. // call waits for the drain. The drain is bounded by ctx: Shutdown returns
  677. // ctx.Err() rather than block forever on a listener that ignores cancellation.
  678. func (m *WebAPISessionManager) Shutdown(ctx context.Context) error {
  679. m.mu.Lock()
  680. if m.closed {
  681. m.mu.Unlock()
  682. return nil
  683. }
  684. m.closed = true
  685. close(m.stopCh)
  686. sessions := make([]*WebAPISession, 0, len(m.sessions))
  687. for _, session := range m.sessions {
  688. sessions = append(sessions, session)
  689. }
  690. // Clear all sessions
  691. m.sessions = make(map[string]*WebAPISession)
  692. m.mu.Unlock()
  693. drained := make(chan struct{})
  694. go func() {
  695. defer close(drained)
  696. // Tear down outside the lock: CloseInstance fans out to buddy-departed
  697. // broadcasts and signout, which we don't want to run under m.mu.
  698. for _, session := range sessions {
  699. session.Close()
  700. }
  701. m.reaperWG.Wait()
  702. }()
  703. select {
  704. case <-drained:
  705. return nil
  706. case <-ctx.Done():
  707. return ctx.Err()
  708. }
  709. }
  710. // generateSessionID creates a cryptographically secure session ID.
  711. func generateSessionID() (string, error) {
  712. bytes := make([]byte, 32) // 256 bits
  713. if _, err := rand.Read(bytes); err != nil {
  714. return "", err
  715. }
  716. return hex.EncodeToString(bytes), nil
  717. }