| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020 |
- package http
- import (
- "errors"
- "fmt"
- "io"
- "log/slog"
- "net/http"
- "net/http/httptest"
- "net/mail"
- "strings"
- "testing"
- "time"
- "github.com/google/uuid"
- "github.com/stretchr/testify/assert"
- "github.com/stretchr/testify/mock"
- "github.com/mk6i/retro-aim-server/config"
- "github.com/mk6i/retro-aim-server/state"
- "github.com/mk6i/retro-aim-server/wire"
- )
- func TestSessionHandler_GET(t *testing.T) {
- fnNewSess := func(screenName string, uin uint32) *state.Session {
- sess := state.NewSession()
- sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
- sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
- sess.SetUIN(uin)
- return sess
- }
- tt := []struct {
- name string
- want string
- statusCode int
- timeSinceFunc func(t time.Time) time.Duration
- mockParams mockParams
- }{
- {
- name: "without sessions",
- want: `{"count":0,"sessions":[]}`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- sessionRetrieverParams: sessionRetrieverParams{
- sessionRetrieverAllSessionsParams: sessionRetrieverAllSessionsParams{
- {
- result: []*state.Session{},
- },
- },
- },
- },
- },
- {
- name: "with sessions",
- 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}]}`,
- statusCode: http.StatusOK,
- timeSinceFunc: func(t time.Time) time.Duration { t0 := time.Now(); return t0.Sub(t0) },
- mockParams: mockParams{
- sessionRetrieverParams: sessionRetrieverParams{
- sessionRetrieverAllSessionsParams: sessionRetrieverAllSessionsParams{
- {
- result: []*state.Session{
- fnNewSess("userA", 0),
- fnNewSess("userB", 0),
- fnNewSess("100003", 100003),
- },
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodGet, "/session", nil)
- responseRecorder := httptest.NewRecorder()
- sessionRetriever := newMockSessionRetriever(t)
- for _, params := range tc.mockParams.sessionRetrieverParams.sessionRetrieverAllSessionsParams {
- sessionRetriever.EXPECT().
- AllSessions().
- Return(params.result)
- }
- getSessionHandler(responseRecorder, request, sessionRetriever, tc.timeSinceFunc)
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestSessionHandlerScreenname_GET(t *testing.T) {
- fnNewSess := func(screenName string, uin uint32) *state.Session {
- sess := state.NewSession()
- sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
- sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
- sess.SetUIN(uin)
- return sess
- }
- tt := []struct {
- name string
- sessions []*state.Session
- requestScreenName state.IdentScreenName
- want string
- statusCode int
- timeSinceFunc func(t time.Time) time.Duration
- mockParams mockParams
- }{
- {
- name: "no session for screenname",
- sessions: []*state.Session{},
- requestScreenName: state.NewIdentScreenName("userA"),
- want: `session not found`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- sessionRetrieverParams: sessionRetrieverParams{
- retrieveSessionByNameParams: retrieveSessionByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: nil,
- },
- },
- },
- },
- },
- {
- name: "active session found for screenname",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: `{"count":1,"sessions":[{"id":"usera","screen_name":"userA","online_seconds":0,"away_message":"","idle_seconds":0,"is_icq":false}]}`,
- statusCode: http.StatusOK,
- timeSinceFunc: func(t time.Time) time.Duration { t0 := time.Now(); return t0.Sub(t0) },
- mockParams: mockParams{
- sessionRetrieverParams: sessionRetrieverParams{
- retrieveSessionByNameParams: retrieveSessionByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: fnNewSess("userA", 0),
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodGet, "/session/"+tc.requestScreenName.String(), nil)
- request.SetPathValue("screenname", tc.requestScreenName.String())
- responseRecorder := httptest.NewRecorder()
- sessionRetriever := newMockSessionRetriever(t)
- for _, params := range tc.mockParams.sessionRetrieverParams.retrieveSessionByNameParams {
- sessionRetriever.EXPECT().
- RetrieveSession(params.screenName).
- Return(params.result)
- }
- getSessionHandler(responseRecorder, request, sessionRetriever, tc.timeSinceFunc)
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestUserAccountHandler_GET(t *testing.T) {
- tt := []struct {
- name string
- requestScreenName state.IdentScreenName
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "invalid account",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: `user not found`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: nil,
- },
- },
- },
- },
- },
- {
- name: "valid aim account",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: `{"id":"usera","screen_name":"userA","profile":"My Profile Text","email_address":"\u003cuserA@aol.com\u003e","reg_status":2,"confirmed":true,"is_icq":false}`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &state.User{
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- },
- },
- },
- accountRetrieverParams: accountRetrieverParams{
- emailAddressByNameParams: emailAddressByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &mail.Address{
- Address: "userA@aol.com",
- },
- },
- },
- regStatusByNameParams: regStatusByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: uint16(0x02),
- },
- },
- confirmStatusByNameParams: confirmStatusByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: true,
- },
- },
- },
- profileRetrieverParams: profileRetrieverParams{
- retrieveProfileParams: retrieveProfileParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: "My Profile Text",
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodGet, "/user/"+tc.requestScreenName.String()+"/account", nil)
- request.SetPathValue("screenname", tc.requestScreenName.String())
- responseRecorder := httptest.NewRecorder()
- userManager := newMockUserManager(t)
- for _, params := range tc.mockParams.userManagerParams.getUserParams {
- userManager.EXPECT().
- User(params.screenName).
- Return(params.result, params.err)
- }
- accountRetriever := newMockAccountRetriever(t)
- for _, params := range tc.mockParams.accountRetrieverParams.emailAddressByNameParams {
- accountRetriever.EXPECT().
- EmailAddressByName(params.screenName).
- Return(params.result, params.err)
- }
- for _, params := range tc.mockParams.accountRetrieverParams.regStatusByNameParams {
- accountRetriever.EXPECT().
- RegStatusByName(params.screenName).
- Return(params.result, params.err)
- }
- for _, params := range tc.mockParams.accountRetrieverParams.confirmStatusByNameParams {
- accountRetriever.EXPECT().
- ConfirmStatusByName(params.screenName).
- Return(params.result, params.err)
- }
- profileRetriever := newMockProfileRetriever(t)
- for _, params := range tc.mockParams.profileRetrieverParams.retrieveProfileParams {
- profileRetriever.EXPECT().
- Profile(params.screenName).
- Return(params.result, params.err)
- }
- getUserAccountHandler(responseRecorder, request, userManager, accountRetriever, profileRetriever, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestUserBuddyIconHandler_GET(t *testing.T) {
- sampleGIF := []byte{
- 0x47, 0x49, 0x46, 0x38, 0x39, 0x61, 0x32, 0x00, 0x32, 0x00, 0x80, 0x00, 0x00, 0x00, 0x00, 0x00,
- 0x00, 0x00, 0x00, 0x21, 0xf9, 0x04, 0x01, 0x00, 0x00, 0x00, 0x00, 0x2c, 0x00, 0x00, 0x00, 0x00,
- 0x32, 0x00, 0x32, 0x00, 0x00, 0x02, 0x02, 0x44, 0x01, 0x00, 0x3b}
- sampleJPG := []byte{0xFF, 0xD8, 0xFF, 0x43, 0x13, 0x37}
- tt := []struct {
- name string
- requestScreenName state.IdentScreenName
- want string
- statusCode int
- contentType string
- mockParams mockParams
- }{
- {
- name: "invalid account",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: `user not found`,
- statusCode: http.StatusNotFound,
- contentType: "text/plain; charset=utf-8",
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: nil,
- },
- },
- },
- },
- },
- {
- name: "account with gif buddy icon",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: string(sampleGIF),
- statusCode: http.StatusOK,
- contentType: "image/gif",
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &state.User{
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- },
- },
- },
- feedBagRetrieverParams: feedBagRetrieverParams{
- buddyIconRefByNameParams: buddyIconRefByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &wire.BARTID{
- Type: wire.BARTTypesBuddyIcon,
- BARTInfo: wire.BARTInfo{
- Flags: 0x00,
- Hash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
- },
- },
- },
- },
- },
- bartRetrieverParams: bartRetrieverParams{
- bartRetrieveParams: bartRetrieveParams{
- {
- itemHash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
- result: sampleGIF,
- },
- },
- },
- },
- },
- {
- name: "account with jpg buddy icon",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: string(sampleJPG),
- statusCode: http.StatusOK,
- contentType: "image/jpeg",
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &state.User{
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- },
- },
- },
- feedBagRetrieverParams: feedBagRetrieverParams{
- buddyIconRefByNameParams: buddyIconRefByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &wire.BARTID{
- Type: wire.BARTTypesBuddyIcon,
- BARTInfo: wire.BARTInfo{
- Flags: 0x00,
- Hash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
- },
- },
- },
- },
- },
- bartRetrieverParams: bartRetrieverParams{
- bartRetrieveParams: bartRetrieveParams{
- {
- itemHash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
- result: sampleJPG,
- },
- },
- },
- },
- },
- {
- name: "account with unknown format buddy icon",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: string([]byte{0x13, 0x37, 0x13, 0x37, 0x13, 0x37}),
- statusCode: http.StatusOK,
- contentType: "application/octet-stream",
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &state.User{
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- },
- },
- },
- feedBagRetrieverParams: feedBagRetrieverParams{
- buddyIconRefByNameParams: buddyIconRefByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &wire.BARTID{
- Type: wire.BARTTypesBuddyIcon,
- BARTInfo: wire.BARTInfo{
- Flags: 0x00,
- Hash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
- },
- },
- },
- },
- },
- bartRetrieverParams: bartRetrieverParams{
- bartRetrieveParams: bartRetrieveParams{
- {
- itemHash: []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'},
- result: []byte{0x13, 0x37, 0x13, 0x37, 0x13, 0x37},
- },
- },
- },
- },
- },
- {
- name: "account with cleared buddy icon",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: "icon not found",
- statusCode: http.StatusNotFound,
- contentType: "text/plain; charset=utf-8",
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &state.User{
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- },
- },
- },
- feedBagRetrieverParams: feedBagRetrieverParams{
- buddyIconRefByNameParams: buddyIconRefByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &wire.BARTID{
- Type: wire.BARTTypesBuddyIcon,
- BARTInfo: wire.BARTInfo{
- Flags: 0x00,
- Hash: wire.GetClearIconHash(),
- },
- },
- },
- },
- },
- },
- },
- {
- name: "account with no buddy icon",
- requestScreenName: state.NewIdentScreenName("userA"),
- want: "icon not found",
- statusCode: http.StatusNotFound,
- contentType: "text/plain; charset=utf-8",
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- getUserParams: getUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: &state.User{
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- },
- },
- },
- feedBagRetrieverParams: feedBagRetrieverParams{
- buddyIconRefByNameParams: buddyIconRefByNameParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- result: nil,
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodGet, "/user/"+tc.requestScreenName.String()+"/icon", nil)
- request.SetPathValue("screenname", tc.requestScreenName.String())
- responseRecorder := httptest.NewRecorder()
- userManager := newMockUserManager(t)
- for _, params := range tc.mockParams.userManagerParams.getUserParams {
- userManager.EXPECT().
- User(params.screenName).
- Return(params.result, params.err)
- }
- feedbagRetriever := newMockFeedBagRetriever(t)
- for _, params := range tc.mockParams.feedBagRetrieverParams.buddyIconRefByNameParams {
- feedbagRetriever.EXPECT().
- BuddyIconRefByName(params.screenName).
- Return(params.result, params.err)
- }
- bartRetriever := newMockBARTRetriever(t)
- for _, params := range tc.mockParams.bartRetrieverParams.bartRetrieveParams {
- bartRetriever.EXPECT().
- BARTRetrieve(params.itemHash).
- Return(params.result, params.err)
- }
- getUserBuddyIconHandler(responseRecorder, request, userManager, feedbagRetriever, bartRetriever, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- contentType := responseRecorder.Header().Get("Content-Type")
- if contentType != tc.contentType {
- t.Errorf("Want content type '%s', got '%s'", tc.contentType, contentType)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestUserHandler_GET(t *testing.T) {
- tt := []struct {
- name string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "empty user store",
- want: `[]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- allUsersParams: allUsersParams{
- {
- result: []state.User{},
- },
- },
- },
- },
- },
- {
- name: "user store containing 3 users",
- 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}]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- allUsersParams: allUsersParams{
- {
- result: []state.User{
- {
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- {
- DisplayScreenName: "userB",
- IdentScreenName: state.NewIdentScreenName("userB"),
- },
- {
- DisplayScreenName: "100003",
- IdentScreenName: state.NewIdentScreenName("100003"),
- IsICQ: true,
- },
- },
- },
- },
- },
- },
- },
- {
- name: "user handler error",
- want: `internal server error`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- allUsersParams: allUsersParams{
- {
- result: []state.User{},
- err: io.EOF,
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- responseRecorder := httptest.NewRecorder()
- userManager := newMockUserManager(t)
- for _, params := range tc.mockParams.userManagerParams.allUsersParams {
- userManager.EXPECT().
- AllUsers().
- Return(params.result, params.err)
- }
- getUserHandler(responseRecorder, userManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestUserHandler_POST(t *testing.T) {
- tt := []struct {
- name string
- body string
- UUID uuid.UUID
- want string
- password string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "with valid AIM user",
- body: `{"screen_name":"userA", "password":"thepassword"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `User account created successfully.`,
- password: "thepassword",
- statusCode: http.StatusCreated,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- insertUserParams: insertUserParams{
- {
- u: state.User{
- AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- err: nil,
- },
- },
- },
- },
- },
- {
- name: "with valid ICQ user",
- body: `{"screen_name":"100003", "password":"thepass"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `User account created successfully.`,
- password: "thepass",
- statusCode: http.StatusCreated,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- insertUserParams: insertUserParams{
- {
- u: state.User{
- AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
- DisplayScreenName: "100003",
- IdentScreenName: state.NewIdentScreenName("100003"),
- IsICQ: true,
- },
- err: nil,
- },
- },
- },
- },
- },
- {
- name: "with malformed body",
- body: `{"screen_name":"userA", "password":"thepassword"`, // missing closing }
- want: `malformed input`,
- statusCode: http.StatusBadRequest,
- },
- {
- name: "user handler error",
- body: `{"screen_name":"userA", "password":"thepassword"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `internal server error`,
- password: "thepassword",
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- insertUserParams: insertUserParams{
- {
- u: state.User{
- AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- err: io.EOF,
- },
- },
- },
- },
- },
- {
- name: "duplicate user",
- body: `{"screen_name":"userA", "password":"thepassword"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `user already exists`,
- password: "thepassword",
- statusCode: http.StatusConflict,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- insertUserParams: insertUserParams{
- {
- u: state.User{
- AuthKey: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b").String(),
- DisplayScreenName: "userA",
- IdentScreenName: state.NewIdentScreenName("userA"),
- },
- err: state.ErrDupUser,
- },
- },
- },
- },
- },
- {
- name: "invalid AIM screen name",
- body: `{"screen_name":"a", "password":"thepassword"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `invalid screen name: screen name must be between 3 and 16 characters`,
- statusCode: http.StatusBadRequest,
- },
- {
- name: "invalid AIM password",
- body: `{"screen_name":"userA", "password":"1"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `invalid password: invalid password length: password length must be between 4-16 characters`,
- statusCode: http.StatusBadRequest,
- },
- {
- name: "invalid ICQ UIN",
- body: `{"screen_name":"1000", "password":"thepass"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `invalid uin: uin must be a number in the range 10000-2147483646`,
- statusCode: http.StatusBadRequest,
- },
- {
- name: "invalid ICQ password",
- body: `{"screen_name":"100003", "password":"thelongpassword"}`,
- UUID: uuid.MustParse("07c70701-ba68-49a9-9f9b-67a53816e37b"),
- want: `invalid password: invalid password length: password must be between 6-8 characters`,
- statusCode: http.StatusBadRequest,
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodPost, "/user", strings.NewReader(tc.body))
- responseRecorder := httptest.NewRecorder()
- userManager := newMockUserManager(t)
- for _, params := range tc.mockParams.userManagerParams.insertUserParams {
- assert.NoError(t, params.u.HashPassword(tc.password))
- userManager.EXPECT().
- InsertUser(params.u).
- Return(params.err)
- }
- newUUID := func() uuid.UUID { return tc.UUID }
- postUserHandler(responseRecorder, request, userManager, newUUID, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestUserHandler_DELETE(t *testing.T) {
- tt := []struct {
- name string
- body string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "with valid user",
- body: `{"screen_name":"userA"}`,
- want: `User account successfully deleted.`,
- statusCode: http.StatusNoContent,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- deleteUserParams: deleteUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- },
- },
- },
- },
- },
- {
- name: "with non-existent user",
- body: `{"screen_name":"userA"}`,
- want: `user does not exist`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- deleteUserParams: deleteUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- err: state.ErrNoUser,
- },
- },
- },
- },
- },
- {
- name: "with malformed body",
- body: `{"screen_name":"userA"`, // missing closing }
- want: `malformed input`,
- statusCode: http.StatusBadRequest,
- },
- {
- name: "user handler error",
- body: `{"screen_name":"userA"}`,
- want: `internal server error`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- deleteUserParams: deleteUserParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- err: io.EOF,
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodDelete, "/user", strings.NewReader(tc.body))
- responseRecorder := httptest.NewRecorder()
- userManager := newMockUserManager(t)
- for _, params := range tc.mockParams.userManagerParams.deleteUserParams {
- userManager.EXPECT().
- DeleteUser(params.screenName).
- Return(params.err)
- }
- deleteUserHandler(responseRecorder, request, userManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestUserPasswordHandler_PUT(t *testing.T) {
- tt := []struct {
- name string
- body string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "user with valid password",
- body: `{"screen_name":"userA", "password":"thenewpassword"}`,
- want: `Password successfully reset.`,
- statusCode: http.StatusNoContent,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- setUserPasswordParams: setUserPasswordParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- newPassword: "thenewpassword",
- },
- },
- },
- },
- },
- {
- name: "user with invalid password",
- body: `{"screen_name":"userA", "password":"a"}`,
- want: `invalid password length`,
- statusCode: http.StatusBadRequest,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- setUserPasswordParams: setUserPasswordParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- newPassword: "a",
- err: state.ErrPasswordInvalid,
- },
- },
- },
- },
- },
- {
- name: "with malformed body",
- body: `{"screen_name":"userA", "password":"thepassword"`, // missing closing }
- want: `malformed input`,
- statusCode: http.StatusBadRequest,
- },
- {
- name: "password updater returns runtime error",
- body: `{"screen_name":"userA", "password":"thepassword"}`,
- want: `internal server error`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- setUserPasswordParams: setUserPasswordParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- newPassword: "thepassword",
- err: io.EOF,
- },
- },
- },
- },
- },
- {
- name: "user doesn't exist",
- body: `{"screen_name":"userA", "password":"thepassword"}`,
- want: `user does not exist`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- userManagerParams: userManagerParams{
- setUserPasswordParams: setUserPasswordParams{
- {
- screenName: state.NewIdentScreenName("userA"),
- newPassword: "thepassword",
- err: state.ErrNoUser,
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodPut, "/user", strings.NewReader(tc.body))
- responseRecorder := httptest.NewRecorder()
- userManager := newMockUserManager(t)
- for _, params := range tc.mockParams.userManagerParams.setUserPasswordParams {
- userManager.EXPECT().
- SetUserPassword(params.screenName, params.newPassword).
- Return(params.err)
- }
- putUserPasswordHandler(responseRecorder, request, userManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestPublicChatHandler_GET(t *testing.T) {
- fnNewSess := func(screenName string) *state.Session {
- sess := state.NewSession()
- sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
- sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
- return sess
- }
- chatRoom1 := state.NewChatRoom("chat-room-1-name", state.NewIdentScreenName("chat-room-1-creator"), state.PublicExchange)
- chatRoom2 := state.NewChatRoom("chat-room-2-name", state.NewIdentScreenName("chat-room-1-creator"), state.PublicExchange)
- tt := []struct {
- name string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "multiple chat rooms with participants",
- 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"}]}]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- chatRoomRetrieverParams: chatRoomRetrieverParams{
- allChatRoomsParams: allChatRoomsParams{
- {
- exchange: state.PublicExchange,
- result: []state.ChatRoom{
- chatRoom1,
- chatRoom2,
- },
- },
- },
- },
- chatSessionRetrieverParams: chatSessionRetrieverParams{
- chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
- {
- cookie: chatRoom1.Cookie(),
- result: []*state.Session{
- fnNewSess("userA"),
- fnNewSess("userB"),
- },
- },
- {
- cookie: chatRoom2.Cookie(),
- result: []*state.Session{
- fnNewSess("userC"),
- fnNewSess("userD"),
- },
- },
- },
- },
- },
- },
- {
- name: "chat room without participants",
- want: `[{"name":"chat-room-1-name","create_time":"0001-01-01T00:00:00Z","url":"aim:gochat?roomname=chat-room-1-name&exchange=5","participants":[]}]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- chatRoomRetrieverParams: chatRoomRetrieverParams{
- allChatRoomsParams: allChatRoomsParams{
- {
- exchange: state.PublicExchange,
- result: []state.ChatRoom{
- chatRoom1,
- },
- },
- },
- },
- chatSessionRetrieverParams: chatSessionRetrieverParams{
- chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
- {
- cookie: chatRoom1.Cookie(),
- result: []*state.Session{},
- },
- },
- },
- },
- },
- {
- name: "no chat rooms",
- want: `[]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- chatRoomRetrieverParams: chatRoomRetrieverParams{
- allChatRoomsParams: allChatRoomsParams{
- {
- exchange: state.PublicExchange,
- result: []state.ChatRoom{},
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodGet, "/chat/room/public", nil)
- responseRecorder := httptest.NewRecorder()
- chatRoomRetriever := newMockChatRoomRetriever(t)
- for _, params := range tc.mockParams.chatRoomRetrieverParams.allChatRoomsParams {
- chatRoomRetriever.EXPECT().
- AllChatRooms(params.exchange).
- Return(params.result, params.err)
- }
- chatSessionRetriever := newMockChatSessionRetriever(t)
- for _, params := range tc.mockParams.chatSessionRetrieverParams.chatSessionRetrieverAllSessionsParams {
- chatSessionRetriever.EXPECT().
- AllSessions(params.cookie).
- Return(params.result)
- }
- getPublicChatHandler(responseRecorder, request, chatRoomRetriever, chatSessionRetriever, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestPrivateChatHandler_GET(t *testing.T) {
- fnNewSess := func(screenName string) *state.Session {
- sess := state.NewSession()
- sess.SetIdentScreenName(state.NewIdentScreenName(screenName))
- sess.SetDisplayScreenName(state.DisplayScreenName(screenName))
- return sess
- }
- chatRoom1 := state.NewChatRoom("chat-room-1-name", state.NewIdentScreenName("chat-room-1-creator"), state.PrivateExchange)
- chatRoom2 := state.NewChatRoom("chat-room-2-name", state.NewIdentScreenName("chat-room-2-creator"), state.PrivateExchange)
- tt := []struct {
- name string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "multiple chat rooms with participants",
- 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"}]}]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- chatRoomRetrieverParams: chatRoomRetrieverParams{
- allChatRoomsParams: allChatRoomsParams{
- {
- exchange: state.PrivateExchange,
- result: []state.ChatRoom{
- chatRoom1,
- chatRoom2,
- },
- },
- },
- },
- chatSessionRetrieverParams: chatSessionRetrieverParams{
- chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
- {
- cookie: chatRoom1.Cookie(),
- result: []*state.Session{
- fnNewSess("userA"),
- fnNewSess("userB"),
- },
- },
- {
- cookie: chatRoom2.Cookie(),
- result: []*state.Session{
- fnNewSess("userC"),
- fnNewSess("userD"),
- },
- },
- },
- },
- },
- },
- {
- name: "chat room without participants",
- 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":[]}]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- chatRoomRetrieverParams: chatRoomRetrieverParams{
- allChatRoomsParams: allChatRoomsParams{
- {
- exchange: state.PrivateExchange,
- result: []state.ChatRoom{
- chatRoom1,
- },
- },
- },
- },
- chatSessionRetrieverParams: chatSessionRetrieverParams{
- chatSessionRetrieverAllSessionsParams: chatSessionRetrieverAllSessionsParams{
- {
- cookie: chatRoom1.Cookie(),
- result: []*state.Session{},
- },
- },
- },
- },
- },
- {
- name: "no chat rooms",
- want: `[]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- chatRoomRetrieverParams: chatRoomRetrieverParams{
- allChatRoomsParams: allChatRoomsParams{
- {
- exchange: state.PrivateExchange,
- result: []state.ChatRoom{},
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodGet, "/chat/room/private", nil)
- responseRecorder := httptest.NewRecorder()
- chatRoomRetriever := newMockChatRoomRetriever(t)
- for _, params := range tc.mockParams.chatRoomRetrieverParams.allChatRoomsParams {
- chatRoomRetriever.EXPECT().
- AllChatRooms(params.exchange).
- Return(params.result, params.err)
- }
- chatSessionRetriever := newMockChatSessionRetriever(t)
- for _, params := range tc.mockParams.chatSessionRetrieverParams.chatSessionRetrieverAllSessionsParams {
- chatSessionRetriever.EXPECT().
- AllSessions(params.cookie).
- Return(params.result)
- }
- getPrivateChatHandler(responseRecorder, request, chatRoomRetriever, chatSessionRetriever, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestInstantMessageHandler_POST(t *testing.T) {
- type relayToScreenNameInputs struct {
- sender state.IdentScreenName
- recipient state.IdentScreenName
- msg string
- }
- tt := []struct {
- name string
- relayToScreenNameInputs []relayToScreenNameInputs
- body string
- want string
- statusCode int
- }{
- {
- name: "send an instant message",
- relayToScreenNameInputs: []relayToScreenNameInputs{
- {
- sender: state.NewIdentScreenName("sender_sn"),
- recipient: state.NewIdentScreenName("recip_sn"),
- msg: "hello world!",
- },
- },
- body: `{"from":"sender_sn","to":"recip_sn","text":"hello world!"}`,
- want: `Message sent successfully.`,
- statusCode: http.StatusOK,
- },
- {
- name: "with malformed body",
- body: `{"screen_name":"userA", "password":"thepassword"`,
- want: `malformed input`,
- statusCode: http.StatusBadRequest,
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodPost, "/user", strings.NewReader(tc.body))
- responseRecorder := httptest.NewRecorder()
- messageRelayer := newMockMessageRelayer(t)
- for _, params := range tc.relayToScreenNameInputs {
- validateSNAC := func(msg wire.SNACMessage) bool {
- body := msg.Body.(wire.SNAC_0x04_0x07_ICBMChannelMsgToClient)
- assert.Equal(t, params.sender.String(), body.TLVUserInfo.ScreenName)
- b, ok := body.Bytes(wire.ICBMTLVAOLIMData)
- assert.True(t, ok)
- txt, err := wire.UnmarshalICBMMessageText(b)
- assert.NoError(t, err)
- assert.Equal(t, params.msg, txt)
- return true
- }
- messageRelayer.EXPECT().
- RelayToScreenName(mock.Anything, params.recipient, mock.MatchedBy(validateSNAC))
- }
- postInstantMessageHandler(responseRecorder, request, messageRelayer, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestVersionHandler_GET(t *testing.T) {
- tt := []struct {
- name string
- want string
- statusCode int
- buildInfo config.Build
- }{
- {
- name: "get ras version",
- want: `{"version":"13.3.7","commit":"asdfASDF12345678","date":"2024-03-01"}`,
- statusCode: http.StatusOK,
- buildInfo: config.Build{
- Version: "13.3.7",
- Commit: "asdfASDF12345678",
- Date: "2024-03-01",
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- responseRecorder := httptest.NewRecorder()
- getVersionHandler(responseRecorder, tc.buildInfo)
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestDirectoryCategoryHandler_GET(t *testing.T) {
- tt := []struct {
- name string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "no categories",
- want: `[]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- categoriesParams: categoriesParams{
- {
- result: nil,
- },
- },
- },
- },
- },
- {
- name: "error fetching categories",
- want: `{"message":"internal server error"}`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- categoriesParams: categoriesParams{
- {
- result: nil,
- err: errors.New("error fetching categories"),
- },
- },
- },
- },
- },
- {
- name: "fetch some categories",
- want: `[{"id":1,"name":"category-1"},{"id":2,"name":"category-2"}]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- categoriesParams: categoriesParams{
- {
- result: []state.Category{
- {
- ID: 1,
- Name: "category-1",
- },
- {
- ID: 2,
- Name: "category-2",
- },
- },
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- responseRecorder := httptest.NewRecorder()
- directoryManager := newMockDirectoryManager(t)
- for _, params := range tc.mockParams.categoriesParams {
- directoryManager.EXPECT().
- Categories().
- Return(params.result, params.err)
- }
- getDirectoryCategoryHandler(responseRecorder, directoryManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestDirectoryCategoryKeywordHandler_GET(t *testing.T) {
- tt := []struct {
- name string
- categoryID int
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "category not found",
- categoryID: 1,
- want: `{"message":"category not found"}`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- keywordsByCategoryParams: keywordsByCategoryParams{
- {
- categoryID: 1,
- result: nil,
- err: state.ErrKeywordCategoryNotFound,
- },
- },
- },
- },
- },
- {
- name: "error fetching keywords by category",
- categoryID: 1,
- want: `{"message":"internal server error"}`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- keywordsByCategoryParams: keywordsByCategoryParams{
- {
- categoryID: 1,
- result: nil,
- err: errors.New("error fetching keywords by category"),
- },
- },
- },
- },
- },
- {
- name: "invalid category ID",
- categoryID: -1,
- want: `{"message":"invalid category ID"}`,
- statusCode: http.StatusBadRequest,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- keywordsByCategoryParams: keywordsByCategoryParams{},
- },
- },
- },
- {
- name: "no keywords",
- categoryID: 1,
- want: `[]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- keywordsByCategoryParams: keywordsByCategoryParams{
- {
- categoryID: 1,
- result: nil,
- },
- },
- },
- },
- },
- {
- name: "fetch some keywords by category",
- categoryID: 1,
- want: `[{"id":1,"name":"keyword-1"},{"id":2,"name":"keyword-2"}]`,
- statusCode: http.StatusOK,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- keywordsByCategoryParams: keywordsByCategoryParams{
- {
- categoryID: 1,
- result: []state.Keyword{
- {
- ID: 1,
- Name: "keyword-1",
- },
- {
- ID: 2,
- Name: "keyword-2",
- },
- },
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodGet, fmt.Sprintf("/directory/category/%d/keyword", tc.categoryID), nil)
- request.SetPathValue("id", fmt.Sprintf("%d", tc.categoryID))
- responseRecorder := httptest.NewRecorder()
- directoryManager := newMockDirectoryManager(t)
- for _, params := range tc.mockParams.keywordsByCategoryParams {
- directoryManager.EXPECT().
- KeywordsByCategory(params.categoryID).
- Return(params.result, params.err)
- }
- getDirectoryCategoryKeywordHandler(responseRecorder, request, directoryManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestDirectoryCategoryHandler_DELETE(t *testing.T) {
- tt := []struct {
- name string
- categoryID int
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "category not found",
- categoryID: 1,
- want: `{"message":"category not found"}`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteCategoryParams: deleteCategoryParams{
- {
- categoryID: 1,
- err: state.ErrKeywordCategoryNotFound,
- },
- },
- },
- },
- },
- {
- name: "keyword in use by user",
- categoryID: 1,
- want: `{"message":"can't delete because category in use by a user"}`,
- statusCode: http.StatusConflict,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteCategoryParams: deleteCategoryParams{
- {
- categoryID: 1,
- err: state.ErrKeywordInUse,
- },
- },
- },
- },
- },
- {
- name: "runtime error",
- categoryID: 1,
- want: `{"message":"internal server error"}`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteCategoryParams: deleteCategoryParams{
- {
- categoryID: 1,
- err: errors.New("error deleting keyword"),
- },
- },
- },
- },
- },
- {
- name: "successful deletion",
- categoryID: 1,
- want: ``,
- statusCode: http.StatusNoContent,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteCategoryParams: deleteCategoryParams{
- {
- categoryID: 1,
- },
- },
- },
- },
- },
- {
- name: "invalid category ID",
- categoryID: -1,
- want: `invalid category ID`,
- statusCode: http.StatusBadRequest,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteCategoryParams: deleteCategoryParams{},
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodDelete, fmt.Sprintf("/directory/category/%d/keyword", tc.categoryID), nil)
- request.SetPathValue("id", fmt.Sprintf("%d", tc.categoryID))
- responseRecorder := httptest.NewRecorder()
- directoryManager := newMockDirectoryManager(t)
- for _, params := range tc.mockParams.deleteCategoryParams {
- directoryManager.EXPECT().
- DeleteCategory(params.categoryID).
- Return(params.err)
- }
- deleteDirectoryCategoryHandler(responseRecorder, request, directoryManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestDirectoryCategoryHandler_POST(t *testing.T) {
- tt := []struct {
- name string
- body string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "category already exists",
- body: `{"name":"the_category"}`,
- want: `{"message":"category already exists"}`,
- statusCode: http.StatusConflict,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createCategoryParams: createCategoryParams{
- {
- name: "the_category",
- err: state.ErrKeywordCategoryExists,
- },
- },
- },
- },
- },
- {
- name: "runtime error",
- body: `{"name":"the_category"}`,
- want: `{"message":"internal server error"}`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createCategoryParams: createCategoryParams{
- {
- name: "the_category",
- err: errors.New("error creating category"),
- },
- },
- },
- },
- },
- {
- name: "bad input",
- body: `{"name":"the_category"`,
- want: `{"message":"malformed input"}`,
- statusCode: http.StatusBadRequest,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createCategoryParams: createCategoryParams{},
- },
- },
- },
- {
- name: "successful creation",
- body: `{"name":"the_category"}`,
- want: `{"id":1,"name":"the_category"}`,
- statusCode: http.StatusCreated,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createCategoryParams: createCategoryParams{
- {
- name: "the_category",
- result: state.Category{
- ID: 1,
- Name: "the_category",
- },
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodPost, "/directory/category", strings.NewReader(tc.body))
- responseRecorder := httptest.NewRecorder()
- directoryManager := newMockDirectoryManager(t)
- for _, params := range tc.mockParams.createCategoryParams {
- directoryManager.EXPECT().
- CreateCategory(params.name).
- Return(params.result, params.err)
- }
- postDirectoryCategoryHandler(responseRecorder, request, directoryManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestDirectoryKeywordHandler_POST(t *testing.T) {
- tt := []struct {
- name string
- body string
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "keyword already exists",
- body: `{"category_id":1,"name":"the_keyword"}`,
- want: `{"message":"keyword already exists"}`,
- statusCode: http.StatusConflict,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createKeywordParams: createKeywordParams{
- {
- name: "the_keyword",
- categoryID: 1,
- err: state.ErrKeywordExists,
- },
- },
- },
- },
- },
- {
- name: "category not found",
- body: `{"category_id":1,"name":"the_keyword"}`,
- want: `{"message":"category not found"}`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createKeywordParams: createKeywordParams{
- {
- name: "the_keyword",
- categoryID: 1,
- err: state.ErrKeywordCategoryNotFound,
- },
- },
- },
- },
- },
- {
- name: "runtime error",
- body: `{"category_id":1,"name":"the_keyword"}`,
- want: `{"message":"internal server error"}`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createKeywordParams: createKeywordParams{
- {
- name: "the_keyword",
- categoryID: 1,
- err: errors.New("error creating keyword"),
- },
- },
- },
- },
- },
- {
- name: "bad input",
- body: `{"category_id":1,"name":"the_keyword"`,
- want: `{"message":"malformed input"}`,
- statusCode: http.StatusBadRequest,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createKeywordParams: createKeywordParams{},
- },
- },
- },
- {
- name: "successful creation",
- body: `{"category_id":1,"name":"the_keyword"}`,
- want: `{"id":1,"name":"the_keyword"}`,
- statusCode: http.StatusCreated,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- createKeywordParams: createKeywordParams{
- {
- name: "the_keyword",
- categoryID: 1,
- result: state.Keyword{
- ID: 1,
- Name: "the_keyword",
- },
- },
- },
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodPost, "/directory/keyword", strings.NewReader(tc.body))
- responseRecorder := httptest.NewRecorder()
- directoryManager := newMockDirectoryManager(t)
- for _, params := range tc.mockParams.createKeywordParams {
- directoryManager.EXPECT().
- CreateKeyword(params.name, params.categoryID).
- Return(params.result, params.err)
- }
- postDirectoryKeywordHandler(responseRecorder, request, directoryManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
- func TestDirectoryKeywordHandler_DELETE(t *testing.T) {
- tt := []struct {
- name string
- categoryID int
- want string
- statusCode int
- mockParams mockParams
- }{
- {
- name: "keyword not found",
- categoryID: 1,
- want: `{"message":"keyword not found"}`,
- statusCode: http.StatusNotFound,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteKeywordParams: deleteKeywordParams{
- {
- id: 1,
- err: state.ErrKeywordNotFound,
- },
- },
- },
- },
- },
- {
- name: "keyword in use by user",
- categoryID: 1,
- want: `{"message":"can't delete because category in use by a user"}`,
- statusCode: http.StatusConflict,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteKeywordParams: deleteKeywordParams{
- {
- id: 1,
- err: state.ErrKeywordInUse,
- },
- },
- },
- },
- },
- {
- name: "runtime error",
- categoryID: 1,
- want: `{"message":"internal server error"}`,
- statusCode: http.StatusInternalServerError,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteKeywordParams: deleteKeywordParams{
- {
- id: 1,
- err: errors.New("error deleting keyword"),
- },
- },
- },
- },
- },
- {
- name: "successful deletion",
- categoryID: 1,
- want: ``,
- statusCode: http.StatusNoContent,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteKeywordParams: deleteKeywordParams{
- {
- id: 1,
- },
- },
- },
- },
- },
- {
- name: "invalid keyword ID",
- categoryID: -1,
- want: `{"message":"invalid keyword ID"}`,
- statusCode: http.StatusBadRequest,
- mockParams: mockParams{
- directoryManagerParams: directoryManagerParams{
- deleteKeywordParams: deleteKeywordParams{},
- },
- },
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- request := httptest.NewRequest(http.MethodDelete, fmt.Sprintf("/directory/keyword/%d", tc.categoryID), nil)
- request.SetPathValue("id", fmt.Sprintf("%d", tc.categoryID))
- responseRecorder := httptest.NewRecorder()
- directoryManager := newMockDirectoryManager(t)
- for _, params := range tc.mockParams.deleteKeywordParams {
- directoryManager.EXPECT().
- DeleteKeyword(params.id).
- Return(params.err)
- }
- deleteDirectoryKeywordHandler(responseRecorder, request, directoryManager, slog.Default())
- if responseRecorder.Code != tc.statusCode {
- t.Errorf("Want status '%d', got '%d'", tc.statusCode, responseRecorder.Code)
- }
- if strings.TrimSpace(responseRecorder.Body.String()) != tc.want {
- t.Errorf("Want '%s', got '%s'", tc.want, responseRecorder.Body)
- }
- })
- }
- }
|