check username

api/email/welcome.go

@@ -13,11 +13,11 @@ func WelcomeEmail(u *models.User) error {
 	password := os.Getenv("SMTP_PASSWORD")
 	to := u.Email
 	message := `Subject: Welcome to Our System
+	<p>Dear ` + u.Username + `,</p>
+	<p>Welcome to our system!</p>
+	<p>Best regards,</p>
+	<p>Support Team</p>`
 
-<p>Dear ` + u.Username + `,</p>
-<p>Welcome to our system!</p>
-<p>Best regards,</p>
-<p>Support Team</p>`
 	smtpServer := os.Getenv("SMTP_SERVER")
 	auth := smtp.PlainAuth("", from, password, smtpServer)
 	err := smtp.SendMail(smtpServer, auth, from, []string{to}, []byte(message))

api/handlers/checkUsername.go

@@ -0,0 +1,35 @@
+package handlers
+
+import (
+	"bkawk/go-echo/api/models"
+	"context"
+	"net/http"
+	"time"
+
+	"github.com/labstack/echo/v4"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/mongo"
+)
+
+func CheckUsernameGet(c echo.Context) error {
+
+	// Get the username from the query parameter
+	username := c.QueryParam("username")
+
+	// Get database connection from context
+	db := c.Get("db").(*mongo.Database)
+	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	defer cancel()
+
+	// Check if username exists in the database
+	var existingUser models.User
+	collection := db.Collection("users")
+	err := collection.FindOne(ctx, bson.M{
+		"username": username,
+	}).Decode(&existingUser)
+	if err == nil {
+		return c.JSON(http.StatusOK, echo.Map{"message": "Username not available"})
+	}
+
+	return c.JSON(http.StatusOK, echo.Map{"message": "Username available"})
+}

api/main.go

@@ -107,6 +107,7 @@ func main() {
 	// Routes
 	e.GET("/health", handlers.HealthGet)                            // Health Check
 	e.POST("/register", handlers.RegisterPost)                      // Register a new user
+	e.GET("/check-username", handlers.CheckUsernameGet)             // Check if a username is available
 	e.POST("/login", handlers.LoginPost)                            // Login with a username and password
 	e.POST("/refresh", handlers.RefreshPost)                        // Refresh the access token using a refresh token
 	e.DELETE("/refresh", handlers.RefreshDelete)                    // Invalidate the current refresh token, effectively logging the user out