| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281 |
- package state
- import (
- "context"
- "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(context.Background(), me, given); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- have, err := f.Feedbag(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), screenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- if err := f.FeedbagDelete(context.Background(), screenName, []wire.FeedbagItem{itemsIn[0]}); err != nil {
- t.Fatalf("failed to delete: %s", err.Error())
- }
- itemsOut, err := f.Feedbag(context.Background(), 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(context.Background(), 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(context.Background(), screenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- _, err = f.FeedbagLastModified(context.Background(), 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(context.Background(), u); err != nil {
- t.Fatalf("failed to upsert new user: %s", err.Error())
- }
- profile, err := f.Profile(context.Background(), 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(context.Background(), screenName, newProfile); err != nil {
- t.Fatalf("failed to create new profile: %s", err.Error())
- }
- profile, err = f.Profile(context.Background(), 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(context.Background(), screenName, updatedProfile); err != nil {
- t.Fatalf("failed to create new profile: %s", err.Error())
- }
- profile, err = f.Profile(context.Background(), 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(context.Background(), 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(context.Background(), *insertedUser)
- assert.NoError(t, err)
- actualUser, err := f.User(context.Background(), 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(context.Background(), 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",
- IsBot: true,
- },
- {
- IdentScreenName: NewIdentScreenName("100003"),
- DisplayScreenName: "100003",
- IsICQ: true,
- },
- }
- for _, u := range want {
- err := f.InsertUser(context.Background(), u)
- assert.NoError(t, err)
- }
- have, err := f.AllUsers(context.Background())
- 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(context.Background(), 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(context.Background(), User{
- IdentScreenName: NewIdentScreenName("userA"),
- DisplayScreenName: "userA",
- })
- assert.NoError(t, err)
- err = f.InsertUser(context.Background(), User{
- IdentScreenName: NewIdentScreenName("userB"),
- DisplayScreenName: "userB",
- })
- assert.NoError(t, err)
- err = f.DeleteUser(context.Background(), NewIdentScreenName("userA"))
- assert.NoError(t, err)
- have, err := f.AllUsers(context.Background())
- 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(context.Background(), 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_SetBuddyIconAndRetrieve(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.BuddyIcon(context.Background(), hash)
- assert.NoError(t, err)
- assert.Empty(t, b)
- err = feedbagStore.SetBuddyIcon(context.Background(), hash, item)
- assert.NoError(t, err)
- b, err = feedbagStore.BuddyIcon(context.Background(), 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(context.Background(), u)
- assert.NoError(t, err)
- err = feedbagStore.SetUserPassword(context.Background(), u.IdentScreenName, "theNEWpassword")
- assert.NoError(t, err)
- gotUser, err := feedbagStore.User(context.Background(), 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(context.Background(), 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(context.Background(), &tt.givenRoom)
- assert.NoError(t, err)
- gotRoom, err := userStore.ChatRoomByCookie(context.Background(), 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(context.Background(), &tt.givenRoom)
- assert.NoError(t, err)
- gotRoom, err := userStore.ChatRoomByName(context.Background(), 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(context.Background(), &chatRooms[i])
- assert.NoError(t, err)
- assert.True(t, chatRooms[i].CreateTime().After(tBefore))
- }
- // public exchange
- gotRooms, err := userStore.AllChatRooms(context.Background(), 5)
- assert.NoError(t, err)
- assert.Equal(t, chatRooms[2:], gotRooms)
- // private exchange
- gotRooms, err = userStore.AllChatRooms(context.Background(), 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(context.Background(), &tc.firstInsert)
- assert.NoError(t, err)
- err = userStore.CreateChatRoom(context.Background(), &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(context.Background(), user); err != nil {
- t.Fatalf("failed to upsert new user: %s", err.Error())
- }
- err = f.UpdateDisplayScreenName(context.Background(), screenNameFormatted)
- if err != nil {
- t.Fatalf("failed to update display screen name: %s", err.Error())
- }
- dbUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, workInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify the work info was set correctly
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, emptyWorkInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify that fields are empty or have default values
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, moreInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify the more info was set correctly
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, emptyMoreInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify that fields are empty or have default values
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, userNotes)
- assert.NoError(t, err)
- // Retrieve the user and verify the notes were set correctly
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, emptyNotes)
- assert.NoError(t, err)
- // Retrieve the user and verify that notes are empty
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, interests)
- assert.NoError(t, err)
- // Retrieve the user and verify the interests were set correctly
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, emptyInterests)
- assert.NoError(t, err)
- // Retrieve the user and verify that interests fields are empty or have default values
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, affiliations)
- assert.NoError(t, err)
- // Retrieve the user and verify the affiliations were set correctly
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, emptyAffiliations)
- assert.NoError(t, err)
- // Retrieve the user and verify that affiliations fields are empty or have default values
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), screenName, basicInfo)
- assert.NoError(t, err)
- // Retrieve the user and verify the basic info was set correctly
- updatedUser, err := f.User(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), user1)
- assert.NoError(t, err)
- interests1 := ICQInterests{
- Code1: 1,
- Keyword1: "Coding",
- Code2: 2,
- Keyword2: "Music",
- }
- err = f.SetInterests(context.Background(), user1.IdentScreenName, interests1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(context.Background(), user2)
- assert.NoError(t, err)
- interests2 := ICQInterests{
- Code1: 1,
- Keyword1: "Coding",
- Code3: 3,
- Keyword3: "Gaming",
- }
- err = f.SetInterests(context.Background(), user2.IdentScreenName, interests2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(context.Background(), user3)
- assert.NoError(t, err)
- interests3 := ICQInterests{
- Code2: 2,
- Keyword2: "Music",
- Code4: 4,
- Keyword4: "Travel",
- }
- err = f.SetInterests(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), user1)
- assert.NoError(t, err)
- interests1 := ICQInterests{
- Keyword1: "Coding",
- Keyword2: "Music",
- }
- err = f.SetInterests(context.Background(), user1.IdentScreenName, interests1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(context.Background(), user2)
- assert.NoError(t, err)
- interests2 := ICQInterests{
- Keyword1: "Coding",
- Keyword3: "Gaming",
- }
- err = f.SetInterests(context.Background(), user2.IdentScreenName, interests2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(context.Background(), user3)
- assert.NoError(t, err)
- interests3 := ICQInterests{
- Keyword3: "Music",
- Keyword4: "Travel",
- }
- err = f.SetInterests(context.Background(), 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(context.Background(), "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(context.Background(), "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(context.Background(), user1)
- assert.NoError(t, err)
- basicInfo1 := ICQBasicInfo{
- FirstName: "John",
- LastName: "Doe",
- Nickname: "Johnny",
- }
- err = f.SetBasicInfo(context.Background(), user1.IdentScreenName, basicInfo1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(context.Background(), user2)
- assert.NoError(t, err)
- basicInfo2 := ICQBasicInfo{
- FirstName: "Jane",
- LastName: "Smith",
- Nickname: "Janey",
- }
- err = f.SetBasicInfo(context.Background(), user2.IdentScreenName, basicInfo2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(context.Background(), user3)
- assert.NoError(t, err)
- basicInfo3 := ICQBasicInfo{
- FirstName: "John",
- LastName: "Smith",
- Nickname: "JohnnyS",
- }
- err = f.SetBasicInfo(context.Background(), 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(context.Background(), "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(context.Background(), "", "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(context.Background(), "", "", "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(context.Background(), "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(context.Background(), "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(context.Background(), user1)
- assert.NoError(t, err)
- directoryInfo1 := AIMNameAndAddr{
- FirstName: "John",
- LastName: "Doe",
- NickName: "Johnny",
- City: "New York",
- }
- err = f.SetDirectoryInfo(context.Background(), user1.IdentScreenName, directoryInfo1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(context.Background(), user2)
- assert.NoError(t, err)
- directoryInfo2 := AIMNameAndAddr{
- FirstName: "Jane",
- LastName: "Smith",
- NickName: "Janey",
- Country: "USA",
- }
- err = f.SetDirectoryInfo(context.Background(), user2.IdentScreenName, directoryInfo2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(context.Background(), user3)
- assert.NoError(t, err)
- directoryInfo3 := AIMNameAndAddr{
- FirstName: "John",
- LastName: "Smith",
- NickName: "JohnnyS",
- State: "California",
- }
- err = f.SetDirectoryInfo(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), user1)
- assert.NoError(t, err)
- basicInfo1 := ICQBasicInfo{
- EmailAddress: "user1@example.com",
- }
- err = f.SetBasicInfo(context.Background(), user1.IdentScreenName, basicInfo1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- }
- err = f.InsertUser(context.Background(), user2)
- assert.NoError(t, err)
- basicInfo2 := ICQBasicInfo{
- EmailAddress: "user2@example.com",
- }
- err = f.SetBasicInfo(context.Background(), user2.IdentScreenName, basicInfo2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- }
- err = f.InsertUser(context.Background(), user3)
- assert.NoError(t, err)
- basicInfo3 := ICQBasicInfo{
- EmailAddress: "user3@example.com",
- }
- err = f.SetBasicInfo(context.Background(), 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(context.Background(), "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(context.Background(), "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(context.Background(), "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(context.Background(), "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(context.Background(), user1)
- assert.NoError(t, err)
- err = f.UpdateEmailAddress(context.Background(), user1.IdentScreenName, &mail.Address{Address: "user1@example.com"})
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("user2"),
- EmailAddress: "user2@example.com",
- }
- err = f.InsertUser(context.Background(), user2)
- assert.NoError(t, err)
- err = f.UpdateEmailAddress(context.Background(), user2.IdentScreenName, &mail.Address{Address: "user2@example.com"})
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("user3"),
- EmailAddress: "user3@example.com",
- }
- err = f.InsertUser(context.Background(), user3)
- assert.NoError(t, err)
- err = f.UpdateEmailAddress(context.Background(), user3.IdentScreenName, &mail.Address{Address: "user3@example.com"})
- 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(context.Background(), "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(context.Background(), "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(context.Background(), "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(context.Background(), "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(context.Background(), user1)
- assert.NoError(t, err)
- user2 := User{
- IdentScreenName: NewIdentScreenName("67890"),
- }
- err = f.InsertUser(context.Background(), user2)
- assert.NoError(t, err)
- user3 := User{
- IdentScreenName: NewIdentScreenName("54321"),
- }
- err = f.InsertUser(context.Background(), 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(context.Background(), 12345)
- assert.NoError(t, err)
- assert.Equal(t, user1.IdentScreenName, user.IdentScreenName)
- // Search for user with UIN 67890
- user, err = f.FindByUIN(context.Background(), 67890)
- assert.NoError(t, err)
- assert.Equal(t, user2.IdentScreenName, user.IdentScreenName)
- // Search for user with UIN 54321
- user, err = f.FindByUIN(context.Background(), 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(context.Background(), 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(context.Background(), msg)
- assert.NoError(t, err)
- }
- t.Run("Retrieve Messages", func(t *testing.T) {
- messages, err := f.RetrieveMessages(context.Background(), 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(context.Background(), 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(context.Background(), msg)
- assert.NoError(t, err)
- }
- t.Run("Delete Messages", func(t *testing.T) {
- err := f.DeleteMessages(context.Background(), NewIdentScreenName("Jack"))
- assert.NoError(t, err)
- messages, err := f.RetrieveMessages(context.Background(), NewIdentScreenName("Jack"))
- assert.NoError(t, err)
- assert.Empty(t, messages)
- messages, err = f.RetrieveMessages(context.Background(), NewIdentScreenName("Anne"))
- assert.NoError(t, err)
- assert.Len(t, messages, 1)
- })
- t.Run("Delete No Messages", func(t *testing.T) {
- err := f.DeleteMessages(context.Background(), NewIdentScreenName("Franke"))
- assert.NoError(t, err)
- messages, err := f.RetrieveMessages(context.Background(), NewIdentScreenName("Anne"))
- assert.NoError(t, err)
- assert.Len(t, messages, 1)
- })
- }
- func TestSQLiteUserStore_BuddyIconMetadataExistingRef(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(context.Background(), screenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- b, err := feedbagStore.BuddyIconMetadata(context.Background(), screenName)
- assert.NoError(t, err)
- if !reflect.DeepEqual(b.BARTInfo.Hash, testHash) {
- t.Fatalf("expected hash did not match")
- }
- }
- func TestSQLiteUserStore_BuddyIconMetadataMissingRef(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(context.Background(), existingScreenName, itemsIn); err != nil {
- t.Fatalf("failed to upsert: %s", err.Error())
- }
- b, err := feedbagStore.BuddyIconMetadata(context.Background(), 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(context.Background(), 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(context.Background(), screenName, directoryInfo)
- assert.NoError(t, err)
- updatedUser, err := f.User(context.Background(), 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(context.Background(), nonExistingScreenName, directoryInfo)
- assert.ErrorIs(t, err, ErrNoUser)
- })
- t.Run("Empty Directory Info", func(t *testing.T) {
- emptyDirectoryInfo := AIMNameAndAddr{}
- err := f.SetDirectoryInfo(context.Background(), screenName, emptyDirectoryInfo)
- assert.NoError(t, err)
- updatedUser, err := f.User(context.Background(), 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(context.Background(), categoryName)
- assert.NoError(t, err)
- }
- retrievedCategories, err := f.Categories(context.Background())
- 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(context.Background())
- 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(context.Background())
- 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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Try to insert the same category name again to trigger the unique constraint
- _, err = f.CreateCategory(context.Background(), 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(context.Background(), categoryName)
- assert.NoError(t, err)
- assert.Equal(t, categoryName, keywordCategory.Name)
- assert.NotZero(t, keywordCategory.ID)
- categories, err := f.Categories(context.Background())
- 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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Try to create the same category again
- _, err = f.CreateCategory(context.Background(), 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(context.Background(), fmt.Sprintf("Category_%d", i))
- assert.NoError(t, err)
- }
- // Next insert should cause an ID overflow
- _, err = f.CreateCategory(context.Background(), "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(context.Background(), "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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Ensure the category was created
- retrievedCategories, err := f.Categories(context.Background())
- assert.NoError(t, err)
- assert.Len(t, retrievedCategories, 1)
- // Delete the category
- err = f.DeleteCategory(context.Background(), category.ID)
- assert.NoError(t, err)
- // Verify the category was deleted
- retrievedCategories, err = f.Categories(context.Background())
- 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(context.Background(), 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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Insert a keyword that references this category
- keywordName := "KeywordInUse"
- _, err = f.CreateKeyword(context.Background(), keywordName, category.ID)
- assert.NoError(t, err)
- // Create a user and associate it with the keyword
- u := User{
- IdentScreenName: NewIdentScreenName("testuser"),
- }
- err = f.InsertUser(context.Background(), u)
- assert.NoError(t, err)
- err = f.SetKeywords(context.Background(), u.IdentScreenName, [5]string{keywordName})
- assert.NoError(t, err)
- // Attempt to delete the category that is in use by the keyword
- err = f.DeleteCategory(context.Background(), 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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Insert a keyword for the category
- keywordName := "TestKeyword"
- keyword, err := f.CreateKeyword(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), 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(context.Background(), keywordName, 0)
- assert.NoError(t, err)
- // Try to create the same keyword again
- _, err = f.CreateKeyword(context.Background(), 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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Simulate ID overflow by inserting max number of entries
- for i := 0; i < math.MaxUint8; i++ {
- _, err := f.CreateKeyword(context.Background(), fmt.Sprintf("Keyword_%d", i), category.ID)
- assert.NoError(t, err)
- }
- // Next insert should cause an ID overflow
- _, err = f.CreateKeyword(context.Background(), "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(context.Background(), "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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Insert a keyword for the category
- keywordName := "TestKeyword"
- keyword, err := f.CreateKeyword(context.Background(), keywordName, category.ID)
- assert.NoError(t, err)
- // Ensure the keyword was created
- retrievedKeywords, err := f.KeywordsByCategory(context.Background(), category.ID)
- assert.NoError(t, err)
- assert.Len(t, retrievedKeywords, 1)
- // Delete the keyword
- err = f.DeleteKeyword(context.Background(), keyword.ID)
- assert.NoError(t, err)
- // Verify the keyword was deleted
- retrievedKeywords, err = f.KeywordsByCategory(context.Background(), 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(context.Background(), 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(context.Background(), categoryName)
- assert.NoError(t, err)
- // Insert a keyword
- keywordName := "KeywordInUse"
- keyword, err := f.CreateKeyword(context.Background(), keywordName, category.ID)
- assert.NoError(t, err)
- // Create a user and associate it with the keyword
- u := User{
- IdentScreenName: NewIdentScreenName("testuser"),
- }
- err = f.InsertUser(context.Background(), u)
- assert.NoError(t, err)
- err = f.SetKeywords(context.Background(), u.IdentScreenName, [5]string{keywordName})
- assert.NoError(t, err)
- // Attempt to delete the keyword and expect an ErrKeywordInUse
- err = f.DeleteKeyword(context.Background(), 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(context.Background(), "Technology")
- assert.NoError(t, err)
- music, err := f.CreateCategory(context.Background(), "Music")
- assert.NoError(t, err)
- sports, err := f.CreateCategory(context.Background(), "Sports")
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Rock", music.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Soccer", sports.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Cybersecurity", tech.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Zoology", 0)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Jazz", music.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Animals", 0)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Basketball", sports.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "Artificial Intelligence", tech.ID)
- assert.NoError(t, err)
- _, err = f.CreateKeyword(context.Background(), "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(context.Background())
- 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(context.Background())
- 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(context.Background(), categoryName)
- assert.NoError(t, err)
- keywords, err := f.KeywordsByCategory(context.Background(), 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(context.Background(), me)
- assert.NoError(t, err)
- for _, them := range users {
- if me == them {
- continue
- }
- err = f.AddBuddy(context.Background(), me, them)
- assert.NoError(t, err)
- }
- }
- relationships, err := f.AllRelationships(context.Background(), 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(context.Background(), users[2])
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), me)
- assert.NoError(t, err)
- for _, them := range users {
- if me == them {
- continue
- }
- err = f.AddBuddy(context.Background(), me, them)
- assert.NoError(t, err)
- }
- }
- for _, me := range users {
- var relationships []Relationship
- relationships, err = f.AllRelationships(context.Background(), me, nil)
- assert.NoError(t, err)
- assert.Len(t, relationships, 2)
- }
- err = f.ClearBuddyListRegistry(context.Background())
- assert.NoError(t, err)
- for _, me := range users {
- var relationships []Relationship
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), me)
- assert.NoError(t, err)
- them := NewIdentScreenName("them")
- err = f.RegisterBuddyList(context.Background(), them)
- assert.NoError(t, err)
- err = f.AddBuddy(context.Background(), me, them)
- assert.NoError(t, err)
- relationships, err := f.AllRelationships(context.Background(), me, nil)
- assert.NoError(t, err)
- expect := []Relationship{
- {
- User: them,
- IsOnTheirList: false,
- IsOnYourList: true,
- },
- }
- assert.ElementsMatch(t, relationships, expect)
- err = f.RemoveBuddy(context.Background(), me, them)
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), me)
- assert.NoError(t, err)
- err = f.SetPDMode(context.Background(), me, wire.FeedbagPDModeDenySome)
- assert.NoError(t, err)
- them := NewIdentScreenName("them")
- err = f.RegisterBuddyList(context.Background(), them)
- assert.NoError(t, err)
- err = f.DenyBuddy(context.Background(), me, them)
- assert.NoError(t, err)
- relationships, err := f.AllRelationships(context.Background(), 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(context.Background(), me, them)
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), me)
- assert.NoError(t, err)
- err = f.SetPDMode(context.Background(), me, wire.FeedbagPDModePermitSome)
- assert.NoError(t, err)
- them := NewIdentScreenName("them")
- err = f.RegisterBuddyList(context.Background(), them)
- assert.NoError(t, err)
- err = f.PermitBuddy(context.Background(), me, them)
- assert.NoError(t, err)
- relationships, err := f.AllRelationships(context.Background(), 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(context.Background(), me, them)
- assert.NoError(t, err)
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), user)
- assert.NoError(t, err)
- }
- assert.NoError(t, f.SetPDMode(context.Background(), users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(context.Background(), users[0], users[1]))
- assert.NoError(t, f.SetPDMode(context.Background(), users[0], wire.FeedbagPDModePermitSome))
- relationships, err := f.AllRelationships(context.Background(), 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(context.Background(), user)
- assert.NoError(t, err)
- }
- assert.NoError(t, f.SetPDMode(context.Background(), users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(context.Background(), users[0], users[1]))
- assert.NoError(t, f.SetPDMode(context.Background(), users[0], wire.FeedbagPDModeDenySome))
- relationships, err := f.AllRelationships(context.Background(), 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(context.Background(), user)
- assert.NoError(t, err)
- }
- // add them1 to buddy list
- assert.NoError(t, f.AddBuddy(context.Background(), users[0], users[1]))
- // permit them2
- assert.NoError(t, f.SetPDMode(context.Background(), users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(context.Background(), users[0], users[2]))
- relationships, err := f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModePermitAll))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModePermitSome))
- assert.NoError(t, f.PermitBuddy(context.Background(), users[0], users[3]))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModePermitOnList))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModeDenySome))
- assert.NoError(t, f.DenyBuddy(context.Background(), users[0], users[2]))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModePermitAll))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModeDenySome))
- assert.NoError(t, f.DenyBuddy(context.Background(), users[0], users[3]))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModeDenyAll))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), users[0], wire.FeedbagPDModePermitAll))
- relationships, err = f.AllRelationships(context.Background(), 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(context.Background(), *insertedUser)
- assert.NoError(t, err)
- err = f.UpdateSuspendedStatus(context.Background(), wire.LoginErrSuspendedAccountAge, screenName)
- assert.NoError(t, err)
- user, err := f.User(context.Background(), screenName)
- assert.NoError(t, err)
- assert.Equal(t, user.SuspendedStatus, wire.LoginErrSuspendedAccountAge)
- }
- func TestSQLiteUserStore_SetBotStatus(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"),
- IsBot: false,
- }
- err = f.InsertUser(context.Background(), *insertedUser)
- assert.NoError(t, err)
- user, err := f.User(context.Background(), screenName)
- assert.NoError(t, err)
- assert.False(t, user.IsBot)
- err = f.SetBotStatus(context.Background(), true, screenName)
- assert.NoError(t, err)
- user, err = f.User(context.Background(), screenName)
- assert.NoError(t, err)
- assert.True(t, user.IsBot)
- err = f.SetBotStatus(context.Background(), false, screenName)
- assert.NoError(t, err)
- user, err = f.User(context.Background(), screenName)
- assert.NoError(t, err)
- assert.False(t, user.IsBot)
- }
|