config_test.go 43 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898
  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 TestDefautSchedulerCountBasedMaxIntervalValue(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 TestDefautSchedulerCountBasedMaxInterval(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 TestDefautSchedulerCountBasedMinIntervalValue(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 TestDefautSchedulerCountBasedMinInterval(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 TestDefautSchedulerEntryFrequencyFactor(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 TestPollingParsingErrorLimit(t *testing.T) {
  731. os.Clearenv()
  732. os.Setenv("POLLING_PARSING_ERROR_LIMIT", "100")
  733. parser := NewParser()
  734. opts, err := parser.ParseEnvironmentVariables()
  735. if err != nil {
  736. t.Fatalf(`Parsing failure: %v`, err)
  737. }
  738. expected := 100
  739. result := opts.PollingParsingErrorLimit()
  740. if result != expected {
  741. t.Fatalf(`Unexpected POLLING_SCHEDULER value, got %v instead of %v`, result, expected)
  742. }
  743. }
  744. func TestOAuth2UserCreationWhenUnset(t *testing.T) {
  745. os.Clearenv()
  746. parser := NewParser()
  747. opts, err := parser.ParseEnvironmentVariables()
  748. if err != nil {
  749. t.Fatalf(`Parsing failure: %v`, err)
  750. }
  751. expected := false
  752. result := opts.IsOAuth2UserCreationAllowed()
  753. if result != expected {
  754. t.Fatalf(`Unexpected OAUTH2_USER_CREATION value, got %v instead of %v`, result, expected)
  755. }
  756. }
  757. func TestOAuth2UserCreationAdmin(t *testing.T) {
  758. os.Clearenv()
  759. os.Setenv("OAUTH2_USER_CREATION", "1")
  760. parser := NewParser()
  761. opts, err := parser.ParseEnvironmentVariables()
  762. if err != nil {
  763. t.Fatalf(`Parsing failure: %v`, err)
  764. }
  765. expected := true
  766. result := opts.IsOAuth2UserCreationAllowed()
  767. if result != expected {
  768. t.Fatalf(`Unexpected OAUTH2_USER_CREATION value, got %v instead of %v`, result, expected)
  769. }
  770. }
  771. func TestOAuth2ClientID(t *testing.T) {
  772. os.Clearenv()
  773. os.Setenv("OAUTH2_CLIENT_ID", "foobar")
  774. parser := NewParser()
  775. opts, err := parser.ParseEnvironmentVariables()
  776. if err != nil {
  777. t.Fatalf(`Parsing failure: %v`, err)
  778. }
  779. expected := "foobar"
  780. result := opts.OAuth2ClientID()
  781. if result != expected {
  782. t.Fatalf(`Unexpected OAUTH2_CLIENT_ID value, got %q instead of %q`, result, expected)
  783. }
  784. }
  785. func TestDefaultOAuth2ClientIDValue(t *testing.T) {
  786. os.Clearenv()
  787. parser := NewParser()
  788. opts, err := parser.ParseEnvironmentVariables()
  789. if err != nil {
  790. t.Fatalf(`Parsing failure: %v`, err)
  791. }
  792. expected := defaultOAuth2ClientID
  793. result := opts.OAuth2ClientID()
  794. if result != expected {
  795. t.Fatalf(`Unexpected OAUTH2_CLIENT_ID value, got %q instead of %q`, result, expected)
  796. }
  797. }
  798. func TestOAuth2ClientSecret(t *testing.T) {
  799. os.Clearenv()
  800. os.Setenv("OAUTH2_CLIENT_SECRET", "secret")
  801. parser := NewParser()
  802. opts, err := parser.ParseEnvironmentVariables()
  803. if err != nil {
  804. t.Fatalf(`Parsing failure: %v`, err)
  805. }
  806. expected := "secret"
  807. result := opts.OAuth2ClientSecret()
  808. if result != expected {
  809. t.Fatalf(`Unexpected OAUTH2_CLIENT_SECRET value, got %q instead of %q`, result, expected)
  810. }
  811. }
  812. func TestDefaultOAuth2ClientSecretValue(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 := defaultOAuth2ClientSecret
  820. result := opts.OAuth2ClientSecret()
  821. if result != expected {
  822. t.Fatalf(`Unexpected OAUTH2_CLIENT_SECRET value, got %q instead of %q`, result, expected)
  823. }
  824. }
  825. func TestOAuth2RedirectURL(t *testing.T) {
  826. os.Clearenv()
  827. os.Setenv("OAUTH2_REDIRECT_URL", "http://example.org")
  828. parser := NewParser()
  829. opts, err := parser.ParseEnvironmentVariables()
  830. if err != nil {
  831. t.Fatalf(`Parsing failure: %v`, err)
  832. }
  833. expected := "http://example.org"
  834. result := opts.OAuth2RedirectURL()
  835. if result != expected {
  836. t.Fatalf(`Unexpected OAUTH2_REDIRECT_URL value, got %q instead of %q`, result, expected)
  837. }
  838. }
  839. func TestDefaultOAuth2RedirectURLValue(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 := defaultOAuth2RedirectURL
  847. result := opts.OAuth2RedirectURL()
  848. if result != expected {
  849. t.Fatalf(`Unexpected OAUTH2_REDIRECT_URL value, got %q instead of %q`, result, expected)
  850. }
  851. }
  852. func TestOAuth2OIDCDiscoveryEndpoint(t *testing.T) {
  853. os.Clearenv()
  854. os.Setenv("OAUTH2_OIDC_DISCOVERY_ENDPOINT", "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.OIDCDiscoveryEndpoint()
  862. if result != expected {
  863. t.Fatalf(`Unexpected OAUTH2_OIDC_DISCOVERY_ENDPOINT value, got %q instead of %q`, result, expected)
  864. }
  865. }
  866. func TestDefaultOIDCDiscoveryEndpointValue(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 := defaultOAuth2OidcDiscoveryEndpoint
  874. result := opts.OIDCDiscoveryEndpoint()
  875. if result != expected {
  876. t.Fatalf(`Unexpected OAUTH2_OIDC_DISCOVERY_ENDPOINT value, got %q instead of %q`, result, expected)
  877. }
  878. }
  879. func TestOAuth2Provider(t *testing.T) {
  880. os.Clearenv()
  881. os.Setenv("OAUTH2_PROVIDER", "google")
  882. parser := NewParser()
  883. opts, err := parser.ParseEnvironmentVariables()
  884. if err != nil {
  885. t.Fatalf(`Parsing failure: %v`, err)
  886. }
  887. expected := "google"
  888. result := opts.OAuth2Provider()
  889. if result != expected {
  890. t.Fatalf(`Unexpected OAUTH2_PROVIDER value, got %q instead of %q`, result, expected)
  891. }
  892. }
  893. func TestDefaultOAuth2ProviderValue(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 := defaultOAuth2Provider
  901. result := opts.OAuth2Provider()
  902. if result != expected {
  903. t.Fatalf(`Unexpected OAUTH2_PROVIDER value, got %q instead of %q`, result, expected)
  904. }
  905. }
  906. func TestHSTSWhenUnset(t *testing.T) {
  907. os.Clearenv()
  908. parser := NewParser()
  909. opts, err := parser.ParseEnvironmentVariables()
  910. if err != nil {
  911. t.Fatalf(`Parsing failure: %v`, err)
  912. }
  913. expected := true
  914. result := opts.HasHSTS()
  915. if result != expected {
  916. t.Fatalf(`Unexpected DISABLE_HSTS value, got %v instead of %v`, result, expected)
  917. }
  918. }
  919. func TestHSTS(t *testing.T) {
  920. os.Clearenv()
  921. os.Setenv("DISABLE_HSTS", "1")
  922. parser := NewParser()
  923. opts, err := parser.ParseEnvironmentVariables()
  924. if err != nil {
  925. t.Fatalf(`Parsing failure: %v`, err)
  926. }
  927. expected := false
  928. result := opts.HasHSTS()
  929. if result != expected {
  930. t.Fatalf(`Unexpected DISABLE_HSTS value, got %v instead of %v`, result, expected)
  931. }
  932. }
  933. func TestDisableHTTPServiceWhenUnset(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.HasHTTPService()
  942. if result != expected {
  943. t.Fatalf(`Unexpected DISABLE_HTTP_SERVICE value, got %v instead of %v`, result, expected)
  944. }
  945. }
  946. func TestDisableHTTPService(t *testing.T) {
  947. os.Clearenv()
  948. os.Setenv("DISABLE_HTTP_SERVICE", "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.HasHTTPService()
  956. if result != expected {
  957. t.Fatalf(`Unexpected DISABLE_HTTP_SERVICE value, got %v instead of %v`, result, expected)
  958. }
  959. }
  960. func TestDisableSchedulerServiceWhenUnset(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.HasSchedulerService()
  969. if result != expected {
  970. t.Fatalf(`Unexpected DISABLE_SCHEDULER_SERVICE value, got %v instead of %v`, result, expected)
  971. }
  972. }
  973. func TestDisableSchedulerService(t *testing.T) {
  974. os.Clearenv()
  975. os.Setenv("DISABLE_SCHEDULER_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.HasSchedulerService()
  983. if result != expected {
  984. t.Fatalf(`Unexpected DISABLE_SCHEDULER_SERVICE value, got %v instead of %v`, result, expected)
  985. }
  986. }
  987. func TestRunMigrationsWhenUnset(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 := false
  995. result := opts.RunMigrations()
  996. if result != expected {
  997. t.Fatalf(`Unexpected RUN_MIGRATIONS value, got %v instead of %v`, result, expected)
  998. }
  999. }
  1000. func TestRunMigrations(t *testing.T) {
  1001. os.Clearenv()
  1002. os.Setenv("RUN_MIGRATIONS", "yes")
  1003. parser := NewParser()
  1004. opts, err := parser.ParseEnvironmentVariables()
  1005. if err != nil {
  1006. t.Fatalf(`Parsing failure: %v`, err)
  1007. }
  1008. expected := true
  1009. result := opts.RunMigrations()
  1010. if result != expected {
  1011. t.Fatalf(`Unexpected RUN_MIGRATIONS value, got %v instead of %v`, result, expected)
  1012. }
  1013. }
  1014. func TestCreateAdminWhenUnset(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.CreateAdmin()
  1023. if result != expected {
  1024. t.Fatalf(`Unexpected CREATE_ADMIN value, got %v instead of %v`, result, expected)
  1025. }
  1026. }
  1027. func TestCreateAdmin(t *testing.T) {
  1028. os.Clearenv()
  1029. os.Setenv("CREATE_ADMIN", "true")
  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.CreateAdmin()
  1037. if result != expected {
  1038. t.Fatalf(`Unexpected CREATE_ADMIN value, got %v instead of %v`, result, expected)
  1039. }
  1040. }
  1041. func TestPocketConsumerKeyFromEnvVariable(t *testing.T) {
  1042. os.Clearenv()
  1043. os.Setenv("POCKET_CONSUMER_KEY", "something")
  1044. parser := NewParser()
  1045. opts, err := parser.ParseEnvironmentVariables()
  1046. if err != nil {
  1047. t.Fatalf(`Parsing failure: %v`, err)
  1048. }
  1049. expected := "something"
  1050. result := opts.PocketConsumerKey("default")
  1051. if result != expected {
  1052. t.Fatalf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1053. }
  1054. }
  1055. func TestPocketConsumerKeyFromUserPrefs(t *testing.T) {
  1056. os.Clearenv()
  1057. parser := NewParser()
  1058. opts, err := parser.ParseEnvironmentVariables()
  1059. if err != nil {
  1060. t.Fatalf(`Parsing failure: %v`, err)
  1061. }
  1062. expected := "default"
  1063. result := opts.PocketConsumerKey("default")
  1064. if result != expected {
  1065. t.Fatalf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1066. }
  1067. }
  1068. func TestProxyOption(t *testing.T) {
  1069. os.Clearenv()
  1070. os.Setenv("PROXY_OPTION", "all")
  1071. parser := NewParser()
  1072. opts, err := parser.ParseEnvironmentVariables()
  1073. if err != nil {
  1074. t.Fatalf(`Parsing failure: %v`, err)
  1075. }
  1076. expected := "all"
  1077. result := opts.ProxyOption()
  1078. if result != expected {
  1079. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expected)
  1080. }
  1081. }
  1082. func TestDefaultProxyOptionValue(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 := defaultProxyOption
  1090. result := opts.ProxyOption()
  1091. if result != expected {
  1092. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expected)
  1093. }
  1094. }
  1095. func TestProxyMediaTypes(t *testing.T) {
  1096. os.Clearenv()
  1097. os.Setenv("PROXY_MEDIA_TYPES", "image,audio")
  1098. parser := NewParser()
  1099. opts, err := parser.ParseEnvironmentVariables()
  1100. if err != nil {
  1101. t.Fatalf(`Parsing failure: %v`, err)
  1102. }
  1103. expected := []string{"audio", "image"}
  1104. if len(expected) != len(opts.ProxyMediaTypes()) {
  1105. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1106. }
  1107. resultMap := make(map[string]bool)
  1108. for _, mediaType := range opts.ProxyMediaTypes() {
  1109. resultMap[mediaType] = true
  1110. }
  1111. for _, mediaType := range expected {
  1112. if !resultMap[mediaType] {
  1113. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1114. }
  1115. }
  1116. }
  1117. func TestProxyMediaTypesWithDuplicatedValues(t *testing.T) {
  1118. os.Clearenv()
  1119. os.Setenv("PROXY_MEDIA_TYPES", "image,audio, image")
  1120. parser := NewParser()
  1121. opts, err := parser.ParseEnvironmentVariables()
  1122. if err != nil {
  1123. t.Fatalf(`Parsing failure: %v`, err)
  1124. }
  1125. expected := []string{"audio", "image"}
  1126. if len(expected) != len(opts.ProxyMediaTypes()) {
  1127. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1128. }
  1129. resultMap := make(map[string]bool)
  1130. for _, mediaType := range opts.ProxyMediaTypes() {
  1131. resultMap[mediaType] = true
  1132. }
  1133. for _, mediaType := range expected {
  1134. if !resultMap[mediaType] {
  1135. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1136. }
  1137. }
  1138. }
  1139. func TestProxyImagesOptionBackwardCompatibility(t *testing.T) {
  1140. os.Clearenv()
  1141. os.Setenv("PROXY_IMAGES", "all")
  1142. parser := NewParser()
  1143. opts, err := parser.ParseEnvironmentVariables()
  1144. if err != nil {
  1145. t.Fatalf(`Parsing failure: %v`, err)
  1146. }
  1147. expected := []string{"image"}
  1148. if len(expected) != len(opts.ProxyMediaTypes()) {
  1149. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1150. }
  1151. resultMap := make(map[string]bool)
  1152. for _, mediaType := range opts.ProxyMediaTypes() {
  1153. resultMap[mediaType] = true
  1154. }
  1155. for _, mediaType := range expected {
  1156. if !resultMap[mediaType] {
  1157. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1158. }
  1159. }
  1160. expectedProxyOption := "all"
  1161. result := opts.ProxyOption()
  1162. if result != expectedProxyOption {
  1163. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expectedProxyOption)
  1164. }
  1165. }
  1166. func TestDefaultProxyMediaTypes(t *testing.T) {
  1167. os.Clearenv()
  1168. parser := NewParser()
  1169. opts, err := parser.ParseEnvironmentVariables()
  1170. if err != nil {
  1171. t.Fatalf(`Parsing failure: %v`, err)
  1172. }
  1173. expected := []string{"image"}
  1174. if len(expected) != len(opts.ProxyMediaTypes()) {
  1175. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1176. }
  1177. resultMap := make(map[string]bool)
  1178. for _, mediaType := range opts.ProxyMediaTypes() {
  1179. resultMap[mediaType] = true
  1180. }
  1181. for _, mediaType := range expected {
  1182. if !resultMap[mediaType] {
  1183. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1184. }
  1185. }
  1186. }
  1187. func TestProxyHTTPClientTimeout(t *testing.T) {
  1188. os.Clearenv()
  1189. os.Setenv("PROXY_HTTP_CLIENT_TIMEOUT", "24")
  1190. parser := NewParser()
  1191. opts, err := parser.ParseEnvironmentVariables()
  1192. if err != nil {
  1193. t.Fatalf(`Parsing failure: %v`, err)
  1194. }
  1195. expected := 24
  1196. result := opts.ProxyHTTPClientTimeout()
  1197. if result != expected {
  1198. t.Fatalf(`Unexpected PROXY_HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1199. }
  1200. }
  1201. func TestDefaultProxyHTTPClientTimeoutValue(t *testing.T) {
  1202. os.Clearenv()
  1203. parser := NewParser()
  1204. opts, err := parser.ParseEnvironmentVariables()
  1205. if err != nil {
  1206. t.Fatalf(`Parsing failure: %v`, err)
  1207. }
  1208. expected := defaultProxyHTTPClientTimeout
  1209. result := opts.ProxyHTTPClientTimeout()
  1210. if result != expected {
  1211. t.Fatalf(`Unexpected PROXY_HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1212. }
  1213. }
  1214. func TestHTTPSOff(t *testing.T) {
  1215. os.Clearenv()
  1216. parser := NewParser()
  1217. opts, err := parser.ParseEnvironmentVariables()
  1218. if err != nil {
  1219. t.Fatalf(`Parsing failure: %v`, err)
  1220. }
  1221. if opts.HTTPS {
  1222. t.Fatalf(`Unexpected HTTPS value, got "%v"`, opts.HTTPS)
  1223. }
  1224. }
  1225. func TestHTTPSOn(t *testing.T) {
  1226. os.Clearenv()
  1227. os.Setenv("HTTPS", "on")
  1228. parser := NewParser()
  1229. opts, err := parser.ParseEnvironmentVariables()
  1230. if err != nil {
  1231. t.Fatalf(`Parsing failure: %v`, err)
  1232. }
  1233. if !opts.HTTPS {
  1234. t.Fatalf(`Unexpected HTTPS value, got "%v"`, opts.HTTPS)
  1235. }
  1236. }
  1237. func TestHTTPClientTimeout(t *testing.T) {
  1238. os.Clearenv()
  1239. os.Setenv("HTTP_CLIENT_TIMEOUT", "42")
  1240. parser := NewParser()
  1241. opts, err := parser.ParseEnvironmentVariables()
  1242. if err != nil {
  1243. t.Fatalf(`Parsing failure: %v`, err)
  1244. }
  1245. expected := 42
  1246. result := opts.HTTPClientTimeout()
  1247. if result != expected {
  1248. t.Fatalf(`Unexpected HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1249. }
  1250. }
  1251. func TestDefaultHTTPClientTimeoutValue(t *testing.T) {
  1252. os.Clearenv()
  1253. parser := NewParser()
  1254. opts, err := parser.ParseEnvironmentVariables()
  1255. if err != nil {
  1256. t.Fatalf(`Parsing failure: %v`, err)
  1257. }
  1258. expected := defaultHTTPClientTimeout
  1259. result := opts.HTTPClientTimeout()
  1260. if result != expected {
  1261. t.Fatalf(`Unexpected HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1262. }
  1263. }
  1264. func TestHTTPClientMaxBodySize(t *testing.T) {
  1265. os.Clearenv()
  1266. os.Setenv("HTTP_CLIENT_MAX_BODY_SIZE", "42")
  1267. parser := NewParser()
  1268. opts, err := parser.ParseEnvironmentVariables()
  1269. if err != nil {
  1270. t.Fatalf(`Parsing failure: %v`, err)
  1271. }
  1272. expected := int64(42 * 1024 * 1024)
  1273. result := opts.HTTPClientMaxBodySize()
  1274. if result != expected {
  1275. t.Fatalf(`Unexpected HTTP_CLIENT_MAX_BODY_SIZE value, got %d instead of %d`, result, expected)
  1276. }
  1277. }
  1278. func TestDefaultHTTPClientMaxBodySizeValue(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 := int64(defaultHTTPClientMaxBodySize * 1024 * 1024)
  1286. result := opts.HTTPClientMaxBodySize()
  1287. if result != expected {
  1288. t.Fatalf(`Unexpected HTTP_CLIENT_MAX_BODY_SIZE value, got %d instead of %d`, result, expected)
  1289. }
  1290. }
  1291. func TestHTTPServerTimeout(t *testing.T) {
  1292. os.Clearenv()
  1293. os.Setenv("HTTP_SERVER_TIMEOUT", "342")
  1294. parser := NewParser()
  1295. opts, err := parser.ParseEnvironmentVariables()
  1296. if err != nil {
  1297. t.Fatalf(`Parsing failure: %v`, err)
  1298. }
  1299. expected := 342
  1300. result := opts.HTTPServerTimeout()
  1301. if result != expected {
  1302. t.Fatalf(`Unexpected HTTP_SERVER_TIMEOUT value, got %d instead of %d`, result, expected)
  1303. }
  1304. }
  1305. func TestDefaultHTTPServerTimeoutValue(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 := defaultHTTPServerTimeout
  1313. result := opts.HTTPServerTimeout()
  1314. if result != expected {
  1315. t.Fatalf(`Unexpected HTTP_SERVER_TIMEOUT value, got %d instead of %d`, result, expected)
  1316. }
  1317. }
  1318. func TestParseConfigFile(t *testing.T) {
  1319. content := []byte(`
  1320. # This is a comment
  1321. DEBUG = yes
  1322. POCKET_CONSUMER_KEY= >#1234
  1323. Invalid text
  1324. `)
  1325. tmpfile, err := os.CreateTemp(".", "miniflux.*.unit_test.conf")
  1326. if err != nil {
  1327. t.Fatal(err)
  1328. }
  1329. if _, err := tmpfile.Write(content); err != nil {
  1330. t.Fatal(err)
  1331. }
  1332. os.Clearenv()
  1333. parser := NewParser()
  1334. opts, err := parser.ParseFile(tmpfile.Name())
  1335. if err != nil {
  1336. t.Errorf(`Parsing failure: %v`, err)
  1337. }
  1338. if opts.LogLevel() != "debug" {
  1339. t.Errorf(`Unexpected debug mode value, got %q`, opts.LogLevel())
  1340. }
  1341. expected := ">#1234"
  1342. result := opts.PocketConsumerKey("default")
  1343. if result != expected {
  1344. t.Errorf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1345. }
  1346. if err := tmpfile.Close(); err != nil {
  1347. t.Fatal(err)
  1348. }
  1349. if err := os.Remove(tmpfile.Name()); err != nil {
  1350. t.Fatal(err)
  1351. }
  1352. }
  1353. func TestAuthProxyHeader(t *testing.T) {
  1354. os.Clearenv()
  1355. os.Setenv("AUTH_PROXY_HEADER", "X-Forwarded-User")
  1356. parser := NewParser()
  1357. opts, err := parser.ParseEnvironmentVariables()
  1358. if err != nil {
  1359. t.Fatalf(`Parsing failure: %v`, err)
  1360. }
  1361. expected := "X-Forwarded-User"
  1362. result := opts.AuthProxyHeader()
  1363. if result != expected {
  1364. t.Fatalf(`Unexpected AUTH_PROXY_HEADER value, got %q instead of %q`, result, expected)
  1365. }
  1366. }
  1367. func TestDefaultAuthProxyHeaderValue(t *testing.T) {
  1368. os.Clearenv()
  1369. parser := NewParser()
  1370. opts, err := parser.ParseEnvironmentVariables()
  1371. if err != nil {
  1372. t.Fatalf(`Parsing failure: %v`, err)
  1373. }
  1374. expected := defaultAuthProxyHeader
  1375. result := opts.AuthProxyHeader()
  1376. if result != expected {
  1377. t.Fatalf(`Unexpected AUTH_PROXY_HEADER value, got %q instead of %q`, result, expected)
  1378. }
  1379. }
  1380. func TestAuthProxyUserCreationWhenUnset(t *testing.T) {
  1381. os.Clearenv()
  1382. parser := NewParser()
  1383. opts, err := parser.ParseEnvironmentVariables()
  1384. if err != nil {
  1385. t.Fatalf(`Parsing failure: %v`, err)
  1386. }
  1387. expected := false
  1388. result := opts.IsAuthProxyUserCreationAllowed()
  1389. if result != expected {
  1390. t.Fatalf(`Unexpected AUTH_PROXY_USER_CREATION value, got %v instead of %v`, result, expected)
  1391. }
  1392. }
  1393. func TestAuthProxyUserCreationAdmin(t *testing.T) {
  1394. os.Clearenv()
  1395. os.Setenv("AUTH_PROXY_USER_CREATION", "1")
  1396. parser := NewParser()
  1397. opts, err := parser.ParseEnvironmentVariables()
  1398. if err != nil {
  1399. t.Fatalf(`Parsing failure: %v`, err)
  1400. }
  1401. expected := true
  1402. result := opts.IsAuthProxyUserCreationAllowed()
  1403. if result != expected {
  1404. t.Fatalf(`Unexpected AUTH_PROXY_USER_CREATION value, got %v instead of %v`, result, expected)
  1405. }
  1406. }
  1407. func TestFetchOdyseeWatchTime(t *testing.T) {
  1408. os.Clearenv()
  1409. os.Setenv("FETCH_ODYSEE_WATCH_TIME", "1")
  1410. parser := NewParser()
  1411. opts, err := parser.ParseEnvironmentVariables()
  1412. if err != nil {
  1413. t.Fatalf(`Parsing failure: %v`, err)
  1414. }
  1415. expected := true
  1416. result := opts.FetchOdyseeWatchTime()
  1417. if result != expected {
  1418. t.Fatalf(`Unexpected FETCH_ODYSEE_WATCH_TIME value, got %v instead of %v`, result, expected)
  1419. }
  1420. }
  1421. func TestFetchYouTubeWatchTime(t *testing.T) {
  1422. os.Clearenv()
  1423. os.Setenv("FETCH_YOUTUBE_WATCH_TIME", "1")
  1424. parser := NewParser()
  1425. opts, err := parser.ParseEnvironmentVariables()
  1426. if err != nil {
  1427. t.Fatalf(`Parsing failure: %v`, err)
  1428. }
  1429. expected := true
  1430. result := opts.FetchYouTubeWatchTime()
  1431. if result != expected {
  1432. t.Fatalf(`Unexpected FETCH_YOUTUBE_WATCH_TIME value, got %v instead of %v`, result, expected)
  1433. }
  1434. }
  1435. func TestYouTubeEmbedUrlOverride(t *testing.T) {
  1436. os.Clearenv()
  1437. os.Setenv("YOUTUBE_EMBED_URL_OVERRIDE", "https://invidious.custom/embed/")
  1438. parser := NewParser()
  1439. opts, err := parser.ParseEnvironmentVariables()
  1440. if err != nil {
  1441. t.Fatalf(`Parsing failure: %v`, err)
  1442. }
  1443. expected := "https://invidious.custom/embed/"
  1444. result := opts.YouTubeEmbedUrlOverride()
  1445. if result != expected {
  1446. t.Fatalf(`Unexpected YOUTUBE_EMBED_URL_OVERRIDE value, got %v instead of %v`, result, expected)
  1447. }
  1448. }
  1449. func TestParseConfigDumpOutput(t *testing.T) {
  1450. os.Clearenv()
  1451. wantOpts := NewOptions()
  1452. wantOpts.adminUsername = "my-username"
  1453. serialized := wantOpts.String()
  1454. tmpfile, err := os.CreateTemp(".", "miniflux.*.unit_test.conf")
  1455. if err != nil {
  1456. t.Fatal(err)
  1457. }
  1458. if _, err := tmpfile.Write([]byte(serialized)); err != nil {
  1459. t.Fatal(err)
  1460. }
  1461. parser := NewParser()
  1462. parsedOpts, err := parser.ParseFile(tmpfile.Name())
  1463. if err != nil {
  1464. t.Errorf(`Parsing failure: %v`, err)
  1465. }
  1466. if parsedOpts.AdminUsername() != wantOpts.AdminUsername() {
  1467. t.Fatalf(`Unexpected ADMIN_USERNAME value, got %q instead of %q`, parsedOpts.AdminUsername(), wantOpts.AdminUsername())
  1468. }
  1469. if err := tmpfile.Close(); err != nil {
  1470. t.Fatal(err)
  1471. }
  1472. if err := os.Remove(tmpfile.Name()); err != nil {
  1473. t.Fatal(err)
  1474. }
  1475. }