options_parsing_test.go 51 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688
  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 "testing"
  5. func TestBaseURLOptionParsing(t *testing.T) {
  6. configParser := NewConfigParser()
  7. if configParser.options.BaseURL() != "http://localhost" {
  8. t.Fatalf("Expected BASE_URL to be 'http://localhost' by default")
  9. }
  10. if configParser.options.RootURL() != "http://localhost" {
  11. t.Fatalf("Expected ROOT_URL to be 'http://localhost' by default")
  12. }
  13. if configParser.options.BasePath() != "" {
  14. t.Fatalf("Expected BASE_PATH to be empty by default")
  15. }
  16. if err := configParser.parseLines([]string{"BASE_URL=https://example.com/app"}); err != nil {
  17. t.Fatalf("Unexpected error: %v", err)
  18. }
  19. if configParser.options.BaseURL() != "https://example.com/app" {
  20. t.Fatalf("Expected BASE_URL to be 'https://example.com/app', got '%s'", configParser.options.BaseURL())
  21. }
  22. if configParser.options.RootURL() != "https://example.com" {
  23. t.Fatalf("Expected ROOT_URL to be 'https://example.com', got '%s'", configParser.options.RootURL())
  24. }
  25. if configParser.options.BasePath() != "/app" {
  26. t.Fatalf("Expected BASE_PATH to be '/app', got '%s'", configParser.options.BasePath())
  27. }
  28. if err := configParser.parseLines([]string{"BASE_URL=https://example.com/app/"}); err != nil {
  29. t.Fatalf("Unexpected error: %v", err)
  30. }
  31. if configParser.options.BaseURL() != "https://example.com/app" {
  32. t.Fatalf("Expected BASE_URL to be 'https://example.com/app', got '%s'", configParser.options.BaseURL())
  33. }
  34. if configParser.options.RootURL() != "https://example.com" {
  35. t.Fatalf("Expected ROOT_URL to be 'https://example.com', got '%s'", configParser.options.RootURL())
  36. }
  37. if configParser.options.BasePath() != "/app" {
  38. t.Fatalf("Expected BASE_PATH to be '/app', got '%s'", configParser.options.BasePath())
  39. }
  40. if err := configParser.parseLines([]string{"BASE_URL=example.com/app/"}); err == nil {
  41. t.Fatal("Expected an error due to missing scheme in BASE_URL")
  42. }
  43. }
  44. func TestWatchdogOptionParsing(t *testing.T) {
  45. configParser := NewConfigParser()
  46. if !configParser.options.Watchdog() {
  47. t.Fatal("Expected WATCHDOG to be enabled by default")
  48. }
  49. if !configParser.options.HasSchedulerService() {
  50. t.Fatal("Expected HAS_SCHEDULER_SERVICE to be enabled by default")
  51. }
  52. if err := configParser.parseLines([]string{"WATCHDOG=1"}); err != nil {
  53. t.Fatal("Unexpected error:", err)
  54. }
  55. if !configParser.options.Watchdog() {
  56. t.Fatal("Expected WATCHDOG to be enabled")
  57. }
  58. if !configParser.options.HasSchedulerService() {
  59. t.Fatal("Expected HAS_SCHEDULER_SERVICE to be enabled")
  60. }
  61. if err := configParser.parseLines([]string{"WATCHDOG=0"}); err != nil {
  62. t.Fatal("Unexpected error:", err)
  63. }
  64. if configParser.options.Watchdog() {
  65. t.Fatal("Expected WATCHDOG to be disabled")
  66. }
  67. if configParser.options.HasWatchdog() {
  68. t.Fatal("Expected HAS_WATCHDOG to be disabled")
  69. }
  70. }
  71. func TestWebAuthnOptionParsing(t *testing.T) {
  72. configParser := NewConfigParser()
  73. if configParser.options.WebAuthn() {
  74. t.Fatalf("Expected WEBAUTHN to be disabled by default")
  75. }
  76. if err := configParser.parseLines([]string{"WEBAUTHN=1"}); err != nil {
  77. t.Fatalf("Unexpected error: %v", err)
  78. }
  79. if !configParser.options.WebAuthn() {
  80. t.Fatalf("Expected WEBAUTHN to be enabled")
  81. }
  82. }
  83. func TestWorkerPoolSizeOptionParsing(t *testing.T) {
  84. configParser := NewConfigParser()
  85. if configParser.options.WorkerPoolSize() != 16 {
  86. t.Fatalf("Expected WORKER_POOL_SIZE to be 16 by default")
  87. }
  88. if err := configParser.parseLines([]string{"WORKER_POOL_SIZE=8"}); err != nil {
  89. t.Fatalf("Unexpected error: %v", err)
  90. }
  91. if configParser.options.WorkerPoolSize() != 8 {
  92. t.Fatalf("Expected WORKER_POOL_SIZE to be 8")
  93. }
  94. }
  95. func TestYouTubeAPIKeyOptionParsing(t *testing.T) {
  96. configParser := NewConfigParser()
  97. if configParser.options.YouTubeAPIKey() != "" {
  98. t.Fatalf("Expected YOUTUBE_API_KEY to be empty by default")
  99. }
  100. if err := configParser.parseLines([]string{"YOUTUBE_API_KEY=somekey"}); err != nil {
  101. t.Fatalf("Unexpected error: %v", err)
  102. }
  103. if configParser.options.YouTubeAPIKey() != "somekey" {
  104. t.Fatalf("Expected YOUTUBE_API_KEY to be 'somekey'")
  105. }
  106. }
  107. func TestAdminPasswordOptionParsing(t *testing.T) {
  108. configParser := NewConfigParser()
  109. if configParser.options.AdminPassword() != "" {
  110. t.Fatalf("Expected ADMIN_PASSWORD to be empty by default")
  111. }
  112. if err := configParser.parseLines([]string{"ADMIN_PASSWORD=secret123"}); err != nil {
  113. t.Fatalf("Unexpected error: %v", err)
  114. }
  115. if configParser.options.AdminPassword() != "secret123" {
  116. t.Fatalf("Expected ADMIN_PASSWORD to be 'secret123'")
  117. }
  118. }
  119. func TestAdminUsernameOptionParsing(t *testing.T) {
  120. configParser := NewConfigParser()
  121. if configParser.options.AdminUsername() != "" {
  122. t.Fatalf("Expected ADMIN_USERNAME to be empty by default")
  123. }
  124. if err := configParser.parseLines([]string{"ADMIN_USERNAME=admin"}); err != nil {
  125. t.Fatalf("Unexpected error: %v", err)
  126. }
  127. if configParser.options.AdminUsername() != "admin" {
  128. t.Fatalf("Expected ADMIN_USERNAME to be 'admin'")
  129. }
  130. }
  131. func TestAuthProxyHeaderOptionParsing(t *testing.T) {
  132. configParser := NewConfigParser()
  133. if configParser.options.AuthProxyHeader() != "" {
  134. t.Fatalf("Expected AUTH_PROXY_HEADER to be empty by default")
  135. }
  136. if err := configParser.parseLines([]string{"AUTH_PROXY_HEADER=X-Forwarded-User"}); err != nil {
  137. t.Fatalf("Unexpected error: %v", err)
  138. }
  139. if configParser.options.AuthProxyHeader() != "X-Forwarded-User" {
  140. t.Fatalf("Expected AUTH_PROXY_HEADER to be 'X-Forwarded-User'")
  141. }
  142. }
  143. func TestAuthProxyUserCreationOptionParsing(t *testing.T) {
  144. configParser := NewConfigParser()
  145. if configParser.options.AuthProxyUserCreation() {
  146. t.Fatal("Expected AUTH_PROXY_USER_CREATION to be disabled by default")
  147. }
  148. if configParser.options.IsAuthProxyUserCreationAllowed() {
  149. t.Fatal("Expected HAS_AUTH_PROXY_USER_CREATION to be disabled by default")
  150. }
  151. if err := configParser.parseLines([]string{"AUTH_PROXY_USER_CREATION=1"}); err != nil {
  152. t.Fatalf("Unexpected error: %v", err)
  153. }
  154. if !configParser.options.AuthProxyUserCreation() {
  155. t.Fatal("Expected AUTH_PROXY_USER_CREATION to be enabled")
  156. }
  157. if !configParser.options.IsAuthProxyUserCreationAllowed() {
  158. t.Fatal("Expected HAS_AUTH_PROXY_USER_CREATION to be enabled")
  159. }
  160. if err := configParser.parseLines([]string{"AUTH_PROXY_USER_CREATION=0"}); err != nil {
  161. t.Fatalf("Unexpected error: %v", err)
  162. }
  163. if configParser.options.AuthProxyUserCreation() {
  164. t.Fatal("Expected AUTH_PROXY_USER_CREATION to be disabled")
  165. }
  166. if configParser.options.IsAuthProxyUserCreationAllowed() {
  167. t.Fatal("Expected HAS_AUTH_PROXY_USER_CREATION to be disabled")
  168. }
  169. }
  170. func TestBatchSizeOptionParsing(t *testing.T) {
  171. configParser := NewConfigParser()
  172. if configParser.options.BatchSize() != 100 {
  173. t.Fatalf("Expected BATCH_SIZE to be 100 by default")
  174. }
  175. if err := configParser.parseLines([]string{"BATCH_SIZE=50"}); err != nil {
  176. t.Fatalf("Unexpected error: %v", err)
  177. }
  178. if configParser.options.BatchSize() != 50 {
  179. t.Fatalf("Expected BATCH_SIZE to be 50")
  180. }
  181. }
  182. func TestCertDomainOptionParsing(t *testing.T) {
  183. configParser := NewConfigParser()
  184. if configParser.options.CertDomain() != "" {
  185. t.Fatalf("Expected CERT_DOMAIN to be empty by default")
  186. }
  187. if err := configParser.parseLines([]string{"CERT_DOMAIN=example.com"}); err != nil {
  188. t.Fatalf("Unexpected error: %v", err)
  189. }
  190. if configParser.options.CertDomain() != "example.com" {
  191. t.Fatalf("Expected CERT_DOMAIN to be 'example.com'")
  192. }
  193. }
  194. func TestCertFileOptionParsing(t *testing.T) {
  195. configParser := NewConfigParser()
  196. if configParser.options.CertFile() != "" {
  197. t.Fatalf("Expected CERT_FILE to be empty by default")
  198. }
  199. if err := configParser.parseLines([]string{"CERT_FILE=/path/to/cert.pem"}); err != nil {
  200. t.Fatalf("Unexpected error: %v", err)
  201. }
  202. if configParser.options.CertFile() != "/path/to/cert.pem" {
  203. t.Fatalf("Expected CERT_FILE to be '/path/to/cert.pem'")
  204. }
  205. }
  206. func TestCleanupArchiveBatchSizeOptionParsing(t *testing.T) {
  207. configParser := NewConfigParser()
  208. if configParser.options.CleanupArchiveBatchSize() != 10000 {
  209. t.Fatalf("Expected CLEANUP_ARCHIVE_BATCH_SIZE to be 10000 by default")
  210. }
  211. if err := configParser.parseLines([]string{"CLEANUP_ARCHIVE_BATCH_SIZE=5000"}); err != nil {
  212. t.Fatalf("Unexpected error: %v", err)
  213. }
  214. if configParser.options.CleanupArchiveBatchSize() != 5000 {
  215. t.Fatalf("Expected CLEANUP_ARCHIVE_BATCH_SIZE to be 5000")
  216. }
  217. }
  218. func TestCreateAdminOptionParsing(t *testing.T) {
  219. configParser := NewConfigParser()
  220. if configParser.options.CreateAdmin() {
  221. t.Fatalf("Expected CREATE_ADMIN to be disabled by default")
  222. }
  223. if err := configParser.parseLines([]string{"CREATE_ADMIN=1"}); err != nil {
  224. t.Fatalf("Unexpected error: %v", err)
  225. }
  226. if !configParser.options.CreateAdmin() {
  227. t.Fatalf("Expected CREATE_ADMIN to be enabled")
  228. }
  229. if err := configParser.parseLines([]string{"CREATE_ADMIN=0"}); err != nil {
  230. t.Fatalf("Unexpected error: %v", err)
  231. }
  232. if configParser.options.CreateAdmin() {
  233. t.Fatalf("Expected CREATE_ADMIN to be disabled")
  234. }
  235. }
  236. func TestDatabaseMaxConnsOptionParsing(t *testing.T) {
  237. configParser := NewConfigParser()
  238. if configParser.options.DatabaseMaxConns() != 20 {
  239. t.Fatalf("Expected DATABASE_MAX_CONNS to be 20 by default")
  240. }
  241. if err := configParser.parseLines([]string{"DATABASE_MAX_CONNS=10"}); err != nil {
  242. t.Fatalf("Unexpected error: %v", err)
  243. }
  244. if configParser.options.DatabaseMaxConns() != 10 {
  245. t.Fatalf("Expected DATABASE_MAX_CONNS to be 10")
  246. }
  247. }
  248. func TestDatabaseMinConnsOptionParsing(t *testing.T) {
  249. configParser := NewConfigParser()
  250. if configParser.options.DatabaseMinConns() != 1 {
  251. t.Fatalf("Expected DATABASE_MIN_CONNS to be 1 by default")
  252. }
  253. if err := configParser.parseLines([]string{"DATABASE_MIN_CONNS=2"}); err != nil {
  254. t.Fatalf("Unexpected error: %v", err)
  255. }
  256. if configParser.options.DatabaseMinConns() != 2 {
  257. t.Fatalf("Expected DATABASE_MIN_CONNS to be 2")
  258. }
  259. }
  260. func TestDatabaseURLOptionParsing(t *testing.T) {
  261. configParser := NewConfigParser()
  262. if configParser.options.DatabaseURL() != "user=postgres password=postgres dbname=miniflux2 sslmode=disable" {
  263. t.Fatal("Expected DATABASE_URL to have default value")
  264. }
  265. if !configParser.options.IsDefaultDatabaseURL() {
  266. t.Fatal("Expected DATABASE_URL to be the default value")
  267. }
  268. if err := configParser.parseLines([]string{"DATABASE_URL=postgres://user:pass@localhost/db"}); err != nil {
  269. t.Fatalf("Unexpected error: %v", err)
  270. }
  271. if configParser.options.DatabaseURL() != "postgres://user:pass@localhost/db" {
  272. t.Fatal("Expected DATABASE_URL to be 'postgres://user:pass@localhost/db'")
  273. }
  274. if configParser.options.IsDefaultDatabaseURL() {
  275. t.Fatal("Expected DATABASE_URL to not be the default value")
  276. }
  277. }
  278. func TestDisableHSTSOptionParsing(t *testing.T) {
  279. configParser := NewConfigParser()
  280. if configParser.options.DisableHSTS() {
  281. t.Fatal("Expected DISABLE_HSTS to be disabled by default")
  282. }
  283. if !configParser.options.HasHSTS() {
  284. t.Fatal("Expected HAS_HSTS to be enabled by default")
  285. }
  286. if err := configParser.parseLines([]string{"DISABLE_HSTS=1"}); err != nil {
  287. t.Fatalf("Unexpected error: %v", err)
  288. }
  289. if !configParser.options.DisableHSTS() {
  290. t.Fatal("Expected DISABLE_HSTS to be enabled")
  291. }
  292. if configParser.options.HasHSTS() {
  293. t.Fatal("Expected HAS_HSTS to be disabled")
  294. }
  295. if err := configParser.parseLines([]string{"DISABLE_HSTS=0"}); err != nil {
  296. t.Fatalf("Unexpected error: %v", err)
  297. }
  298. if configParser.options.DisableHSTS() {
  299. t.Fatal("Expected DISABLE_HSTS to be disabled")
  300. }
  301. if !configParser.options.HasHSTS() {
  302. t.Fatal("Expected HAS_HSTS to be enabled")
  303. }
  304. }
  305. func TestDisableHTTPServiceOptionParsing(t *testing.T) {
  306. configParser := NewConfigParser()
  307. if configParser.options.DisableHTTPService() {
  308. t.Fatal("Expected DISABLE_HTTP_SERVICE to be disabled by default")
  309. }
  310. if !configParser.options.HasHTTPService() {
  311. t.Fatal("Expected HAS_HTTP_SERVICE to be enabled by default")
  312. }
  313. if err := configParser.parseLines([]string{"DISABLE_HTTP_SERVICE=1"}); err != nil {
  314. t.Fatalf("Unexpected error: %v", err)
  315. }
  316. if !configParser.options.DisableHTTPService() {
  317. t.Fatal("Expected DISABLE_HTTP_SERVICE to be enabled")
  318. }
  319. if configParser.options.HasHTTPService() {
  320. t.Fatal("Expected HAS_HTTP_SERVICE to be disabled")
  321. }
  322. if err := configParser.parseLines([]string{"DISABLE_HTTP_SERVICE=0"}); err != nil {
  323. t.Fatalf("Unexpected error: %v", err)
  324. }
  325. if configParser.options.DisableHTTPService() {
  326. t.Fatal("Expected DISABLE_HTTP_SERVICE to be disabled")
  327. }
  328. if !configParser.options.HasHTTPService() {
  329. t.Fatal("Expected HAS_HTTP_SERVICE to be disabled")
  330. }
  331. }
  332. func TestDisableLocalAuthOptionParsing(t *testing.T) {
  333. configParser := NewConfigParser()
  334. if configParser.options.DisableLocalAuth() {
  335. t.Fatalf("Expected DISABLE_LOCAL_AUTH to be disabled by default")
  336. }
  337. if err := configParser.parseLines([]string{"DISABLE_LOCAL_AUTH=1"}); err != nil {
  338. t.Fatalf("Unexpected error: %v", err)
  339. }
  340. if !configParser.options.DisableLocalAuth() {
  341. t.Fatalf("Expected DISABLE_LOCAL_AUTH to be enabled")
  342. }
  343. if err := configParser.parseLines([]string{"DISABLE_LOCAL_AUTH=0"}); err != nil {
  344. t.Fatalf("Unexpected error: %v", err)
  345. }
  346. if configParser.options.DisableLocalAuth() {
  347. t.Fatalf("Expected DISABLE_LOCAL_AUTH to be disabled")
  348. }
  349. }
  350. func TestDisableSchedulerServiceOptionParsing(t *testing.T) {
  351. configParser := NewConfigParser()
  352. if configParser.options.DisableSchedulerService() {
  353. t.Fatal("Expected DISABLE_SCHEDULER_SERVICE to be disabled by default")
  354. }
  355. if !configParser.options.HasSchedulerService() {
  356. t.Fatal("Expected HAS_SCHEDULER_SERVICE to be enabled by default")
  357. }
  358. if err := configParser.parseLines([]string{"DISABLE_SCHEDULER_SERVICE=1"}); err != nil {
  359. t.Fatalf("Unexpected error: %v", err)
  360. }
  361. if !configParser.options.DisableSchedulerService() {
  362. t.Fatal("Expected DISABLE_SCHEDULER_SERVICE to be enabled")
  363. }
  364. if configParser.options.HasSchedulerService() {
  365. t.Fatal("Expected HAS_SCHEDULER_SERVICE to be disabled")
  366. }
  367. if err := configParser.parseLines([]string{"DISABLE_SCHEDULER_SERVICE=0"}); err != nil {
  368. t.Fatalf("Unexpected error: %v", err)
  369. }
  370. if configParser.options.DisableSchedulerService() {
  371. t.Fatal("Expected DISABLE_SCHEDULER_SERVICE to be disabled")
  372. }
  373. if !configParser.options.HasSchedulerService() {
  374. t.Fatal("Expected HAS_SCHEDULER_SERVICE to be enabled")
  375. }
  376. }
  377. func TestFetchBilibiliWatchTimeOptionParsing(t *testing.T) {
  378. configParser := NewConfigParser()
  379. if configParser.options.FetchBilibiliWatchTime() {
  380. t.Fatalf("Expected FETCH_BILIBILI_WATCH_TIME to be disabled by default")
  381. }
  382. if err := configParser.parseLines([]string{"FETCH_BILIBILI_WATCH_TIME=1"}); err != nil {
  383. t.Fatalf("Unexpected error: %v", err)
  384. }
  385. if !configParser.options.FetchBilibiliWatchTime() {
  386. t.Fatalf("Expected FETCH_BILIBILI_WATCH_TIME to be enabled")
  387. }
  388. if err := configParser.parseLines([]string{"FETCH_BILIBILI_WATCH_TIME=0"}); err != nil {
  389. t.Fatalf("Unexpected error: %v", err)
  390. }
  391. if configParser.options.FetchBilibiliWatchTime() {
  392. t.Fatalf("Expected FETCH_BILIBILI_WATCH_TIME to be disabled")
  393. }
  394. }
  395. func TestFetchNebulaWatchTimeOptionParsing(t *testing.T) {
  396. configParser := NewConfigParser()
  397. if configParser.options.FetchNebulaWatchTime() {
  398. t.Fatalf("Expected FETCH_NEBULA_WATCH_TIME to be disabled by default")
  399. }
  400. if err := configParser.parseLines([]string{"FETCH_NEBULA_WATCH_TIME=1"}); err != nil {
  401. t.Fatalf("Unexpected error: %v", err)
  402. }
  403. if !configParser.options.FetchNebulaWatchTime() {
  404. t.Fatalf("Expected FETCH_NEBULA_WATCH_TIME to be enabled")
  405. }
  406. if err := configParser.parseLines([]string{"FETCH_NEBULA_WATCH_TIME=0"}); err != nil {
  407. t.Fatalf("Unexpected error: %v", err)
  408. }
  409. if configParser.options.FetchNebulaWatchTime() {
  410. t.Fatalf("Expected FETCH_NEBULA_WATCH_TIME to be disabled")
  411. }
  412. }
  413. func TestFetchOdyseeWatchTimeOptionParsing(t *testing.T) {
  414. configParser := NewConfigParser()
  415. if configParser.options.FetchOdyseeWatchTime() {
  416. t.Fatalf("Expected FETCH_ODYSEE_WATCH_TIME to be disabled by default")
  417. }
  418. if err := configParser.parseLines([]string{"FETCH_ODYSEE_WATCH_TIME=1"}); err != nil {
  419. t.Fatalf("Unexpected error: %v", err)
  420. }
  421. if !configParser.options.FetchOdyseeWatchTime() {
  422. t.Fatalf("Expected FETCH_ODYSEE_WATCH_TIME to be enabled")
  423. }
  424. if err := configParser.parseLines([]string{"FETCH_ODYSEE_WATCH_TIME=0"}); err != nil {
  425. t.Fatalf("Unexpected error: %v", err)
  426. }
  427. if configParser.options.FetchOdyseeWatchTime() {
  428. t.Fatalf("Expected FETCH_ODYSEE_WATCH_TIME to be disabled")
  429. }
  430. }
  431. func TestFetchYouTubeWatchTimeOptionParsing(t *testing.T) {
  432. configParser := NewConfigParser()
  433. if configParser.options.FetchYouTubeWatchTime() {
  434. t.Fatalf("Expected FETCH_YOUTUBE_WATCH_TIME to be disabled by default")
  435. }
  436. if err := configParser.parseLines([]string{"FETCH_YOUTUBE_WATCH_TIME=1"}); err != nil {
  437. t.Fatalf("Unexpected error: %v", err)
  438. }
  439. if !configParser.options.FetchYouTubeWatchTime() {
  440. t.Fatalf("Expected FETCH_YOUTUBE_WATCH_TIME to be enabled")
  441. }
  442. if err := configParser.parseLines([]string{"FETCH_YOUTUBE_WATCH_TIME=0"}); err != nil {
  443. t.Fatalf("Unexpected error: %v", err)
  444. }
  445. if configParser.options.FetchYouTubeWatchTime() {
  446. t.Fatalf("Expected FETCH_YOUTUBE_WATCH_TIME to be disabled")
  447. }
  448. }
  449. func TestHTTPClientMaxBodySizeOptionParsing(t *testing.T) {
  450. configParser := NewConfigParser()
  451. if configParser.options.HTTPClientMaxBodySize() != 15*1024*1024 {
  452. t.Fatalf("Expected HTTP_CLIENT_MAX_BODY_SIZE to be 15 by default, got %d", configParser.options.HTTPClientMaxBodySize())
  453. }
  454. if err := configParser.parseLines([]string{"HTTP_CLIENT_MAX_BODY_SIZE=25"}); err != nil {
  455. t.Fatalf("Unexpected error: %v", err)
  456. }
  457. expectedValue := 25 * 1024 * 1024
  458. currentValue := configParser.options.HTTPClientMaxBodySize()
  459. if currentValue != int64(expectedValue) {
  460. t.Fatalf("Expected HTTP_CLIENT_MAX_BODY_SIZE to be %d, got %d", expectedValue, currentValue)
  461. }
  462. }
  463. func TestHTTPClientUserAgentOptionParsing(t *testing.T) {
  464. configParser := NewConfigParser()
  465. if configParser.options.HTTPClientUserAgent() != defaultHTTPClientUserAgent {
  466. t.Fatalf("Expected HTTP_CLIENT_USER_AGENT to have default value")
  467. }
  468. if err := configParser.parseLines([]string{"HTTP_CLIENT_USER_AGENT=Custom User Agent"}); err != nil {
  469. t.Fatalf("Unexpected error: %v", err)
  470. }
  471. if configParser.options.HTTPClientUserAgent() != "Custom User Agent" {
  472. t.Fatalf("Expected HTTP_CLIENT_USER_AGENT to be 'Custom User Agent'")
  473. }
  474. }
  475. func TestHTTPSOptionParsing(t *testing.T) {
  476. configParser := NewConfigParser()
  477. if configParser.options.HTTPS() {
  478. t.Fatalf("Expected HTTPS to be disabled by default")
  479. }
  480. if err := configParser.parseLines([]string{"HTTPS=1"}); err != nil {
  481. t.Fatalf("Unexpected error: %v", err)
  482. }
  483. if !configParser.options.HTTPS() {
  484. t.Fatalf("Expected HTTPS to be enabled")
  485. }
  486. if err := configParser.parseLines([]string{"HTTPS=0"}); err != nil {
  487. t.Fatalf("Unexpected error: %v", err)
  488. }
  489. if configParser.options.HTTPS() {
  490. t.Fatalf("Expected HTTPS to be disabled")
  491. }
  492. }
  493. func TestInvidiousInstanceOptionParsing(t *testing.T) {
  494. configParser := NewConfigParser()
  495. if configParser.options.InvidiousInstance() != "yewtu.be" {
  496. t.Fatalf("Expected INVIDIOUS_INSTANCE to be 'yewtu.be' by default")
  497. }
  498. if err := configParser.parseLines([]string{"INVIDIOUS_INSTANCE=invidious.example.com"}); err != nil {
  499. t.Fatalf("Unexpected error: %v", err)
  500. }
  501. if configParser.options.InvidiousInstance() != "invidious.example.com" {
  502. t.Fatalf("Expected INVIDIOUS_INSTANCE to be 'invidious.example.com'")
  503. }
  504. }
  505. func TestCertKeyFileOptionParsing(t *testing.T) {
  506. configParser := NewConfigParser()
  507. if configParser.options.CertKeyFile() != "" {
  508. t.Fatalf("Expected KEY_FILE to be empty by default")
  509. }
  510. if err := configParser.parseLines([]string{"KEY_FILE=/path/to/key.pem"}); err != nil {
  511. t.Fatalf("Unexpected error: %v", err)
  512. }
  513. if configParser.options.CertKeyFile() != "/path/to/key.pem" {
  514. t.Fatalf("Expected KEY_FILE to be '/path/to/key.pem'")
  515. }
  516. }
  517. func TestLogDateTimeOptionParsing(t *testing.T) {
  518. configParser := NewConfigParser()
  519. if configParser.options.LogDateTime() {
  520. t.Fatalf("Expected LOG_DATE_TIME to be disabled by default")
  521. }
  522. if err := configParser.parseLines([]string{"LOG_DATE_TIME=1"}); err != nil {
  523. t.Fatalf("Unexpected error: %v", err)
  524. }
  525. if !configParser.options.LogDateTime() {
  526. t.Fatalf("Expected LOG_DATE_TIME to be enabled")
  527. }
  528. if err := configParser.parseLines([]string{"LOG_DATE_TIME=0"}); err != nil {
  529. t.Fatalf("Unexpected error: %v", err)
  530. }
  531. if configParser.options.LogDateTime() {
  532. t.Fatalf("Expected LOG_DATE_TIME to be disabled")
  533. }
  534. }
  535. func TestLogFileOptionParsing(t *testing.T) {
  536. configParser := NewConfigParser()
  537. if configParser.options.LogFile() != "stderr" {
  538. t.Fatalf("Expected LOG_FILE to be 'stderr' by default")
  539. }
  540. if err := configParser.parseLines([]string{"LOG_FILE=/var/log/miniflux.log"}); err != nil {
  541. t.Fatalf("Unexpected error: %v", err)
  542. }
  543. if configParser.options.LogFile() != "/var/log/miniflux.log" {
  544. t.Fatalf("Expected LOG_FILE to be '/var/log/miniflux.log'")
  545. }
  546. }
  547. func TestLogFormatOptionParsing(t *testing.T) {
  548. configParser := NewConfigParser()
  549. if configParser.options.LogFormat() != "text" {
  550. t.Fatalf("Expected LOG_FORMAT to be 'text' by default")
  551. }
  552. if err := configParser.parseLines([]string{"LOG_FORMAT=json"}); err != nil {
  553. t.Fatalf("Unexpected error: %v", err)
  554. }
  555. if configParser.options.LogFormat() != "json" {
  556. t.Fatalf("Expected LOG_FORMAT to be 'json'")
  557. }
  558. }
  559. func TestLogLevelOptionParsing(t *testing.T) {
  560. configParser := NewConfigParser()
  561. if configParser.options.LogLevel() != "info" {
  562. t.Fatalf("Expected LOG_LEVEL to be 'info' by default")
  563. }
  564. if err := configParser.parseLines([]string{"LOG_LEVEL=debug"}); err != nil {
  565. t.Fatalf("Unexpected error: %v", err)
  566. }
  567. if configParser.options.LogLevel() != "debug" {
  568. t.Fatalf("Expected LOG_LEVEL to be 'debug'")
  569. }
  570. }
  571. func TestMaintenanceMessageOptionParsing(t *testing.T) {
  572. configParser := NewConfigParser()
  573. if configParser.options.MaintenanceMessage() != "Miniflux is currently under maintenance" {
  574. t.Fatalf("Expected MAINTENANCE_MESSAGE to have default value")
  575. }
  576. if err := configParser.parseLines([]string{"MAINTENANCE_MESSAGE=System upgrade in progress"}); err != nil {
  577. t.Fatalf("Unexpected error: %v", err)
  578. }
  579. if configParser.options.MaintenanceMessage() != "System upgrade in progress" {
  580. t.Fatalf("Expected MAINTENANCE_MESSAGE to be 'System upgrade in progress'")
  581. }
  582. }
  583. func TestMaintenanceModeOptionParsing(t *testing.T) {
  584. configParser := NewConfigParser()
  585. if configParser.options.MaintenanceMode() {
  586. t.Fatal("Expected MAINTENANCE_MODE to be disabled by default")
  587. }
  588. if configParser.options.HasMaintenanceMode() {
  589. t.Fatal("Expected HAS_MAINTENANCE_MODE to be disabled by default")
  590. }
  591. if err := configParser.parseLines([]string{"MAINTENANCE_MODE=1"}); err != nil {
  592. t.Fatalf("Unexpected error: %v", err)
  593. }
  594. if !configParser.options.MaintenanceMode() {
  595. t.Fatal("Expected MAINTENANCE_MODE to be enabled")
  596. }
  597. if !configParser.options.HasMaintenanceMode() {
  598. t.Fatal("Expected HAS_MAINTENANCE_MODE to be enabled")
  599. }
  600. if err := configParser.parseLines([]string{"MAINTENANCE_MODE=0"}); err != nil {
  601. t.Fatalf("Unexpected error: %v", err)
  602. }
  603. if configParser.options.MaintenanceMode() {
  604. t.Fatal("Expected MAINTENANCE_MODE to be disabled")
  605. }
  606. if configParser.options.HasMaintenanceMode() {
  607. t.Fatal("Expected HAS_MAINTENANCE_MODE to be disabled")
  608. }
  609. }
  610. func TestMediaProxyModeOptionParsing(t *testing.T) {
  611. configParser := NewConfigParser()
  612. if configParser.options.MediaProxyMode() != "http-only" {
  613. t.Fatalf("Expected MEDIA_PROXY_MODE to be 'http-only' by default")
  614. }
  615. if err := configParser.parseLines([]string{"MEDIA_PROXY_MODE=all"}); err != nil {
  616. t.Fatalf("Unexpected error: %v", err)
  617. }
  618. if configParser.options.MediaProxyMode() != "all" {
  619. t.Fatalf("Expected MEDIA_PROXY_MODE to be 'all'")
  620. }
  621. }
  622. func TestMetricsCollectorOptionParsing(t *testing.T) {
  623. configParser := NewConfigParser()
  624. if configParser.options.MetricsCollector() {
  625. t.Fatal("Expected METRICS_COLLECTOR to be disabled by default")
  626. }
  627. if configParser.options.HasMetricsCollector() {
  628. t.Fatal("Expected HAS_METRICS_COLLECTOR to be disabled by default")
  629. }
  630. if err := configParser.parseLines([]string{"METRICS_COLLECTOR=1"}); err != nil {
  631. t.Fatalf("Unexpected error: %v", err)
  632. }
  633. if !configParser.options.MetricsCollector() {
  634. t.Fatal("Expected METRICS_COLLECTOR to be enabled")
  635. }
  636. if !configParser.options.HasMetricsCollector() {
  637. t.Fatal("Expected HAS_METRICS_COLLECTOR to be enabled")
  638. }
  639. if err := configParser.parseLines([]string{"METRICS_COLLECTOR=0"}); err != nil {
  640. t.Fatalf("Unexpected error: %v", err)
  641. }
  642. if configParser.options.MetricsCollector() {
  643. t.Fatal("Expected METRICS_COLLECTOR to be disabled")
  644. }
  645. if configParser.options.HasMetricsCollector() {
  646. t.Fatal("Expected HAS_METRICS_COLLECTOR to be disabled")
  647. }
  648. }
  649. func TestMetricsPasswordOptionParsing(t *testing.T) {
  650. configParser := NewConfigParser()
  651. if configParser.options.MetricsPassword() != "" {
  652. t.Fatalf("Expected METRICS_PASSWORD to be empty by default")
  653. }
  654. if err := configParser.parseLines([]string{"METRICS_PASSWORD=secret123"}); err != nil {
  655. t.Fatalf("Unexpected error: %v", err)
  656. }
  657. if configParser.options.MetricsPassword() != "secret123" {
  658. t.Fatalf("Expected METRICS_PASSWORD to be 'secret123'")
  659. }
  660. }
  661. func TestMetricsUsernameOptionParsing(t *testing.T) {
  662. configParser := NewConfigParser()
  663. if configParser.options.MetricsUsername() != "" {
  664. t.Fatalf("Expected METRICS_USERNAME to be empty by default")
  665. }
  666. if err := configParser.parseLines([]string{"METRICS_USERNAME=metrics_user"}); err != nil {
  667. t.Fatalf("Unexpected error: %v", err)
  668. }
  669. if configParser.options.MetricsUsername() != "metrics_user" {
  670. t.Fatalf("Expected METRICS_USERNAME to be 'metrics_user'")
  671. }
  672. }
  673. func TestOAuth2ClientIDOptionParsing(t *testing.T) {
  674. configParser := NewConfigParser()
  675. if configParser.options.OAuth2ClientID() != "" {
  676. t.Fatalf("Expected OAUTH2_CLIENT_ID to be empty by default")
  677. }
  678. if err := configParser.parseLines([]string{"OAUTH2_CLIENT_ID=client123"}); err != nil {
  679. t.Fatalf("Unexpected error: %v", err)
  680. }
  681. if configParser.options.OAuth2ClientID() != "client123" {
  682. t.Fatalf("Expected OAUTH2_CLIENT_ID to be 'client123'")
  683. }
  684. }
  685. func TestOAuth2ClientSecretOptionParsing(t *testing.T) {
  686. configParser := NewConfigParser()
  687. if configParser.options.OAuth2ClientSecret() != "" {
  688. t.Fatalf("Expected OAUTH2_CLIENT_SECRET to be empty by default")
  689. }
  690. if err := configParser.parseLines([]string{"OAUTH2_CLIENT_SECRET=secret456"}); err != nil {
  691. t.Fatalf("Unexpected error: %v", err)
  692. }
  693. if configParser.options.OAuth2ClientSecret() != "secret456" {
  694. t.Fatalf("Expected OAUTH2_CLIENT_SECRET to be 'secret456'")
  695. }
  696. }
  697. func TestOAuth2OIDCDiscoveryEndpointOptionParsing(t *testing.T) {
  698. configParser := NewConfigParser()
  699. if configParser.options.OAuth2OIDCDiscoveryEndpoint() != "" {
  700. t.Fatalf("Expected OAUTH2_OIDC_DISCOVERY_ENDPOINT to be empty by default")
  701. }
  702. if err := configParser.parseLines([]string{"OAUTH2_OIDC_DISCOVERY_ENDPOINT=https://example.com/.well-known/openid_configuration"}); err != nil {
  703. t.Fatalf("Unexpected error: %v", err)
  704. }
  705. if configParser.options.OAuth2OIDCDiscoveryEndpoint() != "https://example.com/.well-known/openid_configuration" {
  706. t.Fatalf("Expected OAUTH2_OIDC_DISCOVERY_ENDPOINT to be 'https://example.com/.well-known/openid_configuration'")
  707. }
  708. }
  709. func TestOAuth2OIDCProviderNameOptionParsing(t *testing.T) {
  710. configParser := NewConfigParser()
  711. if configParser.options.OAuth2OIDCProviderName() != "OpenID Connect" {
  712. t.Fatalf("Expected OAUTH2_OIDC_PROVIDER_NAME to be 'OpenID Connect' by default")
  713. }
  714. if err := configParser.parseLines([]string{"OAUTH2_OIDC_PROVIDER_NAME=My Provider"}); err != nil {
  715. t.Fatalf("Unexpected error: %v", err)
  716. }
  717. if configParser.options.OAuth2OIDCProviderName() != "My Provider" {
  718. t.Fatalf("Expected OAUTH2_OIDC_PROVIDER_NAME to be 'My Provider'")
  719. }
  720. }
  721. func TestOAuth2ProviderOptionParsing(t *testing.T) {
  722. configParser := NewConfigParser()
  723. if configParser.options.OAuth2Provider() != "" {
  724. t.Fatal("Expected OAUTH2_PROVIDER to be empty by default")
  725. }
  726. if err := configParser.parseLines([]string{"OAUTH2_PROVIDER=google"}); err != nil {
  727. t.Fatalf("Unexpected error: %v", err)
  728. }
  729. if configParser.options.OAuth2Provider() != "google" {
  730. t.Fatal("Expected OAUTH2_PROVIDER to be 'google'")
  731. }
  732. if err := configParser.parseLines([]string{"OAUTH2_PROVIDER=oidc"}); err != nil {
  733. t.Fatalf("Unexpected error: %v", err)
  734. }
  735. if configParser.options.OAuth2Provider() != "oidc" {
  736. t.Fatal("Expected OAUTH2_PROVIDER to be 'oidc'")
  737. }
  738. if err := configParser.parseLines([]string{"OAUTH2_PROVIDER=invalid"}); err == nil {
  739. t.Fatal("Expected error for invalid OAUTH2_PROVIDER value")
  740. }
  741. }
  742. func TestOAuth2RedirectURLOptionParsing(t *testing.T) {
  743. configParser := NewConfigParser()
  744. if configParser.options.OAuth2RedirectURL() != "" {
  745. t.Fatalf("Expected OAUTH2_REDIRECT_URL to be empty by default")
  746. }
  747. if err := configParser.parseLines([]string{"OAUTH2_REDIRECT_URL=https://example.com/callback"}); err != nil {
  748. t.Fatalf("Unexpected error: %v", err)
  749. }
  750. if configParser.options.OAuth2RedirectURL() != "https://example.com/callback" {
  751. t.Fatalf("Expected OAUTH2_REDIRECT_URL to be 'https://example.com/callback'")
  752. }
  753. }
  754. func TestOAuth2UserCreationOptionParsing(t *testing.T) {
  755. configParser := NewConfigParser()
  756. if configParser.options.OAuth2UserCreation() {
  757. t.Fatal("Expected OAUTH2_USER_CREATION to be disabled by default")
  758. }
  759. if configParser.options.IsOAuth2UserCreationAllowed() {
  760. t.Fatal("Expected OAUTH2_USER_CREATION to be disabled by default")
  761. }
  762. if err := configParser.parseLines([]string{"OAUTH2_USER_CREATION=1"}); err != nil {
  763. t.Fatalf("Unexpected error: %v", err)
  764. }
  765. if !configParser.options.OAuth2UserCreation() {
  766. t.Fatal("Expected OAUTH2_USER_CREATION to be enabled")
  767. }
  768. if !configParser.options.IsOAuth2UserCreationAllowed() {
  769. t.Fatal("Expected OAUTH2_USER_CREATION to be enabled")
  770. }
  771. if err := configParser.parseLines([]string{"OAUTH2_USER_CREATION=0"}); err != nil {
  772. t.Fatalf("Unexpected error: %v", err)
  773. }
  774. if configParser.options.OAuth2UserCreation() {
  775. t.Fatal("Expected OAUTH2_USER_CREATION to be disabled")
  776. }
  777. if configParser.options.IsOAuth2UserCreationAllowed() {
  778. t.Fatal("Expected OAUTH2_USER_CREATION to be disabled")
  779. }
  780. }
  781. func TestPollingLimitPerHostOptionParsing(t *testing.T) {
  782. configParser := NewConfigParser()
  783. if configParser.options.PollingLimitPerHost() != 0 {
  784. t.Fatalf("Expected POLLING_LIMIT_PER_HOST to be 0 by default")
  785. }
  786. if err := configParser.parseLines([]string{"POLLING_LIMIT_PER_HOST=5"}); err != nil {
  787. t.Fatalf("Unexpected error: %v", err)
  788. }
  789. if configParser.options.PollingLimitPerHost() != 5 {
  790. t.Fatalf("Expected POLLING_LIMIT_PER_HOST to be 5")
  791. }
  792. }
  793. func TestPollingParsingErrorLimitOptionParsing(t *testing.T) {
  794. configParser := NewConfigParser()
  795. if configParser.options.PollingParsingErrorLimit() != 3 {
  796. t.Fatalf("Expected POLLING_PARSING_ERROR_LIMIT to be 3 by default")
  797. }
  798. if err := configParser.parseLines([]string{"POLLING_PARSING_ERROR_LIMIT=5"}); err != nil {
  799. t.Fatalf("Unexpected error: %v", err)
  800. }
  801. if configParser.options.PollingParsingErrorLimit() != 5 {
  802. t.Fatalf("Expected POLLING_PARSING_ERROR_LIMIT to be 5")
  803. }
  804. }
  805. func TestPollingSchedulerOptionParsing(t *testing.T) {
  806. configParser := NewConfigParser()
  807. if configParser.options.PollingScheduler() != "round_robin" {
  808. t.Fatalf("Expected POLLING_SCHEDULER to be 'round_robin' by default")
  809. }
  810. if err := configParser.parseLines([]string{"POLLING_SCHEDULER=entry_frequency"}); err != nil {
  811. t.Fatalf("Unexpected error: %v", err)
  812. }
  813. if configParser.options.PollingScheduler() != "entry_frequency" {
  814. t.Fatalf("Expected POLLING_SCHEDULER to be 'entry_frequency'")
  815. }
  816. }
  817. func TestPortOptionParsing(t *testing.T) {
  818. configParser := NewConfigParser()
  819. if configParser.options.Port() != "" {
  820. t.Fatalf("Expected PORT to be empty by default")
  821. }
  822. if err := configParser.parseLines([]string{"PORT=1234"}); err != nil {
  823. t.Fatalf("Unexpected error: %v", err)
  824. }
  825. if configParser.options.Port() != "1234" {
  826. t.Fatalf("Expected PORT to be '1234'")
  827. }
  828. addresses := configParser.options.ListenAddr()
  829. if len(addresses) != 1 || addresses[0] != ":1234" {
  830. t.Fatalf("Expected LISTEN_ADDR to be ':1234'")
  831. }
  832. }
  833. func TestRunMigrationsOptionParsing(t *testing.T) {
  834. configParser := NewConfigParser()
  835. if configParser.options.RunMigrations() {
  836. t.Fatalf("Expected RUN_MIGRATIONS to be disabled by default")
  837. }
  838. if err := configParser.parseLines([]string{"RUN_MIGRATIONS=1"}); err != nil {
  839. t.Fatalf("Unexpected error: %v", err)
  840. }
  841. if !configParser.options.RunMigrations() {
  842. t.Fatalf("Expected RUN_MIGRATIONS to be enabled")
  843. }
  844. if err := configParser.parseLines([]string{"RUN_MIGRATIONS=0"}); err != nil {
  845. t.Fatalf("Unexpected error: %v", err)
  846. }
  847. if configParser.options.RunMigrations() {
  848. t.Fatalf("Expected RUN_MIGRATIONS to be disabled")
  849. }
  850. }
  851. func TestSchedulerEntryFrequencyFactorOptionParsing(t *testing.T) {
  852. configParser := NewConfigParser()
  853. if configParser.options.SchedulerEntryFrequencyFactor() != 1 {
  854. t.Fatalf("Expected SCHEDULER_ENTRY_FREQUENCY_FACTOR to be 1 by default")
  855. }
  856. if err := configParser.parseLines([]string{"SCHEDULER_ENTRY_FREQUENCY_FACTOR=2"}); err != nil {
  857. t.Fatalf("Unexpected error: %v", err)
  858. }
  859. if configParser.options.SchedulerEntryFrequencyFactor() != 2 {
  860. t.Fatalf("Expected SCHEDULER_ENTRY_FREQUENCY_FACTOR to be 2")
  861. }
  862. }
  863. func TestYouTubeEmbedUrlOverrideOptionParsing(t *testing.T) {
  864. configParser := NewConfigParser()
  865. // Test default value
  866. if configParser.options.YouTubeEmbedUrlOverride() != "https://www.youtube-nocookie.com/embed/" {
  867. t.Fatal("Expected YOUTUBE_EMBED_URL_OVERRIDE to have default value")
  868. }
  869. if configParser.options.YouTubeEmbedDomain() != "www.youtube-nocookie.com" {
  870. t.Fatal("Expected YOUTUBE_EMBED_DOMAIN to be 'www.youtube-nocookie.com' by default")
  871. }
  872. // Test custom value
  873. if err := configParser.parseLines([]string{"YOUTUBE_EMBED_URL_OVERRIDE=https://custom.youtube.com/embed/"}); err != nil {
  874. t.Fatalf("Unexpected error: %v", err)
  875. }
  876. if configParser.options.YouTubeEmbedUrlOverride() != "https://custom.youtube.com/embed/" {
  877. t.Fatal("Expected YOUTUBE_EMBED_URL_OVERRIDE to be 'https://custom.youtube.com/embed/'")
  878. }
  879. if configParser.options.YouTubeEmbedDomain() != "custom.youtube.com" {
  880. t.Fatal("Expected YOUTUBE_EMBED_DOMAIN to be 'custom.youtube.com'")
  881. }
  882. // Test empty value resets to default
  883. configParser = NewConfigParser()
  884. if err := configParser.parseLines([]string{"YOUTUBE_EMBED_URL_OVERRIDE="}); err != nil {
  885. t.Fatalf("Unexpected error: %v", err)
  886. }
  887. if configParser.options.YouTubeEmbedUrlOverride() != "https://www.youtube-nocookie.com/embed/" {
  888. t.Fatal("Expected YOUTUBE_EMBED_URL_OVERRIDE to have default value")
  889. }
  890. // Test invalid value
  891. configParser = NewConfigParser()
  892. if err := configParser.parseLines([]string{"YOUTUBE_EMBED_URL_OVERRIDE=http://example.com/%"}); err == nil {
  893. t.Fatal("Expected error for invalid YOUTUBE_EMBED_URL_OVERRIDE")
  894. }
  895. }
  896. func TestCleanupArchiveReadIntervalOptionParsing(t *testing.T) {
  897. configParser := NewConfigParser()
  898. if configParser.options.CleanupArchiveReadInterval().Hours() != 24*60 {
  899. t.Fatalf("Expected CLEANUP_ARCHIVE_READ_DAYS to be 60 days by default")
  900. }
  901. if err := configParser.parseLines([]string{"CLEANUP_ARCHIVE_READ_DAYS=30"}); err != nil {
  902. t.Fatalf("Unexpected error: %v", err)
  903. }
  904. if configParser.options.CleanupArchiveReadInterval().Hours() != 24*30 {
  905. t.Fatalf("Expected CLEANUP_ARCHIVE_READ_DAYS to be 30 days")
  906. }
  907. }
  908. func TestCleanupArchiveUnreadIntervalOptionParsing(t *testing.T) {
  909. configParser := NewConfigParser()
  910. if configParser.options.CleanupArchiveUnreadInterval().Hours() != 24*180 {
  911. t.Fatalf("Expected CLEANUP_ARCHIVE_UNREAD_DAYS to be 180 days by default")
  912. }
  913. if err := configParser.parseLines([]string{"CLEANUP_ARCHIVE_UNREAD_DAYS=90"}); err != nil {
  914. t.Fatalf("Unexpected error: %v", err)
  915. }
  916. if configParser.options.CleanupArchiveUnreadInterval().Hours() != 24*90 {
  917. t.Fatalf("Expected CLEANUP_ARCHIVE_UNREAD_DAYS to be 90 days")
  918. }
  919. }
  920. func TestCleanupFrequencyOptionParsing(t *testing.T) {
  921. configParser := NewConfigParser()
  922. if configParser.options.CleanupFrequency().Hours() != 24 {
  923. t.Fatalf("Expected CLEANUP_FREQUENCY_HOURS to be 24 hours by default")
  924. }
  925. if err := configParser.parseLines([]string{"CLEANUP_FREQUENCY_HOURS=12"}); err != nil {
  926. t.Fatalf("Unexpected error: %v", err)
  927. }
  928. if configParser.options.CleanupFrequency().Hours() != 12 {
  929. t.Fatalf("Expected CLEANUP_FREQUENCY_HOURS to be 12 hours")
  930. }
  931. }
  932. func TestCleanupRemoveSessionsIntervalOptionParsing(t *testing.T) {
  933. configParser := NewConfigParser()
  934. if configParser.options.CleanupRemoveSessionsInterval().Hours() != 24*30 {
  935. t.Fatalf("Expected CLEANUP_REMOVE_SESSIONS_DAYS to be 30 days by default")
  936. }
  937. if err := configParser.parseLines([]string{"CLEANUP_REMOVE_SESSIONS_DAYS=14"}); err != nil {
  938. t.Fatalf("Unexpected error: %v", err)
  939. }
  940. if configParser.options.CleanupRemoveSessionsInterval().Hours() != 24*14 {
  941. t.Fatalf("Expected CLEANUP_REMOVE_SESSIONS_DAYS to be 14 days")
  942. }
  943. }
  944. func TestDatabaseConnectionLifetimeOptionParsing(t *testing.T) {
  945. configParser := NewConfigParser()
  946. if configParser.options.DatabaseConnectionLifetime().Minutes() != 5 {
  947. t.Fatalf("Expected DATABASE_CONNECTION_LIFETIME to be 5 minutes by default")
  948. }
  949. if err := configParser.parseLines([]string{"DATABASE_CONNECTION_LIFETIME=10"}); err != nil {
  950. t.Fatalf("Unexpected error: %v", err)
  951. }
  952. if configParser.options.DatabaseConnectionLifetime().Minutes() != 10 {
  953. t.Fatalf("Expected DATABASE_CONNECTION_LIFETIME to be 10 minutes")
  954. }
  955. }
  956. func TestFilterEntryMaxAgeDaysOptionParsing(t *testing.T) {
  957. configParser := NewConfigParser()
  958. if configParser.options.FilterEntryMaxAgeDays() != 0 {
  959. t.Fatalf("Expected FILTER_ENTRY_MAX_AGE_DAYS to be 0 by default")
  960. }
  961. if err := configParser.parseLines([]string{"FILTER_ENTRY_MAX_AGE_DAYS=7"}); err != nil {
  962. t.Fatalf("Unexpected error: %v", err)
  963. }
  964. if configParser.options.FilterEntryMaxAgeDays() != 7 {
  965. t.Fatalf("Expected FILTER_ENTRY_MAX_AGE_DAYS to be 7 days")
  966. }
  967. }
  968. func TestForceRefreshIntervalOptionParsing(t *testing.T) {
  969. configParser := NewConfigParser()
  970. if configParser.options.ForceRefreshInterval().Minutes() != 30 {
  971. t.Fatalf("Expected FORCE_REFRESH_INTERVAL to be 30 minutes by default")
  972. }
  973. if err := configParser.parseLines([]string{"FORCE_REFRESH_INTERVAL=15"}); err != nil {
  974. t.Fatalf("Unexpected error: %v", err)
  975. }
  976. if configParser.options.ForceRefreshInterval().Minutes() != 15 {
  977. t.Fatalf("Expected FORCE_REFRESH_INTERVAL to be 15 minutes")
  978. }
  979. }
  980. func TestHTTPClientProxiesOptionParsing(t *testing.T) {
  981. configParser := NewConfigParser()
  982. if configParser.options.HasHTTPClientProxiesConfigured() {
  983. t.Fatalf("Expected HTTP_CLIENT_PROXIES to be empty by default")
  984. }
  985. if err := configParser.parseLines([]string{"HTTP_CLIENT_PROXIES=proxy1.example.com:8080,proxy2.example.com:8080"}); err != nil {
  986. t.Fatalf("Unexpected error: %v", err)
  987. }
  988. if !configParser.options.HasHTTPClientProxiesConfigured() {
  989. t.Fatalf("Expected HTTP_CLIENT_PROXIES to be configured")
  990. }
  991. proxies := configParser.options.HTTPClientProxies()
  992. if len(proxies) != 2 || proxies[0] != "proxy1.example.com:8080" || proxies[1] != "proxy2.example.com:8080" {
  993. t.Fatalf("Expected HTTP_CLIENT_PROXIES to contain two proxies")
  994. }
  995. }
  996. func TestHTTPClientProxyOptionParsing(t *testing.T) {
  997. configParser := NewConfigParser()
  998. if configParser.options.HTTPClientProxyURL() != nil {
  999. t.Fatal("Expected HTTP_CLIENT_PROXY to be nil by default")
  1000. }
  1001. if configParser.options.HasHTTPClientProxyURLConfigured() {
  1002. t.Fatal("Expected HAS_HTTP_CLIENT_PROXY to be disabled by default")
  1003. }
  1004. if err := configParser.parseLines([]string{"HTTP_CLIENT_PROXY=http://proxy.example.com:8080"}); err != nil {
  1005. t.Fatalf("Unexpected error: %v", err)
  1006. }
  1007. proxyURL := configParser.options.HTTPClientProxyURL()
  1008. if proxyURL == nil || proxyURL.String() != "http://proxy.example.com:8080" {
  1009. t.Fatal("Expected HTTP_CLIENT_PROXY to be 'http://proxy.example.com:8080'")
  1010. }
  1011. if !configParser.options.HasHTTPClientProxyURLConfigured() {
  1012. t.Fatal("Expected HAS_HTTP_CLIENT_PROXY to be enabled")
  1013. }
  1014. }
  1015. func TestHTTPClientTimeoutOptionParsing(t *testing.T) {
  1016. configParser := NewConfigParser()
  1017. if configParser.options.HTTPClientTimeout().Seconds() != 20 {
  1018. t.Fatalf("Expected HTTP_CLIENT_TIMEOUT to be 20 seconds by default")
  1019. }
  1020. if err := configParser.parseLines([]string{"HTTP_CLIENT_TIMEOUT=30"}); err != nil {
  1021. t.Fatalf("Unexpected error: %v", err)
  1022. }
  1023. if configParser.options.HTTPClientTimeout().Seconds() != 30 {
  1024. t.Fatalf("Expected HTTP_CLIENT_TIMEOUT to be 30 seconds")
  1025. }
  1026. }
  1027. func TestHTTPServerTimeoutOptionParsing(t *testing.T) {
  1028. configParser := NewConfigParser()
  1029. if configParser.options.HTTPServerTimeout().Seconds() != 300 {
  1030. t.Fatal("Expected HTTP_SERVER_TIMEOUT to be 300 seconds by default")
  1031. }
  1032. if err := configParser.parseLines([]string{"HTTP_SERVER_TIMEOUT=60"}); err != nil {
  1033. t.Fatalf("Unexpected error: %v", err)
  1034. }
  1035. if configParser.options.HTTPServerTimeout().Seconds() != 60 {
  1036. t.Fatal("Expected HTTP_SERVER_TIMEOUT to be 60 seconds")
  1037. }
  1038. }
  1039. func TestListenAddrOptionParsing(t *testing.T) {
  1040. configParser := NewConfigParser()
  1041. addrs := configParser.options.ListenAddr()
  1042. if len(addrs) != 1 || addrs[0] != "127.0.0.1:8080" {
  1043. t.Fatalf("Expected LISTEN_ADDR to be '127.0.0.1:8080' by default")
  1044. }
  1045. if err := configParser.parseLines([]string{"LISTEN_ADDR=0.0.0.0:8080,127.0.0.1:8081,/unix.socket"}); err != nil {
  1046. t.Fatalf("Unexpected error: %v", err)
  1047. }
  1048. addrs = configParser.options.ListenAddr()
  1049. if len(addrs) != 3 || addrs[0] != "0.0.0.0:8080" || addrs[1] != "127.0.0.1:8081" || addrs[2] != "/unix.socket" {
  1050. t.Fatalf("Expected LISTEN_ADDR to contain two addresses")
  1051. }
  1052. }
  1053. func TestMediaCustomProxyURLOptionParsing(t *testing.T) {
  1054. configParser := NewConfigParser()
  1055. if configParser.options.MediaCustomProxyURL() != nil {
  1056. t.Fatalf("Expected MEDIA_PROXY_CUSTOM_URL to be nil by default")
  1057. }
  1058. if err := configParser.parseLines([]string{"MEDIA_PROXY_CUSTOM_URL=https://proxy.example.com"}); err != nil {
  1059. t.Fatalf("Unexpected error: %v", err)
  1060. }
  1061. proxyURL := configParser.options.MediaCustomProxyURL()
  1062. if proxyURL == nil || proxyURL.String() != "https://proxy.example.com" {
  1063. t.Fatalf("Expected MEDIA_PROXY_CUSTOM_URL to be 'https://proxy.example.com'")
  1064. }
  1065. }
  1066. func TestMediaProxyHTTPClientTimeoutOptionParsing(t *testing.T) {
  1067. configParser := NewConfigParser()
  1068. if configParser.options.MediaProxyHTTPClientTimeout().Seconds() != 120 {
  1069. t.Fatalf("Expected MEDIA_PROXY_HTTP_CLIENT_TIMEOUT to be 120 seconds by default")
  1070. }
  1071. if err := configParser.parseLines([]string{"MEDIA_PROXY_HTTP_CLIENT_TIMEOUT=60"}); err != nil {
  1072. t.Fatalf("Unexpected error: %v", err)
  1073. }
  1074. if configParser.options.MediaProxyHTTPClientTimeout().Seconds() != 60 {
  1075. t.Fatalf("Expected MEDIA_PROXY_HTTP_CLIENT_TIMEOUT to be 60 seconds")
  1076. }
  1077. }
  1078. func TestMediaProxyPrivateKeyOptionParsing(t *testing.T) {
  1079. configParser := NewConfigParser()
  1080. if len(configParser.options.MediaProxyPrivateKey()) != 0 {
  1081. t.Fatalf("Expected MEDIA_PROXY_PRIVATE_KEY to be empty by default")
  1082. }
  1083. if err := configParser.parseLines([]string{"MEDIA_PROXY_PRIVATE_KEY=secret123"}); err != nil {
  1084. t.Fatalf("Unexpected error: %v", err)
  1085. }
  1086. privateKey := configParser.options.MediaProxyPrivateKey()
  1087. if string(privateKey) != "secret123" {
  1088. t.Fatalf("Expected MEDIA_PROXY_PRIVATE_KEY to be 'secret123'")
  1089. }
  1090. }
  1091. func TestMediaProxyResourceTypesOptionParsing(t *testing.T) {
  1092. configParser := NewConfigParser()
  1093. resourceTypes := configParser.options.MediaProxyResourceTypes()
  1094. if len(resourceTypes) != 1 || resourceTypes[0] != "image" {
  1095. t.Fatalf("Expected MEDIA_PROXY_RESOURCE_TYPES to have default values")
  1096. }
  1097. if err := configParser.parseLines([]string{"MEDIA_PROXY_RESOURCE_TYPES=image,video"}); err != nil {
  1098. t.Fatalf("Unexpected error: %v", err)
  1099. }
  1100. resourceTypes = configParser.options.MediaProxyResourceTypes()
  1101. if len(resourceTypes) != 2 || resourceTypes[0] != "image" || resourceTypes[1] != "video" {
  1102. t.Fatalf("Expected MEDIA_PROXY_RESOURCE_TYPES to contain image and video")
  1103. }
  1104. if err := configParser.parseLines([]string{"MEDIA_PROXY_RESOURCE_TYPES=image,invalid,video"}); err == nil {
  1105. t.Fatal("Expected error due to invalid resource type")
  1106. }
  1107. }
  1108. func TestMetricsAllowedNetworksOptionParsing(t *testing.T) {
  1109. configParser := NewConfigParser()
  1110. networks := configParser.options.MetricsAllowedNetworks()
  1111. if len(networks) != 1 || networks[0] != "127.0.0.1/8" {
  1112. t.Fatalf("Expected METRICS_ALLOWED_NETWORKS to have default values")
  1113. }
  1114. if err := configParser.parseLines([]string{"METRICS_ALLOWED_NETWORKS=10.0.0.0/8,192.168.0.0/16"}); err != nil {
  1115. t.Fatalf("Unexpected error: %v", err)
  1116. }
  1117. networks = configParser.options.MetricsAllowedNetworks()
  1118. if len(networks) != 2 || networks[0] != "10.0.0.0/8" || networks[1] != "192.168.0.0/16" {
  1119. t.Fatalf("Expected METRICS_ALLOWED_NETWORKS to contain specified networks")
  1120. }
  1121. }
  1122. func TestMetricsRefreshIntervalOptionParsing(t *testing.T) {
  1123. configParser := NewConfigParser()
  1124. if configParser.options.MetricsRefreshInterval().Seconds() != 60 {
  1125. t.Fatalf("Expected METRICS_REFRESH_INTERVAL to be 60 seconds by default")
  1126. }
  1127. if err := configParser.parseLines([]string{"METRICS_REFRESH_INTERVAL=120"}); err != nil {
  1128. t.Fatalf("Unexpected error: %v", err)
  1129. }
  1130. if configParser.options.MetricsRefreshInterval().Seconds() != 120 {
  1131. t.Fatalf("Expected METRICS_REFRESH_INTERVAL to be 120 seconds")
  1132. }
  1133. }
  1134. func TestPollingFrequencyOptionParsing(t *testing.T) {
  1135. configParser := NewConfigParser()
  1136. if configParser.options.PollingFrequency().Minutes() != 60 {
  1137. t.Fatalf("Expected POLLING_FREQUENCY to be 60 minutes by default")
  1138. }
  1139. if err := configParser.parseLines([]string{"POLLING_FREQUENCY=30"}); err != nil {
  1140. t.Fatalf("Unexpected error: %v", err)
  1141. }
  1142. if configParser.options.PollingFrequency().Minutes() != 30 {
  1143. t.Fatalf("Expected POLLING_FREQUENCY to be 30 minutes")
  1144. }
  1145. }
  1146. func TestSchedulerEntryFrequencyMaxIntervalOptionParsing(t *testing.T) {
  1147. configParser := NewConfigParser()
  1148. if configParser.options.SchedulerEntryFrequencyMaxInterval().Hours() != 24 {
  1149. t.Fatalf("Expected SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL to be 24 hours by default")
  1150. }
  1151. if err := configParser.parseLines([]string{"SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL=720"}); err != nil {
  1152. t.Fatalf("Unexpected error: %v", err)
  1153. }
  1154. if configParser.options.SchedulerEntryFrequencyMaxInterval().Hours() != 12 {
  1155. t.Fatalf("Expected SCHEDULER_ENTRY_FREQUENCY_MAX_INTERVAL to be 12 hours")
  1156. }
  1157. }
  1158. func TestSchedulerEntryFrequencyMinIntervalOptionParsing(t *testing.T) {
  1159. configParser := NewConfigParser()
  1160. if configParser.options.SchedulerEntryFrequencyMinInterval().Minutes() != 5 {
  1161. t.Fatalf("Expected SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL to be 5 minutes by default")
  1162. }
  1163. if err := configParser.parseLines([]string{"SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL=10"}); err != nil {
  1164. t.Fatalf("Unexpected error: %v", err)
  1165. }
  1166. if configParser.options.SchedulerEntryFrequencyMinInterval().Minutes() != 10 {
  1167. t.Fatalf("Expected SCHEDULER_ENTRY_FREQUENCY_MIN_INTERVAL to be 10 minutes")
  1168. }
  1169. }
  1170. func TestSchedulerRoundRobinMaxIntervalOptionParsing(t *testing.T) {
  1171. configParser := NewConfigParser()
  1172. if configParser.options.SchedulerRoundRobinMaxInterval().Hours() != 24 {
  1173. t.Fatalf("Expected SCHEDULER_ROUND_ROBIN_MAX_INTERVAL to be 24 hours by default")
  1174. }
  1175. if err := configParser.parseLines([]string{"SCHEDULER_ROUND_ROBIN_MAX_INTERVAL=60"}); err != nil {
  1176. t.Fatalf("Unexpected error: %v", err)
  1177. }
  1178. if configParser.options.SchedulerRoundRobinMaxInterval().Hours() != 1 {
  1179. t.Fatalf("Expected SCHEDULER_ROUND_ROBIN_MAX_INTERVAL to be 1 hour")
  1180. }
  1181. }
  1182. func TestSchedulerRoundRobinMinIntervalOptionParsing(t *testing.T) {
  1183. configParser := NewConfigParser()
  1184. if configParser.options.SchedulerRoundRobinMinInterval().Minutes() != 60 {
  1185. t.Fatalf("Expected SCHEDULER_ROUND_ROBIN_MIN_INTERVAL to be 60 minutes by default")
  1186. }
  1187. if err := configParser.parseLines([]string{"SCHEDULER_ROUND_ROBIN_MIN_INTERVAL=30"}); err != nil {
  1188. t.Fatalf("Unexpected error: %v", err)
  1189. }
  1190. if configParser.options.SchedulerRoundRobinMinInterval().Minutes() != 30 {
  1191. t.Fatalf("Expected SCHEDULER_ROUND_ROBIN_MIN_INTERVAL to be 30 minutes")
  1192. }
  1193. }
  1194. func TestYouTubeEmbedDomainOptionParsing(t *testing.T) {
  1195. configParser := NewConfigParser()
  1196. if configParser.options.YouTubeEmbedDomain() != "www.youtube-nocookie.com" {
  1197. t.Fatalf("Expected YouTubeEmbedDomain to be 'www.youtube-nocookie.com' by default")
  1198. }
  1199. // YouTube embed domain is derived from YOUTUBE_EMBED_URL_OVERRIDE
  1200. if err := configParser.parseLines([]string{"YOUTUBE_EMBED_URL_OVERRIDE=https://custom.youtube.com/embed/"}); err != nil {
  1201. t.Fatalf("Unexpected error: %v", err)
  1202. }
  1203. if configParser.options.YouTubeEmbedDomain() != "custom.youtube.com" {
  1204. t.Fatalf("Expected YouTubeEmbedDomain to be 'custom.youtube.com'")
  1205. }
  1206. }
  1207. func TestSetLogLevelFunction(t *testing.T) {
  1208. configParser := NewConfigParser()
  1209. // Test default log level
  1210. if configParser.options.LogLevel() != "info" {
  1211. t.Fatalf("Expected LOG_LEVEL to be 'info' by default, got '%s'", configParser.options.LogLevel())
  1212. }
  1213. // Test setting log level to debug
  1214. configParser.options.SetLogLevel("debug")
  1215. if configParser.options.LogLevel() != "debug" {
  1216. t.Fatalf("Expected LOG_LEVEL to be 'debug' after SetLogLevel('debug'), got '%s'", configParser.options.LogLevel())
  1217. }
  1218. if configParser.options.options["LOG_LEVEL"].RawValue != "debug" {
  1219. t.Fatalf("Expected LOG_LEVEL RawValue to be 'debug', got '%s'", configParser.options.options["LOG_LEVEL"].RawValue)
  1220. }
  1221. // Test setting log level to warning
  1222. configParser.options.SetLogLevel("warning")
  1223. if configParser.options.LogLevel() != "warning" {
  1224. t.Fatalf("Expected LOG_LEVEL to be 'warning' after SetLogLevel('warning'), got '%s'", configParser.options.LogLevel())
  1225. }
  1226. if configParser.options.options["LOG_LEVEL"].RawValue != "warning" {
  1227. t.Fatalf("Expected LOG_LEVEL RawValue to be 'warning', got '%s'", configParser.options.options["LOG_LEVEL"].RawValue)
  1228. }
  1229. }
  1230. func TestSetHTTPSValueFunction(t *testing.T) {
  1231. configParser := NewConfigParser()
  1232. // Test setting HTTPS to true
  1233. configParser.options.SetHTTPSValue(true)
  1234. if !configParser.options.HTTPS() {
  1235. t.Fatalf("Expected HTTPS to be true after SetHTTPSValue(true)")
  1236. }
  1237. // Test setting HTTPS to false
  1238. configParser.options.SetHTTPSValue(false)
  1239. if configParser.options.HTTPS() {
  1240. t.Fatalf("Expected HTTPS to be false after SetHTTPSValue(false)")
  1241. }
  1242. // Test setting HTTPS to true again
  1243. configParser.options.SetHTTPSValue(true)
  1244. if !configParser.options.HTTPS() {
  1245. t.Fatalf("Expected HTTPS to be true after second SetHTTPSValue(true)")
  1246. }
  1247. }
  1248. func TestConfigMap(t *testing.T) {
  1249. configMap := NewConfigOptions().ConfigMap(false)
  1250. if len(configMap) == 0 {
  1251. t.Fatal("Expected ConfigMap to contain configuration options")
  1252. }
  1253. // The first option should be "ADMIN_PASSWORD"
  1254. if configMap[0].Key != "ADMIN_PASSWORD" {
  1255. t.Fatalf("Expected first config option to be 'ADMIN_PASSWORD', got '%s'", configMap[0].Key)
  1256. }
  1257. }
  1258. func TestConfigMapWithRedactedSecrets(t *testing.T) {
  1259. configParser := NewConfigParser()
  1260. if err := configParser.parseLines([]string{"ADMIN_PASSWORD=secret123"}); err != nil {
  1261. t.Fatalf("Unexpected error: %v", err)
  1262. }
  1263. configMap := configParser.options.ConfigMap(true)
  1264. if len(configMap) == 0 {
  1265. t.Fatal("Expected ConfigMap to contain configuration options")
  1266. }
  1267. // The first option should be "ADMIN_PASSWORD"
  1268. if configMap[0].Key != "ADMIN_PASSWORD" {
  1269. t.Fatalf("Expected first config option to be 'ADMIN_PASSWORD', got '%s'", configMap[0].Key)
  1270. }
  1271. // The value should be redacted
  1272. if configMap[0].Value != "<redacted>" {
  1273. t.Fatalf("Expected ADMIN_PASSWORD value to be redacted, got '%s'", configMap[0].Value)
  1274. }
  1275. }