initial commit

Author: cemayan

.gitignore

@@ -1,15 +1,52 @@
-# Binaries for programs and plugins
-*.exe
-*.exe~
-*.dll
-*.so
-*.dylib
-
-# Test binary, built with `go test -c`
-*.test
 
-# Output of the go coverage tool, specifically when used with LiteIDE
-*.out
+.DS_Store
+*.[56789ao]
+*.a[56789o]
+*.so
+*.pyc
+._*
+.nfs.*
+[56789a].out
+*~
+*.orig
+*.rej
+*.exe
+.*.swp
+core
+*.cgo*.go
+*.cgo*.c
+_cgo_*
+_obj
+_test
+_testmain.go
+/VERSION.cache
+/bin/
+/build.out
+/doc/articles/wiki/*.bin
+/goinstall.log
+/last-change
+/misc/cgo/life/run.out
+/misc/cgo/stdio/run.out
+/misc/cgo/testso/main
+/pkg/
+/src/*.*/
+/src/cmd/cgo/zdefaultcc.go
+/src/cmd/dist/dist
+/src/cmd/go/internal/cfg/zdefaultcc.go
+/src/cmd/go/internal/cfg/zosarch.go
+/src/cmd/internal/objabi/zbootstrap.go
+/src/go/build/zcgo.go
+/src/go/doc/headscan
+/src/runtime/internal/sys/zversion.go
+/src/unicode/maketables
+/test.out
+/test/garbage/*.out
+/test/pass.out
+/test/run.out
+/test/times.out
+# This file includes artifacts of Go build that should not be checked in.
+# For files created by specific development environment (e.g. editor),
+# use alternative ways to exclude files from git.
+# For example, set up .git/info/exclude or use a global .gitignore.
 
-# Dependency directories (remove the comment below to include it)
-# vendor/
+.idea

cmd/api/read/main.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"github.com/cemayan/url-shortener/config/api"
+	"github.com/cemayan/url-shortener/handlers/db"
+	"github.com/cemayan/url-shortener/internal/api/read/adapter/database"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/viper"
+	"os"
+)
+
+var _log *logrus.Logger
+var configs *api.AppConfig
+var v *viper.Viper
+
+func init() {
+	_log = logrus.New()
+	if os.Getenv("env") == "dev" {
+		_log.SetFormatter(&logrus.TextFormatter{
+			DisableColors: false,
+			FullTimestamp: true,
+		})
+	} else {
+		_log.SetFormatter(&logrus.JSONFormatter{})
+		_log.SetOutput(os.Stdout)
+	}
+	_log.Out = os.Stdout
+
+	v = viper.New()
+	_configs := api.NewConfig(v)
+
+	env := os.Getenv("env")
+	appConfig, err := _configs.GetConfig(env)
+	configs = appConfig
+	if err != nil {
+		return
+	}
+
+	dbHandler := db.NewCockroachDbHandler(&configs.Cockroach, _log.WithFields(logrus.Fields{"service": "database"}))
+	_db := dbHandler.New()
+	database.DB = _db
+	//util.MigrateDB(_db, _log.WithFields(logrus.Fields{"service": "database"}))
+}
+
+func main() {
+
+}

cmd/api/write/main.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"github.com/cemayan/url-shortener/config/api"
+	"github.com/cemayan/url-shortener/handlers/db"
+	"github.com/cemayan/url-shortener/internal/api/read/adapter/database"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/viper"
+	"os"
+)
+
+var _log *logrus.Logger
+var configs *api.AppConfig
+var v *viper.Viper
+
+func init() {
+	_log = logrus.New()
+	if os.Getenv("env") == "dev" {
+		_log.SetFormatter(&logrus.TextFormatter{
+			DisableColors: false,
+			FullTimestamp: true,
+		})
+	} else {
+		_log.SetFormatter(&logrus.JSONFormatter{})
+		_log.SetOutput(os.Stdout)
+	}
+	_log.Out = os.Stdout
+
+	v = viper.New()
+	_configs := api.NewConfig(v)
+
+	env := os.Getenv("env")
+	appConfig, err := _configs.GetConfig(env)
+	configs = appConfig
+	if err != nil {
+		return
+	}
+
+	dbHandler := db.NewCockroachDbHandler(&configs.Cockroach, _log.WithFields(logrus.Fields{"service": "database"}))
+	_db := dbHandler.New()
+	database.DB = _db
+	//util.MigrateDB(_db, _log.WithFields(logrus.Fields{"service": "database"}))
+}
+
+func main() {
+
+}

cmd/auth/main.go

@@ -0,0 +1,41 @@
+package main
+
+import (
+	"github.com/cemayan/url-shortener/config/user"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/viper"
+	"os"
+)
+
+var _log *logrus.Logger
+var configs *user.AppConfig
+var v *viper.Viper
+
+func init() {
+	_log = logrus.New()
+	if os.Getenv("env") == "dev" {
+		_log.SetFormatter(&logrus.TextFormatter{
+			DisableColors: false,
+			FullTimestamp: true,
+		})
+	} else {
+		_log.SetFormatter(&logrus.JSONFormatter{})
+		_log.SetOutput(os.Stdout)
+	}
+	_log.Out = os.Stdout
+
+	v = viper.New()
+	_configs := user.NewConfig(v)
+
+	env := os.Getenv("env")
+	appConfig, err := _configs.GetConfig(env)
+	configs = appConfig
+	if err != nil {
+		return
+	}
+
+}
+
+func main() {
+
+}

cmd/event_handler/main.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"github.com/cemayan/url-shortener/config/event_handler"
+	"github.com/cemayan/url-shortener/handlers/db"
+	"github.com/cemayan/url-shortener/internal/event_handler/adapter/database"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/viper"
+	"os"
+)
+
+var _log *logrus.Logger
+var configs *event_handler.AppConfig
+var v *viper.Viper
+
+func init() {
+	_log = logrus.New()
+	if os.Getenv("env") == "dev" {
+		_log.SetFormatter(&logrus.TextFormatter{
+			DisableColors: false,
+			FullTimestamp: true,
+		})
+	} else {
+		_log.SetFormatter(&logrus.JSONFormatter{})
+		_log.SetOutput(os.Stdout)
+	}
+	_log.Out = os.Stdout
+
+	v = viper.New()
+	_configs := event_handler.NewConfig(v)
+
+	env := os.Getenv("env")
+	appConfig, err := _configs.GetConfig(env)
+	configs = appConfig
+	if err != nil {
+		return
+	}
+
+	dbHandler := db.NewCockroachDbHandler(&configs.Cockroach, _log.WithFields(logrus.Fields{"service": "database"}))
+	_db := dbHandler.New()
+	database.DB = _db
+	//util.MigrateDB(_db, _log.WithFields(logrus.Fields{"service": "database"}))
+}
+
+func main() {
+
+}

cmd/user/main.go

@@ -0,0 +1,40 @@
+package main
+
+import (
+	"github.com/cemayan/url-shortener/config/user"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/viper"
+	"os"
+)
+
+var _log *logrus.Logger
+var configs *user.AppConfig
+var v *viper.Viper
+
+func init() {
+	_log = logrus.New()
+	if os.Getenv("env") == "dev" {
+		_log.SetFormatter(&logrus.TextFormatter{
+			DisableColors: false,
+			FullTimestamp: true,
+		})
+	} else {
+		_log.SetFormatter(&logrus.JSONFormatter{})
+		_log.SetOutput(os.Stdout)
+	}
+	_log.Out = os.Stdout
+
+	v = viper.New()
+	_configs := user.NewConfig(v)
+
+	env := os.Getenv("env")
+	appConfig, err := _configs.GetConfig(env)
+	configs = appConfig
+	if err != nil {
+		return
+	}
+}
+
+func main() {
+
+}

common/common.go

@@ -0,0 +1,24 @@
+package common
+
+type Cockroach struct {
+	Host     string
+	Port     string
+	User     string
+	Password string
+	Name     string
+}
+
+type Mongo struct {
+	Url    string
+	DbName string
+}
+
+type Kafka struct {
+	Url   string
+	Topic string
+}
+
+type Pulsar struct {
+	Url   string
+	Topic string
+}

config/api/config-dev.yml

@@ -0,0 +1,10 @@
+cockroach:
+  Host: localhost
+  Name: us_metadata
+  Port: 26257
+  User: root
+mongo:
+  DbName: eseventstore
+  url: mongodb://localhost:27017
+secret: secret
+