From aa6dbfefb3209862df25d7dc07e1736ac38f9cad Mon Sep 17 00:00:00 2001
From: Beyhan Ogur <beyhano@gmail.com>
Date: Mon, 11 May 2026 17:08:48 +0300
Subject: [PATCH] feat: add DB_TIMEZONE configuration and update logging for
 PostgreSQL timezone

---
 .env.example        |   4 ++--
 config/config.go    |   3 +++
 data/app.db         | Bin 61440 -> 94208 bytes
 docs/wiki/Config.md |   1 +
 main.go             |  25 ++++++++++++++++++++++++-
 5 files changed, 30 insertions(+), 3 deletions(-)

diff --git a/.env.example b/.env.example
index 8877e6a..23f4942 100644
--- a/.env.example
+++ b/.env.example
@@ -8,7 +8,7 @@ OPENAI_MODEL=deepseek-v4-pro
 DB_MODE=sqlite
 #DB_MODE=pgs
 DB_PATH=./data/app.db
-LOG_LEVEL=warn
+LOG_LEVEL=info
 STREAMING=true
-
+DB_TIMEZONE=Europe/Istanbul
 
diff --git a/config/config.go b/config/config.go
index c832055..602fd81 100644
--- a/config/config.go
+++ b/config/config.go
@@ -17,6 +17,7 @@ type Config struct {
 	RequestTimeoutSeconds int
 	OpenAIModel           string // default model when client omits it
 	Streaming             bool   // enable/disable SSE streaming responses
+	DBTimezone            string // PostgreSQL session timezone (e.g. "Europe/Istanbul")
 }
 
 // Load reads environment variables and returns a populated Config.
@@ -51,6 +52,7 @@ func Load() *Config {
 
 	openAIApiKey := os.Getenv("OPENAI_KEY")
 	openAIModel := os.Getenv("OPENAI_MODEL")
+	dbTimezone := os.Getenv("DB_TIMEZONE")
 
 	streaming := true
 	if v := os.Getenv("STREAMING"); v != "" {
@@ -70,5 +72,6 @@ func Load() *Config {
 		RequestTimeoutSeconds: timeoutSec,
 		OpenAIModel:           openAIModel,
 		Streaming:             streaming,
+		DBTimezone:            dbTimezone,
 	}
 }
diff --git a/data/app.db b/data/app.db
index b121c89e6efd48d925f03fa836a6dad9d09676c6..b727aea3c2c3f79f1ae4f9199e2a9c63ca36181f 100644
GIT binary patch
delta 1152
zcmZ{iPiPZC6vlUxZc|Fqmw%gowoMQZN|R-FXJ#iGkt&{4w3dRN3MNfUh164TB5hC)
zLXp%J^`JINtp`0c20eHwhzMRHR0J<V71WDhz4YS6nT;(;jj;S+A8)?--uGsH!#%&D
zRQ4$Sk|aeJQ^Rt9?c6e?gRsI2QWSo}7W{%A@EyLuC-?~Op#g8<HLSr)cn+)Z1XgP0
z^{%>0UGCk_PekGzYK$Ws;RvZ5!4O9v$l>>M0Mr{v-QSbw<v$6Svppyoff_u8$M6vD
z!5y&SI$VP*Fjo(xjsoj)OL9UWE)Wxl3Pc1{fv`YGASe(J@Yi1qA76cT`o2f@+e>E?
zfb|?Enq?wt=@!b`o7M2{T76Uv_4Fy9ecYK#9+W(H<-uAxC=V@M40@%pG3lh5ynV^#
zGLT_r5Y6a%N~bx3b5z%m!Az7Tmi@D;LVL-wM^$Pcn#R8Ae5o`!J9~a6RhYa`-+b^!
zw!NiOZj7ev@lw1S=W&r9wBMBy_3@k2ZbgwR`G7Fr$ITO6!-mf78^m55P=)uF5_P<L
zV{5{@?5RqgYOQ?BbD%OF@=7Bk!uis%&dwR7#4v=Wuj#v4Xe#!3J~Y!vi!{=;a!O7w
z%&0qQ<U46vnnkH@@eeyO3)$A%|KjL&?L<LHVFI^Av3I?a4?BAlVoWm)Z0dwDW9NdF
znv;bq^3~aXgrAD}%^c5*ugPGTQp2?PxS_!Aq8K^c<FlQKl?I<!Y1GQEl#$CPV%rm6
z9cZ7JYw!<g$fP8T7{x;f=MZXrBLB4feGguHYv9{H#>`1vpjL(uj535;D3i5{g^X#^
zqCP<_ipkWCq@f%xR`O9X3*mYsM-7dyjZ%}x-0{lxmS!YfkDN&2+cIX3W;JH<H-!l^
iJIb`TG-VX#$RxI9SWc(hO_u4{V63A|drMR1$eBOwHVn}K

delta 89
zcmZp8z}oPDd4e>nAOiyf|3n3QM!}5<OZa8D_|E|a82I^r^MB+2$p41_IsYU6yZkr!
rFY}+<*!YNLGn4BXuFdD<4Fx#(xxfmyO=dTc-z=ywfq(Nhd#?=u=J_1J

diff --git a/docs/wiki/Config.md b/docs/wiki/Config.md
index 0434968..e335c73 100644
--- a/docs/wiki/Config.md
+++ b/docs/wiki/Config.md
@@ -20,6 +20,7 @@
 | `REQUEST_TIMEOUT_SECONDS` | `30` | `RequestTimeoutSeconds` | Upstream istek zaman aşımı (saniye) |
 | `OPENAI_MODEL` | `""` | `OpenAIModel` | Varsayılan model adı (istekte model yoksa enjekte edilir) |
 | `STREAMING` | `true` | `Streaming` | SSE streaming yanıtlarını etkinleştir/devre dışı bırak (`true`/`false`) |
+| `DB_TIMEZONE` | `""` | `DBTimezone` | PostgreSQL oturum zaman dilimi (örn: `Europe/Istanbul`) |
 
 ## Önemli Detaylar
 
diff --git a/main.go b/main.go
index e3e5b1b..ba426f8 100644
--- a/main.go
+++ b/main.go
@@ -22,6 +22,7 @@ package main
 import (
 	"fmt"
 	"log"
+	"net/url"
 	"os"
 	"path/filepath"
 
@@ -67,7 +68,11 @@ func main() {
 			dialector = sqlite.Open(dsn)
 			dbEngine = "sqlite"
 		default:
-			dialector = postgres.Open(cfg.PostgresDSN)
+			dsn := cfg.PostgresDSN
+			if cfg.DBTimezone != "" {
+				dsn = appendQueryParam(dsn, "timezone", cfg.DBTimezone)
+			}
+			dialector = postgres.Open(dsn)
 		}
 
 		var err error
@@ -161,9 +166,27 @@ func main() {
 		log.Printf("   DB logging      : enabled")
 	}
 	log.Printf("   SSE streaming   : %v", cfg.Streaming)
+	if cfg.DBTimezone != "" {
+		log.Printf("   DB timezone     : %s", cfg.DBTimezone)
+	}
 
 	if err := app.Listen(addr); err != nil {
 		log.Fatalf("server error: %v", err)
 		os.Exit(1)
 	}
 }
+
+func appendQueryParam(dsn, key, value string) string {
+	if value == "" {
+		return dsn
+	}
+	u, err := url.Parse(dsn)
+	if err != nil {
+		log.Printf("⚠️  Failed to parse DSN for timezone: %v", err)
+		return dsn
+	}
+	q := u.Query()
+	q.Set(key, value)
+	u.RawQuery = q.Encode()
+	return u.String()
+}