Update Env

.idea/legalgo-BE-go.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>

.idea/workspace.xml

@@ -0,0 +1,119 @@
+<?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="e5a7c631-b0eb-4bcf-9341-cd30afbc8d51" name="Changes" comment="">
+      <change afterPath="$PROJECT_DIR$/.idea/legalgo-BE-go.iml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/auth.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/configs.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/db.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/http.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/jwt.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/module.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/oss.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/config/server.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/development.yaml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/internal/accessor/oss/oss.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/internal/accessor/oss/upload.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/internal/api/http/oss/module.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/internal/api/http/oss/upload.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/internal/domain/oss/oss.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/internal/services/oss/impl.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/internal/services/oss/init.go" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/k8s/staging/deployment.yaml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/k8s/staging/ingress.yaml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/k8s/staging/namespace.yaml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/k8s/staging/service.yaml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cmd/gorm/main.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/gorm/main.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cmd/legalgo/main.go" beforeDir="false" afterPath="$PROJECT_DIR$/cmd/legalgo/main.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/database/new_db.go" beforeDir="false" afterPath="$PROJECT_DIR$/database/new_db.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/go.mod" beforeDir="false" afterPath="$PROJECT_DIR$/go.mod" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/go.sum" beforeDir="false" afterPath="$PROJECT_DIR$/go.sum" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/internal/accessor/module.go" beforeDir="false" afterPath="$PROJECT_DIR$/internal/accessor/module.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/internal/api/http/router.go" beforeDir="false" afterPath="$PROJECT_DIR$/internal/api/http/router.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/internal/services/module.go" beforeDir="false" afterPath="$PROJECT_DIR$/internal/services/module.go" afterDir="false" />
+    </list>
+    <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="FileTemplateManagerImpl">
+    <option name="RECENT_TEMPLATES">
+      <list>
+        <option value="Go File" />
+      </list>
+    </option>
+  </component>
+  <component name="GOROOT" url="file:///opt/homebrew/Cellar/go/1.24.0/libexec" />
+  <component name="Git.Settings">
+    <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
+  </component>
+  <component name="MarkdownSettingsMigration">
+    <option name="stateVersion" value="1" />
+  </component>
+  <component name="ProjectId" id="2tlQuDgnVjD2XCHsYVtzhu4hYTb" />
+  <component name="ProjectViewState">
+    <option name="hideEmptyMiddlePackages" value="true" />
+    <option name="showLibraryContents" value="true" />
+  </component>
+  <component name="PropertiesComponent"><![CDATA[{
+  "keyToString": {
+    "ASKED_SHARE_PROJECT_CONFIGURATION_FILES": "true",
+    "DefaultGoTemplateProperty": "Go File",
+    "RunOnceActivity.OpenProjectViewOnStart": "true",
+    "RunOnceActivity.ShowReadmeOnStart": "true",
+    "RunOnceActivity.go.formatter.settings.were.checked": "true",
+    "RunOnceActivity.go.migrated.go.modules.settings": "true",
+    "RunOnceActivity.go.modules.go.list.on.any.changes.was.set": "true",
+    "RunOnceActivity.go.vendoring.notification.had.been.shown": "true",
+    "SHARE_PROJECT_CONFIGURATION_FILES": "true",
+    "WebServerToolWindowFactoryState": "false",
+    "configurable..is.expanded": "false",
+    "configurable.GoLibrariesConfigurable.is.expanded": "true",
+    "go.import.settings.migrated": "true",
+    "go.sdk.automatically.set": "true",
+    "last_opened_file_path": "/Users/aditya.siregar/Personal/Altru/legalgo-news/legalgo-BE-go",
+    "node.js.detected.package.eslint": "true",
+    "node.js.selected.package.eslint": "(autodetect)",
+    "settings.editor.selected.configurable": "go.sdk"
+  }
+}]]></component>
+  <component name="RecentsManager">
+    <key name="CopyFile.RECENT_KEYS">
+      <recent name="$PROJECT_DIR$" />
+      <recent name="$PROJECT_DIR$/internal/api/http/oss" />
+      <recent name="$PROJECT_DIR$/internal/services" />
+      <recent name="$PROJECT_DIR$/internal/accessor" />
+      <recent name="$PROJECT_DIR$/config" />
+    </key>
+    <key name="MoveFile.RECENT_KEYS">
+      <recent name="$PROJECT_DIR$/internal/api/http/oss" />
+    </key>
+  </component>
+  <component name="RunManager">
+    <configuration name="go build legalgo-BE-go/cmd/legalgo" type="GoApplicationRunConfiguration" factoryName="Go Application" temporary="true" nameIsGenerated="true">
+      <module name="legalgo-BE-go" />
+      <working_directory value="$PROJECT_DIR$" />
+      <kind value="PACKAGE" />
+      <package value="legalgo-BE-go/cmd/legalgo" />
+      <directory value="$PROJECT_DIR$" />
+      <filePath value="$PROJECT_DIR$/cmd/legalgo/main.go" />
+      <method v="2" />
+    </configuration>
+    <recent_temporary>
+      <list>
+        <item itemvalue="Go Build.go build legalgo-BE-go/cmd/legalgo" />
+      </list>
+    </recent_temporary>
+  </component>
+  <component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
+  <component name="TypeScriptGeneratedFilesManager">
+    <option name="version" value="3" />
+  </component>
+  <component name="VgoProject">
+    <settings-migrated>true</settings-migrated>
+  </component>
+</project>

.vscode/extensions.json

@@ -0,0 +1,5 @@
+{
+  "recommendations": [
+    "arjun.swagger-viewer"
+  ]
+}

.vscode/launch.json

@@ -0,0 +1,22 @@
+{
+    "version": "0.2.0",
+    "configurations": [   
+        {
+            "name": "Launch Package",
+            "type": "go",
+            "request": "launch",
+            "mode": "debug",
+            "program": "${workspaceFolder}/cmd/legalgo/",
+            "dlvLoadConfig":{
+                "followPointers": true,
+                "maxVariableRecurse": 1,
+                "maxStringLen": 512, // 字符串最大长度
+                "maxArrayValues": 64,
+                "maxStructFields": -1
+              },
+            "dlvFlags": ["--check-go-version=false"],
+            "env": {
+              "TZ": ""
+            }
+        }]
+  }

Dockerfile

@@ -0,0 +1,22 @@
+FROM golang:1.24 AS build
+
+WORKDIR /src
+COPY . .
+
+# RUN CGO_ENABLED=0 GOOS=linux go build -o /app cmd/klinik-core-service
+RUN CGO_ENABLED=0 GOOS=linux go build -o /app cmd/legalgo/main.go
+
+RUN ls -la /
+
+FROM gcr.io/distroless/static
+
+WORKDIR /
+
+COPY --from=build /usr/share/zoneinfo /usr/share/zoneinfo
+COPY --from=build /app /app
+
+# RUN ls -la /
+
+ENV TZ=Asia/Jakarta
+
+ENTRYPOINT ["/app"]

cmd/gorm/main.go

@@ -24,11 +24,14 @@ func main() {
 	}
 
 	config.InitEnv()
-	db, err := database.NewDB()
+	cfg := config.LoadConfig()
+	db, err := database.NewDB(cfg)
 	if err != nil {
 		log.Fatalf("failed to connect to database: %v", err)
 	}
 
+	// db.DropTables()
+
 	if err := db.Migrate(); err != nil {
 		log.Fatal("Migration failed: ", err)
 	}

cmd/legalgo/main.go

@@ -49,10 +49,11 @@ func run(lc fx.Lifecycle, db *database.DB, apiRouter chi.Router) {
 
 func main() {
 	app := fx.New(
+		config.Module,
 		database.Module,
 		repository.Module,
-		internalhttp.Module,
 		services.Module,
+		internalhttp.Module,
 		fx.Invoke(run),
 	)
 

config/auth.go

@@ -0,0 +1,17 @@
+package config
+
+import "time"
+
+type AuthConfig struct {
+	jwtTokenExpiresTTL int
+	jwtTokenSecret     string
+}
+
+func (c *AuthConfig) AccessTokenSecret() string {
+	return c.jwtTokenSecret
+}
+
+func (c *AuthConfig) AccessTokenExpiresDate() time.Time {
+	duration := time.Duration(c.jwtTokenExpiresTTL)
+	return time.Now().UTC().Add(time.Minute * duration)
+}

config/conf.go

@@ -1,9 +1,5 @@
 package config
 
-import (
-	"legalgo-BE-go/internal/utilities/utils"
-)
-
 var (
 	APP_PORT          int
 	GRACEFULL_TIMEOUT int
@@ -13,16 +9,19 @@ var (
 	DB_USER,
 	DB_PASSWORD,
 	DB_NAME,
-	DB_PORT string
+	DB_PORT,
+	SALT_SECURITY string
 )
 
 func InitEnv() {
-	DB_HOST = utils.GetOrDefault("DB_HOST", "localhost")
+	DB_HOST = GetOrDefault("DB_HOST", "localhost")
-	DB_USER = utils.GetOrDefault("DB_USER", "")
+	DB_USER = GetOrDefault("DB_USER", "")
-	DB_PASSWORD = utils.GetOrDefault("DB_PASSWORD", "")
+	DB_PASSWORD = GetOrDefault("DB_PASSWORD", "")
-	DB_NAME = utils.GetOrDefault("DB_NAME", "")
+	DB_NAME = GetOrDefault("DB_NAME", "")
-	DB_PORT = utils.GetOrDefault("DB_PORT", "")
+	DB_PORT = GetOrDefault("DB_PORT", "")
 
-	APP_PORT = utils.GetOrDefault("APP_PORT", 3000)
+	SALT_SECURITY = GetOrDefault("SALT_SECURITY", "legalgo")
-	GRACEFULL_TIMEOUT = utils.GetOrDefault("GRACEFULL_TIMEOUT", 10)
+
+	APP_PORT = GetOrDefault("APP_PORT", 3000)
+	GRACEFULL_TIMEOUT = GetOrDefault("GRACEFULL_TIMEOUT", 10)
 }

config/configs.go

@@ -0,0 +1,68 @@
+package config
+
+import (
+	"fmt"
+	"os"
+	"sync"
+
+	"github.com/spf13/viper"
+	_ "gopkg.in/yaml.v3"
+)
+
+const (
+	YAML_PATH        = "env/%s"
+	ENV_MODE         = "ENV_MODE"
+	DEFAULT_ENV_MODE = "development"
+)
+
+var (
+	validEnvMode = map[string]struct{}{
+		"local":       {},
+		"development": {},
+		"production":  {},
+	}
+)
+
+type Config struct {
+	Server    Server    `mapstructure:"server"`
+	Database  Database  `mapstructure:"postgresql"`
+	Jwt       Jwt       `mapstructure:"jwt"`
+	OSSConfig OSSConfig `mapstructure:"oss"`
+}
+
+var (
+	config     *Config
+	configOnce sync.Once
+)
+
+func LoadConfig() *Config {
+	envMode := os.Getenv(ENV_MODE)
+	if _, ok := validEnvMode[envMode]; !ok {
+		envMode = DEFAULT_ENV_MODE // default env mode
+	}
+	cfgFilePath := fmt.Sprintf(YAML_PATH, envMode)
+
+	configOnce.Do(func() {
+		v := viper.New()
+		v.SetConfigType("yaml")
+		v.AddConfigPath(".")
+		v.SetConfigName(cfgFilePath)
+		if err := v.ReadInConfig(); err != nil {
+			panic(fmt.Errorf("failed to read config file: %s", err))
+		}
+
+		config = &Config{}
+		if err := v.Unmarshal(config); err != nil {
+			panic(fmt.Errorf("failed to unmarshal config: %s", err))
+		}
+	})
+
+	return config
+}
+
+func (c *Config) Auth() *AuthConfig {
+	return &AuthConfig{
+		jwtTokenSecret:     c.Jwt.Token.Secret,
+		jwtTokenExpiresTTL: c.Jwt.Token.ExpiresTTL,
+	}
+}

config/db.go

@@ -0,0 +1,28 @@
+package config
+
+import (
+	"fmt"
+	"time"
+)
+
+type Database struct {
+	Host                          string `mapstructure:"host"`
+	Port                          string `mapstructure:"port"`
+	DB                            string `mapstructure:"db"`
+	Driver                        string `mapstructure:"driver"`
+	Username                      string `mapstructure:"username"`
+	Password                      string `mapstructure:"password"`
+	SslMode                       string `mapstructure:"ssl-mode"`
+	Debug                         bool   `mapstructure:"debug"`
+	MaxIdleConnectionsInSecond    int    `mapstructure:"max-idle-connections-in-second"`
+	MaxOpenConnectionsInSecond    int    `mapstructure:"max-open-connections-in-second"`
+	ConnectionMaxLifetimeInSecond int64  `mapstructure:"connection-max-life-time-in-second"`
+}
+
+func (c Database) DSN() string {
+	return fmt.Sprintf("host=%s port=%s dbname=%s user=%s password=%s sslmode=%s", c.Host, c.Port, c.DB, c.Username, c.Password, c.SslMode)
+}
+
+func (c Database) ConnectionMaxLifetime() time.Duration {
+	return time.Duration(c.ConnectionMaxLifetimeInSecond) * time.Second
+}

config/get_or_default.go

@@ -1,4 +1,4 @@
-package utils
+package config
 
 import (
 	"os"

config/http.go

@@ -0,0 +1,17 @@
+package config
+
+import "fmt"
+
+type httpConfig struct {
+	host          string
+	port          int
+	detailedError bool
+}
+
+func (c *httpConfig) Address() string {
+	return fmt.Sprintf("%s:%d", c.host, c.port)
+}
+
+func (c *httpConfig) DetailedError() bool {
+	return c.detailedError
+}

config/jwt.go

@@ -0,0 +1,10 @@
+package config
+
+type Jwt struct {
+	Token Token `mapstructure:"token"`
+}
+
+type Token struct {
+	ExpiresTTL int    `mapstructure:"expires-ttl"`
+	Secret     string `mapstructure:"secret"`
+}

config/module.go

@@ -0,0 +1,11 @@
+package config
+
+import (
+	"go.uber.org/fx"
+)
+
+var Module = fx.Module("config",
+	fx.Provide(
+		LoadConfig,
+	),
+)

config/oss.go

@@ -0,0 +1,44 @@
+package config
+
+type OSSConfig struct {
+	AccessKeyID     string `mapstructure:"access_key_id"`
+	AccessKeySecret string `mapstructure:"access_key_secret"`
+	Endpoint        string `mapstructure:"endpoint"`
+	BucketName      string `mapstructure:"bucket_name"`
+	PhotoFolder     string `mapstructure:"photo_folder"`
+	LogLevel        string `mapstructure:"log_level"`
+	HostURL         string `mapstructure:"host_url"`
+	PublicURL       string `mapstructure:"public_url"`
+}
+
+func (c OSSConfig) GetAccessKeyID() string {
+	return c.AccessKeyID
+}
+
+func (c OSSConfig) GetAccessKeySecret() string {
+	return c.AccessKeySecret
+}
+
+func (c OSSConfig) GetEndpoint() string {
+	return c.Endpoint
+}
+
+func (c OSSConfig) GetBucketName() string {
+	return c.BucketName
+}
+
+func (c OSSConfig) GetLogLevel() string {
+	return c.LogLevel
+}
+
+func (c OSSConfig) GetHostURL() string {
+	return c.HostURL
+}
+
+func (c OSSConfig) GetPublicURL() string {
+	return c.PublicURL
+}
+
+func (c OSSConfig) GetPhotoFolder() string {
+	return c.PhotoFolder
+}

config/server.go

@@ -0,0 +1,7 @@
+package config
+
+type Server struct {
+	Port     string `mapstructure:"port"`
+	BaseUrl  string `mapstructure:"common-url"`
+	LocalUrl string `mapstructure:"local-url"`
+}

database/category_model.go

@@ -0,0 +1,21 @@
+package database
+
+import (
+	"time"
+)
+
+type Category struct {
+	ID        string    `gorm:"primaryKey" json:"id"`
+	Code      string    `gorm:"not null;unique" json:"code"`
+	Name      string    `gorm:"not null" json:"name"`
+	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
+}
+
+type CategoryModel struct {
+	ID        string    `gorm:"primaryKey" json:"id"`
+	Name      string    `gorm:"not null;unique" json:"name"`
+	Code      string    `gorm:"not null" json:"code"`
+	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
+}

database/new_db.go

@@ -13,14 +13,14 @@ type DB struct {
 	*gorm.DB
 }
 
-func NewDB() (*DB, error) {
+func NewDB(cfg *config.Config) (*DB, error) {
 	dsn := fmt.Sprintf(
 		"host=%s user=%s password=%s dbname=%s port=%v sslmode=disable",
-		config.DB_HOST,
+		cfg.Database.Host,
-		config.DB_USER,
+		cfg.Database.Username,
-		config.DB_PASSWORD,
+		cfg.Database.Password,
-		config.DB_NAME,
+		cfg.Database.DB,
-		config.DB_PORT,
+		cfg.Database.Port,
 	)
 
 	if dsn == "" {
@@ -36,6 +36,18 @@ func NewDB() (*DB, error) {
 	return &DB{db}, nil
 }
 
+func (db *DB) DropTables() error {
+	// Auto Migrate the User model
+	return db.Migrator().DropTable(
+		// &Staff{},
+		// &SubscribePlan{},
+		// &Subscribe{},
+		// &User{},
+		&Tag{},
+		&Category{},
+		&News{},
+	)
+}
 func (db *DB) Migrate() error {
 	// Auto Migrate the User model
 	return db.AutoMigrate(
@@ -43,5 +55,11 @@ func (db *DB) Migrate() error {
 		&SubscribePlan{},
 		&Subscribe{},
 		&User{},
+		// &Tag{},
+		// &Category{},
+		// &News{},
+		&NewsModel{},
+		&TagModel{},
+		&CategoryModel{},
 	)
 }

database/news_model.go

@@ -6,12 +6,30 @@ import (
 
 type News struct {
 	ID            string     `gorm:"primaryKey" json:"id"`
-	AuthorID      string    `gorm:"not null" json:"author_id"`
 	Title         string     `gorm:"default:null" json:"title"`
+	Tags          []Tag      `gorm:"many2many:news_tags" json:"tags"`
+	Categories    []Category `gorm:"many2many:news_categories" json:"categories"`
 	Content       string     `gorm:"default:null" json:"content"`
+	LiveAt        time.Time  `gorm:"not null" json:"live_at"`
+	AuthorID      string     `gorm:"not null" json:"author_id"`
 	IsPremium     bool       `gorm:"default:false" json:"is_premium"`
 	Slug          string     `gorm:"default:null" json:"slug"`
 	FeaturedImage string     `gorm:"default:null" json:"featured_image"`
 	CreatedAt     time.Time  `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
 	UpdatedAt     time.Time  `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
 }
+
+type NewsModel struct {
+	ID            string          `gorm:"primaryKey" json:"id"`
+	Title         string          `json:"title"`
+	Content       string          `json:"content"`
+	Categories    []CategoryModel `gorm:"many2many:news_categories" json:"categories"`
+	Tags          []TagModel      `gorm:"many2many:news_tags" json:"tags"`
+	IsPremium     bool            `gorm:"default:false" json:"is_premium"`
+	Slug          string          `gorm:"default:null" json:"slug"`
+	FeaturedImage string          `gorm:"default:null" json:"featured_image"`
+	AuthorID      string          `gorm:"not null" json:"author_id"`
+	LiveAt        time.Time       `gorm:"not null" json:"live_at"`
+	CreatedAt     time.Time       `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt     time.Time       `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
+}

database/staff_model.go

@@ -6,8 +6,8 @@ import (
 
 type Staff struct {
 	ID        string    `gorm:"primaryKey" json:"id"`
-	Username  string    `gorm:"default:null" json:"username"`
+	Username  string    `gorm:"default:null;unique" json:"username"`
-	Email     string    `gorm:"unique,not null" json:"email"`
+	Email     string    `gorm:"unique;not null" json:"email"`
 	Password  string    `gorm:"not null" json:"password"`
 	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
 	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`

database/subscribe_model.go

@@ -19,7 +19,7 @@ type Subscribe struct {
 
 type SubscribePlan struct {
 	ID        string    `gorm:"primaryKey" json:"id"`
-	Code      string    `gorm:"not null" json:"code"`
+	Code      string    `gorm:"not null;unique" json:"code"`
 	Name      string    `gorm:"not null" json:"name"`
 	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP"`
 	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP"`

database/tag_module.go

@@ -0,0 +1,21 @@
+package database
+
+import (
+	"time"
+)
+
+type Tag struct {
+	ID        string    `gorm:"primaryKey" json:"id"`
+	Code      string    `gorm:"not null;unique" json:"code"`
+	Name      string    `gorm:"not null" json:"name"`
+	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
+}
+
+type TagModel struct {
+	ID        string    `gorm:"primaryKey" json:"id"`
+	Name      string    `gorm:"not null;unique" json:"name"`
+	Code      string    `gorm:"not null" json:"code"`
+	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
+}

database/tags_module.go

@@ -1,13 +0,0 @@
-package database
-
-import (
-	"time"
-)
-
-type Tags struct {
-	ID        string    `gorm:"primaryKey;not null" json:"id"`
-	Code      string    `gorm:"not null" json:"code"`
-	Name      string    `gorm:"not null" json:"name"`
-	CreatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
-	UpdatedAt time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
-}

database/user_model.go

@@ -5,11 +5,11 @@ import (
 )
 
 type User struct {
-	ID          string    `gorm:"primaryKey" json:"id"`
+	ID          string    `gorm:"primaryKey;not null" json:"id"`
 	SubscribeID string    `gorm:"not null" json:"subscribe_id"`
-	Email       string    `gorm:"unique,not null" json:"email"`
+	Email       string    `gorm:"unique;not null" json:"email"`
 	Password    string    `gorm:"not null" json:"password"`
-	Phone       string    `gorm:"default:null" json:"phone"`
+	Phone       string    `gorm:"default:not null;unique" json:"phone"`
 	CreatedAt   time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"created_at"`
 	UpdatedAt   time.Time `gorm:"default:CURRENT_TIMESTAMP" json:"updated_at"`
 

env/development.yaml

@@ -0,0 +1,31 @@
+server:
+  base-url: https://api.legalgo.id/core
+  local-url: http://localhost:3300
+  port: 3300
+
+jwt:
+  token:
+    expires-ttl: 1440
+    secret: "5Lm25V3Qd7aut8dr4QUxm5PZUrSFs"
+
+postgresql:
+  host: 62.72.45.250
+  port: 20826
+  driver: postgres
+  db: legalgonews-dev
+  username: legalgo_admin
+  password: 'K4K!2Kg7c@KW6H&4A2aBy2dFCRY3Sh'
+  ssl-mode: disable
+  max-idle-connections-in-second: 600
+  max-open-connections-in-second: 600
+  connection-max-life-time-in-second: 600
+  debug: false
+
+oss:
+  access_key_id: cf9a475e18bc7626cbdbf09709d82a64
+  access_key_secret: 91f3321294d3e23035427a0ecb893ada
+  endpoint: sin1.contabostorage.com
+  bucket_name: legalgonews-dev
+  log_level: Error
+  host_url: https://sin1.contabostorage.com
+  public_url: https://sin1.contabostorage.com/fda98c2228f246f29a7e466b86b3b9e7

go.mod

@@ -1,31 +1,48 @@
 module legalgo-BE-go
 
-go 1.24.0
+go 1.24
 
 require (
 	github.com/golang-jwt/jwt/v5 v5.2.1
 	github.com/joho/godotenv v1.5.1
+	github.com/spf13/viper v1.19.0
 	go.uber.org/fx v1.23.0
 	golang.org/x/crypto v0.34.0
-	gorm.io/driver/postgres v1.5.11
+	gopkg.in/yaml.v3 v3.0.1
+	gorm.io/driver/postgres v1.4.7
 )
 
 require (
+	github.com/fsnotify/fsnotify v1.7.0 // indirect
 	github.com/gabriel-vasile/mimetype v1.4.8 // indirect
 	github.com/go-playground/locales v0.14.1 // indirect
 	github.com/go-playground/universal-translator v0.18.1 // indirect
+	github.com/hashicorp/hcl v1.0.0 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
-	github.com/jackc/pgx/v5 v5.7.2 // indirect
+	github.com/jackc/pgx/v5 v5.2.0 // indirect
-	github.com/jackc/puddle/v2 v2.2.2 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
+	github.com/jmespath/go-jmespath v0.4.0 // indirect
 	github.com/leodido/go-urn v1.4.0 // indirect
+	github.com/magiconair/properties v1.8.7 // indirect
+	github.com/mitchellh/mapstructure v1.5.0 // indirect
+	github.com/pelletier/go-toml/v2 v2.2.2 // indirect
+	github.com/sagikazarmark/locafero v0.4.0 // indirect
+	github.com/sagikazarmark/slog-shim v0.1.0 // indirect
+	github.com/sourcegraph/conc v0.3.0 // indirect
+	github.com/spf13/afero v1.11.0 // indirect
+	github.com/spf13/cast v1.6.0 // indirect
+	github.com/spf13/pflag v1.0.5 // indirect
+	github.com/subosito/gotenv v1.6.0 // indirect
+	golang.org/x/exp v0.0.0-20230905200255-921286631fa9 // indirect
 	golang.org/x/net v0.34.0 // indirect
 	golang.org/x/text v0.22.0 // indirect
+	gopkg.in/ini.v1 v1.67.0 // indirect
 )
 
 require (
+	github.com/aws/aws-sdk-go v1.50.0
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/go-chi/chi/v5 v5.2.1

go.sum

@@ -1,14 +1,22 @@
+github.com/aws/aws-sdk-go v1.50.0 h1:HBtrLeO+QyDKnc3t1+5DR1RxodOHCGr8ZcrHudpv7jI=
+github.com/aws/aws-sdk-go v1.50.0/go.mod h1:LF8svs817+Nz+DmiMQKTO3ubZ/6IaTpq3TjupRn3Eqk=
 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/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-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/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
+github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/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/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
+github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=
+github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nosvA=
+github.com/fsnotify/fsnotify v1.7.0/go.mod h1:40Bi/Hjc2AVfZrqy+aj+yEI+/bRxZnMJyTJwOpGvigM=
 github.com/gabriel-vasile/mimetype v1.4.8 h1:FfZ3gj38NjllZIeJAmMhr+qKL8Wu+nOoI3GqacKw1NM=
 github.com/gabriel-vasile/mimetype v1.4.8/go.mod h1:ByKUIKGjh1ODkGM1asKUbQZOLGrPjydw3hYPU2YU9t8=
 github.com/go-chi/chi/v5 v5.2.1 h1:KOIHODQj58PmL80G2Eak4WdvUzjSJSm0vG72crDCqb8=
@@ -25,35 +33,89 @@ github.com/go-playground/validator/v10 v10.25.0 h1:5Dh7cjvzR7BRZadnsVOzPhWsrwUr0
 github.com/go-playground/validator/v10 v10.25.0/go.mod h1:GGzBIJMuE98Ic/kJsBXbz1x/7cByt++cQ+YOuDM5wus=
 github.com/golang-jwt/jwt/v5 v5.2.1 h1:OuVbFODueb089Lh128TAcimifWaLhJwVflnrgM17wHk=
 github.com/golang-jwt/jwt/v5 v5.2.1/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4=
+github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
 github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
 github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
+github.com/jackc/pgservicefile v0.0.0-20200714003250-2b9c44734f2b/go.mod h1:vsD4gTJCa9TptPL8sPkXrLZ+hDuNrZCnj29CQpr4X1E=
+github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
 github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 h1:iCEnooe7UlwOQYpKFhBabPMi4aNAfoODPEFNiAnClxo=
 github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
-github.com/jackc/pgx/v5 v5.7.2 h1:mLoDLV6sonKlvjIEsV56SkWNCnuNv531l94GaIzO+XI=
+github.com/jackc/pgx/v5 v5.2.0 h1:NdPpngX0Y6z6XDFKqmFQaE+bCtkqzvQIOt1wvBlAqs8=
-github.com/jackc/pgx/v5 v5.7.2/go.mod h1:ncY89UGWxg82EykZUwSpUKEfccBGGYq1xjrOpsbsfGQ=
+github.com/jackc/pgx/v5 v5.2.0/go.mod h1:Ptn7zmohNsWEsdxRawMzk3gaKma2obW+NWTnKa0S4nk=
-github.com/jackc/puddle/v2 v2.2.2 h1:PR8nw+E/1w0GLuRFSmiioY6UooMp6KJv0/61nB7icHo=
+github.com/jackc/puddle/v2 v2.1.2/go.mod h1:2lpufsF5mRHO6SuZkm0fNYxM6SWHfvyFj62KwNzgels=
-github.com/jackc/puddle/v2 v2.2.2/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
 github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
+github.com/jinzhu/now v1.1.4/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
 github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
+github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg=
+github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
+github.com/jmespath/go-jmespath/internal/testify v1.5.1 h1:shLQSRRSCCPj3f2gpwzGwWFoC7ycTf1rcQZHOlsJ6N8=
+github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
 github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
+github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
+github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
+github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk=
+github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
+github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
 github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/magiconair/properties v1.8.7 h1:IeQXZAiQcpL9mgcAe1Nu6cX9LLw6ExEHKjN0VQdvPDY=
+github.com/magiconair/properties v1.8.7/go.mod h1:Dhd985XPs7jluiymwWYZ0G4Z61jb3vdS329zhj2hYo0=
+github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY=
+github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
+github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
+github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U=
+github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/redis/go-redis/v9 v9.7.1 h1:4LhKRCIduqXqtvCUlaq9c8bdHOkICjDMrr1+Zb3osAc=
 github.com/redis/go-redis/v9 v9.7.1/go.mod h1:f6zhXITC7JUJIlPEiBOTXxJgPLdZcA93GewI7inzyWw=
+github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc=
+github.com/rogpeppe/go-internal v1.9.0 h1:73kH8U+JUqXU8lRuOHeVHaa/SZPifC7BkcraZVejAe8=
+github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
+github.com/sagikazarmark/locafero v0.4.0 h1:HApY1R9zGo4DBgr7dqsTH/JJxLTTsOt7u6keLGt6kNQ=
+github.com/sagikazarmark/locafero v0.4.0/go.mod h1:Pe1W6UlPYUk/+wc/6KFhbORCfqzgYEpgQ3O5fPuL3H4=
+github.com/sagikazarmark/slog-shim v0.1.0 h1:diDBnUNK9N/354PgrxMywXnAwEr1QZcOr6gto+ugjYE=
+github.com/sagikazarmark/slog-shim v0.1.0/go.mod h1:SrcSrq8aKtyuqEI1uvTDTK1arOWRIczQRv+GVI1AkeQ=
 github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ=
 github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
+github.com/sourcegraph/conc v0.3.0 h1:OQTbbt6P72L20UqAkXXuLOj79LfEanQ+YQFNpLA9ySo=
+github.com/sourcegraph/conc v0.3.0/go.mod h1:Sdozi7LEKbFPqYX2/J+iBAM6HpqSLTASQIKqDmF7Mt0=
+github.com/spf13/afero v1.11.0 h1:WJQKhtpdm3v2IzqG8VMqrr6Rf3UYpEF239Jy9wNepM8=
+github.com/spf13/afero v1.11.0/go.mod h1:GH9Y3pIexgf1MTIWtNGyogA5MwRIDXGUr+hbWNoBjkY=
+github.com/spf13/cast v1.6.0 h1:GEiTHELF+vaR5dhz3VqZfFSzZjYbgeKDpBxQVS4GYJ0=
+github.com/spf13/cast v1.6.0/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
+github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
+github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
+github.com/spf13/viper v1.19.0 h1:RWq5SEjt8o25SROyN3z2OrDB9l7RPd3lwTWU8EcEdcI=
+github.com/spf13/viper v1.19.0/go.mod h1:GQUN9bilAbhU/jgc1bKs99f/suXKeUMct8Adx5+Ntkg=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
+github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
+github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
+github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/subosito/gotenv v1.6.0 h1:9NlTDc1FTs4qu0DDq7AEtTPNw6SVm7uBMsUCUjABIf8=
+github.com/subosito/gotenv v1.6.0/go.mod h1:Dk4QP5c2W3ibzajGcXpNraDfq2IrhjMIvMSWPKKo0FU=
+github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
+go.uber.org/atomic v1.10.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
 go.uber.org/dig v1.18.0 h1:imUL1UiY0Mg4bqbFfsRQO5G4CGRBec/ZujWTvSVp3pw=
 go.uber.org/dig v1.18.0/go.mod h1:Us0rSJiThwCv2GteUN0Q7OKvU7n5J4dxZ9JKUXozFdE=
 go.uber.org/fx v1.23.0 h1:lIr/gYWQGfTwGcSXWXu4vP5Ws6iqnNEIY+F/aFzCKTg=
@@ -64,22 +126,67 @@ go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=
 go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
 go.uber.org/zap v1.26.0 h1:sI7k6L95XOKS281NhVKOFCUNIvv9e0w4BF8N3u+tCRo=
 go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so=
+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.0.0-20220829220503-c86fa9a7ed90/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
+golang.org/x/crypto v0.4.0/go.mod h1:3quD/ATkf6oY+rnes5c3ExXTbLc8mueNue5/DoinL80=
 golang.org/x/crypto v0.34.0 h1:+/C6tk6rf/+t5DhUketUbD1aNGqiSX3j15Z6xuIDlBA=
 golang.org/x/crypto v0.34.0/go.mod h1:dy7dXNW32cAb/6/PRuTNsix8T+vJAqvuIy5Bli/x0YQ=
+golang.org/x/exp v0.0.0-20230905200255-921286631fa9 h1:GoHiUyI/Tp2nVkLI2mCxVkOjsbSXD66ic0XW0js0R9g=
+golang.org/x/exp v0.0.0-20230905200255-921286631fa9/go.mod h1:S2oDrQGGwySpoQPVqRShND87VCbxmc6bL1Yd2oYrm6k=
+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-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
+golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
+golang.org/x/net v0.3.0/go.mod h1:MBQ8lrhLObU/6UmLb4fmbmk5OcyYmqtbGd/9yIeKjEE=
 golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0=
 golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
+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.0.0-20220923202941-7f9b1623fab7/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-20210423082822-04245dca01da/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-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.3.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/term v0.3.0/go.mod h1:q750SLmJuPmVoN1blW3UFBPREJfb1KmY3vwxfr+nFDA=
+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.6/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.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 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/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
+gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
+gopkg.in/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA=
+gopkg.in/ini.v1 v1.67.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10=
+gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-gorm.io/driver/postgres v1.5.11 h1:ubBVAfbKEUld/twyKZ0IYn9rSQh448EdelLYk9Mv314=
+gorm.io/driver/postgres v1.4.7 h1:J06jXZCNq7Pdf7LIPn8tZn9LsWjd81BRSKveKNr0ZfA=
-gorm.io/driver/postgres v1.5.11/go.mod h1:DX3GReXH+3FPWGrrgffdvCk3DQ1dwDPdmbenSkweRGI=
+gorm.io/driver/postgres v1.4.7/go.mod h1:UJChCNLFKeBqQRE+HrkFUbKbq9idPXmTOk2u4Wok8S4=
+gorm.io/gorm v1.24.2/go.mod h1:DVrVomtaYTbqs7gB/x2uVvqnXzv0nqjB396B8cG4dBA=
 gorm.io/gorm v1.25.12 h1:I0u8i2hWQItBq1WfE0o2+WuL9+8L21K9e2HHSTE/0f8=
 gorm.io/gorm v1.25.12/go.mod h1:xh7N7RHfYlNc5EmcI/El95gXusucDrQnHXe0+CgWcLQ=

internal/accessor/category/create.go

@@ -0,0 +1,21 @@
+package categoryrepository
+
+import (
+	categorydomain "legalgo-BE-go/internal/domain/category"
+
+	"github.com/google/uuid"
+)
+
+func (a *accessor) Create(spec categorydomain.CategoryReq) error {
+	data := categorydomain.Category{
+		ID:   uuid.NewString(),
+		Name: spec.Name,
+		Code: spec.Code,
+	}
+
+	if err := a.DB.Create(&data).Error; err != nil {
+		return err
+	}
+
+	return nil
+}

internal/accessor/category/create_model.go

@@ -0,0 +1,22 @@
+package categoryrepository
+
+import (
+	"legalgo-BE-go/database"
+	categorydomain "legalgo-BE-go/internal/domain/category"
+
+	"github.com/google/uuid"
+)
+
+func (a *accessor) CreateModel(spec categorydomain.CategoryReq) error {
+	data := database.CategoryModel{
+		ID:   uuid.NewString(),
+		Name: spec.Name,
+		Code: spec.Code,
+	}
+
+	if err := a.DB.Create(&data).Error; err != nil {
+		return err
+	}
+
+	return nil
+}

internal/accessor/category/get_all.go

@@ -0,0 +1,13 @@
+package categoryrepository
+
+import categorydomain "legalgo-BE-go/internal/domain/category"
+
+func (a *accessor) GetAll() ([]categorydomain.Category, error) {
+	var categories []categorydomain.Category
+
+	if err := a.DB.Find(&categories).Error; err != nil {
+		return nil, err
+	}
+
+	return categories, nil
+}

internal/accessor/category/get_all_model.go

@@ -0,0 +1,15 @@
+package categoryrepository
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (a *accessor) GetAllModel() ([]database.CategoryModel, error) {
+	var categories []database.CategoryModel
+
+	if err := a.DB.Find(&categories).Error; err != nil {
+		return nil, err
+	}
+
+	return categories, nil
+}

internal/accessor/category/get_bulk.go

@@ -0,0 +1,15 @@
+package categoryrepository
+
+import (
+	categorydomain "legalgo-BE-go/internal/domain/category"
+)
+
+func (a *accessor) GetByIDs(ids []string) ([]categorydomain.Category, error) {
+	var categories []categorydomain.Category
+
+	if err := a.DB.Find(&categories, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return categories, nil
+}

internal/accessor/category/get_bulk_model.go

@@ -0,0 +1,15 @@
+package categoryrepository
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (a *accessor) GetBulks(ids []string) ([]database.CategoryModel, error) {
+	var categories []database.CategoryModel
+
+	if err := a.DB.Find(&categories, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return categories, nil
+}

internal/accessor/category/impl.go

@@ -0,0 +1,27 @@
+package categoryrepository
+
+import (
+	"legalgo-BE-go/database"
+	categorydomain "legalgo-BE-go/internal/domain/category"
+)
+
+type accessor struct {
+	DB *database.DB
+}
+
+type Category interface {
+	Create(categorydomain.CategoryReq) error
+	CreateModel(categorydomain.CategoryReq) error
+
+	GetAll() ([]categorydomain.Category, error)
+	GetAllModel() ([]database.CategoryModel, error)
+
+	GetByIDs([]string) ([]categorydomain.Category, error)
+	GetBulks([]string) ([]database.CategoryModel, error)
+}
+
+func New(
+	db *database.DB,
+) Category {
+	return &accessor{db}
+}

internal/accessor/module.go

@@ -1,10 +1,14 @@
 package repository
 
 import (
+	categoryrepository "legalgo-BE-go/internal/accessor/category"
+	newsrepository "legalgo-BE-go/internal/accessor/news"
+	"legalgo-BE-go/internal/accessor/oss"
 	redisaccessor "legalgo-BE-go/internal/accessor/redis"
 	staffrepository "legalgo-BE-go/internal/accessor/staff"
 	subscriberepository "legalgo-BE-go/internal/accessor/subscribe"
 	subscribeplanrepository "legalgo-BE-go/internal/accessor/subscribeplan"
+	tagrepository "legalgo-BE-go/internal/accessor/tag"
 	userrepository "legalgo-BE-go/internal/accessor/user_repository"
 
 	"go.uber.org/fx"
@@ -16,4 +20,8 @@ var Module = fx.Module("repository", fx.Provide(
 	redisaccessor.New,
 	subscribeplanrepository.New,
 	subscriberepository.New,
+	tagrepository.New,
+	categoryrepository.New,
+	newsrepository.New,
+	oss.New,
 ))

internal/accessor/news/create.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import (
+	"fmt"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+)
+
+func (a *accessor) Create(spec *newsdomain.News) error {
+	if err := a.db.Create(&spec).Error; err != nil {
+		return fmt.Errorf("failed to create news: %w", err)
+	}
+	return nil
+}

internal/accessor/news/create_model.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import (
+	"fmt"
+	"legalgo-BE-go/database"
+)
+
+func (a *accessor) CreateModel(spec database.NewsModel) error {
+	if err := a.db.Create(&spec).Error; err != nil {
+		return fmt.Errorf("failed to create news: %w", err)
+	}
+	return nil
+}

internal/accessor/news/get_all.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import newsdomain "legalgo-BE-go/internal/domain/news"
+
+func (a *accessor) GetAll() ([]newsdomain.News, error) {
+	var news []newsdomain.News
+
+	if err := a.db.Preload("Tags").Preload("Categories").Find(&news).Error; err != nil {
+		return nil, err
+	}
+
+	return news, nil
+}

internal/accessor/news/get_all_model.go

@@ -0,0 +1,13 @@
+package newsrepository
+
+import "legalgo-BE-go/database"
+
+func (a *accessor) GetAllModel() ([]database.NewsModel, error) {
+	var news []database.NewsModel
+
+	if err := a.db.Preload("Tags").Preload("Categories").Find(&news).Error; err != nil {
+		return nil, err
+	}
+
+	return news, nil
+}

internal/accessor/news/impl.go

@@ -0,0 +1,21 @@
+package newsrepository
+
+import (
+	"legalgo-BE-go/database"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+)
+
+type accessor struct {
+	db *database.DB
+}
+
+type News interface {
+	GetAll() ([]newsdomain.News, error)
+	GetAllModel() ([]database.NewsModel, error)
+	Create(*newsdomain.News) error
+	CreateModel(database.NewsModel) error
+}
+
+func New(db *database.DB) News {
+	return &accessor{db}
+}

internal/accessor/oss/oss.go

@@ -0,0 +1,70 @@
+package oss
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"legalgo-BE-go/config"
+
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/credentials"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/s3"
+)
+
+type OSSConfig interface {
+	GetAccessKeyID() string
+	GetAccessKeySecret() string
+	GetEndpoint() string
+	GetBucketName() string
+	GetHostURL() string
+	GetPublicURL() string
+}
+
+const _awsRegion = "us-east-1"
+const _s3ACL = "public-read"
+
+type OssRepositoryImpl struct {
+	s3  *s3.S3
+	cfg OSSConfig
+}
+
+func New(cfg *config.Config) OSSRepository {
+	ossCfg := cfg.OSSConfig
+	sess, err := session.NewSession(&aws.Config{
+		S3ForcePathStyle: aws.Bool(true),
+		Endpoint:         aws.String(ossCfg.GetEndpoint()),
+		Region:           aws.String(_awsRegion),
+		Credentials:      credentials.NewStaticCredentials(ossCfg.GetAccessKeyID(), ossCfg.GetAccessKeySecret(), ""),
+	})
+
+	if err != nil {
+		fmt.Println("Failed to create AWS session:", err)
+		return nil
+	}
+
+	return &OssRepositoryImpl{
+		s3:  s3.New(sess),
+		cfg: ossCfg,
+	}
+}
+
+func (r *OssRepositoryImpl) UploadFile(ctx context.Context, fileName string, fileContent []byte) (fileUrl string, err error) {
+	reader := bytes.NewReader(fileContent)
+
+	_, err = r.s3.PutObject(&s3.PutObjectInput{
+		Bucket: aws.String(r.cfg.GetBucketName()),
+		Key:    aws.String(fileName),
+		Body:   reader,
+		ACL:    aws.String(_s3ACL),
+	})
+
+	return r.GetPublicURL(fileName), err
+}
+
+func (r *OssRepositoryImpl) GetPublicURL(fileName string) string {
+	if fileName == "" {
+		return ""
+	}
+	return fmt.Sprintf("%s:%s%s", r.cfg.GetPublicURL(), r.cfg.GetBucketName(), fileName)
+}

internal/accessor/oss/upload.go

@@ -0,0 +1,10 @@
+package oss
+
+import (
+	"context"
+)
+
+type OSSRepository interface {
+	UploadFile(ctx context.Context, fileName string, fileContent []byte) (fileUrl string, err error)
+	GetPublicURL(fileName string) string
+}

internal/accessor/staff/get_by_email.go

@@ -15,7 +15,7 @@ func (sr *StaffRepository) GetStaffByEmail(email string) (*authdomain.Staff, err
 		return nil, errors.New("email is required")
 	}
 
-	if err := sr.DB.Where("email = ?", email).First(&staff).Error; err != nil {
+	if err := sr.DB.First(&staff, "email = ?", email).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, errors.New("staff not found")
 		}

internal/accessor/staff/get_by_id.go

@@ -14,7 +14,7 @@ func (sr *StaffRepository) GetStaffByID(ID string) (*authdomain.Staff, error) {
 		return nil, errors.New("id is required")
 	}
 
-	if err := sr.DB.Where("id = ? ", ID).First(&staff).Error; err != nil {
+	if err := sr.DB.First(&staff, "id = ? ", ID).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, errors.New("staff not found")
 		}

internal/accessor/subscribeplan/get_by_id.go

@@ -0,0 +1,21 @@
+package subscribeplanrepository
+
+import (
+	"errors"
+	subscribeplandomain "legalgo-BE-go/internal/domain/subscribe_plan"
+
+	"gorm.io/gorm"
+)
+
+func (s *SubsPlan) GetByID(id string) (subscribeplandomain.SubscribePlan, error) {
+	var subscribePlan subscribeplandomain.SubscribePlan
+
+	if err := s.DB.First(&subscribePlan, "id = ? ", id).Error; err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return subscribePlan, errors.New("subscribe plan not found")
+		}
+		return subscribePlan, err
+	}
+
+	return subscribePlan, nil
+}

internal/accessor/subscribeplan/get_default.go

@@ -9,7 +9,7 @@ import (
 func (s *SubsPlan) GetDefault() (subscribeplandomain.SubscribePlan, error) {
 	var subscribePlan subscribeplandomain.SubscribePlan
 
-	if err := s.DB.Where("code = ?", "basic").First(&subscribePlan).Error; err != nil {
+	if err := s.DB.First(&subscribePlan, "code = ?", "basic").Error; err != nil {
 		s.DB.Create(&subscribeplandomain.SubscribePlan{
 			ID:   uuid.NewString(),
 			Code: "basic",

internal/accessor/subscribeplan/impl.go

@@ -12,6 +12,7 @@ type SubsPlan struct {
 type SubsPlanIntf interface {
 	Create(subscribeplandomain.SubscribePlanReq) error
 	GetAll() ([]subscribeplandomain.SubscribePlan, error)
+	GetByID(string) (subscribeplandomain.SubscribePlan, error)
 	GetDefault() (subscribeplandomain.SubscribePlan, error)
 }
 

internal/accessor/tag/create.go

@@ -0,0 +1,21 @@
+package tagrepository
+
+import (
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+
+	"github.com/google/uuid"
+)
+
+func (acc *accessor) Create(spec tagdomain.TagReq) error {
+	data := &tagdomain.Tag{
+		ID:   uuid.NewString(),
+		Code: spec.Code,
+		Name: spec.Name,
+	}
+
+	if err := acc.DB.Create(&data).Error; err != nil {
+		return err
+	}
+
+	return nil
+}

internal/accessor/tag/create_model.go

@@ -0,0 +1,22 @@
+package tagrepository
+
+import (
+	"legalgo-BE-go/database"
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+
+	"github.com/google/uuid"
+)
+
+func (acc *accessor) CreateModel(spec tagdomain.TagReq) error {
+	data := &database.TagModel{
+		ID:   uuid.NewString(),
+		Code: spec.Code,
+		Name: spec.Name,
+	}
+
+	if err := acc.DB.Create(&data).Error; err != nil {
+		return err
+	}
+
+	return nil
+}

internal/accessor/tag/get_all.go

@@ -0,0 +1,15 @@
+package tagrepository
+
+import (
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+)
+
+func (acc *accessor) GetAll() ([]tagdomain.Tag, error) {
+	var tags []tagdomain.Tag
+
+	if err := acc.DB.Find(&tags).Error; err != nil {
+		return nil, err
+	}
+
+	return tags, nil
+}

internal/accessor/tag/get_all_model.go

@@ -0,0 +1,13 @@
+package tagrepository
+
+import "legalgo-BE-go/database"
+
+func (acc *accessor) GetAllModel() ([]database.TagModel, error) {
+	var tags []database.TagModel
+
+	if err := acc.DB.Find(&tags).Error; err != nil {
+		return nil, err
+	}
+
+	return tags, nil
+}

internal/accessor/tag/get_bulk.go

@@ -0,0 +1,13 @@
+package tagrepository
+
+import tagdomain "legalgo-BE-go/internal/domain/tag"
+
+func (a *accessor) GetByIDs(ids []string) ([]tagdomain.Tag, error) {
+	var tags []tagdomain.Tag
+
+	if err := a.DB.Find(&tags, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return tags, nil
+}

internal/accessor/tag/get_bulk_model.go

@@ -0,0 +1,13 @@
+package tagrepository
+
+import "legalgo-BE-go/database"
+
+func (a *accessor) GetBulks(ids []string) ([]database.TagModel, error) {
+	var tags []database.TagModel
+
+	if err := a.DB.Find(&tags, "id IN ?", ids).Error; err != nil {
+		return nil, err
+	}
+
+	return tags, nil
+}

internal/accessor/tag/impl.go

@@ -0,0 +1,25 @@
+package tagrepository
+
+import (
+	"legalgo-BE-go/database"
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+)
+
+type accessor struct {
+	DB *database.DB
+}
+
+type TagAccessor interface {
+	Create(tagdomain.TagReq) error
+	CreateModel(tagdomain.TagReq) error
+	GetAll() ([]tagdomain.Tag, error)
+	GetAllModel() ([]database.TagModel, error)
+	GetByIDs([]string) ([]tagdomain.Tag, error)
+	GetBulks(ids []string) ([]database.TagModel, error)
+}
+
+func New(
+	db *database.DB,
+) TagAccessor {
+	return &accessor{db}
+}

internal/accessor/user_repository/get_user_by_email.go

@@ -15,7 +15,7 @@ func (ur *UserRepository) GetUserByEmail(email string) (*authdomain.User, error)
 		return nil, errors.New("email is empty")
 	}
 
-	if err := ur.DB.Where("email = ?", email).First(&user).Error; err != nil {
+	if err := ur.DB.First(&user, "email = ?", email).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, errors.New("user not found")
 		}

internal/accessor/user_repository/get_user_profile.go

@@ -0,0 +1,30 @@
+package userrepository
+
+import (
+	"errors"
+	authdomain "legalgo-BE-go/internal/domain/auth"
+
+	"gorm.io/gorm"
+)
+
+func (ur *UserRepository) GetUserProfile(email string) (*authdomain.UserProfile, error) {
+	var users []authdomain.UserProfile
+
+	if email == "" {
+		return nil, errors.New("email is empty")
+	}
+
+	if err := ur.DB.Table("users u").
+		Where("email = ?", email).
+		Select("u.email, u.id, s.status as subscribe_status, sp.code as subscribe_plan_code, sp.name as subscribe_plan_name").
+		Joins("join subscribes s on s.id = u.subscribe_id").
+		Joins("join subscribe_plans sp on s.subscribe_plan_id = sp.id").
+		Scan(&users).Error; err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return nil, errors.New("user not found")
+		}
+		return nil, err
+	}
+
+	return &users[0], nil
+}

internal/accessor/user_repository/impl.go

@@ -12,6 +12,7 @@ type UserRepository struct {
 type UserIntf interface {
 	GetUserByEmail(string) (*authdomain.User, error)
 	GetUserByID(string) (*authdomain.UserProfile, error)
+	GetUserProfile(string) (*authdomain.UserProfile, error)
 	CreateUser(*authdomain.User) (*authdomain.User, error)
 }
 

internal/api/http/auth/profile.go

@@ -1,9 +1,9 @@
 package authhttp
 
 import (
-	"errors"
 	authsvc "legalgo-BE-go/internal/services/auth"
 	"legalgo-BE-go/internal/utilities/response"
+	"legalgo-BE-go/internal/utilities/utils"
 	"net/http"
 
 	"github.com/go-chi/chi/v5"
@@ -13,22 +13,22 @@ func GetStaffProfile(
 	router chi.Router,
 	authSvc authsvc.AuthIntf,
 ) {
-	router.Get("/staff/{id}/profile", func(w http.ResponseWriter, r *http.Request) {
+	router.Get("/staff/profile", func(w http.ResponseWriter, r *http.Request) {
 		ctx := r.Context()
-		id := chi.URLParam(r, "id")
+		destructedToken, err := utils.GetTokenDetail(r)
-		if id == "" {
+		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,
 				w,
-				errors.New("provided id is empty"),
+				err,
 				response.ErrBadRequest.Code,
 				response.ErrBadRequest.HttpCode,
-				"required params is not provided",
+				err.Error(),
 			)
 			return
 		}
 
-		staffProfile, err := authSvc.GetStaffProfile(id)
+		staffProfile, err := authSvc.GetStaffProfile(destructedToken.Email)
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,
@@ -49,22 +49,22 @@ func GetUserProfile(
 	router chi.Router,
 	authSvc authsvc.AuthIntf,
 ) {
-	router.Get("/user/{id}/profile", func(w http.ResponseWriter, r *http.Request) {
+	router.Get("/user/profile", func(w http.ResponseWriter, r *http.Request) {
 		ctx := r.Context()
-		id := chi.URLParam(r, "id")
+		destructedToken, err := utils.GetTokenDetail(r)
-		if id == "" {
+		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,
 				w,
-				errors.New("provided id is empty"),
+				err,
 				response.ErrBadRequest.Code,
 				response.ErrBadRequest.HttpCode,
-				"required params is not provided",
+				err.Error(),
 			)
 			return
 		}
 
-		userProfile, err := authSvc.GetUserProfile(id)
+		userProfile, err := authSvc.GetUserProfile(destructedToken.Email)
 		if err != nil {
 			response.ResponseWithErrorCode(
 				ctx,

internal/api/http/category/create.go

@@ -0,0 +1,67 @@
+package categoryhttp
+
+import (
+	categorydomain "legalgo-BE-go/internal/domain/category"
+	categorysvc "legalgo-BE-go/internal/services/category"
+	"legalgo-BE-go/internal/utilities/response"
+	"legalgo-BE-go/internal/utilities/utils"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+	"github.com/go-playground/validator/v10"
+)
+
+func Create(
+	router chi.Router,
+	validate *validator.Validate,
+	categorySvc categorysvc.Category,
+) {
+	router.Post("/category/create", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+
+		var spec categorydomain.CategoryReq
+
+		if err := utils.UnmarshalBody(r, &spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+
+			return
+		}
+
+		if err := validate.Struct(spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.(validator.ValidationErrors).Error(),
+			)
+			return
+		}
+
+		if err := categorySvc.Create(spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrCreateEntity.Code,
+				response.ErrCreateEntity.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, struct {
+			Message string
+		}{
+			Message: "category created successfully",
+		})
+	})
+}

internal/api/http/category/get_all.go

@@ -0,0 +1,33 @@
+package categoryhttp
+
+import (
+	categorysvc "legalgo-BE-go/internal/services/category"
+	"legalgo-BE-go/internal/utilities/response"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+)
+
+func GetAll(
+	router chi.Router,
+	categorySvc categorysvc.Category,
+) {
+	router.Get("/category", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+		subsPlan, err := categorySvc.GetAllModel()
+		// subsPlan, err := categorySvc.GetAll()
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, subsPlan)
+	})
+}

internal/api/http/category/module.go

@@ -0,0 +1,8 @@
+package categoryhttp
+
+import "go.uber.org/fx"
+
+var Module = fx.Module("categories", fx.Invoke(
+	Create,
+	GetAll,
+))

internal/api/http/news/create.go

@@ -0,0 +1,93 @@
+package newshttp
+
+import (
+	staffrepository "legalgo-BE-go/internal/accessor/staff"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+	newssvc "legalgo-BE-go/internal/services/news"
+	"legalgo-BE-go/internal/utilities/response"
+	"legalgo-BE-go/internal/utilities/utils"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+	"github.com/go-playground/validator/v10"
+)
+
+func Create(
+	validate *validator.Validate,
+	newsSvc newssvc.News,
+	staffRepo staffrepository.StaffIntf,
+	router chi.Router,
+) {
+	router.Post("/news/create", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+		var spec newsdomain.NewsReq
+
+		if err := utils.UnmarshalBody(r, &spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		if err := validate.Struct(spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.(validator.ValidationErrors).Error(),
+			)
+			return
+		}
+
+		destructedToken, err := utils.GetTokenDetail(r)
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		staffProfile, err := staffRepo.GetStaffByEmail(destructedToken.Email)
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		if err := newsSvc.CreateModel(spec, staffProfile.ID); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, struct {
+			Message string
+		}{
+			Message: "news created successfully.",
+		})
+	})
+}

internal/api/http/news/get_all.go

@@ -0,0 +1,32 @@
+package newshttp
+
+import (
+	newssvc "legalgo-BE-go/internal/services/news"
+	"legalgo-BE-go/internal/utilities/response"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+)
+
+func GetAll(
+	router chi.Router,
+	newsSvc newssvc.News,
+) {
+	router.Get("/news", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+		news, err := newsSvc.GetAllModel()
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, news)
+	})
+}

internal/api/http/news/module.go

@@ -0,0 +1,8 @@
+package newshttp
+
+import "go.uber.org/fx"
+
+var Module = fx.Module("news", fx.Invoke(
+	GetAll,
+	Create,
+))

internal/api/http/oss/module.go

@@ -0,0 +1,11 @@
+package osshttp
+
+import (
+	"go.uber.org/fx"
+)
+
+var Module = fx.Module("upload",
+	fx.Invoke(
+		RegisterUploadFile,
+	),
+)

internal/api/http/oss/upload.go

@@ -0,0 +1,92 @@
+package osshttp
+
+import (
+	"fmt"
+	oss2 "legalgo-BE-go/internal/domain/oss"
+	"legalgo-BE-go/internal/services/oss"
+	"legalgo-BE-go/internal/utilities/response"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+)
+
+const _oneMB = 1 << 20
+const _maxUploadSize = 2 * _oneMB
+const _folderName = "/file"
+
+func RegisterUploadFile(ossService oss.OSSService, router chi.Router) {
+	router.Post("/file", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+
+		// Limit the size of the request body to prevent very large uploads.
+		r.Body = http.MaxBytesReader(w, r.Body, int64(_maxUploadSize))
+		if err := r.ParseMultipartForm(int64(_maxUploadSize)); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"Failed to parse multipart form",
+			)
+			return
+		}
+
+		// Retrieve the file from the form.
+		file, header, err := r.FormFile("file")
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"Failed to retrieve file",
+			)
+			return
+		}
+		defer file.Close()
+
+		// Check if file size exceeds the maximum limit.
+		if header.Size > int64(_maxUploadSize) {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				fmt.Errorf("file too big"),
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				fmt.Sprintf("The file is too big. The maximum size is %d MB", _maxUploadSize/_oneMB),
+			)
+			return
+		}
+
+		// Prepare the request for the OSS service.
+		uploadReq := &oss2.UploadFileRequest{
+			FileHeader: header,
+			FolderName: _folderName,
+		}
+
+		// Call the OSS service to handle the file upload.
+		result, err := ossService.UploadFile(ctx, uploadReq)
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		// Return a successful JSON response.
+		response.RespondJsonSuccess(ctx, w, struct {
+			Message string      `json:"message"`
+			Data    interface{} `json:"data"`
+		}{
+			Message: "File uploaded successfully.",
+			Data:    result,
+		})
+	})
+}

internal/api/http/router.go

@@ -2,7 +2,11 @@ package internalhttp
 
 import (
 	authhttp "legalgo-BE-go/internal/api/http/auth"
+	categoryhttp "legalgo-BE-go/internal/api/http/category"
+	newshttp "legalgo-BE-go/internal/api/http/news"
+	osshttp "legalgo-BE-go/internal/api/http/oss"
 	subscribeplanhttp "legalgo-BE-go/internal/api/http/subscribe_plan"
+	taghttp "legalgo-BE-go/internal/api/http/tag"
 
 	"github.com/go-chi/chi/v5"
 	"github.com/go-chi/cors"
@@ -19,6 +23,10 @@ var Module = fx.Module("router",
 	),
 	authhttp.Module,
 	subscribeplanhttp.Module,
+	taghttp.Module,
+	categoryhttp.Module,
+	newshttp.Module,
+	osshttp.Module,
 )
 
 func initRouter() chi.Router {

internal/api/http/tag/create.go

@@ -0,0 +1,67 @@
+package taghttp
+
+import (
+	"net/http"
+
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+	tagsvc "legalgo-BE-go/internal/services/tag"
+	"legalgo-BE-go/internal/utilities/response"
+	"legalgo-BE-go/internal/utilities/utils"
+
+	"github.com/go-chi/chi/v5"
+	"github.com/go-playground/validator/v10"
+)
+
+func Create(
+	router chi.Router,
+	validate *validator.Validate,
+	tagSvc tagsvc.TagIntf,
+) {
+	router.Post("/tag/create", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+
+		var spec tagdomain.TagReq
+
+		if err := utils.UnmarshalBody(r, &spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				"failed to unmarshal request",
+			)
+			return
+		}
+
+		if err := validate.Struct(spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.(validator.ValidationErrors).Error(),
+			)
+			return
+		}
+
+		if err := tagSvc.Create(spec); err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrCreateEntity.Code,
+				response.ErrCreateEntity.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, struct {
+			Message string
+		}{
+			Message: "tag created successfully.",
+		})
+	})
+}

internal/api/http/tag/get_all.go

@@ -0,0 +1,33 @@
+package taghttp
+
+import (
+	tagsvc "legalgo-BE-go/internal/services/tag"
+	"legalgo-BE-go/internal/utilities/response"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+)
+
+func GetAll(
+	router chi.Router,
+	tagSvc tagsvc.TagIntf,
+) {
+	router.Get("/tag", func(w http.ResponseWriter, r *http.Request) {
+		ctx := r.Context()
+		tags, err := tagSvc.GetAllModel()
+		// tags, err := tagSvc.GetAll()
+		if err != nil {
+			response.ResponseWithErrorCode(
+				ctx,
+				w,
+				err,
+				response.ErrBadRequest.Code,
+				response.ErrBadRequest.HttpCode,
+				err.Error(),
+			)
+			return
+		}
+
+		response.RespondJsonSuccess(ctx, w, tags)
+	})
+}

internal/api/http/tag/module.go

@@ -0,0 +1,8 @@
+package taghttp
+
+import "go.uber.org/fx"
+
+var Module = fx.Module("tag", fx.Invoke(
+	Create,
+	GetAll,
+))

internal/domain/auth/register.go

@@ -3,7 +3,7 @@ package authdomain
 type RegisterUserReq struct {
 	Email           string `json:"email" validate:"required"`
 	Password        string `json:"password" validate:"required"`
-	Phone           string `json:"phone"`
+	Phone           string `json:"phone" validate:"required"`
 	SubscribePlanID string `json:"subscribe_plan_id"`
 }
 

internal/domain/auth/token.go

@@ -0,0 +1,6 @@
+package authdomain
+
+type AuthToken struct {
+	Email     string
+	SessionID string
+}

internal/domain/category/spec.go

@@ -0,0 +1,12 @@
+package categorydomain
+
+type Category struct {
+	ID   string `json:"id" gorm:"primaryKey"`
+	Name string `json:"name"`
+	Code string `json:"code"`
+}
+
+type CategoryReq struct {
+	Name string `json:"name" validate:"required"`
+	Code string `json:"code" validate:"required"`
+}

internal/domain/news/request.go

@@ -1,12 +0,0 @@
-package newsdomain
-
-type News struct {
-	Title         string   `json:"title"`
-	Content       string   `json:"content"`
-	FeaturedImage string   `json:"featured_image"`
-	Tags          []string `json:"tags"`
-	Categories    []string `json:"categories"`
-	IsPremium     bool     `json:"is_premium"`
-	Slug          string   `json:"slug"`
-	Author        string   `json:"author"`
-}

internal/domain/news/spec.go

@@ -0,0 +1,32 @@
+package newsdomain
+
+import (
+	categorydomain "legalgo-BE-go/internal/domain/category"
+	tagdomain "legalgo-BE-go/internal/domain/tag"
+	"time"
+)
+
+type NewsReq struct {
+	Title         string   `json:"title" validate:"required"`
+	Content       string   `json:"content"`
+	FeaturedImage string   `json:"featured_image"`
+	Tags          []string `json:"tags"`
+	Categories    []string `json:"categories"`
+	IsPremium     bool     `json:"is_premium"`
+	LiveAt        string   `json:"live_at" validate:"required"`
+}
+
+type News struct {
+	ID            string                    `json:"id"`
+	Title         string                    `json:"title"`
+	Content       string                    `json:"content"`
+	FeaturedImage string                    `json:"featured_image"`
+	Tags          []tagdomain.Tag           `json:"tags"`
+	Categories    []categorydomain.Category `json:"categories"`
+	IsPremium     bool                      `json:"is_premium"`
+	Slug          string                    `json:"slug"`
+	AuthorID      string                    `json:"author_id"`
+	LiveAt        time.Time                 `json:"live_at"`
+	CreatedAt     time.Time                 `json:"created_at"`
+	UpdatedAt     time.Time                 `json:"updated_at"`
+}

internal/domain/oss/oss.go

@@ -0,0 +1,24 @@
+package oss
+
+import "mime/multipart"
+
+type UploadFileRequest struct {
+	FileHeader *multipart.FileHeader
+	FolderName string
+	FileSize   int64  `validate:"max=10000000"` // 10Mb = 10000000 byte
+	Ext        string `validate:"oneof=.png .jpeg .jpg .pdf .xlsx .csv"`
+}
+
+type DownloadFileRequest struct {
+	FileName   string `query:"file_name" validate:"required"`
+	FolderName string `query:"folder_name" validate:"required"`
+}
+
+type UploadFileResponse struct {
+	FilePath string `json:"file_path"`
+	FileUrl  string `json:"file_url"`
+}
+
+type DownloadFileResponse struct {
+	FileUrl string `json:"file_url"`
+}

internal/domain/tag/spec.go

@@ -0,0 +1,12 @@
+package tagdomain
+
+type TagReq struct {
+	Code string `json:"code" validate:"required"`
+	Name string `json:"name" validate:"required"`
+}
+
+type Tag struct {
+	ID   string `json:"id" gorm:"primaryKey"`
+	Code string `json:"code"`
+	Name string `json:"name"`
+}

internal/enums/jwt/jwt_claims.go

@@ -4,7 +4,7 @@ type JWTClaim string
 
 const (
 	TYPE       JWTClaim = "type"
-	USERNAME   JWTClaim = "username"
+	EMAIL      JWTClaim = "email"
 	EXPIRED_AT JWTClaim = "exp"
 	SESSION_ID JWTClaim = "sid"
 	ISSUED_AT  JWTClaim = "iat"

internal/services/auth/get_staff.go

@@ -2,8 +2,8 @@ package authsvc
 
 import authdomain "legalgo-BE-go/internal/domain/auth"
 
-func (as *AuthSvc) GetStaffProfile(id string) (*authdomain.StaffProfile, error) {
+func (as *AuthSvc) GetStaffProfile(email string) (*authdomain.StaffProfile, error) {
-	staff, err := as.staffRepo.GetStaffByID(id)
+	staff, err := as.staffRepo.GetStaffByEmail(email)
 	if err != nil {
 		return nil, err
 	}

internal/services/auth/get_user.go

@@ -2,8 +2,8 @@ package authsvc
 
 import authdomain "legalgo-BE-go/internal/domain/auth"
 
-func (as *AuthSvc) GetUserProfile(id string) (*authdomain.UserProfile, error) {
+func (as *AuthSvc) GetUserProfile(email string) (*authdomain.UserProfile, error) {
-	user, err := as.userRepo.GetUserByID(id)
+	user, err := as.userRepo.GetUserProfile(email)
 	if err != nil {
 		return nil, err
 	}

internal/services/auth/login_as_staff.go

@@ -5,6 +5,8 @@ import (
 
 	authdomain "legalgo-BE-go/internal/domain/auth"
 	"legalgo-BE-go/internal/utilities/utils"
+
+	"github.com/google/uuid"
 )
 
 func (sv *AuthSvc) LoginAsStaff(spec authdomain.LoginReq) (string, error) {
@@ -18,7 +20,12 @@ func (sv *AuthSvc) LoginAsStaff(spec authdomain.LoginReq) (string, error) {
 		return "", errors.New("wrong password")
 	}
 
-	token, err := utils.GenerateToken(staff.Email)
+	authToken := authdomain.AuthToken{
+		Email:     staff.Email,
+		SessionID: uuid.NewString(),
+	}
+
+	token, err := utils.GenerateToken(authToken)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}

internal/services/auth/login_as_user.go

@@ -5,6 +5,8 @@ import (
 
 	authdomain "legalgo-BE-go/internal/domain/auth"
 	"legalgo-BE-go/internal/utilities/utils"
+
+	"github.com/google/uuid"
 )
 
 func (a *AuthSvc) LoginAsUser(spec authdomain.LoginReq) (string, error) {
@@ -18,7 +20,12 @@ func (a *AuthSvc) LoginAsUser(spec authdomain.LoginReq) (string, error) {
 		return "", errors.New("wrong password")
 	}
 
-	token, err := utils.GenerateToken(user.Email)
+	authToken := authdomain.AuthToken{
+		Email:     user.Email,
+		SessionID: uuid.NewString(),
+	}
+
+	token, err := utils.GenerateToken(authToken)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}

internal/services/auth/register_staff.go

@@ -19,19 +19,24 @@ func (a *AuthSvc) RegisterStaff(spec authdomain.RegisterStaffReq) (string, error
 		return "", err
 	}
 
-	user := authdomain.Staff{
+	staff := authdomain.Staff{
 		ID:       uuid.NewString(),
 		Email:    spec.Email,
 		Password: hashedPwd,
 		Username: spec.Username,
 	}
 
-	_, err = a.staffRepo.Create(&user)
+	_, err = a.staffRepo.Create(&staff)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}
 
-	token, err := utils.GenerateToken(spec.Email)
+	authToken := authdomain.AuthToken{
+		Email:     staff.Email,
+		SessionID: uuid.NewString(),
+	}
+
+	token, err := utils.GenerateToken(authToken)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}

internal/services/auth/register_user.go

@@ -25,9 +25,14 @@ func (a *AuthSvc) RegisterUser(spec authdomain.RegisterUserReq) (string, error)
 		spec.SubscribePlanID = subsPlan.ID
 	}
 
+	_, err = a.subsPlanRepo.GetByID(spec.SubscribePlanID)
+	if err != nil {
+		return "", errors.New(err.Error())
+	}
+
 	subsId, err := a.subsRepo.Create(spec.SubscribePlanID)
 	if err != nil {
-		return "", nil
+		return "", err
 	}
 
 	hashedPwd, err := HashPassword(spec.Password)
@@ -48,7 +53,12 @@ func (a *AuthSvc) RegisterUser(spec authdomain.RegisterUserReq) (string, error)
 		return "", errors.New(err.Error())
 	}
 
-	token, err := utils.GenerateToken(spec.Email)
+	authToken := authdomain.AuthToken{
+		Email:     user.Email,
+		SessionID: uuid.NewString(),
+	}
+
+	token, err := utils.GenerateToken(authToken)
 	if err != nil {
 		return "", errors.New(err.Error())
 	}

internal/services/category/create.go

@@ -0,0 +1,8 @@
+package categorysvc
+
+import categorydomain "legalgo-BE-go/internal/domain/category"
+
+func (i *impl) Create(spec categorydomain.CategoryReq) error {
+	return i.categoryRepo.CreateModel(spec)
+	// return i.categoryRepo.Create(spec)
+}

internal/services/category/get_all.go

@@ -0,0 +1,7 @@
+package categorysvc
+
+import categorydomain "legalgo-BE-go/internal/domain/category"
+
+func (i *impl) GetAll() ([]categorydomain.Category, error) {
+	return i.categoryRepo.GetAll()
+}

internal/services/category/get_all_model.go

@@ -0,0 +1,9 @@
+package categorysvc
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (i *impl) GetAllModel() ([]database.CategoryModel, error) {
+	return i.categoryRepo.GetAllModel()
+}

internal/services/category/impl.go

@@ -0,0 +1,25 @@
+package categorysvc
+
+import (
+	"legalgo-BE-go/database"
+	categoryrepository "legalgo-BE-go/internal/accessor/category"
+	categorydomain "legalgo-BE-go/internal/domain/category"
+)
+
+type impl struct {
+	categoryRepo categoryrepository.Category
+}
+
+type Category interface {
+	Create(categorydomain.CategoryReq) error
+	GetAll() ([]categorydomain.Category, error)
+	GetAllModel() ([]database.CategoryModel, error)
+}
+
+func New(
+	categoryRepo categoryrepository.Category,
+) Category {
+	return &impl{
+		categoryRepo: categoryRepo,
+	}
+}

internal/services/module.go

@@ -2,8 +2,12 @@ package services
 
 import (
 	serviceauth "legalgo-BE-go/internal/services/auth"
+	categorysvc "legalgo-BE-go/internal/services/category"
+	newssvc "legalgo-BE-go/internal/services/news"
+	"legalgo-BE-go/internal/services/oss"
 	subscribesvc "legalgo-BE-go/internal/services/subscribe"
 	subscribeplansvc "legalgo-BE-go/internal/services/subscribe_plan"
+	tagsvc "legalgo-BE-go/internal/services/tag"
 
 	"go.uber.org/fx"
 )
@@ -13,5 +17,9 @@ var Module = fx.Module("services",
 		serviceauth.New,
 		subscribeplansvc.New,
 		subscribesvc.New,
+		tagsvc.New,
+		categorysvc.New,
+		newssvc.New,
+		oss.NewOSSService,
 	),
 )

internal/services/news/create.go

@@ -0,0 +1,47 @@
+package newssvc
+
+import (
+	newsdomain "legalgo-BE-go/internal/domain/news"
+	"strings"
+	"time"
+
+	"github.com/google/uuid"
+)
+
+func (i *impl) Create(spec newsdomain.NewsReq, staffId string) error {
+	slug := strings.ToLower(strings.ReplaceAll(spec.Title, " ", "-"))
+
+	tags, err := i.tagRepo.GetByIDs(spec.Tags)
+	if err != nil {
+		return err
+	}
+
+	categories, err := i.categoryRepo.GetByIDs(spec.Categories)
+	if err != nil {
+		return err
+	}
+
+	parsedTime, err := time.Parse(time.RFC3339, spec.LiveAt)
+	if err != nil {
+		return err
+	}
+
+	newSpec := &newsdomain.News{
+		ID:            uuid.NewString(),
+		Title:         spec.Title,
+		Content:       spec.Content,
+		FeaturedImage: spec.FeaturedImage,
+		IsPremium:     spec.IsPremium,
+		Slug:          slug,
+		LiveAt:        parsedTime,
+		AuthorID:      staffId,
+		Tags:          tags,
+		Categories:    categories,
+	}
+
+	if err := i.newsRepo.Create(newSpec); err != nil {
+		return err
+	}
+
+	return nil
+}

internal/services/news/create_model.go

@@ -0,0 +1,48 @@
+package newssvc
+
+import (
+	"legalgo-BE-go/database"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+	"strings"
+	"time"
+
+	"github.com/google/uuid"
+)
+
+func (i *impl) CreateModel(spec newsdomain.NewsReq, staffId string) error {
+	slug := strings.ToLower(strings.ReplaceAll(spec.Title, " ", "-"))
+
+	tags, err := i.tagRepo.GetBulks(spec.Tags)
+	if err != nil {
+		return err
+	}
+
+	categories, err := i.categoryRepo.GetBulks(spec.Categories)
+	if err != nil {
+		return err
+	}
+
+	parsedTime, err := time.Parse(time.RFC3339, spec.LiveAt)
+	if err != nil {
+		return err
+	}
+
+	newSpec := database.NewsModel{
+		ID:            uuid.NewString(),
+		Title:         spec.Title,
+		Content:       spec.Content,
+		FeaturedImage: spec.FeaturedImage,
+		IsPremium:     spec.IsPremium,
+		Slug:          slug,
+		LiveAt:        parsedTime,
+		AuthorID:      staffId,
+		Tags:          tags,
+		Categories:    categories,
+	}
+
+	if err := i.newsRepo.CreateModel(newSpec); err != nil {
+		return err
+	}
+
+	return nil
+}

internal/services/news/get_all.go

@@ -0,0 +1,7 @@
+package newssvc
+
+import newsdomain "legalgo-BE-go/internal/domain/news"
+
+func (i *impl) GetAll() ([]newsdomain.News, error) {
+	return i.newsRepo.GetAll()
+}

internal/services/news/get_all_model.go

@@ -0,0 +1,9 @@
+package newssvc
+
+import (
+	"legalgo-BE-go/database"
+)
+
+func (i *impl) GetAllModel() ([]database.NewsModel, error) {
+	return i.newsRepo.GetAllModel()
+}

internal/services/news/impl.go

@@ -0,0 +1,34 @@
+package newssvc
+
+import (
+	"legalgo-BE-go/database"
+	categoryrepository "legalgo-BE-go/internal/accessor/category"
+	newsrepository "legalgo-BE-go/internal/accessor/news"
+	tagrepository "legalgo-BE-go/internal/accessor/tag"
+	newsdomain "legalgo-BE-go/internal/domain/news"
+)
+
+type impl struct {
+	newsRepo     newsrepository.News
+	tagRepo      tagrepository.TagAccessor
+	categoryRepo categoryrepository.Category
+}
+
+type News interface {
+	GetAll() ([]newsdomain.News, error)
+	GetAllModel() ([]database.NewsModel, error)
+	Create(newsdomain.NewsReq, string) error
+	CreateModel(newsdomain.NewsReq, string) error
+}
+
+func New(
+	newsRepo newsrepository.News,
+	tagRepo tagrepository.TagAccessor,
+	categoryRepo categoryrepository.Category,
+) News {
+	return &impl{
+		newsRepo,
+		tagRepo,
+		categoryRepo,
+	}
+}

internal/services/oss/impl.go

@@ -0,0 +1,62 @@
+package oss
+
+import (
+	"context"
+	"fmt"
+	"github.com/google/uuid"
+	oss2 "legalgo-BE-go/internal/accessor/oss"
+	"legalgo-BE-go/internal/domain/oss"
+	"path"
+	"strconv"
+	"time"
+
+	"github.com/go-playground/validator/v10"
+)
+
+type OssService struct {
+	ossRepo oss2.OSSRepository
+}
+
+func NewOSSService(ossRepo oss2.OSSRepository) OSSService {
+	return &OssService{
+		ossRepo: ossRepo,
+	}
+}
+
+func (s *OssService) UploadFile(ctx context.Context, req *oss.UploadFileRequest) (*oss.UploadFileResponse, error) {
+	file := req.FileHeader
+	req.FileSize = file.Size
+	req.Ext = path.Ext(file.Filename)
+	validate := validator.New()
+	if err := validate.Struct(req); err != nil {
+		return nil, err
+	}
+
+	// Open the file and read its content
+	srcFile, err := file.Open()
+	if err != nil {
+		return nil, err
+	}
+	defer srcFile.Close()
+
+	fileContent := make([]byte, file.Size)
+	_, err = srcFile.Read(fileContent)
+	if err != nil {
+		return nil, err
+	}
+
+	filePath := fmt.Sprintf("%v/%v%v", req.FolderName, s.GenerateFileName(), req.Ext)
+	fileUrl, err := s.ossRepo.UploadFile(ctx, filePath, fileContent)
+	if err != nil {
+		return nil, err
+	}
+
+	return &oss.UploadFileResponse{
+		FilePath: filePath,
+		FileUrl:  fileUrl,
+	}, nil
+}
+
+func (s *OssService) GenerateFileName() string {
+	return fmt.Sprintf("%v-%v", uuid.New(), strconv.Itoa(int(time.Now().Unix())))
+}

internal/services/oss/init.go

@@ -0,0 +1,10 @@
+package oss
+
+import (
+	"context"
+	"legalgo-BE-go/internal/domain/oss"
+)
+
+type OSSService interface {
+	UploadFile(ctx context.Context, req *oss.UploadFileRequest) (*oss.UploadFileResponse, error)
+}

internal/services/subscribe_plan/get_all_plan.go

@@ -5,10 +5,5 @@ import (
 )
 
 func (s *SubsPlanSvc) GetAllPlan() ([]subscribeplandomain.SubscribePlan, error) {
-	subsPlan, err := s.subsAccs.GetAll()
+	return s.subsAccs.GetAll()
-	if err != nil {
-		return nil, err
-	}
-
-	return subsPlan, nil
 }

internal/services/tag/create.go

@@ -0,0 +1,8 @@
+package tagsvc
+
+import tagdomain "legalgo-BE-go/internal/domain/tag"
+
+func (i *impl) Create(spec tagdomain.TagReq) error {
+	// return i.tagRepo.Create(spec)
+	return i.tagRepo.CreateModel(spec)
+}

internal/services/tag/get_all.go

@@ -0,0 +1,7 @@
+package tagsvc
+
+import tagdomain "legalgo-BE-go/internal/domain/tag"
+
+func (i *impl) GetAll() ([]tagdomain.Tag, error) {
+	return i.tagRepo.GetAll()
+}