config_test.go 45 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968
  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 TestDefautForceRefreshInterval(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 := defaultForceRefreshInterval
  603. result := opts.ForceRefreshInterval()
  604. if result != expected {
  605. t.Fatalf(`Unexpected FORCE_REFRESH_INTERVAL value, got %v instead of %v`, result, expected)
  606. }
  607. }
  608. func TestForceRefreshInterval(t *testing.T) {
  609. os.Clearenv()
  610. os.Setenv("FORCE_REFRESH_INTERVAL", "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.ForceRefreshInterval()
  618. if result != expected {
  619. t.Fatalf(`Unexpected FORCE_REFRESH_INTERVAL value, got %v instead of %v`, result, expected)
  620. }
  621. }
  622. func TestDefaultBatchSizeValue(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 := defaultBatchSize
  630. result := opts.BatchSize()
  631. if result != expected {
  632. t.Fatalf(`Unexpected BATCH_SIZE value, got %v instead of %v`, result, expected)
  633. }
  634. }
  635. func TestBatchSize(t *testing.T) {
  636. os.Clearenv()
  637. os.Setenv("BATCH_SIZE", "42")
  638. parser := NewParser()
  639. opts, err := parser.ParseEnvironmentVariables()
  640. if err != nil {
  641. t.Fatalf(`Parsing failure: %v`, err)
  642. }
  643. expected := 42
  644. result := opts.BatchSize()
  645. if result != expected {
  646. t.Fatalf(`Unexpected BATCH_SIZE value, got %v instead of %v`, result, expected)
  647. }
  648. }
  649. func TestDefautPollingSchedulerValue(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 := defaultPollingScheduler
  657. result := opts.PollingScheduler()
  658. if result != expected {
  659. t.Fatalf(`Unexpected POLLING_SCHEDULER value, got %v instead of %v`, result, expected)
  660. }
  661. }
  662. func TestPollingScheduler(t *testing.T) {
  663. os.Clearenv()
  664. os.Setenv("POLLING_SCHEDULER", "entry_count_based")
  665. parser := NewParser()
  666. opts, err := parser.ParseEnvironmentVariables()
  667. if err != nil {
  668. t.Fatalf(`Parsing failure: %v`, err)
  669. }
  670. expected := "entry_count_based"
  671. result := opts.PollingScheduler()
  672. if result != expected {
  673. t.Fatalf(`Unexpected POLLING_SCHEDULER value, got %v instead of %v`, result, expected)
  674. }
  675. }
  676. func TestDefautSchedulerEntryFrequencyMaxIntervalValue(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 := defaultSchedulerEntryFrequencyMaxInterval
  684. result := opts.SchedulerEntryFrequencyMaxInterval()
  685. if result != expected {
  686. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL value, got %v instead of %v`, result, expected)
  687. }
  688. }
  689. func TestSchedulerEntryFrequencyMaxInterval(t *testing.T) {
  690. os.Clearenv()
  691. os.Setenv("SCHEDULER_ENTRY_FREQUENCY_MAX_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.SchedulerEntryFrequencyMaxInterval()
  699. if result != expected {
  700. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL value, got %v instead of %v`, result, expected)
  701. }
  702. }
  703. func TestDefautSchedulerEntryFrequencyMinIntervalValue(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 := defaultSchedulerEntryFrequencyMinInterval
  711. result := opts.SchedulerEntryFrequencyMinInterval()
  712. if result != expected {
  713. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  714. }
  715. }
  716. func TestSchedulerEntryFrequencyMinInterval(t *testing.T) {
  717. os.Clearenv()
  718. os.Setenv("SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL", "30")
  719. parser := NewParser()
  720. opts, err := parser.ParseEnvironmentVariables()
  721. if err != nil {
  722. t.Fatalf(`Parsing failure: %v`, err)
  723. }
  724. expected := 30
  725. result := opts.SchedulerEntryFrequencyMinInterval()
  726. if result != expected {
  727. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  728. }
  729. }
  730. func TestDefautSchedulerEntryFrequencyFactorValue(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 := defaultSchedulerEntryFrequencyFactor
  738. result := opts.SchedulerEntryFrequencyFactor()
  739. if result != expected {
  740. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_FACTOR value, got %v instead of %v`, result, expected)
  741. }
  742. }
  743. func TestSchedulerEntryFrequencyFactor(t *testing.T) {
  744. os.Clearenv()
  745. os.Setenv("SCHEDULER_ENTRY_FREQUENCY_FACTOR", "2")
  746. parser := NewParser()
  747. opts, err := parser.ParseEnvironmentVariables()
  748. if err != nil {
  749. t.Fatalf(`Parsing failure: %v`, err)
  750. }
  751. expected := 2
  752. result := opts.SchedulerEntryFrequencyFactor()
  753. if result != expected {
  754. t.Fatalf(`Unexpected SCHEDULER_ENTRY_FREQUENCY_FACTOR value, got %v instead of %v`, result, expected)
  755. }
  756. }
  757. func TestDefaultSchedulerRoundRobinValue(t *testing.T) {
  758. os.Clearenv()
  759. parser := NewParser()
  760. opts, err := parser.ParseEnvironmentVariables()
  761. if err != nil {
  762. t.Fatalf(`Parsing failure: %v`, err)
  763. }
  764. expected := defaultSchedulerRoundRobinMinInterval
  765. result := opts.SchedulerRoundRobinMinInterval()
  766. if result != expected {
  767. t.Fatalf(`Unexpected SCHEDULER_ROUND_ROBIN_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  768. }
  769. }
  770. func TestSchedulerRoundRobin(t *testing.T) {
  771. os.Clearenv()
  772. os.Setenv("SCHEDULER_ROUND_ROBIN_MIN_INTERVAL", "15")
  773. parser := NewParser()
  774. opts, err := parser.ParseEnvironmentVariables()
  775. if err != nil {
  776. t.Fatalf(`Parsing failure: %v`, err)
  777. }
  778. expected := 15
  779. result := opts.SchedulerRoundRobinMinInterval()
  780. if result != expected {
  781. t.Fatalf(`Unexpected SCHEDULER_ROUND_ROBIN_MIN_INTERVAL value, got %v instead of %v`, result, expected)
  782. }
  783. }
  784. func TestPollingParsingErrorLimit(t *testing.T) {
  785. os.Clearenv()
  786. os.Setenv("POLLING_PARSING_ERROR_LIMIT", "100")
  787. parser := NewParser()
  788. opts, err := parser.ParseEnvironmentVariables()
  789. if err != nil {
  790. t.Fatalf(`Parsing failure: %v`, err)
  791. }
  792. expected := 100
  793. result := opts.PollingParsingErrorLimit()
  794. if result != expected {
  795. t.Fatalf(`Unexpected POLLING_SCHEDULER value, got %v instead of %v`, result, expected)
  796. }
  797. }
  798. func TestOAuth2UserCreationWhenUnset(t *testing.T) {
  799. os.Clearenv()
  800. parser := NewParser()
  801. opts, err := parser.ParseEnvironmentVariables()
  802. if err != nil {
  803. t.Fatalf(`Parsing failure: %v`, err)
  804. }
  805. expected := false
  806. result := opts.IsOAuth2UserCreationAllowed()
  807. if result != expected {
  808. t.Fatalf(`Unexpected OAUTH2_USER_CREATION value, got %v instead of %v`, result, expected)
  809. }
  810. }
  811. func TestOAuth2UserCreationAdmin(t *testing.T) {
  812. os.Clearenv()
  813. os.Setenv("OAUTH2_USER_CREATION", "1")
  814. parser := NewParser()
  815. opts, err := parser.ParseEnvironmentVariables()
  816. if err != nil {
  817. t.Fatalf(`Parsing failure: %v`, err)
  818. }
  819. expected := true
  820. result := opts.IsOAuth2UserCreationAllowed()
  821. if result != expected {
  822. t.Fatalf(`Unexpected OAUTH2_USER_CREATION value, got %v instead of %v`, result, expected)
  823. }
  824. }
  825. func TestOAuth2ClientID(t *testing.T) {
  826. os.Clearenv()
  827. os.Setenv("OAUTH2_CLIENT_ID", "foobar")
  828. parser := NewParser()
  829. opts, err := parser.ParseEnvironmentVariables()
  830. if err != nil {
  831. t.Fatalf(`Parsing failure: %v`, err)
  832. }
  833. expected := "foobar"
  834. result := opts.OAuth2ClientID()
  835. if result != expected {
  836. t.Fatalf(`Unexpected OAUTH2_CLIENT_ID value, got %q instead of %q`, result, expected)
  837. }
  838. }
  839. func TestDefaultOAuth2ClientIDValue(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 := defaultOAuth2ClientID
  847. result := opts.OAuth2ClientID()
  848. if result != expected {
  849. t.Fatalf(`Unexpected OAUTH2_CLIENT_ID value, got %q instead of %q`, result, expected)
  850. }
  851. }
  852. func TestOAuth2ClientSecret(t *testing.T) {
  853. os.Clearenv()
  854. os.Setenv("OAUTH2_CLIENT_SECRET", "secret")
  855. parser := NewParser()
  856. opts, err := parser.ParseEnvironmentVariables()
  857. if err != nil {
  858. t.Fatalf(`Parsing failure: %v`, err)
  859. }
  860. expected := "secret"
  861. result := opts.OAuth2ClientSecret()
  862. if result != expected {
  863. t.Fatalf(`Unexpected OAUTH2_CLIENT_SECRET value, got %q instead of %q`, result, expected)
  864. }
  865. }
  866. func TestDefaultOAuth2ClientSecretValue(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 := defaultOAuth2ClientSecret
  874. result := opts.OAuth2ClientSecret()
  875. if result != expected {
  876. t.Fatalf(`Unexpected OAUTH2_CLIENT_SECRET value, got %q instead of %q`, result, expected)
  877. }
  878. }
  879. func TestOAuth2RedirectURL(t *testing.T) {
  880. os.Clearenv()
  881. os.Setenv("OAUTH2_REDIRECT_URL", "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.OAuth2RedirectURL()
  889. if result != expected {
  890. t.Fatalf(`Unexpected OAUTH2_REDIRECT_URL value, got %q instead of %q`, result, expected)
  891. }
  892. }
  893. func TestDefaultOAuth2RedirectURLValue(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 := defaultOAuth2RedirectURL
  901. result := opts.OAuth2RedirectURL()
  902. if result != expected {
  903. t.Fatalf(`Unexpected OAUTH2_REDIRECT_URL value, got %q instead of %q`, result, expected)
  904. }
  905. }
  906. func TestOAuth2OIDCDiscoveryEndpoint(t *testing.T) {
  907. os.Clearenv()
  908. os.Setenv("OAUTH2_OIDC_DISCOVERY_ENDPOINT", "http://example.org")
  909. parser := NewParser()
  910. opts, err := parser.ParseEnvironmentVariables()
  911. if err != nil {
  912. t.Fatalf(`Parsing failure: %v`, err)
  913. }
  914. expected := "http://example.org"
  915. result := opts.OIDCDiscoveryEndpoint()
  916. if result != expected {
  917. t.Fatalf(`Unexpected OAUTH2_OIDC_DISCOVERY_ENDPOINT value, got %q instead of %q`, result, expected)
  918. }
  919. }
  920. func TestDefaultOIDCDiscoveryEndpointValue(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 := defaultOAuth2OidcDiscoveryEndpoint
  928. result := opts.OIDCDiscoveryEndpoint()
  929. if result != expected {
  930. t.Fatalf(`Unexpected OAUTH2_OIDC_DISCOVERY_ENDPOINT value, got %q instead of %q`, result, expected)
  931. }
  932. }
  933. func TestOAuth2Provider(t *testing.T) {
  934. os.Clearenv()
  935. os.Setenv("OAUTH2_PROVIDER", "google")
  936. parser := NewParser()
  937. opts, err := parser.ParseEnvironmentVariables()
  938. if err != nil {
  939. t.Fatalf(`Parsing failure: %v`, err)
  940. }
  941. expected := "google"
  942. result := opts.OAuth2Provider()
  943. if result != expected {
  944. t.Fatalf(`Unexpected OAUTH2_PROVIDER value, got %q instead of %q`, result, expected)
  945. }
  946. }
  947. func TestDefaultOAuth2ProviderValue(t *testing.T) {
  948. os.Clearenv()
  949. parser := NewParser()
  950. opts, err := parser.ParseEnvironmentVariables()
  951. if err != nil {
  952. t.Fatalf(`Parsing failure: %v`, err)
  953. }
  954. expected := defaultOAuth2Provider
  955. result := opts.OAuth2Provider()
  956. if result != expected {
  957. t.Fatalf(`Unexpected OAUTH2_PROVIDER value, got %q instead of %q`, result, expected)
  958. }
  959. }
  960. func TestHSTSWhenUnset(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.HasHSTS()
  969. if result != expected {
  970. t.Fatalf(`Unexpected DISABLE_HSTS value, got %v instead of %v`, result, expected)
  971. }
  972. }
  973. func TestHSTS(t *testing.T) {
  974. os.Clearenv()
  975. os.Setenv("DISABLE_HSTS", "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.HasHSTS()
  983. if result != expected {
  984. t.Fatalf(`Unexpected DISABLE_HSTS value, got %v instead of %v`, result, expected)
  985. }
  986. }
  987. func TestDisableHTTPServiceWhenUnset(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.HasHTTPService()
  996. if result != expected {
  997. t.Fatalf(`Unexpected DISABLE_HTTP_SERVICE value, got %v instead of %v`, result, expected)
  998. }
  999. }
  1000. func TestDisableHTTPService(t *testing.T) {
  1001. os.Clearenv()
  1002. os.Setenv("DISABLE_HTTP_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.HasHTTPService()
  1010. if result != expected {
  1011. t.Fatalf(`Unexpected DISABLE_HTTP_SERVICE value, got %v instead of %v`, result, expected)
  1012. }
  1013. }
  1014. func TestDisableSchedulerServiceWhenUnset(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 := true
  1022. result := opts.HasSchedulerService()
  1023. if result != expected {
  1024. t.Fatalf(`Unexpected DISABLE_SCHEDULER_SERVICE value, got %v instead of %v`, result, expected)
  1025. }
  1026. }
  1027. func TestDisableSchedulerService(t *testing.T) {
  1028. os.Clearenv()
  1029. os.Setenv("DISABLE_SCHEDULER_SERVICE", "1")
  1030. parser := NewParser()
  1031. opts, err := parser.ParseEnvironmentVariables()
  1032. if err != nil {
  1033. t.Fatalf(`Parsing failure: %v`, err)
  1034. }
  1035. expected := false
  1036. result := opts.HasSchedulerService()
  1037. if result != expected {
  1038. t.Fatalf(`Unexpected DISABLE_SCHEDULER_SERVICE value, got %v instead of %v`, result, expected)
  1039. }
  1040. }
  1041. func TestRunMigrationsWhenUnset(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.RunMigrations()
  1050. if result != expected {
  1051. t.Fatalf(`Unexpected RUN_MIGRATIONS value, got %v instead of %v`, result, expected)
  1052. }
  1053. }
  1054. func TestRunMigrations(t *testing.T) {
  1055. os.Clearenv()
  1056. os.Setenv("RUN_MIGRATIONS", "yes")
  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.RunMigrations()
  1064. if result != expected {
  1065. t.Fatalf(`Unexpected RUN_MIGRATIONS value, got %v instead of %v`, result, expected)
  1066. }
  1067. }
  1068. func TestCreateAdminWhenUnset(t *testing.T) {
  1069. os.Clearenv()
  1070. parser := NewParser()
  1071. opts, err := parser.ParseEnvironmentVariables()
  1072. if err != nil {
  1073. t.Fatalf(`Parsing failure: %v`, err)
  1074. }
  1075. expected := false
  1076. result := opts.CreateAdmin()
  1077. if result != expected {
  1078. t.Fatalf(`Unexpected CREATE_ADMIN value, got %v instead of %v`, result, expected)
  1079. }
  1080. }
  1081. func TestCreateAdmin(t *testing.T) {
  1082. os.Clearenv()
  1083. os.Setenv("CREATE_ADMIN", "true")
  1084. parser := NewParser()
  1085. opts, err := parser.ParseEnvironmentVariables()
  1086. if err != nil {
  1087. t.Fatalf(`Parsing failure: %v`, err)
  1088. }
  1089. expected := true
  1090. result := opts.CreateAdmin()
  1091. if result != expected {
  1092. t.Fatalf(`Unexpected CREATE_ADMIN value, got %v instead of %v`, result, expected)
  1093. }
  1094. }
  1095. func TestPocketConsumerKeyFromEnvVariable(t *testing.T) {
  1096. os.Clearenv()
  1097. os.Setenv("POCKET_CONSUMER_KEY", "something")
  1098. parser := NewParser()
  1099. opts, err := parser.ParseEnvironmentVariables()
  1100. if err != nil {
  1101. t.Fatalf(`Parsing failure: %v`, err)
  1102. }
  1103. expected := "something"
  1104. result := opts.PocketConsumerKey("default")
  1105. if result != expected {
  1106. t.Fatalf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1107. }
  1108. }
  1109. func TestPocketConsumerKeyFromUserPrefs(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 := "default"
  1117. result := opts.PocketConsumerKey("default")
  1118. if result != expected {
  1119. t.Fatalf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1120. }
  1121. }
  1122. func TestProxyOption(t *testing.T) {
  1123. os.Clearenv()
  1124. os.Setenv("PROXY_OPTION", "all")
  1125. parser := NewParser()
  1126. opts, err := parser.ParseEnvironmentVariables()
  1127. if err != nil {
  1128. t.Fatalf(`Parsing failure: %v`, err)
  1129. }
  1130. expected := "all"
  1131. result := opts.ProxyOption()
  1132. if result != expected {
  1133. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expected)
  1134. }
  1135. }
  1136. func TestDefaultProxyOptionValue(t *testing.T) {
  1137. os.Clearenv()
  1138. parser := NewParser()
  1139. opts, err := parser.ParseEnvironmentVariables()
  1140. if err != nil {
  1141. t.Fatalf(`Parsing failure: %v`, err)
  1142. }
  1143. expected := defaultProxyOption
  1144. result := opts.ProxyOption()
  1145. if result != expected {
  1146. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expected)
  1147. }
  1148. }
  1149. func TestProxyMediaTypes(t *testing.T) {
  1150. os.Clearenv()
  1151. os.Setenv("PROXY_MEDIA_TYPES", "image,audio")
  1152. parser := NewParser()
  1153. opts, err := parser.ParseEnvironmentVariables()
  1154. if err != nil {
  1155. t.Fatalf(`Parsing failure: %v`, err)
  1156. }
  1157. expected := []string{"audio", "image"}
  1158. if len(expected) != len(opts.ProxyMediaTypes()) {
  1159. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1160. }
  1161. resultMap := make(map[string]bool)
  1162. for _, mediaType := range opts.ProxyMediaTypes() {
  1163. resultMap[mediaType] = true
  1164. }
  1165. for _, mediaType := range expected {
  1166. if !resultMap[mediaType] {
  1167. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1168. }
  1169. }
  1170. }
  1171. func TestProxyMediaTypesWithDuplicatedValues(t *testing.T) {
  1172. os.Clearenv()
  1173. os.Setenv("PROXY_MEDIA_TYPES", "image,audio, image")
  1174. parser := NewParser()
  1175. opts, err := parser.ParseEnvironmentVariables()
  1176. if err != nil {
  1177. t.Fatalf(`Parsing failure: %v`, err)
  1178. }
  1179. expected := []string{"audio", "image"}
  1180. if len(expected) != len(opts.ProxyMediaTypes()) {
  1181. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1182. }
  1183. resultMap := make(map[string]bool)
  1184. for _, mediaType := range opts.ProxyMediaTypes() {
  1185. resultMap[mediaType] = true
  1186. }
  1187. for _, mediaType := range expected {
  1188. if !resultMap[mediaType] {
  1189. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1190. }
  1191. }
  1192. }
  1193. func TestProxyImagesOptionBackwardCompatibility(t *testing.T) {
  1194. os.Clearenv()
  1195. os.Setenv("PROXY_IMAGES", "all")
  1196. parser := NewParser()
  1197. opts, err := parser.ParseEnvironmentVariables()
  1198. if err != nil {
  1199. t.Fatalf(`Parsing failure: %v`, err)
  1200. }
  1201. expected := []string{"image"}
  1202. if len(expected) != len(opts.ProxyMediaTypes()) {
  1203. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1204. }
  1205. resultMap := make(map[string]bool)
  1206. for _, mediaType := range opts.ProxyMediaTypes() {
  1207. resultMap[mediaType] = true
  1208. }
  1209. for _, mediaType := range expected {
  1210. if !resultMap[mediaType] {
  1211. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1212. }
  1213. }
  1214. expectedProxyOption := "all"
  1215. result := opts.ProxyOption()
  1216. if result != expectedProxyOption {
  1217. t.Fatalf(`Unexpected PROXY_OPTION value, got %q instead of %q`, result, expectedProxyOption)
  1218. }
  1219. }
  1220. func TestDefaultProxyMediaTypes(t *testing.T) {
  1221. os.Clearenv()
  1222. parser := NewParser()
  1223. opts, err := parser.ParseEnvironmentVariables()
  1224. if err != nil {
  1225. t.Fatalf(`Parsing failure: %v`, err)
  1226. }
  1227. expected := []string{"image"}
  1228. if len(expected) != len(opts.ProxyMediaTypes()) {
  1229. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1230. }
  1231. resultMap := make(map[string]bool)
  1232. for _, mediaType := range opts.ProxyMediaTypes() {
  1233. resultMap[mediaType] = true
  1234. }
  1235. for _, mediaType := range expected {
  1236. if !resultMap[mediaType] {
  1237. t.Fatalf(`Unexpected PROXY_MEDIA_TYPES value, got %v instead of %v`, opts.ProxyMediaTypes(), expected)
  1238. }
  1239. }
  1240. }
  1241. func TestProxyHTTPClientTimeout(t *testing.T) {
  1242. os.Clearenv()
  1243. os.Setenv("PROXY_HTTP_CLIENT_TIMEOUT", "24")
  1244. parser := NewParser()
  1245. opts, err := parser.ParseEnvironmentVariables()
  1246. if err != nil {
  1247. t.Fatalf(`Parsing failure: %v`, err)
  1248. }
  1249. expected := 24
  1250. result := opts.ProxyHTTPClientTimeout()
  1251. if result != expected {
  1252. t.Fatalf(`Unexpected PROXY_HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1253. }
  1254. }
  1255. func TestDefaultProxyHTTPClientTimeoutValue(t *testing.T) {
  1256. os.Clearenv()
  1257. parser := NewParser()
  1258. opts, err := parser.ParseEnvironmentVariables()
  1259. if err != nil {
  1260. t.Fatalf(`Parsing failure: %v`, err)
  1261. }
  1262. expected := defaultProxyHTTPClientTimeout
  1263. result := opts.ProxyHTTPClientTimeout()
  1264. if result != expected {
  1265. t.Fatalf(`Unexpected PROXY_HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1266. }
  1267. }
  1268. func TestHTTPSOff(t *testing.T) {
  1269. os.Clearenv()
  1270. parser := NewParser()
  1271. opts, err := parser.ParseEnvironmentVariables()
  1272. if err != nil {
  1273. t.Fatalf(`Parsing failure: %v`, err)
  1274. }
  1275. if opts.HTTPS {
  1276. t.Fatalf(`Unexpected HTTPS value, got "%v"`, opts.HTTPS)
  1277. }
  1278. }
  1279. func TestHTTPSOn(t *testing.T) {
  1280. os.Clearenv()
  1281. os.Setenv("HTTPS", "on")
  1282. parser := NewParser()
  1283. opts, err := parser.ParseEnvironmentVariables()
  1284. if err != nil {
  1285. t.Fatalf(`Parsing failure: %v`, err)
  1286. }
  1287. if !opts.HTTPS {
  1288. t.Fatalf(`Unexpected HTTPS value, got "%v"`, opts.HTTPS)
  1289. }
  1290. }
  1291. func TestHTTPClientTimeout(t *testing.T) {
  1292. os.Clearenv()
  1293. os.Setenv("HTTP_CLIENT_TIMEOUT", "42")
  1294. parser := NewParser()
  1295. opts, err := parser.ParseEnvironmentVariables()
  1296. if err != nil {
  1297. t.Fatalf(`Parsing failure: %v`, err)
  1298. }
  1299. expected := 42
  1300. result := opts.HTTPClientTimeout()
  1301. if result != expected {
  1302. t.Fatalf(`Unexpected HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1303. }
  1304. }
  1305. func TestDefaultHTTPClientTimeoutValue(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 := defaultHTTPClientTimeout
  1313. result := opts.HTTPClientTimeout()
  1314. if result != expected {
  1315. t.Fatalf(`Unexpected HTTP_CLIENT_TIMEOUT value, got %d instead of %d`, result, expected)
  1316. }
  1317. }
  1318. func TestHTTPClientMaxBodySize(t *testing.T) {
  1319. os.Clearenv()
  1320. os.Setenv("HTTP_CLIENT_MAX_BODY_SIZE", "42")
  1321. parser := NewParser()
  1322. opts, err := parser.ParseEnvironmentVariables()
  1323. if err != nil {
  1324. t.Fatalf(`Parsing failure: %v`, err)
  1325. }
  1326. expected := int64(42 * 1024 * 1024)
  1327. result := opts.HTTPClientMaxBodySize()
  1328. if result != expected {
  1329. t.Fatalf(`Unexpected HTTP_CLIENT_MAX_BODY_SIZE value, got %d instead of %d`, result, expected)
  1330. }
  1331. }
  1332. func TestDefaultHTTPClientMaxBodySizeValue(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 := int64(defaultHTTPClientMaxBodySize * 1024 * 1024)
  1340. result := opts.HTTPClientMaxBodySize()
  1341. if result != expected {
  1342. t.Fatalf(`Unexpected HTTP_CLIENT_MAX_BODY_SIZE value, got %d instead of %d`, result, expected)
  1343. }
  1344. }
  1345. func TestHTTPServerTimeout(t *testing.T) {
  1346. os.Clearenv()
  1347. os.Setenv("HTTP_SERVER_TIMEOUT", "342")
  1348. parser := NewParser()
  1349. opts, err := parser.ParseEnvironmentVariables()
  1350. if err != nil {
  1351. t.Fatalf(`Parsing failure: %v`, err)
  1352. }
  1353. expected := 342
  1354. result := opts.HTTPServerTimeout()
  1355. if result != expected {
  1356. t.Fatalf(`Unexpected HTTP_SERVER_TIMEOUT value, got %d instead of %d`, result, expected)
  1357. }
  1358. }
  1359. func TestDefaultHTTPServerTimeoutValue(t *testing.T) {
  1360. os.Clearenv()
  1361. parser := NewParser()
  1362. opts, err := parser.ParseEnvironmentVariables()
  1363. if err != nil {
  1364. t.Fatalf(`Parsing failure: %v`, err)
  1365. }
  1366. expected := defaultHTTPServerTimeout
  1367. result := opts.HTTPServerTimeout()
  1368. if result != expected {
  1369. t.Fatalf(`Unexpected HTTP_SERVER_TIMEOUT value, got %d instead of %d`, result, expected)
  1370. }
  1371. }
  1372. func TestParseConfigFile(t *testing.T) {
  1373. content := []byte(`
  1374. # This is a comment
  1375. DEBUG = yes
  1376. POCKET_CONSUMER_KEY= >#1234
  1377. Invalid text
  1378. `)
  1379. tmpfile, err := os.CreateTemp(".", "miniflux.*.unit_test.conf")
  1380. if err != nil {
  1381. t.Fatal(err)
  1382. }
  1383. if _, err := tmpfile.Write(content); err != nil {
  1384. t.Fatal(err)
  1385. }
  1386. os.Clearenv()
  1387. parser := NewParser()
  1388. opts, err := parser.ParseFile(tmpfile.Name())
  1389. if err != nil {
  1390. t.Errorf(`Parsing failure: %v`, err)
  1391. }
  1392. if opts.LogLevel() != "debug" {
  1393. t.Errorf(`Unexpected debug mode value, got %q`, opts.LogLevel())
  1394. }
  1395. expected := ">#1234"
  1396. result := opts.PocketConsumerKey("default")
  1397. if result != expected {
  1398. t.Errorf(`Unexpected POCKET_CONSUMER_KEY value, got %q instead of %q`, result, expected)
  1399. }
  1400. if err := tmpfile.Close(); err != nil {
  1401. t.Fatal(err)
  1402. }
  1403. if err := os.Remove(tmpfile.Name()); err != nil {
  1404. t.Fatal(err)
  1405. }
  1406. }
  1407. func TestAuthProxyHeader(t *testing.T) {
  1408. os.Clearenv()
  1409. os.Setenv("AUTH_PROXY_HEADER", "X-Forwarded-User")
  1410. parser := NewParser()
  1411. opts, err := parser.ParseEnvironmentVariables()
  1412. if err != nil {
  1413. t.Fatalf(`Parsing failure: %v`, err)
  1414. }
  1415. expected := "X-Forwarded-User"
  1416. result := opts.AuthProxyHeader()
  1417. if result != expected {
  1418. t.Fatalf(`Unexpected AUTH_PROXY_HEADER value, got %q instead of %q`, result, expected)
  1419. }
  1420. }
  1421. func TestDefaultAuthProxyHeaderValue(t *testing.T) {
  1422. os.Clearenv()
  1423. parser := NewParser()
  1424. opts, err := parser.ParseEnvironmentVariables()
  1425. if err != nil {
  1426. t.Fatalf(`Parsing failure: %v`, err)
  1427. }
  1428. expected := defaultAuthProxyHeader
  1429. result := opts.AuthProxyHeader()
  1430. if result != expected {
  1431. t.Fatalf(`Unexpected AUTH_PROXY_HEADER value, got %q instead of %q`, result, expected)
  1432. }
  1433. }
  1434. func TestAuthProxyUserCreationWhenUnset(t *testing.T) {
  1435. os.Clearenv()
  1436. parser := NewParser()
  1437. opts, err := parser.ParseEnvironmentVariables()
  1438. if err != nil {
  1439. t.Fatalf(`Parsing failure: %v`, err)
  1440. }
  1441. expected := false
  1442. result := opts.IsAuthProxyUserCreationAllowed()
  1443. if result != expected {
  1444. t.Fatalf(`Unexpected AUTH_PROXY_USER_CREATION value, got %v instead of %v`, result, expected)
  1445. }
  1446. }
  1447. func TestAuthProxyUserCreationAdmin(t *testing.T) {
  1448. os.Clearenv()
  1449. os.Setenv("AUTH_PROXY_USER_CREATION", "1")
  1450. parser := NewParser()
  1451. opts, err := parser.ParseEnvironmentVariables()
  1452. if err != nil {
  1453. t.Fatalf(`Parsing failure: %v`, err)
  1454. }
  1455. expected := true
  1456. result := opts.IsAuthProxyUserCreationAllowed()
  1457. if result != expected {
  1458. t.Fatalf(`Unexpected AUTH_PROXY_USER_CREATION value, got %v instead of %v`, result, expected)
  1459. }
  1460. }
  1461. func TestFetchOdyseeWatchTime(t *testing.T) {
  1462. os.Clearenv()
  1463. os.Setenv("FETCH_ODYSEE_WATCH_TIME", "1")
  1464. parser := NewParser()
  1465. opts, err := parser.ParseEnvironmentVariables()
  1466. if err != nil {
  1467. t.Fatalf(`Parsing failure: %v`, err)
  1468. }
  1469. expected := true
  1470. result := opts.FetchOdyseeWatchTime()
  1471. if result != expected {
  1472. t.Fatalf(`Unexpected FETCH_ODYSEE_WATCH_TIME value, got %v instead of %v`, result, expected)
  1473. }
  1474. }
  1475. func TestFetchYouTubeWatchTime(t *testing.T) {
  1476. os.Clearenv()
  1477. os.Setenv("FETCH_YOUTUBE_WATCH_TIME", "1")
  1478. parser := NewParser()
  1479. opts, err := parser.ParseEnvironmentVariables()
  1480. if err != nil {
  1481. t.Fatalf(`Parsing failure: %v`, err)
  1482. }
  1483. expected := true
  1484. result := opts.FetchYouTubeWatchTime()
  1485. if result != expected {
  1486. t.Fatalf(`Unexpected FETCH_YOUTUBE_WATCH_TIME value, got %v instead of %v`, result, expected)
  1487. }
  1488. }
  1489. func TestYouTubeEmbedUrlOverride(t *testing.T) {
  1490. os.Clearenv()
  1491. os.Setenv("YOUTUBE_EMBED_URL_OVERRIDE", "https://invidious.custom/embed/")
  1492. parser := NewParser()
  1493. opts, err := parser.ParseEnvironmentVariables()
  1494. if err != nil {
  1495. t.Fatalf(`Parsing failure: %v`, err)
  1496. }
  1497. expected := "https://invidious.custom/embed/"
  1498. result := opts.YouTubeEmbedUrlOverride()
  1499. if result != expected {
  1500. t.Fatalf(`Unexpected YOUTUBE_EMBED_URL_OVERRIDE value, got %v instead of %v`, result, expected)
  1501. }
  1502. }
  1503. func TestParseConfigDumpOutput(t *testing.T) {
  1504. os.Clearenv()
  1505. wantOpts := NewOptions()
  1506. wantOpts.adminUsername = "my-username"
  1507. serialized := wantOpts.String()
  1508. tmpfile, err := os.CreateTemp(".", "miniflux.*.unit_test.conf")
  1509. if err != nil {
  1510. t.Fatal(err)
  1511. }
  1512. if _, err := tmpfile.Write([]byte(serialized)); err != nil {
  1513. t.Fatal(err)
  1514. }
  1515. parser := NewParser()
  1516. parsedOpts, err := parser.ParseFile(tmpfile.Name())
  1517. if err != nil {
  1518. t.Errorf(`Parsing failure: %v`, err)
  1519. }
  1520. if parsedOpts.AdminUsername() != wantOpts.AdminUsername() {
  1521. t.Fatalf(`Unexpected ADMIN_USERNAME value, got %q instead of %q`, parsedOpts.AdminUsername(), wantOpts.AdminUsername())
  1522. }
  1523. if err := tmpfile.Close(); err != nil {
  1524. t.Fatal(err)
  1525. }
  1526. if err := os.Remove(tmpfile.Name()); err != nil {
  1527. t.Fatal(err)
  1528. }
  1529. }