user_store_test.go 84 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141
  1. package state
  2. import (
  3. "fmt"
  4. "math"
  5. "net/mail"
  6. "os"
  7. "reflect"
  8. "testing"
  9. "time"
  10. "github.com/mk6i/retro-aim-server/wire"
  11. "github.com/stretchr/testify/assert"
  12. )
  13. const testFile string = "aim_test.db"
  14. func TestUserStore(t *testing.T) {
  15. screenName := NewIdentScreenName("sn2day")
  16. defer func() {
  17. assert.NoError(t, os.Remove(testFile))
  18. }()
  19. f, err := NewSQLiteUserStore(testFile)
  20. assert.NoError(t, err)
  21. itemsIn := []wire.FeedbagItem{
  22. {
  23. GroupID: 0,
  24. ItemID: 1805,
  25. ClassID: 3,
  26. Name: "spimmer1234",
  27. TLVLBlock: wire.TLVLBlock{},
  28. },
  29. {
  30. GroupID: 0x0A,
  31. ItemID: 0,
  32. ClassID: 1,
  33. Name: "Friends",
  34. },
  35. }
  36. if err := f.FeedbagUpsert(screenName, itemsIn); err != nil {
  37. t.Fatalf("failed to upsert: %s", err.Error())
  38. }
  39. itemsOut, err := f.Feedbag(screenName)
  40. if err != nil {
  41. t.Fatalf("failed to retrieve: %s", err.Error())
  42. }
  43. if !reflect.DeepEqual(itemsIn, itemsOut) {
  44. t.Fatalf("items did not match:\n in: %v\n out: %v", itemsIn, itemsOut)
  45. }
  46. }
  47. func TestFeedbagDelete(t *testing.T) {
  48. screenName := NewIdentScreenName("sn2day")
  49. defer func() {
  50. assert.NoError(t, os.Remove(testFile))
  51. }()
  52. f, err := NewSQLiteUserStore(testFile)
  53. assert.NoError(t, err)
  54. itemsIn := []wire.FeedbagItem{
  55. {
  56. GroupID: 0,
  57. ItemID: 1805,
  58. ClassID: 3,
  59. Name: "spimmer1234",
  60. TLVLBlock: wire.TLVLBlock{
  61. TLVList: wire.TLVList{
  62. wire.NewTLVBE(0x01, uint16(1000)),
  63. },
  64. },
  65. },
  66. {
  67. GroupID: 0x0A,
  68. ItemID: 0,
  69. ClassID: 1,
  70. Name: "Friends",
  71. },
  72. {
  73. GroupID: 0x0B,
  74. ItemID: 100,
  75. ClassID: 1,
  76. Name: "co-workers",
  77. },
  78. }
  79. if err := f.FeedbagUpsert(screenName, itemsIn); err != nil {
  80. t.Fatalf("failed to upsert: %s", err.Error())
  81. }
  82. if err := f.FeedbagDelete(screenName, []wire.FeedbagItem{itemsIn[0]}); err != nil {
  83. t.Fatalf("failed to delete: %s", err.Error())
  84. }
  85. itemsOut, err := f.Feedbag(screenName)
  86. if err != nil {
  87. t.Fatalf("failed to retrieve: %s", err.Error())
  88. }
  89. expect := itemsIn[1:]
  90. if !reflect.DeepEqual(expect, itemsOut) {
  91. t.Fatalf("items did not match:\n in: %v\n out: %v", expect, itemsOut)
  92. }
  93. }
  94. func TestLastModifiedEmpty(t *testing.T) {
  95. screenName := NewIdentScreenName("sn2day")
  96. defer func() {
  97. assert.NoError(t, os.Remove(testFile))
  98. }()
  99. f, err := NewSQLiteUserStore(testFile)
  100. assert.NoError(t, err)
  101. _, err = f.FeedbagLastModified(screenName)
  102. if err != nil {
  103. t.Fatalf("get error from last modified: %s", err.Error())
  104. }
  105. }
  106. func TestLastModifiedNotEmpty(t *testing.T) {
  107. screenName := NewIdentScreenName("sn2day")
  108. defer func() {
  109. assert.NoError(t, os.Remove(testFile))
  110. }()
  111. f, err := NewSQLiteUserStore(testFile)
  112. assert.NoError(t, err)
  113. itemsIn := []wire.FeedbagItem{
  114. {
  115. GroupID: 0x0A,
  116. ItemID: 0,
  117. ClassID: 1,
  118. Name: "Friends",
  119. },
  120. }
  121. if err := f.FeedbagUpsert(screenName, itemsIn); err != nil {
  122. t.Fatalf("failed to upsert: %s", err.Error())
  123. }
  124. _, err = f.FeedbagLastModified(screenName)
  125. if err != nil {
  126. t.Fatalf("get error from last modified: %s", err.Error())
  127. }
  128. }
  129. func TestProfile(t *testing.T) {
  130. screenName := NewIdentScreenName("sn2day")
  131. defer func() {
  132. assert.NoError(t, os.Remove(testFile))
  133. }()
  134. f, err := NewSQLiteUserStore(testFile)
  135. assert.NoError(t, err)
  136. u := User{
  137. IdentScreenName: screenName,
  138. }
  139. if err := f.InsertUser(u); err != nil {
  140. t.Fatalf("failed to upsert new user: %s", err.Error())
  141. }
  142. profile, err := f.Profile(screenName)
  143. if err != nil {
  144. t.Fatalf("failed to retrieve profile: %s", err.Error())
  145. }
  146. if profile != "" {
  147. t.Fatalf("expected empty profile for %s", screenName)
  148. }
  149. newProfile := "here is my profile"
  150. if err := f.SetProfile(screenName, newProfile); err != nil {
  151. t.Fatalf("failed to create new profile: %s", err.Error())
  152. }
  153. profile, err = f.Profile(screenName)
  154. if err != nil {
  155. t.Fatalf("failed to retrieve profile: %s", err.Error())
  156. }
  157. if !reflect.DeepEqual(newProfile, profile) {
  158. t.Fatalf("profiles did not match:\n expected: %v\n actual: %v", newProfile, profile)
  159. }
  160. updatedProfile := "here is my profile [updated]"
  161. if err := f.SetProfile(screenName, updatedProfile); err != nil {
  162. t.Fatalf("failed to create new profile: %s", err.Error())
  163. }
  164. profile, err = f.Profile(screenName)
  165. if err != nil {
  166. t.Fatalf("failed to retrieve profile: %s", err.Error())
  167. }
  168. if !reflect.DeepEqual(updatedProfile, profile) {
  169. t.Fatalf("updated profiles did not match:\n expected: %v\n actual: %v", newProfile, profile)
  170. }
  171. }
  172. func TestProfileNonExistent(t *testing.T) {
  173. screenName := NewIdentScreenName("sn2day")
  174. defer func() {
  175. assert.NoError(t, os.Remove(testFile))
  176. }()
  177. f, err := NewSQLiteUserStore(testFile)
  178. assert.NoError(t, err)
  179. prof, err := f.Profile(screenName)
  180. assert.NoError(t, err)
  181. assert.Empty(t, prof)
  182. }
  183. func TestGetUser(t *testing.T) {
  184. defer func() {
  185. assert.NoError(t, os.Remove(testFile))
  186. }()
  187. f, err := NewSQLiteUserStore(testFile)
  188. assert.NoError(t, err)
  189. screenName := NewIdentScreenName("testscreenname")
  190. insertedUser := &User{
  191. IdentScreenName: screenName,
  192. DisplayScreenName: DisplayScreenName("testscreenname"),
  193. AuthKey: "theauthkey",
  194. StrongMD5Pass: []byte("thepasshash"),
  195. RegStatus: 3,
  196. }
  197. err = f.InsertUser(*insertedUser)
  198. assert.NoError(t, err)
  199. actualUser, err := f.User(screenName)
  200. if err != nil {
  201. t.Fatalf("failed to get user: %s", err.Error())
  202. }
  203. if !reflect.DeepEqual(insertedUser, actualUser) {
  204. t.Fatalf("users are not equal. expect: %v actual: %v", insertedUser, actualUser)
  205. }
  206. }
  207. func TestGetUserNotFound(t *testing.T) {
  208. defer func() {
  209. assert.NoError(t, os.Remove(testFile))
  210. }()
  211. f, err := NewSQLiteUserStore(testFile)
  212. assert.NoError(t, err)
  213. actualUser, err := f.User(NewIdentScreenName("testscreenname"))
  214. if err != nil {
  215. t.Fatalf("failed to get user: %s", err.Error())
  216. }
  217. if actualUser != nil {
  218. t.Fatal("expected user to not be found")
  219. }
  220. }
  221. func TestSQLiteUserStore_Users(t *testing.T) {
  222. defer func() {
  223. assert.NoError(t, os.Remove(testFile))
  224. }()
  225. f, err := NewSQLiteUserStore(testFile)
  226. assert.NoError(t, err)
  227. want := []User{
  228. {
  229. IdentScreenName: NewIdentScreenName("userA"),
  230. DisplayScreenName: "userA",
  231. },
  232. {
  233. IdentScreenName: NewIdentScreenName("userB"),
  234. DisplayScreenName: "userB",
  235. },
  236. {
  237. IdentScreenName: NewIdentScreenName("userC"),
  238. DisplayScreenName: "userC",
  239. },
  240. {
  241. IdentScreenName: NewIdentScreenName("100003"),
  242. DisplayScreenName: "100003",
  243. IsICQ: true,
  244. },
  245. }
  246. for _, u := range want {
  247. err := f.InsertUser(u)
  248. assert.NoError(t, err)
  249. }
  250. have, err := f.AllUsers()
  251. assert.NoError(t, err)
  252. assert.Equal(t, want, have)
  253. }
  254. func TestSQLiteUserStore_InsertUser_UINButNotIsICQ(t *testing.T) {
  255. defer func() {
  256. assert.NoError(t, os.Remove(testFile))
  257. }()
  258. f, err := NewSQLiteUserStore(testFile)
  259. assert.NoError(t, err)
  260. user := User{
  261. IdentScreenName: NewIdentScreenName("100003"),
  262. DisplayScreenName: "100003",
  263. }
  264. err = f.InsertUser(user)
  265. assert.ErrorContains(t, err, "inserting user with UIN and isICQ=false")
  266. }
  267. func TestSQLiteUserStore_DeleteUser_DeleteExistentUser(t *testing.T) {
  268. defer func() {
  269. assert.NoError(t, os.Remove(testFile))
  270. }()
  271. f, err := NewSQLiteUserStore(testFile)
  272. assert.NoError(t, err)
  273. err = f.InsertUser(User{
  274. IdentScreenName: NewIdentScreenName("userA"),
  275. DisplayScreenName: "userA",
  276. })
  277. assert.NoError(t, err)
  278. err = f.InsertUser(User{
  279. IdentScreenName: NewIdentScreenName("userB"),
  280. DisplayScreenName: "userB",
  281. })
  282. assert.NoError(t, err)
  283. err = f.DeleteUser(NewIdentScreenName("userA"))
  284. assert.NoError(t, err)
  285. have, err := f.AllUsers()
  286. assert.NoError(t, err)
  287. want := []User{{
  288. IdentScreenName: NewIdentScreenName("userB"),
  289. DisplayScreenName: "userB",
  290. }}
  291. assert.Equal(t, want, have)
  292. }
  293. func TestSQLiteUserStore_DeleteUser_DeleteNonExistentUser(t *testing.T) {
  294. defer func() {
  295. assert.NoError(t, os.Remove(testFile))
  296. }()
  297. f, err := NewSQLiteUserStore(testFile)
  298. assert.NoError(t, err)
  299. err = f.DeleteUser(NewIdentScreenName("userA"))
  300. assert.ErrorIs(t, ErrNoUser, err)
  301. }
  302. func TestNewStubUser(t *testing.T) {
  303. have, err := NewStubUser("userA")
  304. assert.NoError(t, err)
  305. want := User{
  306. IdentScreenName: NewIdentScreenName("userA"),
  307. DisplayScreenName: "userA",
  308. AuthKey: have.AuthKey,
  309. }
  310. assert.NoError(t, want.HashPassword("welcome1"))
  311. assert.Equal(t, want, have)
  312. }
  313. func newFeedbagItem(classID uint16, itemID uint16, name string) wire.FeedbagItem {
  314. return wire.FeedbagItem{
  315. ClassID: classID,
  316. ItemID: itemID,
  317. Name: name,
  318. }
  319. }
  320. func pdInfoItem(itemID uint16, pdMode wire.FeedbagPDMode) wire.FeedbagItem {
  321. return wire.FeedbagItem{
  322. ClassID: wire.FeedbagClassIdPdinfo,
  323. ItemID: itemID,
  324. TLVLBlock: wire.TLVLBlock{
  325. TLVList: wire.TLVList{
  326. wire.NewTLVBE(wire.FeedbagAttributesPdMode, uint8(pdMode)),
  327. },
  328. },
  329. }
  330. }
  331. func TestSQLiteUserStore_BARTUpsertAndRetrieve(t *testing.T) {
  332. defer func() {
  333. assert.NoError(t, os.Remove(testFile))
  334. }()
  335. feedbagStore, err := NewSQLiteUserStore(testFile)
  336. assert.NoError(t, err)
  337. hash := []byte{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15}
  338. item := []byte{'a', 'b', 'c', 'd'}
  339. b, err := feedbagStore.BARTRetrieve(hash)
  340. assert.NoError(t, err)
  341. assert.Empty(t, b)
  342. err = feedbagStore.BARTUpsert(hash, item)
  343. assert.NoError(t, err)
  344. b, err = feedbagStore.BARTRetrieve(hash)
  345. assert.NoError(t, err)
  346. assert.Equal(t, item, b)
  347. }
  348. func TestSQLiteUserStore_SetUserPassword_UserExists(t *testing.T) {
  349. defer func() {
  350. assert.NoError(t, os.Remove(testFile))
  351. }()
  352. feedbagStore, err := NewSQLiteUserStore(testFile)
  353. assert.NoError(t, err)
  354. u := User{
  355. IdentScreenName: NewIdentScreenName("theuser"),
  356. DisplayScreenName: "theUser",
  357. }
  358. err = u.HashPassword("thepassword")
  359. assert.NoError(t, err)
  360. err = feedbagStore.InsertUser(u)
  361. assert.NoError(t, err)
  362. err = feedbagStore.SetUserPassword(u.IdentScreenName, "theNEWpassword")
  363. assert.NoError(t, err)
  364. gotUser, err := feedbagStore.User(u.IdentScreenName)
  365. assert.NoError(t, err)
  366. wantUser := User{}
  367. wantUser.HashPassword("theNEWpassword")
  368. valid := gotUser.ValidateHash(wantUser.StrongMD5Pass)
  369. assert.True(t, valid)
  370. }
  371. func TestSQLiteUserStore_SetUserPassword_ErrNoUser(t *testing.T) {
  372. defer func() {
  373. assert.NoError(t, os.Remove(testFile))
  374. }()
  375. feedbagStore, err := NewSQLiteUserStore(testFile)
  376. assert.NoError(t, err)
  377. err = feedbagStore.SetUserPassword(NewIdentScreenName("some_user"), "thepassword")
  378. assert.ErrorIs(t, err, ErrNoUser)
  379. }
  380. func TestSQLiteUserStore_ChatRoomByCookie(t *testing.T) {
  381. tests := []struct {
  382. name string
  383. givenRoom ChatRoom
  384. lookupRoom ChatRoom
  385. expectedErr error
  386. }{
  387. {
  388. name: "chat room found",
  389. givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  390. lookupRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  391. expectedErr: nil,
  392. },
  393. {
  394. name: "chat room found - different name casing",
  395. givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  396. lookupRoom: NewChatRoom("MY CHAT ROOM", NewIdentScreenName("creator"), PrivateExchange),
  397. expectedErr: nil,
  398. },
  399. {
  400. name: "chat room not found",
  401. givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  402. lookupRoom: NewChatRoom("your chat room", NewIdentScreenName("creator"), PrivateExchange),
  403. expectedErr: ErrChatRoomNotFound,
  404. },
  405. }
  406. for _, tt := range tests {
  407. t.Run(tt.name, func(t *testing.T) {
  408. defer func() {
  409. assert.NoError(t, os.Remove(testFile))
  410. }()
  411. userStore, err := NewSQLiteUserStore(testFile)
  412. assert.NoError(t, err)
  413. err = userStore.CreateChatRoom(&tt.givenRoom)
  414. assert.NoError(t, err)
  415. gotRoom, err := userStore.ChatRoomByCookie(tt.lookupRoom.Cookie())
  416. assert.ErrorIs(t, err, tt.expectedErr)
  417. if tt.expectedErr == nil {
  418. assert.Equal(t, tt.givenRoom.Cookie(), gotRoom.Cookie())
  419. }
  420. })
  421. }
  422. }
  423. func TestSQLiteUserStore_ChatRoomByName(t *testing.T) {
  424. tests := []struct {
  425. name string
  426. givenRoom ChatRoom
  427. lookupRoom ChatRoom
  428. expectedErr error
  429. }{
  430. {
  431. name: "chat room found",
  432. givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  433. lookupRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  434. expectedErr: nil,
  435. },
  436. {
  437. name: "chat room found - different name casing",
  438. givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  439. lookupRoom: NewChatRoom("MY CHAT ROOM", NewIdentScreenName("creator"), PrivateExchange),
  440. expectedErr: nil,
  441. },
  442. {
  443. name: "chat room not found",
  444. givenRoom: NewChatRoom("my chat room", NewIdentScreenName("creator"), PrivateExchange),
  445. lookupRoom: NewChatRoom("your chat room", NewIdentScreenName("creator"), PrivateExchange),
  446. expectedErr: ErrChatRoomNotFound,
  447. },
  448. }
  449. for _, tt := range tests {
  450. t.Run(tt.name, func(t *testing.T) {
  451. defer func() {
  452. assert.NoError(t, os.Remove(testFile))
  453. }()
  454. userStore, err := NewSQLiteUserStore(testFile)
  455. assert.NoError(t, err)
  456. err = userStore.CreateChatRoom(&tt.givenRoom)
  457. assert.NoError(t, err)
  458. gotRoom, err := userStore.ChatRoomByName(tt.lookupRoom.Exchange(), tt.lookupRoom.Name())
  459. assert.ErrorIs(t, err, tt.expectedErr)
  460. if tt.expectedErr == nil {
  461. assert.Equal(t, tt.givenRoom.Cookie(), gotRoom.Cookie())
  462. }
  463. })
  464. }
  465. }
  466. func TestSQLiteUserStore_AllChatRooms(t *testing.T) {
  467. defer func() {
  468. assert.NoError(t, os.Remove(testFile))
  469. }()
  470. userStore, err := NewSQLiteUserStore(testFile)
  471. assert.NoError(t, err)
  472. chatRooms := []ChatRoom{
  473. NewChatRoom("chat room 1", NewIdentScreenName("creator"), PrivateExchange),
  474. NewChatRoom("chat room 2", NewIdentScreenName("creator"), PrivateExchange),
  475. NewChatRoom("chat room 3", NewIdentScreenName("creator"), PublicExchange),
  476. }
  477. for i := range chatRooms {
  478. tBefore := (&chatRooms[i]).CreateTime()
  479. err = userStore.CreateChatRoom(&chatRooms[i])
  480. assert.NoError(t, err)
  481. assert.True(t, chatRooms[i].CreateTime().After(tBefore))
  482. }
  483. // public exchange
  484. gotRooms, err := userStore.AllChatRooms(5)
  485. assert.NoError(t, err)
  486. assert.Equal(t, chatRooms[2:], gotRooms)
  487. // private exchange
  488. gotRooms, err = userStore.AllChatRooms(4)
  489. assert.NoError(t, err)
  490. assert.Equal(t, chatRooms[0:2], gotRooms)
  491. }
  492. func TestSQLiteUserStore_CreateChatRoom_ErrChatRoomExists(t *testing.T) {
  493. tt := []struct {
  494. name string
  495. firstInsert ChatRoom
  496. secondInsert ChatRoom
  497. wantErr error
  498. }{
  499. {
  500. name: "create two rooms with different cookie/exchange, same name",
  501. firstInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PublicExchange),
  502. secondInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PrivateExchange),
  503. wantErr: nil,
  504. },
  505. {
  506. name: "create two rooms with same cookie/exchange/name",
  507. firstInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PublicExchange),
  508. secondInsert: NewChatRoom("chat room", NewIdentScreenName("creator"), PublicExchange),
  509. wantErr: ErrDupChatRoom,
  510. },
  511. }
  512. for _, tc := range tt {
  513. t.Run(tc.name, func(t *testing.T) {
  514. defer func() {
  515. assert.NoError(t, os.Remove(testFile))
  516. }()
  517. userStore, err := NewSQLiteUserStore(testFile)
  518. assert.NoError(t, err)
  519. err = userStore.CreateChatRoom(&tc.firstInsert)
  520. assert.NoError(t, err)
  521. err = userStore.CreateChatRoom(&tc.secondInsert)
  522. assert.ErrorIs(t, err, tc.wantErr)
  523. })
  524. }
  525. }
  526. func TestUpdateDisplayScreenName(t *testing.T) {
  527. screenNameOriginal := DisplayScreenName("chattingchuck")
  528. screenNameFormatted := DisplayScreenName("Chatting Chuck")
  529. defer func() {
  530. assert.NoError(t, os.Remove(testFile))
  531. }()
  532. f, err := NewSQLiteUserStore(testFile)
  533. assert.NoError(t, err)
  534. user := User{
  535. DisplayScreenName: screenNameOriginal,
  536. IdentScreenName: screenNameOriginal.IdentScreenName(),
  537. RegStatus: 3,
  538. }
  539. if err := f.InsertUser(user); err != nil {
  540. t.Fatalf("failed to upsert new user: %s", err.Error())
  541. }
  542. err = f.UpdateDisplayScreenName(screenNameFormatted)
  543. if err != nil {
  544. t.Fatalf("failed to update display screen name: %s", err.Error())
  545. }
  546. dbUser, err := f.User(screenNameOriginal.IdentScreenName())
  547. if err != nil {
  548. t.Fatalf("failed to retrieve screen name: %s", err.Error())
  549. }
  550. assert.Equal(t, dbUser.DisplayScreenName, screenNameFormatted)
  551. }
  552. func TestSQLiteUserStore_SetWorkInfo(t *testing.T) {
  553. defer func() {
  554. assert.NoError(t, os.Remove(testFile))
  555. }()
  556. f, err := NewSQLiteUserStore(testFile)
  557. assert.NoError(t, err)
  558. screenName := NewIdentScreenName("testuser")
  559. user := User{
  560. IdentScreenName: screenName,
  561. }
  562. err = f.InsertUser(user)
  563. assert.NoError(t, err)
  564. // Define the work info to set
  565. workInfo := ICQWorkInfo{
  566. Company: "Test Company",
  567. Department: "Test Department",
  568. OccupationCode: 10,
  569. Position: "Test Position",
  570. Address: "123 Test St",
  571. City: "Test City",
  572. CountryCode: 1,
  573. Fax: "123-456-7890",
  574. Phone: "098-765-4321",
  575. State: "Test State",
  576. WebPage: "http://www.test.com",
  577. ZIPCode: "12345",
  578. }
  579. t.Run("Successful Update", func(t *testing.T) {
  580. // Call SetWorkInfo
  581. err := f.SetWorkInfo(screenName, workInfo)
  582. assert.NoError(t, err)
  583. // Retrieve the user and verify the work info was set correctly
  584. updatedUser, err := f.User(screenName)
  585. assert.NoError(t, err)
  586. assert.Equal(t, workInfo.Company, updatedUser.ICQWorkInfo.Company)
  587. assert.Equal(t, workInfo.Department, updatedUser.ICQWorkInfo.Department)
  588. assert.Equal(t, workInfo.OccupationCode, updatedUser.ICQWorkInfo.OccupationCode)
  589. assert.Equal(t, workInfo.Position, updatedUser.ICQWorkInfo.Position)
  590. assert.Equal(t, workInfo.Address, updatedUser.ICQWorkInfo.Address)
  591. assert.Equal(t, workInfo.City, updatedUser.ICQWorkInfo.City)
  592. assert.Equal(t, workInfo.CountryCode, updatedUser.ICQWorkInfo.CountryCode)
  593. assert.Equal(t, workInfo.Fax, updatedUser.ICQWorkInfo.Fax)
  594. assert.Equal(t, workInfo.Phone, updatedUser.ICQWorkInfo.Phone)
  595. assert.Equal(t, workInfo.State, updatedUser.ICQWorkInfo.State)
  596. assert.Equal(t, workInfo.WebPage, updatedUser.ICQWorkInfo.WebPage)
  597. assert.Equal(t, workInfo.ZIPCode, updatedUser.ICQWorkInfo.ZIPCode)
  598. })
  599. t.Run("Update Non-Existing User", func(t *testing.T) {
  600. // Try to set work info for a non-existing user
  601. nonExistingScreenName := NewIdentScreenName("nonexistentuser")
  602. err := f.SetWorkInfo(nonExistingScreenName, workInfo)
  603. // This should return ErrNoUser, as the user does not exist
  604. assert.ErrorIs(t, err, ErrNoUser)
  605. })
  606. t.Run("Empty Work Info", func(t *testing.T) {
  607. // Test updating with empty work info (depending on business rules, this might be allowed or not)
  608. emptyWorkInfo := ICQWorkInfo{}
  609. err := f.SetWorkInfo(screenName, emptyWorkInfo)
  610. assert.NoError(t, err)
  611. // Retrieve the user and verify that fields are empty or have default values
  612. updatedUser, err := f.User(screenName)
  613. assert.NoError(t, err)
  614. assert.Empty(t, updatedUser.ICQWorkInfo.Company)
  615. assert.Empty(t, updatedUser.ICQWorkInfo.Department)
  616. assert.Empty(t, updatedUser.ICQWorkInfo.OccupationCode)
  617. assert.Empty(t, updatedUser.ICQWorkInfo.Position)
  618. assert.Empty(t, updatedUser.ICQWorkInfo.Address)
  619. assert.Empty(t, updatedUser.ICQWorkInfo.City)
  620. assert.Empty(t, updatedUser.ICQWorkInfo.CountryCode)
  621. assert.Empty(t, updatedUser.ICQWorkInfo.Fax)
  622. assert.Empty(t, updatedUser.ICQWorkInfo.Phone)
  623. assert.Empty(t, updatedUser.ICQWorkInfo.State)
  624. assert.Empty(t, updatedUser.ICQWorkInfo.WebPage)
  625. assert.Empty(t, updatedUser.ICQWorkInfo.ZIPCode)
  626. })
  627. }
  628. func TestSQLiteUserStore_SetMoreInfo(t *testing.T) {
  629. // Cleanup after test
  630. defer func() {
  631. assert.NoError(t, os.Remove(testFile))
  632. }()
  633. // Initialize the SQLiteUserStore with a test database file
  634. f, err := NewSQLiteUserStore(testFile)
  635. assert.NoError(t, err)
  636. // Create a test user
  637. screenName := NewIdentScreenName("testuser")
  638. user := User{
  639. IdentScreenName: screenName,
  640. }
  641. err = f.InsertUser(user)
  642. assert.NoError(t, err)
  643. // Define the more info data to set
  644. moreInfo := ICQMoreInfo{
  645. BirthDay: 15,
  646. BirthMonth: 8,
  647. BirthYear: 1990,
  648. Gender: 1,
  649. HomePageAddr: "http://example.com",
  650. Lang1: 1,
  651. Lang2: 2,
  652. Lang3: 3,
  653. }
  654. t.Run("Successful Update", func(t *testing.T) {
  655. // Call SetMoreInfo
  656. err := f.SetMoreInfo(screenName, moreInfo)
  657. assert.NoError(t, err)
  658. // Retrieve the user and verify the more info was set correctly
  659. updatedUser, err := f.User(screenName)
  660. assert.NoError(t, err)
  661. assert.Equal(t, moreInfo.BirthDay, updatedUser.ICQMoreInfo.BirthDay)
  662. assert.Equal(t, moreInfo.BirthMonth, updatedUser.ICQMoreInfo.BirthMonth)
  663. assert.Equal(t, moreInfo.BirthYear, updatedUser.ICQMoreInfo.BirthYear)
  664. assert.Equal(t, moreInfo.Gender, updatedUser.ICQMoreInfo.Gender)
  665. assert.Equal(t, moreInfo.HomePageAddr, updatedUser.ICQMoreInfo.HomePageAddr)
  666. assert.Equal(t, moreInfo.Lang1, updatedUser.ICQMoreInfo.Lang1)
  667. assert.Equal(t, moreInfo.Lang2, updatedUser.ICQMoreInfo.Lang2)
  668. assert.Equal(t, moreInfo.Lang3, updatedUser.ICQMoreInfo.Lang3)
  669. })
  670. t.Run("Update Non-Existing User", func(t *testing.T) {
  671. // Try to set more info for a non-existing user
  672. nonExistingScreenName := NewIdentScreenName("nonexistentuser")
  673. err := f.SetMoreInfo(nonExistingScreenName, moreInfo)
  674. // This should return ErrNoUser, as the user does not exist
  675. assert.ErrorIs(t, err, ErrNoUser)
  676. })
  677. t.Run("Empty More Info", func(t *testing.T) {
  678. // Test updating with empty more info
  679. emptyMoreInfo := ICQMoreInfo{}
  680. err := f.SetMoreInfo(screenName, emptyMoreInfo)
  681. assert.NoError(t, err)
  682. // Retrieve the user and verify that fields are empty or have default values
  683. updatedUser, err := f.User(screenName)
  684. assert.NoError(t, err)
  685. assert.Empty(t, updatedUser.ICQMoreInfo.BirthDay)
  686. assert.Empty(t, updatedUser.ICQMoreInfo.BirthMonth)
  687. assert.Empty(t, updatedUser.ICQMoreInfo.BirthYear)
  688. assert.Empty(t, updatedUser.ICQMoreInfo.Gender)
  689. assert.Empty(t, updatedUser.ICQMoreInfo.HomePageAddr)
  690. assert.Empty(t, updatedUser.ICQMoreInfo.Lang1)
  691. assert.Empty(t, updatedUser.ICQMoreInfo.Lang2)
  692. assert.Empty(t, updatedUser.ICQMoreInfo.Lang3)
  693. })
  694. }
  695. func TestSQLiteUserStore_SetUserNotes(t *testing.T) {
  696. // Cleanup after test
  697. defer func() {
  698. assert.NoError(t, os.Remove(testFile))
  699. }()
  700. // Initialize the SQLiteUserStore with a test database file
  701. f, err := NewSQLiteUserStore(testFile)
  702. assert.NoError(t, err)
  703. // Create a test user
  704. screenName := NewIdentScreenName("testuser")
  705. user := User{
  706. IdentScreenName: screenName,
  707. }
  708. err = f.InsertUser(user)
  709. assert.NoError(t, err)
  710. // Define the user notes to set
  711. userNotes := ICQUserNotes{
  712. Notes: "This is a test note.",
  713. }
  714. t.Run("Successful Update", func(t *testing.T) {
  715. // Call SetUserNotes
  716. err := f.SetUserNotes(screenName, userNotes)
  717. assert.NoError(t, err)
  718. // Retrieve the user and verify the notes were set correctly
  719. updatedUser, err := f.User(screenName)
  720. assert.NoError(t, err)
  721. assert.Equal(t, userNotes.Notes, updatedUser.ICQNotes.Notes)
  722. })
  723. t.Run("Update Non-Existing User", func(t *testing.T) {
  724. // Try to set notes for a non-existing user
  725. nonExistingScreenName := NewIdentScreenName("nonexistentuser")
  726. err := f.SetUserNotes(nonExistingScreenName, userNotes)
  727. // This should return ErrNoUser, as the user does not exist
  728. assert.ErrorIs(t, err, ErrNoUser)
  729. })
  730. t.Run("Empty Notes", func(t *testing.T) {
  731. // Test updating with empty notes
  732. emptyNotes := ICQUserNotes{Notes: ""}
  733. err := f.SetUserNotes(screenName, emptyNotes)
  734. assert.NoError(t, err)
  735. // Retrieve the user and verify that notes are empty
  736. updatedUser, err := f.User(screenName)
  737. assert.NoError(t, err)
  738. assert.Empty(t, updatedUser.ICQNotes.Notes)
  739. })
  740. }
  741. func TestSQLiteUserStore_SetInterests(t *testing.T) {
  742. // Cleanup after test
  743. defer func() {
  744. assert.NoError(t, os.Remove(testFile))
  745. }()
  746. // Initialize the SQLiteUserStore with a test database file
  747. f, err := NewSQLiteUserStore(testFile)
  748. assert.NoError(t, err)
  749. // Create a test user
  750. screenName := NewIdentScreenName("testuser")
  751. user := User{
  752. IdentScreenName: screenName,
  753. }
  754. err = f.InsertUser(user)
  755. assert.NoError(t, err)
  756. // Define the interests data to set
  757. interests := ICQInterests{
  758. Code1: 1,
  759. Keyword1: "Coding",
  760. Code2: 2,
  761. Keyword2: "Music",
  762. Code3: 3,
  763. Keyword3: "Gaming",
  764. Code4: 4,
  765. Keyword4: "Travel",
  766. }
  767. t.Run("Successful Update", func(t *testing.T) {
  768. // Call SetInterests
  769. err := f.SetInterests(screenName, interests)
  770. assert.NoError(t, err)
  771. // Retrieve the user and verify the interests were set correctly
  772. updatedUser, err := f.User(screenName)
  773. assert.NoError(t, err)
  774. assert.Equal(t, interests.Code1, updatedUser.ICQInterests.Code1)
  775. assert.Equal(t, interests.Keyword1, updatedUser.ICQInterests.Keyword1)
  776. assert.Equal(t, interests.Code2, updatedUser.ICQInterests.Code2)
  777. assert.Equal(t, interests.Keyword2, updatedUser.ICQInterests.Keyword2)
  778. assert.Equal(t, interests.Code3, updatedUser.ICQInterests.Code3)
  779. assert.Equal(t, interests.Keyword3, updatedUser.ICQInterests.Keyword3)
  780. assert.Equal(t, interests.Code4, updatedUser.ICQInterests.Code4)
  781. assert.Equal(t, interests.Keyword4, updatedUser.ICQInterests.Keyword4)
  782. })
  783. t.Run("Update Non-Existing User", func(t *testing.T) {
  784. // Try to set interests for a non-existing user
  785. nonExistingScreenName := NewIdentScreenName("nonexistentuser")
  786. err := f.SetInterests(nonExistingScreenName, interests)
  787. // This should return ErrNoUser, as the user does not exist
  788. assert.ErrorIs(t, err, ErrNoUser)
  789. })
  790. t.Run("Empty Interests", func(t *testing.T) {
  791. // Test updating with empty interests
  792. emptyInterests := ICQInterests{}
  793. err := f.SetInterests(screenName, emptyInterests)
  794. assert.NoError(t, err)
  795. // Retrieve the user and verify that interests fields are empty or have default values
  796. updatedUser, err := f.User(screenName)
  797. assert.NoError(t, err)
  798. assert.Empty(t, updatedUser.ICQInterests.Code1)
  799. assert.Empty(t, updatedUser.ICQInterests.Keyword1)
  800. assert.Empty(t, updatedUser.ICQInterests.Code2)
  801. assert.Empty(t, updatedUser.ICQInterests.Keyword2)
  802. assert.Empty(t, updatedUser.ICQInterests.Code3)
  803. assert.Empty(t, updatedUser.ICQInterests.Keyword3)
  804. assert.Empty(t, updatedUser.ICQInterests.Code4)
  805. assert.Empty(t, updatedUser.ICQInterests.Keyword4)
  806. })
  807. }
  808. func TestSQLiteUserStore_SetAffiliations(t *testing.T) {
  809. // Cleanup after test
  810. defer func() {
  811. assert.NoError(t, os.Remove(testFile))
  812. }()
  813. // Initialize the SQLiteUserStore with a test database file
  814. f, err := NewSQLiteUserStore(testFile)
  815. assert.NoError(t, err)
  816. // Create a test user
  817. screenName := NewIdentScreenName("testuser")
  818. user := User{
  819. IdentScreenName: screenName,
  820. }
  821. err = f.InsertUser(user)
  822. assert.NoError(t, err)
  823. // Define the affiliations data to set
  824. affiliations := ICQAffiliations{
  825. CurrentCode1: 1,
  826. CurrentKeyword1: "Sports",
  827. CurrentCode2: 2,
  828. CurrentKeyword2: "Science",
  829. CurrentCode3: 3,
  830. CurrentKeyword3: "Arts",
  831. PastCode1: 4,
  832. PastKeyword1: "Literature",
  833. PastCode2: 5,
  834. PastKeyword2: "Music",
  835. PastCode3: 6,
  836. PastKeyword3: "Technology",
  837. }
  838. t.Run("Successful Update", func(t *testing.T) {
  839. // Call SetAffiliations
  840. err := f.SetAffiliations(screenName, affiliations)
  841. assert.NoError(t, err)
  842. // Retrieve the user and verify the affiliations were set correctly
  843. updatedUser, err := f.User(screenName)
  844. assert.NoError(t, err)
  845. assert.Equal(t, affiliations.CurrentCode1, updatedUser.ICQAffiliations.CurrentCode1)
  846. assert.Equal(t, affiliations.CurrentKeyword1, updatedUser.ICQAffiliations.CurrentKeyword1)
  847. assert.Equal(t, affiliations.CurrentCode2, updatedUser.ICQAffiliations.CurrentCode2)
  848. assert.Equal(t, affiliations.CurrentKeyword2, updatedUser.ICQAffiliations.CurrentKeyword2)
  849. assert.Equal(t, affiliations.CurrentCode3, updatedUser.ICQAffiliations.CurrentCode3)
  850. assert.Equal(t, affiliations.CurrentKeyword3, updatedUser.ICQAffiliations.CurrentKeyword3)
  851. assert.Equal(t, affiliations.PastCode1, updatedUser.ICQAffiliations.PastCode1)
  852. assert.Equal(t, affiliations.PastKeyword1, updatedUser.ICQAffiliations.PastKeyword1)
  853. assert.Equal(t, affiliations.PastCode2, updatedUser.ICQAffiliations.PastCode2)
  854. assert.Equal(t, affiliations.PastKeyword2, updatedUser.ICQAffiliations.PastKeyword2)
  855. assert.Equal(t, affiliations.PastCode3, updatedUser.ICQAffiliations.PastCode3)
  856. assert.Equal(t, affiliations.PastKeyword3, updatedUser.ICQAffiliations.PastKeyword3)
  857. })
  858. t.Run("Update Non-Existing User", func(t *testing.T) {
  859. // Try to set affiliations for a non-existing user
  860. nonExistingScreenName := NewIdentScreenName("nonexistentuser")
  861. err := f.SetAffiliations(nonExistingScreenName, affiliations)
  862. // This should return ErrNoUser, as the user does not exist
  863. assert.ErrorIs(t, err, ErrNoUser)
  864. })
  865. t.Run("Empty Affiliations", func(t *testing.T) {
  866. // Test updating with empty affiliations
  867. emptyAffiliations := ICQAffiliations{}
  868. err := f.SetAffiliations(screenName, emptyAffiliations)
  869. assert.NoError(t, err)
  870. // Retrieve the user and verify that affiliations fields are empty or have default values
  871. updatedUser, err := f.User(screenName)
  872. assert.NoError(t, err)
  873. assert.Empty(t, updatedUser.ICQAffiliations.CurrentCode1)
  874. assert.Empty(t, updatedUser.ICQAffiliations.CurrentKeyword1)
  875. assert.Empty(t, updatedUser.ICQAffiliations.CurrentCode2)
  876. assert.Empty(t, updatedUser.ICQAffiliations.CurrentKeyword2)
  877. assert.Empty(t, updatedUser.ICQAffiliations.CurrentCode3)
  878. assert.Empty(t, updatedUser.ICQAffiliations.CurrentKeyword3)
  879. assert.Empty(t, updatedUser.ICQAffiliations.PastCode1)
  880. assert.Empty(t, updatedUser.ICQAffiliations.PastKeyword1)
  881. assert.Empty(t, updatedUser.ICQAffiliations.PastCode2)
  882. assert.Empty(t, updatedUser.ICQAffiliations.PastKeyword2)
  883. assert.Empty(t, updatedUser.ICQAffiliations.PastCode3)
  884. assert.Empty(t, updatedUser.ICQAffiliations.PastKeyword3)
  885. })
  886. }
  887. func TestSQLiteUserStore_SetBasicInfo(t *testing.T) {
  888. // Cleanup after test
  889. defer func() {
  890. assert.NoError(t, os.Remove(testFile))
  891. }()
  892. // Initialize the SQLiteUserStore with a test database file
  893. f, err := NewSQLiteUserStore(testFile)
  894. assert.NoError(t, err)
  895. // Create a test user
  896. screenName := NewIdentScreenName("testuser")
  897. user := User{
  898. IdentScreenName: screenName,
  899. }
  900. err = f.InsertUser(user)
  901. assert.NoError(t, err)
  902. // Define the basic info data to set
  903. basicInfo := ICQBasicInfo{
  904. CellPhone: "123-456-7890",
  905. CountryCode: 1,
  906. EmailAddress: "test@example.com",
  907. FirstName: "John",
  908. GMTOffset: 5,
  909. Address: "123 Main St",
  910. City: "Test City",
  911. Fax: "098-765-4321",
  912. Phone: "111-222-3333",
  913. State: "Test State",
  914. LastName: "Doe",
  915. Nickname: "Johnny",
  916. PublishEmail: true,
  917. ZIPCode: "12345",
  918. }
  919. t.Run("Successful Update", func(t *testing.T) {
  920. // Call SetBasicInfo
  921. err := f.SetBasicInfo(screenName, basicInfo)
  922. assert.NoError(t, err)
  923. // Retrieve the user and verify the basic info was set correctly
  924. updatedUser, err := f.User(screenName)
  925. assert.NoError(t, err)
  926. assert.Equal(t, basicInfo.CellPhone, updatedUser.ICQBasicInfo.CellPhone)
  927. assert.Equal(t, basicInfo.CountryCode, updatedUser.ICQBasicInfo.CountryCode)
  928. assert.Equal(t, basicInfo.EmailAddress, updatedUser.ICQBasicInfo.EmailAddress)
  929. assert.Equal(t, basicInfo.FirstName, updatedUser.ICQBasicInfo.FirstName)
  930. assert.Equal(t, basicInfo.GMTOffset, updatedUser.ICQBasicInfo.GMTOffset)
  931. assert.Equal(t, basicInfo.Address, updatedUser.ICQBasicInfo.Address)
  932. assert.Equal(t, basicInfo.City, updatedUser.ICQBasicInfo.City)
  933. assert.Equal(t, basicInfo.Fax, updatedUser.ICQBasicInfo.Fax)
  934. assert.Equal(t, basicInfo.Phone, updatedUser.ICQBasicInfo.Phone)
  935. assert.Equal(t, basicInfo.State, updatedUser.ICQBasicInfo.State)
  936. assert.Equal(t, basicInfo.LastName, updatedUser.ICQBasicInfo.LastName)
  937. assert.Equal(t, basicInfo.Nickname, updatedUser.ICQBasicInfo.Nickname)
  938. assert.Equal(t, basicInfo.PublishEmail, updatedUser.ICQBasicInfo.PublishEmail)
  939. assert.Equal(t, basicInfo.ZIPCode, updatedUser.ICQBasicInfo.ZIPCode)
  940. })
  941. t.Run("Update Non-Existing User", func(t *testing.T) {
  942. // Try to set basic info for a non-existing user
  943. nonExistingScreenName := NewIdentScreenName("nonexistentuser")
  944. err := f.SetBasicInfo(nonExistingScreenName, basicInfo)
  945. // This should return ErrNoUser, as the user does not exist
  946. assert.ErrorIs(t, err, ErrNoUser)
  947. })
  948. t.Run("Empty Basic Info", func(t *testing.T) {
  949. // Test updating with empty basic info
  950. emptyBasicInfo := ICQBasicInfo{}
  951. err := f.SetBasicInfo(screenName, emptyBasicInfo)
  952. assert.NoError(t, err)
  953. // Retrieve the user and verify that basic info fields are empty or have default values
  954. updatedUser, err := f.User(screenName)
  955. assert.NoError(t, err)
  956. assert.Empty(t, updatedUser.ICQBasicInfo.CellPhone)
  957. assert.Empty(t, updatedUser.ICQBasicInfo.CountryCode)
  958. assert.Empty(t, updatedUser.ICQBasicInfo.EmailAddress)
  959. assert.Empty(t, updatedUser.ICQBasicInfo.FirstName)
  960. assert.Empty(t, updatedUser.ICQBasicInfo.GMTOffset)
  961. assert.Empty(t, updatedUser.ICQBasicInfo.Address)
  962. assert.Empty(t, updatedUser.ICQBasicInfo.City)
  963. assert.Empty(t, updatedUser.ICQBasicInfo.Fax)
  964. assert.Empty(t, updatedUser.ICQBasicInfo.Phone)
  965. assert.Empty(t, updatedUser.ICQBasicInfo.State)
  966. assert.Empty(t, updatedUser.ICQBasicInfo.LastName)
  967. assert.Empty(t, updatedUser.ICQBasicInfo.Nickname)
  968. assert.Empty(t, updatedUser.ICQBasicInfo.PublishEmail)
  969. assert.Empty(t, updatedUser.ICQBasicInfo.ZIPCode)
  970. })
  971. }
  972. func TestSQLiteUserStore_FindByICQInterests(t *testing.T) {
  973. // Cleanup after test
  974. defer func() {
  975. assert.NoError(t, os.Remove(testFile))
  976. }()
  977. // Initialize the SQLiteUserStore with a test database file
  978. f, err := NewSQLiteUserStore(testFile)
  979. assert.NoError(t, err)
  980. // Create and set up test users with different interests
  981. user1 := User{
  982. IdentScreenName: NewIdentScreenName("user1"),
  983. }
  984. err = f.InsertUser(user1)
  985. assert.NoError(t, err)
  986. interests1 := ICQInterests{
  987. Code1: 1,
  988. Keyword1: "Coding",
  989. Code2: 2,
  990. Keyword2: "Music",
  991. }
  992. err = f.SetInterests(user1.IdentScreenName, interests1)
  993. assert.NoError(t, err)
  994. user2 := User{
  995. IdentScreenName: NewIdentScreenName("user2"),
  996. }
  997. err = f.InsertUser(user2)
  998. assert.NoError(t, err)
  999. interests2 := ICQInterests{
  1000. Code1: 1,
  1001. Keyword1: "Coding",
  1002. Code3: 3,
  1003. Keyword3: "Gaming",
  1004. }
  1005. err = f.SetInterests(user2.IdentScreenName, interests2)
  1006. assert.NoError(t, err)
  1007. user3 := User{
  1008. IdentScreenName: NewIdentScreenName("user3"),
  1009. }
  1010. err = f.InsertUser(user3)
  1011. assert.NoError(t, err)
  1012. interests3 := ICQInterests{
  1013. Code2: 2,
  1014. Keyword2: "Music",
  1015. Code4: 4,
  1016. Keyword4: "Travel",
  1017. }
  1018. err = f.SetInterests(user3.IdentScreenName, interests3)
  1019. assert.NoError(t, err)
  1020. // Helper function to check if a user with a specific IdentScreenName exists in the results
  1021. containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
  1022. for _, user := range users {
  1023. if user.IdentScreenName == screenName {
  1024. return true
  1025. }
  1026. }
  1027. return false
  1028. }
  1029. t.Run("Find Users by Single Keyword", func(t *testing.T) {
  1030. // Search for users interested in "Music"
  1031. users, err := f.FindByICQInterests(2, []string{"Music"})
  1032. assert.NoError(t, err)
  1033. assert.Len(t, users, 2)
  1034. // Check that the correct users are returned by IdentScreenName
  1035. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1036. assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
  1037. })
  1038. t.Run("Find Users by Multiple Keywords", func(t *testing.T) {
  1039. // Search for users interested in "Coding" or "Gaming"
  1040. users, err := f.FindByICQInterests(1, []string{"Coding", "Gaming"})
  1041. assert.NoError(t, err)
  1042. assert.Len(t, users, 2)
  1043. // Check that the correct users are returned by IdentScreenName
  1044. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1045. assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
  1046. })
  1047. t.Run("Find Users by Multiple Codes and Keywords", func(t *testing.T) {
  1048. // Search for users interested in "Coding"
  1049. users, err := f.FindByICQInterests(1, []string{"Coding"})
  1050. assert.NoError(t, err)
  1051. assert.Len(t, users, 2)
  1052. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1053. assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
  1054. // Search for users interested in "Travel"
  1055. users, err = f.FindByICQInterests(4, []string{"Travel"})
  1056. assert.NoError(t, err)
  1057. assert.Len(t, users, 1)
  1058. assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
  1059. })
  1060. t.Run("No Users Found", func(t *testing.T) {
  1061. // Search for users interested in a keyword that no user has
  1062. users, err := f.FindByICQInterests(1, []string{"Status"})
  1063. assert.NoError(t, err)
  1064. assert.Empty(t, users)
  1065. })
  1066. }
  1067. func TestSQLiteUserStore_FindByICQKeyword(t *testing.T) {
  1068. // Cleanup after test
  1069. defer func() {
  1070. assert.NoError(t, os.Remove(testFile))
  1071. }()
  1072. // Initialize the SQLiteUserStore with a test database file
  1073. f, err := NewSQLiteUserStore(testFile)
  1074. assert.NoError(t, err)
  1075. // Create and set up test users with different interests
  1076. user1 := User{
  1077. IdentScreenName: NewIdentScreenName("user1"),
  1078. }
  1079. err = f.InsertUser(user1)
  1080. assert.NoError(t, err)
  1081. interests1 := ICQInterests{
  1082. Keyword1: "Coding",
  1083. Keyword2: "Music",
  1084. }
  1085. err = f.SetInterests(user1.IdentScreenName, interests1)
  1086. assert.NoError(t, err)
  1087. user2 := User{
  1088. IdentScreenName: NewIdentScreenName("user2"),
  1089. }
  1090. err = f.InsertUser(user2)
  1091. assert.NoError(t, err)
  1092. interests2 := ICQInterests{
  1093. Keyword1: "Coding",
  1094. Keyword3: "Gaming",
  1095. }
  1096. err = f.SetInterests(user2.IdentScreenName, interests2)
  1097. assert.NoError(t, err)
  1098. user3 := User{
  1099. IdentScreenName: NewIdentScreenName("user3"),
  1100. }
  1101. err = f.InsertUser(user3)
  1102. assert.NoError(t, err)
  1103. interests3 := ICQInterests{
  1104. Keyword3: "Music",
  1105. Keyword4: "Travel",
  1106. }
  1107. err = f.SetInterests(user3.IdentScreenName, interests3)
  1108. assert.NoError(t, err)
  1109. // Helper function to check if a user with a specific IdentScreenName exists in the results
  1110. containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
  1111. for _, user := range users {
  1112. if user.IdentScreenName == screenName {
  1113. return true
  1114. }
  1115. }
  1116. return false
  1117. }
  1118. t.Run("Find Users by Keyword", func(t *testing.T) {
  1119. // Search for users interested in "Music"
  1120. users, err := f.FindByICQKeyword("Music")
  1121. assert.NoError(t, err)
  1122. assert.Len(t, users, 2)
  1123. // Check that the correct users are returned by IdentScreenName
  1124. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1125. assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
  1126. })
  1127. t.Run("No Users Found", func(t *testing.T) {
  1128. // Search for users interested in a keyword that no user has
  1129. users, err := f.FindByICQKeyword("Knitting")
  1130. assert.NoError(t, err)
  1131. assert.Empty(t, users)
  1132. })
  1133. }
  1134. func TestSQLiteUserStore_FindByICQName(t *testing.T) {
  1135. // Cleanup after test
  1136. defer func() {
  1137. assert.NoError(t, os.Remove(testFile))
  1138. }()
  1139. // Initialize the SQLiteUserStore with a test database file
  1140. f, err := NewSQLiteUserStore(testFile)
  1141. assert.NoError(t, err)
  1142. // Create and set up test users with different details using SetBasicInfo
  1143. user1 := User{
  1144. IdentScreenName: NewIdentScreenName("user1"),
  1145. }
  1146. err = f.InsertUser(user1)
  1147. assert.NoError(t, err)
  1148. basicInfo1 := ICQBasicInfo{
  1149. FirstName: "John",
  1150. LastName: "Doe",
  1151. Nickname: "Johnny",
  1152. }
  1153. err = f.SetBasicInfo(user1.IdentScreenName, basicInfo1)
  1154. assert.NoError(t, err)
  1155. user2 := User{
  1156. IdentScreenName: NewIdentScreenName("user2"),
  1157. }
  1158. err = f.InsertUser(user2)
  1159. assert.NoError(t, err)
  1160. basicInfo2 := ICQBasicInfo{
  1161. FirstName: "Jane",
  1162. LastName: "Smith",
  1163. Nickname: "Janey",
  1164. }
  1165. err = f.SetBasicInfo(user2.IdentScreenName, basicInfo2)
  1166. assert.NoError(t, err)
  1167. user3 := User{
  1168. IdentScreenName: NewIdentScreenName("user3"),
  1169. }
  1170. err = f.InsertUser(user3)
  1171. assert.NoError(t, err)
  1172. basicInfo3 := ICQBasicInfo{
  1173. FirstName: "John",
  1174. LastName: "Smith",
  1175. Nickname: "JohnnyS",
  1176. }
  1177. err = f.SetBasicInfo(user3.IdentScreenName, basicInfo3)
  1178. assert.NoError(t, err)
  1179. // Helper function to check if a user with a specific IdentScreenName exists in the results
  1180. containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
  1181. for _, user := range users {
  1182. if user.IdentScreenName == screenName {
  1183. return true
  1184. }
  1185. }
  1186. return false
  1187. }
  1188. t.Run("Find Users by First Name", func(t *testing.T) {
  1189. // Search for users with the first name "John"
  1190. users, err := f.FindByICQName("John", "", "")
  1191. assert.NoError(t, err)
  1192. assert.Len(t, users, 2)
  1193. // Check that the correct users are returned by IdentScreenName
  1194. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1195. assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
  1196. })
  1197. t.Run("Find Users by Last Name", func(t *testing.T) {
  1198. // Search for users with the last name "Smith"
  1199. users, err := f.FindByICQName("", "Smith", "")
  1200. assert.NoError(t, err)
  1201. assert.Len(t, users, 2)
  1202. // Check that the correct users are returned by IdentScreenName
  1203. assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
  1204. assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
  1205. })
  1206. t.Run("Find Users by Nickname", func(t *testing.T) {
  1207. // Search for users with the nickname "Johnny"
  1208. users, err := f.FindByICQName("", "", "Johnny")
  1209. assert.NoError(t, err)
  1210. assert.Len(t, users, 1)
  1211. // Check that the correct user is returned by IdentScreenName
  1212. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1213. })
  1214. t.Run("Find Users by Multiple Fields", func(t *testing.T) {
  1215. // Search for users with the first name "Jane" and last name "Smith"
  1216. users, err := f.FindByICQName("Jane", "Smith", "")
  1217. assert.NoError(t, err)
  1218. assert.Len(t, users, 1)
  1219. // Check that the correct user is returned by IdentScreenName
  1220. assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
  1221. })
  1222. t.Run("No Users Found", func(t *testing.T) {
  1223. // Search for users with a first name that no user has
  1224. users, err := f.FindByICQName("NonExistent", "", "")
  1225. assert.NoError(t, err)
  1226. assert.Empty(t, users)
  1227. })
  1228. }
  1229. func TestSQLiteUserStore_FindByDirectoryInfo(t *testing.T) {
  1230. // Cleanup after test
  1231. defer func() {
  1232. assert.NoError(t, os.Remove(testFile))
  1233. }()
  1234. // Initialize the SQLiteUserStore with a test database file
  1235. f, err := NewSQLiteUserStore(testFile)
  1236. assert.NoError(t, err)
  1237. // Create and set up test users with different directory info
  1238. user1 := User{
  1239. IdentScreenName: NewIdentScreenName("user1"),
  1240. }
  1241. err = f.InsertUser(user1)
  1242. assert.NoError(t, err)
  1243. directoryInfo1 := AIMNameAndAddr{
  1244. FirstName: "John",
  1245. LastName: "Doe",
  1246. NickName: "Johnny",
  1247. City: "New York",
  1248. }
  1249. err = f.SetDirectoryInfo(user1.IdentScreenName, directoryInfo1)
  1250. assert.NoError(t, err)
  1251. user2 := User{
  1252. IdentScreenName: NewIdentScreenName("user2"),
  1253. }
  1254. err = f.InsertUser(user2)
  1255. assert.NoError(t, err)
  1256. directoryInfo2 := AIMNameAndAddr{
  1257. FirstName: "Jane",
  1258. LastName: "Smith",
  1259. NickName: "Janey",
  1260. Country: "USA",
  1261. }
  1262. err = f.SetDirectoryInfo(user2.IdentScreenName, directoryInfo2)
  1263. assert.NoError(t, err)
  1264. user3 := User{
  1265. IdentScreenName: NewIdentScreenName("user3"),
  1266. }
  1267. err = f.InsertUser(user3)
  1268. assert.NoError(t, err)
  1269. directoryInfo3 := AIMNameAndAddr{
  1270. FirstName: "John",
  1271. LastName: "Smith",
  1272. NickName: "JohnnyS",
  1273. State: "California",
  1274. }
  1275. err = f.SetDirectoryInfo(user3.IdentScreenName, directoryInfo3)
  1276. assert.NoError(t, err)
  1277. // Helper function to check if a user with a specific IdentScreenName exists in the results
  1278. containsUserWithScreenName := func(users []User, screenName IdentScreenName) bool {
  1279. for _, user := range users {
  1280. if user.IdentScreenName == screenName {
  1281. return true
  1282. }
  1283. }
  1284. return false
  1285. }
  1286. t.Run("Find Users by First Name", func(t *testing.T) {
  1287. // Search for users with the first name "John"
  1288. users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{FirstName: "John"})
  1289. assert.NoError(t, err)
  1290. assert.Len(t, users, 2)
  1291. // Check that the correct users are returned by IdentScreenName
  1292. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1293. assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
  1294. })
  1295. t.Run("Find Users by Last Name", func(t *testing.T) {
  1296. // Search for users with the last name "Smith"
  1297. users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{LastName: "Smith"})
  1298. assert.NoError(t, err)
  1299. assert.Len(t, users, 2)
  1300. // Check that the correct users are returned by IdentScreenName
  1301. assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
  1302. assert.True(t, containsUserWithScreenName(users, user3.IdentScreenName))
  1303. })
  1304. t.Run("Find Users by Nickname", func(t *testing.T) {
  1305. // Search for users with the nickname "Johnny"
  1306. users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{NickName: "Johnny"})
  1307. assert.NoError(t, err)
  1308. assert.Len(t, users, 1)
  1309. // Check that the correct user is returned by IdentScreenName
  1310. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1311. })
  1312. t.Run("Find Users by City", func(t *testing.T) {
  1313. // Search for users with the city "New York"
  1314. users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{City: "New York"})
  1315. assert.NoError(t, err)
  1316. assert.Len(t, users, 1)
  1317. // Check that the correct user is returned by IdentScreenName
  1318. assert.True(t, containsUserWithScreenName(users, user1.IdentScreenName))
  1319. })
  1320. t.Run("Find Users by Multiple Fields", func(t *testing.T) {
  1321. // Search for users with the first name "Jane" and country "USA"
  1322. users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{FirstName: "Jane", Country: "USA"})
  1323. assert.NoError(t, err)
  1324. assert.Len(t, users, 1)
  1325. // Check that the correct user is returned by IdentScreenName
  1326. assert.True(t, containsUserWithScreenName(users, user2.IdentScreenName))
  1327. })
  1328. t.Run("No Users Found", func(t *testing.T) {
  1329. // Search for users with a first name that no user has
  1330. users, err := f.FindByAIMNameAndAddr(AIMNameAndAddr{FirstName: "NonExistent"})
  1331. assert.NoError(t, err)
  1332. assert.Empty(t, users)
  1333. })
  1334. }
  1335. func TestSQLiteUserStore_FindByICQEmail(t *testing.T) {
  1336. // Cleanup after test
  1337. defer func() {
  1338. assert.NoError(t, os.Remove(testFile))
  1339. }()
  1340. // Initialize the SQLiteUserStore with a test database file
  1341. f, err := NewSQLiteUserStore(testFile)
  1342. assert.NoError(t, err)
  1343. // Create and set up test users with different email addresses using SetBasicInfo
  1344. user1 := User{
  1345. IdentScreenName: NewIdentScreenName("user1"),
  1346. }
  1347. err = f.InsertUser(user1)
  1348. assert.NoError(t, err)
  1349. basicInfo1 := ICQBasicInfo{
  1350. EmailAddress: "user1@example.com",
  1351. }
  1352. err = f.SetBasicInfo(user1.IdentScreenName, basicInfo1)
  1353. assert.NoError(t, err)
  1354. user2 := User{
  1355. IdentScreenName: NewIdentScreenName("user2"),
  1356. }
  1357. err = f.InsertUser(user2)
  1358. assert.NoError(t, err)
  1359. basicInfo2 := ICQBasicInfo{
  1360. EmailAddress: "user2@example.com",
  1361. }
  1362. err = f.SetBasicInfo(user2.IdentScreenName, basicInfo2)
  1363. assert.NoError(t, err)
  1364. user3 := User{
  1365. IdentScreenName: NewIdentScreenName("user3"),
  1366. }
  1367. err = f.InsertUser(user3)
  1368. assert.NoError(t, err)
  1369. basicInfo3 := ICQBasicInfo{
  1370. EmailAddress: "user3@example.com",
  1371. }
  1372. err = f.SetBasicInfo(user3.IdentScreenName, basicInfo3)
  1373. assert.NoError(t, err)
  1374. t.Run("Find User by Email", func(t *testing.T) {
  1375. // Search for user with email "user1@example.com"
  1376. user, err := f.FindByICQEmail("user1@example.com")
  1377. assert.NoError(t, err)
  1378. assert.Equal(t, user1.IdentScreenName, user.IdentScreenName)
  1379. // Search for user with email "user2@example.com"
  1380. user, err = f.FindByICQEmail("user2@example.com")
  1381. assert.NoError(t, err)
  1382. assert.Equal(t, user2.IdentScreenName, user.IdentScreenName)
  1383. // Search for user with email "user3@example.com"
  1384. user, err = f.FindByICQEmail("user3@example.com")
  1385. assert.NoError(t, err)
  1386. assert.Equal(t, user3.IdentScreenName, user.IdentScreenName)
  1387. })
  1388. t.Run("User Not Found", func(t *testing.T) {
  1389. // Search for an email that doesn't exist
  1390. _, err := f.FindByICQEmail("nonexistent@example.com")
  1391. assert.ErrorIs(t, err, ErrNoUser)
  1392. })
  1393. }
  1394. func TestSQLiteUserStore_FindByAIMEmail(t *testing.T) {
  1395. defer func() {
  1396. assert.NoError(t, os.Remove(testFile))
  1397. }()
  1398. f, err := NewSQLiteUserStore(testFile)
  1399. assert.NoError(t, err)
  1400. user1 := User{
  1401. IdentScreenName: NewIdentScreenName("user1"),
  1402. }
  1403. err = f.InsertUser(user1)
  1404. assert.NoError(t, err)
  1405. err = f.UpdateEmailAddress(&mail.Address{Address: "user1@example.com"}, user1.IdentScreenName)
  1406. assert.NoError(t, err)
  1407. user2 := User{
  1408. IdentScreenName: NewIdentScreenName("user2"),
  1409. EmailAddress: "user2@example.com",
  1410. }
  1411. err = f.InsertUser(user2)
  1412. assert.NoError(t, err)
  1413. err = f.UpdateEmailAddress(&mail.Address{Address: "user2@example.com"}, user2.IdentScreenName)
  1414. assert.NoError(t, err)
  1415. user3 := User{
  1416. IdentScreenName: NewIdentScreenName("user3"),
  1417. EmailAddress: "user3@example.com",
  1418. }
  1419. err = f.InsertUser(user3)
  1420. assert.NoError(t, err)
  1421. err = f.UpdateEmailAddress(&mail.Address{Address: "user3@example.com"}, user3.IdentScreenName)
  1422. assert.NoError(t, err)
  1423. t.Run("Find User by Email", func(t *testing.T) {
  1424. // Search for user with email "user1@example.com"
  1425. user, err := f.FindByAIMEmail("user1@example.com")
  1426. assert.NoError(t, err)
  1427. assert.Equal(t, user1.IdentScreenName, user.IdentScreenName)
  1428. // Search for user with email "user2@example.com"
  1429. user, err = f.FindByAIMEmail("user2@example.com")
  1430. assert.NoError(t, err)
  1431. assert.Equal(t, user2.IdentScreenName, user.IdentScreenName)
  1432. // Search for user with email "user3@example.com"
  1433. user, err = f.FindByAIMEmail("user3@example.com")
  1434. assert.NoError(t, err)
  1435. assert.Equal(t, user3.IdentScreenName, user.IdentScreenName)
  1436. })
  1437. t.Run("User Not Found", func(t *testing.T) {
  1438. // Search for an email that doesn't exist
  1439. _, err := f.FindByAIMEmail("nonexistent@example.com")
  1440. assert.ErrorIs(t, err, ErrNoUser)
  1441. })
  1442. }
  1443. func TestSQLiteUserStore_FindByUIN(t *testing.T) {
  1444. // Cleanup after test
  1445. defer func() {
  1446. assert.NoError(t, os.Remove(testFile))
  1447. }()
  1448. // Initialize the SQLiteUserStore with a test database file
  1449. f, err := NewSQLiteUserStore(testFile)
  1450. assert.NoError(t, err)
  1451. // Create and set up test users where UIN is the same as IdentScreenName
  1452. user1 := User{
  1453. IdentScreenName: NewIdentScreenName("12345"),
  1454. }
  1455. err = f.InsertUser(user1)
  1456. assert.NoError(t, err)
  1457. user2 := User{
  1458. IdentScreenName: NewIdentScreenName("67890"),
  1459. }
  1460. err = f.InsertUser(user2)
  1461. assert.NoError(t, err)
  1462. user3 := User{
  1463. IdentScreenName: NewIdentScreenName("54321"),
  1464. }
  1465. err = f.InsertUser(user3)
  1466. assert.NoError(t, err)
  1467. t.Run("Find User by UIN", func(t *testing.T) {
  1468. // Search for user with UIN 12345
  1469. user, err := f.FindByUIN(12345)
  1470. assert.NoError(t, err)
  1471. assert.Equal(t, user1.IdentScreenName, user.IdentScreenName)
  1472. // Search for user with UIN 67890
  1473. user, err = f.FindByUIN(67890)
  1474. assert.NoError(t, err)
  1475. assert.Equal(t, user2.IdentScreenName, user.IdentScreenName)
  1476. // Search for user with UIN 54321
  1477. user, err = f.FindByUIN(54321)
  1478. assert.NoError(t, err)
  1479. assert.Equal(t, user3.IdentScreenName, user.IdentScreenName)
  1480. })
  1481. t.Run("User Not Found", func(t *testing.T) {
  1482. // Search for a UIN that doesn't exist
  1483. _, err := f.FindByUIN(99999)
  1484. assert.ErrorIs(t, err, ErrNoUser)
  1485. })
  1486. }
  1487. func TestSQLiteUserStore_RetrieveMessages(t *testing.T) {
  1488. defer func() {
  1489. assert.NoError(t, os.Remove(testFile))
  1490. }()
  1491. f, err := NewSQLiteUserStore(testFile)
  1492. assert.NoError(t, err)
  1493. sendTime := time.Now().UTC()
  1494. offlineMessages := []OfflineMessage{
  1495. {
  1496. Sender: NewIdentScreenName("John"),
  1497. Recipient: NewIdentScreenName("Jack"),
  1498. Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
  1499. Cookie: 1,
  1500. },
  1501. Sent: sendTime,
  1502. },
  1503. {
  1504. Sender: NewIdentScreenName("John"),
  1505. Recipient: NewIdentScreenName("Anne"),
  1506. Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
  1507. Cookie: 2,
  1508. },
  1509. Sent: sendTime,
  1510. },
  1511. {
  1512. Sender: NewIdentScreenName("John"),
  1513. Recipient: NewIdentScreenName("Jack"),
  1514. Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
  1515. Cookie: 3,
  1516. },
  1517. Sent: sendTime,
  1518. },
  1519. }
  1520. for _, msg := range offlineMessages {
  1521. err = f.SaveMessage(msg)
  1522. assert.NoError(t, err)
  1523. }
  1524. t.Run("Retrieve Messages", func(t *testing.T) {
  1525. messages, err := f.RetrieveMessages(NewIdentScreenName("Jack"))
  1526. assert.NoError(t, err)
  1527. if assert.Len(t, messages, 2) {
  1528. assert.Equal(t, offlineMessages[0], messages[0])
  1529. assert.Equal(t, offlineMessages[2], messages[1])
  1530. }
  1531. })
  1532. t.Run("Retrieve No Messages", func(t *testing.T) {
  1533. messages, err := f.RetrieveMessages(NewIdentScreenName("Franke"))
  1534. assert.NoError(t, err)
  1535. assert.Empty(t, messages)
  1536. })
  1537. }
  1538. func TestSQLiteUserStore_DeleteMessages(t *testing.T) {
  1539. defer func() {
  1540. assert.NoError(t, os.Remove(testFile))
  1541. }()
  1542. f, err := NewSQLiteUserStore(testFile)
  1543. assert.NoError(t, err)
  1544. sendTime := time.Now().UTC()
  1545. offlineMessages := []OfflineMessage{
  1546. {
  1547. Sender: NewIdentScreenName("John"),
  1548. Recipient: NewIdentScreenName("Jack"),
  1549. Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
  1550. Cookie: 1,
  1551. },
  1552. Sent: sendTime,
  1553. },
  1554. {
  1555. Sender: NewIdentScreenName("John"),
  1556. Recipient: NewIdentScreenName("Anne"),
  1557. Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
  1558. Cookie: 2,
  1559. },
  1560. Sent: sendTime,
  1561. },
  1562. {
  1563. Sender: NewIdentScreenName("John"),
  1564. Recipient: NewIdentScreenName("Jack"),
  1565. Message: wire.SNAC_0x04_0x06_ICBMChannelMsgToHost{
  1566. Cookie: 3,
  1567. },
  1568. Sent: sendTime,
  1569. },
  1570. }
  1571. for _, msg := range offlineMessages {
  1572. err = f.SaveMessage(msg)
  1573. assert.NoError(t, err)
  1574. }
  1575. t.Run("Delete Messages", func(t *testing.T) {
  1576. err := f.DeleteMessages(NewIdentScreenName("Jack"))
  1577. assert.NoError(t, err)
  1578. messages, err := f.RetrieveMessages(NewIdentScreenName("Jack"))
  1579. assert.NoError(t, err)
  1580. assert.Empty(t, messages)
  1581. messages, err = f.RetrieveMessages(NewIdentScreenName("Anne"))
  1582. assert.NoError(t, err)
  1583. assert.Len(t, messages, 1)
  1584. })
  1585. t.Run("Delete No Messages", func(t *testing.T) {
  1586. err := f.DeleteMessages(NewIdentScreenName("Franke"))
  1587. assert.NoError(t, err)
  1588. messages, err := f.RetrieveMessages(NewIdentScreenName("Anne"))
  1589. assert.NoError(t, err)
  1590. assert.Len(t, messages, 1)
  1591. })
  1592. }
  1593. func TestSQLiteUserStore_BuddyIconRefByNameExistingRef(t *testing.T) {
  1594. defer func() {
  1595. assert.NoError(t, os.Remove(testFile))
  1596. }()
  1597. screenName := NewIdentScreenName("TalkingTyler")
  1598. testHash := []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'}
  1599. feedbagStore, err := NewSQLiteUserStore(testFile)
  1600. assert.NoError(t, err)
  1601. itemsIn := []wire.FeedbagItem{
  1602. {
  1603. Name: "1",
  1604. ClassID: wire.FeedbagClassIdBart,
  1605. TLVLBlock: wire.TLVLBlock{
  1606. TLVList: wire.TLVList{
  1607. wire.NewTLVBE(wire.FeedbagAttributesBartInfo, wire.BARTInfo{
  1608. Hash: testHash,
  1609. }),
  1610. },
  1611. },
  1612. },
  1613. }
  1614. if err := feedbagStore.FeedbagUpsert(screenName, itemsIn); err != nil {
  1615. t.Fatalf("failed to upsert: %s", err.Error())
  1616. }
  1617. b, err := feedbagStore.BuddyIconRefByName(screenName)
  1618. assert.NoError(t, err)
  1619. if !reflect.DeepEqual(b.BARTInfo.Hash, testHash) {
  1620. t.Fatalf("expected hash did not match")
  1621. }
  1622. }
  1623. func TestSQLiteUserStore_BuddyIconRefByNameMissingRef(t *testing.T) {
  1624. defer func() {
  1625. assert.NoError(t, os.Remove(testFile))
  1626. }()
  1627. existingScreenName := NewIdentScreenName("TalkingTyler")
  1628. queryScreenName := NewIdentScreenName("SingingSuzy")
  1629. testHash := []byte{'t', 'h', 'e', 'h', 'a', 's', 'h'}
  1630. feedbagStore, err := NewSQLiteUserStore(testFile)
  1631. assert.NoError(t, err)
  1632. itemsIn := []wire.FeedbagItem{
  1633. {
  1634. Name: "1",
  1635. ClassID: wire.FeedbagClassIdBart,
  1636. TLVLBlock: wire.TLVLBlock{
  1637. TLVList: wire.TLVList{
  1638. wire.NewTLVBE(wire.FeedbagAttributesBartInfo, wire.BARTInfo{
  1639. Hash: testHash,
  1640. }),
  1641. },
  1642. },
  1643. },
  1644. }
  1645. if err := feedbagStore.FeedbagUpsert(existingScreenName, itemsIn); err != nil {
  1646. t.Fatalf("failed to upsert: %s", err.Error())
  1647. }
  1648. b, err := feedbagStore.BuddyIconRefByName(queryScreenName)
  1649. assert.NoError(t, err)
  1650. if b != nil {
  1651. t.Fatalf("empty BARTID expected")
  1652. }
  1653. }
  1654. func TestSQLiteUserStore_SetDirectoryInfo(t *testing.T) {
  1655. defer func() {
  1656. assert.NoError(t, os.Remove(testFile))
  1657. }()
  1658. f, err := NewSQLiteUserStore(testFile)
  1659. assert.NoError(t, err)
  1660. screenName := NewIdentScreenName("testuser")
  1661. user := User{
  1662. IdentScreenName: screenName,
  1663. }
  1664. err = f.InsertUser(user)
  1665. assert.NoError(t, err)
  1666. directoryInfo := AIMNameAndAddr{
  1667. FirstName: "John",
  1668. LastName: "Doe",
  1669. MiddleName: "Michael",
  1670. MaidenName: "Smith",
  1671. Country: "USA",
  1672. State: "CA",
  1673. City: "San Francisco",
  1674. NickName: "Johnny",
  1675. ZIPCode: "94105",
  1676. Address: "123 Main St",
  1677. }
  1678. t.Run("Successful Update", func(t *testing.T) {
  1679. err := f.SetDirectoryInfo(screenName, directoryInfo)
  1680. assert.NoError(t, err)
  1681. updatedUser, err := f.User(screenName)
  1682. assert.NoError(t, err)
  1683. assert.Equal(t, directoryInfo.FirstName, updatedUser.AIMDirectoryInfo.FirstName)
  1684. assert.Equal(t, directoryInfo.LastName, updatedUser.AIMDirectoryInfo.LastName)
  1685. assert.Equal(t, directoryInfo.MiddleName, updatedUser.AIMDirectoryInfo.MiddleName)
  1686. assert.Equal(t, directoryInfo.MaidenName, updatedUser.AIMDirectoryInfo.MaidenName)
  1687. assert.Equal(t, directoryInfo.Country, updatedUser.AIMDirectoryInfo.Country)
  1688. assert.Equal(t, directoryInfo.State, updatedUser.AIMDirectoryInfo.State)
  1689. assert.Equal(t, directoryInfo.City, updatedUser.AIMDirectoryInfo.City)
  1690. assert.Equal(t, directoryInfo.NickName, updatedUser.AIMDirectoryInfo.NickName)
  1691. assert.Equal(t, directoryInfo.ZIPCode, updatedUser.AIMDirectoryInfo.ZIPCode)
  1692. assert.Equal(t, directoryInfo.Address, updatedUser.AIMDirectoryInfo.Address)
  1693. })
  1694. t.Run("Update Non-Existing User", func(t *testing.T) {
  1695. nonExistingScreenName := NewIdentScreenName("nonexistentuser")
  1696. err := f.SetDirectoryInfo(nonExistingScreenName, directoryInfo)
  1697. assert.ErrorIs(t, err, ErrNoUser)
  1698. })
  1699. t.Run("Empty Directory Info", func(t *testing.T) {
  1700. emptyDirectoryInfo := AIMNameAndAddr{}
  1701. err := f.SetDirectoryInfo(screenName, emptyDirectoryInfo)
  1702. assert.NoError(t, err)
  1703. updatedUser, err := f.User(screenName)
  1704. assert.NoError(t, err)
  1705. assert.Empty(t, updatedUser.AIMDirectoryInfo.FirstName)
  1706. assert.Empty(t, updatedUser.AIMDirectoryInfo.LastName)
  1707. assert.Empty(t, updatedUser.AIMDirectoryInfo.MiddleName)
  1708. assert.Empty(t, updatedUser.AIMDirectoryInfo.MaidenName)
  1709. assert.Empty(t, updatedUser.AIMDirectoryInfo.Country)
  1710. assert.Empty(t, updatedUser.AIMDirectoryInfo.State)
  1711. assert.Empty(t, updatedUser.AIMDirectoryInfo.City)
  1712. assert.Empty(t, updatedUser.AIMDirectoryInfo.NickName)
  1713. assert.Empty(t, updatedUser.AIMDirectoryInfo.ZIPCode)
  1714. assert.Empty(t, updatedUser.AIMDirectoryInfo.Address)
  1715. })
  1716. }
  1717. func TestSQLiteUserStore_Categories(t *testing.T) {
  1718. t.Run("Retrieve Keyword Categories Successfully", func(t *testing.T) {
  1719. defer func() {
  1720. assert.NoError(t, os.Remove(testFile))
  1721. }()
  1722. f, err := NewSQLiteUserStore(testFile)
  1723. assert.NoError(t, err)
  1724. // Insert some test keyword categories
  1725. categories := []string{"Category3", "Category1", "Category2"}
  1726. for _, categoryName := range categories {
  1727. _, err := f.CreateCategory(categoryName)
  1728. assert.NoError(t, err)
  1729. }
  1730. retrievedCategories, err := f.Categories()
  1731. assert.NoError(t, err)
  1732. // Make sure all categories are returned in alphabetical order
  1733. if assert.Len(t, retrievedCategories, len(categories)) {
  1734. expect := []Category{
  1735. {
  1736. ID: 2,
  1737. Name: "Category1",
  1738. },
  1739. {
  1740. ID: 3,
  1741. Name: "Category2",
  1742. },
  1743. {
  1744. ID: 1,
  1745. Name: "Category3",
  1746. },
  1747. }
  1748. assert.Equal(t, expect, retrievedCategories)
  1749. }
  1750. })
  1751. t.Run("No Categories Exist", func(t *testing.T) {
  1752. defer func() {
  1753. assert.NoError(t, os.Remove(testFile))
  1754. }()
  1755. f, err := NewSQLiteUserStore(testFile)
  1756. assert.NoError(t, err)
  1757. // Clean up the database
  1758. _, err = f.db.Exec(`DELETE FROM aimKeywordCategory`)
  1759. assert.NoError(t, err)
  1760. retrievedCategories, err := f.Categories()
  1761. assert.NoError(t, err)
  1762. assert.Empty(t, retrievedCategories)
  1763. })
  1764. t.Run("SQL Error Handling", func(t *testing.T) {
  1765. defer func() {
  1766. assert.NoError(t, os.Remove(testFile))
  1767. }()
  1768. f, err := NewSQLiteUserStore(testFile)
  1769. assert.NoError(t, err)
  1770. // Force an error by querying a non-existent table
  1771. _, err = f.db.Exec(`DROP TABLE aimKeywordCategory`)
  1772. assert.NoError(t, err)
  1773. _, err = f.Categories()
  1774. assert.Error(t, err)
  1775. })
  1776. t.Run("Unique Constraint Violation", func(t *testing.T) {
  1777. defer func() {
  1778. assert.NoError(t, os.Remove(testFile))
  1779. }()
  1780. f, err := NewSQLiteUserStore(testFile)
  1781. assert.NoError(t, err)
  1782. // Insert a category with a unique name
  1783. categoryName := "UniqueCategory"
  1784. _, err = f.CreateCategory(categoryName)
  1785. assert.NoError(t, err)
  1786. // Try to insert the same category name again to trigger the unique constraint
  1787. _, err = f.CreateCategory(categoryName)
  1788. assert.ErrorIs(t, err, ErrKeywordCategoryExists)
  1789. })
  1790. }
  1791. func TestSQLiteUserStore_CreateCategory(t *testing.T) {
  1792. t.Run("Successfully Create Keyword Category", func(t *testing.T) {
  1793. defer func() {
  1794. assert.NoError(t, os.Remove(testFile))
  1795. }()
  1796. f, err := NewSQLiteUserStore(testFile)
  1797. assert.NoError(t, err)
  1798. categoryName := "TestCategory"
  1799. keywordCategory, err := f.CreateCategory(categoryName)
  1800. assert.NoError(t, err)
  1801. assert.Equal(t, categoryName, keywordCategory.Name)
  1802. assert.NotZero(t, keywordCategory.ID)
  1803. categories, err := f.Categories()
  1804. assert.NoError(t, err)
  1805. if assert.Len(t, categories, 1) {
  1806. assert.Equal(t, categoryName, categories[0].Name)
  1807. }
  1808. })
  1809. t.Run("Duplicate Category Name", func(t *testing.T) {
  1810. defer func() {
  1811. assert.NoError(t, os.Remove(testFile))
  1812. }()
  1813. f, err := NewSQLiteUserStore(testFile)
  1814. assert.NoError(t, err)
  1815. categoryName := "DuplicateCategory"
  1816. // Create the category
  1817. _, err = f.CreateCategory(categoryName)
  1818. assert.NoError(t, err)
  1819. // Try to create the same category again
  1820. _, err = f.CreateCategory(categoryName)
  1821. assert.ErrorIs(t, err, ErrKeywordCategoryExists)
  1822. })
  1823. t.Run("ID Overflow", func(t *testing.T) {
  1824. defer func() {
  1825. assert.NoError(t, os.Remove(testFile))
  1826. }()
  1827. f, err := NewSQLiteUserStore(testFile)
  1828. assert.NoError(t, err)
  1829. // Simulate ID overflow by inserting max number of entries
  1830. for i := range math.MaxUint8 {
  1831. _, err := f.CreateCategory(fmt.Sprintf("Category_%d", i))
  1832. assert.NoError(t, err)
  1833. }
  1834. // Next insert should cause an ID overflow
  1835. _, err = f.CreateCategory("OverflowCategory")
  1836. assert.ErrorIs(t, err, errTooManyCategories)
  1837. })
  1838. t.Run("SQL Error Handling", func(t *testing.T) {
  1839. defer func() {
  1840. assert.NoError(t, os.Remove(testFile))
  1841. }()
  1842. f, err := NewSQLiteUserStore(testFile)
  1843. assert.NoError(t, err)
  1844. // Drop the table to cause an error
  1845. _, err = f.db.Exec(`DROP TABLE aimKeywordCategory`)
  1846. assert.NoError(t, err)
  1847. _, err = f.CreateCategory("ShouldFail")
  1848. assert.Error(t, err)
  1849. })
  1850. }
  1851. func TestSQLiteUserStore_DeleteCategory(t *testing.T) {
  1852. t.Run("Successfully Delete Keyword Category", func(t *testing.T) {
  1853. f, err := NewSQLiteUserStore(testFile)
  1854. assert.NoError(t, err)
  1855. defer func() {
  1856. assert.NoError(t, os.Remove(testFile))
  1857. }()
  1858. // Insert a test category
  1859. categoryName := "CategoryToDelete"
  1860. category, err := f.CreateCategory(categoryName)
  1861. assert.NoError(t, err)
  1862. // Ensure the category was created
  1863. retrievedCategories, err := f.Categories()
  1864. assert.NoError(t, err)
  1865. assert.Len(t, retrievedCategories, 1)
  1866. // Delete the category
  1867. err = f.DeleteCategory(category.ID)
  1868. assert.NoError(t, err)
  1869. // Verify the category was deleted
  1870. retrievedCategories, err = f.Categories()
  1871. assert.NoError(t, err)
  1872. assert.Empty(t, retrievedCategories)
  1873. })
  1874. t.Run("Delete Non-Existent Category", func(t *testing.T) {
  1875. f, err := NewSQLiteUserStore(testFile)
  1876. assert.NoError(t, err)
  1877. defer func() {
  1878. assert.NoError(t, os.Remove(testFile))
  1879. }()
  1880. // Attempt to delete a category that does not exist
  1881. nonExistentCategoryID := uint8(99)
  1882. err = f.DeleteCategory(nonExistentCategoryID)
  1883. assert.ErrorIs(t, err, ErrKeywordCategoryNotFound)
  1884. })
  1885. t.Run("Delete category and all of its keywords", func(t *testing.T) {
  1886. f, err := NewSQLiteUserStore(testFile)
  1887. assert.NoError(t, err)
  1888. defer func() {
  1889. assert.NoError(t, os.Remove(testFile))
  1890. }()
  1891. // Insert a category
  1892. categoryName := "CategoryInUse"
  1893. category, err := f.CreateCategory(categoryName)
  1894. assert.NoError(t, err)
  1895. // Insert a keyword that references this category
  1896. keywordName := "KeywordInUse"
  1897. _, err = f.CreateKeyword(keywordName, category.ID)
  1898. assert.NoError(t, err)
  1899. // Create a user and associate it with the keyword
  1900. u := User{
  1901. IdentScreenName: NewIdentScreenName("testuser"),
  1902. }
  1903. err = f.InsertUser(u)
  1904. assert.NoError(t, err)
  1905. err = f.SetKeywords(u.IdentScreenName, [5]string{keywordName})
  1906. assert.NoError(t, err)
  1907. // Attempt to delete the category that is in use by the keyword
  1908. err = f.DeleteCategory(category.ID)
  1909. assert.ErrorIs(t, err, ErrKeywordInUse)
  1910. })
  1911. }
  1912. func TestSQLiteUserStore_CreateKeyword(t *testing.T) {
  1913. t.Run("Successfully Create Keyword", func(t *testing.T) {
  1914. defer func() {
  1915. assert.NoError(t, os.Remove(testFile))
  1916. }()
  1917. f, err := NewSQLiteUserStore(testFile)
  1918. assert.NoError(t, err)
  1919. // Create a test category
  1920. categoryName := "TestCategory"
  1921. category, err := f.CreateCategory(categoryName)
  1922. assert.NoError(t, err)
  1923. // Insert a keyword for the category
  1924. keywordName := "TestKeyword"
  1925. keyword, err := f.CreateKeyword(keywordName, category.ID)
  1926. assert.NoError(t, err)
  1927. assert.Equal(t, keywordName, keyword.Name)
  1928. assert.NotZero(t, keyword.ID)
  1929. // Verify the keyword and category were inserted into the database
  1930. keywords, err := f.KeywordsByCategory(category.ID)
  1931. assert.NoError(t, err)
  1932. if assert.Len(t, keywords, 1) {
  1933. expect := []Keyword{
  1934. keyword,
  1935. }
  1936. assert.Equal(t, expect, keywords)
  1937. }
  1938. })
  1939. t.Run("Create Keyword Without Category", func(t *testing.T) {
  1940. defer func() {
  1941. assert.NoError(t, os.Remove(testFile))
  1942. }()
  1943. f, err := NewSQLiteUserStore(testFile)
  1944. assert.NoError(t, err)
  1945. // Insert a keyword with no category (parent is NULL)
  1946. keywordName := "UncategorizedKeyword"
  1947. keyword, err := f.CreateKeyword(keywordName, 0)
  1948. assert.NoError(t, err)
  1949. assert.Equal(t, keywordName, keyword.Name)
  1950. assert.NotZero(t, keyword.ID)
  1951. // Verify the keyword was inserted into the database
  1952. keywords, err := f.KeywordsByCategory(0)
  1953. assert.NoError(t, err)
  1954. if assert.Len(t, keywords, 1) {
  1955. expect := []Keyword{
  1956. keyword,
  1957. }
  1958. assert.Equal(t, expect, keywords)
  1959. }
  1960. })
  1961. t.Run("Create Keyword With Unknown Category", func(t *testing.T) {
  1962. defer func() {
  1963. assert.NoError(t, os.Remove(testFile))
  1964. }()
  1965. f, err := NewSQLiteUserStore(testFile)
  1966. assert.NoError(t, err)
  1967. // Insert a keyword with no category (parent is NULL)
  1968. keywordName := "AKeyword"
  1969. _, err = f.CreateKeyword(keywordName, 1)
  1970. assert.ErrorIs(t, err, ErrKeywordCategoryNotFound)
  1971. })
  1972. t.Run("Duplicate Keyword Name", func(t *testing.T) {
  1973. defer func() {
  1974. assert.NoError(t, os.Remove(testFile))
  1975. }()
  1976. f, err := NewSQLiteUserStore(testFile)
  1977. assert.NoError(t, err)
  1978. keywordName := "DuplicateKeyword"
  1979. // Create the keyword
  1980. _, err = f.CreateKeyword(keywordName, 0)
  1981. assert.NoError(t, err)
  1982. // Try to create the same keyword again
  1983. _, err = f.CreateKeyword(keywordName, 0)
  1984. assert.ErrorIs(t, err, ErrKeywordExists)
  1985. })
  1986. t.Run("ID Overflow", func(t *testing.T) {
  1987. defer func() {
  1988. assert.NoError(t, os.Remove(testFile))
  1989. }()
  1990. f, err := NewSQLiteUserStore(testFile)
  1991. assert.NoError(t, err)
  1992. // Create a test category
  1993. categoryName := "OverflowCategory"
  1994. category, err := f.CreateCategory(categoryName)
  1995. assert.NoError(t, err)
  1996. // Simulate ID overflow by inserting max number of entries
  1997. for i := 0; i < math.MaxUint8; i++ {
  1998. _, err := f.CreateKeyword(fmt.Sprintf("Keyword_%d", i), category.ID)
  1999. assert.NoError(t, err)
  2000. }
  2001. // Next insert should cause an ID overflow
  2002. _, err = f.CreateKeyword("OverflowKeyword", category.ID)
  2003. assert.ErrorIs(t, err, errTooManyKeywords)
  2004. })
  2005. t.Run("SQL Error Handling", func(t *testing.T) {
  2006. defer func() {
  2007. assert.NoError(t, os.Remove(testFile))
  2008. }()
  2009. f, err := NewSQLiteUserStore(testFile)
  2010. assert.NoError(t, err)
  2011. // Drop the table to cause an error
  2012. _, err = f.db.Exec(`DROP TABLE aimKeyword`)
  2013. assert.NoError(t, err)
  2014. _, err = f.CreateKeyword("ShouldFail", 0)
  2015. assert.Error(t, err)
  2016. })
  2017. }
  2018. func TestSQLiteUserStore_DeleteKeyword(t *testing.T) {
  2019. t.Run("Successfully Delete Keyword", func(t *testing.T) {
  2020. f, err := NewSQLiteUserStore(testFile)
  2021. assert.NoError(t, err)
  2022. defer func() {
  2023. assert.NoError(t, os.Remove(testFile))
  2024. }()
  2025. // Insert a category
  2026. categoryName := "TestCategory"
  2027. category, err := f.CreateCategory(categoryName)
  2028. assert.NoError(t, err)
  2029. // Insert a keyword for the category
  2030. keywordName := "TestKeyword"
  2031. keyword, err := f.CreateKeyword(keywordName, category.ID)
  2032. assert.NoError(t, err)
  2033. // Ensure the keyword was created
  2034. retrievedKeywords, err := f.KeywordsByCategory(category.ID)
  2035. assert.NoError(t, err)
  2036. assert.Len(t, retrievedKeywords, 1)
  2037. // Delete the keyword
  2038. err = f.DeleteKeyword(keyword.ID)
  2039. assert.NoError(t, err)
  2040. // Verify the keyword was deleted
  2041. retrievedKeywords, err = f.KeywordsByCategory(category.ID)
  2042. assert.NoError(t, err)
  2043. assert.Empty(t, retrievedKeywords)
  2044. })
  2045. t.Run("Delete Non-Existent Keyword", func(t *testing.T) {
  2046. f, err := NewSQLiteUserStore(testFile)
  2047. assert.NoError(t, err)
  2048. defer func() {
  2049. assert.NoError(t, os.Remove(testFile))
  2050. }()
  2051. // Attempt to delete a keyword that does not exist
  2052. nonExistentKeywordID := uint8(99)
  2053. err = f.DeleteKeyword(nonExistentKeywordID)
  2054. assert.ErrorIs(t, err, ErrKeywordNotFound)
  2055. })
  2056. t.Run("Delete Keyword Associated with User", func(t *testing.T) {
  2057. f, err := NewSQLiteUserStore(testFile)
  2058. assert.NoError(t, err)
  2059. defer func() {
  2060. assert.NoError(t, os.Remove(testFile))
  2061. }()
  2062. // Insert a category
  2063. categoryName := "CategoryInUse"
  2064. category, err := f.CreateCategory(categoryName)
  2065. assert.NoError(t, err)
  2066. // Insert a keyword
  2067. keywordName := "KeywordInUse"
  2068. keyword, err := f.CreateKeyword(keywordName, category.ID)
  2069. assert.NoError(t, err)
  2070. // Create a user and associate it with the keyword
  2071. u := User{
  2072. IdentScreenName: NewIdentScreenName("testuser"),
  2073. }
  2074. err = f.InsertUser(u)
  2075. assert.NoError(t, err)
  2076. err = f.SetKeywords(u.IdentScreenName, [5]string{keywordName})
  2077. assert.NoError(t, err)
  2078. // Attempt to delete the keyword and expect an ErrKeywordInUse
  2079. err = f.DeleteKeyword(keyword.ID)
  2080. assert.ErrorIs(t, err, ErrKeywordInUse)
  2081. })
  2082. }
  2083. func TestSQLiteUserStore_InterestList(t *testing.T) {
  2084. t.Run("Full list", func(t *testing.T) {
  2085. f, err := NewSQLiteUserStore(testFile)
  2086. assert.NoError(t, err)
  2087. defer func() {
  2088. assert.NoError(t, os.Remove(testFile))
  2089. }()
  2090. tech, err := f.CreateCategory("Technology")
  2091. assert.NoError(t, err)
  2092. music, err := f.CreateCategory("Music")
  2093. assert.NoError(t, err)
  2094. sports, err := f.CreateCategory("Sports")
  2095. assert.NoError(t, err)
  2096. _, err = f.CreateKeyword("Rock", music.ID)
  2097. assert.NoError(t, err)
  2098. _, err = f.CreateKeyword("Soccer", sports.ID)
  2099. assert.NoError(t, err)
  2100. _, err = f.CreateKeyword("Cybersecurity", tech.ID)
  2101. assert.NoError(t, err)
  2102. _, err = f.CreateKeyword("Zoology", 0)
  2103. assert.NoError(t, err)
  2104. _, err = f.CreateKeyword("Jazz", music.ID)
  2105. assert.NoError(t, err)
  2106. _, err = f.CreateKeyword("Animals", 0)
  2107. assert.NoError(t, err)
  2108. _, err = f.CreateKeyword("Basketball", sports.ID)
  2109. assert.NoError(t, err)
  2110. _, err = f.CreateKeyword("Artificial Intelligence", tech.ID)
  2111. assert.NoError(t, err)
  2112. _, err = f.CreateKeyword("Tennis", sports.ID)
  2113. assert.NoError(t, err)
  2114. expect := []wire.ODirKeywordListItem{
  2115. {
  2116. ID: 0,
  2117. Name: "Animals",
  2118. Type: wire.ODirKeyword,
  2119. },
  2120. {
  2121. ID: 2,
  2122. Name: "Music",
  2123. Type: wire.ODirKeywordCategory,
  2124. },
  2125. {
  2126. ID: 2,
  2127. Name: "Jazz",
  2128. Type: wire.ODirKeyword,
  2129. },
  2130. {
  2131. ID: 2,
  2132. Name: "Rock",
  2133. Type: wire.ODirKeyword,
  2134. },
  2135. {
  2136. ID: 3,
  2137. Name: "Sports",
  2138. Type: wire.ODirKeywordCategory,
  2139. },
  2140. {
  2141. ID: 3,
  2142. Name: "Basketball",
  2143. Type: wire.ODirKeyword,
  2144. },
  2145. {
  2146. ID: 3,
  2147. Name: "Soccer",
  2148. Type: wire.ODirKeyword,
  2149. },
  2150. {
  2151. ID: 3,
  2152. Name: "Tennis",
  2153. Type: wire.ODirKeyword,
  2154. },
  2155. {
  2156. ID: 1,
  2157. Name: "Technology",
  2158. Type: wire.ODirKeywordCategory,
  2159. },
  2160. {
  2161. ID: 1,
  2162. Name: "Artificial Intelligence",
  2163. Type: wire.ODirKeyword,
  2164. },
  2165. {
  2166. ID: 1,
  2167. Name: "Cybersecurity",
  2168. Type: wire.ODirKeyword,
  2169. },
  2170. {
  2171. ID: 0,
  2172. Name: "Zoology",
  2173. Type: wire.ODirKeyword,
  2174. },
  2175. }
  2176. actual, err := f.InterestList()
  2177. assert.NoError(t, err)
  2178. assert.Equal(t, expect, actual)
  2179. })
  2180. t.Run("Empty list list", func(t *testing.T) {
  2181. f, err := NewSQLiteUserStore(testFile)
  2182. assert.NoError(t, err)
  2183. defer func() {
  2184. assert.NoError(t, os.Remove(testFile))
  2185. }()
  2186. actual, err := f.InterestList()
  2187. assert.NoError(t, err)
  2188. assert.Empty(t, actual)
  2189. })
  2190. }
  2191. func TestSQLiteUserStore_KeywordsByCategory(t *testing.T) {
  2192. t.Run("Category Does Not Exist", func(t *testing.T) {
  2193. defer func() {
  2194. assert.NoError(t, os.Remove(testFile))
  2195. }()
  2196. f, err := NewSQLiteUserStore(testFile)
  2197. assert.NoError(t, err)
  2198. // Create a test category
  2199. categoryName := "TestCategory"
  2200. category, err := f.CreateCategory(categoryName)
  2201. assert.NoError(t, err)
  2202. keywords, err := f.KeywordsByCategory(category.ID + 1)
  2203. assert.Empty(t, keywords)
  2204. assert.ErrorIs(t, err, ErrKeywordCategoryNotFound)
  2205. })
  2206. }
  2207. func TestSQLiteUserStore_UnregisterBuddyList(t *testing.T) {
  2208. defer func() {
  2209. assert.NoError(t, os.Remove(testFile))
  2210. }()
  2211. f, err := NewSQLiteUserStore(testFile)
  2212. assert.NoError(t, err)
  2213. users := []IdentScreenName{
  2214. NewIdentScreenName("user1"),
  2215. NewIdentScreenName("user2"),
  2216. NewIdentScreenName("user3"),
  2217. }
  2218. for _, me := range users {
  2219. err = f.RegisterBuddyList(me)
  2220. assert.NoError(t, err)
  2221. for _, them := range users {
  2222. if me == them {
  2223. continue
  2224. }
  2225. err = f.AddBuddy(me, them)
  2226. assert.NoError(t, err)
  2227. }
  2228. }
  2229. relationships, err := f.AllRelationships(users[0], nil)
  2230. assert.NoError(t, err)
  2231. expect := []Relationship{
  2232. {
  2233. User: NewIdentScreenName("user2"),
  2234. IsOnTheirList: true,
  2235. IsOnYourList: true,
  2236. },
  2237. {
  2238. User: NewIdentScreenName("user3"),
  2239. IsOnTheirList: true,
  2240. IsOnYourList: true,
  2241. },
  2242. }
  2243. assert.ElementsMatch(t, relationships, expect)
  2244. err = f.UnregisterBuddyList(users[2])
  2245. assert.NoError(t, err)
  2246. relationships, err = f.AllRelationships(users[0], nil)
  2247. expect = []Relationship{
  2248. {
  2249. User: NewIdentScreenName("user2"),
  2250. IsOnTheirList: true,
  2251. IsOnYourList: true,
  2252. },
  2253. }
  2254. assert.ElementsMatch(t, relationships, expect)
  2255. }
  2256. func TestSQLiteUserStore_ClearBuddyListRegistry(t *testing.T) {
  2257. defer func() {
  2258. assert.NoError(t, os.Remove(testFile))
  2259. }()
  2260. f, err := NewSQLiteUserStore(testFile)
  2261. assert.NoError(t, err)
  2262. users := []IdentScreenName{
  2263. NewIdentScreenName("user1"),
  2264. NewIdentScreenName("user2"),
  2265. NewIdentScreenName("user3"),
  2266. }
  2267. for _, me := range users {
  2268. err = f.RegisterBuddyList(me)
  2269. assert.NoError(t, err)
  2270. for _, them := range users {
  2271. if me == them {
  2272. continue
  2273. }
  2274. err = f.AddBuddy(me, them)
  2275. assert.NoError(t, err)
  2276. }
  2277. }
  2278. for _, me := range users {
  2279. var relationships []Relationship
  2280. relationships, err = f.AllRelationships(me, nil)
  2281. assert.NoError(t, err)
  2282. assert.Len(t, relationships, 2)
  2283. }
  2284. err = f.ClearBuddyListRegistry()
  2285. assert.NoError(t, err)
  2286. for _, me := range users {
  2287. var relationships []Relationship
  2288. relationships, err = f.AllRelationships(me, nil)
  2289. assert.NoError(t, err)
  2290. assert.Empty(t, relationships)
  2291. }
  2292. }
  2293. func TestSQLiteUserStore_RemoveBuddy(t *testing.T) {
  2294. defer func() {
  2295. assert.NoError(t, os.Remove(testFile))
  2296. }()
  2297. f, err := NewSQLiteUserStore(testFile)
  2298. assert.NoError(t, err)
  2299. me := NewIdentScreenName("me")
  2300. err = f.RegisterBuddyList(me)
  2301. assert.NoError(t, err)
  2302. them := NewIdentScreenName("them")
  2303. err = f.RegisterBuddyList(them)
  2304. assert.NoError(t, err)
  2305. err = f.AddBuddy(me, them)
  2306. assert.NoError(t, err)
  2307. relationships, err := f.AllRelationships(me, nil)
  2308. assert.NoError(t, err)
  2309. expect := []Relationship{
  2310. {
  2311. User: them,
  2312. IsOnTheirList: false,
  2313. IsOnYourList: true,
  2314. },
  2315. }
  2316. assert.ElementsMatch(t, relationships, expect)
  2317. err = f.RemoveBuddy(me, them)
  2318. assert.NoError(t, err)
  2319. relationships, err = f.AllRelationships(me, nil)
  2320. assert.NoError(t, err)
  2321. expect = []Relationship{
  2322. {
  2323. User: them,
  2324. IsOnTheirList: false,
  2325. IsOnYourList: false,
  2326. },
  2327. }
  2328. assert.ElementsMatch(t, relationships, expect)
  2329. }
  2330. func TestSQLiteUserStore_RemoveDenyBuddy(t *testing.T) {
  2331. defer func() {
  2332. assert.NoError(t, os.Remove(testFile))
  2333. }()
  2334. f, err := NewSQLiteUserStore(testFile)
  2335. assert.NoError(t, err)
  2336. me := NewIdentScreenName("me")
  2337. err = f.RegisterBuddyList(me)
  2338. assert.NoError(t, err)
  2339. err = f.SetPDMode(me, wire.FeedbagPDModeDenySome)
  2340. assert.NoError(t, err)
  2341. them := NewIdentScreenName("them")
  2342. err = f.RegisterBuddyList(them)
  2343. assert.NoError(t, err)
  2344. err = f.DenyBuddy(me, them)
  2345. assert.NoError(t, err)
  2346. relationships, err := f.AllRelationships(me, nil)
  2347. assert.NoError(t, err)
  2348. expect := []Relationship{
  2349. {
  2350. User: them,
  2351. IsOnTheirList: false,
  2352. IsOnYourList: false,
  2353. YouBlock: true,
  2354. BlocksYou: false,
  2355. },
  2356. }
  2357. assert.ElementsMatch(t, relationships, expect)
  2358. err = f.RemoveDenyBuddy(me, them)
  2359. assert.NoError(t, err)
  2360. relationships, err = f.AllRelationships(me, nil)
  2361. assert.NoError(t, err)
  2362. expect = []Relationship{
  2363. {
  2364. User: them,
  2365. IsOnTheirList: false,
  2366. IsOnYourList: false,
  2367. YouBlock: false,
  2368. BlocksYou: false,
  2369. },
  2370. }
  2371. assert.ElementsMatch(t, relationships, expect)
  2372. }
  2373. func TestSQLiteUserStore_RemovePermitBuddy(t *testing.T) {
  2374. defer func() {
  2375. assert.NoError(t, os.Remove(testFile))
  2376. }()
  2377. f, err := NewSQLiteUserStore(testFile)
  2378. assert.NoError(t, err)
  2379. me := NewIdentScreenName("me")
  2380. err = f.RegisterBuddyList(me)
  2381. assert.NoError(t, err)
  2382. err = f.SetPDMode(me, wire.FeedbagPDModePermitSome)
  2383. assert.NoError(t, err)
  2384. them := NewIdentScreenName("them")
  2385. err = f.RegisterBuddyList(them)
  2386. assert.NoError(t, err)
  2387. err = f.PermitBuddy(me, them)
  2388. assert.NoError(t, err)
  2389. relationships, err := f.AllRelationships(me, nil)
  2390. assert.NoError(t, err)
  2391. expect := []Relationship{
  2392. {
  2393. User: them,
  2394. IsOnTheirList: false,
  2395. IsOnYourList: false,
  2396. YouBlock: false,
  2397. BlocksYou: false,
  2398. },
  2399. }
  2400. assert.ElementsMatch(t, relationships, expect)
  2401. err = f.RemovePermitBuddy(me, them)
  2402. assert.NoError(t, err)
  2403. relationships, err = f.AllRelationships(me, nil)
  2404. assert.NoError(t, err)
  2405. expect = []Relationship{
  2406. {
  2407. User: them,
  2408. IsOnTheirList: false,
  2409. IsOnYourList: false,
  2410. YouBlock: true,
  2411. BlocksYou: false,
  2412. },
  2413. }
  2414. assert.ElementsMatch(t, relationships, expect)
  2415. }
  2416. func TestSQLiteUserStore_SetPDMode(t *testing.T) {
  2417. t.Run("Ensure idempotency", func(t *testing.T) {
  2418. defer func() {
  2419. assert.NoError(t, os.Remove(testFile))
  2420. }()
  2421. f, err := NewSQLiteUserStore(testFile)
  2422. assert.NoError(t, err)
  2423. users := []IdentScreenName{
  2424. NewIdentScreenName("me"),
  2425. NewIdentScreenName("them1"),
  2426. }
  2427. for _, user := range users {
  2428. err = f.RegisterBuddyList(user)
  2429. assert.NoError(t, err)
  2430. }
  2431. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
  2432. assert.NoError(t, f.PermitBuddy(users[0], users[1]))
  2433. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
  2434. relationships, err := f.AllRelationships(users[0], nil)
  2435. assert.NoError(t, err)
  2436. expect := []Relationship{
  2437. {
  2438. User: users[1],
  2439. IsOnTheirList: false,
  2440. IsOnYourList: false,
  2441. YouBlock: false,
  2442. BlocksYou: false,
  2443. },
  2444. }
  2445. assert.ElementsMatch(t, relationships, expect)
  2446. })
  2447. t.Run("Ensure transition from one mode to another clears previously set flags", func(t *testing.T) {
  2448. defer func() {
  2449. assert.NoError(t, os.Remove(testFile))
  2450. }()
  2451. f, err := NewSQLiteUserStore(testFile)
  2452. assert.NoError(t, err)
  2453. users := []IdentScreenName{
  2454. NewIdentScreenName("me"),
  2455. NewIdentScreenName("them1"),
  2456. }
  2457. for _, user := range users {
  2458. err = f.RegisterBuddyList(user)
  2459. assert.NoError(t, err)
  2460. }
  2461. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
  2462. assert.NoError(t, f.PermitBuddy(users[0], users[1]))
  2463. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenySome))
  2464. relationships, err := f.AllRelationships(users[0], nil)
  2465. assert.NoError(t, err)
  2466. assert.Empty(t, relationships)
  2467. })
  2468. }
  2469. // Ensure that transitioning between all the PD modes works.
  2470. func TestSQLiteUserStore_PermitDenyTransitionIntegration(t *testing.T) {
  2471. defer func() {
  2472. assert.NoError(t, os.Remove(testFile))
  2473. }()
  2474. f, err := NewSQLiteUserStore(testFile)
  2475. assert.NoError(t, err)
  2476. users := []IdentScreenName{
  2477. NewIdentScreenName("me"),
  2478. NewIdentScreenName("them1"),
  2479. NewIdentScreenName("them2"),
  2480. NewIdentScreenName("them3"),
  2481. }
  2482. for _, user := range users {
  2483. err = f.RegisterBuddyList(user)
  2484. assert.NoError(t, err)
  2485. }
  2486. // add them1 to buddy list
  2487. assert.NoError(t, f.AddBuddy(users[0], users[1]))
  2488. // permit them2
  2489. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
  2490. assert.NoError(t, f.PermitBuddy(users[0], users[2]))
  2491. relationships, err := f.AllRelationships(users[0], nil)
  2492. assert.NoError(t, err)
  2493. // make sure them1 is blocked and them2 is permitted
  2494. expect := []Relationship{
  2495. {
  2496. User: users[1],
  2497. IsOnTheirList: false,
  2498. IsOnYourList: true,
  2499. YouBlock: true,
  2500. BlocksYou: false,
  2501. },
  2502. {
  2503. User: users[2],
  2504. IsOnTheirList: false,
  2505. IsOnYourList: false,
  2506. YouBlock: false,
  2507. BlocksYou: false,
  2508. },
  2509. }
  2510. assert.ElementsMatch(t, relationships, expect)
  2511. // allow everyone
  2512. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitAll))
  2513. relationships, err = f.AllRelationships(users[0], nil)
  2514. assert.NoError(t, err)
  2515. // make sure buddy1 is on your buddy list and permitted
  2516. expect = []Relationship{
  2517. {
  2518. User: users[1],
  2519. IsOnTheirList: false,
  2520. IsOnYourList: true,
  2521. YouBlock: false,
  2522. BlocksYou: false,
  2523. },
  2524. }
  2525. assert.ElementsMatch(t, relationships, expect)
  2526. // permit them3
  2527. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitSome))
  2528. assert.NoError(t, f.PermitBuddy(users[0], users[3]))
  2529. relationships, err = f.AllRelationships(users[0], nil)
  2530. assert.NoError(t, err)
  2531. // make sure them1 is blocked them3 is permitted
  2532. expect = []Relationship{
  2533. {
  2534. User: users[1],
  2535. IsOnTheirList: false,
  2536. IsOnYourList: true,
  2537. YouBlock: true,
  2538. BlocksYou: false,
  2539. },
  2540. {
  2541. User: users[3],
  2542. IsOnTheirList: false,
  2543. IsOnYourList: false,
  2544. YouBlock: false,
  2545. BlocksYou: false,
  2546. },
  2547. }
  2548. assert.ElementsMatch(t, relationships, expect)
  2549. // only allow on buddy list
  2550. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitOnList))
  2551. relationships, err = f.AllRelationships(users[0], nil)
  2552. assert.NoError(t, err)
  2553. // make sure buddy1 is on your buddy list and permitted
  2554. expect = []Relationship{
  2555. {
  2556. User: users[1],
  2557. IsOnTheirList: false,
  2558. IsOnYourList: true,
  2559. YouBlock: false,
  2560. BlocksYou: false,
  2561. },
  2562. }
  2563. assert.ElementsMatch(t, relationships, expect)
  2564. // deny them2
  2565. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenySome))
  2566. assert.NoError(t, f.DenyBuddy(users[0], users[2]))
  2567. relationships, err = f.AllRelationships(users[0], nil)
  2568. assert.NoError(t, err)
  2569. // make sure them1 is allowed and them2 is blocked
  2570. expect = []Relationship{
  2571. {
  2572. User: users[1],
  2573. IsOnTheirList: false,
  2574. IsOnYourList: true,
  2575. YouBlock: false,
  2576. BlocksYou: false,
  2577. },
  2578. {
  2579. User: users[2],
  2580. IsOnTheirList: false,
  2581. IsOnYourList: false,
  2582. YouBlock: true,
  2583. BlocksYou: false,
  2584. },
  2585. }
  2586. assert.ElementsMatch(t, relationships, expect)
  2587. // allow everyone
  2588. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitAll))
  2589. relationships, err = f.AllRelationships(users[0], nil)
  2590. assert.NoError(t, err)
  2591. // make sure buddy1 is on your buddy list and permitted
  2592. expect = []Relationship{
  2593. {
  2594. User: users[1],
  2595. IsOnTheirList: false,
  2596. IsOnYourList: true,
  2597. YouBlock: false,
  2598. BlocksYou: false,
  2599. },
  2600. }
  2601. assert.ElementsMatch(t, relationships, expect)
  2602. // deny them3
  2603. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenySome))
  2604. assert.NoError(t, f.DenyBuddy(users[0], users[3]))
  2605. relationships, err = f.AllRelationships(users[0], nil)
  2606. assert.NoError(t, err)
  2607. // make sure them1 is allowed and them3 is blocked
  2608. expect = []Relationship{
  2609. {
  2610. User: users[1],
  2611. IsOnTheirList: false,
  2612. IsOnYourList: true,
  2613. YouBlock: false,
  2614. BlocksYou: false,
  2615. },
  2616. {
  2617. User: users[3],
  2618. IsOnTheirList: false,
  2619. IsOnYourList: false,
  2620. YouBlock: true,
  2621. BlocksYou: false,
  2622. },
  2623. }
  2624. assert.ElementsMatch(t, relationships, expect)
  2625. // deny everyone
  2626. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModeDenyAll))
  2627. relationships, err = f.AllRelationships(users[0], nil)
  2628. assert.NoError(t, err)
  2629. // make sure them1 is blocked
  2630. expect = []Relationship{
  2631. {
  2632. User: users[1],
  2633. IsOnTheirList: false,
  2634. IsOnYourList: true,
  2635. YouBlock: true,
  2636. BlocksYou: false,
  2637. },
  2638. }
  2639. assert.ElementsMatch(t, relationships, expect)
  2640. // allow everyone
  2641. assert.NoError(t, f.SetPDMode(users[0], wire.FeedbagPDModePermitAll))
  2642. relationships, err = f.AllRelationships(users[0], nil)
  2643. assert.NoError(t, err)
  2644. // make sure them1 is on your buddy list and permitted
  2645. expect = []Relationship{
  2646. {
  2647. User: users[1],
  2648. IsOnTheirList: false,
  2649. IsOnYourList: true,
  2650. YouBlock: false,
  2651. BlocksYou: false,
  2652. },
  2653. }
  2654. assert.ElementsMatch(t, relationships, expect)
  2655. }