config_test.go 44 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933
  1. // SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
  2. // SPDX-License-Identifier: Apache-2.0
  3. package config // import "miniflux.app/v2/internal/config"
  4. import (
  5. "os"
  6. "testing"
  7. )
  8. func TestLogFileDefaultValue(t *testing.T) {
  9. os.Clearenv()
  10. parser := NewParser()
  11. opts, err := parser.ParseEnvironmentVariables()
  12. if err != nil {
  13. t.Fatalf(`Parsing failure: %v`, err)
  14. }
  15. if opts.LogFile() != defaultLogFile {
  16. t.Fatalf(`Unexpected log file value, got %q`, opts.LogFile())
  17. }
  18. }
  19. func TestLogFileWithCustomFilename(t *testing.T) {
  20. os.Clearenv()
  21. os.Setenv("LOG_FILE", "foobar.log")
  22. parser := NewParser()
  23. opts, err := parser.ParseEnvironmentVariables()
  24. if err != nil {
  25. t.Fatalf(`Parsing failure: %v`, err)
  26. }
  27. if opts.LogFile() != "foobar.log" {
  28. t.Fatalf(`Unexpected log file value, got %q`, opts.LogFile())
  29. }
  30. }
  31. func TestLogFileWithEmptyValue(t *testing.T) {
  32. os.Clearenv()
  33. os.Setenv("LOG_FILE", "")
  34. parser := NewParser()
  35. opts, err := parser.ParseEnvironmentVariables()
  36. if err != nil {
  37. t.Fatalf(`Parsing failure: %v`, err)
  38. }
  39. if opts.LogFile() != defaultLogFile {
  40. t.Fatalf(`Unexpected log file value, got %q`, opts.LogFile())
  41. }
  42. }
  43. func TestLogLevelDefaultValue(t *testing.T) {
  44. os.Clearenv()
  45. parser := NewParser()
  46. opts, err := parser.ParseEnvironmentVariables()
  47. if err != nil {
  48. t.Fatalf(`Parsing failure: %v`, err)
  49. }
  50. if opts.LogLevel() != defaultLogLevel {
  51. t.Fatalf(`Unexpected log level value, got %q`, opts.LogLevel())
  52. }
  53. }
  54. func TestLogLevelWithCustomValue(t *testing.T) {
  55. os.Clearenv()
  56. os.Setenv("LOG_LEVEL", "warning")
  57. parser := NewParser()
  58. opts, err := parser.ParseEnvironmentVariables()
  59. if err != nil {
  60. t.Fatalf(`Parsing failure: %v`, err)
  61. }
  62. if opts.LogLevel() != "warning" {
  63. t.Fatalf(`Unexpected log level value, got %q`, opts.LogLevel())
  64. }
  65. }
  66. func TestLogLevelWithInvalidValue(t *testing.T) {
  67. os.Clearenv()
  68. os.Setenv("LOG_LEVEL", "invalid")
  69. parser := NewParser()
  70. opts, err := parser.ParseEnvironmentVariables()
  71. if err != nil {
  72. t.Fatalf(`Parsing failure: %v`, err)
  73. }
  74. if opts.LogLevel() != defaultLogLevel {
  75. t.Fatalf(`Unexpected log level value, got %q`, opts.LogLevel())
  76. }
  77. }
  78. func TestLogDateTimeDefaultValue(t *testing.T) {
  79. os.Clearenv()
  80. parser := NewParser()
  81. opts, err := parser.ParseEnvironmentVariables()
  82. if err != nil {
  83. t.Fatalf(`Parsing failure: %v`, err)
  84. }
  85. if opts.LogDateTime() != defaultLogDateTime {
  86. t.Fatalf(`Unexpected log date time value, got %v`, opts.LogDateTime())
  87. }
  88. }
  89. func TestLogDateTimeWithCustomValue(t *testing.T) {
  90. os.Clearenv()
  91. os.Setenv("LOG_DATETIME", "false")
  92. parser := NewParser()
  93. opts, err := parser.ParseEnvironmentVariables()
  94. if err != nil {
  95. t.Fatalf(`Parsing failure: %v`, err)
  96. }
  97. if opts.LogDateTime() != false {
  98. t.Fatalf(`Unexpected log date time value, got %v`, opts.LogDateTime())
  99. }
  100. }
  101. func TestLogDateTimeWithInvalidValue(t *testing.T) {
  102. os.Clearenv()
  103. os.Setenv("LOG_DATETIME", "invalid")
  104. parser := NewParser()
  105. opts, err := parser.ParseEnvironmentVariables()
  106. if err != nil {
  107. t.Fatalf(`Parsing failure: %v`, err)
  108. }
  109. if opts.LogDateTime() != defaultLogDateTime {
  110. t.Fatalf(`Unexpected log date time value, got %v`, opts.LogDateTime())
  111. }
  112. }
  113. func TestLogFormatDefaultValue(t *testing.T) {
  114. os.Clearenv()
  115. parser := NewParser()
  116. opts, err := parser.ParseEnvironmentVariables()
  117. if err != nil {
  118. t.Fatalf(`Parsing failure: %v`, err)
  119. }
  120. if opts.LogFormat() != defaultLogFormat {
  121. t.Fatalf(`Unexpected log format value, got %q`, opts.LogFormat())
  122. }
  123. }
  124. func TestLogFormatWithCustomValue(t *testing.T) {
  125. os.Clearenv()
  126. os.Setenv("LOG_FORMAT", "json")
  127. parser := NewParser()
  128. opts, err := parser.ParseEnvironmentVariables()
  129. if err != nil {
  130. t.Fatalf(`Parsing failure: %v`, err)
  131. }
  132. if opts.LogFormat() != "json" {
  133. t.Fatalf(`Unexpected log format value, got %q`, opts.LogFormat())
  134. }
  135. }
  136. func TestLogFormatWithInvalidValue(t *testing.T) {
  137. os.Clearenv()
  138. os.Setenv("LOG_FORMAT", "invalid")
  139. parser := NewParser()
  140. opts, err := parser.ParseEnvironmentVariables()
  141. if err != nil {
  142. t.Fatalf(`Parsing failure: %v`, err)
  143. }
  144. if opts.LogFormat() != defaultLogFormat {
  145. t.Fatalf(`Unexpected log format value, got %q`, opts.LogFormat())
  146. }
  147. }
  148. func TestDebugModeOn(t *testing.T) {
  149. os.Clearenv()
  150. os.Setenv("DEBUG", "1")
  151. parser := NewParser()
  152. opts, err := parser.ParseEnvironmentVariables()
  153. if err != nil {
  154. t.Fatalf(`Parsing failure: %v`, err)
  155. }
  156. if opts.LogLevel() != "debug" {
  157. t.Fatalf(`Unexpected debug mode value, got %q`, opts.LogLevel())
  158. }
  159. }
  160. func TestDebugModeOff(t *testing.T) {
  161. os.Clearenv()
  162. parser := NewParser()
  163. opts, err := parser.ParseEnvironmentVariables()
  164. if err != nil {
  165. t.Fatalf(`Parsing failure: %v`, err)
  166. }
  167. if opts.LogLevel() != "info" {
  168. t.Fatalf(`Unexpected debug mode value, got %q`, opts.LogLevel())
  169. }
  170. }
  171. func TestCustomBaseURL(t *testing.T) {
  172. os.Clearenv()
  173. os.Setenv("BASE_URL", "http://example.org")
  174. parser := NewParser()
  175. opts, err := parser.ParseEnvironmentVariables()
  176. if err != nil {
  177. t.Fatalf(`Parsing failure: %v`, err)
  178. }
  179. if opts.BaseURL() != "http://example.org" {
  180. t.Fatalf(`Unexpected base URL, got "%s"`, opts.BaseURL())
  181. }
  182. if opts.RootURL() != "http://example.org" {
  183. t.Fatalf(`Unexpected root URL, got "%s"`, opts.RootURL())
  184. }
  185. if opts.BasePath() != "" {
  186. t.Fatalf(`Unexpected base path, got "%s"`, opts.BasePath())
  187. }
  188. }
  189. func TestCustomBaseURLWithTrailingSlash(t *testing.T) {
  190. os.Clearenv()
  191. os.Setenv("BASE_URL", "http://example.org/folder/")
  192. parser := NewParser()
  193. opts, err := parser.ParseEnvironmentVariables()
  194. if err != nil {
  195. t.Fatalf(`Parsing failure: %v`, err)
  196. }
  197. if opts.BaseURL() != "http://example.org/folder" {
  198. t.Fatalf(`Unexpected base URL, got "%s"`, opts.BaseURL())
  199. }
  200. if opts.RootURL() != "http://example.org" {
  201. t.Fatalf(`Unexpected root URL, got "%s"`, opts.RootURL())
  202. }
  203. if opts.BasePath() != "/folder" {
  204. t.Fatalf(`Unexpected base path, got "%s"`, opts.BasePath())
  205. }
  206. }
  207. func TestBaseURLWithoutScheme(t *testing.T) {
  208. os.Clearenv()
  209. os.Setenv("BASE_URL", "example.org/folder/")
  210. _, err := NewParser().ParseEnvironmentVariables()
  211. if err == nil {
  212. t.Fatalf(`Parsing must fail`)
  213. }
  214. }
  215. func TestBaseURLWithInvalidScheme(t *testing.T) {
  216. os.Clearenv()
  217. os.Setenv("BASE_URL", "ftp://example.org/folder/")
  218. _, err := NewParser().ParseEnvironmentVariables()
  219. if err == nil {
  220. t.Fatalf(`Parsing must fail`)
  221. }
  222. }
  223. func TestInvalidBaseURL(t *testing.T) {
  224. os.Clearenv()
  225. os.Setenv("BASE_URL", "http://example|org")
  226. _, err := NewParser().ParseEnvironmentVariables()
  227. if err == nil {
  228. t.Fatalf(`Parsing must fail`)
  229. }
  230. }
  231. func TestDefaultBaseURL(t *testing.T) {
  232. os.Clearenv()
  233. parser := NewParser()
  234. opts, err := parser.ParseEnvironmentVariables()
  235. if err != nil {
  236. t.Fatalf(`Parsing failure: %v`, err)
  237. }
  238. if opts.BaseURL() != defaultBaseURL {
  239. t.Fatalf(`Unexpected base URL, got "%s"`, opts.BaseURL())
  240. }
  241. if opts.RootURL() != defaultBaseURL {
  242. t.Fatalf(`Unexpected root URL, got "%s"`, opts.RootURL())
  243. }
  244. if opts.BasePath() != "" {
  245. t.Fatalf(`Unexpected base path, got "%s"`, opts.BasePath())
  246. }
  247. }
  248. func TestDatabaseURL(t *testing.T) {
  249. os.Clearenv()
  250. os.Setenv("DATABASE_URL", "foobar")
  251. parser := NewParser()
  252. opts, err := parser.ParseEnvironmentVariables()
  253. if err != nil {
  254. t.Fatalf(`Parsing failure: %v`, err)
  255. }
  256. expected := "foobar"
  257. result := opts.DatabaseURL()
  258. if result != expected {
  259. t.Errorf(`Unexpected DATABASE_URL value, got %q instead of %q`, result, expected)
  260. }
  261. if opts.IsDefaultDatabaseURL() {
  262. t.Errorf(`This is not the default database URL and it should returns false`)
  263. }
  264. }
  265. func TestDefaultDatabaseURLValue(t *testing.T) {
  266. os.Clearenv()
  267. parser := NewParser()
  268. opts, err := parser.ParseEnvironmentVariables()
  269. if err != nil {
  270. t.Fatalf(`Parsing failure: %v`, err)
  271. }
  272. expected := defaultDatabaseURL
  273. result := opts.DatabaseURL()
  274. if result != expected {
  275. t.Errorf(`Unexpected DATABASE_URL value, got %q instead of %q`, result, expected)
  276. }
  277. if !opts.IsDefaultDatabaseURL() {
  278. t.Errorf(`This is the default database URL and it should returns true`)
  279. }
  280. }
  281. func TestDefaultDatabaseMaxConnsValue(t *testing.T) {
  282. os.Clearenv()
  283. parser := NewParser()
  284. opts, err := parser.ParseEnvironmentVariables()
  285. if err != nil {
  286. t.Fatalf(`Parsing failure: %v`, err)
  287. }
  288. expected := defaultDatabaseMaxConns
  289. result := opts.DatabaseMaxConns()
  290. if result != expected {
  291. t.Fatalf(`Unexpected DATABASE_MAX_CONNS value, got %v instead of %v`, result, expected)
  292. }
  293. }
  294. func TestDatabaseMaxConns(t *testing.T) {
  295. os.Clearenv()
  296. os.Setenv("DATABASE_MAX_CONNS", "42")
  297. parser := NewParser()
  298. opts, err := parser.ParseEnvironmentVariables()
  299. if err != nil {
  300. t.Fatalf(`Parsing failure: %v`, err)
  301. }
  302. expected := 42
  303. result := opts.DatabaseMaxConns()
  304. if result != expected {
  305. t.Fatalf(`Unexpected DATABASE_MAX_CONNS value, got %v instead of %v`, result, expected)
  306. }
  307. }
  308. func TestDefaultDatabaseMinConnsValue(t *testing.T) {
  309. os.Clearenv()
  310. parser := NewParser()
  311. opts, err := parser.ParseEnvironmentVariables()
  312. if err != nil {
  313. t.Fatalf(`Parsing failure: %v`, err)
  314. }
  315. expected := defaultDatabaseMinConns
  316. result := opts.DatabaseMinConns()
  317. if result != expected {
  318. t.Fatalf(`Unexpected DATABASE_MIN_CONNS value, got %v instead of %v`, result, expected)
  319. }
  320. }
  321. func TestDatabaseMinConns(t *testing.T) {
  322. os.Clearenv()
  323. os.Setenv("DATABASE_MIN_CONNS", "42")
  324. parser := NewParser()
  325. opts, err := parser.ParseEnvironmentVariables()
  326. if err != nil {
  327. t.Fatalf(`Parsing failure: %v`, err)
  328. }
  329. expected := 42
  330. result := opts.DatabaseMinConns()
  331. if result != expected {
  332. t.Fatalf(`Unexpected DATABASE_MIN_CONNS value, got %v instead of %v`, result, expected)
  333. }
  334. }
  335. func TestListenAddr(t *testing.T) {
  336. os.Clearenv()
  337. os.Setenv("LISTEN_ADDR", "foobar")
  338. parser := NewParser()
  339. opts, err := parser.ParseEnvironmentVariables()
  340. if err != nil {
  341. t.Fatalf(`Parsing failure: %v`, err)
  342. }
  343. expected := "foobar"
  344. result := opts.ListenAddr()
  345. if result != expected {
  346. t.Fatalf(`Unexpected LISTEN_ADDR value, got %q instead of %q`, result, expected)
  347. }
  348. }
  349. func TestListenAddrWithPortDefined(t *testing.T) {
  350. os.Clearenv()
  351. os.Setenv("PORT", "3000")
  352. os.Setenv("LISTEN_ADDR", "foobar")
  353. parser := NewParser()
  354. opts, err := parser.ParseEnvironmentVariables()
  355. if err != nil {
  356. t.Fatalf(`Parsing failure: %v`, err)
  357. }
  358. expected := ":3000"
  359. result := opts.ListenAddr()
  360. if result != expected {
  361. t.Fatalf(`Unexpected LISTEN_ADDR value, got %q instead of %q`, result, expected)
  362. }
  363. }
  364. func TestDefaultListenAddrValue(t *testing.T) {
  365. os.Clearenv()
  366. parser := NewParser()
  367. opts, err := parser.ParseEnvironmentVariables()
  368. if err != nil {
  369. t.Fatalf(`Parsing failure: %v`, err)
  370. }
  371. expected := defaultListenAddr
  372. result := opts.ListenAddr()
  373. if result != expected {
  374. t.Fatalf(`Unexpected LISTEN_ADDR value, got %q instead of %q`, result, expected)
  375. }
  376. }
  377. func TestCertFile(t *testing.T) {
  378. os.Clearenv()
  379. os.Setenv("CERT_FILE", "foobar")
  380. parser := NewParser()
  381. opts, err := parser.ParseEnvironmentVariables()
  382. if err != nil {
  383. t.Fatalf(`Parsing failure: %v`, err)
  384. }
  385. expected := "foobar"
  386. result := opts.CertFile()
  387. if result != expected {
  388. t.Fatalf(`Unexpected CERT_FILE value, got %q instead of %q`, result, expected)
  389. }
  390. }
  391. func TestDefaultCertFileValue(t *testing.T) {
  392. os.Clearenv()
  393. parser := NewParser()
  394. opts, err := parser.ParseEnvironmentVariables()
  395. if err != nil {
  396. t.Fatalf(`Parsing failure: %v`, err)
  397. }
  398. expected := defaultCertFile
  399. result := opts.CertFile()
  400. if result != expected {
  401. t.Fatalf(`Unexpected CERT_FILE value, got %q instead of %q`, result, expected)
  402. }
  403. }
  404. func TestKeyFile(t *testing.T) {
  405. os.Clearenv()
  406. os.Setenv("KEY_FILE", "foobar")
  407. parser := NewParser()
  408. opts, err := parser.ParseEnvironmentVariables()
  409. if err != nil {
  410. t.Fatalf(`Parsing failure: %v`, err)
  411. }
  412. expected := "foobar"
  413. result := opts.CertKeyFile()
  414. if result != expected {
  415. t.Fatalf(`Unexpected KEY_FILE value, got %q instead of %q`, result, expected)
  416. }
  417. }
  418. func TestDefaultKeyFileValue(t *testing.T) {
  419. os.Clearenv()
  420. parser := NewParser()
  421. opts, err := parser.ParseEnvironmentVariables()
  422. if err != nil {
  423. t.Fatalf(`Parsing failure: %v`, err)
  424. }
  425. expected := defaultKeyFile
  426. result := opts.CertKeyFile()
  427. if result != expected {
  428. t.Fatalf(`Unexpected KEY_FILE value, got %q instead of %q`, result, expected)
  429. }
  430. }
  431. func TestCertDomain(t *testing.T) {
  432. os.Clearenv()
  433. os.Setenv("CERT_DOMAIN", "example.org")
  434. parser := NewParser()
  435. opts, err := parser.ParseEnvironmentVariables()
  436. if err != nil {
  437. t.Fatalf(`Parsing failure: %v`, err)
  438. }
  439. expected := "example.org"
  440. result := opts.CertDomain()
  441. if result != expected {
  442. t.Fatalf(`Unexpected CERT_DOMAIN value, got %q instead of %q`, result, expected)
  443. }
  444. }
  445. func TestDefaultCertDomainValue(t *testing.T) {
  446. os.Clearenv()
  447. parser := NewParser()
  448. opts, err := parser.ParseEnvironmentVariables()
  449. if err != nil {
  450. t.Fatalf(`Parsing failure: %v`, err)
  451. }
  452. expected := defaultCertDomain
  453. result := opts.CertDomain()
  454. if result != expected {
  455. t.Fatalf(`Unexpected CERT_DOMAIN value, got %q instead of %q`, result, expected)
  456. }
  457. }
  458. func TestDefaultCleanupFrequencyHoursValue(t *testing.T) {
  459. os.Clearenv()
  460. parser := NewParser()
  461. opts, err := parser.ParseEnvironmentVariables()
  462. if err != nil {
  463. t.Fatalf(`Parsing failure: %v`, err)
  464. }
  465. expected := defaultCleanupFrequencyHours
  466. result := opts.CleanupFrequencyHours()
  467. if result != expected {
  468. t.Fatalf(`Unexpected CLEANUP_FREQUENCY_HOURS value, got %v instead of %v`, result, expected)
  469. }
  470. }
  471. func TestCleanupFrequencyHours(t *testing.T) {
  472. os.Clearenv()
  473. os.Setenv("CLEANUP_FREQUENCY_HOURS", "42")
  474. os.Setenv("CLEANUP_FREQUENCY", "19")
  475. parser := NewParser()
  476. opts, err := parser.ParseEnvironmentVariables()
  477. if err != nil {
  478. t.Fatalf(`Parsing failure: %v`, err)
  479. }
  480. expected := 42
  481. result := opts.CleanupFrequencyHours()
  482. if result != expected {
  483. t.Fatalf(`Unexpected CLEANUP_FREQUENCY_HOURS value, got %v instead of %v`, result, expected)
  484. }
  485. }
  486. func TestDefaultCleanupArchiveReadDaysValue(t *testing.T) {
  487. os.Clearenv()
  488. parser := NewParser()
  489. opts, err := parser.ParseEnvironmentVariables()
  490. if err != nil {
  491. t.Fatalf(`Parsing failure: %v`, err)
  492. }
  493. expected := 60
  494. result := opts.CleanupArchiveReadDays()
  495. if result != expected {
  496. t.Fatalf(`Unexpected CLEANUP_ARCHIVE_READ_DAYS value, got %v instead of %v`, result, expected)
  497. }
  498. }
  499. func TestCleanupArchiveReadDays(t *testing.T) {
  500. os.Clearenv()
  501. os.Setenv("CLEANUP_ARCHIVE_READ_DAYS", "7")
  502. os.Setenv("ARCHIVE_READ_DAYS", "19")
  503. parser := NewParser()
  504. opts, err := parser.ParseEnvironmentVariables()
  505. if err != nil {
  506. t.Fatalf(`Parsing failure: %v`, err)
  507. }
  508. expected := 7
  509. result := opts.CleanupArchiveReadDays()
  510. if result != expected {
  511. t.Fatalf(`Unexpected CLEANUP_ARCHIVE_READ_DAYS value, got %v instead of %v`, result, expected)
  512. }
  513. }
  514. func TestDefaultCleanupRemoveSessionsDaysValue(t *testing.T) {
  515. os.Clearenv()
  516. parser := NewParser()
  517. opts, err := parser.ParseEnvironmentVariables()
  518. if err != nil {
  519. t.Fatalf(`Parsing failure: %v`, err)
  520. }
  521. expected := 30
  522. result := opts.CleanupRemoveSessionsDays()
  523. if result != expected {
  524. t.Fatalf(`Unexpected CLEANUP_REMOVE_SESSIONS_DAYS value, got %v instead of %v`, result, expected)
  525. }
  526. }
  527. func TestCleanupRemoveSessionsDays(t *testing.T) {
  528. os.Clearenv()
  529. os.Setenv("CLEANUP_REMOVE_SESSIONS_DAYS", "7")
  530. parser := NewParser()
  531. opts, err := parser.ParseEnvironmentVariables()
  532. if err != nil {
  533. t.Fatalf(`Parsing failure: %v`, err)
  534. }
  535. expected := 7
  536. result := opts.CleanupRemoveSessionsDays()
  537. if result != expected {
  538. t.Fatalf(`Unexpected CLEANUP_REMOVE_SESSIONS_DAYS value, got %v instead of %v`, result, expected)
  539. }
  540. }
  541. func TestDefaultWorkerPoolSizeValue(t *testing.T) {
  542. os.Clearenv()
  543. parser := NewParser()
  544. opts, err := parser.ParseEnvironmentVariables()
  545. if err != nil {
  546. t.Fatalf(`Parsing failure: %v`, err)
  547. }
  548. expected := defaultWorkerPoolSize
  549. result := opts.WorkerPoolSize()
  550. if result != expected {
  551. t.Fatalf(`Unexpected WORKER_POOL_SIZE value, got %v instead of %v`, result, expected)
  552. }
  553. }
  554. func TestWorkerPoolSize(t *testing.T) {
  555. os.Clearenv()
  556. os.Setenv("WORKER_POOL_SIZE", "42")
  557. parser := NewParser()
  558. opts, err := parser.ParseEnvironmentVariables()
  559. if err != nil {
  560. t.Fatalf(`Parsing failure: %v`, err)
  561. }
  562. expected := 42
  563. result := opts.WorkerPoolSize()
  564. if result != expected {
  565. t.Fatalf(`Unexpected WORKER_POOL_SIZE value, got %v instead of %v`, result, expected)
  566. }
  567. }
  568. func TestDefautPollingFrequencyValue(t *testing.T) {
  569. os.Clearenv()
  570. parser := NewParser()
  571. opts, err := parser.ParseEnvironmentVariables()
  572. if err != nil {
  573. t.Fatalf(`Parsing failure: %v`, err)
  574. }
  575. expected := defaultPollingFrequency
  576. result := opts.PollingFrequency()
  577. if result != expected {
  578. t.Fatalf(`Unexpected POLLING_FREQUENCY value, got %v instead of %v`, result, expected)
  579. }
  580. }
  581. func TestPollingFrequency(t *testing.T) {
  582. os.Clearenv()
  583. os.Setenv("POLLING_FREQUENCY", "42")
  584. parser := NewParser()
  585. opts, err := parser.ParseEnvironmentVariables()
  586. if err != nil {
  587. t.Fatalf(`Parsing failure: %v`, err)
  588. }
  589. expected := 42
  590. result := opts.PollingFrequency()
  591. if result != expected {
  592. t.Fatalf(`Unexpected POLLING_FREQUENCY value, got %v instead of %v`, result, expected)
  593. }
  594. }
  595. func TestDefaultBatchSizeValue(t *testing.T) {
  596. os.Clearenv()
  597. parser := NewParser()
  598. opts, err := parser.ParseEnvironmentVariables()
  599. if err != nil {
  600. t.Fatalf(`Parsing failure: %v`, err)
  601. }
  602. expected := defaultBatchSize
  603. result := opts.BatchSize()
  604. if result != expected {
  605. t.Fatalf(`Unexpected BATCH_SIZE value, got %v instead of %v`, result, expected)
  606. }
  607. }
  608. func TestBatchSize(t *testing.T) {
  609. os.Clearenv()
  610. os.Setenv("BATCH_SIZE", "42")
  611. parser := NewParser()
  612. opts, err := parser.ParseEnvironmentVariables()
  613. if err != nil {
  614. t.Fatalf(`Parsing failure: %v`, err)
  615. }
  616. expected := 42
  617. result := opts.BatchSize()
  618. if result != expected {
  619. t.Fatalf(`Unexpected BATCH_SIZE value, got %v instead of %v`, result, expected)
  620. }
  621. }
  622. func TestDefautPollingSchedulerValue(t *testing.T) {
  623. os.Clearenv()
  624. parser := NewParser()
  625. opts, err := parser.ParseEnvironmentVariables()
  626. if err != nil {
  627. t.Fatalf(`Parsing failure: %v`, err)
  628. }
  629. expected := defaultPollingScheduler
  630. result := opts.PollingScheduler()
  631. if result != expected {
  632. t.Fatalf(`Unexpected POLLING_SCHEDULER value, got %v instead of %v`, result, expected)
  633. }
  634. }
  635. func TestPollingScheduler(t *testing.T) {
  636. os.Clearenv()
  637. os.Setenv("POLLING_SCHEDULER", "entry_count_based")
  638. parser := NewParser()
  639. opts, err := parser.ParseEnvironmentVariables()
  640. if err != nil {
  641. t.Fatalf(`Parsing failure: %v`, err)
  642. }
  643. expected := "entry_count_based"
  644. result := opts.PollingScheduler()
  645. if result != expected {
  646. t.Fatalf(`Unexpected POLLING_SCHEDULER value, got %v instead of %v`, result, expected)
  647. }
  648. }
  649. func TestDefautSchedulerEntryFrequencyMaxIntervalValue(t *testing.T) {
  650. os.Clearenv()
  651. parser := NewParser()
  652. opts, err := parser.ParseEnvironmentVariables()
  653. if err != nil {
  654. t.Fatalf(`Parsing failure: %v`, err)
  655. }
  656. expected := defaultSchedulerEntryFrequencyMaxInterval
  657. result := opts.SchedulerEntryFrequencyMaxInterval()
  658. if result != expected {
  659. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL value, got %v instead of %v`, result, expected)
  660. }
  661. }
  662. func TestSchedulerEntryFrequencyMaxInterval(t *testing.T) {
  663. os.Clearenv()
  664. os.Setenv("SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL", "30")
  665. parser := NewParser()
  666. opts, err := parser.ParseEnvironmentVariables()
  667. if err != nil {
  668. t.Fatalf(`Parsing failure: %v`, err)
  669. }
  670. expected := 30
  671. result := opts.SchedulerEntryFrequencyMaxInterval()
  672. if result != expected {
  673. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL value, got %v instead of %v`, result, expected)
  674. }
  675. }
  676. func TestDefautSchedulerEntryFrequencyMinIntervalValue(t *testing.T) {
  677. os.Clearenv()
  678. parser := NewParser()
  679. opts, err := parser.ParseEnvironmentVariables()
  680. if err != nil {
  681. t.Fatalf(`Parsing failure: %v`, err)
  682. }
  683. expected := defaultSchedulerEntryFrequencyMinInterval
  684. result := opts.SchedulerEntryFrequencyMinInterval()
  685. if result != expected {
  686. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  687. }
  688. }
  689. func TestSchedulerEntryFrequencyMinInterval(t *testing.T) {
  690. os.Clearenv()
  691. os.Setenv("SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL", "30")
  692. parser := NewParser()
  693. opts, err := parser.ParseEnvironmentVariables()
  694. if err != nil {
  695. t.Fatalf(`Parsing failure: %v`, err)
  696. }
  697. expected := 30
  698. result := opts.SchedulerEntryFrequencyMinInterval()
  699. if result != expected {
  700. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  701. }
  702. }
  703. func TestDefautSchedulerEntryFrequencyFactorValue(t *testing.T) {
  704. os.Clearenv()
  705. parser := NewParser()
  706. opts, err := parser.ParseEnvironmentVariables()
  707. if err != nil {
  708. t.Fatalf(`Parsing failure: %v`, err)
  709. }
  710. expected := defaultSchedulerEntryFrequencyFactor
  711. result := opts.SchedulerEntryFrequencyFactor()
  712. if result != expected {
  713. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_FACTOR value, got %v instead of %v`, result, expected)
  714. }
  715. }
  716. func TestSchedulerEntryFrequencyFactor(t *testing.T) {
  717. os.Clearenv()
  718. os.Setenv("SCHEDULER_ENTRY_FREQUENCY_FACTOR", "2")
  719. parser := NewParser()
  720. opts, err := parser.ParseEnvironmentVariables()
  721. if err != nil {
  722. t.Fatalf(`Parsing failure: %v`, err)
  723. }
  724. expected := 2
  725. result := opts.SchedulerEntryFrequencyFactor()
  726. if result != expected {
  727. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_FACTOR value, got %v instead of %v`, result, expected)
  728. }
  729. }
  730. func TestDefaultSchedulerRoundRobinValue(t *testing.T) {
  731. os.Clearenv()
  732. parser := NewParser()
  733. opts, err := parser.ParseEnvironmentVariables()
  734. if err != nil {
  735. t.Fatalf(`Parsing failure: %v`, err)
  736. }
  737. expected := defaultSchedulerRoundRobinMinInterval
  738. result := opts.SchedulerRoundRobinMinInterval()
  739. if result != expected {
  740. t.Fatalf(`Unexpected SCHEDULER_ROUND_ROBIN_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  741. }
  742. }
  743. func TestSchedulerRoundRobin(t *testing.T) {
  744. os.Clearenv()
  745. os.Setenv("SCHEDULER_ROUND_ROBIN_MIN_INTERVAL", "15")
  746. parser := NewParser()
  747. opts, err := parser.ParseEnvironmentVariables()
  748. if err != nil {
  749. t.Fatalf(`Parsing failure: %v`, err)
  750. }
  751. expected := 15
  752. result := opts.SchedulerRoundRobinMinInterval()
  753. if result != expected {
  754. t.Fatalf(`Unexpected SCHEDULER_ROUND_ROBIN_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  755. }
  756. }
  757. func TestPollingParsingErrorLimit(t *testing.T) {
  758. os.Clearenv()
  759. os.Setenv("POLLING_PARSING_ERROR_LIMIT", "100")
  760. parser := NewParser()
  761. opts, err := parser.ParseEnvironmentVariables()
  762. if err != nil {
  763. t.Fatalf(`Parsing failure: %v`, err)
  764. }
  765. expected := 100
  766. result := opts.PollingParsingErrorLimit()
  767. if result != expected {
  768. t.Fatalf(`Unexpected POLLING_SCHEDULER value, got %v instead of %v`, result, expected)
  769. }
  770. }
  771. func TestOAuth2UserCreationWhenUnset(t *testing.T) {
  772. os.Clearenv()
  773. parser := NewParser()
  774. opts, err := parser.ParseEnvironmentVariables()
  775. if err != nil {
  776. t.Fatalf(`Parsing failure: %v`, err)
  777. }
  778. expected := false
  779. result := opts.IsOAuth2UserCreationAllowed()
  780. if result != expected {
  781. t.Fatalf(`Unexpected OAUTH2_USER_CREATION value, got %v instead of %v`, result, expected)
  782. }
  783. }
  784. func TestOAuth2UserCreationAdmin(t *testing.T) {
  785. os.Clearenv()
  786. os.Setenv("OAUTH2_USER_CREATION", "1")
  787. parser := NewParser()
  788. opts, err := parser.ParseEnvironmentVariables()
  789. if err != nil {
  790. t.Fatalf(`Parsing failure: %v`, err)
  791. }
  792. expected := true
  793. result := opts.IsOAuth2UserCreationAllowed()
  794. if result != expected {
  795. t.Fatalf(`Unexpected OAUTH2_USER_CREATION value, got %v instead of %v`, result, expected)
  796. }
  797. }
  798. func TestOAuth2ClientID(t *testing.T) {
  799. os.Clearenv()
  800. os.Setenv("OAUTH2_CLIENT_ID", "foobar")
  801. parser := NewParser()
  802. opts, err := parser.ParseEnvironmentVariables()
  803. if err != nil {
  804. t.Fatalf(`Parsing failure: %v`, err)
  805. }
  806. expected := "foobar"
  807. result := opts.OAuth2ClientID()
  808. if result != expected {
  809. t.Fatalf(`Unexpected OAUTH2_CLIENT_ID value, got %q instead of %q`, result, expected)
  810. }
  811. }
  812. func TestDefaultOAuth2ClientIDValue(t *testing.T) {
  813. os.Clearenv()
  814. parser := NewParser()
  815. opts, err := parser.ParseEnvironmentVariables()
  816. if err != nil {
  817. t.Fatalf(`Parsing failure: %v`, err)
  818. }
  819. expected := defaultOAuth2ClientID
  820. result := opts.OAuth2ClientID()
  821. if result != expected {
  822. t.Fatalf(`Unexpected OAUTH2_CLIENT_ID value, got %q instead of %q`, result, expected)
  823. }
  824. }
  825. func TestOAuth2ClientSecret(t *testing.T) {
  826. os.Clearenv()
  827. os.Setenv("OAUTH2_CLIENT_SECRET", "secret")
  828. parser := NewParser()
  829. opts, err := parser.ParseEnvironmentVariables()
  830. if err != nil {
  831. t.Fatalf(`Parsing failure: %v`, err)
  832. }
  833. expected := "secret"
  834. result := opts.OAuth2ClientSecret()
  835. if result != expected {
  836. t.Fatalf(`Unexpected OAUTH2_CLIENT_SECRET value, got %q instead of %q`, result, expected)
  837. }
  838. }
  839. func TestDefaultOAuth2ClientSecretValue(t *testing.T) {
  840. os.Clearenv()
  841. parser := NewParser()
  842. opts, err := parser.ParseEnvironmentVariables()
  843. if err != nil {
  844. t.Fatalf(`Parsing failure: %v`, err)
  845. }
  846. expected := defaultOAuth2ClientSecret
  847. result := opts.OAuth2ClientSecret()
  848. if result != expected {
  849. t.Fatalf(`Unexpected OAUTH2_CLIENT_SECRET value, got %q instead of %q`, result, expected)
  850. }
  851. }
  852. func TestOAuth2RedirectURL(t *testing.T) {
  853. os.Clearenv()
  854. os.Setenv("OAUTH2_REDIRECT_URL", "http://example.org")
  855. parser := NewParser()
  856. opts, err := parser.ParseEnvironmentVariables()
  857. if err != nil {
  858. t.Fatalf(`Parsing failure: %v`, err)
  859. }
  860. expected := "http://example.org"
  861. result := opts.OAuth2RedirectURL()
  862. if result != expected {
  863. t.Fatalf(`Unexpected OAUTH2_REDIRECT_URL value, got %q instead of %q`, result, expected)
  864. }
  865. }
  866. func TestDefaultOAuth2RedirectURLValue(t *testing.T) {
  867. os.Clearenv()
  868. parser := NewParser()
  869. opts, err := parser.ParseEnvironmentVariables()
  870. if err != nil {
  871. t.Fatalf(`Parsing failure: %v`, err)
  872. }
  873. expected := defaultOAuth2RedirectURL
  874. result := opts.OAuth2RedirectURL()
  875. if result != expected {
  876. t.Fatalf(`Unexpected OAUTH2_REDIRECT_URL value, got %q instead of %q`, result, expected)
  877. }
  878. }
  879. func TestOAuth2OIDCDiscoveryEndpoint(t *testing.T) {
  880. os.Clearenv()
  881. os.Setenv("OAUTH2_OIDC_DISCOVERY_ENDPOINT", "http://example.org")
  882. parser := NewParser()
  883. opts, err := parser.ParseEnvironmentVariables()
  884. if err != nil {
  885. t.Fatalf(`Parsing failure: %v`, err)
  886. }
  887. expected := "http://example.org"
  888. result := opts.OIDCDiscoveryEndpoint()
  889. if result != expected {
  890. t.Fatalf(`Unexpected OAUTH2_OIDC_DISCOVERY_ENDPOINT value, got %q instead of %q`, result, expected)
  891. }
  892. }
  893. func TestDefaultOIDCDiscoveryEndpointValue(t *testing.T) {
  894. os.Clearenv()
  895. parser := NewParser()
  896. opts, err := parser.ParseEnvironmentVariables()
  897. if err != nil {
  898. t.Fatalf(`Parsing failure: %v`, err)
  899. }
  900. expected := defaultOAuth2OidcDiscoveryEndpoint
  901. result := opts.OIDCDiscoveryEndpoint()
  902. if result != expected {
  903. t.Fatalf(`Unexpected OAUTH2_OIDC_DISCOVERY_ENDPOINT value, got %q instead of %q`, result, expected)
  904. }
  905. }
  906. func TestOAuth2Provider(t *testing.T) {
  907. os.Clearenv()
  908. os.Setenv("OAUTH2_PROVIDER", "google")
  909. parser := NewParser()
  910. opts, err := parser.ParseEnvironmentVariables()
  911. if err != nil {
  912. t.Fatalf(`Parsing failure: %v`, err)
  913. }
  914. expected := "google"
  915. result := opts.OAuth2Provider()
  916. if result != expected {
  917. t.Fatalf(`Unexpected OAUTH2_PROVIDER value, got %q instead of %q`, result, expected)
  918. }
  919. }
  920. func TestDefaultOAuth2ProviderValue(t *testing.T) {
  921. os.Clearenv()
  922. parser := NewParser()
  923. opts, err := parser.ParseEnvironmentVariables()
  924. if err != nil {
  925. t.Fatalf(`Parsing failure: %v`, err)
  926. }
  927. expected := defaultOAuth2Provider
  928. result := opts.OAuth2Provider()
  929. if result != expected {
  930. t.Fatalf(`Unexpected OAUTH2_PROVIDER value, got %q instead of %q`, result, expected)
  931. }
  932. }
  933. func TestHSTSWhenUnset(t *testing.T) {
  934. os.Clearenv()
  935. parser := NewParser()
  936. opts, err := parser.ParseEnvironmentVariables()
  937. if err != nil {
  938. t.Fatalf(`Parsing failure: %v`, err)
  939. }
  940. expected := true
  941. result := opts.HasHSTS()
  942. if result != expected {
  943. t.Fatalf(`Unexpected DISABLE_HSTS value, got %v instead of %v`, result, expected)
  944. }
  945. }
  946. func TestHSTS(t *testing.T) {
  947. os.Clearenv()
  948. os.Setenv("DISABLE_HSTS", "1")
  949. parser := NewParser()
  950. opts, err := parser.ParseEnvironmentVariables()
  951. if err != nil {
  952. t.Fatalf(`Parsing failure: %v`, err)
  953. }
  954. expected := false
  955. result := opts.HasHSTS()
  956. if result != expected {
  957. t.Fatalf(`Unexpected DISABLE_HSTS value, got %v instead of %v`, result, expected)
  958. }
  959. }
  960. func TestDisableHTTPServiceWhenUnset(t *testing.T) {
  961. os.Clearenv()
  962. parser := NewParser()
  963. opts, err := parser.ParseEnvironmentVariables()
  964. if err != nil {
  965. t.Fatalf(`Parsing failure: %v`, err)
  966. }
  967. expected := true
  968. result := opts.HasHTTPService()
  969. if result != expected {
  970. t.Fatalf(`Unexpected DISABLE_HTTP_SERVICE value, got %v instead of %v`, result, expected)
  971. }
  972. }
  973. func TestDisableHTTPService(t *testing.T) {
  974. os.Clearenv()
  975. os.Setenv("DISABLE_HTTP_SERVICE", "1")
  976. parser := NewParser()
  977. opts, err := parser.ParseEnvironmentVariables()
  978. if err != nil {
  979. t.Fatalf(`Parsing failure: %v`, err)
  980. }
  981. expected := false
  982. result := opts.HasHTTPService()
  983. if result != expected {
  984. t.Fatalf(`Unexpected DISABLE_HTTP_SERVICE value, got %v instead of %v`, result, expected)
  985. }
  986. }
  987. func TestDisableSchedulerServiceWhenUnset(t *testing.T) {
  988. os.Clearenv()
  989. parser := NewParser()
  990. opts, err := parser.ParseEnvironmentVariables()
  991. if err != nil {
  992. t.Fatalf(`Parsing failure: %v`, err)
  993. }
  994. expected := true
  995. result := opts.HasSchedulerService()
  996. if result != expected {
  997. t.Fatalf(`Unexpected DISABLE_SCHEDULER_SERVICE value, got %v instead of %v`, result, expected)
  998. }
  999. }
  1000. func TestDisableSchedulerService(t *testing.T) {
  1001. os.Clearenv()
  1002. os.Setenv("DISABLE_SCHEDULER_SERVICE", "1")
  1003. parser := NewParser()
  1004. opts, err := parser.ParseEnvironmentVariables()
  1005. if err != nil {
  1006. t.Fatalf(`Parsing failure: %v`, err)
  1007. }
  1008. expected := false
  1009. result := opts.HasSchedulerService()
  1010. if result != expected {
  1011. t.Fatalf(`Unexpected DISABLE_SCHEDULER_SERVICE value, got %v instead of %v`, result, expected)
  1012. }
  1013. }
  1014. func TestRunMigrationsWhenUnset(t *testing.T) {
  1015. os.Clearenv()
  1016. parser := NewParser()
  1017. opts, err := parser.ParseEnvironmentVariables()
  1018. if err != nil {
  1019. t.Fatalf(`Parsing failure: %v`, err)
  1020. }
  1021. expected := false
  1022. result := opts.RunMigrations()
  1023. if result != expected {
  1024. t.Fatalf(`Unexpected RUN_MIGRATIONS value, got %v instead of %v`, result, expected)
  1025. }
  1026. }
  1027. func TestRunMigrations(t *testing.T) {
  1028. os.Clearenv()
  1029. os.Setenv("RUN_MIGRATIONS", "yes")
  1030. parser := NewParser()
  1031. opts, err := parser.ParseEnvironmentVariables()
  1032. if err != nil {
  1033. t.Fatalf(`Parsing failure: %v`, err)
  1034. }
  1035. expected := true
  1036. result := opts.RunMigrations()
  1037. if result != expected {
  1038. t.Fatalf(`Unexpected RUN_MIGRATIONS value, got %v instead of %v`, result, expected)
  1039. }
  1040. }
  1041. func TestCreateAdminWhenUnset(t *testing.T) {
  1042. os.Clearenv()
  1043. parser := NewParser()
  1044. opts, err := parser.ParseEnvironmentVariables()
  1045. if err != nil {
  1046. t.Fatalf(`Parsing failure: %v`, err)
  1047. }
  1048. expected := false
  1049. result := opts.CreateAdmin()
  1050. if result != expected {
  1051. t.Fatalf(`Unexpected CREATE_ADMIN value, got %v instead of %v`, result, expected)
  1052. }
  1053. }
  1054. func TestCreateAdmin(t *testing.T) {
  1055. os.Clearenv()
  1056. os.Setenv("CREATE_ADMIN", "true")
  1057. parser := NewParser()
  1058. opts, err := parser.ParseEnvironmentVariables()
  1059. if err != nil {
  1060. t.Fatalf(`Parsing failure: %v`, err)
  1061. }
  1062. expected := true
  1063. result := opts.CreateAdmin()
  1064. if result != expected {
  1065. t.Fatalf(`Unexpected CREATE_ADMIN value, got %v instead of %v`, result, expected)
  1066. }
  1067. }
  1068. func TestPocketConsumerKeyFromEnvVariable(t *testing.T) {
  1069. os.Clearenv()
  1070. os.Setenv("POCKET_CONSUMER_KEY", "something")
  1071. parser := NewParser()
  1072. opts, err := parser.ParseEnvironmentVariables()
  1073. if err != nil {
  1074. t.Fatalf(`Parsing failure: %v`, err)
  1075. }
  1076. expected := "something"
  1077. result := opts.PocketConsumerKey("default")
  1078. if result != expected {
  1079. t.Fatalf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1080. }
  1081. }
  1082. func TestPocketConsumerKeyFromUserPrefs(t *testing.T) {
  1083. os.Clearenv()
  1084. parser := NewParser()
  1085. opts, err := parser.ParseEnvironmentVariables()
  1086. if err != nil {
  1087. t.Fatalf(`Parsing failure: %v`, err)
  1088. }
  1089. expected := "default"
  1090. result := opts.PocketConsumerKey("default")
  1091. if result != expected {
  1092. t.Fatalf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1093. }
  1094. }
  1095. func TestProxyOption(t *testing.T) {
  1096. os.Clearenv()
  1097. os.Setenv("PROXY_OPTION", "all")
  1098. parser := NewParser()
  1099. opts, err := parser.ParseEnvironmentVariables()
  1100. if err != nil {
  1101. t.Fatalf(`Parsing failure: %v`, err)
  1102. }
  1103. expected := "all"
  1104. result := opts.ProxyOption()
  1105. if result != expected {
  1106. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expected)
  1107. }
  1108. }
  1109. func TestDefaultProxyOptionValue(t *testing.T) {
  1110. os.Clearenv()
  1111. parser := NewParser()
  1112. opts, err := parser.ParseEnvironmentVariables()
  1113. if err != nil {
  1114. t.Fatalf(`Parsing failure: %v`, err)
  1115. }
  1116. expected := defaultProxyOption
  1117. result := opts.ProxyOption()
  1118. if result != expected {
  1119. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expected)
  1120. }
  1121. }
  1122. func TestProxyMediaTypes(t *testing.T) {
  1123. os.Clearenv()
  1124. os.Setenv("PROXY_MEDIA_TYPES", "image,audio")
  1125. parser := NewParser()
  1126. opts, err := parser.ParseEnvironmentVariables()
  1127. if err != nil {
  1128. t.Fatalf(`Parsing failure: %v`, err)
  1129. }
  1130. expected := []string{"audio", "image"}
  1131. if len(expected) != len(opts.ProxyMediaTypes()) {
  1132. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1133. }
  1134. resultMap := make(map[string]bool)
  1135. for _, mediaType := range opts.ProxyMediaTypes() {
  1136. resultMap[mediaType] = true
  1137. }
  1138. for _, mediaType := range expected {
  1139. if !resultMap[mediaType] {
  1140. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1141. }
  1142. }
  1143. }
  1144. func TestProxyMediaTypesWithDuplicatedValues(t *testing.T) {
  1145. os.Clearenv()
  1146. os.Setenv("PROXY_MEDIA_TYPES", "image,audio, image")
  1147. parser := NewParser()
  1148. opts, err := parser.ParseEnvironmentVariables()
  1149. if err != nil {
  1150. t.Fatalf(`Parsing failure: %v`, err)
  1151. }
  1152. expected := []string{"audio", "image"}
  1153. if len(expected) != len(opts.ProxyMediaTypes()) {
  1154. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1155. }
  1156. resultMap := make(map[string]bool)
  1157. for _, mediaType := range opts.ProxyMediaTypes() {
  1158. resultMap[mediaType] = true
  1159. }
  1160. for _, mediaType := range expected {
  1161. if !resultMap[mediaType] {
  1162. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1163. }
  1164. }
  1165. }
  1166. func TestProxyImagesOptionBackwardCompatibility(t *testing.T) {
  1167. os.Clearenv()
  1168. os.Setenv("PROXY_IMAGES", "all")
  1169. parser := NewParser()
  1170. opts, err := parser.ParseEnvironmentVariables()
  1171. if err != nil {
  1172. t.Fatalf(`Parsing failure: %v`, err)
  1173. }
  1174. expected := []string{"image"}
  1175. if len(expected) != len(opts.ProxyMediaTypes()) {
  1176. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1177. }
  1178. resultMap := make(map[string]bool)
  1179. for _, mediaType := range opts.ProxyMediaTypes() {
  1180. resultMap[mediaType] = true
  1181. }
  1182. for _, mediaType := range expected {
  1183. if !resultMap[mediaType] {
  1184. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1185. }
  1186. }
  1187. expectedProxyOption := "all"
  1188. result := opts.ProxyOption()
  1189. if result != expectedProxyOption {
  1190. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expectedProxyOption)
  1191. }
  1192. }
  1193. func TestDefaultProxyMediaTypes(t *testing.T) {
  1194. os.Clearenv()
  1195. parser := NewParser()
  1196. opts, err := parser.ParseEnvironmentVariables()
  1197. if err != nil {
  1198. t.Fatalf(`Parsing failure: %v`, err)
  1199. }
  1200. expected := []string{"image"}
  1201. if len(expected) != len(opts.ProxyMediaTypes()) {
  1202. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1203. }
  1204. resultMap := make(map[string]bool)
  1205. for _, mediaType := range opts.ProxyMediaTypes() {
  1206. resultMap[mediaType] = true
  1207. }
  1208. for _, mediaType := range expected {
  1209. if !resultMap[mediaType] {
  1210. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1211. }
  1212. }
  1213. }
  1214. func TestProxyHTTPClientTimeout(t *testing.T) {
  1215. os.Clearenv()
  1216. os.Setenv("PROXY_HTTP_CLIENT_TIMEOUT", "24")
  1217. parser := NewParser()
  1218. opts, err := parser.ParseEnvironmentVariables()
  1219. if err != nil {
  1220. t.Fatalf(`Parsing failure: %v`, err)
  1221. }
  1222. expected := 24
  1223. result := opts.ProxyHTTPClientTimeout()
  1224. if result != expected {
  1225. t.Fatalf(`Unexpected PROXY_HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1226. }
  1227. }
  1228. func TestDefaultProxyHTTPClientTimeoutValue(t *testing.T) {
  1229. os.Clearenv()
  1230. parser := NewParser()
  1231. opts, err := parser.ParseEnvironmentVariables()
  1232. if err != nil {
  1233. t.Fatalf(`Parsing failure: %v`, err)
  1234. }
  1235. expected := defaultProxyHTTPClientTimeout
  1236. result := opts.ProxyHTTPClientTimeout()
  1237. if result != expected {
  1238. t.Fatalf(`Unexpected PROXY_HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1239. }
  1240. }
  1241. func TestHTTPSOff(t *testing.T) {
  1242. os.Clearenv()
  1243. parser := NewParser()
  1244. opts, err := parser.ParseEnvironmentVariables()
  1245. if err != nil {
  1246. t.Fatalf(`Parsing failure: %v`, err)
  1247. }
  1248. if opts.HTTPS {
  1249. t.Fatalf(`Unexpected HTTPS value, got "%v"`, opts.HTTPS)
  1250. }
  1251. }
  1252. func TestHTTPSOn(t *testing.T) {
  1253. os.Clearenv()
  1254. os.Setenv("HTTPS", "on")
  1255. parser := NewParser()
  1256. opts, err := parser.ParseEnvironmentVariables()
  1257. if err != nil {
  1258. t.Fatalf(`Parsing failure: %v`, err)
  1259. }
  1260. if !opts.HTTPS {
  1261. t.Fatalf(`Unexpected HTTPS value, got "%v"`, opts.HTTPS)
  1262. }
  1263. }
  1264. func TestHTTPClientTimeout(t *testing.T) {
  1265. os.Clearenv()
  1266. os.Setenv("HTTP_CLIENT_TIMEOUT", "42")
  1267. parser := NewParser()
  1268. opts, err := parser.ParseEnvironmentVariables()
  1269. if err != nil {
  1270. t.Fatalf(`Parsing failure: %v`, err)
  1271. }
  1272. expected := 42
  1273. result := opts.HTTPClientTimeout()
  1274. if result != expected {
  1275. t.Fatalf(`Unexpected HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1276. }
  1277. }
  1278. func TestDefaultHTTPClientTimeoutValue(t *testing.T) {
  1279. os.Clearenv()
  1280. parser := NewParser()
  1281. opts, err := parser.ParseEnvironmentVariables()
  1282. if err != nil {
  1283. t.Fatalf(`Parsing failure: %v`, err)
  1284. }
  1285. expected := defaultHTTPClientTimeout
  1286. result := opts.HTTPClientTimeout()
  1287. if result != expected {
  1288. t.Fatalf(`Unexpected HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1289. }
  1290. }
  1291. func TestHTTPClientMaxBodySize(t *testing.T) {
  1292. os.Clearenv()
  1293. os.Setenv("HTTP_CLIENT_MAX_BODY_SIZE", "42")
  1294. parser := NewParser()
  1295. opts, err := parser.ParseEnvironmentVariables()
  1296. if err != nil {
  1297. t.Fatalf(`Parsing failure: %v`, err)
  1298. }
  1299. expected := int64(42 * 1024 * 1024)
  1300. result := opts.HTTPClientMaxBodySize()
  1301. if result != expected {
  1302. t.Fatalf(`Unexpected HTTP_CLIENT_MAX_BODY_SIZE value, got %d instead of %d`, result, expected)
  1303. }
  1304. }
  1305. func TestDefaultHTTPClientMaxBodySizeValue(t *testing.T) {
  1306. os.Clearenv()
  1307. parser := NewParser()
  1308. opts, err := parser.ParseEnvironmentVariables()
  1309. if err != nil {
  1310. t.Fatalf(`Parsing failure: %v`, err)
  1311. }
  1312. expected := int64(defaultHTTPClientMaxBodySize * 1024 * 1024)
  1313. result := opts.HTTPClientMaxBodySize()
  1314. if result != expected {
  1315. t.Fatalf(`Unexpected HTTP_CLIENT_MAX_BODY_SIZE value, got %d instead of %d`, result, expected)
  1316. }
  1317. }
  1318. func TestHTTPServerTimeout(t *testing.T) {
  1319. os.Clearenv()
  1320. os.Setenv("HTTP_SERVER_TIMEOUT", "342")
  1321. parser := NewParser()
  1322. opts, err := parser.ParseEnvironmentVariables()
  1323. if err != nil {
  1324. t.Fatalf(`Parsing failure: %v`, err)
  1325. }
  1326. expected := 342
  1327. result := opts.HTTPServerTimeout()
  1328. if result != expected {
  1329. t.Fatalf(`Unexpected HTTP_SERVER_TIMEOUT value, got %d instead of %d`, result, expected)
  1330. }
  1331. }
  1332. func TestDefaultHTTPServerTimeoutValue(t *testing.T) {
  1333. os.Clearenv()
  1334. parser := NewParser()
  1335. opts, err := parser.ParseEnvironmentVariables()
  1336. if err != nil {
  1337. t.Fatalf(`Parsing failure: %v`, err)
  1338. }
  1339. expected := defaultHTTPServerTimeout
  1340. result := opts.HTTPServerTimeout()
  1341. if result != expected {
  1342. t.Fatalf(`Unexpected HTTP_SERVER_TIMEOUT value, got %d instead of %d`, result, expected)
  1343. }
  1344. }
  1345. func TestParseConfigFile(t *testing.T) {
  1346. content := []byte(`
  1347. # This is a comment
  1348. DEBUG = yes
  1349. POCKET_CONSUMER_KEY= >#1234
  1350. Invalid text
  1351. `)
  1352. tmpfile, err := os.CreateTemp(".", "miniflux.*.unit_test.conf")
  1353. if err != nil {
  1354. t.Fatal(err)
  1355. }
  1356. if _, err := tmpfile.Write(content); err != nil {
  1357. t.Fatal(err)
  1358. }
  1359. os.Clearenv()
  1360. parser := NewParser()
  1361. opts, err := parser.ParseFile(tmpfile.Name())
  1362. if err != nil {
  1363. t.Errorf(`Parsing failure: %v`, err)
  1364. }
  1365. if opts.LogLevel() != "debug" {
  1366. t.Errorf(`Unexpected debug mode value, got %q`, opts.LogLevel())
  1367. }
  1368. expected := ">#1234"
  1369. result := opts.PocketConsumerKey("default")
  1370. if result != expected {
  1371. t.Errorf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1372. }
  1373. if err := tmpfile.Close(); err != nil {
  1374. t.Fatal(err)
  1375. }
  1376. if err := os.Remove(tmpfile.Name()); err != nil {
  1377. t.Fatal(err)
  1378. }
  1379. }
  1380. func TestAuthProxyHeader(t *testing.T) {
  1381. os.Clearenv()
  1382. os.Setenv("AUTH_PROXY_HEADER", "X-Forwarded-User")
  1383. parser := NewParser()
  1384. opts, err := parser.ParseEnvironmentVariables()
  1385. if err != nil {
  1386. t.Fatalf(`Parsing failure: %v`, err)
  1387. }
  1388. expected := "X-Forwarded-User"
  1389. result := opts.AuthProxyHeader()
  1390. if result != expected {
  1391. t.Fatalf(`Unexpected AUTH_PROXY_HEADER value, got %q instead of %q`, result, expected)
  1392. }
  1393. }
  1394. func TestDefaultAuthProxyHeaderValue(t *testing.T) {
  1395. os.Clearenv()
  1396. parser := NewParser()
  1397. opts, err := parser.ParseEnvironmentVariables()
  1398. if err != nil {
  1399. t.Fatalf(`Parsing failure: %v`, err)
  1400. }
  1401. expected := defaultAuthProxyHeader
  1402. result := opts.AuthProxyHeader()
  1403. if result != expected {
  1404. t.Fatalf(`Unexpected AUTH_PROXY_HEADER value, got %q instead of %q`, result, expected)
  1405. }
  1406. }
  1407. func TestAuthProxyUserCreationWhenUnset(t *testing.T) {
  1408. os.Clearenv()
  1409. parser := NewParser()
  1410. opts, err := parser.ParseEnvironmentVariables()
  1411. if err != nil {
  1412. t.Fatalf(`Parsing failure: %v`, err)
  1413. }
  1414. expected := false
  1415. result := opts.IsAuthProxyUserCreationAllowed()
  1416. if result != expected {
  1417. t.Fatalf(`Unexpected AUTH_PROXY_USER_CREATION value, got %v instead of %v`, result, expected)
  1418. }
  1419. }
  1420. func TestAuthProxyUserCreationAdmin(t *testing.T) {
  1421. os.Clearenv()
  1422. os.Setenv("AUTH_PROXY_USER_CREATION", "1")
  1423. parser := NewParser()
  1424. opts, err := parser.ParseEnvironmentVariables()
  1425. if err != nil {
  1426. t.Fatalf(`Parsing failure: %v`, err)
  1427. }
  1428. expected := true
  1429. result := opts.IsAuthProxyUserCreationAllowed()
  1430. if result != expected {
  1431. t.Fatalf(`Unexpected AUTH_PROXY_USER_CREATION value, got %v instead of %v`, result, expected)
  1432. }
  1433. }
  1434. func TestFetchOdyseeWatchTime(t *testing.T) {
  1435. os.Clearenv()
  1436. os.Setenv("FETCH_ODYSEE_WATCH_TIME", "1")
  1437. parser := NewParser()
  1438. opts, err := parser.ParseEnvironmentVariables()
  1439. if err != nil {
  1440. t.Fatalf(`Parsing failure: %v`, err)
  1441. }
  1442. expected := true
  1443. result := opts.FetchOdyseeWatchTime()
  1444. if result != expected {
  1445. t.Fatalf(`Unexpected FETCH_ODYSEE_WATCH_TIME value, got %v instead of %v`, result, expected)
  1446. }
  1447. }
  1448. func TestFetchYouTubeWatchTime(t *testing.T) {
  1449. os.Clearenv()
  1450. os.Setenv("FETCH_YOUTUBE_WATCH_TIME", "1")
  1451. parser := NewParser()
  1452. opts, err := parser.ParseEnvironmentVariables()
  1453. if err != nil {
  1454. t.Fatalf(`Parsing failure: %v`, err)
  1455. }
  1456. expected := true
  1457. result := opts.FetchYouTubeWatchTime()
  1458. if result != expected {
  1459. t.Fatalf(`Unexpected FETCH_YOUTUBE_WATCH_TIME value, got %v instead of %v`, result, expected)
  1460. }
  1461. }
  1462. func TestYouTubeEmbedUrlOverride(t *testing.T) {
  1463. os.Clearenv()
  1464. os.Setenv("YOUTUBE_EMBED_URL_OVERRIDE", "https://invidious.custom/embed/")
  1465. parser := NewParser()
  1466. opts, err := parser.ParseEnvironmentVariables()
  1467. if err != nil {
  1468. t.Fatalf(`Parsing failure: %v`, err)
  1469. }
  1470. expected := "https://invidious.custom/embed/"
  1471. result := opts.YouTubeEmbedUrlOverride()
  1472. if result != expected {
  1473. t.Fatalf(`Unexpected YOUTUBE_EMBED_URL_OVERRIDE value, got %v instead of %v`, result, expected)
  1474. }
  1475. }
  1476. func TestParseConfigDumpOutput(t *testing.T) {
  1477. os.Clearenv()
  1478. wantOpts := NewOptions()
  1479. wantOpts.adminUsername = "my-username"
  1480. serialized := wantOpts.String()
  1481. tmpfile, err := os.CreateTemp(".", "miniflux.*.unit_test.conf")
  1482. if err != nil {
  1483. t.Fatal(err)
  1484. }
  1485. if _, err := tmpfile.Write([]byte(serialized)); err != nil {
  1486. t.Fatal(err)
  1487. }
  1488. parser := NewParser()
  1489. parsedOpts, err := parser.ParseFile(tmpfile.Name())
  1490. if err != nil {
  1491. t.Errorf(`Parsing failure: %v`, err)
  1492. }
  1493. if parsedOpts.AdminUsername() != wantOpts.AdminUsername() {
  1494. t.Fatalf(`Unexpected ADMIN_USERNAME value, got %q instead of %q`, parsedOpts.AdminUsername(), wantOpts.AdminUsername())
  1495. }
  1496. if err := tmpfile.Close(); err != nil {
  1497. t.Fatal(err)
  1498. }
  1499. if err := os.Remove(tmpfile.Name()); err != nil {
  1500. t.Fatal(err)
  1501. }
  1502. }