commit 3454d1a5567f642b0dadc7a385a236a48a5675b3 · bretton.dev/coves

.idea/.gitignore

···

       1
       +
       # Default ignored files

     

       2
       +
       /shelf/

     

       3
       +
       /workspace.xml

     

       4
       +
       # Editor-based HTTP Client requests

     

       5
       +
       /httpRequests/

     

       6
       +
       # Datasource local storage ignored files

     

       7
       +
       /dataSources/

     

       8
       +
       /dataSources.local.xml

.idea/Coves.iml

···

       1
       +
       <?xml version="1.0" encoding="UTF-8"?>

     

       2
       +
       <module type="WEB_MODULE" version="4">

     

       3
       +
         <component name="Go" enabled="true" />

     

       4
       +
         <component name="NewModuleRootManager">

     

       5
       +
           <content url="file://$MODULE_DIR$" />

     

       6
       +
           <orderEntry type="inheritedJdk" />

     

       7
       +
           <orderEntry type="sourceFolder" forTests="false" />

     

       8
       +
         </component>

     

       9
       +
       </module>

+17

.idea/dataSources.xml

···

       1
       +
       <?xml version="1.0" encoding="UTF-8"?>

     

       2
       +
       <project version="4">

     

       3
       +
         <component name="DataSourceManagerImpl" format="xml" multifile-model="true">

     

       4
       +
           <data-source source="LOCAL" name="postgres@localhost" uuid="66e25b60-2901-4e78-bdb8-343f2c71fb79">

     

       5
       +
             <driver-ref>postgresql</driver-ref>

     

       6
       +
             <synchronize>true</synchronize>

     

       7
       +
             <jdbc-driver>org.postgresql.Driver</jdbc-driver>

     

       8
       +
             <jdbc-url>jdbc:postgresql://localhost:5433/postgres</jdbc-url>

     

       9
       +
             <jdbc-additional-properties>

     

       10
       +
               <property name="com.intellij.clouds.kubernetes.db.host.port" />

     

       11
       +
               <property name="com.intellij.clouds.kubernetes.db.enabled" value="false" />

     

       12
       +
               <property name="com.intellij.clouds.kubernetes.db.container.port" />

     

       13
       +
             </jdbc-additional-properties>

     

       14
       +
             <working-dir>$ProjectFileDir$</working-dir>

     

       15
       +
           </data-source>

     

       16
       +
         </component>

     

       17
       +
       </project>

.idea/modules.xml

···

       1
       +
       <?xml version="1.0" encoding="UTF-8"?>

     

       2
       +
       <project version="4">

     

       3
       +
         <component name="ProjectModuleManager">

     

       4
       +
           <modules>

     

       5
       +
             <module fileurl="file://$PROJECT_DIR$/.idea/Coves.iml" filepath="$PROJECT_DIR$/.idea/Coves.iml" />

     

       6
       +
           </modules>

     

       7
       +
         </component>

     

       8
       +
       </project>

.idea/vcs.xml

···

       1
       +
       <?xml version="1.0" encoding="UTF-8"?>

     

       2
       +
       <project version="4">

     

       3
       +
         <component name="VcsDirectoryMappings">

     

       4
       +
           <mapping directory="$PROJECT_DIR$" vcs="Git" />

     

       5
       +
         </component>

     

       6
       +
       </project>

+160

CLAUDE.md

···

       1
       +
       Project:

     

       2
       +
       You are a distinguished developer helping build Coves, a forum like atProto social media platform (think reddit).

     

       3
       +
       

     

       4
       +
       Human & LLM Readability Guidelines:

     

       5
       +
       - Clear Module Boundaries: Each feature is a self-contained module with explicit interfaces

     

       6
       +
       - Descriptive Naming: Use full words over abbreviations (e.g., CommunityGovernance not CommGov)

     

       7
       +
       - Structured Documentation: Each module includes purpose, dependencies, and example usage

     

       8
       +
       - Consistent Patterns: RESTful APIs, standard error handling, predictable data structures

     

       9
       +
       - Context-Rich Comments: Explain "why" not just "what" at decision points

     

       10
       +
       

     

       11
       +
       Core Principles:

     

       12
       +
       - When in doubt, choose the simpler implementation

     

       13
       +
       - Features are the enemy of shipping

     

       14
       +
       - A working tool today beats a perfect tool tomorrow

     

       15
       +
       

     

       16
       +
       Utilize existing tech stack

     

       17
       +
       - Before attempting to use an external tool, ensure it cannot be done via the current stack:

     

       18
       +
       - Go Chi (Web framework)

     

       19
       +
       - DB: PostgreSQL

     

       20
       +
       - atProto for federation & user identities

     

       21
       +
       

     

       22
       +
       # Architecture Guidelines

     

       23
       +
       

     

       24
       +
       ## Required Layered Architecture

     

       25
       +
       Follow this strict separation of concerns:

     

       26
       +
       ```

     

       27
       +
       Handler (HTTP) → Service (Business Logic) → Repository (Data Access) → Database

     

       28
       +
       ```

     

       29
       +
       

     

       30
       +
       ## Directory Structure

     

       31
       +
       ```

     

       32
       +
       internal/

     

       33
       +
       ├── api/

     

       34
       +
       │   ├── handlers/     # HTTP request/response handling ONLY

     

       35
       +
       │   └── routes/       # Route definitions

     

       36
       +
       ├── core/

     

       37
       +
       │   └── [domain]/     # Business logic, domain models, service interfaces

     

       38
       +
       │       ├── service.go     # Business logic implementation

     

       39
       +
       │       ├── repository.go  # Data access interface

     

       40
       +
       │       └── [domain].go    # Domain models

     

       41
       +
       └── db/

     

       42
       +
           └── postgres/     # Database implementation details

     

       43
       +
               └── [domain]_repo.go  # Repository implementations

     

       44
       +
       ```

     

       45
       +
       

     

       46
       +
       ## Strict Prohibitions

     

       47
       +
       - **NEVER** put SQL queries in handlers

     

       48
       +
       - **NEVER** import database packages in handlers

     

       49
       +
       - **NEVER** pass *sql.DB directly to handlers

     

       50
       +
       - **NEVER** mix business logic with HTTP concerns

     

       51
       +
       - **NEVER** bypass the service layer

     

       52
       +
       

     

       53
       +
       ## Required Patterns

     

       54
       +
       

     

       55
       +
       ### Handlers (HTTP Layer)

     

       56
       +
       - Only handle HTTP concerns: parsing requests, formatting responses

     

       57
       +
       - Delegate all business logic to services

     

       58
       +
       - No direct database access

     

       59
       +
       

     

       60
       +
       Example:

     

       61
       +
       ```go

     

       62
       +
       func (h *UserHandler) CreateUser(w http.ResponseWriter, r *http.Request) {

     

       63
       +
           var req CreateUserRequest

     

       64
       +
           json.NewDecoder(r.Body).Decode(&req)

     

       65
       +
           

     

       66
       +
           user, err := h.userService.CreateUser(req)  // Delegate to service

     

       67
       +
           // Handle response formatting only

     

       68
       +
       }

     

       69
       +
       ```

     

       70
       +
       

     

       71
       +
       ### Services (Business Layer)

     

       72
       +
       - Contain all business logic and validation

     

       73
       +
       - Use repository interfaces, never concrete implementations

     

       74
       +
       - Handle transactions and complex operations

     

       75
       +
       

     

       76
       +
       Example:

     

       77
       +
       ```go

     

       78
       +
       type UserService struct {

     

       79
       +
           userRepo UserRepository  // Interface, not concrete type

     

       80
       +
       }

     

       81
       +
       ```

     

       82
       +
       

     

       83
       +
       ### Repositories (Data Layer)

     

       84
       +
       - Define interfaces in core/[domain]/

     

       85
       +
       - Implement in db/postgres/

     

       86
       +
       - Handle all SQL queries and database operations

     

       87
       +
       

     

       88
       +
       Example:

     

       89
       +
       ```go

     

       90
       +
       // Interface in core/users/repository.go

     

       91
       +
       type UserRepository interface {

     

       92
       +
           Create(user User) (*User, error)

     

       93
       +
           GetByID(id int) (*User, error)

     

       94
       +
       }

     

       95
       +
       

     

       96
       +
       // Implementation in db/postgres/user_repo.go

     

       97
       +
       type PostgresUserRepo struct {

     

       98
       +
           db *sql.DB

     

       99
       +
       }

     

       100
       +
       ```

     

       101
       +
       

     

       102
       +
       ## Testing Requirements

     

       103
       +
       - Services must be easily mockable (use interfaces)

     

       104
       +
       - Integration tests should test the full stack

     

       105
       +
       - Unit tests should test individual layers in isolation

     

       106
       +
       

     

       107
       +
       Test File Naming:

     

       108
       +
       - Unit tests: `[file]_test.go` in same directory

     

       109
       +
       - Integration tests: `[feature]_integration_test.go` in tests/ directory

     

       110
       +
       

     

       111
       +
       ## Claude Code Instructions

     

       112
       +
       

     

       113
       +
       ### Code Generation Patterns

     

       114
       +
       When creating new features:

     

       115
       +
       1. Generate interface first in core/[domain]/

     

       116
       +
       2. Generate test file with failing tests

     

       117
       +
       3. Generate implementation to pass tests

     

       118
       +
       4. Generate handler with tests

     

       119
       +
       5. Update routes in api/routes/

     

       120
       +
       

     

       121
       +
       ### Refactoring Checklist

     

       122
       +
       Before considering a feature complete:

     

       123
       +
       - All tests pass

     

       124
       +
       - No SQL in handlers

     

       125
       +
       - Services use interfaces only

     

       126
       +
       - Error handling follows patterns

     

       127
       +
       - API documented with examples

     

       128
       +
       

     

       129
       +
       ## Database Migrations

     

       130
       +
       - Use golang-goose for version control

     

       131
       +
       - Migrations in db/migrations/

     

       132
       +
       - Never modify existing migrations

     

       133
       +
       - Always provide rollback migrations

     

       134
       +
       

     

       135
       +
       

     

       136
       +
       

     

       137
       +
       ## Dependency Injection

     

       138
       +
       - Use constructor functions for all components

     

       139
       +
       - Pass interfaces, not concrete types

     

       140
       +
       - Wire dependencies in main.go or cmd/server/main.go

     

       141
       +
       

     

       142
       +
       Example dependency wiring:

     

       143
       +
       ```go

     

       144
       +
       // main.go

     

       145
       +
       userRepo := postgres.NewUserRepository(db)

     

       146
       +
       userService := users.NewUserService(userRepo)

     

       147
       +
       userHandler := handlers.NewUserHandler(userService)

     

       148
       +
       ```

     

       149
       +
       

     

       150
       +
       ## Error Handling

     

       151
       +
       - Define custom error types in core/errors/

     

       152
       +
       - Use error wrapping with context: fmt.Errorf("service: %w", err)

     

       153
       +
       - Services return domain errors, handlers translate to HTTP status codes

     

       154
       +
       - Never expose internal error details in API responses

     

       155
       +
       

     

       156
       +
       ### Context7 Usage Guidelines:

     

       157
       +
       - Always check Context7 for best practices before implementing external integrations

     

       158
       +
       - Use Context7 to understand proper error handling patterns for specific libraries

     

       159
       +
       - Reference Context7 for testing patterns with external dependencies

     

       160
       +
       - Consult Context7 for proper configuration patterns

+67

cmd/server/main.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"database/sql"

     

       5
       +
       	"fmt"

     

       6
       +
       	"log"

     

       7
       +
       	"net/http"

     

       8
       +
       	"os"

     

       9
       +
       

     

       10
       +
       	"github.com/go-chi/chi/v5"

     

       11
       +
       	"github.com/go-chi/chi/v5/middleware"

     

       12
       +
       	_ "github.com/lib/pq"

     

       13
       +
       	"github.com/pressly/goose/v3"

     

       14
       +
       

     

       15
       +
       	"Coves/internal/api/routes"

     

       16
       +
       	"Coves/internal/core/users"

     

       17
       +
       	"Coves/internal/db/postgres"

     

       18
       +
       )

     

       19
       +
       

     

       20
       +
       func main() {

     

       21
       +
       	dbURL := os.Getenv("DATABASE_URL")

     

       22
       +
       	if dbURL == "" {

     

       23
       +
       		dbURL = "postgres://postgres:password@localhost:5432/coves?sslmode=disable"

     

       24
       +
       	}

     

       25
       +
       

     

       26
       +
       	db, err := sql.Open("postgres", dbURL)

     

       27
       +
       	if err != nil {

     

       28
       +
       		log.Fatal("Failed to connect to database:", err)

     

       29
       +
       	}

     

       30
       +
       	defer db.Close()

     

       31
       +
       

     

       32
       +
       	if err := db.Ping(); err != nil {

     

       33
       +
       		log.Fatal("Failed to ping database:", err)

     

       34
       +
       	}

     

       35
       +
       

     

       36
       +
       	if err := goose.SetDialect("postgres"); err != nil {

     

       37
       +
       		log.Fatal("Failed to set goose dialect:", err)

     

       38
       +
       	}

     

       39
       +
       

     

       40
       +
       	if err := goose.Up(db, "internal/db/migrations"); err != nil {

     

       41
       +
       		log.Fatal("Failed to run migrations:", err)

     

       42
       +
       	}

     

       43
       +
       

     

       44
       +
       	r := chi.NewRouter()

     

       45
       +
       	

     

       46
       +
       	r.Use(middleware.Logger)

     

       47
       +
       	r.Use(middleware.Recoverer)

     

       48
       +
       	r.Use(middleware.RequestID)

     

       49
       +
       

     

       50
       +
       	userRepo := postgres.NewUserRepository(db)

     

       51
       +
       	userService := users.NewUserService(userRepo)

     

       52
       +
       

     

       53
       +
       	r.Mount("/api/users", routes.UserRoutes(userService))

     

       54
       +
       

     

       55
       +
       	r.Get("/health", func(w http.ResponseWriter, r *http.Request) {

     

       56
       +
       		w.WriteHeader(http.StatusOK)

     

       57
       +
       		w.Write([]byte("OK"))

     

       58
       +
       	})

     

       59
       +
       

     

       60
       +
       	port := os.Getenv("PORT")

     

       61
       +
       	if port == "" {

     

       62
       +
       		port = "8080"

     

       63
       +
       	}

     

       64
       +
       

     

       65
       +
       	fmt.Printf("Server starting on port %s\n", port)

     

       66
       +
       	log.Fatal(http.ListenAndServe(":"+port, r))

     

       67
       +
       }

+16

go.mod

···

       1
       +
       module Coves

     

       2
       +
       

     

       3
       +
       go 1.24

     

       4
       +
       

     

       5
       +
       require (

     

       6
       +
       	github.com/go-chi/chi/v5 v5.2.1

     

       7
       +
       	github.com/lib/pq v1.10.9

     

       8
       +
       	github.com/pressly/goose/v3 v3.22.1

     

       9
       +
       )

     

       10
       +
       

     

       11
       +
       require (

     

       12
       +
       	github.com/mfridman/interpolate v0.0.2 // indirect

     

       13
       +
       	github.com/sethvargo/go-retry v0.3.0 // indirect

     

       14
       +
       	go.uber.org/multierr v1.11.0 // indirect

     

       15
       +
       	golang.org/x/sync v0.8.0 // indirect

     

       16
       +
       )

+48

go.sum

···

       1
       +
       github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=

     

       2
       +
       github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

     

       3
       +
       github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=

     

       4
       +
       github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=

     

       5
       +
       github.com/go-chi/chi/v5 v5.2.1 h1:KOIHODQj58PmL80G2Eak4WdvUzjSJSm0vG72crDCqb8=

     

       6
       +
       github.com/go-chi/chi/v5 v5.2.1/go.mod h1:L2yAIGWB3H+phAw1NxKwWM+7eUH/lU8pOMm5hHcoops=

     

       7
       +
       github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=

     

       8
       +
       github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=

     

       9
       +
       github.com/hashicorp/golang-lru/v2 v2.0.7 h1:a+bsQ5rvGLjzHuww6tVxozPZFVghXaHOwFs4luLUK2k=

     

       10
       +
       github.com/hashicorp/golang-lru/v2 v2.0.7/go.mod h1:QeFd9opnmA6QUJc5vARoKUSoFhyfM2/ZepoAG6RGpeM=

     

       11
       +
       github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=

     

       12
       +
       github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=

     

       13
       +
       github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=

     

       14
       +
       github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=

     

       15
       +
       github.com/mfridman/interpolate v0.0.2 h1:pnuTK7MQIxxFz1Gr+rjSIx9u7qVjf5VOoM/u6BbAxPY=

     

       16
       +
       github.com/mfridman/interpolate v0.0.2/go.mod h1:p+7uk6oE07mpE/Ik1b8EckO0O4ZXiGAfshKBWLUM9Xg=

     

       17
       +
       github.com/ncruces/go-strftime v0.1.9 h1:bY0MQC28UADQmHmaF5dgpLmImcShSi2kHU9XLdhx/f4=

     

       18
       +
       github.com/ncruces/go-strftime v0.1.9/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls=

     

       19
       +
       github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=

     

       20
       +
       github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=

     

       21
       +
       github.com/pressly/goose/v3 v3.22.1 h1:2zICEfr1O3yTP9BRZMGPj7qFxQ+ik6yeo+z1LMuioLc=

     

       22
       +
       github.com/pressly/goose/v3 v3.22.1/go.mod h1:xtMpbstWyCpyH+0cxLTMCENWBG+0CSxvTsXhW95d5eo=

     

       23
       +
       github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=

     

       24
       +
       github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=

     

       25
       +
       github.com/sethvargo/go-retry v0.3.0 h1:EEt31A35QhrcRZtrYFDTBg91cqZVnFL2navjDrah2SE=

     

       26
       +
       github.com/sethvargo/go-retry v0.3.0/go.mod h1:mNX17F0C/HguQMyMyJxcnU471gOZGxCLyYaFyAZraas=

     

       27
       +
       github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=

     

       28
       +
       github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=

     

       29
       +
       go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=

     

       30
       +
       go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=

     

       31
       +
       golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ=

     

       32
       +
       golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=

     

       33
       +
       golang.org/x/sys v0.25.0 h1:r+8e+loiHxRqhXVl6ML1nO3l1+oFoWbnlu2Ehimmi34=

     

       34
       +
       golang.org/x/sys v0.25.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=

     

       35
       +
       gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

     

       36
       +
       gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

     

       37
       +
       modernc.org/gc/v3 v3.0.0-20240107210532-573471604cb6 h1:5D53IMaUuA5InSeMu9eJtlQXS2NxAhyWQvkKEgXZhHI=

     

       38
       +
       modernc.org/gc/v3 v3.0.0-20240107210532-573471604cb6/go.mod h1:Qz0X07sNOR1jWYCrJMEnbW/X55x206Q7Vt4mz6/wHp4=

     

       39
       +
       modernc.org/mathutil v1.6.0 h1:fRe9+AmYlaej+64JsEEhoWuAYBkOtQiMEU7n/XgfYi4=

     

       40
       +
       modernc.org/mathutil v1.6.0/go.mod h1:Ui5Q9q1TR2gFm0AQRqQUaBWFLAhQpCwNcuhBOSedWPo=

     

       41
       +
       modernc.org/memory v1.8.0 h1:IqGTL6eFMaDZZhEWwcREgeMXYwmW83LYW8cROZYkg+E=

     

       42
       +
       modernc.org/memory v1.8.0/go.mod h1:XPZ936zp5OMKGWPqbD3JShgd/ZoQ7899TUuQqxY+peU=

     

       43
       +
       modernc.org/sqlite v1.33.0 h1:WWkA/T2G17okiLGgKAj4/RMIvgyMT19yQ038160IeYk=

     

       44
       +
       modernc.org/sqlite v1.33.0/go.mod h1:9uQ9hF/pCZoYZK73D/ud5Z7cIRIILSZI8NdIemVMTX8=

     

       45
       +
       modernc.org/strutil v1.2.0 h1:agBi9dp1I+eOnxXeiZawM8F4LawKv4NzGWSaLfyeNZA=

     

       46
       +
       modernc.org/strutil v1.2.0/go.mod h1:/mdcBmfOibveCTBxUl5B5l6W+TTH1FXPLHZE6bTosX0=

     

       47
       +
       modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y=

     

       48
       +
       modernc.org/token v1.1.0/go.mod h1:UGzOrNV1mAFSEB63lOFHIpNRUVMvYTc6yu1SMY/XTDM=

+71

internal/api/handlers/users.go

···

       1
       +
       package handlers

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"Coves/internal/core/users"

     

       5
       +
       	"encoding/json"

     

       6
       +
       	"net/http"

     

       7
       +
       	"strconv"

     

       8
       +
       	"strings"

     

       9
       +
       

     

       10
       +
       	"github.com/go-chi/chi/v5"

     

       11
       +
       )

     

       12
       +
       

     

       13
       +
       type UserHandler struct {

     

       14
       +
       	userService users.UserServiceInterface

     

       15
       +
       }

     

       16
       +
       

     

       17
       +
       func NewUserHandler(userService users.UserServiceInterface) *UserHandler {

     

       18
       +
       	return &UserHandler{userService: userService}

     

       19
       +
       }

     

       20
       +
       

     

       21
       +
       func (h *UserHandler) GetUser(w http.ResponseWriter, r *http.Request) {

     

       22
       +
       	idStr := chi.URLParam(r, "id")

     

       23
       +
       	id, err := strconv.Atoi(idStr)

     

       24
       +
       	if err != nil {

     

       25
       +
       		http.Error(w, "Invalid user ID", http.StatusBadRequest)

     

       26
       +
       		return

     

       27
       +
       	}

     

       28
       +
       

     

       29
       +
       	user, err := h.userService.GetUserByID(id)

     

       30
       +
       	if err != nil {

     

       31
       +
       		if strings.Contains(err.Error(), "not found") {

     

       32
       +
       			http.Error(w, "User not found", http.StatusNotFound)

     

       33
       +
       			return

     

       34
       +
       		}

     

       35
       +
       		if strings.Contains(err.Error(), "invalid") {

     

       36
       +
       			http.Error(w, err.Error(), http.StatusBadRequest)

     

       37
       +
       			return

     

       38
       +
       		}

     

       39
       +
       		http.Error(w, "Failed to fetch user", http.StatusInternalServerError)

     

       40
       +
       		return

     

       41
       +
       	}

     

       42
       +
       

     

       43
       +
       	w.Header().Set("Content-Type", "application/json")

     

       44
       +
       	json.NewEncoder(w).Encode(user)

     

       45
       +
       }

     

       46
       +
       

     

       47
       +
       func (h *UserHandler) CreateUser(w http.ResponseWriter, r *http.Request) {

     

       48
       +
       	var req users.CreateUserRequest

     

       49
       +
       	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {

     

       50
       +
       		http.Error(w, "Invalid request body", http.StatusBadRequest)

     

       51
       +
       		return

     

       52
       +
       	}

     

       53
       +
       

     

       54
       +
       	user, err := h.userService.CreateUser(req)

     

       55
       +
       	if err != nil {

     

       56
       +
       		if strings.Contains(err.Error(), "required") || strings.Contains(err.Error(), "invalid") || strings.Contains(err.Error(), "at least") {

     

       57
       +
       			http.Error(w, err.Error(), http.StatusBadRequest)

     

       58
       +
       			return

     

       59
       +
       		}

     

       60
       +
       		if strings.Contains(err.Error(), "already exists") {

     

       61
       +
       			http.Error(w, err.Error(), http.StatusConflict)

     

       62
       +
       			return

     

       63
       +
       		}

     

       64
       +
       		http.Error(w, "Failed to create user", http.StatusInternalServerError)

     

       65
       +
       		return

     

       66
       +
       	}

     

       67
       +
       

     

       68
       +
       	w.Header().Set("Content-Type", "application/json")

     

       69
       +
       	w.WriteHeader(http.StatusCreated)

     

       70
       +
       	json.NewEncoder(w).Encode(user)

     

       71
       +
       }

+133

internal/api/handlers/users_test.go

···

       1
       +
       package handlers_test

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"bytes"

     

       5
       +
       	"encoding/json"

     

       6
       +
       	"fmt"

     

       7
       +
       	"net/http"

     

       8
       +
       	"net/http/httptest"

     

       9
       +
       	"testing"

     

       10
       +
       

     

       11
       +
       	"Coves/internal/api/handlers"

     

       12
       +
       	"Coves/internal/core/users"

     

       13
       +
       )

     

       14
       +
       

     

       15
       +
       type mockUserService struct {

     

       16
       +
       	users      []users.User

     

       17
       +
       	shouldFail bool

     

       18
       +
       }

     

       19
       +
       

     

       20
       +
       func (m *mockUserService) CreateUser(req users.CreateUserRequest) (*users.User, error) {

     

       21
       +
       	if m.shouldFail {

     

       22
       +
       		return nil, fmt.Errorf("service: failed to create user")

     

       23
       +
       	}

     

       24
       +
       	

     

       25
       +
       	user := &users.User{

     

       26
       +
       		ID:       1,

     

       27
       +
       		Email:    req.Email,

     

       28
       +
       		Username: req.Username,

     

       29
       +
       	}

     

       30
       +
       	m.users = append(m.users, *user)

     

       31
       +
       	return user, nil

     

       32
       +
       }

     

       33
       +
       

     

       34
       +
       func (m *mockUserService) GetUserByID(id int) (*users.User, error) {

     

       35
       +
       	if m.shouldFail {

     

       36
       +
       		return nil, fmt.Errorf("service: failed to get user")

     

       37
       +
       	}

     

       38
       +
       	

     

       39
       +
       	for _, user := range m.users {

     

       40
       +
       		if user.ID == id {

     

       41
       +
       			return &user, nil

     

       42
       +
       		}

     

       43
       +
       	}

     

       44
       +
       	return nil, fmt.Errorf("service: user not found")

     

       45
       +
       }

     

       46
       +
       

     

       47
       +
       func (m *mockUserService) GetUserByEmail(email string) (*users.User, error) {

     

       48
       +
       	for i := range m.users {

     

       49
       +
       		if m.users[i].Email == email {

     

       50
       +
       			return &m.users[i], nil

     

       51
       +
       		}

     

       52
       +
       	}

     

       53
       +
       	return nil, fmt.Errorf("service: user not found")

     

       54
       +
       }

     

       55
       +
       

     

       56
       +
       func (m *mockUserService) GetUserByUsername(username string) (*users.User, error) {

     

       57
       +
       	for i := range m.users {

     

       58
       +
       		if m.users[i].Username == username {

     

       59
       +
       			return &m.users[i], nil

     

       60
       +
       		}

     

       61
       +
       	}

     

       62
       +
       	return nil, fmt.Errorf("service: user not found")

     

       63
       +
       }

     

       64
       +
       

     

       65
       +
       func (m *mockUserService) UpdateUser(id int, req users.UpdateUserRequest) (*users.User, error) {

     

       66
       +
       	for i := range m.users {

     

       67
       +
       		if m.users[i].ID == id {

     

       68
       +
       			if req.Email != "" {

     

       69
       +
       				m.users[i].Email = req.Email

     

       70
       +
       			}

     

       71
       +
       			if req.Username != "" {

     

       72
       +
       				m.users[i].Username = req.Username

     

       73
       +
       			}

     

       74
       +
       			return &m.users[i], nil

     

       75
       +
       		}

     

       76
       +
       	}

     

       77
       +
       	return nil, fmt.Errorf("service: user not found")

     

       78
       +
       }

     

       79
       +
       

     

       80
       +
       func (m *mockUserService) DeleteUser(id int) error {

     

       81
       +
       	for i, user := range m.users {

     

       82
       +
       		if user.ID == id {

     

       83
       +
       			m.users = append(m.users[:i], m.users[i+1:]...)

     

       84
       +
       			return nil

     

       85
       +
       		}

     

       86
       +
       	}

     

       87
       +
       	return fmt.Errorf("service: user not found")

     

       88
       +
       }

     

       89
       +
       

     

       90
       +
       func TestCreateUserHandler(t *testing.T) {

     

       91
       +
       	service := &mockUserService{}

     

       92
       +
       	handler := handlers.NewUserHandler(service)

     

       93
       +
       	

     

       94
       +
       	tests := []struct {

     

       95
       +
       		name       string

     

       96
       +
       		body       users.CreateUserRequest

     

       97
       +
       		wantStatus int

     

       98
       +
       	}{

     

       99
       +
       		{

     

       100
       +
       			name: "valid request",

     

       101
       +
       			body: users.CreateUserRequest{

     

       102
       +
       				Email:    "test@example.com",

     

       103
       +
       				Username: "testuser",

     

       104
       +
       			},

     

       105
       +
       			wantStatus: http.StatusCreated,

     

       106
       +
       		},

     

       107
       +
       	}

     

       108
       +
       	

     

       109
       +
       	for _, tt := range tests {

     

       110
       +
       		t.Run(tt.name, func(t *testing.T) {

     

       111
       +
       			body, _ := json.Marshal(tt.body)

     

       112
       +
       			req := httptest.NewRequest("POST", "/api/users", bytes.NewReader(body))

     

       113
       +
       			req.Header.Set("Content-Type", "application/json")

     

       114
       +
       			

     

       115
       +
       			rr := httptest.NewRecorder()

     

       116
       +
       			handler.CreateUser(rr, req)

     

       117
       +
       			

     

       118
       +
       			if status := rr.Code; status != tt.wantStatus {

     

       119
       +
       				t.Errorf("handler returned wrong status code: got %v want %v", status, tt.wantStatus)

     

       120
       +
       			}

     

       121
       +
       			

     

       122
       +
       			if tt.wantStatus == http.StatusCreated {

     

       123
       +
       				var user users.User

     

       124
       +
       				if err := json.NewDecoder(rr.Body).Decode(&user); err != nil {

     

       125
       +
       					t.Errorf("failed to decode response: %v", err)

     

       126
       +
       				}

     

       127
       +
       				if user.Email != tt.body.Email {

     

       128
       +
       					t.Errorf("expected email %s but got %s", tt.body.Email, user.Email)

     

       129
       +
       				}

     

       130
       +
       			}

     

       131
       +
       		})

     

       132
       +
       	}

     

       133
       +
       }

+18

internal/api/routes/users.go

···

       1
       +
       package routes

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"github.com/go-chi/chi/v5"

     

       5
       +
       

     

       6
       +
       	"Coves/internal/api/handlers"

     

       7
       +
       	"Coves/internal/core/users"

     

       8
       +
       )

     

       9
       +
       

     

       10
       +
       func UserRoutes(userService users.UserServiceInterface) chi.Router {

     

       11
       +
       	r := chi.NewRouter()

     

       12
       +
       	userHandler := handlers.NewUserHandler(userService)

     

       13
       +
       

     

       14
       +
       	r.Post("/", userHandler.CreateUser)

     

       15
       +
       	r.Get("/{id}", userHandler.GetUser)

     

       16
       +
       

     

       17
       +
       	return r

     

       18
       +
       }

+67

internal/core/errors/errors.go

···

       1
       +
       package errors

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"errors"

     

       5
       +
       	"fmt"

     

       6
       +
       )

     

       7
       +
       

     

       8
       +
       var (

     

       9
       +
       	ErrNotFound         = errors.New("resource not found")

     

       10
       +
       	ErrAlreadyExists    = errors.New("resource already exists")

     

       11
       +
       	ErrInvalidInput     = errors.New("invalid input")

     

       12
       +
       	ErrUnauthorized     = errors.New("unauthorized")

     

       13
       +
       	ErrForbidden        = errors.New("forbidden")

     

       14
       +
       	ErrInternal         = errors.New("internal server error")

     

       15
       +
       	ErrDatabaseError    = errors.New("database error")

     

       16
       +
       	ErrValidationFailed = errors.New("validation failed")

     

       17
       +
       )

     

       18
       +
       

     

       19
       +
       type ValidationError struct {

     

       20
       +
       	Field   string

     

       21
       +
       	Message string

     

       22
       +
       }

     

       23
       +
       

     

       24
       +
       func (e ValidationError) Error() string {

     

       25
       +
       	return fmt.Sprintf("validation error on field '%s': %s", e.Field, e.Message)

     

       26
       +
       }

     

       27
       +
       

     

       28
       +
       type ConflictError struct {

     

       29
       +
       	Resource string

     

       30
       +
       	Field    string

     

       31
       +
       	Value    string

     

       32
       +
       }

     

       33
       +
       

     

       34
       +
       func (e ConflictError) Error() string {

     

       35
       +
       	return fmt.Sprintf("%s with %s '%s' already exists", e.Resource, e.Field, e.Value)

     

       36
       +
       }

     

       37
       +
       

     

       38
       +
       type NotFoundError struct {

     

       39
       +
       	Resource string

     

       40
       +
       	ID       interface{}

     

       41
       +
       }

     

       42
       +
       

     

       43
       +
       func (e NotFoundError) Error() string {

     

       44
       +
       	return fmt.Sprintf("%s with ID '%v' not found", e.Resource, e.ID)

     

       45
       +
       }

     

       46
       +
       

     

       47
       +
       func NewValidationError(field, message string) error {

     

       48
       +
       	return ValidationError{

     

       49
       +
       		Field:   field,

     

       50
       +
       		Message: message,

     

       51
       +
       	}

     

       52
       +
       }

     

       53
       +
       

     

       54
       +
       func NewConflictError(resource, field, value string) error {

     

       55
       +
       	return ConflictError{

     

       56
       +
       		Resource: resource,

     

       57
       +
       		Field:    field,

     

       58
       +
       		Value:    value,

     

       59
       +
       	}

     

       60
       +
       }

     

       61
       +
       

     

       62
       +
       func NewNotFoundError(resource string, id interface{}) error {

     

       63
       +
       	return NotFoundError{

     

       64
       +
       		Resource: resource,

     

       65
       +
       		ID:       id,

     

       66
       +
       	}

     

       67
       +
       }

+10

internal/core/users/interfaces.go

···

       1
       +
       package users

     

       2
       +
       

     

       3
       +
       type UserServiceInterface interface {

     

       4
       +
       	CreateUser(req CreateUserRequest) (*User, error)

     

       5
       +
       	GetUserByID(id int) (*User, error)

     

       6
       +
       	GetUserByEmail(email string) (*User, error)

     

       7
       +
       	GetUserByUsername(username string) (*User, error)

     

       8
       +
       	UpdateUser(id int, req UpdateUserRequest) (*User, error)

     

       9
       +
       	DeleteUser(id int) error

     

       10
       +
       }

+10

internal/core/users/repository.go

···

       1
       +
       package users

     

       2
       +
       

     

       3
       +
       type UserRepository interface {

     

       4
       +
       	Create(user *User) (*User, error)

     

       5
       +
       	GetByID(id int) (*User, error)

     

       6
       +
       	GetByEmail(email string) (*User, error)

     

       7
       +
       	GetByUsername(username string) (*User, error)

     

       8
       +
       	Update(user *User) (*User, error)

     

       9
       +
       	Delete(id int) error

     

       10
       +
       }

+164

internal/core/users/service.go

···

       1
       +
       package users

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"fmt"

     

       5
       +
       	"strings"

     

       6
       +
       )

     

       7
       +
       

     

       8
       +
       type UserService struct {

     

       9
       +
       	userRepo UserRepository

     

       10
       +
       }

     

       11
       +
       

     

       12
       +
       func NewUserService(userRepo UserRepository) *UserService {

     

       13
       +
       	return &UserService{

     

       14
       +
       		userRepo: userRepo,

     

       15
       +
       	}

     

       16
       +
       }

     

       17
       +
       

     

       18
       +
       func (s *UserService) CreateUser(req CreateUserRequest) (*User, error) {

     

       19
       +
       	if err := s.validateCreateRequest(req); err != nil {

     

       20
       +
       		return nil, err

     

       21
       +
       	}

     

       22
       +
       	

     

       23
       +
       	req.Email = strings.TrimSpace(strings.ToLower(req.Email))

     

       24
       +
       	req.Username = strings.TrimSpace(req.Username)

     

       25
       +
       	

     

       26
       +
       	existingUser, _ := s.userRepo.GetByEmail(req.Email)

     

       27
       +
       	if existingUser != nil {

     

       28
       +
       		return nil, fmt.Errorf("service: email already exists")

     

       29
       +
       	}

     

       30
       +
       	

     

       31
       +
       	existingUser, _ = s.userRepo.GetByUsername(req.Username)

     

       32
       +
       	if existingUser != nil {

     

       33
       +
       		return nil, fmt.Errorf("service: username already exists")

     

       34
       +
       	}

     

       35
       +
       	

     

       36
       +
       	user := &User{

     

       37
       +
       		Email:    req.Email,

     

       38
       +
       		Username: req.Username,

     

       39
       +
       	}

     

       40
       +
       	

     

       41
       +
       	return s.userRepo.Create(user)

     

       42
       +
       }

     

       43
       +
       

     

       44
       +
       func (s *UserService) GetUserByID(id int) (*User, error) {

     

       45
       +
       	if id <= 0 {

     

       46
       +
       		return nil, fmt.Errorf("service: invalid user ID")

     

       47
       +
       	}

     

       48
       +
       	

     

       49
       +
       	user, err := s.userRepo.GetByID(id)

     

       50
       +
       	if err != nil {

     

       51
       +
       		if strings.Contains(err.Error(), "not found") {

     

       52
       +
       			return nil, fmt.Errorf("service: user not found")

     

       53
       +
       		}

     

       54
       +
       		return nil, fmt.Errorf("service: %w", err)

     

       55
       +
       	}

     

       56
       +
       	

     

       57
       +
       	return user, nil

     

       58
       +
       }

     

       59
       +
       

     

       60
       +
       func (s *UserService) GetUserByEmail(email string) (*User, error) {

     

       61
       +
       	email = strings.TrimSpace(strings.ToLower(email))

     

       62
       +
       	if email == "" {

     

       63
       +
       		return nil, fmt.Errorf("service: email is required")

     

       64
       +
       	}

     

       65
       +
       	

     

       66
       +
       	user, err := s.userRepo.GetByEmail(email)

     

       67
       +
       	if err != nil {

     

       68
       +
       		if strings.Contains(err.Error(), "not found") {

     

       69
       +
       			return nil, fmt.Errorf("service: user not found")

     

       70
       +
       		}

     

       71
       +
       		return nil, fmt.Errorf("service: %w", err)

     

       72
       +
       	}

     

       73
       +
       	

     

       74
       +
       	return user, nil

     

       75
       +
       }

     

       76
       +
       

     

       77
       +
       func (s *UserService) GetUserByUsername(username string) (*User, error) {

     

       78
       +
       	username = strings.TrimSpace(username)

     

       79
       +
       	if username == "" {

     

       80
       +
       		return nil, fmt.Errorf("service: username is required")

     

       81
       +
       	}

     

       82
       +
       	

     

       83
       +
       	user, err := s.userRepo.GetByUsername(username)

     

       84
       +
       	if err != nil {

     

       85
       +
       		if strings.Contains(err.Error(), "not found") {

     

       86
       +
       			return nil, fmt.Errorf("service: user not found")

     

       87
       +
       		}

     

       88
       +
       		return nil, fmt.Errorf("service: %w", err)

     

       89
       +
       	}

     

       90
       +
       	

     

       91
       +
       	return user, nil

     

       92
       +
       }

     

       93
       +
       

     

       94
       +
       func (s *UserService) UpdateUser(id int, req UpdateUserRequest) (*User, error) {

     

       95
       +
       	user, err := s.GetUserByID(id)

     

       96
       +
       	if err != nil {

     

       97
       +
       		return nil, err

     

       98
       +
       	}

     

       99
       +
       	

     

       100
       +
       	if req.Email != "" {

     

       101
       +
       		req.Email = strings.TrimSpace(strings.ToLower(req.Email))

     

       102
       +
       		if req.Email != user.Email {

     

       103
       +
       			existingUser, _ := s.userRepo.GetByEmail(req.Email)

     

       104
       +
       			if existingUser != nil && existingUser.ID != id {

     

       105
       +
       				return nil, fmt.Errorf("service: email already exists")

     

       106
       +
       			}

     

       107
       +
       		}

     

       108
       +
       		user.Email = req.Email

     

       109
       +
       	}

     

       110
       +
       	

     

       111
       +
       	if req.Username != "" {

     

       112
       +
       		req.Username = strings.TrimSpace(req.Username)

     

       113
       +
       		if req.Username != user.Username {

     

       114
       +
       			existingUser, _ := s.userRepo.GetByUsername(req.Username)

     

       115
       +
       			if existingUser != nil && existingUser.ID != id {

     

       116
       +
       				return nil, fmt.Errorf("service: username already exists")

     

       117
       +
       			}

     

       118
       +
       		}

     

       119
       +
       		user.Username = req.Username

     

       120
       +
       	}

     

       121
       +
       	

     

       122
       +
       	return s.userRepo.Update(user)

     

       123
       +
       }

     

       124
       +
       

     

       125
       +
       func (s *UserService) DeleteUser(id int) error {

     

       126
       +
       	if id <= 0 {

     

       127
       +
       		return fmt.Errorf("service: invalid user ID")

     

       128
       +
       	}

     

       129
       +
       	

     

       130
       +
       	err := s.userRepo.Delete(id)

     

       131
       +
       	if err != nil {

     

       132
       +
       		if strings.Contains(err.Error(), "not found") {

     

       133
       +
       			return fmt.Errorf("service: user not found")

     

       134
       +
       		}

     

       135
       +
       		return fmt.Errorf("service: %w", err)

     

       136
       +
       	}

     

       137
       +
       	

     

       138
       +
       	return nil

     

       139
       +
       }

     

       140
       +
       

     

       141
       +
       func (s *UserService) validateCreateRequest(req CreateUserRequest) error {

     

       142
       +
       	if strings.TrimSpace(req.Email) == "" {

     

       143
       +
       		return fmt.Errorf("service: email is required")

     

       144
       +
       	}

     

       145
       +
       	

     

       146
       +
       	if strings.TrimSpace(req.Username) == "" {

     

       147
       +
       		return fmt.Errorf("service: username is required")

     

       148
       +
       	}

     

       149
       +
       	

     

       150
       +
       	if !strings.Contains(req.Email, "@") {

     

       151
       +
       		return fmt.Errorf("service: invalid email format")

     

       152
       +
       	}

     

       153
       +
       	

     

       154
       +
       	if len(req.Username) < 3 {

     

       155
       +
       		return fmt.Errorf("service: username must be at least 3 characters")

     

       156
       +
       	}

     

       157
       +
       	

     

       158
       +
       	return nil

     

       159
       +
       }

     

       160
       +
       

     

       161
       +
       type UpdateUserRequest struct {

     

       162
       +
       	Email    string `json:"email,omitempty"`

     

       163
       +
       	Username string `json:"username,omitempty"`

     

       164
       +
       }

+272

internal/core/users/service_test.go

···

       1
       +
       package users_test

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"fmt"

     

       5
       +
       	"testing"

     

       6
       +
       	"time"

     

       7
       +
       

     

       8
       +
       	"Coves/internal/core/users"

     

       9
       +
       )

     

       10
       +
       

     

       11
       +
       type mockUserRepository struct {

     

       12
       +
       	users      map[int]*users.User

     

       13
       +
       	nextID     int

     

       14
       +
       	shouldFail bool

     

       15
       +
       }

     

       16
       +
       

     

       17
       +
       func newMockUserRepository() *mockUserRepository {

     

       18
       +
       	return &mockUserRepository{

     

       19
       +
       		users:  make(map[int]*users.User),

     

       20
       +
       		nextID: 1,

     

       21
       +
       	}

     

       22
       +
       }

     

       23
       +
       

     

       24
       +
       func (m *mockUserRepository) Create(user *users.User) (*users.User, error) {

     

       25
       +
       	if m.shouldFail {

     

       26
       +
       		return nil, fmt.Errorf("mock: database error")

     

       27
       +
       	}

     

       28
       +
       	

     

       29
       +
       	user.ID = m.nextID

     

       30
       +
       	m.nextID++

     

       31
       +
       	user.CreatedAt = time.Now()

     

       32
       +
       	user.UpdatedAt = time.Now()

     

       33
       +
       	

     

       34
       +
       	m.users[user.ID] = user

     

       35
       +
       	return user, nil

     

       36
       +
       }

     

       37
       +
       

     

       38
       +
       func (m *mockUserRepository) GetByID(id int) (*users.User, error) {

     

       39
       +
       	if m.shouldFail {

     

       40
       +
       		return nil, fmt.Errorf("mock: database error")

     

       41
       +
       	}

     

       42
       +
       	

     

       43
       +
       	user, exists := m.users[id]

     

       44
       +
       	if !exists {

     

       45
       +
       		return nil, fmt.Errorf("repository: user not found")

     

       46
       +
       	}

     

       47
       +
       	return user, nil

     

       48
       +
       }

     

       49
       +
       

     

       50
       +
       func (m *mockUserRepository) GetByEmail(email string) (*users.User, error) {

     

       51
       +
       	if m.shouldFail {

     

       52
       +
       		return nil, fmt.Errorf("mock: database error")

     

       53
       +
       	}

     

       54
       +
       	

     

       55
       +
       	for _, user := range m.users {

     

       56
       +
       		if user.Email == email {

     

       57
       +
       			return user, nil

     

       58
       +
       		}

     

       59
       +
       	}

     

       60
       +
       	return nil, fmt.Errorf("repository: user not found")

     

       61
       +
       }

     

       62
       +
       

     

       63
       +
       func (m *mockUserRepository) GetByUsername(username string) (*users.User, error) {

     

       64
       +
       	if m.shouldFail {

     

       65
       +
       		return nil, fmt.Errorf("mock: database error")

     

       66
       +
       	}

     

       67
       +
       	

     

       68
       +
       	for _, user := range m.users {

     

       69
       +
       		if user.Username == username {

     

       70
       +
       			return user, nil

     

       71
       +
       		}

     

       72
       +
       	}

     

       73
       +
       	return nil, fmt.Errorf("repository: user not found")

     

       74
       +
       }

     

       75
       +
       

     

       76
       +
       func (m *mockUserRepository) Update(user *users.User) (*users.User, error) {

     

       77
       +
       	if m.shouldFail {

     

       78
       +
       		return nil, fmt.Errorf("mock: database error")

     

       79
       +
       	}

     

       80
       +
       	

     

       81
       +
       	if _, exists := m.users[user.ID]; !exists {

     

       82
       +
       		return nil, fmt.Errorf("repository: user not found")

     

       83
       +
       	}

     

       84
       +
       	

     

       85
       +
       	user.UpdatedAt = time.Now()

     

       86
       +
       	m.users[user.ID] = user

     

       87
       +
       	return user, nil

     

       88
       +
       }

     

       89
       +
       

     

       90
       +
       func (m *mockUserRepository) Delete(id int) error {

     

       91
       +
       	if m.shouldFail {

     

       92
       +
       		return fmt.Errorf("mock: database error")

     

       93
       +
       	}

     

       94
       +
       	

     

       95
       +
       	if _, exists := m.users[id]; !exists {

     

       96
       +
       		return fmt.Errorf("repository: user not found")

     

       97
       +
       	}

     

       98
       +
       	

     

       99
       +
       	delete(m.users, id)

     

       100
       +
       	return nil

     

       101
       +
       }

     

       102
       +
       

     

       103
       +
       func TestCreateUser(t *testing.T) {

     

       104
       +
       	repo := newMockUserRepository()

     

       105
       +
       	service := users.NewUserService(repo)

     

       106
       +
       	

     

       107
       +
       	tests := []struct {

     

       108
       +
       		name    string

     

       109
       +
       		req     users.CreateUserRequest

     

       110
       +
       		wantErr bool

     

       111
       +
       		errMsg  string

     

       112
       +
       	}{

     

       113
       +
       		{

     

       114
       +
       			name: "valid user",

     

       115
       +
       			req: users.CreateUserRequest{

     

       116
       +
       				Email:    "test@example.com",

     

       117
       +
       				Username: "testuser",

     

       118
       +
       			},

     

       119
       +
       			wantErr: false,

     

       120
       +
       		},

     

       121
       +
       		{

     

       122
       +
       			name: "empty email",

     

       123
       +
       			req: users.CreateUserRequest{

     

       124
       +
       				Email:    "",

     

       125
       +
       				Username: "testuser",

     

       126
       +
       			},

     

       127
       +
       			wantErr: true,

     

       128
       +
       			errMsg:  "email is required",

     

       129
       +
       		},

     

       130
       +
       		{

     

       131
       +
       			name: "empty username",

     

       132
       +
       			req: users.CreateUserRequest{

     

       133
       +
       				Email:    "test@example.com",

     

       134
       +
       				Username: "",

     

       135
       +
       			},

     

       136
       +
       			wantErr: true,

     

       137
       +
       			errMsg:  "username is required",

     

       138
       +
       		},

     

       139
       +
       		{

     

       140
       +
       			name: "invalid email format",

     

       141
       +
       			req: users.CreateUserRequest{

     

       142
       +
       				Email:    "invalidemail",

     

       143
       +
       				Username: "testuser",

     

       144
       +
       			},

     

       145
       +
       			wantErr: true,

     

       146
       +
       			errMsg:  "invalid email format",

     

       147
       +
       		},

     

       148
       +
       		{

     

       149
       +
       			name: "short username",

     

       150
       +
       			req: users.CreateUserRequest{

     

       151
       +
       				Email:    "test@example.com",

     

       152
       +
       				Username: "ab",

     

       153
       +
       			},

     

       154
       +
       			wantErr: true,

     

       155
       +
       			errMsg:  "username must be at least 3 characters",

     

       156
       +
       		},

     

       157
       +
       	}

     

       158
       +
       	

     

       159
       +
       	for _, tt := range tests {

     

       160
       +
       		t.Run(tt.name, func(t *testing.T) {

     

       161
       +
       			user, err := service.CreateUser(tt.req)

     

       162
       +
       			

     

       163
       +
       			if tt.wantErr {

     

       164
       +
       				if err == nil {

     

       165
       +
       					t.Errorf("expected error but got none")

     

       166
       +
       				} else if tt.errMsg != "" && err.Error() != "service: "+tt.errMsg {

     

       167
       +
       					t.Errorf("expected error message '%s' but got '%s'", tt.errMsg, err.Error())

     

       168
       +
       				}

     

       169
       +
       			} else {

     

       170
       +
       				if err != nil {

     

       171
       +
       					t.Errorf("unexpected error: %v", err)

     

       172
       +
       				}

     

       173
       +
       				if user == nil {

     

       174
       +
       					t.Errorf("expected user but got nil")

     

       175
       +
       				}

     

       176
       +
       			}

     

       177
       +
       		})

     

       178
       +
       	}

     

       179
       +
       }

     

       180
       +
       

     

       181
       +
       func TestCreateUserDuplicates(t *testing.T) {

     

       182
       +
       	repo := newMockUserRepository()

     

       183
       +
       	service := users.NewUserService(repo)

     

       184
       +
       	

     

       185
       +
       	req := users.CreateUserRequest{

     

       186
       +
       		Email:    "test@example.com",

     

       187
       +
       		Username: "testuser",

     

       188
       +
       	}

     

       189
       +
       	

     

       190
       +
       	_, err := service.CreateUser(req)

     

       191
       +
       	if err != nil {

     

       192
       +
       		t.Fatalf("unexpected error creating first user: %v", err)

     

       193
       +
       	}

     

       194
       +
       	

     

       195
       +
       	_, err = service.CreateUser(req)

     

       196
       +
       	if err == nil {

     

       197
       +
       		t.Errorf("expected error for duplicate email but got none")

     

       198
       +
       	} else if err.Error() != "service: email already exists" {

     

       199
       +
       		t.Errorf("unexpected error message: %v", err)

     

       200
       +
       	}

     

       201
       +
       	

     

       202
       +
       	req2 := users.CreateUserRequest{

     

       203
       +
       		Email:    "different@example.com",

     

       204
       +
       		Username: "testuser",

     

       205
       +
       	}

     

       206
       +
       	

     

       207
       +
       	_, err = service.CreateUser(req2)

     

       208
       +
       	if err == nil {

     

       209
       +
       		t.Errorf("expected error for duplicate username but got none")

     

       210
       +
       	} else if err.Error() != "service: username already exists" {

     

       211
       +
       		t.Errorf("unexpected error message: %v", err)

     

       212
       +
       	}

     

       213
       +
       }

     

       214
       +
       

     

       215
       +
       func TestGetUserByID(t *testing.T) {

     

       216
       +
       	repo := newMockUserRepository()

     

       217
       +
       	service := users.NewUserService(repo)

     

       218
       +
       	

     

       219
       +
       	createdUser, err := service.CreateUser(users.CreateUserRequest{

     

       220
       +
       		Email:    "test@example.com",

     

       221
       +
       		Username: "testuser",

     

       222
       +
       	})

     

       223
       +
       	if err != nil {

     

       224
       +
       		t.Fatalf("failed to create user: %v", err)

     

       225
       +
       	}

     

       226
       +
       	

     

       227
       +
       	tests := []struct {

     

       228
       +
       		name    string

     

       229
       +
       		id      int

     

       230
       +
       		wantErr bool

     

       231
       +
       		errMsg  string

     

       232
       +
       	}{

     

       233
       +
       		{

     

       234
       +
       			name:    "valid ID",

     

       235
       +
       			id:      createdUser.ID,

     

       236
       +
       			wantErr: false,

     

       237
       +
       		},

     

       238
       +
       		{

     

       239
       +
       			name:    "invalid ID",

     

       240
       +
       			id:      0,

     

       241
       +
       			wantErr: true,

     

       242
       +
       			errMsg:  "invalid user ID",

     

       243
       +
       		},

     

       244
       +
       		{

     

       245
       +
       			name:    "non-existent ID",

     

       246
       +
       			id:      999,

     

       247
       +
       			wantErr: true,

     

       248
       +
       			errMsg:  "user not found",

     

       249
       +
       		},

     

       250
       +
       	}

     

       251
       +
       	

     

       252
       +
       	for _, tt := range tests {

     

       253
       +
       		t.Run(tt.name, func(t *testing.T) {

     

       254
       +
       			user, err := service.GetUserByID(tt.id)

     

       255
       +
       			

     

       256
       +
       			if tt.wantErr {

     

       257
       +
       				if err == nil {

     

       258
       +
       					t.Errorf("expected error but got none")

     

       259
       +
       				} else if tt.errMsg != "" && err.Error() != "service: "+tt.errMsg {

     

       260
       +
       					t.Errorf("expected error message '%s' but got '%s'", tt.errMsg, err.Error())

     

       261
       +
       				}

     

       262
       +
       			} else {

     

       263
       +
       				if err != nil {

     

       264
       +
       					t.Errorf("unexpected error: %v", err)

     

       265
       +
       				}

     

       266
       +
       				if user == nil {

     

       267
       +
       					t.Errorf("expected user but got nil")

     

       268
       +
       				}

     

       269
       +
       			}

     

       270
       +
       		})

     

       271
       +
       	}

     

       272
       +
       }

+18

internal/core/users/user.go

···

       1
       +
       package users

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"time"

     

       5
       +
       )

     

       6
       +
       

     

       7
       +
       type User struct {

     

       8
       +
       	ID        int       `json:"id" db:"id"`

     

       9
       +
       	Email     string    `json:"email" db:"email"`

     

       10
       +
       	Username  string    `json:"username" db:"username"`

     

       11
       +
       	CreatedAt time.Time `json:"created_at" db:"created_at"`

     

       12
       +
       	UpdatedAt time.Time `json:"updated_at" db:"updated_at"`

     

       13
       +
       }

     

       14
       +
       

     

       15
       +
       type CreateUserRequest struct {

     

       16
       +
       	Email    string `json:"email"`

     

       17
       +
       	Username string `json:"username"`

     

       18
       +
       }

+12

internal/db/local_dev_db_compose/docker-compose.yml

···

       1
       +
       # docker-compose.yml

     

       2
       +
       services:

     

       3
       +
         postgres:

     

       4
       +
           image: postgres:15

     

       5
       +
           network_mode: host  # Add this line

     

       6
       +
           environment:

     

       7
       +
             POSTGRES_DB: coves_dev

     

       8
       +
             POSTGRES_USER: dev_user

     

       9
       +
             POSTGRES_PASSWORD: dev_password

     

       10
       +
             PGPORT: 5433

     

       11
       +
           volumes:

     

       12
       +
             - ~/Code/Coves/local_dev_data:/var/lib/postgresql/data

+14

internal/db/migrations/001_create_users_table.sql

···

       1
       +
       -- +goose Up

     

       2
       +
       CREATE TABLE users (

     

       3
       +
           id SERIAL PRIMARY KEY,

     

       4
       +
           email VARCHAR(255) UNIQUE NOT NULL,

     

       5
       +
           username VARCHAR(50) UNIQUE NOT NULL,

     

       6
       +
           created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,

     

       7
       +
           updated_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP

     

       8
       +
       );

     

       9
       +
       

     

       10
       +
       CREATE INDEX idx_users_email ON users(email);

     

       11
       +
       CREATE INDEX idx_users_username ON users(username);

     

       12
       +
       

     

       13
       +
       -- +goose Down

     

       14
       +
       DROP TABLE users;

+123

internal/db/postgres/user_repo.go

···

       1
       +
       package postgres

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"database/sql"

     

       5
       +
       	"fmt"

     

       6
       +
       

     

       7
       +
       	"Coves/internal/core/users"

     

       8
       +
       )

     

       9
       +
       

     

       10
       +
       type PostgresUserRepo struct {

     

       11
       +
       	db *sql.DB

     

       12
       +
       }

     

       13
       +
       

     

       14
       +
       func NewUserRepository(db *sql.DB) users.UserRepository {

     

       15
       +
       	return &PostgresUserRepo{db: db}

     

       16
       +
       }

     

       17
       +
       

     

       18
       +
       func (r *PostgresUserRepo) Create(user *users.User) (*users.User, error) {

     

       19
       +
       	query := `

     

       20
       +
       		INSERT INTO users (email, username) 

     

       21
       +
       		VALUES ($1, $2) 

     

       22
       +
       		RETURNING id, email, username, created_at, updated_at`

     

       23
       +
       

     

       24
       +
       	err := r.db.QueryRow(query, user.Email, user.Username).

     

       25
       +
       		Scan(&user.ID, &user.Email, &user.Username, &user.CreatedAt, &user.UpdatedAt)

     

       26
       +
       

     

       27
       +
       	if err != nil {

     

       28
       +
       		return nil, fmt.Errorf("repository: failed to create user: %w", err)

     

       29
       +
       	}

     

       30
       +
       

     

       31
       +
       	return user, nil

     

       32
       +
       }

     

       33
       +
       

     

       34
       +
       func (r *PostgresUserRepo) GetByID(id int) (*users.User, error) {

     

       35
       +
       	user := &users.User{}

     

       36
       +
       	query := `SELECT id, email, username, created_at, updated_at FROM users WHERE id = $1`

     

       37
       +
       

     

       38
       +
       	err := r.db.QueryRow(query, id).

     

       39
       +
       		Scan(&user.ID, &user.Email, &user.Username, &user.CreatedAt, &user.UpdatedAt)

     

       40
       +
       

     

       41
       +
       	if err == sql.ErrNoRows {

     

       42
       +
       		return nil, fmt.Errorf("repository: user not found")

     

       43
       +
       	}

     

       44
       +
       	if err != nil {

     

       45
       +
       		return nil, fmt.Errorf("repository: failed to get user: %w", err)

     

       46
       +
       	}

     

       47
       +
       

     

       48
       +
       	return user, nil

     

       49
       +
       }

     

       50
       +
       

     

       51
       +
       func (r *PostgresUserRepo) GetByEmail(email string) (*users.User, error) {

     

       52
       +
       	user := &users.User{}

     

       53
       +
       	query := `SELECT id, email, username, created_at, updated_at FROM users WHERE email = $1`

     

       54
       +
       

     

       55
       +
       	err := r.db.QueryRow(query, email).

     

       56
       +
       		Scan(&user.ID, &user.Email, &user.Username, &user.CreatedAt, &user.UpdatedAt)

     

       57
       +
       

     

       58
       +
       	if err == sql.ErrNoRows {

     

       59
       +
       		return nil, fmt.Errorf("repository: user not found")

     

       60
       +
       	}

     

       61
       +
       	if err != nil {

     

       62
       +
       		return nil, fmt.Errorf("repository: failed to get user by email: %w", err)

     

       63
       +
       	}

     

       64
       +
       

     

       65
       +
       	return user, nil

     

       66
       +
       }

     

       67
       +
       

     

       68
       +
       func (r *PostgresUserRepo) GetByUsername(username string) (*users.User, error) {

     

       69
       +
       	user := &users.User{}

     

       70
       +
       	query := `SELECT id, email, username, created_at, updated_at FROM users WHERE username = $1`

     

       71
       +
       

     

       72
       +
       	err := r.db.QueryRow(query, username).

     

       73
       +
       		Scan(&user.ID, &user.Email, &user.Username, &user.CreatedAt, &user.UpdatedAt)

     

       74
       +
       

     

       75
       +
       	if err == sql.ErrNoRows {

     

       76
       +
       		return nil, fmt.Errorf("repository: user not found")

     

       77
       +
       	}

     

       78
       +
       	if err != nil {

     

       79
       +
       		return nil, fmt.Errorf("repository: failed to get user by username: %w", err)

     

       80
       +
       	}

     

       81
       +
       

     

       82
       +
       	return user, nil

     

       83
       +
       }

     

       84
       +
       

     

       85
       +
       func (r *PostgresUserRepo) Update(user *users.User) (*users.User, error) {

     

       86
       +
       	query := `

     

       87
       +
       		UPDATE users 

     

       88
       +
       		SET email = $2, username = $3, updated_at = CURRENT_TIMESTAMP

     

       89
       +
       		WHERE id = $1

     

       90
       +
       		RETURNING id, email, username, created_at, updated_at`

     

       91
       +
       

     

       92
       +
       	err := r.db.QueryRow(query, user.ID, user.Email, user.Username).

     

       93
       +
       		Scan(&user.ID, &user.Email, &user.Username, &user.CreatedAt, &user.UpdatedAt)

     

       94
       +
       

     

       95
       +
       	if err == sql.ErrNoRows {

     

       96
       +
       		return nil, fmt.Errorf("repository: user not found")

     

       97
       +
       	}

     

       98
       +
       	if err != nil {

     

       99
       +
       		return nil, fmt.Errorf("repository: failed to update user: %w", err)

     

       100
       +
       	}

     

       101
       +
       

     

       102
       +
       	return user, nil

     

       103
       +
       }

     

       104
       +
       

     

       105
       +
       func (r *PostgresUserRepo) Delete(id int) error {

     

       106
       +
       	query := `DELETE FROM users WHERE id = $1`

     

       107
       +
       

     

       108
       +
       	result, err := r.db.Exec(query, id)

     

       109
       +
       	if err != nil {

     

       110
       +
       		return fmt.Errorf("repository: failed to delete user: %w", err)

     

       111
       +
       	}

     

       112
       +
       

     

       113
       +
       	rowsAffected, err := result.RowsAffected()

     

       114
       +
       	if err != nil {

     

       115
       +
       		return fmt.Errorf("repository: failed to get rows affected: %w", err)

     

       116
       +
       	}

     

       117
       +
       

     

       118
       +
       	if rowsAffected == 0 {

     

       119
       +
       		return fmt.Errorf("repository: user not found")

     

       120
       +
       	}

     

       121
       +
       

     

       122
       +
       	return nil

     

       123
       +
       }

server

This is a binary file and will not be displayed.

+94

tests/integration/integration_test.go

···

       1
       +
       package integration

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"Coves/internal/core/users"

     

       5
       +
       	"Coves/internal/db/postgres"

     

       6
       +
       	"bytes"

     

       7
       +
       	"database/sql"

     

       8
       +
       	"encoding/json"

     

       9
       +
       	"net/http"

     

       10
       +
       	"net/http/httptest"

     

       11
       +
       	"os"

     

       12
       +
       	"testing"

     

       13
       +
       

     

       14
       +
       	"github.com/go-chi/chi/v5"

     

       15
       +
       	_ "github.com/lib/pq"

     

       16
       +
       	"github.com/pressly/goose/v3"

     

       17
       +
       

     

       18
       +
       	"Coves/internal/api/routes"

     

       19
       +
       )

     

       20
       +
       

     

       21
       +
       func setupTestDB(t *testing.T) *sql.DB {

     

       22
       +
       	dbURL := os.Getenv("TEST_DATABASE_URL")

     

       23
       +
       	if dbURL == "" {

     

       24
       +
       		dbURL = "postgres://dev_user:dev_password@localhost:5433/coves_dev?sslmode=disable"

     

       25
       +
       	}

     

       26
       +
       

     

       27
       +
       	db, err := sql.Open("postgres", dbURL)

     

       28
       +
       	if err != nil {

     

       29
       +
       		t.Fatalf("Failed to connect to test database: %v", err)

     

       30
       +
       	}

     

       31
       +
       

     

       32
       +
       	if err := db.Ping(); err != nil {

     

       33
       +
       		t.Fatalf("Failed to ping test database: %v", err)

     

       34
       +
       	}

     

       35
       +
       

     

       36
       +
       	if err := goose.SetDialect("postgres"); err != nil {

     

       37
       +
       		t.Fatalf("Failed to set goose dialect: %v", err)

     

       38
       +
       	}

     

       39
       +
       

     

       40
       +
       	if err := goose.Up(db, "../../internal/db/migrations"); err != nil {

     

       41
       +
       		t.Fatalf("Failed to run migrations: %v", err)

     

       42
       +
       	}

     

       43
       +
       

     

       44
       +
       	// Clean up any existing test data

     

       45
       +
       	_, err = db.Exec("DELETE FROM users WHERE email LIKE '%@example.com'")

     

       46
       +
       	if err != nil {

     

       47
       +
       		t.Logf("Warning: Failed to clean up test data: %v", err)

     

       48
       +
       	}

     

       49
       +
       

     

       50
       +
       	return db

     

       51
       +
       }

     

       52
       +
       

     

       53
       +
       func TestCreateUser(t *testing.T) {

     

       54
       +
       	db := setupTestDB(t)

     

       55
       +
       	defer db.Close()

     

       56
       +
       

     

       57
       +
       	// Wire up dependencies according to architecture

     

       58
       +
       	userRepo := postgres.NewUserRepository(db)

     

       59
       +
       	userService := users.NewUserService(userRepo)

     

       60
       +
       

     

       61
       +
       	r := chi.NewRouter()

     

       62
       +
       	r.Mount("/api/users", routes.UserRoutes(userService))

     

       63
       +
       

     

       64
       +
       	user := users.CreateUserRequest{

     

       65
       +
       		Email:    "test@example.com",

     

       66
       +
       		Username: "testuser",

     

       67
       +
       	}

     

       68
       +
       

     

       69
       +
       	body, _ := json.Marshal(user)

     

       70
       +
       	req := httptest.NewRequest("POST", "/api/users", bytes.NewBuffer(body))

     

       71
       +
       	req.Header.Set("Content-Type", "application/json")

     

       72
       +
       

     

       73
       +
       	w := httptest.NewRecorder()

     

       74
       +
       	r.ServeHTTP(w, req)

     

       75
       +
       

     

       76
       +
       	if w.Code != http.StatusCreated {

     

       77
       +
       		t.Errorf("Expected status %d, got %d. Response: %s", http.StatusCreated, w.Code, w.Body.String())

     

       78
       +
       		return

     

       79
       +
       	}

     

       80
       +
       

     

       81
       +
       	var createdUser users.User

     

       82
       +
       	if err := json.NewDecoder(w.Body).Decode(&createdUser); err != nil {

     

       83
       +
       		t.Fatalf("Failed to decode response: %v", err)

     

       84
       +
       	}

     

       85
       +
       

     

       86
       +
       	if createdUser.Email != user.Email {

     

       87
       +
       		t.Errorf("Expected email %s, got %s", user.Email, createdUser.Email)

     

       88
       +
       	}

     

       89
       +
       

     

       90
       +
       	if createdUser.Username != user.Username {

     

       91
       +
       		t.Errorf("Expected username %s, got %s", user.Username, createdUser.Username)

     

       92
       +
       	}

     

       93
       +
       }

     

       94
       +