mgmt_api_test.go 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020
  1. package http
  2. import (
  3. "errors"
  4. "fmt"
  5. "io"
  6. "log/slog"
  7. "net/http"
  8. "net/http/httptest"
  9. "net/mail"
  10. "strings"
  11. "testing"
  12. "time"
  13. "github.com/google/uuid"
  14. "github.com/stretchr/testify/assert"
  15. "github.com/stretchr/testify/mock"
  16. "github.com/mk6i/retro-aim-server/config"
  17. "github.com/mk6i/retro-aim-server/state"
  18. "github.com/mk6i/retro-aim-server/wire"
  19. )
  20. func TestSessionHandler_GET(t *testing.T) {
  21. fnNewSess := func(screenName string, uin uint32) *state.Session {
  22. sess := state.NewSession()
  23. sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
  24. sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
  25. sess.SetUIN(uin)
  26. return sess
  27. }
  28. tt := []struct {
  29. name string
  30. want string
  31. statusCode int
  32. timeSinceFunc func(t time.Time) time.Duration
  33. mockParams mockParams
  34. }{
  35. {
  36. name: "without sessions",
  37. want: `{"count":0,"sessions":[]}`,
  38. statusCode: http.StatusOK,
  39. mockParams: mockParams{
  40. sessionRetrieverParams: sessionRetrieverParams{
  41. sessionRetrieverAllSessionsParams: sessionRetrieverAllSessionsParams{
  42. {
  43. result: []*state.Session{},
  44. },
  45. },
  46. },
  47. },
  48. },
  49. {
  50. name: "with sessions",
  51. want: `{"count":3,"sessions":[{"id":"usera","screen_name":"userA","online_seconds":0,"away_message":"","idle_seconds":0,"is_icq":false},{"id":"userb","screen_name":"userB","online_seconds":0,"away_message":"","idle_seconds":0,"is_icq":false},{"id":"100003","screen_name":"100003","online_seconds":0,"away_message":"","idle_seconds":0,"is_icq":true}]}`,
  52. statusCode: http.StatusOK,
  53. timeSinceFunc: func(t time.Time) time.Duration { t0 := time.Now(); return t0.Sub(t0) },
  54. mockParams: mockParams{
  55. sessionRetrieverParams: sessionRetrieverParams{
  56. sessionRetrieverAllSessionsParams: sessionRetrieverAllSessionsParams{
  57. {
  58. result: []*state.Session{
  59. fnNewSess("userA", 0),
  60. fnNewSess("userB", 0),
  61. fnNewSess("100003", 100003),
  62. },
  63. },
  64. },
  65. },
  66. },
  67. },
  68. }
  69. for _, tc := range tt {
  70. t.Run(tc.name, func(t *testing.T) {
  71. request := httptest.NewRequest(http.MethodGet, "/session", nil)
  72. responseRecorder := httptest.NewRecorder()
  73. sessionRetriever := newMockSessionRetriever(t)
  74. for _, params := range tc.mockParams.sessionRetrieverParams.sessionRetrieverAllSessionsParams {
  75. sessionRetriever.EXPECT().
  76. AllSessions().
  77. Return(params.result)
  78. }
  79. getSessionHandler(responseRecorder, request, sessionRetriever, tc.timeSinceFunc)
  80. if responseRecorder.Code != tc.statusCode {
  81. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  82. }
  83. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  84. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  85. }
  86. })
  87. }
  88. }
  89. func TestSessionHandlerScreenname_GET(t *testing.T) {
  90. fnNewSess := func(screenName string, uin uint32) *state.Session {
  91. sess := state.NewSession()
  92. sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
  93. sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
  94. sess.SetUIN(uin)
  95. return sess
  96. }
  97. tt := []struct {
  98. name string
  99. sessions []*state.Session
  100. requestScreenName state.IdentScreenName
  101. want string
  102. statusCode int
  103. timeSinceFunc func(t time.Time) time.Duration
  104. mockParams mockParams
  105. }{
  106. {
  107. name: "no session for screenname",
  108. sessions: []*state.Session{},
  109. requestScreenName: state.NewIdentScreenName("userA"),
  110. want: `session not found`,
  111. statusCode: http.StatusNotFound,
  112. mockParams: mockParams{
  113. sessionRetrieverParams: sessionRetrieverParams{
  114. retrieveSessionByNameParams: retrieveSessionByNameParams{
  115. {
  116. screenName: state.NewIdentScreenName("userA"),
  117. result: nil,
  118. },
  119. },
  120. },
  121. },
  122. },
  123. {
  124. name: "active session found for screenname",
  125. requestScreenName: state.NewIdentScreenName("userA"),
  126. want: `{"count":1,"sessions":[{"id":"usera","screen_name":"userA","online_seconds":0,"away_message":"","idle_seconds":0,"is_icq":false}]}`,
  127. statusCode: http.StatusOK,
  128. timeSinceFunc: func(t time.Time) time.Duration { t0 := time.Now(); return t0.Sub(t0) },
  129. mockParams: mockParams{
  130. sessionRetrieverParams: sessionRetrieverParams{
  131. retrieveSessionByNameParams: retrieveSessionByNameParams{
  132. {
  133. screenName: state.NewIdentScreenName("userA"),
  134. result: fnNewSess("userA", 0),
  135. },
  136. },
  137. },
  138. },
  139. },
  140. }
  141. for _, tc := range tt {
  142. t.Run(tc.name, func(t *testing.T) {
  143. request := httptest.NewRequest(http.MethodGet, "/session/"+tc.requestScreenName.String(), nil)
  144. request.SetPathValue("screenname", tc.requestScreenName.String())
  145. responseRecorder := httptest.NewRecorder()
  146. sessionRetriever := newMockSessionRetriever(t)
  147. for _, params := range tc.mockParams.sessionRetrieverParams.retrieveSessionByNameParams {
  148. sessionRetriever.EXPECT().
  149. RetrieveSession(params.screenName).
  150. Return(params.result)
  151. }
  152. getSessionHandler(responseRecorder, request, sessionRetriever, tc.timeSinceFunc)
  153. if responseRecorder.Code != tc.statusCode {
  154. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  155. }
  156. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  157. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  158. }
  159. })
  160. }
  161. }
  162. func TestUserAccountHandler_GET(t *testing.T) {
  163. tt := []struct {
  164. name string
  165. requestScreenName state.IdentScreenName
  166. want string
  167. statusCode int
  168. mockParams mockParams
  169. }{
  170. {
  171. name: "invalid account",
  172. requestScreenName: state.NewIdentScreenName("userA"),
  173. want: `user not found`,
  174. statusCode: http.StatusNotFound,
  175. mockParams: mockParams{
  176. userManagerParams: userManagerParams{
  177. getUserParams: getUserParams{
  178. {
  179. screenName: state.NewIdentScreenName("userA"),
  180. result: nil,
  181. },
  182. },
  183. },
  184. },
  185. },
  186. {
  187. name: "valid aim account",
  188. requestScreenName: state.NewIdentScreenName("userA"),
  189. want: `{"id":"usera","screen_name":"userA","profile":"My Profile Text","email_address":"\u003cuserA@aol.com\u003e","reg_status":2,"confirmed":true,"is_icq":false}`,
  190. statusCode: http.StatusOK,
  191. mockParams: mockParams{
  192. userManagerParams: userManagerParams{
  193. getUserParams: getUserParams{
  194. {
  195. screenName: state.NewIdentScreenName("userA"),
  196. result: &state.User{
  197. DisplayScreenName: "userA",
  198. IdentScreenName: state.NewIdentScreenName("userA"),
  199. },
  200. },
  201. },
  202. },
  203. accountRetrieverParams: accountRetrieverParams{
  204. emailAddressByNameParams: emailAddressByNameParams{
  205. {
  206. screenName: state.NewIdentScreenName("userA"),
  207. result: &mail.Address{
  208. Address: "userA@aol.com",
  209. },
  210. },
  211. },
  212. regStatusByNameParams: regStatusByNameParams{
  213. {
  214. screenName: state.NewIdentScreenName("userA"),
  215. result: uint16(0x02),
  216. },
  217. },
  218. confirmStatusByNameParams: confirmStatusByNameParams{
  219. {
  220. screenName: state.NewIdentScreenName("userA"),
  221. result: true,
  222. },
  223. },
  224. },
  225. profileRetrieverParams: profileRetrieverParams{
  226. retrieveProfileParams: retrieveProfileParams{
  227. {
  228. screenName: state.NewIdentScreenName("userA"),
  229. result: "My Profile Text",
  230. },
  231. },
  232. },
  233. },
  234. },
  235. }
  236. for _, tc := range tt {
  237. t.Run(tc.name, func(t *testing.T) {
  238. request := httptest.NewRequest(http.MethodGet, "/user/"+tc.requestScreenName.String()+"/account", nil)
  239. request.SetPathValue("screenname", tc.requestScreenName.String())
  240. responseRecorder := httptest.NewRecorder()
  241. userManager := newMockUserManager(t)
  242. for _, params := range tc.mockParams.userManagerParams.getUserParams {
  243. userManager.EXPECT().
  244. User(params.screenName).
  245. Return(params.result, params.err)
  246. }
  247. accountRetriever := newMockAccountRetriever(t)
  248. for _, params := range tc.mockParams.accountRetrieverParams.emailAddressByNameParams {
  249. accountRetriever.EXPECT().
  250. EmailAddressByName(params.screenName).
  251. Return(params.result, params.err)
  252. }
  253. for _, params := range tc.mockParams.accountRetrieverParams.regStatusByNameParams {
  254. accountRetriever.EXPECT().
  255. RegStatusByName(params.screenName).
  256. Return(params.result, params.err)
  257. }
  258. for _, params := range tc.mockParams.accountRetrieverParams.confirmStatusByNameParams {
  259. accountRetriever.EXPECT().
  260. ConfirmStatusByName(params.screenName).
  261. Return(params.result, params.err)
  262. }
  263. profileRetriever := newMockProfileRetriever(t)
  264. for _, params := range tc.mockParams.profileRetrieverParams.retrieveProfileParams {
  265. profileRetriever.EXPECT().
  266. Profile(params.screenName).
  267. Return(params.result, params.err)
  268. }
  269. getUserAccountHandler(responseRecorder, request, userManager, accountRetriever, profileRetriever, slog.Default())
  270. if responseRecorder.Code != tc.statusCode {
  271. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  272. }
  273. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  274. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  275. }
  276. })
  277. }
  278. }
  279. func TestUserBuddyIconHandler_GET(t *testing.T) {
  280. sampleGIF := []byte{
  281. 0x47, 0x49, 0x46, 0x38, 0x39, 0x61, 0x32, 0x00, 0x32, 0x00, 0x80, 0x00, 0x00, 0x00, 0x00, 0x00,
  282. 0x00, 0x00, 0x00, 0x21, 0xf9, 0x04, 0x01, 0x00, 0x00, 0x00, 0x00, 0x2c, 0x00, 0x00, 0x00, 0x00,
  283. 0x32, 0x00, 0x32, 0x00, 0x00, 0x02, 0x02, 0x44, 0x01, 0x00, 0x3b}
  284. sampleJPG := []byte{0xFF, 0xD8, 0xFF, 0x43, 0x13, 0x37}
  285. tt := []struct {
  286. name string
  287. requestScreenName state.IdentScreenName
  288. want string
  289. statusCode int
  290. contentType string
  291. mockParams mockParams
  292. }{
  293. {
  294. name: "invalid account",
  295. requestScreenName: state.NewIdentScreenName("userA"),
  296. want: `user not found`,
  297. statusCode: http.StatusNotFound,
  298. contentType: "text/plain; charset=utf-8",
  299. mockParams: mockParams{
  300. userManagerParams: userManagerParams{
  301. getUserParams: getUserParams{
  302. {
  303. screenName: state.NewIdentScreenName("userA"),
  304. result: nil,
  305. },
  306. },
  307. },
  308. },
  309. },
  310. {
  311. name: "account with gif buddy icon",
  312. requestScreenName: state.NewIdentScreenName("userA"),
  313. want: string(sampleGIF),
  314. statusCode: http.StatusOK,
  315. contentType: "image/gif",
  316. mockParams: mockParams{
  317. userManagerParams: userManagerParams{
  318. getUserParams: getUserParams{
  319. {
  320. screenName: state.NewIdentScreenName("userA"),
  321. result: &state.User{
  322. DisplayScreenName: "userA",
  323. IdentScreenName: state.NewIdentScreenName("userA"),
  324. },
  325. },
  326. },
  327. },
  328. feedBagRetrieverParams: feedBagRetrieverParams{
  329. buddyIconRefByNameParams: buddyIconRefByNameParams{
  330. {
  331. screenName: state.NewIdentScreenName("userA"),
  332. result: &wire.BARTID{
  333. Type: wire.BARTTypesBuddyIcon,
  334. BARTInfo: wire.BARTInfo{
  335. Flags: 0x00,
  336. Hash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
  337. },
  338. },
  339. },
  340. },
  341. },
  342. bartRetrieverParams: bartRetrieverParams{
  343. bartRetrieveParams: bartRetrieveParams{
  344. {
  345. itemHash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
  346. result: sampleGIF,
  347. },
  348. },
  349. },
  350. },
  351. },
  352. {
  353. name: "account with jpg buddy icon",
  354. requestScreenName: state.NewIdentScreenName("userA"),
  355. want: string(sampleJPG),
  356. statusCode: http.StatusOK,
  357. contentType: "image/jpeg",
  358. mockParams: mockParams{
  359. userManagerParams: userManagerParams{
  360. getUserParams: getUserParams{
  361. {
  362. screenName: state.NewIdentScreenName("userA"),
  363. result: &state.User{
  364. DisplayScreenName: "userA",
  365. IdentScreenName: state.NewIdentScreenName("userA"),
  366. },
  367. },
  368. },
  369. },
  370. feedBagRetrieverParams: feedBagRetrieverParams{
  371. buddyIconRefByNameParams: buddyIconRefByNameParams{
  372. {
  373. screenName: state.NewIdentScreenName("userA"),
  374. result: &wire.BARTID{
  375. Type: wire.BARTTypesBuddyIcon,
  376. BARTInfo: wire.BARTInfo{
  377. Flags: 0x00,
  378. Hash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
  379. },
  380. },
  381. },
  382. },
  383. },
  384. bartRetrieverParams: bartRetrieverParams{
  385. bartRetrieveParams: bartRetrieveParams{
  386. {
  387. itemHash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
  388. result: sampleJPG,
  389. },
  390. },
  391. },
  392. },
  393. },
  394. {
  395. name: "account with unknown format buddy icon",
  396. requestScreenName: state.NewIdentScreenName("userA"),
  397. want: string([]byte{0x13, 0x37, 0x13, 0x37, 0x13, 0x37}),
  398. statusCode: http.StatusOK,
  399. contentType: "application/octet-stream",
  400. mockParams: mockParams{
  401. userManagerParams: userManagerParams{
  402. getUserParams: getUserParams{
  403. {
  404. screenName: state.NewIdentScreenName("userA"),
  405. result: &state.User{
  406. DisplayScreenName: "userA",
  407. IdentScreenName: state.NewIdentScreenName("userA"),
  408. },
  409. },
  410. },
  411. },
  412. feedBagRetrieverParams: feedBagRetrieverParams{
  413. buddyIconRefByNameParams: buddyIconRefByNameParams{
  414. {
  415. screenName: state.NewIdentScreenName("userA"),
  416. result: &wire.BARTID{
  417. Type: wire.BARTTypesBuddyIcon,
  418. BARTInfo: wire.BARTInfo{
  419. Flags: 0x00,
  420. Hash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
  421. },
  422. },
  423. },
  424. },
  425. },
  426. bartRetrieverParams: bartRetrieverParams{
  427. bartRetrieveParams: bartRetrieveParams{
  428. {
  429. itemHash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
  430. result: []byte{0x13, 0x37, 0x13, 0x37, 0x13, 0x37},
  431. },
  432. },
  433. },
  434. },
  435. },
  436. {
  437. name: "account with cleared buddy icon",
  438. requestScreenName: state.NewIdentScreenName("userA"),
  439. want: "icon not found",
  440. statusCode: http.StatusNotFound,
  441. contentType: "text/plain; charset=utf-8",
  442. mockParams: mockParams{
  443. userManagerParams: userManagerParams{
  444. getUserParams: getUserParams{
  445. {
  446. screenName: state.NewIdentScreenName("userA"),
  447. result: &state.User{
  448. DisplayScreenName: "userA",
  449. IdentScreenName: state.NewIdentScreenName("userA"),
  450. },
  451. },
  452. },
  453. },
  454. feedBagRetrieverParams: feedBagRetrieverParams{
  455. buddyIconRefByNameParams: buddyIconRefByNameParams{
  456. {
  457. screenName: state.NewIdentScreenName("userA"),
  458. result: &wire.BARTID{
  459. Type: wire.BARTTypesBuddyIcon,
  460. BARTInfo: wire.BARTInfo{
  461. Flags: 0x00,
  462. Hash: wire.GetClearIconHash(),
  463. },
  464. },
  465. },
  466. },
  467. },
  468. },
  469. },
  470. {
  471. name: "account with no buddy icon",
  472. requestScreenName: state.NewIdentScreenName("userA"),
  473. want: "icon not found",
  474. statusCode: http.StatusNotFound,
  475. contentType: "text/plain; charset=utf-8",
  476. mockParams: mockParams{
  477. userManagerParams: userManagerParams{
  478. getUserParams: getUserParams{
  479. {
  480. screenName: state.NewIdentScreenName("userA"),
  481. result: &state.User{
  482. DisplayScreenName: "userA",
  483. IdentScreenName: state.NewIdentScreenName("userA"),
  484. },
  485. },
  486. },
  487. },
  488. feedBagRetrieverParams: feedBagRetrieverParams{
  489. buddyIconRefByNameParams: buddyIconRefByNameParams{
  490. {
  491. screenName: state.NewIdentScreenName("userA"),
  492. result: nil,
  493. },
  494. },
  495. },
  496. },
  497. },
  498. }
  499. for _, tc := range tt {
  500. t.Run(tc.name, func(t *testing.T) {
  501. request := httptest.NewRequest(http.MethodGet, "/user/"+tc.requestScreenName.String()+"/icon", nil)
  502. request.SetPathValue("screenname", tc.requestScreenName.String())
  503. responseRecorder := httptest.NewRecorder()
  504. userManager := newMockUserManager(t)
  505. for _, params := range tc.mockParams.userManagerParams.getUserParams {
  506. userManager.EXPECT().
  507. User(params.screenName).
  508. Return(params.result, params.err)
  509. }
  510. feedbagRetriever := newMockFeedBagRetriever(t)
  511. for _, params := range tc.mockParams.feedBagRetrieverParams.buddyIconRefByNameParams {
  512. feedbagRetriever.EXPECT().
  513. BuddyIconRefByName(params.screenName).
  514. Return(params.result, params.err)
  515. }
  516. bartRetriever := newMockBARTRetriever(t)
  517. for _, params := range tc.mockParams.bartRetrieverParams.bartRetrieveParams {
  518. bartRetriever.EXPECT().
  519. BARTRetrieve(params.itemHash).
  520. Return(params.result, params.err)
  521. }
  522. getUserBuddyIconHandler(responseRecorder, request, userManager, feedbagRetriever, bartRetriever, slog.Default())
  523. if responseRecorder.Code != tc.statusCode {
  524. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  525. }
  526. contentType := responseRecorder.Header().Get("Content-Type")
  527. if contentType != tc.contentType {
  528. t.Errorf("Want content type '%s', got '%s'", tc.contentType, contentType)
  529. }
  530. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  531. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  532. }
  533. })
  534. }
  535. }
  536. func TestUserHandler_GET(t *testing.T) {
  537. tt := []struct {
  538. name string
  539. want string
  540. statusCode int
  541. mockParams mockParams
  542. }{
  543. {
  544. name: "empty user store",
  545. want: `[]`,
  546. statusCode: http.StatusOK,
  547. mockParams: mockParams{
  548. userManagerParams: userManagerParams{
  549. allUsersParams: allUsersParams{
  550. {
  551. result: []state.User{},
  552. },
  553. },
  554. },
  555. },
  556. },
  557. {
  558. name: "user store containing 3 users",
  559. want: `[{"id":"usera","screen_name":"userA","is_icq":false},{"id":"userb","screen_name":"userB","is_icq":false},{"id":"100003","screen_name":"100003","is_icq":true}]`,
  560. statusCode: http.StatusOK,
  561. mockParams: mockParams{
  562. userManagerParams: userManagerParams{
  563. allUsersParams: allUsersParams{
  564. {
  565. result: []state.User{
  566. {
  567. DisplayScreenName: "userA",
  568. IdentScreenName: state.NewIdentScreenName("userA"),
  569. },
  570. {
  571. DisplayScreenName: "userB",
  572. IdentScreenName: state.NewIdentScreenName("userB"),
  573. },
  574. {
  575. DisplayScreenName: "100003",
  576. IdentScreenName: state.NewIdentScreenName("100003"),
  577. IsICQ: true,
  578. },
  579. },
  580. },
  581. },
  582. },
  583. },
  584. },
  585. {
  586. name: "user handler error",
  587. want: `internal server error`,
  588. statusCode: http.StatusInternalServerError,
  589. mockParams: mockParams{
  590. userManagerParams: userManagerParams{
  591. allUsersParams: allUsersParams{
  592. {
  593. result: []state.User{},
  594. err: io.EOF,
  595. },
  596. },
  597. },
  598. },
  599. },
  600. }
  601. for _, tc := range tt {
  602. t.Run(tc.name, func(t *testing.T) {
  603. responseRecorder := httptest.NewRecorder()
  604. userManager := newMockUserManager(t)
  605. for _, params := range tc.mockParams.userManagerParams.allUsersParams {
  606. userManager.EXPECT().
  607. AllUsers().
  608. Return(params.result, params.err)
  609. }
  610. getUserHandler(responseRecorder, userManager, slog.Default())
  611. if responseRecorder.Code != tc.statusCode {
  612. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  613. }
  614. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  615. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  616. }
  617. })
  618. }
  619. }
  620. func TestUserHandler_POST(t *testing.T) {
  621. tt := []struct {
  622. name string
  623. body string
  624. UUID uuid.UUID
  625. want string
  626. password string
  627. statusCode int
  628. mockParams mockParams
  629. }{
  630. {
  631. name: "with valid AIM user",
  632. body: `{"screen_name":"userA", "password":"thepassword"}`,
  633. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  634. want: `User account created successfully.`,
  635. password: "thepassword",
  636. statusCode: http.StatusCreated,
  637. mockParams: mockParams{
  638. userManagerParams: userManagerParams{
  639. insertUserParams: insertUserParams{
  640. {
  641. u: state.User{
  642. AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
  643. DisplayScreenName: "userA",
  644. IdentScreenName: state.NewIdentScreenName("userA"),
  645. },
  646. err: nil,
  647. },
  648. },
  649. },
  650. },
  651. },
  652. {
  653. name: "with valid ICQ user",
  654. body: `{"screen_name":"100003", "password":"thepass"}`,
  655. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  656. want: `User account created successfully.`,
  657. password: "thepass",
  658. statusCode: http.StatusCreated,
  659. mockParams: mockParams{
  660. userManagerParams: userManagerParams{
  661. insertUserParams: insertUserParams{
  662. {
  663. u: state.User{
  664. AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
  665. DisplayScreenName: "100003",
  666. IdentScreenName: state.NewIdentScreenName("100003"),
  667. IsICQ: true,
  668. },
  669. err: nil,
  670. },
  671. },
  672. },
  673. },
  674. },
  675. {
  676. name: "with malformed body",
  677. body: `{"screen_name":"userA", "password":"thepassword"`, // missing closing }
  678. want: `malformed input`,
  679. statusCode: http.StatusBadRequest,
  680. },
  681. {
  682. name: "user handler error",
  683. body: `{"screen_name":"userA", "password":"thepassword"}`,
  684. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  685. want: `internal server error`,
  686. password: "thepassword",
  687. statusCode: http.StatusInternalServerError,
  688. mockParams: mockParams{
  689. userManagerParams: userManagerParams{
  690. insertUserParams: insertUserParams{
  691. {
  692. u: state.User{
  693. AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
  694. DisplayScreenName: "userA",
  695. IdentScreenName: state.NewIdentScreenName("userA"),
  696. },
  697. err: io.EOF,
  698. },
  699. },
  700. },
  701. },
  702. },
  703. {
  704. name: "duplicate user",
  705. body: `{"screen_name":"userA", "password":"thepassword"}`,
  706. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  707. want: `user already exists`,
  708. password: "thepassword",
  709. statusCode: http.StatusConflict,
  710. mockParams: mockParams{
  711. userManagerParams: userManagerParams{
  712. insertUserParams: insertUserParams{
  713. {
  714. u: state.User{
  715. AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
  716. DisplayScreenName: "userA",
  717. IdentScreenName: state.NewIdentScreenName("userA"),
  718. },
  719. err: state.ErrDupUser,
  720. },
  721. },
  722. },
  723. },
  724. },
  725. {
  726. name: "invalid AIM screen name",
  727. body: `{"screen_name":"a", "password":"thepassword"}`,
  728. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  729. want: `invalid screen name: screen name must be between 3 and 16 characters`,
  730. statusCode: http.StatusBadRequest,
  731. },
  732. {
  733. name: "invalid AIM password",
  734. body: `{"screen_name":"userA", "password":"1"}`,
  735. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  736. want: `invalid password: invalid password length: password length must be between 4-16 characters`,
  737. statusCode: http.StatusBadRequest,
  738. },
  739. {
  740. name: "invalid ICQ UIN",
  741. body: `{"screen_name":"1000", "password":"thepass"}`,
  742. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  743. want: `invalid uin: uin must be a number in the range 10000-2147483646`,
  744. statusCode: http.StatusBadRequest,
  745. },
  746. {
  747. name: "invalid ICQ password",
  748. body: `{"screen_name":"100003", "password":"thelongpassword"}`,
  749. UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
  750. want: `invalid password: invalid password length: password must be between 6-8 characters`,
  751. statusCode: http.StatusBadRequest,
  752. },
  753. }
  754. for _, tc := range tt {
  755. t.Run(tc.name, func(t *testing.T) {
  756. request := httptest.NewRequest(http.MethodPost, "/user", strings.NewReader(tc.body))
  757. responseRecorder := httptest.NewRecorder()
  758. userManager := newMockUserManager(t)
  759. for _, params := range tc.mockParams.userManagerParams.insertUserParams {
  760. assert.NoError(t, params.u.HashPassword(tc.password))
  761. userManager.EXPECT().
  762. InsertUser(params.u).
  763. Return(params.err)
  764. }
  765. newUUID := func() uuid.UUID { return tc.UUID }
  766. postUserHandler(responseRecorder, request, userManager, newUUID, slog.Default())
  767. if responseRecorder.Code != tc.statusCode {
  768. t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  769. }
  770. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  771. t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
  772. }
  773. })
  774. }
  775. }
  776. func TestUserHandler_DELETE(t *testing.T) {
  777. tt := []struct {
  778. name string
  779. body string
  780. want string
  781. statusCode int
  782. mockParams mockParams
  783. }{
  784. {
  785. name: "with valid user",
  786. body: `{"screen_name":"userA"}`,
  787. want: `User account successfully deleted.`,
  788. statusCode: http.StatusNoContent,
  789. mockParams: mockParams{
  790. userManagerParams: userManagerParams{
  791. deleteUserParams: deleteUserParams{
  792. {
  793. screenName: state.NewIdentScreenName("userA"),
  794. },
  795. },
  796. },
  797. },
  798. },
  799. {
  800. name: "with non-existent user",
  801. body: `{"screen_name":"userA"}`,
  802. want: `user does not exist`,
  803. statusCode: http.StatusNotFound,
  804. mockParams: mockParams{
  805. userManagerParams: userManagerParams{
  806. deleteUserParams: deleteUserParams{
  807. {
  808. screenName: state.NewIdentScreenName("userA"),
  809. err: state.ErrNoUser,
  810. },
  811. },
  812. },
  813. },
  814. },
  815. {
  816. name: "with malformed body",
  817. body: `{"screen_name":"userA"`, // missing closing }
  818. want: `malformed input`,
  819. statusCode: http.StatusBadRequest,
  820. },
  821. {
  822. name: "user handler error",
  823. body: `{"screen_name":"userA"}`,
  824. want: `internal server error`,
  825. statusCode: http.StatusInternalServerError,
  826. mockParams: mockParams{
  827. userManagerParams: userManagerParams{
  828. deleteUserParams: deleteUserParams{
  829. {
  830. screenName: state.NewIdentScreenName("userA"),
  831. err: io.EOF,
  832. },
  833. },
  834. },
  835. },
  836. },
  837. }
  838. for _, tc := range tt {
  839. t.Run(tc.name, func(t *testing.T) {
  840. request := httptest.NewRequest(http.MethodDelete, "/user", strings.NewReader(tc.body))
  841. responseRecorder := httptest.NewRecorder()
  842. userManager := newMockUserManager(t)
  843. for _, params := range tc.mockParams.userManagerParams.deleteUserParams {
  844. userManager.EXPECT().
  845. DeleteUser(params.screenName).
  846. Return(params.err)
  847. }
  848. deleteUserHandler(responseRecorder, request, userManager, slog.Default())
  849. if responseRecorder.Code != tc.statusCode {
  850. t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  851. }
  852. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  853. t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
  854. }
  855. })
  856. }
  857. }
  858. func TestUserPasswordHandler_PUT(t *testing.T) {
  859. tt := []struct {
  860. name string
  861. body string
  862. want string
  863. statusCode int
  864. mockParams mockParams
  865. }{
  866. {
  867. name: "user with valid password",
  868. body: `{"screen_name":"userA", "password":"thenewpassword"}`,
  869. want: `Password successfully reset.`,
  870. statusCode: http.StatusNoContent,
  871. mockParams: mockParams{
  872. userManagerParams: userManagerParams{
  873. setUserPasswordParams: setUserPasswordParams{
  874. {
  875. screenName: state.NewIdentScreenName("userA"),
  876. newPassword: "thenewpassword",
  877. },
  878. },
  879. },
  880. },
  881. },
  882. {
  883. name: "user with invalid password",
  884. body: `{"screen_name":"userA", "password":"a"}`,
  885. want: `invalid password length`,
  886. statusCode: http.StatusBadRequest,
  887. mockParams: mockParams{
  888. userManagerParams: userManagerParams{
  889. setUserPasswordParams: setUserPasswordParams{
  890. {
  891. screenName: state.NewIdentScreenName("userA"),
  892. newPassword: "a",
  893. err: state.ErrPasswordInvalid,
  894. },
  895. },
  896. },
  897. },
  898. },
  899. {
  900. name: "with malformed body",
  901. body: `{"screen_name":"userA", "password":"thepassword"`, // missing closing }
  902. want: `malformed input`,
  903. statusCode: http.StatusBadRequest,
  904. },
  905. {
  906. name: "password updater returns runtime error",
  907. body: `{"screen_name":"userA", "password":"thepassword"}`,
  908. want: `internal server error`,
  909. statusCode: http.StatusInternalServerError,
  910. mockParams: mockParams{
  911. userManagerParams: userManagerParams{
  912. setUserPasswordParams: setUserPasswordParams{
  913. {
  914. screenName: state.NewIdentScreenName("userA"),
  915. newPassword: "thepassword",
  916. err: io.EOF,
  917. },
  918. },
  919. },
  920. },
  921. },
  922. {
  923. name: "user doesn't exist",
  924. body: `{"screen_name":"userA", "password":"thepassword"}`,
  925. want: `user does not exist`,
  926. statusCode: http.StatusNotFound,
  927. mockParams: mockParams{
  928. userManagerParams: userManagerParams{
  929. setUserPasswordParams: setUserPasswordParams{
  930. {
  931. screenName: state.NewIdentScreenName("userA"),
  932. newPassword: "thepassword",
  933. err: state.ErrNoUser,
  934. },
  935. },
  936. },
  937. },
  938. },
  939. }
  940. for _, tc := range tt {
  941. t.Run(tc.name, func(t *testing.T) {
  942. request := httptest.NewRequest(http.MethodPut, "/user", strings.NewReader(tc.body))
  943. responseRecorder := httptest.NewRecorder()
  944. userManager := newMockUserManager(t)
  945. for _, params := range tc.mockParams.userManagerParams.setUserPasswordParams {
  946. userManager.EXPECT().
  947. SetUserPassword(params.screenName, params.newPassword).
  948. Return(params.err)
  949. }
  950. putUserPasswordHandler(responseRecorder, request, userManager, slog.Default())
  951. if responseRecorder.Code != tc.statusCode {
  952. t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  953. }
  954. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  955. t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
  956. }
  957. })
  958. }
  959. }
  960. func TestPublicChatHandler_GET(t *testing.T) {
  961. fnNewSess := func(screenName string) *state.Session {
  962. sess := state.NewSession()
  963. sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
  964. sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
  965. return sess
  966. }
  967. chatRoom1 := state.NewChatRoom("chat-room-1-name", state.NewIdentScreenName("chat-room-1-creator"), state.PublicExchange)
  968. chatRoom2 := state.NewChatRoom("chat-room-2-name", state.NewIdentScreenName("chat-room-1-creator"), state.PublicExchange)
  969. tt := []struct {
  970. name string
  971. want string
  972. statusCode int
  973. mockParams mockParams
  974. }{
  975. {
  976. name: "multiple chat rooms with participants",
  977. want: `[{"name":"chat-room-1-name","create_time":"0001-01-01T00:00:00Z","url":"aim:gochat?roomname=chat-room-1-name&exchange=5","participants":[{"id":"usera","screen_name":"userA"},{"id":"userb","screen_name":"userB"}]},{"name":"chat-room-2-name","create_time":"0001-01-01T00:00:00Z","url":"aim:gochat?roomname=chat-room-2-name&exchange=5","participants":[{"id":"userc","screen_name":"userC"},{"id":"userd","screen_name":"userD"}]}]`,
  978. statusCode: http.StatusOK,
  979. mockParams: mockParams{
  980. chatRoomRetrieverParams: chatRoomRetrieverParams{
  981. allChatRoomsParams: allChatRoomsParams{
  982. {
  983. exchange: state.PublicExchange,
  984. result: []state.ChatRoom{
  985. chatRoom1,
  986. chatRoom2,
  987. },
  988. },
  989. },
  990. },
  991. chatSessionRetrieverParams: chatSessionRetrieverParams{
  992. chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
  993. {
  994. cookie: chatRoom1.Cookie(),
  995. result: []*state.Session{
  996. fnNewSess("userA"),
  997. fnNewSess("userB"),
  998. },
  999. },
  1000. {
  1001. cookie: chatRoom2.Cookie(),
  1002. result: []*state.Session{
  1003. fnNewSess("userC"),
  1004. fnNewSess("userD"),
  1005. },
  1006. },
  1007. },
  1008. },
  1009. },
  1010. },
  1011. {
  1012. name: "chat room without participants",
  1013. want: `[{"name":"chat-room-1-name","create_time":"0001-01-01T00:00:00Z","url":"aim:gochat?roomname=chat-room-1-name&exchange=5","participants":[]}]`,
  1014. statusCode: http.StatusOK,
  1015. mockParams: mockParams{
  1016. chatRoomRetrieverParams: chatRoomRetrieverParams{
  1017. allChatRoomsParams: allChatRoomsParams{
  1018. {
  1019. exchange: state.PublicExchange,
  1020. result: []state.ChatRoom{
  1021. chatRoom1,
  1022. },
  1023. },
  1024. },
  1025. },
  1026. chatSessionRetrieverParams: chatSessionRetrieverParams{
  1027. chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
  1028. {
  1029. cookie: chatRoom1.Cookie(),
  1030. result: []*state.Session{},
  1031. },
  1032. },
  1033. },
  1034. },
  1035. },
  1036. {
  1037. name: "no chat rooms",
  1038. want: `[]`,
  1039. statusCode: http.StatusOK,
  1040. mockParams: mockParams{
  1041. chatRoomRetrieverParams: chatRoomRetrieverParams{
  1042. allChatRoomsParams: allChatRoomsParams{
  1043. {
  1044. exchange: state.PublicExchange,
  1045. result: []state.ChatRoom{},
  1046. },
  1047. },
  1048. },
  1049. },
  1050. },
  1051. }
  1052. for _, tc := range tt {
  1053. t.Run(tc.name, func(t *testing.T) {
  1054. request := httptest.NewRequest(http.MethodGet, "/chat/room/public", nil)
  1055. responseRecorder := httptest.NewRecorder()
  1056. chatRoomRetriever := newMockChatRoomRetriever(t)
  1057. for _, params := range tc.mockParams.chatRoomRetrieverParams.allChatRoomsParams {
  1058. chatRoomRetriever.EXPECT().
  1059. AllChatRooms(params.exchange).
  1060. Return(params.result, params.err)
  1061. }
  1062. chatSessionRetriever := newMockChatSessionRetriever(t)
  1063. for _, params := range tc.mockParams.chatSessionRetrieverParams.chatSessionRetrieverAllSessionsParams {
  1064. chatSessionRetriever.EXPECT().
  1065. AllSessions(params.cookie).
  1066. Return(params.result)
  1067. }
  1068. getPublicChatHandler(responseRecorder, request, chatRoomRetriever, chatSessionRetriever, slog.Default())
  1069. if responseRecorder.Code != tc.statusCode {
  1070. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1071. }
  1072. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1073. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1074. }
  1075. })
  1076. }
  1077. }
  1078. func TestPrivateChatHandler_GET(t *testing.T) {
  1079. fnNewSess := func(screenName string) *state.Session {
  1080. sess := state.NewSession()
  1081. sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
  1082. sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
  1083. return sess
  1084. }
  1085. chatRoom1 := state.NewChatRoom("chat-room-1-name", state.NewIdentScreenName("chat-room-1-creator"), state.PrivateExchange)
  1086. chatRoom2 := state.NewChatRoom("chat-room-2-name", state.NewIdentScreenName("chat-room-2-creator"), state.PrivateExchange)
  1087. tt := []struct {
  1088. name string
  1089. want string
  1090. statusCode int
  1091. mockParams mockParams
  1092. }{
  1093. {
  1094. name: "multiple chat rooms with participants",
  1095. want: `[{"name":"chat-room-1-name","create_time":"0001-01-01T00:00:00Z","creator_id":"chat-room-1-creator","url":"aim:gochat?roomname=chat-room-1-name&exchange=4","participants":[{"id":"usera","screen_name":"userA"},{"id":"userb","screen_name":"userB"}]},{"name":"chat-room-2-name","create_time":"0001-01-01T00:00:00Z","creator_id":"chat-room-2-creator","url":"aim:gochat?roomname=chat-room-2-name&exchange=4","participants":[{"id":"userc","screen_name":"userC"},{"id":"userd","screen_name":"userD"}]}]`,
  1096. statusCode: http.StatusOK,
  1097. mockParams: mockParams{
  1098. chatRoomRetrieverParams: chatRoomRetrieverParams{
  1099. allChatRoomsParams: allChatRoomsParams{
  1100. {
  1101. exchange: state.PrivateExchange,
  1102. result: []state.ChatRoom{
  1103. chatRoom1,
  1104. chatRoom2,
  1105. },
  1106. },
  1107. },
  1108. },
  1109. chatSessionRetrieverParams: chatSessionRetrieverParams{
  1110. chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
  1111. {
  1112. cookie: chatRoom1.Cookie(),
  1113. result: []*state.Session{
  1114. fnNewSess("userA"),
  1115. fnNewSess("userB"),
  1116. },
  1117. },
  1118. {
  1119. cookie: chatRoom2.Cookie(),
  1120. result: []*state.Session{
  1121. fnNewSess("userC"),
  1122. fnNewSess("userD"),
  1123. },
  1124. },
  1125. },
  1126. },
  1127. },
  1128. },
  1129. {
  1130. name: "chat room without participants",
  1131. want: `[{"name":"chat-room-1-name","create_time":"0001-01-01T00:00:00Z","creator_id":"chat-room-1-creator","url":"aim:gochat?roomname=chat-room-1-name&exchange=4","participants":[]}]`,
  1132. statusCode: http.StatusOK,
  1133. mockParams: mockParams{
  1134. chatRoomRetrieverParams: chatRoomRetrieverParams{
  1135. allChatRoomsParams: allChatRoomsParams{
  1136. {
  1137. exchange: state.PrivateExchange,
  1138. result: []state.ChatRoom{
  1139. chatRoom1,
  1140. },
  1141. },
  1142. },
  1143. },
  1144. chatSessionRetrieverParams: chatSessionRetrieverParams{
  1145. chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
  1146. {
  1147. cookie: chatRoom1.Cookie(),
  1148. result: []*state.Session{},
  1149. },
  1150. },
  1151. },
  1152. },
  1153. },
  1154. {
  1155. name: "no chat rooms",
  1156. want: `[]`,
  1157. statusCode: http.StatusOK,
  1158. mockParams: mockParams{
  1159. chatRoomRetrieverParams: chatRoomRetrieverParams{
  1160. allChatRoomsParams: allChatRoomsParams{
  1161. {
  1162. exchange: state.PrivateExchange,
  1163. result: []state.ChatRoom{},
  1164. },
  1165. },
  1166. },
  1167. },
  1168. },
  1169. }
  1170. for _, tc := range tt {
  1171. t.Run(tc.name, func(t *testing.T) {
  1172. request := httptest.NewRequest(http.MethodGet, "/chat/room/private", nil)
  1173. responseRecorder := httptest.NewRecorder()
  1174. chatRoomRetriever := newMockChatRoomRetriever(t)
  1175. for _, params := range tc.mockParams.chatRoomRetrieverParams.allChatRoomsParams {
  1176. chatRoomRetriever.EXPECT().
  1177. AllChatRooms(params.exchange).
  1178. Return(params.result, params.err)
  1179. }
  1180. chatSessionRetriever := newMockChatSessionRetriever(t)
  1181. for _, params := range tc.mockParams.chatSessionRetrieverParams.chatSessionRetrieverAllSessionsParams {
  1182. chatSessionRetriever.EXPECT().
  1183. AllSessions(params.cookie).
  1184. Return(params.result)
  1185. }
  1186. getPrivateChatHandler(responseRecorder, request, chatRoomRetriever, chatSessionRetriever, slog.Default())
  1187. if responseRecorder.Code != tc.statusCode {
  1188. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1189. }
  1190. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1191. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1192. }
  1193. })
  1194. }
  1195. }
  1196. func TestInstantMessageHandler_POST(t *testing.T) {
  1197. type relayToScreenNameInputs struct {
  1198. sender state.IdentScreenName
  1199. recipient state.IdentScreenName
  1200. msg string
  1201. }
  1202. tt := []struct {
  1203. name string
  1204. relayToScreenNameInputs []relayToScreenNameInputs
  1205. body string
  1206. want string
  1207. statusCode int
  1208. }{
  1209. {
  1210. name: "send an instant message",
  1211. relayToScreenNameInputs: []relayToScreenNameInputs{
  1212. {
  1213. sender: state.NewIdentScreenName("sender_sn"),
  1214. recipient: state.NewIdentScreenName("recip_sn"),
  1215. msg: "hello world!",
  1216. },
  1217. },
  1218. body: `{"from":"sender_sn","to":"recip_sn","text":"hello world!"}`,
  1219. want: `Message sent successfully.`,
  1220. statusCode: http.StatusOK,
  1221. },
  1222. {
  1223. name: "with malformed body",
  1224. body: `{"screen_name":"userA", "password":"thepassword"`,
  1225. want: `malformed input`,
  1226. statusCode: http.StatusBadRequest,
  1227. },
  1228. }
  1229. for _, tc := range tt {
  1230. t.Run(tc.name, func(t *testing.T) {
  1231. request := httptest.NewRequest(http.MethodPost, "/user", strings.NewReader(tc.body))
  1232. responseRecorder := httptest.NewRecorder()
  1233. messageRelayer := newMockMessageRelayer(t)
  1234. for _, params := range tc.relayToScreenNameInputs {
  1235. validateSNAC := func(msg wire.SNACMessage) bool {
  1236. body := msg.Body.(wire.SNAC_0x04_0x07_ICBMChannelMsgToClient)
  1237. assert.Equal(t, params.sender.String(), body.TLVUserInfo.ScreenName)
  1238. b, ok := body.Bytes(wire.ICBMTLVAOLIMData)
  1239. assert.True(t, ok)
  1240. txt, err := wire.UnmarshalICBMMessageText(b)
  1241. assert.NoError(t, err)
  1242. assert.Equal(t, params.msg, txt)
  1243. return true
  1244. }
  1245. messageRelayer.EXPECT().
  1246. RelayToScreenName(mock.Anything, params.recipient, mock.MatchedBy(validateSNAC))
  1247. }
  1248. postInstantMessageHandler(responseRecorder, request, messageRelayer, slog.Default())
  1249. if responseRecorder.Code != tc.statusCode {
  1250. t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1251. }
  1252. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1253. t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
  1254. }
  1255. })
  1256. }
  1257. }
  1258. func TestVersionHandler_GET(t *testing.T) {
  1259. tt := []struct {
  1260. name string
  1261. want string
  1262. statusCode int
  1263. buildInfo config.Build
  1264. }{
  1265. {
  1266. name: "get ras version",
  1267. want: `{"version":"13.3.7","commit":"asdfASDF12345678","date":"2024-03-01"}`,
  1268. statusCode: http.StatusOK,
  1269. buildInfo: config.Build{
  1270. Version: "13.3.7",
  1271. Commit: "asdfASDF12345678",
  1272. Date: "2024-03-01",
  1273. },
  1274. },
  1275. }
  1276. for _, tc := range tt {
  1277. t.Run(tc.name, func(t *testing.T) {
  1278. responseRecorder := httptest.NewRecorder()
  1279. getVersionHandler(responseRecorder, tc.buildInfo)
  1280. if responseRecorder.Code != tc.statusCode {
  1281. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1282. }
  1283. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1284. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1285. }
  1286. })
  1287. }
  1288. }
  1289. func TestDirectoryCategoryHandler_GET(t *testing.T) {
  1290. tt := []struct {
  1291. name string
  1292. want string
  1293. statusCode int
  1294. mockParams mockParams
  1295. }{
  1296. {
  1297. name: "no categories",
  1298. want: `[]`,
  1299. statusCode: http.StatusOK,
  1300. mockParams: mockParams{
  1301. directoryManagerParams: directoryManagerParams{
  1302. categoriesParams: categoriesParams{
  1303. {
  1304. result: nil,
  1305. },
  1306. },
  1307. },
  1308. },
  1309. },
  1310. {
  1311. name: "error fetching categories",
  1312. want: `{"message":"internal server error"}`,
  1313. statusCode: http.StatusInternalServerError,
  1314. mockParams: mockParams{
  1315. directoryManagerParams: directoryManagerParams{
  1316. categoriesParams: categoriesParams{
  1317. {
  1318. result: nil,
  1319. err: errors.New("error fetching categories"),
  1320. },
  1321. },
  1322. },
  1323. },
  1324. },
  1325. {
  1326. name: "fetch some categories",
  1327. want: `[{"id":1,"name":"category-1"},{"id":2,"name":"category-2"}]`,
  1328. statusCode: http.StatusOK,
  1329. mockParams: mockParams{
  1330. directoryManagerParams: directoryManagerParams{
  1331. categoriesParams: categoriesParams{
  1332. {
  1333. result: []state.Category{
  1334. {
  1335. ID: 1,
  1336. Name: "category-1",
  1337. },
  1338. {
  1339. ID: 2,
  1340. Name: "category-2",
  1341. },
  1342. },
  1343. },
  1344. },
  1345. },
  1346. },
  1347. },
  1348. }
  1349. for _, tc := range tt {
  1350. t.Run(tc.name, func(t *testing.T) {
  1351. responseRecorder := httptest.NewRecorder()
  1352. directoryManager := newMockDirectoryManager(t)
  1353. for _, params := range tc.mockParams.categoriesParams {
  1354. directoryManager.EXPECT().
  1355. Categories().
  1356. Return(params.result, params.err)
  1357. }
  1358. getDirectoryCategoryHandler(responseRecorder, directoryManager, slog.Default())
  1359. if responseRecorder.Code != tc.statusCode {
  1360. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1361. }
  1362. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1363. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1364. }
  1365. })
  1366. }
  1367. }
  1368. func TestDirectoryCategoryKeywordHandler_GET(t *testing.T) {
  1369. tt := []struct {
  1370. name string
  1371. categoryID int
  1372. want string
  1373. statusCode int
  1374. mockParams mockParams
  1375. }{
  1376. {
  1377. name: "category not found",
  1378. categoryID: 1,
  1379. want: `{"message":"category not found"}`,
  1380. statusCode: http.StatusNotFound,
  1381. mockParams: mockParams{
  1382. directoryManagerParams: directoryManagerParams{
  1383. keywordsByCategoryParams: keywordsByCategoryParams{
  1384. {
  1385. categoryID: 1,
  1386. result: nil,
  1387. err: state.ErrKeywordCategoryNotFound,
  1388. },
  1389. },
  1390. },
  1391. },
  1392. },
  1393. {
  1394. name: "error fetching keywords by category",
  1395. categoryID: 1,
  1396. want: `{"message":"internal server error"}`,
  1397. statusCode: http.StatusInternalServerError,
  1398. mockParams: mockParams{
  1399. directoryManagerParams: directoryManagerParams{
  1400. keywordsByCategoryParams: keywordsByCategoryParams{
  1401. {
  1402. categoryID: 1,
  1403. result: nil,
  1404. err: errors.New("error fetching keywords by category"),
  1405. },
  1406. },
  1407. },
  1408. },
  1409. },
  1410. {
  1411. name: "invalid category ID",
  1412. categoryID: -1,
  1413. want: `{"message":"invalid category ID"}`,
  1414. statusCode: http.StatusBadRequest,
  1415. mockParams: mockParams{
  1416. directoryManagerParams: directoryManagerParams{
  1417. keywordsByCategoryParams: keywordsByCategoryParams{},
  1418. },
  1419. },
  1420. },
  1421. {
  1422. name: "no keywords",
  1423. categoryID: 1,
  1424. want: `[]`,
  1425. statusCode: http.StatusOK,
  1426. mockParams: mockParams{
  1427. directoryManagerParams: directoryManagerParams{
  1428. keywordsByCategoryParams: keywordsByCategoryParams{
  1429. {
  1430. categoryID: 1,
  1431. result: nil,
  1432. },
  1433. },
  1434. },
  1435. },
  1436. },
  1437. {
  1438. name: "fetch some keywords by category",
  1439. categoryID: 1,
  1440. want: `[{"id":1,"name":"keyword-1"},{"id":2,"name":"keyword-2"}]`,
  1441. statusCode: http.StatusOK,
  1442. mockParams: mockParams{
  1443. directoryManagerParams: directoryManagerParams{
  1444. keywordsByCategoryParams: keywordsByCategoryParams{
  1445. {
  1446. categoryID: 1,
  1447. result: []state.Keyword{
  1448. {
  1449. ID: 1,
  1450. Name: "keyword-1",
  1451. },
  1452. {
  1453. ID: 2,
  1454. Name: "keyword-2",
  1455. },
  1456. },
  1457. },
  1458. },
  1459. },
  1460. },
  1461. },
  1462. }
  1463. for _, tc := range tt {
  1464. t.Run(tc.name, func(t *testing.T) {
  1465. request := httptest.NewRequest(http.MethodGet, fmt.Sprintf("/directory/category/%d/keyword", tc.categoryID), nil)
  1466. request.SetPathValue("id", fmt.Sprintf("%d", tc.categoryID))
  1467. responseRecorder := httptest.NewRecorder()
  1468. directoryManager := newMockDirectoryManager(t)
  1469. for _, params := range tc.mockParams.keywordsByCategoryParams {
  1470. directoryManager.EXPECT().
  1471. KeywordsByCategory(params.categoryID).
  1472. Return(params.result, params.err)
  1473. }
  1474. getDirectoryCategoryKeywordHandler(responseRecorder, request, directoryManager, slog.Default())
  1475. if responseRecorder.Code != tc.statusCode {
  1476. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1477. }
  1478. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1479. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1480. }
  1481. })
  1482. }
  1483. }
  1484. func TestDirectoryCategoryHandler_DELETE(t *testing.T) {
  1485. tt := []struct {
  1486. name string
  1487. categoryID int
  1488. want string
  1489. statusCode int
  1490. mockParams mockParams
  1491. }{
  1492. {
  1493. name: "category not found",
  1494. categoryID: 1,
  1495. want: `{"message":"category not found"}`,
  1496. statusCode: http.StatusNotFound,
  1497. mockParams: mockParams{
  1498. directoryManagerParams: directoryManagerParams{
  1499. deleteCategoryParams: deleteCategoryParams{
  1500. {
  1501. categoryID: 1,
  1502. err: state.ErrKeywordCategoryNotFound,
  1503. },
  1504. },
  1505. },
  1506. },
  1507. },
  1508. {
  1509. name: "keyword in use by user",
  1510. categoryID: 1,
  1511. want: `{"message":"can't delete because category in use by a user"}`,
  1512. statusCode: http.StatusConflict,
  1513. mockParams: mockParams{
  1514. directoryManagerParams: directoryManagerParams{
  1515. deleteCategoryParams: deleteCategoryParams{
  1516. {
  1517. categoryID: 1,
  1518. err: state.ErrKeywordInUse,
  1519. },
  1520. },
  1521. },
  1522. },
  1523. },
  1524. {
  1525. name: "runtime error",
  1526. categoryID: 1,
  1527. want: `{"message":"internal server error"}`,
  1528. statusCode: http.StatusInternalServerError,
  1529. mockParams: mockParams{
  1530. directoryManagerParams: directoryManagerParams{
  1531. deleteCategoryParams: deleteCategoryParams{
  1532. {
  1533. categoryID: 1,
  1534. err: errors.New("error deleting keyword"),
  1535. },
  1536. },
  1537. },
  1538. },
  1539. },
  1540. {
  1541. name: "successful deletion",
  1542. categoryID: 1,
  1543. want: ``,
  1544. statusCode: http.StatusNoContent,
  1545. mockParams: mockParams{
  1546. directoryManagerParams: directoryManagerParams{
  1547. deleteCategoryParams: deleteCategoryParams{
  1548. {
  1549. categoryID: 1,
  1550. },
  1551. },
  1552. },
  1553. },
  1554. },
  1555. {
  1556. name: "invalid category ID",
  1557. categoryID: -1,
  1558. want: `invalid category ID`,
  1559. statusCode: http.StatusBadRequest,
  1560. mockParams: mockParams{
  1561. directoryManagerParams: directoryManagerParams{
  1562. deleteCategoryParams: deleteCategoryParams{},
  1563. },
  1564. },
  1565. },
  1566. }
  1567. for _, tc := range tt {
  1568. t.Run(tc.name, func(t *testing.T) {
  1569. request := httptest.NewRequest(http.MethodDelete, fmt.Sprintf("/directory/category/%d/keyword", tc.categoryID), nil)
  1570. request.SetPathValue("id", fmt.Sprintf("%d", tc.categoryID))
  1571. responseRecorder := httptest.NewRecorder()
  1572. directoryManager := newMockDirectoryManager(t)
  1573. for _, params := range tc.mockParams.deleteCategoryParams {
  1574. directoryManager.EXPECT().
  1575. DeleteCategory(params.categoryID).
  1576. Return(params.err)
  1577. }
  1578. deleteDirectoryCategoryHandler(responseRecorder, request, directoryManager, slog.Default())
  1579. if responseRecorder.Code != tc.statusCode {
  1580. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1581. }
  1582. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1583. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1584. }
  1585. })
  1586. }
  1587. }
  1588. func TestDirectoryCategoryHandler_POST(t *testing.T) {
  1589. tt := []struct {
  1590. name string
  1591. body string
  1592. want string
  1593. statusCode int
  1594. mockParams mockParams
  1595. }{
  1596. {
  1597. name: "category already exists",
  1598. body: `{"name":"the_category"}`,
  1599. want: `{"message":"category already exists"}`,
  1600. statusCode: http.StatusConflict,
  1601. mockParams: mockParams{
  1602. directoryManagerParams: directoryManagerParams{
  1603. createCategoryParams: createCategoryParams{
  1604. {
  1605. name: "the_category",
  1606. err: state.ErrKeywordCategoryExists,
  1607. },
  1608. },
  1609. },
  1610. },
  1611. },
  1612. {
  1613. name: "runtime error",
  1614. body: `{"name":"the_category"}`,
  1615. want: `{"message":"internal server error"}`,
  1616. statusCode: http.StatusInternalServerError,
  1617. mockParams: mockParams{
  1618. directoryManagerParams: directoryManagerParams{
  1619. createCategoryParams: createCategoryParams{
  1620. {
  1621. name: "the_category",
  1622. err: errors.New("error creating category"),
  1623. },
  1624. },
  1625. },
  1626. },
  1627. },
  1628. {
  1629. name: "bad input",
  1630. body: `{"name":"the_category"`,
  1631. want: `{"message":"malformed input"}`,
  1632. statusCode: http.StatusBadRequest,
  1633. mockParams: mockParams{
  1634. directoryManagerParams: directoryManagerParams{
  1635. createCategoryParams: createCategoryParams{},
  1636. },
  1637. },
  1638. },
  1639. {
  1640. name: "successful creation",
  1641. body: `{"name":"the_category"}`,
  1642. want: `{"id":1,"name":"the_category"}`,
  1643. statusCode: http.StatusCreated,
  1644. mockParams: mockParams{
  1645. directoryManagerParams: directoryManagerParams{
  1646. createCategoryParams: createCategoryParams{
  1647. {
  1648. name: "the_category",
  1649. result: state.Category{
  1650. ID: 1,
  1651. Name: "the_category",
  1652. },
  1653. },
  1654. },
  1655. },
  1656. },
  1657. },
  1658. }
  1659. for _, tc := range tt {
  1660. t.Run(tc.name, func(t *testing.T) {
  1661. request := httptest.NewRequest(http.MethodPost, "/directory/category", strings.NewReader(tc.body))
  1662. responseRecorder := httptest.NewRecorder()
  1663. directoryManager := newMockDirectoryManager(t)
  1664. for _, params := range tc.mockParams.createCategoryParams {
  1665. directoryManager.EXPECT().
  1666. CreateCategory(params.name).
  1667. Return(params.result, params.err)
  1668. }
  1669. postDirectoryCategoryHandler(responseRecorder, request, directoryManager, slog.Default())
  1670. if responseRecorder.Code != tc.statusCode {
  1671. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1672. }
  1673. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1674. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1675. }
  1676. })
  1677. }
  1678. }
  1679. func TestDirectoryKeywordHandler_POST(t *testing.T) {
  1680. tt := []struct {
  1681. name string
  1682. body string
  1683. want string
  1684. statusCode int
  1685. mockParams mockParams
  1686. }{
  1687. {
  1688. name: "keyword already exists",
  1689. body: `{"category_id":1,"name":"the_keyword"}`,
  1690. want: `{"message":"keyword already exists"}`,
  1691. statusCode: http.StatusConflict,
  1692. mockParams: mockParams{
  1693. directoryManagerParams: directoryManagerParams{
  1694. createKeywordParams: createKeywordParams{
  1695. {
  1696. name: "the_keyword",
  1697. categoryID: 1,
  1698. err: state.ErrKeywordExists,
  1699. },
  1700. },
  1701. },
  1702. },
  1703. },
  1704. {
  1705. name: "category not found",
  1706. body: `{"category_id":1,"name":"the_keyword"}`,
  1707. want: `{"message":"category not found"}`,
  1708. statusCode: http.StatusNotFound,
  1709. mockParams: mockParams{
  1710. directoryManagerParams: directoryManagerParams{
  1711. createKeywordParams: createKeywordParams{
  1712. {
  1713. name: "the_keyword",
  1714. categoryID: 1,
  1715. err: state.ErrKeywordCategoryNotFound,
  1716. },
  1717. },
  1718. },
  1719. },
  1720. },
  1721. {
  1722. name: "runtime error",
  1723. body: `{"category_id":1,"name":"the_keyword"}`,
  1724. want: `{"message":"internal server error"}`,
  1725. statusCode: http.StatusInternalServerError,
  1726. mockParams: mockParams{
  1727. directoryManagerParams: directoryManagerParams{
  1728. createKeywordParams: createKeywordParams{
  1729. {
  1730. name: "the_keyword",
  1731. categoryID: 1,
  1732. err: errors.New("error creating keyword"),
  1733. },
  1734. },
  1735. },
  1736. },
  1737. },
  1738. {
  1739. name: "bad input",
  1740. body: `{"category_id":1,"name":"the_keyword"`,
  1741. want: `{"message":"malformed input"}`,
  1742. statusCode: http.StatusBadRequest,
  1743. mockParams: mockParams{
  1744. directoryManagerParams: directoryManagerParams{
  1745. createKeywordParams: createKeywordParams{},
  1746. },
  1747. },
  1748. },
  1749. {
  1750. name: "successful creation",
  1751. body: `{"category_id":1,"name":"the_keyword"}`,
  1752. want: `{"id":1,"name":"the_keyword"}`,
  1753. statusCode: http.StatusCreated,
  1754. mockParams: mockParams{
  1755. directoryManagerParams: directoryManagerParams{
  1756. createKeywordParams: createKeywordParams{
  1757. {
  1758. name: "the_keyword",
  1759. categoryID: 1,
  1760. result: state.Keyword{
  1761. ID: 1,
  1762. Name: "the_keyword",
  1763. },
  1764. },
  1765. },
  1766. },
  1767. },
  1768. },
  1769. }
  1770. for _, tc := range tt {
  1771. t.Run(tc.name, func(t *testing.T) {
  1772. request := httptest.NewRequest(http.MethodPost, "/directory/keyword", strings.NewReader(tc.body))
  1773. responseRecorder := httptest.NewRecorder()
  1774. directoryManager := newMockDirectoryManager(t)
  1775. for _, params := range tc.mockParams.createKeywordParams {
  1776. directoryManager.EXPECT().
  1777. CreateKeyword(params.name, params.categoryID).
  1778. Return(params.result, params.err)
  1779. }
  1780. postDirectoryKeywordHandler(responseRecorder, request, directoryManager, slog.Default())
  1781. if responseRecorder.Code != tc.statusCode {
  1782. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1783. }
  1784. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1785. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1786. }
  1787. })
  1788. }
  1789. }
  1790. func TestDirectoryKeywordHandler_DELETE(t *testing.T) {
  1791. tt := []struct {
  1792. name string
  1793. categoryID int
  1794. want string
  1795. statusCode int
  1796. mockParams mockParams
  1797. }{
  1798. {
  1799. name: "keyword not found",
  1800. categoryID: 1,
  1801. want: `{"message":"keyword not found"}`,
  1802. statusCode: http.StatusNotFound,
  1803. mockParams: mockParams{
  1804. directoryManagerParams: directoryManagerParams{
  1805. deleteKeywordParams: deleteKeywordParams{
  1806. {
  1807. id: 1,
  1808. err: state.ErrKeywordNotFound,
  1809. },
  1810. },
  1811. },
  1812. },
  1813. },
  1814. {
  1815. name: "keyword in use by user",
  1816. categoryID: 1,
  1817. want: `{"message":"can't delete because category in use by a user"}`,
  1818. statusCode: http.StatusConflict,
  1819. mockParams: mockParams{
  1820. directoryManagerParams: directoryManagerParams{
  1821. deleteKeywordParams: deleteKeywordParams{
  1822. {
  1823. id: 1,
  1824. err: state.ErrKeywordInUse,
  1825. },
  1826. },
  1827. },
  1828. },
  1829. },
  1830. {
  1831. name: "runtime error",
  1832. categoryID: 1,
  1833. want: `{"message":"internal server error"}`,
  1834. statusCode: http.StatusInternalServerError,
  1835. mockParams: mockParams{
  1836. directoryManagerParams: directoryManagerParams{
  1837. deleteKeywordParams: deleteKeywordParams{
  1838. {
  1839. id: 1,
  1840. err: errors.New("error deleting keyword"),
  1841. },
  1842. },
  1843. },
  1844. },
  1845. },
  1846. {
  1847. name: "successful deletion",
  1848. categoryID: 1,
  1849. want: ``,
  1850. statusCode: http.StatusNoContent,
  1851. mockParams: mockParams{
  1852. directoryManagerParams: directoryManagerParams{
  1853. deleteKeywordParams: deleteKeywordParams{
  1854. {
  1855. id: 1,
  1856. },
  1857. },
  1858. },
  1859. },
  1860. },
  1861. {
  1862. name: "invalid keyword ID",
  1863. categoryID: -1,
  1864. want: `{"message":"invalid keyword ID"}`,
  1865. statusCode: http.StatusBadRequest,
  1866. mockParams: mockParams{
  1867. directoryManagerParams: directoryManagerParams{
  1868. deleteKeywordParams: deleteKeywordParams{},
  1869. },
  1870. },
  1871. },
  1872. }
  1873. for _, tc := range tt {
  1874. t.Run(tc.name, func(t *testing.T) {
  1875. request := httptest.NewRequest(http.MethodDelete, fmt.Sprintf("/directory/keyword/%d", tc.categoryID), nil)
  1876. request.SetPathValue("id", fmt.Sprintf("%d", tc.categoryID))
  1877. responseRecorder := httptest.NewRecorder()
  1878. directoryManager := newMockDirectoryManager(t)
  1879. for _, params := range tc.mockParams.deleteKeywordParams {
  1880. directoryManager.EXPECT().
  1881. DeleteKeyword(params.id).
  1882. Return(params.err)
  1883. }
  1884. deleteDirectoryKeywordHandler(responseRecorder, request, directoryManager, slog.Default())
  1885. if responseRecorder.Code != tc.statusCode {
  1886. t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
  1887. }
  1888. if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
  1889. t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
  1890. }
  1891. })
  1892. }
  1893. }