place endpoint are added

cmd/main.go

@@ -1,6 +1,8 @@
 package main
 
 import (
+	"TripAdvisor/pkg/auth"
+	"encoding/json"
 	"flag"
 	"fmt"
 	"log"
@@ -19,6 +21,8 @@ type application struct {
 }
 
 func main() {
+	repos := auth.NewRepository()
+	repoUsecase := auth.NewRepoUsecase(repos)
 	var cfg config
 	flag.IntVar(&cfg.port, "port", 8080, "API server port")
 	flag.StringVar(&cfg.env, "env", "development", "Environment")
@@ -30,6 +34,7 @@ func main() {
 	}
 	mux := http.NewServeMux()
 	mux.HandleFunc("/healthcheck", app.healthcheckHandler)
+	mux.HandleFunc("/place", app.getPlaceHandler)
 	srv := &http.Server{
 		Addr:         fmt.Sprintf(":%d", cfg.port),
 		Handler:      mux,
@@ -50,3 +55,16 @@ func (app *application) healthcheckHandler(w http.ResponseWriter, r *http.Reques
 		fmt.Printf("ERROR: healthcheckHandler: %s\n", err)
 	}
 }
+
+func (app *application) getPlaceHandler(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json")
+	places, err := repoUsecase.getPlaces()
+	if err != nil {
+		http.Error(w, "Не удалось получить список достопримечательностей", http.StatusInternalServerError)
+		return
+	}
+	err = json.NewEncoder(w).Encode(places)
+	if err != nil {
+		return
+	}
+}

pkg/auth/repo.go

@@ -0,0 +1,37 @@
+package auth
+
+import "database/sql"
+
+type Repo interface {
+	getPlaces() ([]Place, error)
+}
+
+type Repository struct{}
+
+func NewRepository() *Repository {
+	return &Repository{}
+}
+
+func (r *Repository) getPlaces() ([]Place, error) {
+	connStr := "user=postgres password=mypassword host=localhost port=5432 dbname=landmarks sslmode=disable"
+	db, err := sql.Open("postgres", connStr)
+	if err != nil {
+		return nil, err
+	}
+	defer db.Close()
+	rows, err := db.Query("SELECT * FROM places")
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	places := []Place{}
+	for rows.Next() {
+		var place Place
+		err := rows.Scan(&place.ID, &place.Name, &place.Image)
+		if err != nil {
+			return nil, err
+		}
+		places = append(places, place)
+	}
+	return places, nil
+}

pkg/auth/usecase.go

@@ -0,0 +1,27 @@
+package auth
+
+type Place struct {
+	ID    int
+	Name  string
+	Image string
+}
+
+type PlaceUsecase interface {
+	getPlace() ([]Place, error)
+}
+
+type RepoUsecase struct {
+	repos Repository
+}
+
+func NewRepoUsecase(repos *Repository) *RepoUsecase {
+	return &RepoUsecase{repos: *repos}
+}
+
+func (i *RepoUsecase) getPlace() ([]Place, error) {
+	places, err := i.repos.getPlaces()
+	if err != nil {
+		return nil, err
+	}
+	return places, nil
+}