buddy_list_manager.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636
  1. package handlers
  2. import (
  3. "context"
  4. "errors"
  5. "fmt"
  6. "log/slog"
  7. "math/rand"
  8. "slices"
  9. "strings"
  10. "github.com/mk6i/open-oscar-server/state"
  11. "github.com/mk6i/open-oscar-server/wire"
  12. )
  13. // BuddyListManager handles the conversion of OSCAR feedbag data
  14. // to WebAPI buddy list format for web clients.
  15. type BuddyListManager struct {
  16. feedbagService FeedbagService
  17. locateService LocateService
  18. iconSource BuddyIconSource
  19. logger *slog.Logger
  20. }
  21. // NewBuddyListManager creates a new instance of the buddy list manager.
  22. func NewBuddyListManager(feedbagService FeedbagService, locateService LocateService, iconSource BuddyIconSource, logger *slog.Logger) *BuddyListManager {
  23. return &BuddyListManager{
  24. feedbagService: feedbagService,
  25. locateService: locateService,
  26. iconSource: iconSource,
  27. logger: logger,
  28. }
  29. }
  30. // WebAPIBuddyGroup represents a group in the WebAPI buddy list format.
  31. type WebAPIBuddyGroup struct {
  32. Name string `json:"name"`
  33. Buddies []WebAPIBuddyInfo `json:"buddies"`
  34. Recent bool `json:"recent,omitempty"`
  35. Smart interface{} `json:"smart,omitempty"` // Can be null or number
  36. }
  37. // WebAPIBuddyInfo represents a buddy in the WebAPI format.
  38. type WebAPIBuddyInfo struct {
  39. AimID string `json:"aimId"`
  40. DisplayID string `json:"displayId"`
  41. Friendly string `json:"friendly,omitempty"` // Viewer's private alias, rendered in preference to DisplayID
  42. State string `json:"state"` // "online", "offline", "away", "idle"
  43. StatusMsg string `json:"statusMsg,omitempty"`
  44. AwayMsg string `json:"awayMsg,omitempty"`
  45. OnlineTime int64 `json:"onlineTime,omitempty"`
  46. IdleTime int `json:"idleTime,omitempty"` // Minutes idle
  47. UserType string `json:"userType"` // "aim", "icq", "admin"
  48. Bot bool `json:"bot"`
  49. Service string `json:"service,omitempty"` // "AIM", "ICQ" (Web AIM client compares case-sensitively)
  50. PresenceIcon string `json:"presenceIcon,omitempty"`
  51. BuddyIcon string `json:"buddyIcon,omitempty"`
  52. Capabilities []string `json:"capabilities,omitempty"`
  53. MemberSince int64 `json:"memberSince,omitempty"`
  54. }
  55. // GetBuddyListForUser retrieves and converts the buddy list for a user.
  56. func (m *BuddyListManager) GetBuddyListForUser(ctx context.Context, sess *state.WebAPISession) ([]WebAPIBuddyGroup, error) {
  57. frame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagQuery}
  58. snac, err := m.feedbagService.Query(ctx, sess.OSCARSession, frame)
  59. if err != nil {
  60. return nil, fmt.Errorf("failed to retrieve feedbag: %w", err)
  61. }
  62. reply, ok := snac.Body.(wire.SNAC_0x13_0x06_FeedbagReply)
  63. if !ok {
  64. return nil, fmt.Errorf("failed to retrieve feedbag: unexpected reply type")
  65. }
  66. items := reply.Items
  67. type buddy struct {
  68. name string
  69. alias string
  70. }
  71. type group struct {
  72. name string
  73. buddies map[uint16]buddy
  74. order []uint16
  75. }
  76. type feedbagBL struct {
  77. order []uint16
  78. groups map[uint16]group
  79. }
  80. bl := feedbagBL{groups: make(map[uint16]group)}
  81. for _, item := range items {
  82. if item.ClassID != wire.FeedbagClassIdGroup {
  83. continue
  84. }
  85. if item.GroupID == 0 {
  86. val, hasVal := item.Uint16SliceBE(wire.FeedbagAttributesOrder)
  87. if hasVal {
  88. bl.order = val
  89. }
  90. continue
  91. }
  92. name := item.Name
  93. if name == "" {
  94. name = "Buddies"
  95. }
  96. g := group{
  97. name: name,
  98. buddies: make(map[uint16]buddy),
  99. }
  100. val, _ := item.Uint16SliceBE(wire.FeedbagAttributesOrder)
  101. g.order = val
  102. bl.groups[item.GroupID] = g
  103. }
  104. for _, item := range items {
  105. if item.ClassID != wire.FeedbagClassIdBuddy || item.Name == "" {
  106. continue
  107. }
  108. if _, exists := bl.groups[item.GroupID]; !exists {
  109. bl.groups[item.GroupID] = group{
  110. name: "Buddies",
  111. buddies: make(map[uint16]buddy),
  112. order: nil,
  113. }
  114. }
  115. b := buddy{name: item.Name}
  116. if val, hasVal := item.String(wire.FeedbagAttributesAlias); hasVal {
  117. b.alias = val
  118. }
  119. g := bl.groups[item.GroupID]
  120. g.buddies[item.ItemID] = b
  121. bl.groups[item.GroupID] = g
  122. }
  123. groupOrder := bl.order
  124. if len(groupOrder) == 0 && len(bl.groups) > 0 {
  125. groupOrder = make([]uint16, 0, len(bl.groups))
  126. for gid := range bl.groups {
  127. groupOrder = append(groupOrder, gid)
  128. }
  129. slices.Sort(groupOrder)
  130. }
  131. var out []WebAPIBuddyGroup
  132. for _, gid := range groupOrder {
  133. g, ok := bl.groups[gid]
  134. if !ok {
  135. continue
  136. }
  137. groupName := g.name
  138. if groupName == "" {
  139. groupName = "Buddies"
  140. }
  141. wg := WebAPIBuddyGroup{Name: groupName, Buddies: []WebAPIBuddyInfo{}}
  142. for _, bid := range g.order {
  143. b, ok := g.buddies[bid]
  144. if !ok {
  145. continue
  146. }
  147. info := m.getBuddyInfo(ctx, sess.OSCARSession, sess.BaseURL, b.name)
  148. // The alias belongs in friendly, not displayId: the client renders
  149. // friendly in preference to displayId but still shows displayId as
  150. // the buddy's actual screen name.
  151. info.Friendly = b.alias
  152. wg.Buddies = append(wg.Buddies, info)
  153. }
  154. out = append(out, wg)
  155. }
  156. return out, nil
  157. }
  158. // getBuddyInfo retrieves a buddy's current presence by issuing a locate
  159. // UserInfoQuery on behalf of the requesting session's OSCAR instance.
  160. func (m *BuddyListManager) getBuddyInfo(ctx context.Context, instance *state.SessionInstance, baseURL string, buddyName string) WebAPIBuddyInfo {
  161. // Default to offline. The web client keys users by the normalized aimId and
  162. // shallow-merges each buddy map onto the shared user object, so a display-form
  163. // aimId here overwrites the id every other event is keyed by.
  164. //
  165. // Feedbag buddy names are stored normalized, so they are not a source of
  166. // display names. DisplayID is filled in from the locate reply below when the
  167. // buddy is online, or overridden by the caller's alias when one is set.
  168. ident := state.NewIdentScreenName(buddyName)
  169. info := WebAPIBuddyInfo{
  170. AimID: ident.String(),
  171. DisplayID: buddyName,
  172. State: "offline",
  173. UserType: "aim",
  174. Bot: false,
  175. Service: "AIM",
  176. }
  177. reply, err := m.locateService.UserInfoQuery(ctx, instance, wire.SNACFrame{},
  178. wire.SNAC_0x02_0x05_LocateUserInfoQuery{
  179. Type: uint16(wire.LocateTypeUnavailable), // away message
  180. ScreenName: ident.String(),
  181. })
  182. if err != nil {
  183. m.logger.WarnContext(ctx, "failed to query buddy info", "screenName", buddyName, "error", err)
  184. return info
  185. }
  186. userInfo, ok := reply.Body.(wire.SNAC_0x02_0x06_LocateUserInfoReply)
  187. if !ok {
  188. // Locate error => buddy is blocked or offline.
  189. return info
  190. }
  191. info.State = "online"
  192. info.Capabilities = []string{}
  193. // Publish the icon only now that locate has confirmed the buddy is online and
  194. // has not blocked the caller. Offline and blocking buddies return above without
  195. // an icon, so neither their icon nor its activity-revealing hash leaks.
  196. info.BuddyIcon = m.iconSource.PublishedURL(ctx, baseURL, ident)
  197. // The locate reply carries the screen name as the buddy formatted it.
  198. if userInfo.ScreenName != "" {
  199. info.DisplayID = userInfo.ScreenName
  200. }
  201. if tod, ok := userInfo.Uint32BE(wire.OServiceUserInfoSignonTOD); ok {
  202. info.OnlineTime = int64(tod)
  203. }
  204. if userInfo.IsAway() {
  205. info.State = "away"
  206. if msg, ok := userInfo.LocateInfo.String(wire.LocateTLVTagsInfoUnavailableData); ok {
  207. info.AwayMsg = msg
  208. }
  209. }
  210. if idle, ok := userInfo.Uint16BE(wire.OServiceUserInfoIdleTime); ok && idle > 0 {
  211. info.IdleTime = int(idle)
  212. if info.State == "online" {
  213. info.State = "idle"
  214. }
  215. }
  216. return info
  217. }
  218. // RemoveBuddyFromFeedbag removes a buddy from a group (or all groups if allGroups is true) using feedbag delete/update SNACs.
  219. func (m *BuddyListManager) RemoveBuddyFromFeedbag(ctx context.Context, sess *state.WebAPISession, buddyName, groupName string, allGroups bool) (resultCode string, err error) {
  220. // Buddy items carry the owner's alias for the buddy, and the feedbag service
  221. // relays a session's own writes only to the owner's other instances, so every
  222. // method here that rewrites buddy items has to drop the alias cache itself.
  223. defer sess.InvalidateAliases()
  224. buddyName = strings.TrimSpace(buddyName)
  225. if buddyName == "" {
  226. return "error", fmt.Errorf("empty buddy")
  227. }
  228. frame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagQuery}
  229. snac, err := m.feedbagService.Query(ctx, sess.OSCARSession, frame)
  230. if err != nil {
  231. m.logger.ErrorContext(ctx, "remove buddy: feedbag query failed", "err", err.Error())
  232. return "error", err
  233. }
  234. reply, ok := snac.Body.(wire.SNAC_0x13_0x06_FeedbagReply)
  235. if !ok {
  236. return "error", fmt.Errorf("unexpected feedbag reply type")
  237. }
  238. fl := state.NewFeedbagList(reply.Items, rand.Intn)
  239. target := groupName
  240. if allGroups {
  241. target = "*"
  242. }
  243. if err := fl.DeleteBuddy(target, buddyName); err != nil {
  244. if errors.Is(err, state.ErrGroupNotFound) {
  245. return "notFound", nil
  246. }
  247. m.logger.ErrorContext(ctx, "remove buddy: DeleteBuddy failed", "err", err.Error())
  248. return "error", err
  249. }
  250. if pending := fl.PendingDeletes(); len(pending) > 0 {
  251. delFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagDeleteItem}
  252. delBody := wire.SNAC_0x13_0x0A_FeedbagDeleteItem{Items: pending}
  253. if _, err := m.feedbagService.DeleteItem(ctx, sess.OSCARSession, delFrame, delBody); err != nil {
  254. m.logger.ErrorContext(ctx, "remove buddy: Feedbag DeleteItem failed", "err", err.Error())
  255. return "error", err
  256. }
  257. } else {
  258. return "notFound", nil
  259. }
  260. if pending := fl.PendingUpdates(); len(pending) > 0 {
  261. upFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagUpdateItem}
  262. if _, err := m.feedbagService.UpsertItem(ctx, sess.OSCARSession, upFrame, pending); err != nil {
  263. m.logger.ErrorContext(ctx, "remove buddy: Feedbag UpsertItem failed", "err", err.Error())
  264. return "error", err
  265. }
  266. }
  267. return "success", nil
  268. }
  269. // RemoveGroupFromFeedbag deletes a buddy group and updates the root order (TOC DelGroup).
  270. func (m *BuddyListManager) RemoveGroupFromFeedbag(ctx context.Context, sess *state.WebAPISession, requestedGroup string) (resultCode string, err error) {
  271. defer sess.InvalidateAliases()
  272. req := strings.TrimSpace(requestedGroup)
  273. if req == "" {
  274. return "error", fmt.Errorf("empty group")
  275. }
  276. frame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagQuery}
  277. snac, err := m.feedbagService.Query(ctx, sess.OSCARSession, frame)
  278. if err != nil {
  279. m.logger.ErrorContext(ctx, "remove group: feedbag query failed", "err", err.Error())
  280. return "error", err
  281. }
  282. reply, ok := snac.Body.(wire.SNAC_0x13_0x06_FeedbagReply)
  283. if !ok {
  284. return "error", fmt.Errorf("unexpected feedbag reply type")
  285. }
  286. storedName, found := storedGroupNameForRequest(reply.Items, req)
  287. if !found {
  288. return "notFound", nil
  289. }
  290. fl := state.NewFeedbagList(reply.Items, rand.Intn)
  291. fl.DeleteGroup(storedName)
  292. if pending := fl.PendingDeletes(); len(pending) > 0 {
  293. delFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagDeleteItem}
  294. delBody := wire.SNAC_0x13_0x0A_FeedbagDeleteItem{Items: pending}
  295. if _, err := m.feedbagService.DeleteItem(ctx, sess.OSCARSession, delFrame, delBody); err != nil {
  296. m.logger.ErrorContext(ctx, "remove group: Feedbag DeleteItem failed", "err", err.Error())
  297. return "error", err
  298. }
  299. } else {
  300. return "notFound", nil
  301. }
  302. if pending := fl.PendingUpdates(); len(pending) > 0 {
  303. upFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagUpdateItem}
  304. if _, err := m.feedbagService.UpsertItem(ctx, sess.OSCARSession, upFrame, pending); err != nil {
  305. m.logger.ErrorContext(ctx, "remove group: Feedbag UpsertItem failed", "err", err.Error())
  306. return "error", err
  307. }
  308. }
  309. return "success", nil
  310. }
  311. // RenameGroupInFeedbag renames a buddy group, updating the group item in place.
  312. func (m *BuddyListManager) RenameGroupInFeedbag(ctx context.Context, sess *state.WebAPISession, oldGroup, newGroup string) (resultCode string, err error) {
  313. defer sess.InvalidateAliases()
  314. oldGroup = strings.TrimSpace(oldGroup)
  315. newGroup = strings.TrimSpace(newGroup)
  316. if oldGroup == "" || newGroup == "" {
  317. return "error", fmt.Errorf("empty group name")
  318. }
  319. frame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagQuery}
  320. snac, err := m.feedbagService.Query(ctx, sess.OSCARSession, frame)
  321. if err != nil {
  322. m.logger.ErrorContext(ctx, "rename group: feedbag query failed", "err", err.Error())
  323. return "error", err
  324. }
  325. reply, ok := snac.Body.(wire.SNAC_0x13_0x06_FeedbagReply)
  326. if !ok {
  327. return "error", fmt.Errorf("unexpected feedbag reply type")
  328. }
  329. storedName, found := storedGroupNameForRequest(reply.Items, oldGroup)
  330. if !found {
  331. return "notFound", nil
  332. }
  333. fl := state.NewFeedbagList(reply.Items, rand.Intn)
  334. if err := fl.RenameGroup(storedName, newGroup); err != nil {
  335. switch {
  336. case errors.Is(err, state.ErrGroupNotFound):
  337. return "notFound", nil
  338. case errors.Is(err, state.ErrGroupExists):
  339. return "alreadyExists", nil
  340. default:
  341. m.logger.ErrorContext(ctx, "rename group: RenameGroup failed", "err", err.Error())
  342. return "error", err
  343. }
  344. }
  345. if pending := fl.PendingUpdates(); len(pending) > 0 {
  346. upFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagUpdateItem}
  347. if _, err := m.feedbagService.UpsertItem(ctx, sess.OSCARSession, upFrame, pending); err != nil {
  348. m.logger.ErrorContext(ctx, "rename group: Feedbag UpsertItem failed", "err", err.Error())
  349. return "error", err
  350. }
  351. }
  352. return "success", nil
  353. }
  354. // MoveBuddyInFeedbag moves a buddy to a different group and/or repositions it
  355. // within a group's order.
  356. func (m *BuddyListManager) MoveBuddyInFeedbag(ctx context.Context, sess *state.WebAPISession, buddyName, fromGroup, toGroup, beforeBuddy string) (resultCode string, err error) {
  357. defer sess.InvalidateAliases()
  358. buddyName = strings.TrimSpace(buddyName)
  359. fromGroup = strings.TrimSpace(fromGroup)
  360. toGroup = strings.TrimSpace(toGroup)
  361. beforeBuddy = strings.TrimSpace(beforeBuddy)
  362. if buddyName == "" || fromGroup == "" {
  363. return "error", fmt.Errorf("empty buddy or group")
  364. }
  365. frame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagQuery}
  366. snac, err := m.feedbagService.Query(ctx, sess.OSCARSession, frame)
  367. if err != nil {
  368. m.logger.ErrorContext(ctx, "move buddy: feedbag query failed", "err", err.Error())
  369. return "error", err
  370. }
  371. reply, ok := snac.Body.(wire.SNAC_0x13_0x06_FeedbagReply)
  372. if !ok {
  373. return "error", fmt.Errorf("unexpected feedbag reply type")
  374. }
  375. storedFrom, found := storedGroupNameForRequest(reply.Items, fromGroup)
  376. if !found {
  377. return "notFound", nil
  378. }
  379. storedTo := ""
  380. if toGroup != "" {
  381. storedTo, found = storedGroupNameForRequest(reply.Items, toGroup)
  382. if !found {
  383. return "notFound", nil
  384. }
  385. }
  386. fl := state.NewFeedbagList(reply.Items, rand.Intn)
  387. if err := fl.MoveBuddy(storedFrom, storedTo, buddyName, beforeBuddy); err != nil {
  388. if errors.Is(err, state.ErrGroupNotFound) || errors.Is(err, state.ErrBuddyNotFound) {
  389. return "notFound", nil
  390. }
  391. m.logger.ErrorContext(ctx, "move buddy: MoveBuddy failed", "err", err.Error())
  392. return "error", err
  393. }
  394. if pending := fl.PendingDeletes(); len(pending) > 0 {
  395. delFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagDeleteItem}
  396. delBody := wire.SNAC_0x13_0x0A_FeedbagDeleteItem{Items: pending}
  397. if _, err := m.feedbagService.DeleteItem(ctx, sess.OSCARSession, delFrame, delBody); err != nil {
  398. m.logger.ErrorContext(ctx, "move buddy: Feedbag DeleteItem failed", "err", err.Error())
  399. return "error", err
  400. }
  401. }
  402. if pending := fl.PendingUpdates(); len(pending) > 0 {
  403. var inserts, updates []wire.FeedbagItem
  404. for _, item := range pending {
  405. if item.ClassID == wire.FeedbagClassIdBuddy {
  406. inserts = append(inserts, item)
  407. } else {
  408. updates = append(updates, item)
  409. }
  410. }
  411. if len(inserts) > 0 {
  412. insFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagInsertItem}
  413. if _, err := m.feedbagService.UpsertItem(ctx, sess.OSCARSession, insFrame, inserts); err != nil {
  414. m.logger.ErrorContext(ctx, "move buddy: Feedbag InsertItem failed", "err", err.Error())
  415. return "error", err
  416. }
  417. }
  418. if len(updates) > 0 {
  419. upFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagUpdateItem}
  420. if _, err := m.feedbagService.UpsertItem(ctx, sess.OSCARSession, upFrame, updates); err != nil {
  421. m.logger.ErrorContext(ctx, "move buddy: Feedbag UpdateItem failed", "err", err.Error())
  422. return "error", err
  423. }
  424. }
  425. }
  426. return "success", nil
  427. }
  428. // SetBuddyAttributeInFeedbag sets a buddy's friendly (alias) name across all
  429. // groups it belongs to. An empty friendly clears the alias.
  430. func (m *BuddyListManager) SetBuddyAttributeInFeedbag(ctx context.Context, sess *state.WebAPISession, buddyName, friendly string) (resultCode string, err error) {
  431. defer sess.InvalidateAliases()
  432. buddyName = strings.TrimSpace(buddyName)
  433. if buddyName == "" {
  434. return "error", fmt.Errorf("empty buddy")
  435. }
  436. frame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagQuery}
  437. snac, err := m.feedbagService.Query(ctx, sess.OSCARSession, frame)
  438. if err != nil {
  439. m.logger.ErrorContext(ctx, "set buddy attribute: feedbag query failed", "err", err.Error())
  440. return "error", err
  441. }
  442. reply, ok := snac.Body.(wire.SNAC_0x13_0x06_FeedbagReply)
  443. if !ok {
  444. return "error", fmt.Errorf("unexpected feedbag reply type")
  445. }
  446. fl := state.NewFeedbagList(reply.Items, rand.Intn)
  447. found, err := fl.SetBuddyAlias(buddyName, friendly)
  448. if err != nil {
  449. m.logger.ErrorContext(ctx, "set buddy attribute: SetBuddyAlias failed", "err", err.Error())
  450. return "error", err
  451. }
  452. if !found {
  453. return "notFound", nil
  454. }
  455. if pending := fl.PendingUpdates(); len(pending) > 0 {
  456. upFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagUpdateItem}
  457. if _, err := m.feedbagService.UpsertItem(ctx, sess.OSCARSession, upFrame, pending); err != nil {
  458. m.logger.ErrorContext(ctx, "set buddy attribute: Feedbag UpsertItem failed", "err", err.Error())
  459. return "error", err
  460. }
  461. }
  462. return "success", nil
  463. }
  464. // SetGroupAttributeInFeedbag sets a group's collapsed state. An empty group
  465. // targets the unnamed default group.
  466. func (m *BuddyListManager) SetGroupAttributeInFeedbag(ctx context.Context, sess *state.WebAPISession, groupName string, collapsed bool) (resultCode string, err error) {
  467. defer sess.InvalidateAliases()
  468. groupName = strings.TrimSpace(groupName)
  469. frame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagQuery}
  470. snac, err := m.feedbagService.Query(ctx, sess.OSCARSession, frame)
  471. if err != nil {
  472. m.logger.ErrorContext(ctx, "set group attribute: feedbag query failed", "err", err.Error())
  473. return "error", err
  474. }
  475. reply, ok := snac.Body.(wire.SNAC_0x13_0x06_FeedbagReply)
  476. if !ok {
  477. return "error", fmt.Errorf("unexpected feedbag reply type")
  478. }
  479. // An empty group targets the unnamed default group (stored name ""); a named
  480. // group is resolved through the "Buddies" default-label mapping.
  481. storedName := ""
  482. if groupName != "" {
  483. var found bool
  484. storedName, found = storedGroupNameForRequest(reply.Items, groupName)
  485. if !found {
  486. return "notFound", nil
  487. }
  488. }
  489. fl := state.NewFeedbagList(reply.Items, rand.Intn)
  490. if err := fl.SetGroupCollapsed(storedName, collapsed); err != nil {
  491. if errors.Is(err, state.ErrGroupNotFound) {
  492. return "notFound", nil
  493. }
  494. m.logger.ErrorContext(ctx, "set group attribute: SetGroupCollapsed failed", "err", err.Error())
  495. return "error", err
  496. }
  497. if pending := fl.PendingUpdates(); len(pending) > 0 {
  498. upFrame := wire.SNACFrame{FoodGroup: wire.Feedbag, SubGroup: wire.FeedbagUpdateItem}
  499. if _, err := m.feedbagService.UpsertItem(ctx, sess.OSCARSession, upFrame, pending); err != nil {
  500. m.logger.ErrorContext(ctx, "set group attribute: Feedbag UpsertItem failed", "err", err.Error())
  501. return "error", err
  502. }
  503. }
  504. return "success", nil
  505. }
  506. // FormatBuddyListEvent formats a buddy list for an event.
  507. func (m *BuddyListManager) FormatBuddyListEvent(groups []WebAPIBuddyGroup) map[string]interface{} {
  508. // Convert groups to a format that AMF3 can properly encode
  509. // AMF3 has trouble with complex struct slices, so convert to maps
  510. groupMaps := make([]interface{}, len(groups))
  511. for i, group := range groups {
  512. buddyMaps := make([]interface{}, len(group.Buddies))
  513. for j, buddy := range group.Buddies {
  514. // Convert each buddy to a map
  515. buddyMap := map[string]interface{}{
  516. "aimId": buddy.AimID,
  517. "displayId": buddy.DisplayID,
  518. "state": buddy.State,
  519. "userType": buddy.UserType,
  520. "bot": buddy.Bot,
  521. "service": buddy.Service,
  522. }
  523. // Add optional fields if present
  524. if buddy.StatusMsg != "" {
  525. buddyMap["statusMsg"] = buddy.StatusMsg
  526. }
  527. if buddy.AwayMsg != "" {
  528. buddyMap["awayMsg"] = buddy.AwayMsg
  529. }
  530. if buddy.OnlineTime > 0 {
  531. buddyMap["onlineTime"] = float64(buddy.OnlineTime)
  532. }
  533. if buddy.IdleTime > 0 {
  534. buddyMap["idleTime"] = buddy.IdleTime
  535. }
  536. if buddy.PresenceIcon != "" {
  537. buddyMap["presenceIcon"] = buddy.PresenceIcon
  538. }
  539. if buddy.BuddyIcon != "" {
  540. buddyMap["buddyIcon"] = buddy.BuddyIcon
  541. }
  542. if len(buddy.Capabilities) > 0 {
  543. buddyMap["capabilities"] = buddy.Capabilities
  544. }
  545. if buddy.MemberSince > 0 {
  546. buddyMap["memberSince"] = float64(buddy.MemberSince)
  547. }
  548. buddyMaps[j] = buddyMap
  549. }
  550. // Convert group to a map
  551. groupMap := map[string]interface{}{
  552. "name": group.Name,
  553. "buddies": buddyMaps,
  554. }
  555. // Add optional group fields
  556. if group.Recent {
  557. groupMap["recent"] = group.Recent
  558. }
  559. if group.Smart != nil {
  560. groupMap["smart"] = group.Smart
  561. }
  562. groupMaps[i] = groupMap
  563. }
  564. return map[string]interface{}{
  565. "groups": groupMaps,
  566. }
  567. }