Add search handler

Author: Leo7Deng

backend/circles/handler.go

@@ -255,4 +255,29 @@ func DeleteCircleHandler(w http.ResponseWriter, r *http.Request, hub *websockets
 
 	w.WriteHeader(http.StatusOK)
 	json.NewEncoder(w).Encode("Circle deleted\n")
+}
+
+func SearchTextHandler(w http.ResponseWriter, r *http.Request) {
+	type SearchData struct {
+		CircleID string `json:"circle_id"`
+		Content string `json:"content"`
+	}
+	var searchData SearchData
+	err := json.NewDecoder(r.Body).Decode(&searchData)
+	if err != nil {
+		fmt.Printf("HTTP 400 bad request\n")
+		w.WriteHeader(http.StatusBadRequest)
+		json.NewEncoder(w).Encode("HTTP 400 bad request")
+		return
+	}
+	results, err := postgres.SearchCircle(searchData.CircleID, searchData.Content)
+	if err != nil {
+		fmt.Printf("Failed to search circles\n")
+		w.WriteHeader(http.StatusInternalServerError)
+		json.NewEncoder(w).Encode("Failed to search circles\n")
+		return
+	}
+	fmt.Printf("Search results: %v\n", results)
+	w.WriteHeader(http.StatusOK)
+	json.NewEncoder(w).Encode(results)
 }

backend/main.go

@@ -72,6 +72,13 @@ func main() {
 
 	mux.HandleFunc("/api/register", middleware.AddCorsHeaders(auth.RegisterHandler))
 	mux.HandleFunc("/api/login", middleware.AddCorsHeaders(auth.LoginHandler))
+	mux.HandleFunc("/api/circles/search", middleware.AddCorsHeaders(
+		middleware.AuthMiddleware(
+			http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+				circles.SearchTextHandler(w, r)
+			}),
+		),
+	))
 	mux.Handle("/api/circles", middleware.AddCorsHeaders(
 		middleware.AuthMiddleware(
 			http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {

backend/models/message.go

@@ -1,5 +1,7 @@
 package models
 
+import "time"
+
 type WebsocketMessage struct {
 	Origin  string      `json:"origin"` // user or server
     Type string      `json:"type"` // message or circle
@@ -14,3 +16,9 @@ type Message struct {
 	CreatedAt string `json:"created_at"`
 	AuthorID  string `json:"author_id"`
 }
+
+type SearchMessage struct {
+	Content string `json:"content"`
+	CreatedAt time.Time `json:"created_at"`
+	AuthorUsername string `json:"author_username"`
+}

backend/postgres/circles_repo.go

@@ -350,3 +350,42 @@ func LoadCircleUserMap() (map[string]map[string]bool, error) {
 	}
 	return circleUsers, nil
 }
+
+func SearchCircle(circleID string, content string) ([]models.SearchMessage, error) {
+	ctx := context.Background()
+	conn, err := pool.Acquire(ctx)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Unable to acquire a connection from the pool: %v\n", err)
+		return nil, err
+	}
+	defer conn.Release()
+
+	rows, err := conn.Query(
+		ctx,
+		`
+		SELECT m.content, m.created_at, u.username
+		FROM messages m
+		INNER JOIN users u ON m.author_id = u.id
+		WHERE m.circle_id = $1 AND m.content ILIKE '%' || $2 || '%';
+		`,
+		circleID,
+		content,
+	)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Unable to query PSQL: %v\n", err)
+		return nil, err
+	}
+	defer rows.Close()
+
+	var messages []models.SearchMessage
+	for rows.Next() {
+		var message models.SearchMessage
+		err = rows.Scan(&message.Content, &message.CreatedAt, &message.AuthorUsername)
+		if err != nil {
+			fmt.Fprintf(os.Stderr, "Unable to scan row: %v\n", err)
+			return nil, err
+		}
+		messages = append(messages, message)
+	}
+	return messages, nil
+}

frontend/app/components/SearchModal.tsx

@@ -24,7 +24,7 @@ function SearchModal({ isOpen, setOpen, circleId }: SearchModalProps) {
         };
         const body = {
             circle_id: circleId,
-            content: (e.currentTarget.elements.namedItem('circleName') as HTMLInputElement).value,
+            content: (document.getElementById("circleName") as HTMLInputElement).value,
         };
         console.log(body);
         fetch('http://localhost:8000/api/circles/search', {