Datastar_Meetup/demo/crud/.server/api/board.go

package api

import (
	"context"
	"crud/sqlite"
	"encoding/json"
	"fmt"
	"html/template"
	"net/http"
	"strconv"
)

const baseQuery = `SELECT u.id, u.name, u.username,  u.email, u.phone, u.website, a.street, a.suite, a.zipcode, a.city, c.name as company, c.catch_phrase, c.bs 
				FROM user u
				JOIN company c ON u.company_id = c.id
				JOIN address a ON u.address_id = a.id 
				`

func Board(ctx context.Context, db *sqlite.Database, templ *template.Template) http.Handler {
	return http.HandlerFunc(

		func(w http.ResponseWriter, r *http.Request) {

			w.Header().Set("Content-Type", "text/html")

			records, err := sqlite.NoRowsOk(db.ReadRecords(ctx, baseQuery+";"))
			if err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}

			// Execute template with proper error handling
			if err := templ.ExecuteTemplate(w, "board", sqlite.Record{"records": records}); err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}
		},
	)
}

func DeleteRecord(ctx context.Context, db *sqlite.Database, templ *template.Template) http.Handler {
	// Implementation of DeleteRecord handler
	return http.HandlerFunc(

		func(w http.ResponseWriter, r *http.Request) {

			id, err := strconv.ParseInt(r.PathValue("id"), 10, 64)
			if err != nil {
				w.WriteHeader(http.StatusInternalServerError)
				w.Write([]byte(err.Error()))
			}

			// fmt.Println("DeleteRecord handler called ", id)

			if err := db.DeleteRecord(ctx, "user", "id", id); err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}

			// Redirect or respond with success
			http.Redirect(w, r, "/board", http.StatusSeeOther)
		},
	)
}

func EditRecord(ctx context.Context, db *sqlite.Database, templ *template.Template) http.Handler {
	// Implementation of EditRecord handler
	return http.HandlerFunc(

		func(w http.ResponseWriter, r *http.Request) {

			// fmt.Println("EditRecord handler called")

			id, err := strconv.ParseInt(r.PathValue("id"), 10, 64)
			if err != nil {
				w.WriteHeader(http.StatusInternalServerError)
				w.Write([]byte(err.Error()))
			}

			records, err := db.ReadRecords(ctx, baseQuery+" WHERE u.id = ?;", id)
			if err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}

			rec := records[0]

			// fmt.Printf("Record to edit: %+v\n", rec)

			w.Header().Set("Content-Type", "text/html")

			// Execute template with proper error handling
			if err := templ.ExecuteTemplate(w, "edit-user", rec); err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}

		},
	)
}

func PatchRecord(ctx context.Context, db *sqlite.Database, templ *template.Template) http.Handler {
	// Implementation of PatchRecord handler
	return http.HandlerFunc(

		func(w http.ResponseWriter, r *http.Request) {

			id, err := strconv.ParseInt(r.PathValue("id"), 10, 64)
			if err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}

			// Parse form values
			if err := r.ParseForm(); err != nil {
				http.Error(w, err.Error(), http.StatusBadRequest)
				return
			}

			formData := sqlite.Record{}
			formData["id"] = id
			for key, vals := range r.Form {
				if len(vals) > 0 {
					formData[key] = vals[0]
				}
			}

			user, err := db.GetRecord(ctx, "user", "id", id)
			if err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}
			user["email"] = formData["email"]
			user["phone"] = formData["phone"]
			user["website"] = formData["website"]

			address, err := db.GetRecord(ctx, "address", "id", user["address_id"])
			if err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}
			address["street"] = formData["street"]
			address["suite"] = formData["suite"]
			address["city"] = formData["city"]
			address["zipcode"] = formData["zipcode"]

			company, err := db.GetRecord(ctx, "company", "id", user["company_id"])
			if err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}
			company["name"] = formData["company"]

			// Upsert address
			if _,err := db.UpsertRecord(ctx, "address", "id", address); err != nil {
				fmt.Println("Error updating address:", err)
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			} 

			// Upsert company
			if _, err := db.UpsertRecord(ctx, "company", "id", company); err != nil {
				fmt.Println("Error updating company:", err)
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			} 

			// Update the record in the database
			if _, err := db.UpsertRecord(ctx, "user", "id", user); err != nil {
				fmt.Println("Error updating record:", err)
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			} 

			// Redirect or respond with success
			http.Redirect(w, r, "/board", http.StatusSeeOther)
		},
	)
}

func RecordJson(ctx context.Context, db *sqlite.Database, templ *template.Template) http.Handler {
	// Implementation of EditRecord handler
	return http.HandlerFunc(

		func(w http.ResponseWriter, r *http.Request) {

			id, err := strconv.ParseInt(r.PathValue("id"), 10, 64)
			if err != nil {
				w.WriteHeader(http.StatusInternalServerError)
				w.Write([]byte(err.Error()))
			}

			records, err := db.ReadRecords(ctx, baseQuery+" WHERE u.id = ?;", id)
			if err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}

			rec := records[0]

			w.Header().Set("Content-Type", "application/json")

			if err := json.NewEncoder(w).Encode(rec); err != nil {
				http.Error(w, err.Error(), http.StatusInternalServerError)
				return
			}

		},
	)
}