Routes for user participation

Author: mxmeinhold

backend/main.go

@@ -349,6 +349,95 @@ func main() {
 		rw.Write(data)
 	})
 
+	v1.Path("/cluesheet/{cluesheet_id}/participation/{ipa_uid}").Methods("GET").HandlerFunc(func(rw http.ResponseWriter, r *http.Request) {
+		vars := mux.Vars(r)
+		cluesheet_id, err := uuid.Parse(vars["cluesheet_id"])
+		if err != nil {
+			http.Error(rw, fmt.Sprintf("failed to parse uuid '%s': '%s'", vars["id"], err), 400)
+			return
+		}
+
+		ipa_uid := vars["ipa_uid"]
+		// todo validation
+
+		rows, err := conn.Query(r.Context(), `select * from user_participation where cluesheet_id = $1 and ipa_uid = $2`, cluesheet_id, ipa_uid)
+		if err != nil {
+			http.Error(rw, fmt.Sprintf("failed to query for user participation on '%s' for user '%s': %s", cluesheet_id, ipa_uid, err), 500)
+			return
+		}
+
+		participation, err := pgx.CollectOneRow[UserParticipation](rows, pgx.RowToStructByNameLax[UserParticipation])
+		if err == pgx.ErrNoRows {
+			// if no stored result, there's no hiding
+			participation = UserParticipation{
+				Cluesheet_id: cluesheet_id,
+				Ipa_uid:      ipa_uid,
+				Hidden:       false,
+			}
+		} else if err != nil {
+			http.Error(rw, fmt.Sprintf("failed to query for user participation on '%s' for user '%s': %s", cluesheet_id, ipa_uid, err), 500)
+			return
+		}
+
+		data, err := json.Marshal(participation)
+		if err != nil {
+			http.Error(rw, "Failed to marshal data", 500)
+			fmt.Println(err.Error())
+			return
+		}
+
+		rw.Header().Set("Content-Type", "application/json")
+		rw.Write(data)
+	})
+
+	v1.Path("/cluesheet/{cluesheet_id}/participation/{ipa_uid}").Methods("POST").HandlerFunc(func(rw http.ResponseWriter, r *http.Request) {
+		vars := mux.Vars(r)
+		cluesheet_id, err := uuid.Parse(vars["cluesheet_id"])
+		if err != nil {
+			http.Error(rw, fmt.Sprintf("failed to parse uuid '%s': '%s'", vars["id"], err), 400)
+			return
+		}
+
+		ipa_uid := vars["ipa_uid"]
+		// todo validation
+
+		body, err := io.ReadAll(r.Body)
+		if err != nil {
+			http.Error(rw, fmt.Sprintf("failed to read request: %s", err.Error()), 400)
+			return
+		}
+
+		var params struct {
+			Hidden bool
+		}
+
+		err = json.Unmarshal(body, &params)
+		if err != nil {
+			http.Error(rw, fmt.Sprintf("failed to parse request: %s", err.Error()), 400)
+			return
+		}
+
+		participation := UserParticipation{Cluesheet_id: cluesheet_id, Ipa_uid: ipa_uid, Hidden: params.Hidden}
+
+		log.FromContext(r.Context()).Info("participation", zap.Any("participation", participation))
+		_, err = conn.Exec(r.Context(), `insert into user_participation(cluesheet_id, ipa_uid, hidden) values ($1, $2, $3) on conflict (cluesheet_id, ipa_uid) do update set hidden = $3`, participation.Cluesheet_id, participation.Ipa_uid, participation.Hidden)
+		if err != nil {
+			http.Error(rw, "failed to store clue parent", 500)
+			fmt.Println(err.Error())
+			return
+		}
+
+		data, err := json.Marshal(participation)
+		if err != nil {
+			http.Error(rw, "Failed to marshal data", 500)
+			fmt.Println(err.Error())
+			return
+		}
+
+		rw.Header().Set("Content-Type", "application/json")
+		rw.Write(data)
+	})
+
 	srv := &http.Server{
 		Addr:    ":8080",
 		Handler: router,

backend/migrations/002_participation_constraint.down.sql

@@ -0,0 +1,5 @@
+ALTER TABLE user_participation
+ADD COLUMN id UUID;
+
+ALTER TABLE user_participation
+DROP CONSTRAINT IF EXISTS user_participation_pk;

backend/migrations/002_participation_constraint.up.sql

@@ -0,0 +1,5 @@
+ALTER TABLE user_participation
+DROP COLUMN IF EXISTS id;
+
+ALTER TABLE user_participation
+ADD CONSTRAINT user_participation_pk PRIMARY KEY (cluesheet_id, ipa_uid);

backend/model.go

@@ -45,6 +45,12 @@ type Clue struct {
 	Children    []*Clue `json:",omitzero"`
 }
 
+type UserParticipation struct {
+	Cluesheet_id uuid.UUID
+	Ipa_uid      string
+	Hidden       bool
+}
+
 type ClueRelation struct {
 	Id        uuid.UUID
 	Parent_id uuid.UUID