| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241 |
- package state
- import (
- "fmt"
- "math"
- "net/mail"
- "os"
- "reflect"
- "testing"
- "time"
- "github.com/mk6i/retro-aim-server/wire"
- "github.com/stretchr/testify/assert"
- )
- const testFile string = "aim_test.db"
- func TestSQLiteUserStore_FeedbagUpsert(t *testing.T) {
- t.Run("buddy screen name is converted to ident screen name", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- given := []wire.FeedbagItem{
- {
- GroupID: 0,
- ItemID: 1805,
- ClassID: wire.FeedbagClassIdBuddy,
- Name: "my Friend Bill",
- TLVLBlock: wire.TLVLBlock{},
- },
- {
- GroupID: 0x0A,
- ItemID: 0,
- ClassID: wire.FeedbagClassIdGroup,
- Name: "Friends",
- },
- }
- expect := []wire.FeedbagItem{
- {
- GroupID: 0,
- ItemID: 1805,
- ClassID: wire.FeedbagClassIdBuddy,
- Name: "myfriendbill",
- TLVLBlock: wire.TLVLBlock{},
- },
- {
- GroupID: 0x0A,
- ItemID: 0,
- ClassID: wire.FeedbagClassIdGroup,
- Name: "Friends",
- },
- }
- me := NewIdentScreenName("me")
- if err := f.FeedbagUpsert(me, given); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- have, err := f.Feedbag(me)
- assert.NoError(t, err)
- assert.ElementsMatch(t, expect, have)
- })
- t.Run("upsert PD info with mode", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- given := []wire.FeedbagItem{
- {
- GroupID: 0x0A,
- ItemID: 0,
- ClassID: wire.FeedbagClassIdPdinfo,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesPdMode, wire.FeedbagPDModePermitSome),
- },
- },
- },
- }
- me := NewIdentScreenName("me")
- err = f.FeedbagUpsert(me, given)
- assert.NoError(t, err)
- var pdMode uint8
- err = f.db.QueryRow(`SELECT pdMode from feedbag WHERE screenName = ?`, me.String()).Scan(&pdMode)
- assert.NoError(t, err)
- assert.Equal(t, wire.FeedbagPDMode(pdMode), wire.FeedbagPDModePermitSome)
- })
- t.Run("upsert PD info without mode (QIP behavior)", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- given := []wire.FeedbagItem{
- {
- GroupID: 0x0A,
- ItemID: 0,
- ClassID: wire.FeedbagClassIdPdinfo,
- TLVLBlock: wire.TLVLBlock{},
- },
- }
- me := NewIdentScreenName("me")
- err = f.FeedbagUpsert(me, given)
- assert.NoError(t, err)
- var pdMode uint8
- err = f.db.QueryRow(`SELECT pdMode from feedbag WHERE screenName = ?`, me.String()).Scan(&pdMode)
- assert.NoError(t, err)
- assert.Equal(t, wire.FeedbagPDMode(pdMode), wire.FeedbagPDModePermitAll)
- })
- }
- func TestFeedbagDelete(t *testing.T) {
- screenName := NewIdentScreenName("sn2day")
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- itemsIn := []wire.FeedbagItem{
- {
- GroupID: 0,
- ItemID: 1805,
- ClassID: 3,
- Name: "spimmer1234",
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(0x01, uint16(1000)),
- },
- },
- },
- {
- GroupID: 0x0A,
- ItemID: 0,
- ClassID: 1,
- Name: "Friends",
- },
- {
- GroupID: 0x0B,
- ItemID: 100,
- ClassID: 1,
- Name: "co-workers",
- },
- }
- if err := f.FeedbagUpsert(screenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- if err := f.FeedbagDelete(screenName, []wire.FeedbagItem{itemsIn[0]}); err != nil {
- t.Fatalf("failed to delete: %s", err.Error())
- }
- itemsOut, err := f.Feedbag(screenName)
- if err != nil {
- t.Fatalf("failed to retrieve: %s", err.Error())
- }
- expect := itemsIn[1:]
- if !reflect.DeepEqual(expect, itemsOut) {
- t.Fatalf("items did not match:\n in: %v\n out: %v", expect, itemsOut)
- }
- }
- func TestLastModifiedEmpty(t *testing.T) {
- screenName := NewIdentScreenName("sn2day")
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- _, err = f.FeedbagLastModified(screenName)
- if err != nil {
- t.Fatalf("get error from last modified: %s", err.Error())
- }
- }
- func TestLastModifiedNotEmpty(t *testing.T) {
- screenName := NewIdentScreenName("sn2day")
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- itemsIn := []wire.FeedbagItem{
- {
- GroupID: 0x0A,
- ItemID: 0,
- ClassID: 1,
- Name: "Friends",
- },
- }
- if err := f.FeedbagUpsert(screenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- _, err = f.FeedbagLastModified(screenName)
- if err != nil {
- t.Fatalf("get error from last modified: %s", err.Error())
- }
- }
- func TestProfile(t *testing.T) {
- screenName := NewIdentScreenName("sn2day")
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- u := User{
- IdentScreenName: screenName,
- }
- if err := f.InsertUser(u); err != nil {
- t.Fatalf("failed to upsert new user: %s", err.Error())
- }
- profile, err := f.Profile(screenName)
- if err != nil {
- t.Fatalf("failed to retrieve profile: %s", err.Error())
- }
- if profile != "" {
- t.Fatalf("expected empty profile for %s", screenName)
- }
- newProfile := "here is my profile"
- if err := f.SetProfile(screenName, newProfile); err != nil {
- t.Fatalf("failed to create new profile: %s", err.Error())
- }
- profile, err = f.Profile(screenName)
- if err != nil {
- t.Fatalf("failed to retrieve profile: %s", err.Error())
- }
- if !reflect.DeepEqual(newProfile, profile) {
- t.Fatalf("profiles did not match:\n expected: %v\n actual: %v", newProfile, profile)
- }
- updatedProfile := "here is my profile [updated]"
- if err := f.SetProfile(screenName, updatedProfile); err != nil {
- t.Fatalf("failed to create new profile: %s", err.Error())
- }
- profile, err = f.Profile(screenName)
- if err != nil {
- t.Fatalf("failed to retrieve profile: %s", err.Error())
- }
- if !reflect.DeepEqual(updatedProfile, profile) {
- t.Fatalf("updated profiles did not match:\n expected: %v\n actual: %v", newProfile, profile)
- }
- }
- func TestProfileNonExistent(t *testing.T) {
- screenName := NewIdentScreenName("sn2day")
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- prof, err := f.Profile(screenName)
- assert.NoError(t, err)
- assert.Empty(t, prof)
- }
- func TestGetUser(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- screenName := NewIdentScreenName("testscreenname")
- insertedUser := &User{
- IdentScreenName: screenName,
- DisplayScreenName: DisplayScreenName("testscreenname"),
- AuthKey: "theauthkey",
- StrongMD5Pass: []byte("thepasshash"),
- RegStatus: 3,
- }
- err = f.InsertUser(*insertedUser)
- assert.NoError(t, err)
- actualUser, err := f.User(screenName)
- if err != nil {
- t.Fatalf("failed to get user: %s", err.Error())
- }
- if !reflect.DeepEqual(insertedUser, actualUser) {
- t.Fatalf("users are not equal. expect: %v actual: %v", insertedUser, actualUser)
- }
- }
- func TestGetUserNotFound(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- actualUser, err := f.User(NewIdentScreenName("testscreenname"))
- if err != nil {
- t.Fatalf("failed to get user: %s", err.Error())
- }
- if actualUser != nil {
- t.Fatal("expected user to not be found")
- }
- }
- func TestSQLiteUserStore_Users(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- want := []User{
- {
- IdentScreenName: NewIdentScreenName("userA"),
- DisplayScreenName: "userA",
- },
- {
- IdentScreenName: NewIdentScreenName("userB"),
- DisplayScreenName: "userB",
- },
- {
- IdentScreenName: NewIdentScreenName("userC"),
- DisplayScreenName: "userC",
- },
- {
- IdentScreenName: NewIdentScreenName("100003"),
- DisplayScreenName: "100003",
- IsICQ: true,
- },
- }
- for _, u := range want {
- err := f.InsertUser(u)
- assert.NoError(t, err)
- }
- have, err := f.AllUsers()
- assert.NoError(t, err)
- assert.Equal(t, want, have)
- }
- func TestSQLiteUserStore_InsertUser_UINButNotIsICQ(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- user := User{
- IdentScreenName: NewIdentScreenName("100003"),
- DisplayScreenName: "100003",
- }
- err = f.InsertUser(user)
- assert.ErrorContains(t, err, "inserting user with UIN and isICQ=false")
- }
- func TestSQLiteUserStore_DeleteUser_DeleteExistentUser(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- err = f.InsertUser(User{
- IdentScreenName: NewIdentScreenName("userA"),
- DisplayScreenName: "userA",
- })
- assert.NoError(t, err)
- err = f.InsertUser(User{
- IdentScreenName: NewIdentScreenName("userB"),
- DisplayScreenName: "userB",
- })
- assert.NoError(t, err)
- err = f.DeleteUser(NewIdentScreenName("userA"))
- assert.NoError(t, err)
- have, err := f.AllUsers()
- assert.NoError(t, err)
- want := []User{{
- IdentScreenName: NewIdentScreenName("userB"),
- DisplayScreenName: "userB",
- }}
- assert.Equal(t, want, have)
- }
- func TestSQLiteUserStore_DeleteUser_DeleteNonExistentUser(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- err = f.DeleteUser(NewIdentScreenName("userA"))
- assert.ErrorIs(t, ErrNoUser, err)
- }
- func TestNewStubUser(t *testing.T) {
- have, err := NewStubUser("userA")
- assert.NoError(t, err)
- want := User{
- IdentScreenName: NewIdentScreenName("userA"),
- DisplayScreenName: "userA",
- AuthKey: have.AuthKey,
- }
- assert.NoError(t, want.HashPassword("welcome1"))
- assert.Equal(t, want, have)
- }
- func newFeedbagItem(classID uint16, itemID uint16, name string) wire.FeedbagItem {
- return wire.FeedbagItem{
- ClassID: classID,
- ItemID: itemID,
- Name: name,
- }
- }
- func pdInfoItem(itemID uint16, pdMode wire.FeedbagPDMode) wire.FeedbagItem {
- return wire.FeedbagItem{
- ClassID: wire.FeedbagClassIdPdinfo,
- ItemID: itemID,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesPdMode, uint8(pdMode)),
- },
- },
- }
- }
- func TestSQLiteUserStore_BARTUpsertAndRetrieve(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- feedbagStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- hash := []byte{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15}
- item := []byte{'a', 'b', 'c', 'd'}
- b, err := feedbagStore.BARTRetrieve(hash)
- assert.NoError(t, err)
- assert.Empty(t, b)
- err = feedbagStore.BARTUpsert(hash, item)
- assert.NoError(t, err)
- b, err = feedbagStore.BARTRetrieve(hash)
- assert.NoError(t, err)
- assert.Equal(t, item, b)
- }
- func TestSQLiteUserStore_SetUserPassword_UserExists(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- feedbagStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- u := User{
- IdentScreenName: NewIdentScreenName("theuser"),
- DisplayScreenName: "theUser",
- }
- err = u.HashPassword("thepassword")
- assert.NoError(t, err)
- err = feedbagStore.InsertUser(u)
- assert.NoError(t, err)
- err = feedbagStore.SetUserPassword(u.IdentScreenName, "theNEWpassword")
- assert.NoError(t, err)
- gotUser, err := feedbagStore.User(u.IdentScreenName)
- assert.NoError(t, err)
- wantUser := User{}
- wantUser.HashPassword("theNEWpassword")
- valid := gotUser.ValidateHash(wantUser.StrongMD5Pass)
- assert.True(t, valid)
- }
- func TestSQLiteUserStore_SetUserPassword_ErrNoUser(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- feedbagStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- err = feedbagStore.SetUserPassword(NewIdentScreenName("some_user"), "thepassword")
- assert.ErrorIs(t, err, ErrNoUser)
- }
- func TestSQLiteUserStore_ChatRoomByCookie(t *testing.T) {
- tests := []struct {
- name string
- givenRoom ChatRoom
- lookupRoom ChatRoom
- expectedErr error
- }{
- {
- name: "chat room found",
- givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- lookupRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- expectedErr: nil,
- },
- {
- name: "chat room found - different name casing",
- givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- lookupRoom: NewChatRoom("MY CHAT ROOM", NewIdentScreenName("creator"), PrivateExchange),
- expectedErr: nil,
- },
- {
- name: "chat room not found",
- givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- lookupRoom: NewChatRoom("your chat room", NewIdentScreenName("creator"), PrivateExchange),
- expectedErr: ErrChatRoomNotFound,
- },
- }
- for _, tt := range tests {
- t.Run(tt.name, func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- userStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- err = userStore.CreateChatRoom(&tt.givenRoom)
- assert.NoError(t, err)
- gotRoom, err := userStore.ChatRoomByCookie(tt.lookupRoom.Cookie())
- assert.ErrorIs(t, err, tt.expectedErr)
- if tt.expectedErr == nil {
- assert.Equal(t, tt.givenRoom.Cookie(), gotRoom.Cookie())
- }
- })
- }
- }
- func TestSQLiteUserStore_ChatRoomByName(t *testing.T) {
- tests := []struct {
- name string
- givenRoom ChatRoom
- lookupRoom ChatRoom
- expectedErr error
- }{
- {
- name: "chat room found",
- givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- lookupRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- expectedErr: nil,
- },
- {
- name: "chat room found - different name casing",
- givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- lookupRoom: NewChatRoom("MY CHAT ROOM", NewIdentScreenName("creator"), PrivateExchange),
- expectedErr: nil,
- },
- {
- name: "chat room not found",
- givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
- lookupRoom: NewChatRoom("your chat room", NewIdentScreenName("creator"), PrivateExchange),
- expectedErr: ErrChatRoomNotFound,
- },
- }
- for _, tt := range tests {
- t.Run(tt.name, func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- userStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- err = userStore.CreateChatRoom(&tt.givenRoom)
- assert.NoError(t, err)
- gotRoom, err := userStore.ChatRoomByName(tt.lookupRoom.Exchange(), tt.lookupRoom.Name())
- assert.ErrorIs(t, err, tt.expectedErr)
- if tt.expectedErr == nil {
- assert.Equal(t, tt.givenRoom.Cookie(), gotRoom.Cookie())
- }
- })
- }
- }
- func TestSQLiteUserStore_AllChatRooms(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- userStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- chatRooms := []ChatRoom{
- NewChatRoom("chat room 1", NewIdentScreenName("creator"), PrivateExchange),
- NewChatRoom("chat room 2", NewIdentScreenName("creator"), PrivateExchange),
- NewChatRoom("chat room 3", NewIdentScreenName("creator"), PublicExchange),
- }
- for i := range chatRooms {
- tBefore := (&chatRooms[i]).CreateTime()
- err = userStore.CreateChatRoom(&chatRooms[i])
- assert.NoError(t, err)
- assert.True(t, chatRooms[i].CreateTime().After(tBefore))
- }
- // public exchange
- gotRooms, err := userStore.AllChatRooms(5)
- assert.NoError(t, err)
- assert.Equal(t, chatRooms[2:], gotRooms)
- // private exchange
- gotRooms, err = userStore.AllChatRooms(4)
- assert.NoError(t, err)
- assert.Equal(t, chatRooms[0:2], gotRooms)
- }
- func TestSQLiteUserStore_CreateChatRoom_ErrChatRoomExists(t *testing.T) {
- tt := []struct {
- name string
- firstInsert ChatRoom
- secondInsert ChatRoom
- wantErr error
- }{
- {
- name: "create two rooms with different cookie/exchange, same name",
- firstInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PublicExchange),
- secondInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PrivateExchange),
- wantErr: nil,
- },
- {
- name: "create two rooms with same cookie/exchange/name",
- firstInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PublicExchange),
- secondInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PublicExchange),
- wantErr: ErrDupChatRoom,
- },
- }
- for _, tc := range tt {
- t.Run(tc.name, func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- userStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- err = userStore.CreateChatRoom(&tc.firstInsert)
- assert.NoError(t, err)
- err = userStore.CreateChatRoom(&tc.secondInsert)
- assert.ErrorIs(t, err, tc.wantErr)
- })
- }
- }
- func TestUpdateDisplayScreenName(t *testing.T) {
- screenNameOriginal := DisplayScreenName("chattingchuck")
- screenNameFormatted := DisplayScreenName("Chatting Chuck")
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- user := User{
- DisplayScreenName: screenNameOriginal,
- IdentScreenName: screenNameOriginal.IdentScreenName(),
- RegStatus: 3,
- }
- if err := f.InsertUser(user); err != nil {
- t.Fatalf("failed to upsert new user: %s", err.Error())
- }
- err = f.UpdateDisplayScreenName(screenNameFormatted)
- if err != nil {
- t.Fatalf("failed to update display screen name: %s", err.Error())
- }
- dbUser, err := f.User(screenNameOriginal.IdentScreenName())
- if err != nil {
- t.Fatalf("failed to retrieve screen name: %s", err.Error())
- }
- assert.Equal(t, dbUser.DisplayScreenName, screenNameFormatted)
- }
- func TestSQLiteUserStore_SetWorkInfo(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- screenName := NewIdentScreenName("testuser")
- user := User{
- IdentScreenName: screenName,
- }
- err = f.InsertUser(user)
- assert.NoError(t, err)
- // Define the work info to set
- workInfo := ICQWorkInfo{
- Company: "Test Company",
- Department: "Test Department",
- OccupationCode: 10,
- Position: "Test Position",
- Address: "123 Test St",
- City: "Test City",
- CountryCode: 1,
- Fax: "123-456-7890",
- Phone: "098-765-4321",
- State: "Test State",
- WebPage: "http://www.test.com",
- ZIPCode: "12345",
- }
- t.Run("Successful Update", func(t *testing.T) {
- // Call SetWorkInfo
- err := f.SetWorkInfo(screenName, workInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify the work info was set correctly
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, workInfo.Company, updatedUser.ICQWorkInfo.Company)
- assert.Equal(t, workInfo.Department, updatedUser.ICQWorkInfo.Department)
- assert.Equal(t, workInfo.OccupationCode, updatedUser.ICQWorkInfo.OccupationCode)
- assert.Equal(t, workInfo.Position, updatedUser.ICQWorkInfo.Position)
- assert.Equal(t, workInfo.Address, updatedUser.ICQWorkInfo.Address)
- assert.Equal(t, workInfo.City, updatedUser.ICQWorkInfo.City)
- assert.Equal(t, workInfo.CountryCode, updatedUser.ICQWorkInfo.CountryCode)
- assert.Equal(t, workInfo.Fax, updatedUser.ICQWorkInfo.Fax)
- assert.Equal(t, workInfo.Phone, updatedUser.ICQWorkInfo.Phone)
- assert.Equal(t, workInfo.State, updatedUser.ICQWorkInfo.State)
- assert.Equal(t, workInfo.WebPage, updatedUser.ICQWorkInfo.WebPage)
- assert.Equal(t, workInfo.ZIPCode, updatedUser.ICQWorkInfo.ZIPCode)
- })
- t.Run("Update Non-Existing User", func(t *testing.T) {
- // Try to set work info for a non-existing user
- nonExistingScreenName := NewIdentScreenName("nonexistentuser")
- err := f.SetWorkInfo(nonExistingScreenName, workInfo)
- // This should return ErrNoUser, as the user does not exist
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty Work Info", func(t *testing.T) {
- // Test updating with empty work info (depending on business rules, this might be allowed or not)
- emptyWorkInfo := ICQWorkInfo{}
- err := f.SetWorkInfo(screenName, emptyWorkInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify that fields are empty or have default values
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Empty(t, updatedUser.ICQWorkInfo.Company)
- assert.Empty(t, updatedUser.ICQWorkInfo.Department)
- assert.Empty(t, updatedUser.ICQWorkInfo.OccupationCode)
- assert.Empty(t, updatedUser.ICQWorkInfo.Position)
- assert.Empty(t, updatedUser.ICQWorkInfo.Address)
- assert.Empty(t, updatedUser.ICQWorkInfo.City)
- assert.Empty(t, updatedUser.ICQWorkInfo.CountryCode)
- assert.Empty(t, updatedUser.ICQWorkInfo.Fax)
- assert.Empty(t, updatedUser.ICQWorkInfo.Phone)
- assert.Empty(t, updatedUser.ICQWorkInfo.State)
- assert.Empty(t, updatedUser.ICQWorkInfo.WebPage)
- assert.Empty(t, updatedUser.ICQWorkInfo.ZIPCode)
- })
- }
- func TestSQLiteUserStore_SetMoreInfo(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test user
- screenName := NewIdentScreenName("testuser")
- user := User{
- IdentScreenName: screenName,
- }
- err = f.InsertUser(user)
- assert.NoError(t, err)
- // Define the more info data to set
- moreInfo := ICQMoreInfo{
- BirthDay: 15,
- BirthMonth: 8,
- BirthYear: 1990,
- Gender: 1,
- HomePageAddr: "http://example.com",
- Lang1: 1,
- Lang2: 2,
- Lang3: 3,
- }
- t.Run("Successful Update", func(t *testing.T) {
- // Call SetMoreInfo
- err := f.SetMoreInfo(screenName, moreInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify the more info was set correctly
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, moreInfo.BirthDay, updatedUser.ICQMoreInfo.BirthDay)
- assert.Equal(t, moreInfo.BirthMonth, updatedUser.ICQMoreInfo.BirthMonth)
- assert.Equal(t, moreInfo.BirthYear, updatedUser.ICQMoreInfo.BirthYear)
- assert.Equal(t, moreInfo.Gender, updatedUser.ICQMoreInfo.Gender)
- assert.Equal(t, moreInfo.HomePageAddr, updatedUser.ICQMoreInfo.HomePageAddr)
- assert.Equal(t, moreInfo.Lang1, updatedUser.ICQMoreInfo.Lang1)
- assert.Equal(t, moreInfo.Lang2, updatedUser.ICQMoreInfo.Lang2)
- assert.Equal(t, moreInfo.Lang3, updatedUser.ICQMoreInfo.Lang3)
- })
- t.Run("Update Non-Existing User", func(t *testing.T) {
- // Try to set more info for a non-existing user
- nonExistingScreenName := NewIdentScreenName("nonexistentuser")
- err := f.SetMoreInfo(nonExistingScreenName, moreInfo)
- // This should return ErrNoUser, as the user does not exist
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty More Info", func(t *testing.T) {
- // Test updating with empty more info
- emptyMoreInfo := ICQMoreInfo{}
- err := f.SetMoreInfo(screenName, emptyMoreInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify that fields are empty or have default values
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Empty(t, updatedUser.ICQMoreInfo.BirthDay)
- assert.Empty(t, updatedUser.ICQMoreInfo.BirthMonth)
- assert.Empty(t, updatedUser.ICQMoreInfo.BirthYear)
- assert.Empty(t, updatedUser.ICQMoreInfo.Gender)
- assert.Empty(t, updatedUser.ICQMoreInfo.HomePageAddr)
- assert.Empty(t, updatedUser.ICQMoreInfo.Lang1)
- assert.Empty(t, updatedUser.ICQMoreInfo.Lang2)
- assert.Empty(t, updatedUser.ICQMoreInfo.Lang3)
- })
- }
- func TestSQLiteUserStore_SetUserNotes(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test user
- screenName := NewIdentScreenName("testuser")
- user := User{
- IdentScreenName: screenName,
- }
- err = f.InsertUser(user)
- assert.NoError(t, err)
- // Define the user notes to set
- userNotes := ICQUserNotes{
- Notes: "This is a test note.",
- }
- t.Run("Successful Update", func(t *testing.T) {
- // Call SetUserNotes
- err := f.SetUserNotes(screenName, userNotes)
- assert.NoError(t, err)
- // Retrieve the user and verify the notes were set correctly
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, userNotes.Notes, updatedUser.ICQNotes.Notes)
- })
- t.Run("Update Non-Existing User", func(t *testing.T) {
- // Try to set notes for a non-existing user
- nonExistingScreenName := NewIdentScreenName("nonexistentuser")
- err := f.SetUserNotes(nonExistingScreenName, userNotes)
- // This should return ErrNoUser, as the user does not exist
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty Notes", func(t *testing.T) {
- // Test updating with empty notes
- emptyNotes := ICQUserNotes{Notes: ""}
- err := f.SetUserNotes(screenName, emptyNotes)
- assert.NoError(t, err)
- // Retrieve the user and verify that notes are empty
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Empty(t, updatedUser.ICQNotes.Notes)
- })
- }
- func TestSQLiteUserStore_SetInterests(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test user
- screenName := NewIdentScreenName("testuser")
- user := User{
- IdentScreenName: screenName,
- }
- err = f.InsertUser(user)
- assert.NoError(t, err)
- // Define the interests data to set
- interests := ICQInterests{
- Code1: 1,
- Keyword1: "Coding",
- Code2: 2,
- Keyword2: "Music",
- Code3: 3,
- Keyword3: "Gaming",
- Code4: 4,
- Keyword4: "Travel",
- }
- t.Run("Successful Update", func(t *testing.T) {
- // Call SetInterests
- err := f.SetInterests(screenName, interests)
- assert.NoError(t, err)
- // Retrieve the user and verify the interests were set correctly
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, interests.Code1, updatedUser.ICQInterests.Code1)
- assert.Equal(t, interests.Keyword1, updatedUser.ICQInterests.Keyword1)
- assert.Equal(t, interests.Code2, updatedUser.ICQInterests.Code2)
- assert.Equal(t, interests.Keyword2, updatedUser.ICQInterests.Keyword2)
- assert.Equal(t, interests.Code3, updatedUser.ICQInterests.Code3)
- assert.Equal(t, interests.Keyword3, updatedUser.ICQInterests.Keyword3)
- assert.Equal(t, interests.Code4, updatedUser.ICQInterests.Code4)
- assert.Equal(t, interests.Keyword4, updatedUser.ICQInterests.Keyword4)
- })
- t.Run("Update Non-Existing User", func(t *testing.T) {
- // Try to set interests for a non-existing user
- nonExistingScreenName := NewIdentScreenName("nonexistentuser")
- err := f.SetInterests(nonExistingScreenName, interests)
- // This should return ErrNoUser, as the user does not exist
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty Interests", func(t *testing.T) {
- // Test updating with empty interests
- emptyInterests := ICQInterests{}
- err := f.SetInterests(screenName, emptyInterests)
- assert.NoError(t, err)
- // Retrieve the user and verify that interests fields are empty or have default values
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Empty(t, updatedUser.ICQInterests.Code1)
- assert.Empty(t, updatedUser.ICQInterests.Keyword1)
- assert.Empty(t, updatedUser.ICQInterests.Code2)
- assert.Empty(t, updatedUser.ICQInterests.Keyword2)
- assert.Empty(t, updatedUser.ICQInterests.Code3)
- assert.Empty(t, updatedUser.ICQInterests.Keyword3)
- assert.Empty(t, updatedUser.ICQInterests.Code4)
- assert.Empty(t, updatedUser.ICQInterests.Keyword4)
- })
- }
- func TestSQLiteUserStore_SetAffiliations(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test user
- screenName := NewIdentScreenName("testuser")
- user := User{
- IdentScreenName: screenName,
- }
- err = f.InsertUser(user)
- assert.NoError(t, err)
- // Define the affiliations data to set
- affiliations := ICQAffiliations{
- CurrentCode1: 1,
- CurrentKeyword1: "Sports",
- CurrentCode2: 2,
- CurrentKeyword2: "Science",
- CurrentCode3: 3,
- CurrentKeyword3: "Arts",
- PastCode1: 4,
- PastKeyword1: "Literature",
- PastCode2: 5,
- PastKeyword2: "Music",
- PastCode3: 6,
- PastKeyword3: "Technology",
- }
- t.Run("Successful Update", func(t *testing.T) {
- // Call SetAffiliations
- err := f.SetAffiliations(screenName, affiliations)
- assert.NoError(t, err)
- // Retrieve the user and verify the affiliations were set correctly
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, affiliations.CurrentCode1, updatedUser.ICQAffiliations.CurrentCode1)
- assert.Equal(t, affiliations.CurrentKeyword1, updatedUser.ICQAffiliations.CurrentKeyword1)
- assert.Equal(t, affiliations.CurrentCode2, updatedUser.ICQAffiliations.CurrentCode2)
- assert.Equal(t, affiliations.CurrentKeyword2, updatedUser.ICQAffiliations.CurrentKeyword2)
- assert.Equal(t, affiliations.CurrentCode3, updatedUser.ICQAffiliations.CurrentCode3)
- assert.Equal(t, affiliations.CurrentKeyword3, updatedUser.ICQAffiliations.CurrentKeyword3)
- assert.Equal(t, affiliations.PastCode1, updatedUser.ICQAffiliations.PastCode1)
- assert.Equal(t, affiliations.PastKeyword1, updatedUser.ICQAffiliations.PastKeyword1)
- assert.Equal(t, affiliations.PastCode2, updatedUser.ICQAffiliations.PastCode2)
- assert.Equal(t, affiliations.PastKeyword2, updatedUser.ICQAffiliations.PastKeyword2)
- assert.Equal(t, affiliations.PastCode3, updatedUser.ICQAffiliations.PastCode3)
- assert.Equal(t, affiliations.PastKeyword3, updatedUser.ICQAffiliations.PastKeyword3)
- })
- t.Run("Update Non-Existing User", func(t *testing.T) {
- // Try to set affiliations for a non-existing user
- nonExistingScreenName := NewIdentScreenName("nonexistentuser")
- err := f.SetAffiliations(nonExistingScreenName, affiliations)
- // This should return ErrNoUser, as the user does not exist
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty Affiliations", func(t *testing.T) {
- // Test updating with empty affiliations
- emptyAffiliations := ICQAffiliations{}
- err := f.SetAffiliations(screenName, emptyAffiliations)
- assert.NoError(t, err)
- // Retrieve the user and verify that affiliations fields are empty or have default values
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Empty(t, updatedUser.ICQAffiliations.CurrentCode1)
- assert.Empty(t, updatedUser.ICQAffiliations.CurrentKeyword1)
- assert.Empty(t, updatedUser.ICQAffiliations.CurrentCode2)
- assert.Empty(t, updatedUser.ICQAffiliations.CurrentKeyword2)
- assert.Empty(t, updatedUser.ICQAffiliations.CurrentCode3)
- assert.Empty(t, updatedUser.ICQAffiliations.CurrentKeyword3)
- assert.Empty(t, updatedUser.ICQAffiliations.PastCode1)
- assert.Empty(t, updatedUser.ICQAffiliations.PastKeyword1)
- assert.Empty(t, updatedUser.ICQAffiliations.PastCode2)
- assert.Empty(t, updatedUser.ICQAffiliations.PastKeyword2)
- assert.Empty(t, updatedUser.ICQAffiliations.PastCode3)
- assert.Empty(t, updatedUser.ICQAffiliations.PastKeyword3)
- })
- }
- func TestSQLiteUserStore_SetBasicInfo(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test user
- screenName := NewIdentScreenName("testuser")
- user := User{
- IdentScreenName: screenName,
- }
- err = f.InsertUser(user)
- assert.NoError(t, err)
- // Define the basic info data to set
- basicInfo := ICQBasicInfo{
- CellPhone: "123-456-7890",
- CountryCode: 1,
- EmailAddress: "test@example.com",
- FirstName: "John",
- GMTOffset: 5,
- Address: "123 Main St",
- City: "Test City",
- Fax: "098-765-4321",
- Phone: "111-222-3333",
- State: "Test State",
- LastName: "Doe",
- Nickname: "Johnny",
- PublishEmail: true,
- ZIPCode: "12345",
- }
- t.Run("Successful Update", func(t *testing.T) {
- // Call SetBasicInfo
- err := f.SetBasicInfo(screenName, basicInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify the basic info was set correctly
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, basicInfo.CellPhone, updatedUser.ICQBasicInfo.CellPhone)
- assert.Equal(t, basicInfo.CountryCode, updatedUser.ICQBasicInfo.CountryCode)
- assert.Equal(t, basicInfo.EmailAddress, updatedUser.ICQBasicInfo.EmailAddress)
- assert.Equal(t, basicInfo.FirstName, updatedUser.ICQBasicInfo.FirstName)
- assert.Equal(t, basicInfo.GMTOffset, updatedUser.ICQBasicInfo.GMTOffset)
- assert.Equal(t, basicInfo.Address, updatedUser.ICQBasicInfo.Address)
- assert.Equal(t, basicInfo.City, updatedUser.ICQBasicInfo.City)
- assert.Equal(t, basicInfo.Fax, updatedUser.ICQBasicInfo.Fax)
- assert.Equal(t, basicInfo.Phone, updatedUser.ICQBasicInfo.Phone)
- assert.Equal(t, basicInfo.State, updatedUser.ICQBasicInfo.State)
- assert.Equal(t, basicInfo.LastName, updatedUser.ICQBasicInfo.LastName)
- assert.Equal(t, basicInfo.Nickname, updatedUser.ICQBasicInfo.Nickname)
- assert.Equal(t, basicInfo.PublishEmail, updatedUser.ICQBasicInfo.PublishEmail)
- assert.Equal(t, basicInfo.ZIPCode, updatedUser.ICQBasicInfo.ZIPCode)
- })
- t.Run("Update Non-Existing User", func(t *testing.T) {
- // Try to set basic info for a non-existing user
- nonExistingScreenName := NewIdentScreenName("nonexistentuser")
- err := f.SetBasicInfo(nonExistingScreenName, basicInfo)
- // This should return ErrNoUser, as the user does not exist
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty Basic Info", func(t *testing.T) {
- // Test updating with empty basic info
- emptyBasicInfo := ICQBasicInfo{}
- err := f.SetBasicInfo(screenName, emptyBasicInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify that basic info fields are empty or have default values
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Empty(t, updatedUser.ICQBasicInfo.CellPhone)
- assert.Empty(t, updatedUser.ICQBasicInfo.CountryCode)
- assert.Empty(t, updatedUser.ICQBasicInfo.EmailAddress)
- assert.Empty(t, updatedUser.ICQBasicInfo.FirstName)
- assert.Empty(t, updatedUser.ICQBasicInfo.GMTOffset)
- assert.Empty(t, updatedUser.ICQBasicInfo.Address)
- assert.Empty(t, updatedUser.ICQBasicInfo.City)
- assert.Empty(t, updatedUser.ICQBasicInfo.Fax)
- assert.Empty(t, updatedUser.ICQBasicInfo.Phone)
- assert.Empty(t, updatedUser.ICQBasicInfo.State)
- assert.Empty(t, updatedUser.ICQBasicInfo.LastName)
- assert.Empty(t, updatedUser.ICQBasicInfo.Nickname)
- assert.Empty(t, updatedUser.ICQBasicInfo.PublishEmail)
- assert.Empty(t, updatedUser.ICQBasicInfo.ZIPCode)
- })
- }
- func TestSQLiteUserStore_FindByICQInterests(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create and set up test users with different interests
- user1 := User{
- IdentScreenName: NewIdentScreenName("user1"),
- }
- err = f.InsertUser(user1)
- assert.NoError(t, err)
- interests1 := ICQInterests{
- Code1: 1,
- Keyword1: "Coding",
- Code2: 2,
- Keyword2: "Music",
- }
- err = f.SetInterests(user1.IdentScreenName, interests1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(user2)
- assert.NoError(t, err)
- interests2 := ICQInterests{
- Code1: 1,
- Keyword1: "Coding",
- Code3: 3,
- Keyword3: "Gaming",
- }
- err = f.SetInterests(user2.IdentScreenName, interests2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(user3)
- assert.NoError(t, err)
- interests3 := ICQInterests{
- Code2: 2,
- Keyword2: "Music",
- Code4: 4,
- Keyword4: "Travel",
- }
- err = f.SetInterests(user3.IdentScreenName, interests3)
- assert.NoError(t, err)
- // Helper function to check if a user with a specific IdentScreenName exists in the results
- containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
- for _, user := range users {
- if user.IdentScreenName == screenName {
- return true
- }
- }
- return false
- }
- t.Run("Find Users by Single Keyword", func(t *testing.T) {
- // Search for users interested in "Music"
- users, err := f.FindByICQInterests(2, []string{"Music"})
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- // Check that the correct users are returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
- })
- t.Run("Find Users by Multiple Keywords", func(t *testing.T) {
- // Search for users interested in "Coding" or "Gaming"
- users, err := f.FindByICQInterests(1, []string{"Coding", "Gaming"})
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- // Check that the correct users are returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
- })
- t.Run("Find Users by Multiple Codes and Keywords", func(t *testing.T) {
- // Search for users interested in "Coding"
- users, err := f.FindByICQInterests(1, []string{"Coding"})
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
- // Search for users interested in "Travel"
- users, err = f.FindByICQInterests(4, []string{"Travel"})
- assert.NoError(t, err)
- assert.Len(t, users, 1)
- assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
- })
- t.Run("No Users Found", func(t *testing.T) {
- // Search for users interested in a keyword that no user has
- users, err := f.FindByICQInterests(1, []string{"Status"})
- assert.NoError(t, err)
- assert.Empty(t, users)
- })
- }
- func TestSQLiteUserStore_FindByICQKeyword(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create and set up test users with different interests
- user1 := User{
- IdentScreenName: NewIdentScreenName("user1"),
- }
- err = f.InsertUser(user1)
- assert.NoError(t, err)
- interests1 := ICQInterests{
- Keyword1: "Coding",
- Keyword2: "Music",
- }
- err = f.SetInterests(user1.IdentScreenName, interests1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(user2)
- assert.NoError(t, err)
- interests2 := ICQInterests{
- Keyword1: "Coding",
- Keyword3: "Gaming",
- }
- err = f.SetInterests(user2.IdentScreenName, interests2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(user3)
- assert.NoError(t, err)
- interests3 := ICQInterests{
- Keyword3: "Music",
- Keyword4: "Travel",
- }
- err = f.SetInterests(user3.IdentScreenName, interests3)
- assert.NoError(t, err)
- // Helper function to check if a user with a specific IdentScreenName exists in the results
- containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
- for _, user := range users {
- if user.IdentScreenName == screenName {
- return true
- }
- }
- return false
- }
- t.Run("Find Users by Keyword", func(t *testing.T) {
- // Search for users interested in "Music"
- users, err := f.FindByICQKeyword("Music")
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- // Check that the correct users are returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
- })
- t.Run("No Users Found", func(t *testing.T) {
- // Search for users interested in a keyword that no user has
- users, err := f.FindByICQKeyword("Knitting")
- assert.NoError(t, err)
- assert.Empty(t, users)
- })
- }
- func TestSQLiteUserStore_FindByICQName(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create and set up test users with different details using SetBasicInfo
- user1 := User{
- IdentScreenName: NewIdentScreenName("user1"),
- }
- err = f.InsertUser(user1)
- assert.NoError(t, err)
- basicInfo1 := ICQBasicInfo{
- FirstName: "John",
- LastName: "Doe",
- Nickname: "Johnny",
- }
- err = f.SetBasicInfo(user1.IdentScreenName, basicInfo1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(user2)
- assert.NoError(t, err)
- basicInfo2 := ICQBasicInfo{
- FirstName: "Jane",
- LastName: "Smith",
- Nickname: "Janey",
- }
- err = f.SetBasicInfo(user2.IdentScreenName, basicInfo2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(user3)
- assert.NoError(t, err)
- basicInfo3 := ICQBasicInfo{
- FirstName: "John",
- LastName: "Smith",
- Nickname: "JohnnyS",
- }
- err = f.SetBasicInfo(user3.IdentScreenName, basicInfo3)
- assert.NoError(t, err)
- // Helper function to check if a user with a specific IdentScreenName exists in the results
- containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
- for _, user := range users {
- if user.IdentScreenName == screenName {
- return true
- }
- }
- return false
- }
- t.Run("Find Users by First Cookie", func(t *testing.T) {
- // Search for users with the first name "John"
- users, err := f.FindByICQName("John", "", "")
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- // Check that the correct users are returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
- })
- t.Run("Find Users by Last Cookie", func(t *testing.T) {
- // Search for users with the last name "Smith"
- users, err := f.FindByICQName("", "Smith", "")
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- // Check that the correct users are returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
- })
- t.Run("Find Users by Nickname", func(t *testing.T) {
- // Search for users with the nickname "Johnny"
- users, err := f.FindByICQName("", "", "Johnny")
- assert.NoError(t, err)
- assert.Len(t, users, 1)
- // Check that the correct user is returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- })
- t.Run("Find Users by Multiple Fields", func(t *testing.T) {
- // Search for users with the first name "Jane" and last name "Smith"
- users, err := f.FindByICQName("Jane", "Smith", "")
- assert.NoError(t, err)
- assert.Len(t, users, 1)
- // Check that the correct user is returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
- })
- t.Run("No Users Found", func(t *testing.T) {
- // Search for users with a first name that no user has
- users, err := f.FindByICQName("NonExistent", "", "")
- assert.NoError(t, err)
- assert.Empty(t, users)
- })
- }
- func TestSQLiteUserStore_FindByDirectoryInfo(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create and set up test users with different directory info
- user1 := User{
- IdentScreenName: NewIdentScreenName("user1"),
- }
- err = f.InsertUser(user1)
- assert.NoError(t, err)
- directoryInfo1 := AIMNameAndAddr{
- FirstName: "John",
- LastName: "Doe",
- NickName: "Johnny",
- City: "New York",
- }
- err = f.SetDirectoryInfo(user1.IdentScreenName, directoryInfo1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(user2)
- assert.NoError(t, err)
- directoryInfo2 := AIMNameAndAddr{
- FirstName: "Jane",
- LastName: "Smith",
- NickName: "Janey",
- Country: "USA",
- }
- err = f.SetDirectoryInfo(user2.IdentScreenName, directoryInfo2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(user3)
- assert.NoError(t, err)
- directoryInfo3 := AIMNameAndAddr{
- FirstName: "John",
- LastName: "Smith",
- NickName: "JohnnyS",
- State: "California",
- }
- err = f.SetDirectoryInfo(user3.IdentScreenName, directoryInfo3)
- assert.NoError(t, err)
- // Helper function to check if a user with a specific IdentScreenName exists in the results
- containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
- for _, user := range users {
- if user.IdentScreenName == screenName {
- return true
- }
- }
- return false
- }
- t.Run("Find Users by First Cookie", func(t *testing.T) {
- // Search for users with the first name "John"
- users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{FirstName: "John"})
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- // Check that the correct users are returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
- })
- t.Run("Find Users by Last Cookie", func(t *testing.T) {
- // Search for users with the last name "Smith"
- users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{LastName: "Smith"})
- assert.NoError(t, err)
- assert.Len(t, users, 2)
- // Check that the correct users are returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
- assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
- })
- t.Run("Find Users by Nickname", func(t *testing.T) {
- // Search for users with the nickname "Johnny"
- users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{NickName: "Johnny"})
- assert.NoError(t, err)
- assert.Len(t, users, 1)
- // Check that the correct user is returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- })
- t.Run("Find Users by City", func(t *testing.T) {
- // Search for users with the city "New York"
- users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{City: "New York"})
- assert.NoError(t, err)
- assert.Len(t, users, 1)
- // Check that the correct user is returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
- })
- t.Run("Find Users by Multiple Fields", func(t *testing.T) {
- // Search for users with the first name "Jane" and country "USA"
- users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{FirstName: "Jane", Country: "USA"})
- assert.NoError(t, err)
- assert.Len(t, users, 1)
- // Check that the correct user is returned by IdentScreenName
- assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
- })
- t.Run("No Users Found", func(t *testing.T) {
- // Search for users with a first name that no user has
- users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{FirstName: "NonExistent"})
- assert.NoError(t, err)
- assert.Empty(t, users)
- })
- }
- func TestSQLiteUserStore_FindByICQEmail(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create and set up test users with different email addresses using SetBasicInfo
- user1 := User{
- IdentScreenName: NewIdentScreenName("user1"),
- }
- err = f.InsertUser(user1)
- assert.NoError(t, err)
- basicInfo1 := ICQBasicInfo{
- EmailAddress: "user1@example.com",
- }
- err = f.SetBasicInfo(user1.IdentScreenName, basicInfo1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(user2)
- assert.NoError(t, err)
- basicInfo2 := ICQBasicInfo{
- EmailAddress: "user2@example.com",
- }
- err = f.SetBasicInfo(user2.IdentScreenName, basicInfo2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(user3)
- assert.NoError(t, err)
- basicInfo3 := ICQBasicInfo{
- EmailAddress: "user3@example.com",
- }
- err = f.SetBasicInfo(user3.IdentScreenName, basicInfo3)
- assert.NoError(t, err)
- t.Run("Find User by Email", func(t *testing.T) {
- // Search for user with email "user1@example.com"
- user, err := f.FindByICQEmail("user1@example.com")
- assert.NoError(t, err)
- assert.Equal(t, user1.IdentScreenName, user.IdentScreenName)
- // Search for user with email "user2@example.com"
- user, err = f.FindByICQEmail("user2@example.com")
- assert.NoError(t, err)
- assert.Equal(t, user2.IdentScreenName, user.IdentScreenName)
- // Search for user with email "user3@example.com"
- user, err = f.FindByICQEmail("user3@example.com")
- assert.NoError(t, err)
- assert.Equal(t, user3.IdentScreenName, user.IdentScreenName)
- })
- t.Run("User Not Found", func(t *testing.T) {
- // Search for an email that doesn't exist
- _, err := f.FindByICQEmail("nonexistent@example.com")
- assert.ErrorIs(t, err, ErrNoUser)
- })
- }
- func TestSQLiteUserStore_FindByAIMEmail(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- user1 := User{
- IdentScreenName: NewIdentScreenName("user1"),
- }
- err = f.InsertUser(user1)
- assert.NoError(t, err)
- err = f.UpdateEmailAddress(&mail.Address{Address: "user1@example.com"}, user1.IdentScreenName)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- EmailAddress: "user2@example.com",
- }
- err = f.InsertUser(user2)
- assert.NoError(t, err)
- err = f.UpdateEmailAddress(&mail.Address{Address: "user2@example.com"}, user2.IdentScreenName)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- EmailAddress: "user3@example.com",
- }
- err = f.InsertUser(user3)
- assert.NoError(t, err)
- err = f.UpdateEmailAddress(&mail.Address{Address: "user3@example.com"}, user3.IdentScreenName)
- assert.NoError(t, err)
- t.Run("Find User by Email", func(t *testing.T) {
- // Search for user with email "user1@example.com"
- user, err := f.FindByAIMEmail("user1@example.com")
- assert.NoError(t, err)
- assert.Equal(t, user1.IdentScreenName, user.IdentScreenName)
- // Search for user with email "user2@example.com"
- user, err = f.FindByAIMEmail("user2@example.com")
- assert.NoError(t, err)
- assert.Equal(t, user2.IdentScreenName, user.IdentScreenName)
- // Search for user with email "user3@example.com"
- user, err = f.FindByAIMEmail("user3@example.com")
- assert.NoError(t, err)
- assert.Equal(t, user3.IdentScreenName, user.IdentScreenName)
- })
- t.Run("User Not Found", func(t *testing.T) {
- // Search for an email that doesn't exist
- _, err := f.FindByAIMEmail("nonexistent@example.com")
- assert.ErrorIs(t, err, ErrNoUser)
- })
- }
- func TestSQLiteUserStore_FindByUIN(t *testing.T) {
- // Cleanup after test
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Initialize the SQLiteUserStore with a test database file
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create and set up test users where UIN is the same as IdentScreenName
- user1 := User{
- IdentScreenName: NewIdentScreenName("12345"),
- }
- err = f.InsertUser(user1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("67890"),
- }
- err = f.InsertUser(user2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("54321"),
- }
- err = f.InsertUser(user3)
- assert.NoError(t, err)
- t.Run("Find User by UIN", func(t *testing.T) {
- // Search for user with UIN 12345
- user, err := f.FindByUIN(12345)
- assert.NoError(t, err)
- assert.Equal(t, user1.IdentScreenName, user.IdentScreenName)
- // Search for user with UIN 67890
- user, err = f.FindByUIN(67890)
- assert.NoError(t, err)
- assert.Equal(t, user2.IdentScreenName, user.IdentScreenName)
- // Search for user with UIN 54321
- user, err = f.FindByUIN(54321)
- assert.NoError(t, err)
- assert.Equal(t, user3.IdentScreenName, user.IdentScreenName)
- })
- t.Run("User Not Found", func(t *testing.T) {
- // Search for a UIN that doesn't exist
- _, err := f.FindByUIN(99999)
- assert.ErrorIs(t, err, ErrNoUser)
- })
- }
- func TestSQLiteUserStore_RetrieveMessages(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- sendTime := time.Now().UTC()
- offlineMessages := []OfflineMessage{
- {
- Sender: NewIdentScreenName("John"),
- Recipient: NewIdentScreenName("Jack"),
- Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
- Cookie: 1,
- },
- Sent: sendTime,
- },
- {
- Sender: NewIdentScreenName("John"),
- Recipient: NewIdentScreenName("Anne"),
- Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
- Cookie: 2,
- },
- Sent: sendTime,
- },
- {
- Sender: NewIdentScreenName("John"),
- Recipient: NewIdentScreenName("Jack"),
- Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
- Cookie: 3,
- },
- Sent: sendTime,
- },
- }
- for _, msg := range offlineMessages {
- err = f.SaveMessage(msg)
- assert.NoError(t, err)
- }
- t.Run("Retrieve Messages", func(t *testing.T) {
- messages, err := f.RetrieveMessages(NewIdentScreenName("Jack"))
- assert.NoError(t, err)
- if assert.Len(t, messages, 2) {
- assert.Equal(t, offlineMessages[0], messages[0])
- assert.Equal(t, offlineMessages[2], messages[1])
- }
- })
- t.Run("Retrieve No Messages", func(t *testing.T) {
- messages, err := f.RetrieveMessages(NewIdentScreenName("Franke"))
- assert.NoError(t, err)
- assert.Empty(t, messages)
- })
- }
- func TestSQLiteUserStore_DeleteMessages(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- sendTime := time.Now().UTC()
- offlineMessages := []OfflineMessage{
- {
- Sender: NewIdentScreenName("John"),
- Recipient: NewIdentScreenName("Jack"),
- Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
- Cookie: 1,
- },
- Sent: sendTime,
- },
- {
- Sender: NewIdentScreenName("John"),
- Recipient: NewIdentScreenName("Anne"),
- Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
- Cookie: 2,
- },
- Sent: sendTime,
- },
- {
- Sender: NewIdentScreenName("John"),
- Recipient: NewIdentScreenName("Jack"),
- Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
- Cookie: 3,
- },
- Sent: sendTime,
- },
- }
- for _, msg := range offlineMessages {
- err = f.SaveMessage(msg)
- assert.NoError(t, err)
- }
- t.Run("Delete Messages", func(t *testing.T) {
- err := f.DeleteMessages(NewIdentScreenName("Jack"))
- assert.NoError(t, err)
- messages, err := f.RetrieveMessages(NewIdentScreenName("Jack"))
- assert.NoError(t, err)
- assert.Empty(t, messages)
- messages, err = f.RetrieveMessages(NewIdentScreenName("Anne"))
- assert.NoError(t, err)
- assert.Len(t, messages, 1)
- })
- t.Run("Delete No Messages", func(t *testing.T) {
- err := f.DeleteMessages(NewIdentScreenName("Franke"))
- assert.NoError(t, err)
- messages, err := f.RetrieveMessages(NewIdentScreenName("Anne"))
- assert.NoError(t, err)
- assert.Len(t, messages, 1)
- })
- }
- func TestSQLiteUserStore_BuddyIconRefByNameExistingRef(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- screenName := NewIdentScreenName("TalkingTyler")
- testHash := []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'}
- feedbagStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- itemsIn := []wire.FeedbagItem{
- {
- Name: "1",
- ClassID: wire.FeedbagClassIdBart,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesBartInfo, wire.BARTInfo{
- Hash: testHash,
- }),
- },
- },
- },
- }
- if err := feedbagStore.FeedbagUpsert(screenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- b, err := feedbagStore.BuddyIconRefByName(screenName)
- assert.NoError(t, err)
- if !reflect.DeepEqual(b.BARTInfo.Hash, testHash) {
- t.Fatalf("expected hash did not match")
- }
- }
- func TestSQLiteUserStore_BuddyIconRefByNameMissingRef(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- existingScreenName := NewIdentScreenName("TalkingTyler")
- queryScreenName := NewIdentScreenName("SingingSuzy")
- testHash := []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'}
- feedbagStore, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- itemsIn := []wire.FeedbagItem{
- {
- Name: "1",
- ClassID: wire.FeedbagClassIdBart,
- TLVLBlock: wire.TLVLBlock{
- TLVList: wire.TLVList{
- wire.NewTLVBE(wire.FeedbagAttributesBartInfo, wire.BARTInfo{
- Hash: testHash,
- }),
- },
- },
- },
- }
- if err := feedbagStore.FeedbagUpsert(existingScreenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- b, err := feedbagStore.BuddyIconRefByName(queryScreenName)
- assert.NoError(t, err)
- if b != nil {
- t.Fatalf("empty BARTID expected")
- }
- }
- func TestSQLiteUserStore_SetDirectoryInfo(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- screenName := NewIdentScreenName("testuser")
- user := User{
- IdentScreenName: screenName,
- }
- err = f.InsertUser(user)
- assert.NoError(t, err)
- directoryInfo := AIMNameAndAddr{
- FirstName: "John",
- LastName: "Doe",
- MiddleName: "Michael",
- MaidenName: "Smith",
- Country: "USA",
- State: "CA",
- City: "San Francisco",
- NickName: "Johnny",
- ZIPCode: "94105",
- Address: "123 Main St",
- }
- t.Run("Successful Update", func(t *testing.T) {
- err := f.SetDirectoryInfo(screenName, directoryInfo)
- assert.NoError(t, err)
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, directoryInfo.FirstName, updatedUser.AIMDirectoryInfo.FirstName)
- assert.Equal(t, directoryInfo.LastName, updatedUser.AIMDirectoryInfo.LastName)
- assert.Equal(t, directoryInfo.MiddleName, updatedUser.AIMDirectoryInfo.MiddleName)
- assert.Equal(t, directoryInfo.MaidenName, updatedUser.AIMDirectoryInfo.MaidenName)
- assert.Equal(t, directoryInfo.Country, updatedUser.AIMDirectoryInfo.Country)
- assert.Equal(t, directoryInfo.State, updatedUser.AIMDirectoryInfo.State)
- assert.Equal(t, directoryInfo.City, updatedUser.AIMDirectoryInfo.City)
- assert.Equal(t, directoryInfo.NickName, updatedUser.AIMDirectoryInfo.NickName)
- assert.Equal(t, directoryInfo.ZIPCode, updatedUser.AIMDirectoryInfo.ZIPCode)
- assert.Equal(t, directoryInfo.Address, updatedUser.AIMDirectoryInfo.Address)
- })
- t.Run("Update Non-Existing User", func(t *testing.T) {
- nonExistingScreenName := NewIdentScreenName("nonexistentuser")
- err := f.SetDirectoryInfo(nonExistingScreenName, directoryInfo)
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty Directory Info", func(t *testing.T) {
- emptyDirectoryInfo := AIMNameAndAddr{}
- err := f.SetDirectoryInfo(screenName, emptyDirectoryInfo)
- assert.NoError(t, err)
- updatedUser, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.FirstName)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.LastName)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.MiddleName)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.MaidenName)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.Country)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.State)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.City)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.NickName)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.ZIPCode)
- assert.Empty(t, updatedUser.AIMDirectoryInfo.Address)
- })
- }
- func TestSQLiteUserStore_Categories(t *testing.T) {
- t.Run("Retrieve Keyword Categories Successfully", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Insert some test keyword categories
- categories := []string{"Category3", "Category1", "Category2"}
- for _, categoryName := range categories {
- _, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- }
- retrievedCategories, err := f.Categories()
- assert.NoError(t, err)
- // Make sure all categories are returned in alphabetical order
- if assert.Len(t, retrievedCategories, len(categories)) {
- expect := []Category{
- {
- ID: 2,
- Name: "Category1",
- },
- {
- ID: 3,
- Name: "Category2",
- },
- {
- ID: 1,
- Name: "Category3",
- },
- }
- assert.Equal(t, expect, retrievedCategories)
- }
- })
- t.Run("No Categories Exist", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Clean up the database
- _, err = f.db.Exec(`DELETE FROM aimKeywordCategory`)
- assert.NoError(t, err)
- retrievedCategories, err := f.Categories()
- assert.NoError(t, err)
- assert.Empty(t, retrievedCategories)
- })
- t.Run("SQL Error Handling", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Force an error by querying a non-existent table
- _, err = f.db.Exec(`DROP TABLE aimKeywordCategory`)
- assert.NoError(t, err)
- _, err = f.Categories()
- assert.Error(t, err)
- })
- t.Run("Unique Constraint Violation", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Insert a category with a unique name
- categoryName := "UniqueCategory"
- _, err = f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Try to insert the same category name again to trigger the unique constraint
- _, err = f.CreateCategory(categoryName)
- assert.ErrorIs(t, err, ErrKeywordCategoryExists)
- })
- }
- func TestSQLiteUserStore_CreateCategory(t *testing.T) {
- t.Run("Successfully Create Keyword Category", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- categoryName := "TestCategory"
- keywordCategory, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- assert.Equal(t, categoryName, keywordCategory.Name)
- assert.NotZero(t, keywordCategory.ID)
- categories, err := f.Categories()
- assert.NoError(t, err)
- if assert.Len(t, categories, 1) {
- assert.Equal(t, categoryName, categories[0].Name)
- }
- })
- t.Run("Duplicate Category Cookie", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- categoryName := "DuplicateCategory"
- // Create the category
- _, err = f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Try to create the same category again
- _, err = f.CreateCategory(categoryName)
- assert.ErrorIs(t, err, ErrKeywordCategoryExists)
- })
- t.Run("ID Overflow", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Simulate ID overflow by inserting max number of entries
- for i := range math.MaxUint8 {
- _, err := f.CreateCategory(fmt.Sprintf("Category_%d", i))
- assert.NoError(t, err)
- }
- // Next insert should cause an ID overflow
- _, err = f.CreateCategory("OverflowCategory")
- assert.ErrorIs(t, err, errTooManyCategories)
- })
- t.Run("SQL Error Handling", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Drop the table to cause an error
- _, err = f.db.Exec(`DROP TABLE aimKeywordCategory`)
- assert.NoError(t, err)
- _, err = f.CreateCategory("ShouldFail")
- assert.Error(t, err)
- })
- }
- func TestSQLiteUserStore_DeleteCategory(t *testing.T) {
- t.Run("Successfully Delete Keyword Category", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Insert a test category
- categoryName := "CategoryToDelete"
- category, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Ensure the category was created
- retrievedCategories, err := f.Categories()
- assert.NoError(t, err)
- assert.Len(t, retrievedCategories, 1)
- // Delete the category
- err = f.DeleteCategory(category.ID)
- assert.NoError(t, err)
- // Verify the category was deleted
- retrievedCategories, err = f.Categories()
- assert.NoError(t, err)
- assert.Empty(t, retrievedCategories)
- })
- t.Run("Delete Non-Existent Category", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Attempt to delete a category that does not exist
- nonExistentCategoryID := uint8(99)
- err = f.DeleteCategory(nonExistentCategoryID)
- assert.ErrorIs(t, err, ErrKeywordCategoryNotFound)
- })
- t.Run("Delete category and all of its keywords", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Insert a category
- categoryName := "CategoryInUse"
- category, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Insert a keyword that references this category
- keywordName := "KeywordInUse"
- _, err = f.CreateKeyword(keywordName, category.ID)
- assert.NoError(t, err)
- // Create a user and associate it with the keyword
- u := User{
- IdentScreenName: NewIdentScreenName("testuser"),
- }
- err = f.InsertUser(u)
- assert.NoError(t, err)
- err = f.SetKeywords(u.IdentScreenName, [5]string{keywordName})
- assert.NoError(t, err)
- // Attempt to delete the category that is in use by the keyword
- err = f.DeleteCategory(category.ID)
- assert.ErrorIs(t, err, ErrKeywordInUse)
- })
- }
- func TestSQLiteUserStore_CreateKeyword(t *testing.T) {
- t.Run("Successfully Create Keyword", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test category
- categoryName := "TestCategory"
- category, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Insert a keyword for the category
- keywordName := "TestKeyword"
- keyword, err := f.CreateKeyword(keywordName, category.ID)
- assert.NoError(t, err)
- assert.Equal(t, keywordName, keyword.Name)
- assert.NotZero(t, keyword.ID)
- // Verify the keyword and category were inserted into the database
- keywords, err := f.KeywordsByCategory(category.ID)
- assert.NoError(t, err)
- if assert.Len(t, keywords, 1) {
- expect := []Keyword{
- keyword,
- }
- assert.Equal(t, expect, keywords)
- }
- })
- t.Run("Create Keyword Without Category", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Insert a keyword with no category (parent is NULL)
- keywordName := "UncategorizedKeyword"
- keyword, err := f.CreateKeyword(keywordName, 0)
- assert.NoError(t, err)
- assert.Equal(t, keywordName, keyword.Name)
- assert.NotZero(t, keyword.ID)
- // Verify the keyword was inserted into the database
- keywords, err := f.KeywordsByCategory(0)
- assert.NoError(t, err)
- if assert.Len(t, keywords, 1) {
- expect := []Keyword{
- keyword,
- }
- assert.Equal(t, expect, keywords)
- }
- })
- t.Run("Create Keyword With Unknown Category", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Insert a keyword with no category (parent is NULL)
- keywordName := "AKeyword"
- _, err = f.CreateKeyword(keywordName, 1)
- assert.ErrorIs(t, err, ErrKeywordCategoryNotFound)
- })
- t.Run("Duplicate Keyword Cookie", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- keywordName := "DuplicateKeyword"
- // Create the keyword
- _, err = f.CreateKeyword(keywordName, 0)
- assert.NoError(t, err)
- // Try to create the same keyword again
- _, err = f.CreateKeyword(keywordName, 0)
- assert.ErrorIs(t, err, ErrKeywordExists)
- })
- t.Run("ID Overflow", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test category
- categoryName := "OverflowCategory"
- category, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Simulate ID overflow by inserting max number of entries
- for i := 0; i < math.MaxUint8; i++ {
- _, err := f.CreateKeyword(fmt.Sprintf("Keyword_%d", i), category.ID)
- assert.NoError(t, err)
- }
- // Next insert should cause an ID overflow
- _, err = f.CreateKeyword("OverflowKeyword", category.ID)
- assert.ErrorIs(t, err, errTooManyKeywords)
- })
- t.Run("SQL Error Handling", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Drop the table to cause an error
- _, err = f.db.Exec(`DROP TABLE aimKeyword`)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("ShouldFail", 0)
- assert.Error(t, err)
- })
- }
- func TestSQLiteUserStore_DeleteKeyword(t *testing.T) {
- t.Run("Successfully Delete Keyword", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Insert a category
- categoryName := "TestCategory"
- category, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Insert a keyword for the category
- keywordName := "TestKeyword"
- keyword, err := f.CreateKeyword(keywordName, category.ID)
- assert.NoError(t, err)
- // Ensure the keyword was created
- retrievedKeywords, err := f.KeywordsByCategory(category.ID)
- assert.NoError(t, err)
- assert.Len(t, retrievedKeywords, 1)
- // Delete the keyword
- err = f.DeleteKeyword(keyword.ID)
- assert.NoError(t, err)
- // Verify the keyword was deleted
- retrievedKeywords, err = f.KeywordsByCategory(category.ID)
- assert.NoError(t, err)
- assert.Empty(t, retrievedKeywords)
- })
- t.Run("Delete Non-Existent Keyword", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Attempt to delete a keyword that does not exist
- nonExistentKeywordID := uint8(99)
- err = f.DeleteKeyword(nonExistentKeywordID)
- assert.ErrorIs(t, err, ErrKeywordNotFound)
- })
- t.Run("Delete Keyword Associated with User", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- // Insert a category
- categoryName := "CategoryInUse"
- category, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- // Insert a keyword
- keywordName := "KeywordInUse"
- keyword, err := f.CreateKeyword(keywordName, category.ID)
- assert.NoError(t, err)
- // Create a user and associate it with the keyword
- u := User{
- IdentScreenName: NewIdentScreenName("testuser"),
- }
- err = f.InsertUser(u)
- assert.NoError(t, err)
- err = f.SetKeywords(u.IdentScreenName, [5]string{keywordName})
- assert.NoError(t, err)
- // Attempt to delete the keyword and expect an ErrKeywordInUse
- err = f.DeleteKeyword(keyword.ID)
- assert.ErrorIs(t, err, ErrKeywordInUse)
- })
- }
- func TestSQLiteUserStore_InterestList(t *testing.T) {
- t.Run("Full list", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- tech, err := f.CreateCategory("Technology")
- assert.NoError(t, err)
- music, err := f.CreateCategory("Music")
- assert.NoError(t, err)
- sports, err := f.CreateCategory("Sports")
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Rock", music.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Soccer", sports.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Cybersecurity", tech.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Zoology", 0)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Jazz", music.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Animals", 0)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Basketball", sports.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Artificial Intelligence", tech.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword("Tennis", sports.ID)
- assert.NoError(t, err)
- expect := []wire.ODirKeywordListItem{
- {
- ID: 0,
- Name: "Animals",
- Type: wire.ODirKeyword,
- },
- {
- ID: 2,
- Name: "Music",
- Type: wire.ODirKeywordCategory,
- },
- {
- ID: 2,
- Name: "Jazz",
- Type: wire.ODirKeyword,
- },
- {
- ID: 2,
- Name: "Rock",
- Type: wire.ODirKeyword,
- },
- {
- ID: 3,
- Name: "Sports",
- Type: wire.ODirKeywordCategory,
- },
- {
- ID: 3,
- Name: "Basketball",
- Type: wire.ODirKeyword,
- },
- {
- ID: 3,
- Name: "Soccer",
- Type: wire.ODirKeyword,
- },
- {
- ID: 3,
- Name: "Tennis",
- Type: wire.ODirKeyword,
- },
- {
- ID: 1,
- Name: "Technology",
- Type: wire.ODirKeywordCategory,
- },
- {
- ID: 1,
- Name: "Artificial Intelligence",
- Type: wire.ODirKeyword,
- },
- {
- ID: 1,
- Name: "Cybersecurity",
- Type: wire.ODirKeyword,
- },
- {
- ID: 0,
- Name: "Zoology",
- Type: wire.ODirKeyword,
- },
- }
- actual, err := f.InterestList()
- assert.NoError(t, err)
- assert.Equal(t, expect, actual)
- })
- t.Run("Empty list list", func(t *testing.T) {
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- actual, err := f.InterestList()
- assert.NoError(t, err)
- assert.Empty(t, actual)
- })
- }
- func TestSQLiteUserStore_KeywordsByCategory(t *testing.T) {
- t.Run("Category Does Not Exist", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- // Create a test category
- categoryName := "TestCategory"
- category, err := f.CreateCategory(categoryName)
- assert.NoError(t, err)
- keywords, err := f.KeywordsByCategory(category.ID + 1)
- assert.Empty(t, keywords)
- assert.ErrorIs(t, err, ErrKeywordCategoryNotFound)
- })
- }
- func TestSQLiteUserStore_UnregisterBuddyList(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- users := []IdentScreenName{
- NewIdentScreenName("user1"),
- NewIdentScreenName("user2"),
- NewIdentScreenName("user3"),
- }
- for _, me := range users {
- err = f.RegisterBuddyList(me)
- assert.NoError(t, err)
- for _, them := range users {
- if me == them {
- continue
- }
- err = f.AddBuddy(me, them)
- assert.NoError(t, err)
- }
- }
- relationships, err := f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- expect := []Relationship{
- {
- User: NewIdentScreenName("user2"),
- IsOnTheirList: true,
- IsOnYourList: true,
- },
- {
- User: NewIdentScreenName("user3"),
- IsOnTheirList: true,
- IsOnYourList: true,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- err = f.UnregisterBuddyList(users[2])
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(users[0], nil)
- expect = []Relationship{
- {
- User: NewIdentScreenName("user2"),
- IsOnTheirList: true,
- IsOnYourList: true,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- }
- func TestSQLiteUserStore_ClearBuddyListRegistry(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- users := []IdentScreenName{
- NewIdentScreenName("user1"),
- NewIdentScreenName("user2"),
- NewIdentScreenName("user3"),
- }
- for _, me := range users {
- err = f.RegisterBuddyList(me)
- assert.NoError(t, err)
- for _, them := range users {
- if me == them {
- continue
- }
- err = f.AddBuddy(me, them)
- assert.NoError(t, err)
- }
- }
- for _, me := range users {
- var relationships []Relationship
- relationships, err = f.AllRelationships(me, nil)
- assert.NoError(t, err)
- assert.Len(t, relationships, 2)
- }
- err = f.ClearBuddyListRegistry()
- assert.NoError(t, err)
- for _, me := range users {
- var relationships []Relationship
- relationships, err = f.AllRelationships(me, nil)
- assert.NoError(t, err)
- assert.Empty(t, relationships)
- }
- }
- func TestSQLiteUserStore_RemoveBuddy(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- me := NewIdentScreenName("me")
- err = f.RegisterBuddyList(me)
- assert.NoError(t, err)
- them := NewIdentScreenName("them")
- err = f.RegisterBuddyList(them)
- assert.NoError(t, err)
- err = f.AddBuddy(me, them)
- assert.NoError(t, err)
- relationships, err := f.AllRelationships(me, nil)
- assert.NoError(t, err)
- expect := []Relationship{
- {
- User: them,
- IsOnTheirList: false,
- IsOnYourList: true,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- err = f.RemoveBuddy(me, them)
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(me, nil)
- assert.NoError(t, err)
- expect = []Relationship{
- {
- User: them,
- IsOnTheirList: false,
- IsOnYourList: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- }
- func TestSQLiteUserStore_RemoveDenyBuddy(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- me := NewIdentScreenName("me")
- err = f.RegisterBuddyList(me)
- assert.NoError(t, err)
- err = f.SetPDMode(me, wire.FeedbagPDModeDenySome)
- assert.NoError(t, err)
- them := NewIdentScreenName("them")
- err = f.RegisterBuddyList(them)
- assert.NoError(t, err)
- err = f.DenyBuddy(me, them)
- assert.NoError(t, err)
- relationships, err := f.AllRelationships(me, nil)
- assert.NoError(t, err)
- expect := []Relationship{
- {
- User: them,
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: true,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- err = f.RemoveDenyBuddy(me, them)
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(me, nil)
- assert.NoError(t, err)
- expect = []Relationship{
- {
- User: them,
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- }
- func TestSQLiteUserStore_RemovePermitBuddy(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- me := NewIdentScreenName("me")
- err = f.RegisterBuddyList(me)
- assert.NoError(t, err)
- err = f.SetPDMode(me, wire.FeedbagPDModePermitSome)
- assert.NoError(t, err)
- them := NewIdentScreenName("them")
- err = f.RegisterBuddyList(them)
- assert.NoError(t, err)
- err = f.PermitBuddy(me, them)
- assert.NoError(t, err)
- relationships, err := f.AllRelationships(me, nil)
- assert.NoError(t, err)
- expect := []Relationship{
- {
- User: them,
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- err = f.RemovePermitBuddy(me, them)
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(me, nil)
- assert.NoError(t, err)
- expect = []Relationship{
- {
- User: them,
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: true,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- }
- func TestSQLiteUserStore_SetPDMode(t *testing.T) {
- t.Run("Ensure idempotency", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- users := []IdentScreenName{
- NewIdentScreenName("me"),
- NewIdentScreenName("them1"),
- }
- for _, user := range users {
- err = f.RegisterBuddyList(user)
- assert.NoError(t, err)
- }
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(users[0], users[1]))
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
- relationships, err := f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- expect := []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- })
- t.Run("Ensure transition from one mode to another clears previously set flags", func(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- users := []IdentScreenName{
- NewIdentScreenName("me"),
- NewIdentScreenName("them1"),
- }
- for _, user := range users {
- err = f.RegisterBuddyList(user)
- assert.NoError(t, err)
- }
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(users[0], users[1]))
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenySome))
- relationships, err := f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- assert.Empty(t, relationships)
- })
- }
- // Ensure that transitioning between all the PD modes works.
- func TestSQLiteUserStore_PermitDenyTransitionIntegration(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- users := []IdentScreenName{
- NewIdentScreenName("me"),
- NewIdentScreenName("them1"),
- NewIdentScreenName("them2"),
- NewIdentScreenName("them3"),
- }
- for _, user := range users {
- err = f.RegisterBuddyList(user)
- assert.NoError(t, err)
- }
- // add them1 to buddy list
- assert.NoError(t, f.AddBuddy(users[0], users[1]))
- // permit them2
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(users[0], users[2]))
- relationships, err := f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure them1 is blocked and them2 is permitted
- expect := []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: true,
- BlocksYou: false,
- },
- {
- User: users[2],
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // allow everyone
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitAll))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure buddy1 is on your buddy list and permitted
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // permit them3
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(users[0], users[3]))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure them1 is blocked them3 is permitted
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: true,
- BlocksYou: false,
- },
- {
- User: users[3],
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // only allow on buddy list
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitOnList))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure buddy1 is on your buddy list and permitted
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // deny them2
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenySome))
- assert.NoError(t, f.DenyBuddy(users[0], users[2]))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure them1 is allowed and them2 is blocked
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: false,
- BlocksYou: false,
- },
- {
- User: users[2],
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: true,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // allow everyone
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitAll))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure buddy1 is on your buddy list and permitted
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // deny them3
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenySome))
- assert.NoError(t, f.DenyBuddy(users[0], users[3]))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure them1 is allowed and them3 is blocked
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: false,
- BlocksYou: false,
- },
- {
- User: users[3],
- IsOnTheirList: false,
- IsOnYourList: false,
- YouBlock: true,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // deny everyone
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenyAll))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure them1 is blocked
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: true,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- // allow everyone
- assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitAll))
- relationships, err = f.AllRelationships(users[0], nil)
- assert.NoError(t, err)
- // make sure them1 is on your buddy list and permitted
- expect = []Relationship{
- {
- User: users[1],
- IsOnTheirList: false,
- IsOnYourList: true,
- YouBlock: false,
- BlocksYou: false,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- }
- func TestSQLiteUserStore_UpdateSuspendedStatus(t *testing.T) {
- defer func() {
- assert.NoError(t, os.Remove(testFile))
- }()
- f, err := NewSQLiteUserStore(testFile)
- assert.NoError(t, err)
- screenName := NewIdentScreenName("userA")
- insertedUser := &User{
- IdentScreenName: screenName,
- DisplayScreenName: DisplayScreenName("usera"),
- AuthKey: "theauthkey",
- StrongMD5Pass: []byte("thepasshash"),
- RegStatus: 3,
- SuspendedStatus: wire.LoginErrSuspendedAccount,
- }
- err = f.InsertUser(*insertedUser)
- assert.NoError(t, err)
- err = f.UpdateSuspendedStatus(wire.LoginErrSuspendedAccountAge, screenName)
- assert.NoError(t, err)
- user, err := f.User(screenName)
- assert.NoError(t, err)
- assert.Equal(t, user.SuspendedStatus, wire.LoginErrSuspendedAccountAge)
- }
|