alice.pds.demo.boltless.dev
This repository has no description
1package state
2
3import (
4 "net/http"
5 "time"
6
7 comatproto "github.com/bluesky-social/indigo/api/atproto"
8 "github.com/bluesky-social/indigo/atproto/syntax"
9 lexutil "github.com/bluesky-social/indigo/lex/util"
10 "github.com/ipfs/go-cid"
11 "tangled.org/core/api/tangled"
12 "tangled.org/core/appview/db"
13 "tangled.org/core/appview/models"
14 "tangled.org/core/log"
15)
16
17func (s *State) SkipVouchSuggestion(w http.ResponseWriter, r *http.Request) {
18 l := log.SubLogger(s.logger, "skipVouchSuggestion")
19 currentUser := s.oauth.GetMultiAccountUser(r)
20
21 subject := r.FormValue("subject")
22 if subject == "" {
23 l.Warn("missing subject")
24 s.pages.Notice(w, "error", "Missing subject user.")
25 return
26 }
27
28 subjectIdent, err := s.idResolver.ResolveIdent(r.Context(), subject)
29 if err != nil {
30 l.Error("failed to resolve subject", "subject", subject, "err", err)
31 s.pages.Notice(w, "error", "Could not find that user.")
32 return
33 }
34
35 if currentUser.Did == subjectIdent.DID.String() {
36 l.Warn("cannot skip yourself")
37 s.pages.Notice(w, "error", "You cannot skip yourself.")
38 return
39 }
40
41 if err := db.SkipVouchSuggestion(s.db, currentUser.Did, subjectIdent.DID.String()); err != nil {
42 l.Error("failed to skip vouch suggestion", "err", err)
43 s.pages.Notice(w, "error", "Failed to skip suggestion.")
44 return
45 }
46
47 s.pages.HxRefresh(w)
48}
49
50func (s *State) Vouch(w http.ResponseWriter, r *http.Request) {
51 l := log.SubLogger(s.logger, "vouch")
52 l = s.logger.With("handler", "Vouch")
53 currentUser := s.oauth.GetMultiAccountUser(r)
54
55 var subject string
56
57 subject = r.FormValue("subject")
58
59 if subject == "" {
60 l.Warn("invalid form: missing subject")
61 s.pages.Notice(w, "error", "Missing subject user.")
62 return
63 }
64
65 subjectIdent, err := s.idResolver.ResolveIdent(r.Context(), subject)
66 if err != nil {
67 l.Error("failed to vouch, invalid did", "subject", subject, "err", err)
68 s.pages.Notice(w, "error", "Could not find that user.")
69 return
70 }
71
72 if currentUser.Did == subjectIdent.DID.String() {
73 l.Warn("cant vouch or denounce yourself")
74 s.pages.Notice(w, "error", "You cannot vouch for yourself.")
75 return
76 }
77
78 client, err := s.oauth.AuthorizedClient(r)
79 if err != nil {
80 l.Error("failed to authorize client", "err", err)
81 s.pages.Notice(w, "error", "Authentication required.")
82 return
83 }
84
85 if err := r.ParseForm(); err != nil {
86 l.Warn("failed to parse form", "err", err)
87 s.pages.Notice(w, "error", "Invalid form data.")
88 return
89 }
90
91 subjectDid := subjectIdent.DID.String()
92
93 // handle "none" by deleting any existing vouch
94 if r.FormValue("kind") == "none" {
95 _, err := db.GetVouch(s.db, currentUser.Did, subjectDid)
96 if err != nil {
97 l.Info("no existing vouch to delete")
98 s.pages.HxRefresh(w)
99 return
100 }
101
102 _, err = comatproto.RepoDeleteRecord(r.Context(), client, &comatproto.RepoDeleteRecord_Input{
103 Collection: tangled.GraphVouchNSID,
104 Repo: currentUser.Did,
105 Rkey: subjectDid,
106 })
107
108 if err != nil {
109 l.Error("failed to delete vouch record", "err", err)
110 s.pages.Notice(w, "error", "Failed to delete vouch record.")
111 return
112 }
113
114 err = db.DeleteVouch(s.db, currentUser.Did, subjectDid)
115 if err != nil {
116 l.Warn("failed to delete vouch from DB", "err", err)
117 }
118
119 l.Info("deleted vouch record")
120 s.pages.HxRefresh(w)
121 return
122 }
123
124 kind, err := models.ParseVouchKind(r.FormValue("kind"))
125 if err != nil {
126 l.Warn("failed to parse vouch kind", "err", err)
127 s.pages.Notice(w, "error", "Invalid action type.")
128 return
129 }
130
131 reason := r.FormValue("reason")
132 createdAt := time.Now().Format(time.RFC3339)
133
134 var reasonPtr *string
135 if reason != "" {
136 reasonPtr = &reason
137 }
138
139 var evidences []string
140 for _, raw := range r.Form["evidences"] {
141 if _, err := syntax.ParseATURI(raw); err != nil {
142 l.Warn("invalid evidence AT-URI, skipping", "uri", raw, "err", err)
143 continue
144 }
145 evidences = append(evidences, raw)
146 }
147
148 var swapCid *string
149 existingVouch, err := db.GetVouch(s.db, currentUser.Did, subjectDid)
150 if err == nil {
151 cidStr := existingVouch.Cid.String()
152 swapCid = &cidStr
153 }
154
155 resp, err := comatproto.RepoPutRecord(r.Context(), client, &comatproto.RepoPutRecord_Input{
156 Collection: tangled.GraphVouchNSID,
157 Repo: currentUser.Did,
158 Rkey: subjectDid,
159 SwapRecord: swapCid,
160 Record: &lexutil.LexiconTypeDecoder{
161 Val: &tangled.GraphVouch{
162 Kind: string(kind),
163 Reason: reasonPtr,
164 CreatedAt: createdAt,
165 Evidences: evidences,
166 }},
167 })
168 if err != nil {
169 l.Error("failed to create atproto record", "err", err)
170 s.pages.Notice(w, "error", "Failed to create vouch record.")
171 return
172 }
173
174 l.Info("created atproto record", "uri", resp.Uri, "kind", kind)
175
176 newCid, err := cid.Parse(resp.Cid)
177 if err != nil {
178 l.Error("failed to parse returned cid", "err", err)
179 s.pages.Notice(w, "error", "Failed to save vouch.")
180 return
181 }
182
183 vouch := &models.Vouch{
184 Did: syntax.DID(currentUser.Did),
185 SubjectDid: subjectIdent.DID,
186 Cid: newCid,
187 Kind: kind,
188 Reason: reasonPtr,
189 Evidences: evidences,
190 }
191
192 tx, err := s.db.Begin()
193 if err != nil {
194 l.Error("failed to start transaction", "err", err)
195 s.pages.Notice(w, "error", "Failed to save vouch.")
196 return
197 }
198 defer tx.Rollback()
199
200 err = db.AddVouch(tx, vouch)
201 if err != nil {
202 l.Error("failed to add vouch to db", "err", err)
203 s.pages.Notice(w, "error", "Failed to save vouch.")
204 return
205 }
206
207 if err = tx.Commit(); err != nil {
208 l.Error("failed to commit vouch transaction", "err", err)
209 s.pages.Notice(w, "error", "Failed to save vouch.")
210 return
211 }
212
213 s.pages.HxRefresh(w)
214}