this repo has no description
pds: remove `app.bsky.*` endpoints (#513)
This code is unused. These routes are not served from the PDS, they get
served from the AppView.
In theory the implementation might be useful for a future golang
appview; we can grab the code from git history if needed.
+2
-1454
+1
-2
labeler/service.go
+1
-2
labeler/service.go
···
20
20
"github.com/bluesky-social/indigo/indexer"
21
21
lexutil "github.com/bluesky-social/indigo/lex/util"
22
22
"github.com/bluesky-social/indigo/models"
23
-
"github.com/bluesky-social/indigo/pds"
24
23
"github.com/bluesky-social/indigo/repo"
25
24
"github.com/bluesky-social/indigo/repomgr"
26
25
cbg "github.com/whyrusleeping/cbor-gen"
···
102
101
head, _ := s.repoman.GetRepoRoot(ctx, s.user.UserId)
103
102
if !head.Defined() {
104
103
log.Info("initializing labelmaker repo")
105
-
if err := s.repoman.InitNewActor(ctx, s.user.UserId, s.user.Handle, s.user.Did, "Label Maker", pds.UserActorDeclCid, pds.UserActorDeclType); err != nil {
104
+
if err := s.repoman.InitNewActor(ctx, s.user.UserId, s.user.Handle, s.user.Did, "Label Maker", "", ""); err != nil {
106
105
return nil, fmt.Errorf("creating labelmaker repo: %w", err)
107
106
}
108
107
} else {
+1
-369
pds/handlers.go
+1
-369
pds/handlers.go
···
6
6
"database/sql"
7
7
"fmt"
8
8
"io"
9
-
"time"
10
9
11
10
comatprototypes "github.com/bluesky-social/indigo/api/atproto"
12
-
appbskytypes "github.com/bluesky-social/indigo/api/bsky"
13
11
lexutil "github.com/bluesky-social/indigo/lex/util"
14
12
"github.com/bluesky-social/indigo/models"
15
13
"github.com/ipfs/go-cid"
16
14
"github.com/lestrrat-go/jwx/v2/jwt"
17
15
)
18
16
19
-
func (s *Server) handleAppBskyActorGetProfile(ctx context.Context, actor string) (*appbskytypes.ActorDefs_ProfileViewDetailed, error) {
20
-
profile, err := s.feedgen.GetActorProfile(ctx, actor)
21
-
if err != nil {
22
-
return nil, err
23
-
}
24
-
25
-
return &appbskytypes.ActorDefs_ProfileViewDetailed{
26
-
Viewer: nil, //*ActorGetProfile_MyState `json:"myState" cborgen:"myState"`
27
-
Did: profile.Did,
28
-
Description: nil,
29
-
PostsCount: &profile.Posts,
30
-
FollowsCount: &profile.Following,
31
-
Handle: profile.Handle.String,
32
-
DisplayName: &profile.DisplayName,
33
-
FollowersCount: &profile.Followers,
34
-
}, nil
35
-
}
36
-
37
-
func (s *Server) handleAppBskyActorGetSuggestions(ctx context.Context, cursor string, limit int) (*appbskytypes.ActorGetSuggestions_Output, error) {
38
-
39
-
var out appbskytypes.ActorGetSuggestions_Output
40
-
out.Actors = []*appbskytypes.ActorDefs_ProfileView{}
41
-
return &out, nil
42
-
}
43
-
44
-
func (s *Server) handleAppBskyFeedGetAuthorFeed(ctx context.Context, author string, before string, filter string, limit int) (*appbskytypes.FeedGetAuthorFeed_Output, error) {
45
-
_, err := s.getUser(ctx)
46
-
if err != nil {
47
-
return nil, err
48
-
}
49
-
50
-
target, err := s.lookupUser(ctx, author)
51
-
//target, err := s.lookupUserByHandle(ctx, author)
52
-
if err != nil {
53
-
return nil, err
54
-
}
55
-
56
-
feed, err := s.feedgen.GetAuthorFeed(ctx, target, before, limit)
57
-
if err != nil {
58
-
return nil, err
59
-
}
60
-
61
-
out := appbskytypes.FeedGetAuthorFeed_Output{
62
-
Feed: feed,
63
-
}
64
-
65
-
return &out, nil
66
-
}
67
-
68
-
func (s *Server) handleAppBskyFeedGetPostThread(ctx context.Context, depth int, parentHeight int, uri string) (*appbskytypes.FeedGetPostThread_Output, error) {
69
-
u, err := s.getUser(ctx)
70
-
if err != nil {
71
-
return nil, err
72
-
}
73
-
74
-
d := depth
75
-
76
-
pthread, err := s.feedgen.GetPostThread(ctx, uri, d)
77
-
if err != nil {
78
-
return nil, err
79
-
}
80
-
81
-
fmt.Println("TODO: replies")
82
-
83
-
var convertToOutputType func(thr *ThreadPost) (*appbskytypes.FeedDefs_ThreadViewPost, error)
84
-
convertToOutputType = func(thr *ThreadPost) (*appbskytypes.FeedDefs_ThreadViewPost, error) {
85
-
p := thr.Post
86
-
87
-
vs, err := s.feedgen.getPostViewerState(ctx, thr.PostID, u.ID, u.Did)
88
-
if err != nil {
89
-
return nil, err
90
-
}
91
-
92
-
p.Post.Viewer = vs
93
-
94
-
out := &appbskytypes.FeedDefs_ThreadViewPost{
95
-
Post: p.Post,
96
-
}
97
-
98
-
if thr.ParentUri != "" {
99
-
if thr.Parent == nil {
100
-
out.Parent = &appbskytypes.FeedDefs_ThreadViewPost_Parent{
101
-
FeedDefs_NotFoundPost: &appbskytypes.FeedDefs_NotFoundPost{
102
-
Uri: thr.ParentUri,
103
-
NotFound: true,
104
-
},
105
-
}
106
-
} else {
107
-
othr, err := convertToOutputType(thr.Parent)
108
-
if err != nil {
109
-
return nil, err
110
-
}
111
-
112
-
out.Parent = &appbskytypes.FeedDefs_ThreadViewPost_Parent{
113
-
FeedDefs_ThreadViewPost: othr,
114
-
}
115
-
}
116
-
}
117
-
118
-
return out, nil
119
-
}
120
-
121
-
othr, err := convertToOutputType(pthread)
122
-
if err != nil {
123
-
return nil, err
124
-
}
125
-
126
-
out := appbskytypes.FeedGetPostThread_Output{
127
-
Thread: &appbskytypes.FeedGetPostThread_Output_Thread{
128
-
FeedDefs_ThreadViewPost: othr,
129
-
//FeedGetPostThread_NotFoundPost: &appbskytypes.FeedGetPostThread_NotFoundPost{},
130
-
},
131
-
}
132
-
133
-
return &out, nil
134
-
}
135
-
136
-
func (s *Server) handleAppBskyFeedGetRepostedBy(ctx context.Context, before string, cc string, limit int, uri string) (*appbskytypes.FeedGetRepostedBy_Output, error) {
137
-
panic("not yet implemented")
138
-
}
139
-
140
-
func (s *Server) handleAppBskyFeedGetTimeline(ctx context.Context, algorithm string, before string, limit int) (*appbskytypes.FeedGetTimeline_Output, error) {
141
-
u, err := s.getUser(ctx)
142
-
if err != nil {
143
-
return nil, err
144
-
}
145
-
146
-
tl, err := s.feedgen.GetTimeline(ctx, u, algorithm, before, limit)
147
-
if err != nil {
148
-
return nil, err
149
-
}
150
-
151
-
var out appbskytypes.FeedGetTimeline_Output
152
-
out.Feed = tl
153
-
154
-
return &out, nil
155
-
}
156
-
157
-
func (s *Server) handleAppBskyFeedGetLikes(ctx context.Context, cc string, cursor string, limit int, uri string) (*appbskytypes.FeedGetLikes_Output, error) {
158
-
// func (s *Server) handleAppBskyFeedGetLikes(ctx context.Context,cid string,cursor string,limit int,uri string) (*appbskytypes.FeedGetLikes_Output, error)
159
-
pcid, err := cid.Decode(cc)
160
-
if err != nil {
161
-
return nil, err
162
-
}
163
-
164
-
votes, err := s.feedgen.GetVotes(ctx, uri, pcid, limit, cursor)
165
-
if err != nil {
166
-
return nil, err
167
-
}
168
-
169
-
var out appbskytypes.FeedGetLikes_Output
170
-
out.Uri = uri
171
-
out.Likes = []*appbskytypes.FeedGetLikes_Like{}
172
-
173
-
for _, v := range votes {
174
-
out.Likes = append(out.Likes, &appbskytypes.FeedGetLikes_Like{
175
-
Actor: s.actorBasicToView(ctx, v.Actor),
176
-
IndexedAt: v.IndexedAt.Format(time.RFC3339),
177
-
CreatedAt: v.CreatedAt,
178
-
})
179
-
}
180
-
181
-
return &out, nil
182
-
}
183
-
184
-
func (s *Server) handleAppBskyGraphGetFollowers(ctx context.Context, actor string, cursor string, limit int) (*appbskytypes.GraphGetFollowers_Output, error) {
185
-
panic("not yet implemented")
186
-
}
187
-
188
-
func (s *Server) handleAppBskyGraphGetFollows(ctx context.Context, actor string, cursor string, limit int) (*appbskytypes.GraphGetFollows_Output, error) {
189
-
follows, err := s.feedgen.GetFollows(ctx, actor, limit, cursor)
190
-
if err != nil {
191
-
return nil, err
192
-
}
193
-
194
-
ai, err := s.feedgen.GetActorProfile(ctx, actor)
195
-
if err != nil {
196
-
return nil, err
197
-
}
198
-
199
-
var out appbskytypes.GraphGetFollows_Output
200
-
out.Subject = s.actorBasicToView(ctx, ai.ActorRef())
201
-
202
-
out.Follows = []*appbskytypes.ActorDefs_ProfileView{}
203
-
for _, f := range follows {
204
-
out.Follows = append(out.Follows, &appbskytypes.ActorDefs_ProfileView{
205
-
Handle: f.Subject.Handle,
206
-
DisplayName: f.Subject.DisplayName,
207
-
Did: f.Subject.Did,
208
-
})
209
-
}
210
-
211
-
return &out, nil
212
-
}
213
-
214
-
func (s *Server) handleAppBskyGraphGetMutes(ctx context.Context, before string, limit int) (*appbskytypes.GraphGetMutes_Output, error) {
215
-
panic("not yet implemented")
216
-
}
217
-
218
-
func (s *Server) handleAppBskyGraphMuteActor(ctx context.Context, input *appbskytypes.GraphMuteActor_Input) error {
219
-
panic("not yet implemented")
220
-
}
221
-
222
-
func (s *Server) handleAppBskyGraphUnmuteActor(ctx context.Context, input *appbskytypes.GraphUnmuteActor_Input) error {
223
-
panic("not yet implemented")
224
-
}
225
-
226
-
func (s *Server) handleAppBskyNotificationGetUnreadCount(ctx context.Context, seenAt string) (*appbskytypes.NotificationGetUnreadCount_Output, error) {
227
-
u, err := s.getUser(ctx)
228
-
if err != nil {
229
-
return nil, err
230
-
}
231
-
232
-
// TODO: use seenAt
233
-
234
-
count, err := s.notifman.GetCount(ctx, u.ID)
235
-
if err != nil {
236
-
return nil, fmt.Errorf("notification getCount: %w", err)
237
-
}
238
-
239
-
fmt.Println("notif count: ", u.Handle, count)
240
-
return &appbskytypes.NotificationGetUnreadCount_Output{
241
-
Count: count,
242
-
}, nil
243
-
}
244
-
245
-
func (s *Server) handleAppBskyNotificationListNotifications(ctx context.Context, cursor string, limit int, seenAt string) (*appbskytypes.NotificationListNotifications_Output, error) {
246
-
u, err := s.getUser(ctx)
247
-
if err != nil {
248
-
return nil, err
249
-
}
250
-
251
-
// TODO: use seenAt
252
-
_ = seenAt
253
-
254
-
notifs, err := s.notifman.GetNotifications(ctx, u.ID)
255
-
if err != nil {
256
-
return nil, err
257
-
}
258
-
259
-
return &appbskytypes.NotificationListNotifications_Output{
260
-
Notifications: notifs,
261
-
}, nil
262
-
}
263
-
264
-
func (s *Server) handleAppBskyNotificationUpdateSeen(ctx context.Context, input *appbskytypes.NotificationUpdateSeen_Input) error {
265
-
u, err := s.getUser(ctx)
266
-
if err != nil {
267
-
return err
268
-
}
269
-
270
-
seen, err := time.Parse(time.RFC3339, input.SeenAt)
271
-
if err != nil {
272
-
return fmt.Errorf("invalid time format for 'seenAt': %w", err)
273
-
}
274
-
275
-
return s.notifman.UpdateSeen(ctx, u.ID, seen)
276
-
}
277
-
278
17
func (s *Server) handleComAtprotoServerCreateAccount(ctx context.Context, body *comatprototypes.ServerCreateAccount_Input) (*comatprototypes.ServerCreateAccount_Output, error) {
279
18
if body.Email == nil {
280
19
return nil, fmt.Errorf("email is required")
···
340
79
return nil, err
341
80
}
342
81
343
-
if err := s.repoman.InitNewActor(ctx, u.ID, u.Handle, u.Did, "", UserActorDeclCid, UserActorDeclType); err != nil {
82
+
if err := s.repoman.InitNewActor(ctx, u.ID, u.Handle, u.Did, "", "", ""); err != nil {
344
83
return nil, err
345
84
}
346
85
···
615
354
return buf, nil
616
355
}
617
356
618
-
func (s *Server) handleAppBskyActorGetProfiles(ctx context.Context, actors []string) (*appbskytypes.ActorGetProfiles_Output, error) {
619
-
panic("nyi")
620
-
}
621
-
622
357
func (s *Server) handleComAtprotoAdminGetRecord(ctx context.Context, cid string, uri string) (*comatprototypes.AdminDefs_RecordViewDetail, error) {
623
358
panic("nyi")
624
359
}
···
650
385
panic("nyi")
651
386
}
652
387
653
-
func (s *Server) handleAppBskyActorSearchActors(ctx context.Context, cursor string, limit int, q string, term string) (*appbskytypes.ActorSearchActors_Output, error) {
654
-
panic("nyi")
655
-
}
656
-
657
-
func (s *Server) handleAppBskyActorSearchActorsTypeahead(ctx context.Context, limit int, q string, term string) (*appbskytypes.ActorSearchActorsTypeahead_Output, error) {
658
-
panic("nyi")
659
-
}
660
-
661
-
func (s *Server) handleAppBskyUnspeccedGetPopular(ctx context.Context, cursor string, includeNsfw bool, limit int) (*appbskytypes.UnspeccedGetPopular_Output, error) {
662
-
panic("nyi")
663
-
}
664
-
665
388
func (s *Server) handleComAtprotoIdentityUpdateHandle(ctx context.Context, body *comatprototypes.IdentityUpdateHandle_Input) error {
666
389
if err := s.validateHandle(body.Handle); err != nil {
667
390
return err
···
726
449
func (s *Server) handleComAtprotoServerRevokeAppPassword(ctx context.Context, body *comatprototypes.ServerRevokeAppPassword_Input) error {
727
450
panic("nyi")
728
451
}
729
-
func (s *Server) handleAppBskyActorGetPreferences(ctx context.Context) (*appbskytypes.ActorGetPreferences_Output, error) {
730
-
panic("nyi")
731
-
}
732
-
733
-
func (s *Server) handleAppBskyActorPutPreferences(ctx context.Context, body *appbskytypes.ActorPutPreferences_Input) error {
734
-
panic("nyi")
735
-
}
736
-
func (s *Server) handleAppBskyFeedGetPosts(ctx context.Context, uris []string) (*appbskytypes.FeedGetPosts_Output, error) {
737
-
panic("nyi")
738
-
}
739
-
func (s *Server) handleAppBskyGraphGetBlocks(ctx context.Context, cursor string, limit int) (*appbskytypes.GraphGetBlocks_Output, error) {
740
-
panic("nyi")
741
-
}
742
-
func (s *Server) handleAppBskyGraphGetList(ctx context.Context, cursor string, limit int, list string) (*appbskytypes.GraphGetList_Output, error) {
743
-
panic("nyi")
744
-
}
745
-
func (s *Server) handleAppBskyGraphGetListMutes(ctx context.Context, cursor string, limit int) (*appbskytypes.GraphGetListMutes_Output, error) {
746
-
panic("nyi")
747
-
}
748
-
func (s *Server) handleAppBskyGraphGetLists(ctx context.Context, actor string, cursor string, limit int) (*appbskytypes.GraphGetLists_Output, error) {
749
-
panic("nyi")
750
-
}
751
-
func (s *Server) handleAppBskyGraphMuteActorList(ctx context.Context, body *appbskytypes.GraphMuteActorList_Input) error {
752
-
panic("nyi")
753
-
}
754
-
func (s *Server) handleAppBskyGraphUnmuteActorList(ctx context.Context, body *appbskytypes.GraphUnmuteActorList_Input) error {
755
-
panic("nyi")
756
-
}
757
452
758
453
func (s *Server) handleComAtprotoAdminDisableAccountInvites(ctx context.Context, body *comatprototypes.AdminDisableAccountInvites_Input) error {
759
454
panic("nyi")
···
763
458
panic("nyi")
764
459
}
765
460
766
-
func (s *Server) handleAppBskyFeedDescribeFeedGenerator(ctx context.Context) (*appbskytypes.FeedDescribeFeedGenerator_Output, error) {
767
-
panic("nyi")
768
-
}
769
-
func (s *Server) handleAppBskyFeedGetActorFeeds(ctx context.Context, actor string, cursor string, limit int) (*appbskytypes.FeedGetActorFeeds_Output, error) {
770
-
panic("nyi")
771
-
}
772
-
func (s *Server) handleAppBskyFeedGetFeed(ctx context.Context, cursor string, feed string, limit int) (*appbskytypes.FeedGetFeed_Output, error) {
773
-
panic("nyi")
774
-
}
775
-
func (s *Server) handleAppBskyFeedGetFeedGenerator(ctx context.Context, feed string) (*appbskytypes.FeedGetFeedGenerator_Output, error) {
776
-
panic("nyi")
777
-
}
778
-
func (s *Server) handleAppBskyFeedGetFeedGenerators(ctx context.Context, feeds []string) (*appbskytypes.FeedGetFeedGenerators_Output, error) {
779
-
panic("nyi")
780
-
}
781
-
func (s *Server) handleAppBskyFeedGetFeedSkeleton(ctx context.Context, cursor string, feed string, limit int) (*appbskytypes.FeedGetFeedSkeleton_Output, error) {
782
-
panic("nyi")
783
-
}
784
-
785
-
func (s *Server) handleAppBskyUnspeccedApplyLabels(ctx context.Context, body *appbskytypes.UnspeccedApplyLabels_Input) error {
786
-
panic("nyi")
787
-
}
788
-
func (s *Server) handleAppBskyUnspeccedGetPopularFeedGenerators(ctx context.Context, cursor string, limit int, query string) (*appbskytypes.UnspeccedGetPopularFeedGenerators_Output, error) {
789
-
panic("nyi")
790
-
}
791
-
func (s *Server) handleAppBskyUnspeccedGetTimelineSkeleton(ctx context.Context, cursor string, limit int) (*appbskytypes.UnspeccedGetTimelineSkeleton_Output, error) {
792
-
panic("nyi")
793
-
}
794
-
795
461
func (s *Server) handleComAtprotoAdminSendEmail(ctx context.Context, body *comatprototypes.AdminSendEmail_Input) (*comatprototypes.AdminSendEmail_Output, error) {
796
462
panic("nyi")
797
463
}
798
464
799
-
func (s *Server) handleAppBskyFeedGetActorLikes(ctx context.Context, actor string, cursor string, limit int) (*appbskytypes.FeedGetActorLikes_Output, error) {
800
-
panic("nyi")
801
-
}
802
-
803
-
func (s *Server) handleAppBskyNotificationRegisterPush(ctx context.Context, body *appbskytypes.NotificationRegisterPush_Input) error {
804
-
panic("nyi")
805
-
}
806
-
807
465
func (s *Server) handleComAtprotoSyncGetLatestCommit(ctx context.Context, did string) (*comatprototypes.SyncGetLatestCommit_Output, error) {
808
466
panic("nyi")
809
467
}
···
812
470
panic("nyi")
813
471
}
814
472
815
-
func (s *Server) handleAppBskyFeedGetListFeed(ctx context.Context, cursor string, limit int, list string) (*appbskytypes.FeedGetListFeed_Output, error) {
816
-
panic("nyi")
817
-
}
818
-
819
-
func (s *Server) handleAppBskyFeedGetSuggestedFeeds(ctx context.Context, cursor string, limit int) (*appbskytypes.FeedGetSuggestedFeeds_Output, error) {
820
-
panic("nyi")
821
-
}
822
-
823
-
func (s *Server) handleAppBskyFeedSearchPosts(ctx context.Context, cursor string, limit int, q string) (*appbskytypes.FeedSearchPosts_Output, error) {
824
-
panic("nyi")
825
-
}
826
-
827
-
func (s *Server) handleAppBskyGraphGetListBlocks(ctx context.Context, cursor string, limit int) (*appbskytypes.GraphGetListBlocks_Output, error) {
828
-
panic("nyi")
829
-
}
830
-
831
-
func (s *Server) handleAppBskyGraphGetSuggestedFollowsByActor(ctx context.Context, actor string) (*appbskytypes.GraphGetSuggestedFollowsByActor_Output, error) {
832
-
panic("nyi")
833
-
}
834
-
835
-
func (s *Server) handleAppBskyUnspeccedSearchActorsSkeleton(ctx context.Context, cursor string, limit int, q string, typeahead *bool) (*appbskytypes.UnspeccedSearchActorsSkeleton_Output, error) {
836
-
panic("nyi")
837
-
}
838
-
func (s *Server) handleAppBskyUnspeccedSearchPostsSkeleton(ctx context.Context, cursor string, limit int, q string) (*appbskytypes.UnspeccedSearchPostsSkeleton_Output, error) {
839
-
panic("nyi")
840
-
}
841
473
func (s *Server) handleComAtprotoAdminGetAccountInfo(ctx context.Context, did string) (*comatprototypes.AdminDefs_AccountView, error) {
842
474
panic("nyi")
843
475
}
-7
pds/server.go
-7
pds/server.go
···
59
59
plc plc.PLCClient
60
60
}
61
61
62
-
const UserActorDeclCid = "bafyreid27zk7lbis4zw5fz4podbvbs4fc5ivwji3dmrwa6zggnj4bnd57u"
63
-
const UserActorDeclType = "app.bsky.system.actorUser"
64
-
65
62
// serverListenerBootTimeout is how long to wait for the requested server socket
66
63
// to become available for use. This is an arbitrary timeout that should be safe
67
64
// on any platform, but there's no great way to weave this timeout without
···
316
313
return true
317
314
case "/xrpc/com.atproto.server.describeServer":
318
315
return true
319
-
case "/xrpc/app.bsky.actor.getProfile":
320
-
fmt.Println("TODO: currently not requiring auth on get profile endpoint")
321
-
return true
322
316
case "/xrpc/com.atproto.sync.getRepo":
323
317
fmt.Println("TODO: currently not requiring auth on get repo endpoint")
324
318
return true
···
356
350
357
351
e.Use(middleware.JWTWithConfig(cfg), s.userCheckMiddleware)
358
352
s.RegisterHandlersComAtproto(e)
359
-
s.RegisterHandlersAppBsky(e)
360
353
e.GET("/xrpc/com.atproto.sync.subscribeRepos", s.EventsHandler)
361
354
e.GET("/xrpc/_health", s.HandleHealthCheck)
362
355
e.GET("/.well-known/atproto-did", s.HandleResolveDid)
-1076
pds/stubs.go
-1076
pds/stubs.go
···
5
5
"strconv"
6
6
7
7
comatprototypes "github.com/bluesky-social/indigo/api/atproto"
8
-
appbskytypes "github.com/bluesky-social/indigo/api/bsky"
9
8
"github.com/labstack/echo/v4"
10
9
"go.opentelemetry.io/otel"
11
10
)
12
-
13
-
func (s *Server) RegisterHandlersAppBsky(e *echo.Echo) error {
14
-
e.GET("/xrpc/app.bsky.actor.getPreferences", s.HandleAppBskyActorGetPreferences)
15
-
e.GET("/xrpc/app.bsky.actor.getProfile", s.HandleAppBskyActorGetProfile)
16
-
e.GET("/xrpc/app.bsky.actor.getProfiles", s.HandleAppBskyActorGetProfiles)
17
-
e.GET("/xrpc/app.bsky.actor.getSuggestions", s.HandleAppBskyActorGetSuggestions)
18
-
e.POST("/xrpc/app.bsky.actor.putPreferences", s.HandleAppBskyActorPutPreferences)
19
-
e.GET("/xrpc/app.bsky.actor.searchActors", s.HandleAppBskyActorSearchActors)
20
-
e.GET("/xrpc/app.bsky.actor.searchActorsTypeahead", s.HandleAppBskyActorSearchActorsTypeahead)
21
-
e.GET("/xrpc/app.bsky.feed.describeFeedGenerator", s.HandleAppBskyFeedDescribeFeedGenerator)
22
-
e.GET("/xrpc/app.bsky.feed.getActorFeeds", s.HandleAppBskyFeedGetActorFeeds)
23
-
e.GET("/xrpc/app.bsky.feed.getActorLikes", s.HandleAppBskyFeedGetActorLikes)
24
-
e.GET("/xrpc/app.bsky.feed.getAuthorFeed", s.HandleAppBskyFeedGetAuthorFeed)
25
-
e.GET("/xrpc/app.bsky.feed.getFeed", s.HandleAppBskyFeedGetFeed)
26
-
e.GET("/xrpc/app.bsky.feed.getFeedGenerator", s.HandleAppBskyFeedGetFeedGenerator)
27
-
e.GET("/xrpc/app.bsky.feed.getFeedGenerators", s.HandleAppBskyFeedGetFeedGenerators)
28
-
e.GET("/xrpc/app.bsky.feed.getFeedSkeleton", s.HandleAppBskyFeedGetFeedSkeleton)
29
-
e.GET("/xrpc/app.bsky.feed.getLikes", s.HandleAppBskyFeedGetLikes)
30
-
e.GET("/xrpc/app.bsky.feed.getListFeed", s.HandleAppBskyFeedGetListFeed)
31
-
e.GET("/xrpc/app.bsky.feed.getPostThread", s.HandleAppBskyFeedGetPostThread)
32
-
e.GET("/xrpc/app.bsky.feed.getPosts", s.HandleAppBskyFeedGetPosts)
33
-
e.GET("/xrpc/app.bsky.feed.getRepostedBy", s.HandleAppBskyFeedGetRepostedBy)
34
-
e.GET("/xrpc/app.bsky.feed.getSuggestedFeeds", s.HandleAppBskyFeedGetSuggestedFeeds)
35
-
e.GET("/xrpc/app.bsky.feed.getTimeline", s.HandleAppBskyFeedGetTimeline)
36
-
e.GET("/xrpc/app.bsky.feed.searchPosts", s.HandleAppBskyFeedSearchPosts)
37
-
e.GET("/xrpc/app.bsky.graph.getBlocks", s.HandleAppBskyGraphGetBlocks)
38
-
e.GET("/xrpc/app.bsky.graph.getFollowers", s.HandleAppBskyGraphGetFollowers)
39
-
e.GET("/xrpc/app.bsky.graph.getFollows", s.HandleAppBskyGraphGetFollows)
40
-
e.GET("/xrpc/app.bsky.graph.getList", s.HandleAppBskyGraphGetList)
41
-
e.GET("/xrpc/app.bsky.graph.getListBlocks", s.HandleAppBskyGraphGetListBlocks)
42
-
e.GET("/xrpc/app.bsky.graph.getListMutes", s.HandleAppBskyGraphGetListMutes)
43
-
e.GET("/xrpc/app.bsky.graph.getLists", s.HandleAppBskyGraphGetLists)
44
-
e.GET("/xrpc/app.bsky.graph.getMutes", s.HandleAppBskyGraphGetMutes)
45
-
e.GET("/xrpc/app.bsky.graph.getSuggestedFollowsByActor", s.HandleAppBskyGraphGetSuggestedFollowsByActor)
46
-
e.POST("/xrpc/app.bsky.graph.muteActor", s.HandleAppBskyGraphMuteActor)
47
-
e.POST("/xrpc/app.bsky.graph.muteActorList", s.HandleAppBskyGraphMuteActorList)
48
-
e.POST("/xrpc/app.bsky.graph.unmuteActor", s.HandleAppBskyGraphUnmuteActor)
49
-
e.POST("/xrpc/app.bsky.graph.unmuteActorList", s.HandleAppBskyGraphUnmuteActorList)
50
-
e.GET("/xrpc/app.bsky.notification.getUnreadCount", s.HandleAppBskyNotificationGetUnreadCount)
51
-
e.GET("/xrpc/app.bsky.notification.listNotifications", s.HandleAppBskyNotificationListNotifications)
52
-
e.POST("/xrpc/app.bsky.notification.registerPush", s.HandleAppBskyNotificationRegisterPush)
53
-
e.POST("/xrpc/app.bsky.notification.updateSeen", s.HandleAppBskyNotificationUpdateSeen)
54
-
e.GET("/xrpc/app.bsky.unspecced.getPopular", s.HandleAppBskyUnspeccedGetPopular)
55
-
e.GET("/xrpc/app.bsky.unspecced.getPopularFeedGenerators", s.HandleAppBskyUnspeccedGetPopularFeedGenerators)
56
-
e.GET("/xrpc/app.bsky.unspecced.getTimelineSkeleton", s.HandleAppBskyUnspeccedGetTimelineSkeleton)
57
-
e.GET("/xrpc/app.bsky.unspecced.searchActorsSkeleton", s.HandleAppBskyUnspeccedSearchActorsSkeleton)
58
-
e.GET("/xrpc/app.bsky.unspecced.searchPostsSkeleton", s.HandleAppBskyUnspeccedSearchPostsSkeleton)
59
-
return nil
60
-
}
61
-
62
-
func (s *Server) HandleAppBskyActorGetPreferences(c echo.Context) error {
63
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorGetPreferences")
64
-
defer span.End()
65
-
var out *appbskytypes.ActorGetPreferences_Output
66
-
var handleErr error
67
-
// func (s *Server) handleAppBskyActorGetPreferences(ctx context.Context) (*appbskytypes.ActorGetPreferences_Output, error)
68
-
out, handleErr = s.handleAppBskyActorGetPreferences(ctx)
69
-
if handleErr != nil {
70
-
return handleErr
71
-
}
72
-
return c.JSON(200, out)
73
-
}
74
-
75
-
func (s *Server) HandleAppBskyActorGetProfile(c echo.Context) error {
76
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorGetProfile")
77
-
defer span.End()
78
-
actor := c.QueryParam("actor")
79
-
var out *appbskytypes.ActorDefs_ProfileViewDetailed
80
-
var handleErr error
81
-
// func (s *Server) handleAppBskyActorGetProfile(ctx context.Context,actor string) (*appbskytypes.ActorDefs_ProfileViewDetailed, error)
82
-
out, handleErr = s.handleAppBskyActorGetProfile(ctx, actor)
83
-
if handleErr != nil {
84
-
return handleErr
85
-
}
86
-
return c.JSON(200, out)
87
-
}
88
-
89
-
func (s *Server) HandleAppBskyActorGetProfiles(c echo.Context) error {
90
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorGetProfiles")
91
-
defer span.End()
92
-
93
-
actors := c.QueryParams()["actors"]
94
-
var out *appbskytypes.ActorGetProfiles_Output
95
-
var handleErr error
96
-
// func (s *Server) handleAppBskyActorGetProfiles(ctx context.Context,actors []string) (*appbskytypes.ActorGetProfiles_Output, error)
97
-
out, handleErr = s.handleAppBskyActorGetProfiles(ctx, actors)
98
-
if handleErr != nil {
99
-
return handleErr
100
-
}
101
-
return c.JSON(200, out)
102
-
}
103
-
104
-
func (s *Server) HandleAppBskyActorGetSuggestions(c echo.Context) error {
105
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorGetSuggestions")
106
-
defer span.End()
107
-
cursor := c.QueryParam("cursor")
108
-
109
-
var limit int
110
-
if p := c.QueryParam("limit"); p != "" {
111
-
var err error
112
-
limit, err = strconv.Atoi(p)
113
-
if err != nil {
114
-
return err
115
-
}
116
-
} else {
117
-
limit = 50
118
-
}
119
-
var out *appbskytypes.ActorGetSuggestions_Output
120
-
var handleErr error
121
-
// func (s *Server) handleAppBskyActorGetSuggestions(ctx context.Context,cursor string,limit int) (*appbskytypes.ActorGetSuggestions_Output, error)
122
-
out, handleErr = s.handleAppBskyActorGetSuggestions(ctx, cursor, limit)
123
-
if handleErr != nil {
124
-
return handleErr
125
-
}
126
-
return c.JSON(200, out)
127
-
}
128
-
129
-
func (s *Server) HandleAppBskyActorPutPreferences(c echo.Context) error {
130
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorPutPreferences")
131
-
defer span.End()
132
-
133
-
var body appbskytypes.ActorPutPreferences_Input
134
-
if err := c.Bind(&body); err != nil {
135
-
return err
136
-
}
137
-
var handleErr error
138
-
// func (s *Server) handleAppBskyActorPutPreferences(ctx context.Context,body *appbskytypes.ActorPutPreferences_Input) error
139
-
handleErr = s.handleAppBskyActorPutPreferences(ctx, &body)
140
-
if handleErr != nil {
141
-
return handleErr
142
-
}
143
-
return nil
144
-
}
145
-
146
-
func (s *Server) HandleAppBskyActorSearchActors(c echo.Context) error {
147
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorSearchActors")
148
-
defer span.End()
149
-
cursor := c.QueryParam("cursor")
150
-
151
-
var limit int
152
-
if p := c.QueryParam("limit"); p != "" {
153
-
var err error
154
-
limit, err = strconv.Atoi(p)
155
-
if err != nil {
156
-
return err
157
-
}
158
-
} else {
159
-
limit = 25
160
-
}
161
-
q := c.QueryParam("q")
162
-
term := c.QueryParam("term")
163
-
var out *appbskytypes.ActorSearchActors_Output
164
-
var handleErr error
165
-
// func (s *Server) handleAppBskyActorSearchActors(ctx context.Context,cursor string,limit int,q string,term string) (*appbskytypes.ActorSearchActors_Output, error)
166
-
out, handleErr = s.handleAppBskyActorSearchActors(ctx, cursor, limit, q, term)
167
-
if handleErr != nil {
168
-
return handleErr
169
-
}
170
-
return c.JSON(200, out)
171
-
}
172
-
173
-
func (s *Server) HandleAppBskyActorSearchActorsTypeahead(c echo.Context) error {
174
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyActorSearchActorsTypeahead")
175
-
defer span.End()
176
-
177
-
var limit int
178
-
if p := c.QueryParam("limit"); p != "" {
179
-
var err error
180
-
limit, err = strconv.Atoi(p)
181
-
if err != nil {
182
-
return err
183
-
}
184
-
} else {
185
-
limit = 10
186
-
}
187
-
q := c.QueryParam("q")
188
-
term := c.QueryParam("term")
189
-
var out *appbskytypes.ActorSearchActorsTypeahead_Output
190
-
var handleErr error
191
-
// func (s *Server) handleAppBskyActorSearchActorsTypeahead(ctx context.Context,limit int,q string,term string) (*appbskytypes.ActorSearchActorsTypeahead_Output, error)
192
-
out, handleErr = s.handleAppBskyActorSearchActorsTypeahead(ctx, limit, q, term)
193
-
if handleErr != nil {
194
-
return handleErr
195
-
}
196
-
return c.JSON(200, out)
197
-
}
198
-
199
-
func (s *Server) HandleAppBskyFeedDescribeFeedGenerator(c echo.Context) error {
200
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedDescribeFeedGenerator")
201
-
defer span.End()
202
-
var out *appbskytypes.FeedDescribeFeedGenerator_Output
203
-
var handleErr error
204
-
// func (s *Server) handleAppBskyFeedDescribeFeedGenerator(ctx context.Context) (*appbskytypes.FeedDescribeFeedGenerator_Output, error)
205
-
out, handleErr = s.handleAppBskyFeedDescribeFeedGenerator(ctx)
206
-
if handleErr != nil {
207
-
return handleErr
208
-
}
209
-
return c.JSON(200, out)
210
-
}
211
-
212
-
func (s *Server) HandleAppBskyFeedGetActorFeeds(c echo.Context) error {
213
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetActorFeeds")
214
-
defer span.End()
215
-
actor := c.QueryParam("actor")
216
-
cursor := c.QueryParam("cursor")
217
-
218
-
var limit int
219
-
if p := c.QueryParam("limit"); p != "" {
220
-
var err error
221
-
limit, err = strconv.Atoi(p)
222
-
if err != nil {
223
-
return err
224
-
}
225
-
} else {
226
-
limit = 50
227
-
}
228
-
var out *appbskytypes.FeedGetActorFeeds_Output
229
-
var handleErr error
230
-
// func (s *Server) handleAppBskyFeedGetActorFeeds(ctx context.Context,actor string,cursor string,limit int) (*appbskytypes.FeedGetActorFeeds_Output, error)
231
-
out, handleErr = s.handleAppBskyFeedGetActorFeeds(ctx, actor, cursor, limit)
232
-
if handleErr != nil {
233
-
return handleErr
234
-
}
235
-
return c.JSON(200, out)
236
-
}
237
-
238
-
func (s *Server) HandleAppBskyFeedGetActorLikes(c echo.Context) error {
239
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetActorLikes")
240
-
defer span.End()
241
-
actor := c.QueryParam("actor")
242
-
cursor := c.QueryParam("cursor")
243
-
244
-
var limit int
245
-
if p := c.QueryParam("limit"); p != "" {
246
-
var err error
247
-
limit, err = strconv.Atoi(p)
248
-
if err != nil {
249
-
return err
250
-
}
251
-
} else {
252
-
limit = 50
253
-
}
254
-
var out *appbskytypes.FeedGetActorLikes_Output
255
-
var handleErr error
256
-
// func (s *Server) handleAppBskyFeedGetActorLikes(ctx context.Context,actor string,cursor string,limit int) (*appbskytypes.FeedGetActorLikes_Output, error)
257
-
out, handleErr = s.handleAppBskyFeedGetActorLikes(ctx, actor, cursor, limit)
258
-
if handleErr != nil {
259
-
return handleErr
260
-
}
261
-
return c.JSON(200, out)
262
-
}
263
-
264
-
func (s *Server) HandleAppBskyFeedGetAuthorFeed(c echo.Context) error {
265
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetAuthorFeed")
266
-
defer span.End()
267
-
actor := c.QueryParam("actor")
268
-
cursor := c.QueryParam("cursor")
269
-
filter := c.QueryParam("filter")
270
-
271
-
var limit int
272
-
if p := c.QueryParam("limit"); p != "" {
273
-
var err error
274
-
limit, err = strconv.Atoi(p)
275
-
if err != nil {
276
-
return err
277
-
}
278
-
} else {
279
-
limit = 50
280
-
}
281
-
var out *appbskytypes.FeedGetAuthorFeed_Output
282
-
var handleErr error
283
-
// func (s *Server) handleAppBskyFeedGetAuthorFeed(ctx context.Context,actor string,cursor string,filter string,limit int) (*appbskytypes.FeedGetAuthorFeed_Output, error)
284
-
out, handleErr = s.handleAppBskyFeedGetAuthorFeed(ctx, actor, cursor, filter, limit)
285
-
if handleErr != nil {
286
-
return handleErr
287
-
}
288
-
return c.JSON(200, out)
289
-
}
290
-
291
-
func (s *Server) HandleAppBskyFeedGetFeed(c echo.Context) error {
292
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetFeed")
293
-
defer span.End()
294
-
cursor := c.QueryParam("cursor")
295
-
feed := c.QueryParam("feed")
296
-
297
-
var limit int
298
-
if p := c.QueryParam("limit"); p != "" {
299
-
var err error
300
-
limit, err = strconv.Atoi(p)
301
-
if err != nil {
302
-
return err
303
-
}
304
-
} else {
305
-
limit = 50
306
-
}
307
-
var out *appbskytypes.FeedGetFeed_Output
308
-
var handleErr error
309
-
// func (s *Server) handleAppBskyFeedGetFeed(ctx context.Context,cursor string,feed string,limit int) (*appbskytypes.FeedGetFeed_Output, error)
310
-
out, handleErr = s.handleAppBskyFeedGetFeed(ctx, cursor, feed, limit)
311
-
if handleErr != nil {
312
-
return handleErr
313
-
}
314
-
return c.JSON(200, out)
315
-
}
316
-
317
-
func (s *Server) HandleAppBskyFeedGetFeedGenerator(c echo.Context) error {
318
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetFeedGenerator")
319
-
defer span.End()
320
-
feed := c.QueryParam("feed")
321
-
var out *appbskytypes.FeedGetFeedGenerator_Output
322
-
var handleErr error
323
-
// func (s *Server) handleAppBskyFeedGetFeedGenerator(ctx context.Context,feed string) (*appbskytypes.FeedGetFeedGenerator_Output, error)
324
-
out, handleErr = s.handleAppBskyFeedGetFeedGenerator(ctx, feed)
325
-
if handleErr != nil {
326
-
return handleErr
327
-
}
328
-
return c.JSON(200, out)
329
-
}
330
-
331
-
func (s *Server) HandleAppBskyFeedGetFeedGenerators(c echo.Context) error {
332
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetFeedGenerators")
333
-
defer span.End()
334
-
335
-
feeds := c.QueryParams()["feeds"]
336
-
var out *appbskytypes.FeedGetFeedGenerators_Output
337
-
var handleErr error
338
-
// func (s *Server) handleAppBskyFeedGetFeedGenerators(ctx context.Context,feeds []string) (*appbskytypes.FeedGetFeedGenerators_Output, error)
339
-
out, handleErr = s.handleAppBskyFeedGetFeedGenerators(ctx, feeds)
340
-
if handleErr != nil {
341
-
return handleErr
342
-
}
343
-
return c.JSON(200, out)
344
-
}
345
-
346
-
func (s *Server) HandleAppBskyFeedGetFeedSkeleton(c echo.Context) error {
347
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetFeedSkeleton")
348
-
defer span.End()
349
-
cursor := c.QueryParam("cursor")
350
-
feed := c.QueryParam("feed")
351
-
352
-
var limit int
353
-
if p := c.QueryParam("limit"); p != "" {
354
-
var err error
355
-
limit, err = strconv.Atoi(p)
356
-
if err != nil {
357
-
return err
358
-
}
359
-
} else {
360
-
limit = 50
361
-
}
362
-
var out *appbskytypes.FeedGetFeedSkeleton_Output
363
-
var handleErr error
364
-
// func (s *Server) handleAppBskyFeedGetFeedSkeleton(ctx context.Context,cursor string,feed string,limit int) (*appbskytypes.FeedGetFeedSkeleton_Output, error)
365
-
out, handleErr = s.handleAppBskyFeedGetFeedSkeleton(ctx, cursor, feed, limit)
366
-
if handleErr != nil {
367
-
return handleErr
368
-
}
369
-
return c.JSON(200, out)
370
-
}
371
-
372
-
func (s *Server) HandleAppBskyFeedGetLikes(c echo.Context) error {
373
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetLikes")
374
-
defer span.End()
375
-
cid := c.QueryParam("cid")
376
-
cursor := c.QueryParam("cursor")
377
-
378
-
var limit int
379
-
if p := c.QueryParam("limit"); p != "" {
380
-
var err error
381
-
limit, err = strconv.Atoi(p)
382
-
if err != nil {
383
-
return err
384
-
}
385
-
} else {
386
-
limit = 50
387
-
}
388
-
uri := c.QueryParam("uri")
389
-
var out *appbskytypes.FeedGetLikes_Output
390
-
var handleErr error
391
-
// func (s *Server) handleAppBskyFeedGetLikes(ctx context.Context,cid string,cursor string,limit int,uri string) (*appbskytypes.FeedGetLikes_Output, error)
392
-
out, handleErr = s.handleAppBskyFeedGetLikes(ctx, cid, cursor, limit, uri)
393
-
if handleErr != nil {
394
-
return handleErr
395
-
}
396
-
return c.JSON(200, out)
397
-
}
398
-
399
-
func (s *Server) HandleAppBskyFeedGetListFeed(c echo.Context) error {
400
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetListFeed")
401
-
defer span.End()
402
-
cursor := c.QueryParam("cursor")
403
-
404
-
var limit int
405
-
if p := c.QueryParam("limit"); p != "" {
406
-
var err error
407
-
limit, err = strconv.Atoi(p)
408
-
if err != nil {
409
-
return err
410
-
}
411
-
} else {
412
-
limit = 50
413
-
}
414
-
list := c.QueryParam("list")
415
-
var out *appbskytypes.FeedGetListFeed_Output
416
-
var handleErr error
417
-
// func (s *Server) handleAppBskyFeedGetListFeed(ctx context.Context,cursor string,limit int,list string) (*appbskytypes.FeedGetListFeed_Output, error)
418
-
out, handleErr = s.handleAppBskyFeedGetListFeed(ctx, cursor, limit, list)
419
-
if handleErr != nil {
420
-
return handleErr
421
-
}
422
-
return c.JSON(200, out)
423
-
}
424
-
425
-
func (s *Server) HandleAppBskyFeedGetPostThread(c echo.Context) error {
426
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetPostThread")
427
-
defer span.End()
428
-
429
-
var depth int
430
-
if p := c.QueryParam("depth"); p != "" {
431
-
var err error
432
-
depth, err = strconv.Atoi(p)
433
-
if err != nil {
434
-
return err
435
-
}
436
-
} else {
437
-
depth = 6
438
-
}
439
-
440
-
var parentHeight int
441
-
if p := c.QueryParam("parentHeight"); p != "" {
442
-
var err error
443
-
parentHeight, err = strconv.Atoi(p)
444
-
if err != nil {
445
-
return err
446
-
}
447
-
} else {
448
-
parentHeight = 80
449
-
}
450
-
uri := c.QueryParam("uri")
451
-
var out *appbskytypes.FeedGetPostThread_Output
452
-
var handleErr error
453
-
// func (s *Server) handleAppBskyFeedGetPostThread(ctx context.Context,depth int,parentHeight int,uri string) (*appbskytypes.FeedGetPostThread_Output, error)
454
-
out, handleErr = s.handleAppBskyFeedGetPostThread(ctx, depth, parentHeight, uri)
455
-
if handleErr != nil {
456
-
return handleErr
457
-
}
458
-
return c.JSON(200, out)
459
-
}
460
-
461
-
func (s *Server) HandleAppBskyFeedGetPosts(c echo.Context) error {
462
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetPosts")
463
-
defer span.End()
464
-
465
-
uris := c.QueryParams()["uris"]
466
-
var out *appbskytypes.FeedGetPosts_Output
467
-
var handleErr error
468
-
// func (s *Server) handleAppBskyFeedGetPosts(ctx context.Context,uris []string) (*appbskytypes.FeedGetPosts_Output, error)
469
-
out, handleErr = s.handleAppBskyFeedGetPosts(ctx, uris)
470
-
if handleErr != nil {
471
-
return handleErr
472
-
}
473
-
return c.JSON(200, out)
474
-
}
475
-
476
-
func (s *Server) HandleAppBskyFeedGetRepostedBy(c echo.Context) error {
477
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetRepostedBy")
478
-
defer span.End()
479
-
cid := c.QueryParam("cid")
480
-
cursor := c.QueryParam("cursor")
481
-
482
-
var limit int
483
-
if p := c.QueryParam("limit"); p != "" {
484
-
var err error
485
-
limit, err = strconv.Atoi(p)
486
-
if err != nil {
487
-
return err
488
-
}
489
-
} else {
490
-
limit = 50
491
-
}
492
-
uri := c.QueryParam("uri")
493
-
var out *appbskytypes.FeedGetRepostedBy_Output
494
-
var handleErr error
495
-
// func (s *Server) handleAppBskyFeedGetRepostedBy(ctx context.Context,cid string,cursor string,limit int,uri string) (*appbskytypes.FeedGetRepostedBy_Output, error)
496
-
out, handleErr = s.handleAppBskyFeedGetRepostedBy(ctx, cid, cursor, limit, uri)
497
-
if handleErr != nil {
498
-
return handleErr
499
-
}
500
-
return c.JSON(200, out)
501
-
}
502
-
503
-
func (s *Server) HandleAppBskyFeedGetSuggestedFeeds(c echo.Context) error {
504
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetSuggestedFeeds")
505
-
defer span.End()
506
-
cursor := c.QueryParam("cursor")
507
-
508
-
var limit int
509
-
if p := c.QueryParam("limit"); p != "" {
510
-
var err error
511
-
limit, err = strconv.Atoi(p)
512
-
if err != nil {
513
-
return err
514
-
}
515
-
} else {
516
-
limit = 50
517
-
}
518
-
var out *appbskytypes.FeedGetSuggestedFeeds_Output
519
-
var handleErr error
520
-
// func (s *Server) handleAppBskyFeedGetSuggestedFeeds(ctx context.Context,cursor string,limit int) (*appbskytypes.FeedGetSuggestedFeeds_Output, error)
521
-
out, handleErr = s.handleAppBskyFeedGetSuggestedFeeds(ctx, cursor, limit)
522
-
if handleErr != nil {
523
-
return handleErr
524
-
}
525
-
return c.JSON(200, out)
526
-
}
527
-
528
-
func (s *Server) HandleAppBskyFeedGetTimeline(c echo.Context) error {
529
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedGetTimeline")
530
-
defer span.End()
531
-
algorithm := c.QueryParam("algorithm")
532
-
cursor := c.QueryParam("cursor")
533
-
534
-
var limit int
535
-
if p := c.QueryParam("limit"); p != "" {
536
-
var err error
537
-
limit, err = strconv.Atoi(p)
538
-
if err != nil {
539
-
return err
540
-
}
541
-
} else {
542
-
limit = 50
543
-
}
544
-
var out *appbskytypes.FeedGetTimeline_Output
545
-
var handleErr error
546
-
// func (s *Server) handleAppBskyFeedGetTimeline(ctx context.Context,algorithm string,cursor string,limit int) (*appbskytypes.FeedGetTimeline_Output, error)
547
-
out, handleErr = s.handleAppBskyFeedGetTimeline(ctx, algorithm, cursor, limit)
548
-
if handleErr != nil {
549
-
return handleErr
550
-
}
551
-
return c.JSON(200, out)
552
-
}
553
-
554
-
func (s *Server) HandleAppBskyFeedSearchPosts(c echo.Context) error {
555
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyFeedSearchPosts")
556
-
defer span.End()
557
-
cursor := c.QueryParam("cursor")
558
-
559
-
var limit int
560
-
if p := c.QueryParam("limit"); p != "" {
561
-
var err error
562
-
limit, err = strconv.Atoi(p)
563
-
if err != nil {
564
-
return err
565
-
}
566
-
} else {
567
-
limit = 25
568
-
}
569
-
q := c.QueryParam("q")
570
-
var out *appbskytypes.FeedSearchPosts_Output
571
-
var handleErr error
572
-
// func (s *Server) handleAppBskyFeedSearchPosts(ctx context.Context,cursor string,limit int,q string) (*appbskytypes.FeedSearchPosts_Output, error)
573
-
out, handleErr = s.handleAppBskyFeedSearchPosts(ctx, cursor, limit, q)
574
-
if handleErr != nil {
575
-
return handleErr
576
-
}
577
-
return c.JSON(200, out)
578
-
}
579
-
580
-
func (s *Server) HandleAppBskyGraphGetBlocks(c echo.Context) error {
581
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetBlocks")
582
-
defer span.End()
583
-
cursor := c.QueryParam("cursor")
584
-
585
-
var limit int
586
-
if p := c.QueryParam("limit"); p != "" {
587
-
var err error
588
-
limit, err = strconv.Atoi(p)
589
-
if err != nil {
590
-
return err
591
-
}
592
-
} else {
593
-
limit = 50
594
-
}
595
-
var out *appbskytypes.GraphGetBlocks_Output
596
-
var handleErr error
597
-
// func (s *Server) handleAppBskyGraphGetBlocks(ctx context.Context,cursor string,limit int) (*appbskytypes.GraphGetBlocks_Output, error)
598
-
out, handleErr = s.handleAppBskyGraphGetBlocks(ctx, cursor, limit)
599
-
if handleErr != nil {
600
-
return handleErr
601
-
}
602
-
return c.JSON(200, out)
603
-
}
604
-
605
-
func (s *Server) HandleAppBskyGraphGetFollowers(c echo.Context) error {
606
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetFollowers")
607
-
defer span.End()
608
-
actor := c.QueryParam("actor")
609
-
cursor := c.QueryParam("cursor")
610
-
611
-
var limit int
612
-
if p := c.QueryParam("limit"); p != "" {
613
-
var err error
614
-
limit, err = strconv.Atoi(p)
615
-
if err != nil {
616
-
return err
617
-
}
618
-
} else {
619
-
limit = 50
620
-
}
621
-
var out *appbskytypes.GraphGetFollowers_Output
622
-
var handleErr error
623
-
// func (s *Server) handleAppBskyGraphGetFollowers(ctx context.Context,actor string,cursor string,limit int) (*appbskytypes.GraphGetFollowers_Output, error)
624
-
out, handleErr = s.handleAppBskyGraphGetFollowers(ctx, actor, cursor, limit)
625
-
if handleErr != nil {
626
-
return handleErr
627
-
}
628
-
return c.JSON(200, out)
629
-
}
630
-
631
-
func (s *Server) HandleAppBskyGraphGetFollows(c echo.Context) error {
632
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetFollows")
633
-
defer span.End()
634
-
actor := c.QueryParam("actor")
635
-
cursor := c.QueryParam("cursor")
636
-
637
-
var limit int
638
-
if p := c.QueryParam("limit"); p != "" {
639
-
var err error
640
-
limit, err = strconv.Atoi(p)
641
-
if err != nil {
642
-
return err
643
-
}
644
-
} else {
645
-
limit = 50
646
-
}
647
-
var out *appbskytypes.GraphGetFollows_Output
648
-
var handleErr error
649
-
// func (s *Server) handleAppBskyGraphGetFollows(ctx context.Context,actor string,cursor string,limit int) (*appbskytypes.GraphGetFollows_Output, error)
650
-
out, handleErr = s.handleAppBskyGraphGetFollows(ctx, actor, cursor, limit)
651
-
if handleErr != nil {
652
-
return handleErr
653
-
}
654
-
return c.JSON(200, out)
655
-
}
656
-
657
-
func (s *Server) HandleAppBskyGraphGetList(c echo.Context) error {
658
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetList")
659
-
defer span.End()
660
-
cursor := c.QueryParam("cursor")
661
-
662
-
var limit int
663
-
if p := c.QueryParam("limit"); p != "" {
664
-
var err error
665
-
limit, err = strconv.Atoi(p)
666
-
if err != nil {
667
-
return err
668
-
}
669
-
} else {
670
-
limit = 50
671
-
}
672
-
list := c.QueryParam("list")
673
-
var out *appbskytypes.GraphGetList_Output
674
-
var handleErr error
675
-
// func (s *Server) handleAppBskyGraphGetList(ctx context.Context,cursor string,limit int,list string) (*appbskytypes.GraphGetList_Output, error)
676
-
out, handleErr = s.handleAppBskyGraphGetList(ctx, cursor, limit, list)
677
-
if handleErr != nil {
678
-
return handleErr
679
-
}
680
-
return c.JSON(200, out)
681
-
}
682
-
683
-
func (s *Server) HandleAppBskyGraphGetListBlocks(c echo.Context) error {
684
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetListBlocks")
685
-
defer span.End()
686
-
cursor := c.QueryParam("cursor")
687
-
688
-
var limit int
689
-
if p := c.QueryParam("limit"); p != "" {
690
-
var err error
691
-
limit, err = strconv.Atoi(p)
692
-
if err != nil {
693
-
return err
694
-
}
695
-
} else {
696
-
limit = 50
697
-
}
698
-
var out *appbskytypes.GraphGetListBlocks_Output
699
-
var handleErr error
700
-
// func (s *Server) handleAppBskyGraphGetListBlocks(ctx context.Context,cursor string,limit int) (*appbskytypes.GraphGetListBlocks_Output, error)
701
-
out, handleErr = s.handleAppBskyGraphGetListBlocks(ctx, cursor, limit)
702
-
if handleErr != nil {
703
-
return handleErr
704
-
}
705
-
return c.JSON(200, out)
706
-
}
707
-
708
-
func (s *Server) HandleAppBskyGraphGetListMutes(c echo.Context) error {
709
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetListMutes")
710
-
defer span.End()
711
-
cursor := c.QueryParam("cursor")
712
-
713
-
var limit int
714
-
if p := c.QueryParam("limit"); p != "" {
715
-
var err error
716
-
limit, err = strconv.Atoi(p)
717
-
if err != nil {
718
-
return err
719
-
}
720
-
} else {
721
-
limit = 50
722
-
}
723
-
var out *appbskytypes.GraphGetListMutes_Output
724
-
var handleErr error
725
-
// func (s *Server) handleAppBskyGraphGetListMutes(ctx context.Context,cursor string,limit int) (*appbskytypes.GraphGetListMutes_Output, error)
726
-
out, handleErr = s.handleAppBskyGraphGetListMutes(ctx, cursor, limit)
727
-
if handleErr != nil {
728
-
return handleErr
729
-
}
730
-
return c.JSON(200, out)
731
-
}
732
-
733
-
func (s *Server) HandleAppBskyGraphGetLists(c echo.Context) error {
734
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetLists")
735
-
defer span.End()
736
-
actor := c.QueryParam("actor")
737
-
cursor := c.QueryParam("cursor")
738
-
739
-
var limit int
740
-
if p := c.QueryParam("limit"); p != "" {
741
-
var err error
742
-
limit, err = strconv.Atoi(p)
743
-
if err != nil {
744
-
return err
745
-
}
746
-
} else {
747
-
limit = 50
748
-
}
749
-
var out *appbskytypes.GraphGetLists_Output
750
-
var handleErr error
751
-
// func (s *Server) handleAppBskyGraphGetLists(ctx context.Context,actor string,cursor string,limit int) (*appbskytypes.GraphGetLists_Output, error)
752
-
out, handleErr = s.handleAppBskyGraphGetLists(ctx, actor, cursor, limit)
753
-
if handleErr != nil {
754
-
return handleErr
755
-
}
756
-
return c.JSON(200, out)
757
-
}
758
-
759
-
func (s *Server) HandleAppBskyGraphGetMutes(c echo.Context) error {
760
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetMutes")
761
-
defer span.End()
762
-
cursor := c.QueryParam("cursor")
763
-
764
-
var limit int
765
-
if p := c.QueryParam("limit"); p != "" {
766
-
var err error
767
-
limit, err = strconv.Atoi(p)
768
-
if err != nil {
769
-
return err
770
-
}
771
-
} else {
772
-
limit = 50
773
-
}
774
-
var out *appbskytypes.GraphGetMutes_Output
775
-
var handleErr error
776
-
// func (s *Server) handleAppBskyGraphGetMutes(ctx context.Context,cursor string,limit int) (*appbskytypes.GraphGetMutes_Output, error)
777
-
out, handleErr = s.handleAppBskyGraphGetMutes(ctx, cursor, limit)
778
-
if handleErr != nil {
779
-
return handleErr
780
-
}
781
-
return c.JSON(200, out)
782
-
}
783
-
784
-
func (s *Server) HandleAppBskyGraphGetSuggestedFollowsByActor(c echo.Context) error {
785
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphGetSuggestedFollowsByActor")
786
-
defer span.End()
787
-
actor := c.QueryParam("actor")
788
-
var out *appbskytypes.GraphGetSuggestedFollowsByActor_Output
789
-
var handleErr error
790
-
// func (s *Server) handleAppBskyGraphGetSuggestedFollowsByActor(ctx context.Context,actor string) (*appbskytypes.GraphGetSuggestedFollowsByActor_Output, error)
791
-
out, handleErr = s.handleAppBskyGraphGetSuggestedFollowsByActor(ctx, actor)
792
-
if handleErr != nil {
793
-
return handleErr
794
-
}
795
-
return c.JSON(200, out)
796
-
}
797
-
798
-
func (s *Server) HandleAppBskyGraphMuteActor(c echo.Context) error {
799
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphMuteActor")
800
-
defer span.End()
801
-
802
-
var body appbskytypes.GraphMuteActor_Input
803
-
if err := c.Bind(&body); err != nil {
804
-
return err
805
-
}
806
-
var handleErr error
807
-
// func (s *Server) handleAppBskyGraphMuteActor(ctx context.Context,body *appbskytypes.GraphMuteActor_Input) error
808
-
handleErr = s.handleAppBskyGraphMuteActor(ctx, &body)
809
-
if handleErr != nil {
810
-
return handleErr
811
-
}
812
-
return nil
813
-
}
814
-
815
-
func (s *Server) HandleAppBskyGraphMuteActorList(c echo.Context) error {
816
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphMuteActorList")
817
-
defer span.End()
818
-
819
-
var body appbskytypes.GraphMuteActorList_Input
820
-
if err := c.Bind(&body); err != nil {
821
-
return err
822
-
}
823
-
var handleErr error
824
-
// func (s *Server) handleAppBskyGraphMuteActorList(ctx context.Context,body *appbskytypes.GraphMuteActorList_Input) error
825
-
handleErr = s.handleAppBskyGraphMuteActorList(ctx, &body)
826
-
if handleErr != nil {
827
-
return handleErr
828
-
}
829
-
return nil
830
-
}
831
-
832
-
func (s *Server) HandleAppBskyGraphUnmuteActor(c echo.Context) error {
833
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphUnmuteActor")
834
-
defer span.End()
835
-
836
-
var body appbskytypes.GraphUnmuteActor_Input
837
-
if err := c.Bind(&body); err != nil {
838
-
return err
839
-
}
840
-
var handleErr error
841
-
// func (s *Server) handleAppBskyGraphUnmuteActor(ctx context.Context,body *appbskytypes.GraphUnmuteActor_Input) error
842
-
handleErr = s.handleAppBskyGraphUnmuteActor(ctx, &body)
843
-
if handleErr != nil {
844
-
return handleErr
845
-
}
846
-
return nil
847
-
}
848
-
849
-
func (s *Server) HandleAppBskyGraphUnmuteActorList(c echo.Context) error {
850
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyGraphUnmuteActorList")
851
-
defer span.End()
852
-
853
-
var body appbskytypes.GraphUnmuteActorList_Input
854
-
if err := c.Bind(&body); err != nil {
855
-
return err
856
-
}
857
-
var handleErr error
858
-
// func (s *Server) handleAppBskyGraphUnmuteActorList(ctx context.Context,body *appbskytypes.GraphUnmuteActorList_Input) error
859
-
handleErr = s.handleAppBskyGraphUnmuteActorList(ctx, &body)
860
-
if handleErr != nil {
861
-
return handleErr
862
-
}
863
-
return nil
864
-
}
865
-
866
-
func (s *Server) HandleAppBskyNotificationGetUnreadCount(c echo.Context) error {
867
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyNotificationGetUnreadCount")
868
-
defer span.End()
869
-
seenAt := c.QueryParam("seenAt")
870
-
var out *appbskytypes.NotificationGetUnreadCount_Output
871
-
var handleErr error
872
-
// func (s *Server) handleAppBskyNotificationGetUnreadCount(ctx context.Context,seenAt string) (*appbskytypes.NotificationGetUnreadCount_Output, error)
873
-
out, handleErr = s.handleAppBskyNotificationGetUnreadCount(ctx, seenAt)
874
-
if handleErr != nil {
875
-
return handleErr
876
-
}
877
-
return c.JSON(200, out)
878
-
}
879
-
880
-
func (s *Server) HandleAppBskyNotificationListNotifications(c echo.Context) error {
881
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyNotificationListNotifications")
882
-
defer span.End()
883
-
cursor := c.QueryParam("cursor")
884
-
885
-
var limit int
886
-
if p := c.QueryParam("limit"); p != "" {
887
-
var err error
888
-
limit, err = strconv.Atoi(p)
889
-
if err != nil {
890
-
return err
891
-
}
892
-
} else {
893
-
limit = 50
894
-
}
895
-
seenAt := c.QueryParam("seenAt")
896
-
var out *appbskytypes.NotificationListNotifications_Output
897
-
var handleErr error
898
-
// func (s *Server) handleAppBskyNotificationListNotifications(ctx context.Context,cursor string,limit int,seenAt string) (*appbskytypes.NotificationListNotifications_Output, error)
899
-
out, handleErr = s.handleAppBskyNotificationListNotifications(ctx, cursor, limit, seenAt)
900
-
if handleErr != nil {
901
-
return handleErr
902
-
}
903
-
return c.JSON(200, out)
904
-
}
905
-
906
-
func (s *Server) HandleAppBskyNotificationRegisterPush(c echo.Context) error {
907
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyNotificationRegisterPush")
908
-
defer span.End()
909
-
910
-
var body appbskytypes.NotificationRegisterPush_Input
911
-
if err := c.Bind(&body); err != nil {
912
-
return err
913
-
}
914
-
var handleErr error
915
-
// func (s *Server) handleAppBskyNotificationRegisterPush(ctx context.Context,body *appbskytypes.NotificationRegisterPush_Input) error
916
-
handleErr = s.handleAppBskyNotificationRegisterPush(ctx, &body)
917
-
if handleErr != nil {
918
-
return handleErr
919
-
}
920
-
return nil
921
-
}
922
-
923
-
func (s *Server) HandleAppBskyNotificationUpdateSeen(c echo.Context) error {
924
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyNotificationUpdateSeen")
925
-
defer span.End()
926
-
927
-
var body appbskytypes.NotificationUpdateSeen_Input
928
-
if err := c.Bind(&body); err != nil {
929
-
return err
930
-
}
931
-
var handleErr error
932
-
// func (s *Server) handleAppBskyNotificationUpdateSeen(ctx context.Context,body *appbskytypes.NotificationUpdateSeen_Input) error
933
-
handleErr = s.handleAppBskyNotificationUpdateSeen(ctx, &body)
934
-
if handleErr != nil {
935
-
return handleErr
936
-
}
937
-
return nil
938
-
}
939
-
940
-
func (s *Server) HandleAppBskyUnspeccedGetPopular(c echo.Context) error {
941
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyUnspeccedGetPopular")
942
-
defer span.End()
943
-
cursor := c.QueryParam("cursor")
944
-
945
-
var includeNsfw bool
946
-
if p := c.QueryParam("includeNsfw"); p != "" {
947
-
var err error
948
-
includeNsfw, err = strconv.ParseBool(p)
949
-
if err != nil {
950
-
return err
951
-
}
952
-
} else {
953
-
includeNsfw = false
954
-
}
955
-
956
-
var limit int
957
-
if p := c.QueryParam("limit"); p != "" {
958
-
var err error
959
-
limit, err = strconv.Atoi(p)
960
-
if err != nil {
961
-
return err
962
-
}
963
-
} else {
964
-
limit = 50
965
-
}
966
-
var out *appbskytypes.UnspeccedGetPopular_Output
967
-
var handleErr error
968
-
// func (s *Server) handleAppBskyUnspeccedGetPopular(ctx context.Context,cursor string,includeNsfw bool,limit int) (*appbskytypes.UnspeccedGetPopular_Output, error)
969
-
out, handleErr = s.handleAppBskyUnspeccedGetPopular(ctx, cursor, includeNsfw, limit)
970
-
if handleErr != nil {
971
-
return handleErr
972
-
}
973
-
return c.JSON(200, out)
974
-
}
975
-
976
-
func (s *Server) HandleAppBskyUnspeccedGetPopularFeedGenerators(c echo.Context) error {
977
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyUnspeccedGetPopularFeedGenerators")
978
-
defer span.End()
979
-
cursor := c.QueryParam("cursor")
980
-
981
-
var limit int
982
-
if p := c.QueryParam("limit"); p != "" {
983
-
var err error
984
-
limit, err = strconv.Atoi(p)
985
-
if err != nil {
986
-
return err
987
-
}
988
-
} else {
989
-
limit = 50
990
-
}
991
-
query := c.QueryParam("query")
992
-
var out *appbskytypes.UnspeccedGetPopularFeedGenerators_Output
993
-
var handleErr error
994
-
// func (s *Server) handleAppBskyUnspeccedGetPopularFeedGenerators(ctx context.Context,cursor string,limit int,query string) (*appbskytypes.UnspeccedGetPopularFeedGenerators_Output, error)
995
-
out, handleErr = s.handleAppBskyUnspeccedGetPopularFeedGenerators(ctx, cursor, limit, query)
996
-
if handleErr != nil {
997
-
return handleErr
998
-
}
999
-
return c.JSON(200, out)
1000
-
}
1001
-
1002
-
func (s *Server) HandleAppBskyUnspeccedGetTimelineSkeleton(c echo.Context) error {
1003
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyUnspeccedGetTimelineSkeleton")
1004
-
defer span.End()
1005
-
cursor := c.QueryParam("cursor")
1006
-
1007
-
var limit int
1008
-
if p := c.QueryParam("limit"); p != "" {
1009
-
var err error
1010
-
limit, err = strconv.Atoi(p)
1011
-
if err != nil {
1012
-
return err
1013
-
}
1014
-
} else {
1015
-
limit = 50
1016
-
}
1017
-
var out *appbskytypes.UnspeccedGetTimelineSkeleton_Output
1018
-
var handleErr error
1019
-
// func (s *Server) handleAppBskyUnspeccedGetTimelineSkeleton(ctx context.Context,cursor string,limit int) (*appbskytypes.UnspeccedGetTimelineSkeleton_Output, error)
1020
-
out, handleErr = s.handleAppBskyUnspeccedGetTimelineSkeleton(ctx, cursor, limit)
1021
-
if handleErr != nil {
1022
-
return handleErr
1023
-
}
1024
-
return c.JSON(200, out)
1025
-
}
1026
-
1027
-
func (s *Server) HandleAppBskyUnspeccedSearchActorsSkeleton(c echo.Context) error {
1028
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyUnspeccedSearchActorsSkeleton")
1029
-
defer span.End()
1030
-
cursor := c.QueryParam("cursor")
1031
-
1032
-
var limit int
1033
-
if p := c.QueryParam("limit"); p != "" {
1034
-
var err error
1035
-
limit, err = strconv.Atoi(p)
1036
-
if err != nil {
1037
-
return err
1038
-
}
1039
-
} else {
1040
-
limit = 25
1041
-
}
1042
-
q := c.QueryParam("q")
1043
-
1044
-
var typeahead *bool
1045
-
if p := c.QueryParam("typeahead"); p != "" {
1046
-
typeahead_val, err := strconv.ParseBool(p)
1047
-
if err != nil {
1048
-
return err
1049
-
}
1050
-
typeahead = &typeahead_val
1051
-
}
1052
-
var out *appbskytypes.UnspeccedSearchActorsSkeleton_Output
1053
-
var handleErr error
1054
-
// func (s *Server) handleAppBskyUnspeccedSearchActorsSkeleton(ctx context.Context,cursor string,limit int,q string,typeahead *bool) (*appbskytypes.UnspeccedSearchActorsSkeleton_Output, error)
1055
-
out, handleErr = s.handleAppBskyUnspeccedSearchActorsSkeleton(ctx, cursor, limit, q, typeahead)
1056
-
if handleErr != nil {
1057
-
return handleErr
1058
-
}
1059
-
return c.JSON(200, out)
1060
-
}
1061
-
1062
-
func (s *Server) HandleAppBskyUnspeccedSearchPostsSkeleton(c echo.Context) error {
1063
-
ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyUnspeccedSearchPostsSkeleton")
1064
-
defer span.End()
1065
-
cursor := c.QueryParam("cursor")
1066
-
1067
-
var limit int
1068
-
if p := c.QueryParam("limit"); p != "" {
1069
-
var err error
1070
-
limit, err = strconv.Atoi(p)
1071
-
if err != nil {
1072
-
return err
1073
-
}
1074
-
} else {
1075
-
limit = 25
1076
-
}
1077
-
q := c.QueryParam("q")
1078
-
var out *appbskytypes.UnspeccedSearchPostsSkeleton_Output
1079
-
var handleErr error
1080
-
// func (s *Server) handleAppBskyUnspeccedSearchPostsSkeleton(ctx context.Context,cursor string,limit int,q string) (*appbskytypes.UnspeccedSearchPostsSkeleton_Output, error)
1081
-
out, handleErr = s.handleAppBskyUnspeccedSearchPostsSkeleton(ctx, cursor, limit, q)
1082
-
if handleErr != nil {
1083
-
return handleErr
1084
-
}
1085
-
return c.JSON(200, out)
1086
-
}
1087
11
1088
12
func (s *Server) RegisterHandlersComAtproto(e *echo.Echo) error {
1089
13
e.POST("/xrpc/com.atproto.admin.disableAccountInvites", s.HandleComAtprotoAdminDisableAccountInvites)