Monorepo for Tangled forked from tangled.org/core
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120package state
import ( "log" "net/http" "time"
comatproto "github.com/bluesky-social/indigo/api/atproto" lexutil "github.com/bluesky-social/indigo/lex/util" "tangled.org/core/api/tangled" "tangled.org/core/appview/db" "tangled.org/core/appview/models" "tangled.org/core/appview/pages" "tangled.org/core/tid")
func (s *State) Follow(w http.ResponseWriter, r *http.Request) { currentUser := s.oauth.GetUser(r)
subject := r.URL.Query().Get("subject") if subject == "" { log.Println("invalid form") return }
subjectIdent, err := s.idResolver.ResolveIdent(r.Context(), subject) if err != nil { log.Println("failed to follow, invalid did") return }
if currentUser.Did == subjectIdent.DID.String() { log.Println("cant follow or unfollow yourself") return }
client, err := s.oauth.AuthorizedClient(r) if err != nil { log.Println("failed to authorize client") return }
switch r.Method { case http.MethodPost: createdAt := time.Now().Format(time.RFC3339) rkey := tid.TID() resp, err := comatproto.RepoPutRecord(r.Context(), client, &comatproto.RepoPutRecord_Input{ Collection: tangled.GraphFollowNSID, Repo: currentUser.Did, Rkey: rkey, Record: &lexutil.LexiconTypeDecoder{ Val: &tangled.GraphFollow{ Subject: subjectIdent.DID.String(), CreatedAt: createdAt, }}, }) if err != nil { log.Println("failed to create atproto record", err) return }
log.Println("created atproto record: ", resp.Uri)
follow := &models.Follow{ UserDid: currentUser.Did, SubjectDid: subjectIdent.DID.String(), Rkey: rkey, }
err = db.AddFollow(s.db, follow) if err != nil { log.Println("failed to follow", err) return }
s.notifier.NewFollow(r.Context(), follow)
s.pages.FollowFragment(w, pages.FollowFragmentParams{ UserDid: subjectIdent.DID.String(), FollowStatus: models.IsFollowing, })
return case http.MethodDelete: // find the record in the db follow, err := db.GetFollow(s.db, currentUser.Did, subjectIdent.DID.String()) if err != nil { log.Println("failed to get follow relationship") return }
_, err = comatproto.RepoDeleteRecord(r.Context(), client, &comatproto.RepoDeleteRecord_Input{ Collection: tangled.GraphFollowNSID, Repo: currentUser.Did, Rkey: follow.Rkey, })
if err != nil { log.Println("failed to unfollow") return }
err = db.DeleteFollowByRkey(s.db, currentUser.Did, follow.Rkey) if err != nil { log.Println("failed to delete follow from DB") // this is not an issue, the firehose event might have already done this }
s.pages.FollowFragment(w, pages.FollowFragmentParams{ UserDid: subjectIdent.DID.String(), FollowStatus: models.IsNotFollowing, })
s.notifier.DeleteFollow(r.Context(), follow)
return }
}