feat: added status on venue

Author: fullstacksherpa

cmd/api/api.go

@@ -141,6 +141,7 @@ func (app *application) mount() http.Handler {
 			// Routes that require venue ownership
 			r.Route("/{venueID}", func(r chi.Router) {
 				r.Use(app.IsOwnerMiddleware)
+				r.Delete("/", app.deleteVenueHandler)
 				r.Get("/pending-bookings", app.getPendingBookingsHandler)
 				r.Get("/scheduled-bookings", app.getScheduledBookingsHandler)
 				r.Post("/pending-bookings/{bookingID}/accept", app.acceptBookingHandler)

cmd/api/images.go

@@ -23,6 +23,8 @@ func (app *application) parseVenueForm(w http.ResponseWriter, r *http.Request, d
 		return nil, fmt.Errorf("missing venue data in form")
 	}
 
+	fmt.Printf("📚 venueData %s\n", venueData)
+
 	// Decode JSON payload
 	if err := json.Unmarshal([]byte(venueData), data); err != nil {
 		return nil, fmt.Errorf("failed to decode JSON venue data: %w", err)

cmd/api/venues.go

@@ -241,7 +241,7 @@ type VenueListResponse struct {
 // @Param			limit		query	int		false	"Items per page"	default(7)
 // @Success		200			{array}	VenueListResponse
 //
-//	@Security		ApiKeyAuth
+// @Security		ApiKeyAuth
 //
 // @Router			/venues/list-venues [get]
 func (app *application) listVenuesHandler(w http.ResponseWriter, r *http.Request) {
@@ -336,8 +336,6 @@ func nullString(s string) *string {
 // 3. Update the venue record with the returned image URLs.
 // If an error occurs at any external step, the venue is deleted to ensure consistency.
 func (app *application) CreateAndUploadVenue(ctx context.Context, venue *store.Venue, files []*multipart.FileHeader, w http.ResponseWriter, r *http.Request) error {
-	// Step 1: Create the venue in the database (without images).
-	fmt.Print("calling database for Create")
 	if err := app.store.Venues.Create(ctx, venue); err != nil {
 		return fmt.Errorf("error creating venue: %w", err)
 	}
@@ -352,7 +350,6 @@ func (app *application) CreateAndUploadVenue(ctx context.Context, venue *store.V
 		return fmt.Errorf("error uploading images: %w", err)
 	}
 
-	fmt.Print("calling database to updateImageURLs")
 	// Step 3: Update the venue with the uploaded image URLs.
 	if err := app.store.Venues.UpdateImageURLs(ctx, venue.ID, imageUrls); err != nil {
 		// Compensate: Delete the venue if updating image URLs fails.
@@ -390,6 +387,7 @@ func (app *application) CreateAndUploadVenue(ctx context.Context, venue *store.V
 //	@Security		ApiKeyAuth
 //	@Router			/venues [post]
 func (app *application) createVenueHandler(w http.ResponseWriter, r *http.Request) {
+	fmt.Println("🚀 Entering createVenueHandler")
 	var payload CreateVenuePayload
 
 	// Parse form and JSON payload from multipart form.
@@ -399,19 +397,15 @@ func (app *application) createVenueHandler(w http.ResponseWriter, r *http.Reques
 		return
 	}
 
+	fmt.Printf("🎾 Parsed payload: %+v, %d files\n", payload, len(files))
+	//for debug only
+	for _, fh := range files {
+		fmt.Printf("📷 got file: %q (%d bytes)\n", fh.Filename, fh.Size)
+	}
+
 	// Retrieve the current user (owner) from the request context.
 	user := getUserFromContext(r)
-
-	// Check for an existing venue with the same name for this owner.
-	exists, err := app.store.Venues.CheckIfVenueExists(r.Context(), payload.Name, user.ID)
-	if err != nil {
-		app.internalServerError(w, r, err)
-		return
-	}
-	if exists {
-		app.alreadyExistVenue(w, r, fmt.Errorf("a venue with this name already exists for this owner"))
-		return
-	}
+	fmt.Println("👤 current user:", user.ID)
 
 	// Prepare the venue model without image URLs initially.
 	venue := &store.Venue{
@@ -427,12 +421,16 @@ func (app *application) createVenueHandler(w http.ResponseWriter, r *http.Reques
 		// ImageURLs field remains empty until updated.
 	}
 
+	fmt.Println("🏗️ About to Create venue in DB:", venue)
+
 	// Use the SAGA pattern to create the venue record and upload images externally.
 	if err := app.CreateAndUploadVenue(r.Context(), venue, files, w, r); err != nil {
 		app.internalServerError(w, r, err)
 		return
 	}
 
+	fmt.Println("✅ Venue created successfully:", venue.ID)
+
 	// Return a JSON response with the created venue details.
 	if err := app.jsonResponse(w, http.StatusCreated, venue); err != nil {
 		app.internalServerError(w, r, err)
@@ -515,3 +513,56 @@ func (app *application) getVenueDetailHandler(w http.ResponseWriter, r *http.Req
 		return
 	}
 }
+
+// -----------------------------------------------
+// HTTP Handler for Venue Deletion
+// -----------------------------------------------
+
+// deleteVenueHandler handles deletion of a venue and its associated images from Cloudinary.
+
+// DeleteVenue godoc
+//
+//	@Summary		Delete a venue from the system
+//	@Description	Deletes a venue by ID and removes all associated images from Cloudinary.
+//	@Tags			Venue-Owner
+//	@Produce		json
+//	@Param			venueID	path		int					true	"Venue ID"
+//	@Success		200		{object}	map[string]string	"Venue deleted successfully"
+//	@Failure		400		{object}	error				"Invalid venue ID"
+//	@Failure		401		{object}	error				"Unauthorized"
+//	@Failure		404		{object}	error				"Venue not found"
+//	@Failure		500		{object}	error				"Internal server error"
+//	@Security		ApiKeyAuth
+//	@Router			/venues/{venueID} [delete]
+func (app *application) deleteVenueHandler(w http.ResponseWriter, r *http.Request) {
+	venueIDStr := chi.URLParam(r, "venueID")
+
+	// Convert venueID to int64
+	venueID, err := strconv.ParseInt(venueIDStr, 10, 64)
+	if err != nil {
+		app.badRequestResponse(w, r, fmt.Errorf("invalid venueID: %v", err))
+		return
+	}
+	urls, err := app.store.Venues.GetImageURLs(r.Context(), venueID)
+	if err != nil {
+		app.internalServerError(w, r, err)
+		return
+	}
+
+	// 2) Delete each from Cloudinary
+	for _, url := range urls {
+		if err := app.deletePhotoFromCloudinary(url); err != nil {
+			app.logger.Warnw("failed to delete image from Cloudinary", "url", url, "err", err)
+			app.internalServerError(w, r, err)
+			return
+
+		}
+	}
+
+	if err := app.store.Venues.Delete(r.Context(), venueID); err != nil {
+		app.internalServerError(w, r, err)
+		return
+	}
+
+	app.jsonResponse(w, http.StatusOK, map[string]string{"message": "Venue deleted successfully"})
+}

cmd/migrate/migrations/000026_add_status_enums_to_venues.down.sql

@@ -0,0 +1,5 @@
+-- 1. Remove the column
+ALTER TABLE venues DROP COLUMN status;
+
+-- 2. Drop the enum type
+DROP TYPE venue_status;

cmd/migrate/migrations/000026_add_status_enums_to_venues.up.sql

@@ -0,0 +1,14 @@
+-- 1. Create the enum type
+CREATE TYPE venue_status AS ENUM ('requested', 'active', 'rejected', 'hold');
+
+-- 2. Add the column using the new enum type
+ALTER TABLE venues ADD COLUMN status venue_status;
+
+-- 3. Set default to 'requested' for future inserts (optional)
+ALTER TABLE venues ALTER COLUMN status SET DEFAULT 'requested';
+
+-- 4. Set status to 'active' for all existing records
+UPDATE venues SET status = 'active' WHERE status IS NULL;
+
+-- (Optional) 5. Add NOT NULL constraint if status should always be present
+ALTER TABLE venues ALTER COLUMN status SET NOT NULL;

docs/docs.go

@@ -2248,6 +2248,57 @@ const docTemplate = `{
             }
         },
         "/venues/{venueID}": {
+            "delete": {
+                "security": [
+                    {
+                        "ApiKeyAuth": []
+                    }
+                ],
+                "description": "Deletes a venue by ID and removes all associated images from Cloudinary.",
+                "produces": [
+                    "application/json"
+                ],
+                "tags": [
+                    "Venue-Owner"
+                ],
+                "summary": "Delete a venue from the system",
+                "parameters": [
+                    {
+                        "type": "integer",
+                        "description": "Venue ID",
+                        "name": "venueID",
+                        "in": "path",
+                        "required": true
+                    }
+                ],
+                "responses": {
+                    "200": {
+                        "description": "Venue deleted successfully",
+                        "schema": {
+                            "type": "object",
+                            "additionalProperties": {
+                                "type": "string"
+                            }
+                        }
+                    },
+                    "400": {
+                        "description": "Invalid venue ID",
+                        "schema": {}
+                    },
+                    "401": {
+                        "description": "Unauthorized",
+                        "schema": {}
+                    },
+                    "404": {
+                        "description": "Venue not found",
+                        "schema": {}
+                    },
+                    "500": {
+                        "description": "Internal server error",
+                        "schema": {}
+                    }
+                }
+            },
             "patch": {
                 "security": [
                     {

docs/swagger.json

@@ -2240,6 +2240,57 @@
             }
         },
         "/venues/{venueID}": {
+            "delete": {
+                "security": [
+                    {
+                        "ApiKeyAuth": []
+                    }
+                ],
+                "description": "Deletes a venue by ID and removes all associated images from Cloudinary.",
+                "produces": [
+                    "application/json"
+                ],
+                "tags": [
+                    "Venue-Owner"
+                ],
+                "summary": "Delete a venue from the system",
+                "parameters": [
+                    {
+                        "type": "integer",
+                        "description": "Venue ID",
+                        "name": "venueID",
+                        "in": "path",
+                        "required": true
+                    }
+                ],
+                "responses": {
+                    "200": {
+                        "description": "Venue deleted successfully",
+                        "schema": {
+                            "type": "object",
+                            "additionalProperties": {
+                                "type": "string"
+                            }
+                        }
+                    },
+                    "400": {
+                        "description": "Invalid venue ID",
+                        "schema": {}
+                    },
+                    "401": {
+                        "description": "Unauthorized",
+                        "schema": {}
+                    },
+                    "404": {
+                        "description": "Venue not found",
+                        "schema": {}
+                    },
+                    "500": {
+                        "description": "Internal server error",
+                        "schema": {}
+                    }
+                }
+            },
             "patch": {
                 "security": [
                     {

docs/swagger.yaml

@@ -2217,6 +2217,40 @@ paths:
       tags:
       - Venue-Owner
   /venues/{venueID}:
+    delete:
+      description: Deletes a venue by ID and removes all associated images from Cloudinary.
+      parameters:
+      - description: Venue ID
+        in: path
+        name: venueID
+        required: true
+        type: integer
+      produces:
+      - application/json
+      responses:
+        "200":
+          description: Venue deleted successfully
+          schema:
+            additionalProperties:
+              type: string
+            type: object
+        "400":
+          description: Invalid venue ID
+          schema: {}
+        "401":
+          description: Unauthorized
+          schema: {}
+        "404":
+          description: Venue not found
+          schema: {}
+        "500":
+          description: Internal server error
+          schema: {}
+      security:
+      - ApiKeyAuth: []
+      summary: Delete a venue from the system
+      tags:
+      - Venue-Owner
     patch:
       consumes:
       - application/json

internal/store/storage.go

@@ -47,6 +47,7 @@ type Storage struct {
 		GetOwnedVenueIDs(ctx context.Context, userID int64) ([]int64, error)
 		List(ctx context.Context, filter VenueFilter) ([]VenueListing, error)
 		GetVenueDetail(ctx context.Context, venueID int64) (*VenueDetail, error)
+		GetImageURLs(ctx context.Context, venueID int64) ([]string, error)
 	}
 	Reviews interface {
 		CreateReview(context.Context, *Review) error