v0.2.4

v0.2.3
v0.2.2
2026-01-28 16:46:44 +03:00 · 2026-01-28 16:44:11 +03:00 · 2026-01-28 16:42:45 +03:00 · 2026-01-28 16:41:26 +03:00 · 2026-01-28 16:31:02 +03:00
10 changed files with 414 additions and 71 deletions
--- a/.idea/Laniakea.iml
+++ b/.idea/Laniakea.iml
@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true" />
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
--- a/.idea/go.imports.xml
+++ b/.idea/go.imports.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="GoImports">
+    <option name="excludedPackages">
+      <array>
+        <option value="github.com/pkg/errors" />
+        <option value="golang.org/x/net/context" />
+      </array>
+    </option>
+  </component>
+</project>
--- a/.idea/inspectionProfiles/Project_Default.xml
+++ b/.idea/inspectionProfiles/Project_Default.xml
@@ -0,0 +1,14 @@
+<component name="InspectionProjectProfileManager">
+  <profile version="1.0">
+    <option name="myName" value="Project Default" />
+    <inspection_tool class="PyPackageRequirementsInspection" enabled="true" level="WARNING" enabled_by_default="true">
+      <option name="ignoredPackages">
+        <value>
+          <list size="1">
+            <item index="0" class="java.lang.String" itemvalue="mysql-connector-python" />
+          </list>
+        </value>
+      </option>
+    </inspection_tool>
+  </profile>
+</component>
--- a/.idea/modules.xml
+++ b/.idea/modules.xml
@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/Laniakea.iml" filepath="$PROJECT_DIR$/.idea/Laniakea.iml" />
+    </modules>
+  </component>
+</project>
--- a/.idea/vcs.xml
+++ b/.idea/vcs.xml
@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="" vcs="Git" />
+  </component>
+</project>
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -0,0 +1,67 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="AutoImportSettings">
+    <option name="autoReloadType" value="ALL" />
+  </component>
+  <component name="ChangeListManager">
+    <list default="true" id="8c106281-226d-4431-97ed-a32cb0060023" name="Changes" comment="" />
+    <option name="SHOW_DIALOG" value="false" />
+    <option name="HIGHLIGHT_CONFLICTS" value="true" />
+    <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
+    <option name="LAST_RESOLUTION" value="IGNORE" />
+  </component>
+  <component name="GOROOT" url="file:///usr/lib/go" />
+  <component name="Git.Settings">
+    <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
+  </component>
+  <component name="ProjectColorInfo"><![CDATA[{
+  "associatedIndex": 8
+}]]></component>
+  <component name="ProjectId" id="38t79d1gErKltj3wyP2yVMpAvnn" />
+  <component name="ProjectViewState">
+    <option name="hideEmptyMiddlePackages" value="true" />
+    <option name="showLibraryContents" value="true" />
+  </component>
+  <component name="PropertiesComponent"><![CDATA[{
+  "keyToString": {
+    "ModuleVcsDetector.initialDetectionPerformed": "true",
+    "RunOnceActivity.GoLinterPluginOnboardingV2": "true",
+    "RunOnceActivity.GoLinterPluginStorageMigration": "true",
+    "RunOnceActivity.ShowReadmeOnStart": "true",
+    "RunOnceActivity.TerminalTabsStorage.copyFrom.TerminalArrangementManager.252": "true",
+    "RunOnceActivity.git.unshallow": "true",
+    "RunOnceActivity.go.formatter.settings.were.checked": "true",
+    "RunOnceActivity.go.modules.go.list.on.any.changes.was.set": "true",
+    "git-widget-placeholder": "dev",
+    "go.import.settings.migrated": "true",
+    "go.sdk.automatically.set": "true",
+    "last_opened_file_path": "/home/scuroneko/Projects/Laniakea",
+    "settings.editor.selected.configurable": "preferences.pluginManager"
+  }
+}]]></component>
+  <component name="RecentsManager">
+    <key name="CopyFile.RECENT_KEYS">
+      <recent name="$PROJECT_DIR$" />
+    </key>
+    <key name="MoveFile.RECENT_KEYS">
+      <recent name="$PROJECT_DIR$/laniakea" />
+    </key>
+  </component>
+  <component name="SharedIndexes">
+    <attachedChunks>
+      <set>
+        <option value="bundled-gosdk-72a9cf600ed8-dfa3e7267ae0-org.jetbrains.plugins.go.sharedIndexes.bundled-GO-253.29346.379" />
+      </set>
+    </attachedChunks>
+  </component>
+  <component name="TaskManager">
+    <task active="true" id="Default" summary="Default task">
+      <changelist id="8c106281-226d-4431-97ed-a32cb0060023" name="Changes" comment="" />
+      <created>1769606862833</created>
+      <option name="number" value="Default" />
+      <option name="presentableId" value="Default" />
+      <updated>1769606862833</updated>
+    </task>
+    <servers />
+  </component>
+</project>
--- a/bot.go
+++ b/bot.go
@@ -106,11 +106,11 @@ func NewBot(settings *BotSettings) *Bot {
 		level = DEBUG
 	}

-	bot.logger = CreateLogger().Level(level).PrintTraceback(true)
-	bot.logger.AddWriter(bot.logger.CreateStdoutWriter())
+	bot.logger = CreateLogger().Level(level)
+	bot.logger.AddWriter(bot.logger.CreateJsonStdoutWriter())
 	if settings.WriteToFile {
 		path := fmt.Sprintf("%s/main.log", strings.TrimRight(settings.LoggerBasePath, "/"))
-		fileWriter, err := bot.logger.CreateFileWriter(path)
+		fileWriter, err := bot.logger.CreateTextFileWriter(path)
 		if err != nil {
 			bot.logger.Fatal(err)
 		}
@@ -119,10 +119,10 @@ func NewBot(settings *BotSettings) *Bot {

 	if settings.UseRequestLogger {
 		bot.requestLogger = CreateLogger().Level(level).Prefix("REQUESTS")
-		bot.requestLogger.AddWriter(bot.requestLogger.CreateStdoutWriter())
+		bot.requestLogger.AddWriter(bot.requestLogger.CreateJsonStdoutWriter())
 		if settings.WriteToFile {
 			path := fmt.Sprintf("%s/requests.log", strings.TrimRight(settings.LoggerBasePath, "/"))
-			fileWriter, err := bot.requestLogger.CreateFileWriter(path)
+			fileWriter, err := bot.requestLogger.CreateTextFileWriter(path)
 			if err != nil {
 				bot.logger.Fatal(err)
 			}
@@ -146,7 +146,7 @@ func (b *Bot) InitDatabaseContext(ctx *DatabaseContext) *Bot {
 	b.dbContext = ctx
 	return b
 }
-func (b *Bot) AddDatabaseLogger(writer func(db *DatabaseContext) *LoggerWriter) *Bot {
+func (b *Bot) AddDatabaseLogger(writer func(db *DatabaseContext) LoggerWriter) *Bot {
 	w := writer(b.dbContext)
 	b.logger.AddWriter(w)
 	if b.requestLogger != nil {
--- a/go.mod
+++ b/go.mod
@@ -0,0 +1,28 @@
+module git.nix13.pw/scuroneko/laniakea
+
+go 1.25.6
+
+require (
+	github.com/fatih/color v1.18.0
+	github.com/redis/go-redis/v9 v9.17.3
+	github.com/vinovest/sqlx v1.7.1
+	go.mongodb.org/mongo-driver/v2 v2.4.2
+)
+
+require (
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	github.com/golang/snappy v1.0.0 // indirect
+	github.com/klauspost/compress v1.16.7 // indirect
+	github.com/mattn/go-colorable v0.1.13 // indirect
+	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/muir/sqltoken v0.1.0 // indirect
+	github.com/xdg-go/pbkdf2 v1.0.0 // indirect
+	github.com/xdg-go/scram v1.1.2 // indirect
+	github.com/xdg-go/stringprep v1.0.4 // indirect
+	github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 // indirect
+	golang.org/x/crypto v0.33.0 // indirect
+	golang.org/x/sync v0.11.0 // indirect
+	golang.org/x/sys v0.30.0 // indirect
+	golang.org/x/text v0.22.0 // indirect
+)
--- a/go.sum
+++ b/go.sum
@@ -0,0 +1,87 @@
+filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
+filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
+github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
+github.com/bsm/ginkgo/v2 v2.12.0/go.mod h1:SwYbGRRDovPVboqFv0tPTcG1sN61LM1Z4ARdbAV9g4c=
+github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
+github.com/bsm/gomega v1.27.10/go.mod h1:JyEr/xRbxbtgWNi8tIEVPUYZ5Dzef52k01W3YH0H+O0=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
+github.com/fatih/color v1.18.0 h1:S8gINlzdQ840/4pfAwic/ZE0djQEH3wM94VfqLTZcOM=
+github.com/fatih/color v1.18.0/go.mod h1:4FelSpRwEGDpQ12mAdzqdOukCy4u8WUtOY6lkT/6HfU=
+github.com/go-sql-driver/mysql v1.9.0 h1:Y0zIbQXhQKmQgTp44Y1dp3wTXcn804QoTptLZT1vtvo=
+github.com/go-sql-driver/mysql v1.9.0/go.mod h1:pDetrLJeA3oMujJuvXc8RJoasr589B6A9fwzD3QMrqw=
+github.com/golang/snappy v1.0.0 h1:Oy607GVXHs7RtbggtPBnr2RmDArIsAefDwvrdWvRhGs=
+github.com/golang/snappy v1.0.0/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
+github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/klauspost/compress v1.16.7 h1:2mk3MPGNzKyxErAw8YaohYh69+pa4sIQSC0fPGCFR9I=
+github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE=
+github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
+github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
+github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
+github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
+github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
+github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
+github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
+github.com/mattn/go-sqlite3 v1.14.16 h1:yOQRA0RpS5PFz/oikGwBEqvAWhWg5ufRz4ETLjwpU1Y=
+github.com/mattn/go-sqlite3 v1.14.16/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
+github.com/muir/sqltoken v0.1.0 h1:edosEGsOClOZNfgGQNQSgxR9O6LiVefm2rDRqp2InuI=
+github.com/muir/sqltoken v0.1.0/go.mod h1:lgOIORnKekMsuc/ZwdPOfwz/PtWLPCke43cEbT3uDuY=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/redis/go-redis/v9 v9.17.3 h1:fN29NdNrE17KttK5Ndf20buqfDZwGNgoUr9qjl1DQx4=
+github.com/redis/go-redis/v9 v9.17.3/go.mod h1:u410H11HMLoB+TP67dz8rL9s6QW2j76l0//kSOd3370=
+github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
+github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/vinovest/sqlx v1.7.1 h1:kdq4v0N9kRLpytWGSWOw4aulOGdQPmIoMR6Y+cTBxow=
+github.com/vinovest/sqlx v1.7.1/go.mod h1:3fAv74r4iDMv2PpFomADb+vex5ukzfYn4GseC9KngD8=
+github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
+github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
+github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY=
+github.com/xdg-go/scram v1.1.2/go.mod h1:RT/sEzTbU5y00aCK8UOx6R7YryM0iF1N2MOmC3kKLN4=
+github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8=
+github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
+github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 h1:ilQV1hzziu+LLM3zUTJ0trRztfwgjqKnBWNtSRkbmwM=
+github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78/go.mod h1:aL8wCCfTfSfmXjznFBSZNN13rSJjlIOI1fUNAtF7rmI=
+github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
+go.mongodb.org/mongo-driver/v2 v2.4.2 h1:HrJ+Auygxceby9MLp3YITobef5a8Bv4HcPFIkml1U7U=
+go.mongodb.org/mongo-driver/v2 v2.4.2/go.mod h1:jHeEDJHJq7tm6ZF45Issun9dbogjfnPySb1vXA7EeAI=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
+golang.org/x/crypto v0.33.0 h1:IOBPskki6Lysi0lo9qQvbxiQ+FvsCC/YWOecCHAixus=
+golang.org/x/crypto v0.33.0/go.mod h1:bVdXmD7IV/4GdElGPozy6U7lWdRXA4qyRVGJV57uQ5M=
+golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
+golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.11.0 h1:GGz8+XQP4FvTTrjZPzNKTMFtSXH80RAzG+5ghFPgK9w=
+golang.org/x/sync v0.11.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
+golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
+golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ=
+golang.org/x/text v0.22.0 h1:bofq7m3/HAFvbF51jz3Q9wLg3jkvSPuiZu/pD1XwgtM=
+golang.org/x/text v0.22.0/go.mod h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
--- a/logger.go
+++ b/logger.go
@@ -1,6 +1,8 @@
 package laniakea

 import (
+	"bufio"
+	"encoding/json"
 	"fmt"
 	"io"
 	"os"
@@ -13,30 +15,91 @@ import (
 	"github.com/fatih/color"
 )

-type LoggerWriter struct {
+type LoggerWriter interface {
+	Close() error
+	Write(p []byte) (n int, err error)
+	Print(level LogLevel, prefix string, traceback []*MethodTraceback, messages ...any) error
+}
+type LoggerTextWriter struct {
+	LoggerWriter
 	writer         io.Writer
-	writeFn LoggerWriterFn
-	logger  *Logger
+	printTraceback bool
+	printTime      bool
 }

-func (w *LoggerWriter) SetFn(fn LoggerWriterFn) {
-	w.writeFn = fn
+func (w *LoggerTextWriter) Write(p []byte) (n int, err error) {
+	n, err = w.writer.Write(p)
+	if err != nil {
+		return n, err
+	}
+	err = bufio.NewWriter(w.writer).Flush()
+	return n, err
 }
-func (w *LoggerWriter) Write(p []byte) (n int, err error) {
-	return w.writer.Write(p)
+func (w *LoggerTextWriter) Print(level LogLevel, prefix string, tb []*MethodTraceback, messages ...any) error {
+	s := buildString(level, prefix, true, w.printTraceback, w.printTime, messages...)
+	_, err := w.Write([]byte(s))
+	return err
 }
-func (w *LoggerWriter) Close() error {
+func (w *LoggerTextWriter) Close() error {
 	return w.writer.(io.Closer).Close()
 }

-type LoggerWriterFn func(level LogLevel, prefix, traceback string, message []any) error
+type LoggerJsonWriter struct {
+	LoggerWriter
+	writer io.Writer
+	pretty bool
+}
+type LoggerJsonMessage struct {
+	Time      time.Time          `json:"time"`
+	Level     string             `json:"level"`
+	Prefix    string             `json:"prefix"`
+	Message   string             `json:"message"`
+	Traceback []*MethodTraceback `json:"traceback"`
+}
+
+func (w *LoggerJsonWriter) Write(data []byte) (int, error) {
+	n, err := w.writer.Write(data)
+	if err != nil {
+		return n, err
+	}
+	err = bufio.NewWriter(w.writer).Flush()
+	return n, err
+}
+func (w *LoggerJsonWriter) Print(level LogLevel, prefix string, traceback []*MethodTraceback, messages ...any) error {
+	msg := Map(messages, func(el any) string {
+		return fmt.Sprintf("%v", el)
+	})
+	m := LoggerJsonMessage{
+		Time:      time.Now(),
+		Level:     level.GetName(),
+		Prefix:    prefix,
+		Message:   strings.Join(msg, " "),
+		Traceback: traceback,
+	}
+	var data []byte
+	var err error
+	if w.pretty {
+		data, err = json.MarshalIndent(m, "", "  ")
+	} else {
+		data, err = json.Marshal(m)
+	}
+	if err != nil {
+		return err
+	}
+	_, err = w.Write(append(data, []byte("\n")...))
+	return err
+}
+func (w *LoggerJsonWriter) Close() error {
+	return w.writer.(io.Closer).Close()
+}

 type Logger struct {
 	prefix         string
 	level          LogLevel
 	printTraceback bool
 	printTime      bool
-	writers        []*LoggerWriter
+	jsonPretty     bool
+	writers        []LoggerWriter
 }

 type LogLevel struct {
@@ -50,12 +113,12 @@ func (l *LogLevel) GetName() string {
 }

 type MethodTraceback struct {
-	Package   string
-	Method    string
+	Package   string `json:"package"`
+	Method    string `json:"method"`
 	fullPath  string
 	signature string
-	filename  string
-	line      int
+	Filename  string `json:"filename"`
+	Line      int    `json:"line"`
 }

 var (
@@ -75,7 +138,7 @@ func CreateLogger() *Logger {
 	}
 }

-func (l *Logger) CreateFileWriter(path string) (*LoggerWriter, error) {
+func (l *Logger) CreateTextFileWriter(path string) (*LoggerTextWriter, error) {
 	err := os.MkdirAll(filepath.Dir(path), os.ModePerm)
 	if err != nil {
 		return nil, err
@@ -85,22 +148,46 @@ func (l *Logger) CreateFileWriter(path string) (*LoggerWriter, error) {
 		return nil, err
 	}

-	writer := &LoggerWriter{
-		writer: file, logger: l,
-	}
-	writer.writeFn = func(level LogLevel, prefix, traceback string, message []any) error {
-		_, err = writer.Write([]byte(writer.logger.buildString(level, message) + "\n"))
-		return err
+	writer := &LoggerTextWriter{
+		writer: file, printTraceback: l.printTraceback, printTime: l.printTime,
 	}
 	return writer, nil
 }
-func (l *Logger) CreateStdoutWriter() *LoggerWriter {
-	writer := &LoggerWriter{
-		writer: os.Stdout, logger: l,
+func (l *Logger) CreateTextStdoutWriter() *LoggerTextWriter {
+	writer := &LoggerTextWriter{
+		writer: os.Stdout, printTraceback: l.printTraceback, printTime: l.printTime,
 	}
-	writer.writeFn = func(level LogLevel, prefix, traceback string, message []any) error {
-		_, err := color.New(level.c).Fprint(writer.writer, writer.logger.buildString(level, message))
-		return err
+	return writer
+}
+func (l *Logger) CreateJsonStdoutWriter() *LoggerJsonWriter {
+	writer := &LoggerJsonWriter{
+		writer: os.Stdout, pretty: l.jsonPretty,
+	}
+	return writer
+}
+func (l *Logger) CreateJsonFileWriter(path string) (*LoggerJsonWriter, error) {
+	err := os.MkdirAll(filepath.Dir(path), os.ModePerm)
+	if err != nil {
+		return nil, err
+	}
+	file, err := os.OpenFile(path, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644)
+	if err != nil {
+		return nil, err
+	}
+	writer := &LoggerJsonWriter{
+		writer: file, pretty: l.jsonPretty,
+	}
+	return writer, nil
+}
+func (l *Logger) CreateTextWriter(w io.Writer) *LoggerTextWriter {
+	writer := &LoggerTextWriter{
+		writer: w, printTraceback: l.printTraceback, printTime: l.printTime,
+	}
+	return writer
+}
+func (l *Logger) CreateJsonWriter(w io.Writer) *LoggerJsonWriter {
+	writer := &LoggerJsonWriter{
+		writer: w, pretty: l.jsonPretty,
 	}
 	return writer
 }
@@ -121,44 +208,61 @@ func (l *Logger) PrintTime(b bool) *Logger {
 	l.printTime = b
 	return l
 }
-func (l *Logger) AddWriters(writers ...*LoggerWriter) *Logger {
+func (l *Logger) JsonPretty(b bool) *Logger {
+	l.jsonPretty = b
+	return l
+}
+func (l *Logger) AddWriters(writers ...LoggerWriter) *Logger {
 	l.writers = append(l.writers, writers...)
 	return l
 }
-func (l *Logger) AddWriter(writer *LoggerWriter) *Logger {
+func (l *Logger) AddWriter(writer LoggerWriter) *Logger {
 	l.writers = append(l.writers, writer)
 	return l
 }

-func (l *Logger) Infof(format string, m ...any) {
-	l.print(INFO, []any{fmt.Sprintf(format, m...)})
+func (l *Logger) Infof(format string, args ...any) {
+	l.print(INFO, fmt.Sprintf(format, args...))
 }
 func (l *Logger) Info(m ...any) {
-	l.print(INFO, m)
+	l.println(INFO, m...)
 }

+func (l *Logger) Warnf(format string, args ...any) {
+	l.print(WARN, fmt.Sprintf(format, args...))
+}
 func (l *Logger) Warn(m ...any) {
-	l.print(WARN, m)
+	l.println(WARN, m...)
 }

 func (l *Logger) Error(m ...any) {
-	l.print(ERROR, m)
+	l.println(ERROR, m...)
 }

 func (l *Logger) Fatal(m ...any) {
-	l.print(FATAL, m)
+	l.println(FATAL, m...)
 	os.Exit(1)
 }

 func (l *Logger) Debug(m ...any) {
-	l.print(DEBUG, m)
+	l.println(DEBUG, m...)
 }

-func (l *Logger) formatTime(t time.Time) string {
+func formatTime(t time.Time) string {
 	return fmt.Sprintf("%02d.%02d.%02d %02d:%02d:%02d", t.Day(), t.Month(), t.Year(), t.Hour(), t.Minute(), t.Second())
 }
+func formatTraceback(mt *MethodTraceback) string {
+	return fmt.Sprintf("%s:%s:%d", mt.Filename, mt.Method, mt.Line)
+}
+func FormatFullTraceback(tracebacks []*MethodTraceback) string {
+	formatted := make([]string, 0)
+	for _, tb := range tracebacks {
+		formatted = append(formatted, formatTraceback(tb))
+	}
+	return strings.Join(formatted, "->")
+}

-func (l *Logger) getTraceback() *MethodTraceback {
+func getTraceback() *MethodTraceback {
 	caller, _, _, _ := runtime.Caller(4)
 	details := runtime.FuncForPC(caller)
 	signature := details.Name()
@@ -169,9 +273,9 @@ func (l *Logger) getTraceback() *MethodTraceback {
 	pkg, method := splitSignature[0], splitSignature[len(splitSignature)-1]

 	tb := &MethodTraceback{
-		filename:  splitPath[len(splitPath)-1],
+		Filename:  splitPath[len(splitPath)-1],
 		fullPath:  path,
-		line:      line,
+		Line:      line,
 		signature: signature,
 		Package:   pkg,
 		Method:    method,
@@ -179,11 +283,7 @@ func (l *Logger) getTraceback() *MethodTraceback {

 	return tb
 }
-func (l *Logger) formatTraceback(mt *MethodTraceback) string {
-	return fmt.Sprintf("%s:%s:%d", mt.filename, mt.Method, mt.line)
-}
-
-func (l *Logger) getFullTraceback(skip int) []*MethodTraceback {
+func getFullTraceback(skip int) []*MethodTraceback {
 	pc := make([]uintptr, 15)
 	runtime.Callers(skip, pc)
 	list := make([]*MethodTraceback, 0)
@@ -202,9 +302,9 @@ func (l *Logger) getFullTraceback(skip int) []*MethodTraceback {
 		pkg, method := splitSignature[0], splitSignature[len(splitSignature)-1]

 		tb := &MethodTraceback{
-			filename:  splitPath[len(splitPath)-1],
+			Filename:  splitPath[len(splitPath)-1],
 			fullPath:  path,
-			line:      line,
+			Line:      line,
 			signature: signature,
 			Package:   pkg,
 			Method:    method,
@@ -216,42 +316,55 @@ func (l *Logger) getFullTraceback(skip int) []*MethodTraceback {
 	})
 	return list
 }
-func (l *Logger) formatFullTraceback(tracebacks []*MethodTraceback) string {
-	formatted := make([]string, 0)
-	for _, tb := range tracebacks {
-		formatted = append(formatted, l.formatTraceback(tb))
-	}
-	return strings.Join(formatted, "->")
-}

-func (l *Logger) buildString(level LogLevel, m []any) string {
+func buildString(level LogLevel, prefix string, newline, printTime, printTraceback bool, m ...any) string {
 	args := []string{
-		fmt.Sprintf("[%s]", l.prefix),
+		fmt.Sprintf("[%s]", prefix),
 		fmt.Sprintf("[%s]", strings.ToUpper(level.t)),
 	}

-	if l.printTraceback {
-		args = append(args, fmt.Sprintf("[%s]", l.formatTraceback(l.getTraceback())))
+	if printTraceback {
+		args = append(args, fmt.Sprintf("[%s]", formatTraceback(getTraceback())))
 	}

-	if l.printTime {
-		args = append(args, fmt.Sprintf("[%s]", l.formatTime(time.Now())))
+	if printTime {
+		args = append(args, fmt.Sprintf("[%s]", formatTime(time.Now())))
 	}

 	msg := Map(m, func(el any) string {
 		return fmt.Sprintf("%v", el)
 	})
-
-	return fmt.Sprintf("%s %v", strings.Join(args, " "), strings.Join(msg, " "))
+	s := fmt.Sprintf("%s %s", strings.Join(args, " "), strings.Join(msg, " "))
+	if newline {
+		s += "\n"
+	}
+	return s
 }

-func (l *Logger) print(level LogLevel, m []any) {
+func (l *Logger) print(level LogLevel, m ...any) {
 	if l.level.n < level.n {
 		return
 	}

+	tb := getFullTraceback(0)
 	for _, writer := range l.writers {
-		err := writer.writeFn(level, l.prefix, l.formatFullTraceback(l.getFullTraceback(0)), m)
+		err := writer.Print(level, l.prefix, tb, m...)
+		if err != nil {
+			l.Error(err)
+		}
+	}
+}
+
+// Docker requires "\n" at end to write to log.
+// print not work for docker, otherwise it will work and write into stdout
+func (l *Logger) println(level LogLevel, m ...any) {
+	if l.level.n < level.n {
+		return
+	}
+
+	tb := getFullTraceback(0)
+	for _, writer := range l.writers {
+		err := writer.Print(level, l.prefix, tb, m...)
 		if err != nil {
 			l.Error(err)
 		}
Author	SHA1	Message	Date
ScuroNeko	199940359d	v0.2.4	2026-01-28 16:46:44 +03:00
ScuroNeko	d1c75ac0a6	v0.2.3	2026-01-28 16:44:11 +03:00
ScuroNeko	75be66d5a9	v0.2.2	2026-01-28 16:42:45 +03:00
ScuroNeko	ee51d29c30	v0.2.0	2026-01-28 16:41:26 +03:00
ScuroNeko	8f8182039d	v0.2.0	2026-01-28 16:31:02 +03:00