Implement URL redirection handler with Redis integration and error ha…

…ndling

api/redirect.go

@@ -1,10 +1,47 @@
 package api
 
 import (
+	"encoding/json"
 	"net/http"
+
+	"github.com/SartajBhuvaji/database"
 )
 
+type RedirectURLRequest struct {
+	LongURL string `json:"long_url"`
+}
+
 // handle the short --> long URL redirection
-func RedirectHandler(w http.ResponseWriter, r *http.Request) {
-	http.Error(w, "Not implemented", http.StatusNotImplemented)
+func RedirectHandler(w http.ResponseWriter, r *http.Request, redisClient *database.RedisClient) {
+	if r.Method != http.MethodPost {
+		http.Error(w, "Invalid request method", http.StatusMethodNotAllowed)
+		return
+	}
+
+	var req ShortenURLRequest
+	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
+		http.Error(w, "Invalid request body", http.StatusBadRequest)
+		return
+	}
+
+	if req.URL == "" {
+		http.Error(w, "URL is required", http.StatusBadRequest)
+		return
+	}
+	shortUrl := req.URL
+	longUrl, err := redisClient.Get(shortUrl)
+	if err != nil {
+		http.Error(w, "Error fetching URL from Reddis", http.StatusInternalServerError)
+		return
+	}
+	//http.Redirect(w, r, longUrl, http.StatusMovedPermanently)
+
+	response := RedirectURLRequest{
+		LongURL: longUrl,
+	}
+	w.Header().Set("Content-Type", "application/json")
+	if err := json.NewEncoder(w).Encode(response); err != nil {
+		http.Error(w, "Error encoding response", http.StatusInternalServerError)
+		return
+	}
 }

api/shorten.go

@@ -50,7 +50,7 @@ func ShortenURLHandler(w http.ResponseWriter, r *http.Request, redisClient *data
 	shortURL := "something/" + enc
 
 	// Update the counter counter++
-	err = redisClient.SetCounter("counter", counter+1)
+	redisClient.SetCounter("counter", counter+1)
 
 	// Add the short URL to the database
 	err = redisClient.Set(shortURL, req.URL)

database/redis.go

@@ -3,6 +3,7 @@ package database
 import (
 	"context"
 	"fmt"
+	"log"
 	"strconv"
 	"time"
 
@@ -93,6 +94,7 @@ func (r *RedisClient) Get(shortURL string) (string, error) {
 	var urlValue URLValue
 	err := r.client.Get(r.ctx, shortURL).Scan(&urlValue)
 	if err != nil {
+		log.Println("Error fetching URL from Redis: ", err)
 		return "", err
 	}
 

main.go

@@ -23,7 +23,9 @@ func main() {
 	})
 
 	// shortURL --> longURL
-	http.HandleFunc("/redirect", api.RedirectHandler)
+	http.HandleFunc("/redirect", func(w http.ResponseWriter, r *http.Request) {
+		api.RedirectHandler(w, r, redisClient)
+	})
 
 	log.Println("Server started on :8080")
 	if err := http.ListenAndServe(":8080", nil); err != nil {