backend for xcvr appview
remove bsky/follow endpoints and logics
-96
-2
server/internal/handler/handler.go
-2
server/internal/handler/handler.go
···
35
35
// xcvr handlers
36
36
mux.HandleFunc("POST /xcvr/profile", h.oauthMiddleware(h.postProfile))
37
37
mux.HandleFunc("POST /xcvr/beep", h.oauthMiddleware(h.beep))
38
-
mux.HandleFunc("DELETE /xcvr/follow", h.oauthMiddleware(h.unfollow))
39
-
mux.HandleFunc("POST /xcvr/follow", h.oauthMiddleware(h.follow))
40
38
// lexicon handlers
41
39
mux.HandleFunc("GET /xrpc/org.xcvr.feed.getChannels", h.WithCORS(h.getChannels))
42
40
mux.HandleFunc("GET /xrpc/org.xcvr.lrc.getMessages", h.WithCORS(h.getMessages))
-36
server/internal/handler/xcvrHandlers.go
-36
server/internal/handler/xcvrHandlers.go
···
45
45
}
46
46
w.Write(nil)
47
47
}
48
-
49
-
func (h *Handler) unfollow(cs *atoauth.ClientSession, w http.ResponseWriter, r *http.Request) {
50
-
if cs == nil {
51
-
h.badRequest(w, errors.New("must be logged in!"))
52
-
return
53
-
}
54
-
qp := r.URL.Query()
55
-
furi := qp.Get("followUri")
56
-
if furi == "" {
57
-
h.badRequest(w, errors.New("must unfollow a user"))
58
-
return
59
-
}
60
-
err := h.rm.Unfollow(cs, furi, r.Context())
61
-
if err != nil {
62
-
h.serverError(w, errors.New("failed to unfollow: "+err.Error()))
63
-
}
64
-
w.Write(nil)
65
-
}
66
-
67
-
func (h *Handler) follow(cs *atoauth.ClientSession, w http.ResponseWriter, r *http.Request) {
68
-
if cs == nil {
69
-
h.badRequest(w, errors.New("must be logged in!"))
70
-
return
71
-
}
72
-
qp := r.URL.Query()
73
-
did := qp.Get("did")
74
-
if did == "" {
75
-
h.badRequest(w, errors.New("must unfollow a user"))
76
-
return
77
-
}
78
-
err := h.rm.Follow(cs, did, r.Context())
79
-
if err != nil {
80
-
h.serverError(w, errors.New("failed to unfollow: "+err.Error()))
81
-
}
82
-
w.Write(nil)
83
-
}
-51
server/internal/oauth/oauthclient.go
-51
server/internal/oauth/oauthclient.go
···
9
9
"github.com/bluesky-social/indigo/atproto/auth/oauth"
10
10
"github.com/bluesky-social/indigo/atproto/syntax"
11
11
12
-
"rvcx/internal/atputils"
13
12
"rvcx/internal/lex"
14
13
"rvcx/internal/log"
15
14
"rvcx/internal/types"
···
42
41
return nil
43
42
}
44
43
45
-
func Follow(cs *oauth.ClientSession, did string, ctx context.Context) error {
46
-
c := cs.APIClient()
47
-
body := map[string]any{
48
-
"repo": *c.AccountDID,
49
-
"collection": "app.bsky.graph.follow",
50
-
"record": map[string]any{
51
-
"$type": "app.bsky.graph.follow",
52
-
"did": did,
53
-
"createdAt": syntax.DatetimeNow(),
54
-
},
55
-
}
56
-
err := c.Post(ctx, "com.atproto.repo.createRecord", body, nil)
57
-
if err != nil {
58
-
return errors.New("failed to follow: " + err.Error())
59
-
}
60
-
return nil
61
-
}
62
-
63
-
func Unfollow(cs *oauth.ClientSession, followuri string, ctx context.Context) error {
64
-
c := cs.APIClient()
65
-
rkey, err := atputils.RkeyFromUri(followuri)
66
-
if err != nil {
67
-
return errors.New("bad" + err.Error())
68
-
}
69
-
70
-
params := map[string]any{
71
-
"repo": *c.AccountDID,
72
-
"collection": "app.bsky.graph.follow",
73
-
"rkey": rkey,
74
-
}
75
-
var getOut atproto.RepoGetRecord_Output
76
-
err = c.Get(ctx, "com.atproto.repo.getRecord", params, &getOut)
77
-
if err != nil {
78
-
return errors.New("error getting: " + err.Error())
79
-
}
80
-
if getOut.Cid == nil {
81
-
return errors.New("not sure what to do in this case, no cid from good req")
82
-
}
83
-
body := map[string]any{
84
-
"repo": *c.AccountDID,
85
-
"collection": "app.bsky.graph.follow",
86
-
"rkey": rkey,
87
-
"swapRecord": "getOut.cid",
88
-
}
89
-
err = c.Post(ctx, "com.atproto.repo.deleteRecord", body, nil)
90
-
if err != nil {
91
-
return errors.New("failed to tweet: " + err.Error())
92
-
}
93
-
return nil
94
-
}
95
44
func CreateXCVRProfile(cs *oauth.ClientSession, profile *lex.ProfileRecord, ctx context.Context) (p *lex.ProfileRecord, err error) {
96
45
c := cs.APIClient()
97
46
nsid, err := syntax.ParseNSID("com.atproto.repo.getRecord")
-7
server/internal/recordmanager/beep.go
-7
server/internal/recordmanager/beep.go
···
9
9
func (rm *RecordManager) Beep(cs *atoauth.ClientSession, ctx context.Context) error {
10
10
return oauth.MakeBskyPost(cs, "beep_", ctx)
11
11
}
12
-
13
-
func (rm *RecordManager) Unfollow(cs *atoauth.ClientSession, followuri string, ctx context.Context) error {
14
-
return oauth.Unfollow(cs, followuri, ctx)
15
-
}
16
-
func (rm *RecordManager) Follow(cs *atoauth.ClientSession, did string, ctx context.Context) error {
17
-
return oauth.Follow(cs, did, ctx)
18
-
}