user_store_test.go 87 KB

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