storage_test.go 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408
  1. package storage
  2. import (
  3. "database/sql"
  4. "log"
  5. "os"
  6. "path"
  7. "testing"
  8. _ "github.com/mattn/go-sqlite3"
  9. "github.com/stretchr/testify/assert"
  10. )
  11. func newTestDb() (*SQLiteRepo, *sql.DB) {
  12. db, err := sql.Open("sqlite3", ":memory:")
  13. if err != nil {
  14. log.Fatal(err)
  15. }
  16. testDb := &SQLiteRepo{db: db}
  17. err = testDb.Migrate()
  18. if err != nil {
  19. log.Fatal("failed to start the test database: ", err)
  20. }
  21. return testDb, db
  22. }
  23. func TestMigrate(t *testing.T) {
  24. requiredTables := []string{
  25. "posts",
  26. "images",
  27. "menu",
  28. "navbar",
  29. "assets",
  30. "admin",
  31. }
  32. db, err := sql.Open("sqlite3", ":memory:")
  33. if err != nil {
  34. log.Fatal(err)
  35. }
  36. testDb := &SQLiteRepo{db: db}
  37. err = testDb.Migrate()
  38. if err != nil {
  39. t.Error(err)
  40. }
  41. for i := range requiredTables {
  42. name := requiredTables[i]
  43. row := db.QueryRow("SELECT name FROM sqlite_master WHERE type='table' AND name='?'", name)
  44. if row.Err() != nil {
  45. t.Errorf("error querying table: %s", name)
  46. }
  47. if row == nil {
  48. t.Errorf("no table returned: %s", name)
  49. }
  50. }
  51. }
  52. func TestGetDropdownElements(t *testing.T) {
  53. type testcase struct {
  54. seed []LinkPair
  55. }
  56. testDb, db := newTestDb()
  57. for _, tc := range []testcase{
  58. {
  59. seed: []LinkPair{
  60. {
  61. Text: "abc123",
  62. Link: "/abc/123",
  63. },
  64. },
  65. },
  66. } {
  67. stmt, _ := db.Prepare("INSERT INTO menu(link, text) VALUES (?,?)")
  68. for i := range tc.seed {
  69. _, err := stmt.Exec(tc.seed[i].Link, tc.seed[i].Text)
  70. if err != nil {
  71. t.Errorf("failed to seed: %s", err)
  72. }
  73. }
  74. got := testDb.GetDropdownElements()
  75. assert.Equal(t, got, tc.seed)
  76. }
  77. }
  78. func TestGetNavBarLinks(t *testing.T) {
  79. type testcase struct {
  80. seed []NavBarItem
  81. }
  82. testDb, db := newTestDb()
  83. for _, tc := range []testcase{
  84. {
  85. seed: []NavBarItem{
  86. {
  87. Link: "/abc/123",
  88. Redirect: "/abc/123/site",
  89. Png: []byte("xzy123abc098"),
  90. },
  91. },
  92. },
  93. } {
  94. stmt, _ := db.Prepare("INSERT INTO navbar(png, link, redirect) VALUES (?,?,?)")
  95. for i := range tc.seed {
  96. _, err := stmt.Exec(tc.seed[i].Png, tc.seed[i].Link, tc.seed[i].Redirect)
  97. if err != nil {
  98. t.Errorf("failed to seed: %s", err)
  99. }
  100. }
  101. got := testDb.GetNavBarLinks()
  102. assert.Equal(t, tc.seed, got)
  103. }
  104. }
  105. func TestGetAssets(t *testing.T) {
  106. type testcase struct {
  107. seed []Asset
  108. }
  109. testDb, db := newTestDb()
  110. for _, tc := range []testcase{
  111. {
  112. seed: []Asset{
  113. {
  114. Data: []byte("abc123xyz098"),
  115. Name: "asset1",
  116. },
  117. },
  118. },
  119. } {
  120. stmt, _ := db.Prepare("INSERT INTO assets(data, name) VALUES (?,?)")
  121. for i := range tc.seed {
  122. _, err := stmt.Exec(tc.seed[i].Data, tc.seed[i].Name)
  123. if err != nil {
  124. t.Error(err)
  125. }
  126. }
  127. got := testDb.GetAssets()
  128. assert.Equal(t, tc.seed, got)
  129. }
  130. }
  131. func TestGetAdminTables(t *testing.T) {
  132. type testcase struct {
  133. seed AdminPage
  134. }
  135. testDb, db := newTestDb()
  136. for _, tc := range []testcase{
  137. {
  138. seed: AdminPage{
  139. Tables: map[string][]TableData{
  140. "test": {
  141. {
  142. DisplayName: "abc123",
  143. Link: "xyz098",
  144. },
  145. },
  146. },
  147. },
  148. },
  149. } {
  150. stmt, _ := db.Prepare("INSERT INTO admin(display_name, link, category) VALUES (?,?,?)")
  151. for k, table := range tc.seed.Tables {
  152. for i := range table {
  153. _, err := stmt.Exec(table[i].DisplayName, table[i].Link, k)
  154. if err != nil {
  155. t.Error(err)
  156. }
  157. }
  158. }
  159. got := testDb.GetAdminTables()
  160. assert.Equal(t, tc.seed, got)
  161. }
  162. }
  163. func TestGetDocument(t *testing.T) {
  164. type testcase struct {
  165. seed Document
  166. }
  167. testDb, db := newTestDb()
  168. for _, tc := range []testcase{
  169. {
  170. seed: Document{
  171. Ident: Identifier("qwerty"),
  172. Title: "abc 123",
  173. Created: "2024-12-31",
  174. Body: "blog post body etc",
  175. Category: BLOG,
  176. Sample: "this is a sample",
  177. },
  178. },
  179. } {
  180. stmt, _ := db.Prepare("INSERT INTO posts(id, title, created, body, category, sample) VALUES (?,?,?,?,?,?)")
  181. _, err := stmt.Exec(tc.seed.Ident, tc.seed.Title, tc.seed.Created, tc.seed.Body, tc.seed.Category, tc.seed.Sample)
  182. if err != nil {
  183. t.Error(err)
  184. }
  185. got, _ := testDb.GetDocument(Identifier("qwerty"))
  186. assert.Equal(t, tc.seed, got)
  187. }
  188. }
  189. func TestGetByCategory(t *testing.T) {
  190. type testcase struct {
  191. seed []Document
  192. }
  193. testDb, db := newTestDb()
  194. for _, tc := range []testcase{
  195. {
  196. seed: []Document{
  197. {
  198. Row: 1,
  199. Ident: Identifier("qwerty"),
  200. Title: "abc 123",
  201. Created: "2024-12-31",
  202. Body: "blog post body etc",
  203. Category: BLOG,
  204. Sample: "this is a sample",
  205. },
  206. {
  207. Row: 2,
  208. Ident: Identifier("poiuyt"),
  209. Title: "abc 123",
  210. Created: "2024-12-31",
  211. Body: "blog post body etc",
  212. Category: BLOG,
  213. Sample: "this is a sample",
  214. },
  215. },
  216. },
  217. } {
  218. stmt, _ := db.Prepare("INSERT INTO posts(id, title, created, body, category, sample) VALUES (?,?,?,?,?,?)")
  219. for i := range tc.seed {
  220. _, err := stmt.Exec(tc.seed[i].Ident, tc.seed[i].Title, tc.seed[i].Created, tc.seed[i].Body, tc.seed[i].Category, tc.seed[i].Sample)
  221. if err != nil {
  222. t.Error(err)
  223. }
  224. }
  225. got := testDb.GetByCategory(BLOG)
  226. assert.Equal(t, tc.seed, got)
  227. }
  228. }
  229. func TestGetImage(t *testing.T) {
  230. testDb, db := newTestDb()
  231. type testcase struct {
  232. seed Image
  233. }
  234. tmp := t.TempDir()
  235. testImageLoc := path.Join(tmp, "test.jpg")
  236. for _, tc := range []testcase{
  237. {
  238. seed: Image{
  239. Ident: Identifier("abc123"),
  240. Title: "xyz098",
  241. Location: testImageLoc,
  242. Desc: "description",
  243. Created: "2024-12-31",
  244. Data: []byte("abc123xyz098"),
  245. },
  246. },
  247. } {
  248. _, err := db.Exec("INSERT INTO images (id, title, location, desc, created) VALUES (?,?,?,?,?)", string(tc.seed.Ident), tc.seed.Title, tc.seed.Location, tc.seed.Desc, "2024-12-31")
  249. if err != nil {
  250. t.Error(err)
  251. }
  252. os.WriteFile(tc.seed.Location, tc.seed.Data, os.ModePerm)
  253. got, err := testDb.GetImage(tc.seed.Ident)
  254. if err != nil {
  255. t.Error(err)
  256. }
  257. assert.Equal(t, tc.seed, got)
  258. }
  259. }
  260. func TestGetAllImages(t *testing.T) {
  261. testDb, db := newTestDb()
  262. type testcase struct {
  263. seed []Image
  264. }
  265. tmp := t.TempDir()
  266. for _, tc := range []testcase{
  267. {
  268. seed: []Image{
  269. {
  270. Ident: Identifier("abc123"),
  271. Title: "xyz098",
  272. Location: path.Join(tmp, "1.jpg"),
  273. Data: []byte("abc123xyz098"),
  274. Created: "2024-12-31",
  275. Desc: "description",
  276. },
  277. {
  278. Ident: Identifier("xyz098"),
  279. Title: "abc123",
  280. Location: path.Join(tmp, "2.jpg"),
  281. Data: []byte("abc123xyz098"),
  282. Created: "2024-12-31",
  283. Desc: "description",
  284. },
  285. },
  286. },
  287. } {
  288. for i := range tc.seed {
  289. _, err := db.Exec("INSERT INTO images (id, title, location, desc, created) VALUES (?,?,?,?,?)", string(tc.seed[i].Ident), tc.seed[i].Title, tc.seed[i].Location, tc.seed[i].Desc, tc.seed[i].Created)
  290. if err != nil {
  291. t.Error(err)
  292. }
  293. os.WriteFile(tc.seed[i].Location, tc.seed[i].Data, os.ModePerm)
  294. }
  295. got := testDb.GetAllImages()
  296. assert.Equal(t, tc.seed, got)
  297. }
  298. }
  299. func TestAllDocuments(t *testing.T) {
  300. testDb, db := newTestDb()
  301. type testcase struct {
  302. seed []Document
  303. }
  304. for _, tc := range []testcase{
  305. {
  306. seed: []Document{
  307. {
  308. Row: 1,
  309. Ident: Identifier("qwerty"),
  310. Title: "abc 123",
  311. Created: "2024-12-31",
  312. Body: "blog post body etc",
  313. Category: BLOG,
  314. Sample: "this is a sample",
  315. },
  316. {
  317. Row: 2,
  318. Ident: Identifier("poiuyt"),
  319. Title: "abc 123",
  320. Created: "2024-12-31",
  321. Body: "blog post body etc",
  322. Category: BLOG,
  323. Sample: "this is a sample",
  324. },
  325. },
  326. },
  327. } {
  328. stmt, _ := db.Prepare("INSERT INTO posts(id, title, created, body, category, sample) VALUES (?,?,?,?,?,?)")
  329. for i := range tc.seed {
  330. _, err := stmt.Exec(tc.seed[i].Ident, tc.seed[i].Title, tc.seed[i].Created, tc.seed[i].Body, tc.seed[i].Category, tc.seed[i].Sample)
  331. if err != nil {
  332. t.Error(err)
  333. }
  334. }
  335. got := testDb.AllDocuments()
  336. assert.Equal(t, tc.seed, got)
  337. }
  338. }
  339. func TestUpdateDocument(t *testing.T) {
  340. // testDb, db := newTestDb()
  341. }
  342. func TestAddImage(t *testing.T) {
  343. // testDb, db := newTestDb()
  344. }
  345. func TestAddMenuItem(t *testing.T) {
  346. // testDb, db := newTestDb()
  347. }
  348. func TestAddNavbarItem(t *testing.T) {
  349. // testDb, db := newTestDb()
  350. }
  351. func TestAddAsset(t *testing.T) {
  352. // testDb, db := newTestDb()
  353. }
  354. func TestAddDocument(t *testing.T) {
  355. // testDb, db := newTestDb()
  356. }
  357. func TestAddAdminTableEntry(t *testing.T) {
  358. // testDb, db := newTestDb()
  359. }
  360. func TestDeleteDocument(t *testing.T) {
  361. // testDb, db := newTestDb()
  362. }
  363. func TestGetImageStore(t *testing.T) {
  364. // testDb, db := newTestDb()
  365. }
  366. func TestNewIdentifier(t *testing.T) {
  367. // testDb, db := newTestDb()
  368. }