this repo has no description
0
fork

Configure Feed

Select the types of activity you want to include in your feed.

some more lexicon updates (#126)

authored by

Whyrusleeping and committed by
GitHub
22c94f06 0ea3242f

+295 -25
+2
api/atproto/admindefs.go
··· 198 198 Blobs []*AdminDefs_BlobView `json:"blobs" cborgen:"blobs"` 199 199 Cid string `json:"cid" cborgen:"cid"` 200 200 IndexedAt string `json:"indexedAt" cborgen:"indexedAt"` 201 + Labels []*LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 201 202 Moderation *AdminDefs_ModerationDetail `json:"moderation" cborgen:"moderation"` 202 203 Repo *AdminDefs_RepoView `json:"repo" cborgen:"repo"` 203 204 Uri string `json:"uri" cborgen:"uri"` ··· 229 230 IndexedAt string `json:"indexedAt" cborgen:"indexedAt"` 230 231 InvitedBy *ServerDefs_InviteCode `json:"invitedBy,omitempty" cborgen:"invitedBy,omitempty"` 231 232 Invites []*ServerDefs_InviteCode `json:"invites,omitempty" cborgen:"invites,omitempty"` 233 + Labels []*LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 232 234 Moderation *AdminDefs_ModerationDetail `json:"moderation" cborgen:"moderation"` 233 235 RelatedRecords []*util.LexiconTypeDecoder `json:"relatedRecords" cborgen:"relatedRecords"` 234 236 }
+25
api/atproto/adminupdateAccountEmail.go
··· 1 + package atproto 2 + 3 + import ( 4 + "context" 5 + 6 + "github.com/bluesky-social/indigo/xrpc" 7 + ) 8 + 9 + // schema: com.atproto.admin.updateAccountEmail 10 + 11 + func init() { 12 + } 13 + 14 + type AdminUpdateAccountEmail_Input struct { 15 + Account string `json:"account" cborgen:"account"` 16 + Email string `json:"email" cborgen:"email"` 17 + } 18 + 19 + func AdminUpdateAccountEmail(ctx context.Context, c *xrpc.Client, input *AdminUpdateAccountEmail_Input) error { 20 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.admin.updateAccountEmail", nil, input, nil); err != nil { 21 + return err 22 + } 23 + 24 + return nil 25 + }
+25
api/atproto/adminupdateAccountHandle.go
··· 1 + package atproto 2 + 3 + import ( 4 + "context" 5 + 6 + "github.com/bluesky-social/indigo/xrpc" 7 + ) 8 + 9 + // schema: com.atproto.admin.updateAccountHandle 10 + 11 + func init() { 12 + } 13 + 14 + type AdminUpdateAccountHandle_Input struct { 15 + Did string `json:"did" cborgen:"did"` 16 + Handle string `json:"handle" cborgen:"handle"` 17 + } 18 + 19 + func AdminUpdateAccountHandle(ctx context.Context, c *xrpc.Client, input *AdminUpdateAccountHandle_Input) error { 20 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.admin.updateAccountHandle", nil, input, nil); err != nil { 21 + return err 22 + } 23 + 24 + return nil 25 + }
+8 -1
api/atproto/labeldefs.go
··· 5 5 func init() { 6 6 } 7 7 8 - type LabelDefs_Label interface{} 8 + type LabelDefs_Label struct { 9 + Cid *string `json:"cid,omitempty" cborgen:"cid,omitempty"` 10 + Cts string `json:"cts" cborgen:"cts"` 11 + Neg *bool `json:"neg,omitempty" cborgen:"neg,omitempty"` 12 + Src string `json:"src" cborgen:"src"` 13 + Uri string `json:"uri" cborgen:"uri"` 14 + Val string `json:"val" cborgen:"val"` 15 + }
+31
api/atproto/servercreateAppPassword.go
··· 1 + package atproto 2 + 3 + import ( 4 + "context" 5 + 6 + "github.com/bluesky-social/indigo/xrpc" 7 + ) 8 + 9 + // schema: com.atproto.server.createAppPassword 10 + 11 + func init() { 12 + } 13 + 14 + type ServerCreateAppPassword_AppPassword struct { 15 + CreatedAt string `json:"createdAt" cborgen:"createdAt"` 16 + Name string `json:"name" cborgen:"name"` 17 + Password string `json:"password" cborgen:"password"` 18 + } 19 + 20 + type ServerCreateAppPassword_Input struct { 21 + Name string `json:"name" cborgen:"name"` 22 + } 23 + 24 + func ServerCreateAppPassword(ctx context.Context, c *xrpc.Client, input *ServerCreateAppPassword_Input) (*ServerCreateAppPassword_AppPassword, error) { 25 + var out ServerCreateAppPassword_AppPassword 26 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.server.createAppPassword", nil, input, &out); err != nil { 27 + return nil, err 28 + } 29 + 30 + return &out, nil 31 + }
+9 -4
api/atproto/servercreateInviteCodes.go
··· 11 11 func init() { 12 12 } 13 13 14 + type ServerCreateInviteCodes_AccountCodes struct { 15 + Account string `json:"account" cborgen:"account"` 16 + Codes []string `json:"codes" cborgen:"codes"` 17 + } 18 + 14 19 type ServerCreateInviteCodes_Input struct { 15 - CodeCount int64 `json:"codeCount" cborgen:"codeCount"` 16 - ForAccount *string `json:"forAccount,omitempty" cborgen:"forAccount,omitempty"` 17 - UseCount int64 `json:"useCount" cborgen:"useCount"` 20 + CodeCount int64 `json:"codeCount" cborgen:"codeCount"` 21 + ForAccounts []string `json:"forAccounts,omitempty" cborgen:"forAccounts,omitempty"` 22 + UseCount int64 `json:"useCount" cborgen:"useCount"` 18 23 } 19 24 20 25 type ServerCreateInviteCodes_Output struct { 21 - Codes []string `json:"codes" cborgen:"codes"` 26 + Codes []*ServerCreateInviteCodes_AccountCodes `json:"codes" cborgen:"codes"` 22 27 } 23 28 24 29 func ServerCreateInviteCodes(ctx context.Context, c *xrpc.Client, input *ServerCreateInviteCodes_Input) (*ServerCreateInviteCodes_Output, error) {
+30
api/atproto/serverlistAppPasswords.go
··· 1 + package atproto 2 + 3 + import ( 4 + "context" 5 + 6 + "github.com/bluesky-social/indigo/xrpc" 7 + ) 8 + 9 + // schema: com.atproto.server.listAppPasswords 10 + 11 + func init() { 12 + } 13 + 14 + type ServerListAppPasswords_AppPassword struct { 15 + CreatedAt string `json:"createdAt" cborgen:"createdAt"` 16 + Name string `json:"name" cborgen:"name"` 17 + } 18 + 19 + type ServerListAppPasswords_Output struct { 20 + Passwords []*ServerListAppPasswords_AppPassword `json:"passwords" cborgen:"passwords"` 21 + } 22 + 23 + func ServerListAppPasswords(ctx context.Context, c *xrpc.Client) (*ServerListAppPasswords_Output, error) { 24 + var out ServerListAppPasswords_Output 25 + if err := c.Do(ctx, xrpc.Query, "", "com.atproto.server.listAppPasswords", nil, nil, &out); err != nil { 26 + return nil, err 27 + } 28 + 29 + return &out, nil 30 + }
+24
api/atproto/serverrevokeAppPassword.go
··· 1 + package atproto 2 + 3 + import ( 4 + "context" 5 + 6 + "github.com/bluesky-social/indigo/xrpc" 7 + ) 8 + 9 + // schema: com.atproto.server.revokeAppPassword 10 + 11 + func init() { 12 + } 13 + 14 + type ServerRevokeAppPassword_Input struct { 15 + Name string `json:"name" cborgen:"name"` 16 + } 17 + 18 + func ServerRevokeAppPassword(ctx context.Context, c *xrpc.Client, input *ServerRevokeAppPassword_Input) error { 19 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.server.revokeAppPassword", nil, input, nil); err != nil { 20 + return err 21 + } 22 + 23 + return nil 24 + }
+6 -2
api/bsky/notificationgetUnreadCount.go
··· 15 15 Count int64 `json:"count" cborgen:"count"` 16 16 } 17 17 18 - func NotificationGetUnreadCount(ctx context.Context, c *xrpc.Client) (*NotificationGetUnreadCount_Output, error) { 18 + func NotificationGetUnreadCount(ctx context.Context, c *xrpc.Client, seenAt string) (*NotificationGetUnreadCount_Output, error) { 19 19 var out NotificationGetUnreadCount_Output 20 - if err := c.Do(ctx, xrpc.Query, "", "app.bsky.notification.getUnreadCount", nil, nil, &out); err != nil { 20 + 21 + params := map[string]interface{}{ 22 + "seenAt": seenAt, 23 + } 24 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.notification.getUnreadCount", params, nil, &out); err != nil { 21 25 return nil, err 22 26 } 23 27
+2 -1
api/bsky/notificationlistNotifications.go
··· 30 30 Notifications []*NotificationListNotifications_Notification `json:"notifications" cborgen:"notifications"` 31 31 } 32 32 33 - func NotificationListNotifications(ctx context.Context, c *xrpc.Client, cursor string, limit int64) (*NotificationListNotifications_Output, error) { 33 + func NotificationListNotifications(ctx context.Context, c *xrpc.Client, cursor string, limit int64, seenAt string) (*NotificationListNotifications_Output, error) { 34 34 var out NotificationListNotifications_Output 35 35 36 36 params := map[string]interface{}{ 37 37 "cursor": cursor, 38 38 "limit": limit, 39 + "seenAt": seenAt, 39 40 } 40 41 if err := c.Do(ctx, xrpc.Query, "", "app.bsky.notification.listNotifications", params, nil, &out); err != nil { 41 42 return nil, err
+10 -8
cmd/gosky/main.go
··· 661 661 return err 662 662 } 663 663 664 - notifs, err := appbsky.NotificationListNotifications(ctx, xrpcc, "", 50) 664 + notifs, err := appbsky.NotificationListNotifications(ctx, xrpcc, "", 50, "") 665 665 if err != nil { 666 666 return err 667 667 } ··· 1059 1059 for d := range feeder { 1060 1060 did := d 1061 1061 resp, err := comatproto.ServerCreateInviteCodes(context.TODO(), xrpcc, &comatproto.ServerCreateInviteCodes_Input{ 1062 - UseCount: int64(count), 1063 - ForAccount: &did, 1064 - CodeCount: int64(num), 1062 + UseCount: int64(count), 1063 + ForAccounts: []string{did}, 1064 + CodeCount: int64(num), 1065 1065 }) 1066 1066 if err != nil { 1067 1067 log.Error(err) ··· 1093 1093 1094 1094 xrpcc.AdminToken = &adminKey 1095 1095 resp, err := comatproto.ServerCreateInviteCodes(context.TODO(), xrpcc, &comatproto.ServerCreateInviteCodes_Input{ 1096 - UseCount: int64(count), 1097 - ForAccount: usrdid, 1098 - CodeCount: int64(num), 1096 + UseCount: int64(count), 1097 + ForAccounts: []string{*usrdid}, 1098 + CodeCount: int64(num), 1099 1099 }) 1100 1100 if err != nil { 1101 1101 return fmt.Errorf("creating codes: %w", err) 1102 1102 } 1103 1103 1104 1104 for _, c := range resp.Codes { 1105 - fmt.Println(c) 1105 + for _, cc := range c.Codes { 1106 + fmt.Println(cc) 1107 + } 1106 1108 } 1107 1109 1108 1110 return nil
+2 -2
fakedata/generators.go
··· 382 382 func BrowseAccount(xrpcc *xrpc.Client, acc *AccountContext) error { 383 383 // fetch notifications 384 384 maxNotif := 50 385 - resp, err := appbsky.NotificationListNotifications(context.TODO(), xrpcc, "", int64(maxNotif)) 385 + resp, err := appbsky.NotificationListNotifications(context.TODO(), xrpcc, "", int64(maxNotif), "") 386 386 if err != nil { 387 387 return err 388 388 } ··· 452 452 t2(len(timelineResp.Feed)) 453 453 454 454 // notification count for good measure 455 - _, err = appbsky.NotificationGetUnreadCount(context.TODO(), xrpcc) 455 + _, err = appbsky.NotificationGetUnreadCount(context.TODO(), xrpcc, "") 456 456 return err 457 457 }
+27 -2
pds/handlers.go
··· 224 224 panic("not yet implemented") 225 225 } 226 226 227 - func (s *Server) handleAppBskyNotificationGetUnreadCount(ctx context.Context) (*appbskytypes.NotificationGetUnreadCount_Output, error) { 227 + func (s *Server) handleAppBskyNotificationGetUnreadCount(ctx context.Context, seenAt string) (*appbskytypes.NotificationGetUnreadCount_Output, error) { 228 228 u, err := s.getUser(ctx) 229 229 if err != nil { 230 230 return nil, err 231 231 } 232 + 233 + // TODO: use seenAt 232 234 233 235 count, err := s.notifman.GetCount(ctx, u.ID) 234 236 if err != nil { ··· 241 243 }, nil 242 244 } 243 245 244 - func (s *Server) handleAppBskyNotificationListNotifications(ctx context.Context, cursor string, limit int) (*appbskytypes.NotificationListNotifications_Output, error) { 246 + func (s *Server) handleAppBskyNotificationListNotifications(ctx context.Context, cursor string, limit int, seenAt string) (*appbskytypes.NotificationListNotifications_Output, error) { 245 247 u, err := s.getUser(ctx) 246 248 if err != nil { 247 249 return nil, err 248 250 } 251 + 252 + // TODO: use seenAt 253 + _ = seenAt 249 254 250 255 notifs, err := s.notifman.GetNotifications(ctx, u.ID) 251 256 if err != nil { ··· 728 733 func (s *Server) handleComAtprotoSyncListRepos(ctx context.Context, cursor string, limit int) (*comatprototypes.SyncListRepos_Output, error) { 729 734 panic("nyi") 730 735 } 736 + 737 + func (s *Server) handleComAtprotoAdminUpdateAccountEmail(ctx context.Context, body *comatprototypes.AdminUpdateAccountEmail_Input) error { 738 + panic("nyi") 739 + } 740 + 741 + func (s *Server) handleComAtprotoAdminUpdateAccountHandle(ctx context.Context, body *comatprototypes.AdminUpdateAccountHandle_Input) error { 742 + panic("nyi") 743 + } 744 + 745 + func (s *Server) handleComAtprotoServerCreateAppPassword(ctx context.Context, body *comatprototypes.ServerCreateAppPassword_Input) (*comatprototypes.ServerCreateAppPassword_AppPassword, error) { 746 + panic("nyi") 747 + } 748 + 749 + func (s *Server) handleComAtprotoServerListAppPasswords(ctx context.Context) (*comatprototypes.ServerListAppPasswords_Output, error) { 750 + panic("nyi") 751 + } 752 + 753 + func (s *Server) handleComAtprotoServerRevokeAppPassword(ctx context.Context, body *comatprototypes.ServerRevokeAppPassword_Input) error { 754 + panic("nyi") 755 + }
+93 -4
pds/stubs.go
··· 381 381 func (s *Server) HandleAppBskyNotificationGetUnreadCount(c echo.Context) error { 382 382 ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleAppBskyNotificationGetUnreadCount") 383 383 defer span.End() 384 + seenAt := c.QueryParam("seenAt") 384 385 var out *appbskytypes.NotificationGetUnreadCount_Output 385 386 var handleErr error 386 - // func (s *Server) handleAppBskyNotificationGetUnreadCount(ctx context.Context) (*appbskytypes.NotificationGetUnreadCount_Output, error) 387 - out, handleErr = s.handleAppBskyNotificationGetUnreadCount(ctx) 387 + // func (s *Server) handleAppBskyNotificationGetUnreadCount(ctx context.Context,seenAt string) (*appbskytypes.NotificationGetUnreadCount_Output, error) 388 + out, handleErr = s.handleAppBskyNotificationGetUnreadCount(ctx, seenAt) 388 389 if handleErr != nil { 389 390 return handleErr 390 391 } ··· 406 407 } else { 407 408 limit = 50 408 409 } 410 + seenAt := c.QueryParam("seenAt") 409 411 var out *appbskytypes.NotificationListNotifications_Output 410 412 var handleErr error 411 - // func (s *Server) handleAppBskyNotificationListNotifications(ctx context.Context,cursor string,limit int) (*appbskytypes.NotificationListNotifications_Output, error) 412 - out, handleErr = s.handleAppBskyNotificationListNotifications(ctx, cursor, limit) 413 + // func (s *Server) handleAppBskyNotificationListNotifications(ctx context.Context,cursor string,limit int,seenAt string) (*appbskytypes.NotificationListNotifications_Output, error) 414 + out, handleErr = s.handleAppBskyNotificationListNotifications(ctx, cursor, limit, seenAt) 413 415 if handleErr != nil { 414 416 return handleErr 415 417 } ··· 471 473 e.POST("/xrpc/com.atproto.admin.reverseModerationAction", s.HandleComAtprotoAdminReverseModerationAction) 472 474 e.GET("/xrpc/com.atproto.admin.searchRepos", s.HandleComAtprotoAdminSearchRepos) 473 475 e.POST("/xrpc/com.atproto.admin.takeModerationAction", s.HandleComAtprotoAdminTakeModerationAction) 476 + e.POST("/xrpc/com.atproto.admin.updateAccountEmail", s.HandleComAtprotoAdminUpdateAccountEmail) 477 + e.POST("/xrpc/com.atproto.admin.updateAccountHandle", s.HandleComAtprotoAdminUpdateAccountHandle) 474 478 e.GET("/xrpc/com.atproto.identity.resolveHandle", s.HandleComAtprotoIdentityResolveHandle) 475 479 e.POST("/xrpc/com.atproto.identity.updateHandle", s.HandleComAtprotoIdentityUpdateHandle) 476 480 e.GET("/xrpc/com.atproto.label.queryLabels", s.HandleComAtprotoLabelQueryLabels) ··· 484 488 e.POST("/xrpc/com.atproto.repo.putRecord", s.HandleComAtprotoRepoPutRecord) 485 489 e.POST("/xrpc/com.atproto.repo.uploadBlob", s.HandleComAtprotoRepoUploadBlob) 486 490 e.POST("/xrpc/com.atproto.server.createAccount", s.HandleComAtprotoServerCreateAccount) 491 + e.POST("/xrpc/com.atproto.server.createAppPassword", s.HandleComAtprotoServerCreateAppPassword) 487 492 e.POST("/xrpc/com.atproto.server.createInviteCode", s.HandleComAtprotoServerCreateInviteCode) 488 493 e.POST("/xrpc/com.atproto.server.createInviteCodes", s.HandleComAtprotoServerCreateInviteCodes) 489 494 e.POST("/xrpc/com.atproto.server.createSession", s.HandleComAtprotoServerCreateSession) ··· 492 497 e.GET("/xrpc/com.atproto.server.describeServer", s.HandleComAtprotoServerDescribeServer) 493 498 e.GET("/xrpc/com.atproto.server.getAccountInviteCodes", s.HandleComAtprotoServerGetAccountInviteCodes) 494 499 e.GET("/xrpc/com.atproto.server.getSession", s.HandleComAtprotoServerGetSession) 500 + e.GET("/xrpc/com.atproto.server.listAppPasswords", s.HandleComAtprotoServerListAppPasswords) 495 501 e.POST("/xrpc/com.atproto.server.refreshSession", s.HandleComAtprotoServerRefreshSession) 496 502 e.POST("/xrpc/com.atproto.server.requestAccountDelete", s.HandleComAtprotoServerRequestAccountDelete) 497 503 e.POST("/xrpc/com.atproto.server.requestPasswordReset", s.HandleComAtprotoServerRequestPasswordReset) 498 504 e.POST("/xrpc/com.atproto.server.resetPassword", s.HandleComAtprotoServerResetPassword) 505 + e.POST("/xrpc/com.atproto.server.revokeAppPassword", s.HandleComAtprotoServerRevokeAppPassword) 499 506 e.GET("/xrpc/com.atproto.sync.getBlob", s.HandleComAtprotoSyncGetBlob) 500 507 e.GET("/xrpc/com.atproto.sync.getBlocks", s.HandleComAtprotoSyncGetBlocks) 501 508 e.GET("/xrpc/com.atproto.sync.getCheckout", s.HandleComAtprotoSyncGetCheckout) ··· 758 765 return handleErr 759 766 } 760 767 return c.JSON(200, out) 768 + } 769 + 770 + func (s *Server) HandleComAtprotoAdminUpdateAccountEmail(c echo.Context) error { 771 + ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoAdminUpdateAccountEmail") 772 + defer span.End() 773 + 774 + var body comatprototypes.AdminUpdateAccountEmail_Input 775 + if err := c.Bind(&body); err != nil { 776 + return err 777 + } 778 + var handleErr error 779 + // func (s *Server) handleComAtprotoAdminUpdateAccountEmail(ctx context.Context,body *comatprototypes.AdminUpdateAccountEmail_Input) error 780 + handleErr = s.handleComAtprotoAdminUpdateAccountEmail(ctx, &body) 781 + if handleErr != nil { 782 + return handleErr 783 + } 784 + return nil 785 + } 786 + 787 + func (s *Server) HandleComAtprotoAdminUpdateAccountHandle(c echo.Context) error { 788 + ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoAdminUpdateAccountHandle") 789 + defer span.End() 790 + 791 + var body comatprototypes.AdminUpdateAccountHandle_Input 792 + if err := c.Bind(&body); err != nil { 793 + return err 794 + } 795 + var handleErr error 796 + // func (s *Server) handleComAtprotoAdminUpdateAccountHandle(ctx context.Context,body *comatprototypes.AdminUpdateAccountHandle_Input) error 797 + handleErr = s.handleComAtprotoAdminUpdateAccountHandle(ctx, &body) 798 + if handleErr != nil { 799 + return handleErr 800 + } 801 + return nil 761 802 } 762 803 763 804 func (s *Server) HandleComAtprotoIdentityResolveHandle(c echo.Context) error { ··· 1010 1051 return c.JSON(200, out) 1011 1052 } 1012 1053 1054 + func (s *Server) HandleComAtprotoServerCreateAppPassword(c echo.Context) error { 1055 + ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoServerCreateAppPassword") 1056 + defer span.End() 1057 + 1058 + var body comatprototypes.ServerCreateAppPassword_Input 1059 + if err := c.Bind(&body); err != nil { 1060 + return err 1061 + } 1062 + var out *comatprototypes.ServerCreateAppPassword_AppPassword 1063 + var handleErr error 1064 + // func (s *Server) handleComAtprotoServerCreateAppPassword(ctx context.Context,body *comatprototypes.ServerCreateAppPassword_Input) (*comatprototypes.ServerCreateAppPassword_AppPassword, error) 1065 + out, handleErr = s.handleComAtprotoServerCreateAppPassword(ctx, &body) 1066 + if handleErr != nil { 1067 + return handleErr 1068 + } 1069 + return c.JSON(200, out) 1070 + } 1071 + 1013 1072 func (s *Server) HandleComAtprotoServerCreateInviteCode(c echo.Context) error { 1014 1073 ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoServerCreateInviteCode") 1015 1074 defer span.End() ··· 1154 1213 return c.JSON(200, out) 1155 1214 } 1156 1215 1216 + func (s *Server) HandleComAtprotoServerListAppPasswords(c echo.Context) error { 1217 + ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoServerListAppPasswords") 1218 + defer span.End() 1219 + var out *comatprototypes.ServerListAppPasswords_Output 1220 + var handleErr error 1221 + // func (s *Server) handleComAtprotoServerListAppPasswords(ctx context.Context) (*comatprototypes.ServerListAppPasswords_Output, error) 1222 + out, handleErr = s.handleComAtprotoServerListAppPasswords(ctx) 1223 + if handleErr != nil { 1224 + return handleErr 1225 + } 1226 + return c.JSON(200, out) 1227 + } 1228 + 1157 1229 func (s *Server) HandleComAtprotoServerRefreshSession(c echo.Context) error { 1158 1230 ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoServerRefreshSession") 1159 1231 defer span.End() ··· 1207 1279 var handleErr error 1208 1280 // func (s *Server) handleComAtprotoServerResetPassword(ctx context.Context,body *comatprototypes.ServerResetPassword_Input) error 1209 1281 handleErr = s.handleComAtprotoServerResetPassword(ctx, &body) 1282 + if handleErr != nil { 1283 + return handleErr 1284 + } 1285 + return nil 1286 + } 1287 + 1288 + func (s *Server) HandleComAtprotoServerRevokeAppPassword(c echo.Context) error { 1289 + ctx, span := otel.Tracer("server").Start(c.Request().Context(), "HandleComAtprotoServerRevokeAppPassword") 1290 + defer span.End() 1291 + 1292 + var body comatprototypes.ServerRevokeAppPassword_Input 1293 + if err := c.Bind(&body); err != nil { 1294 + return err 1295 + } 1296 + var handleErr error 1297 + // func (s *Server) handleComAtprotoServerRevokeAppPassword(ctx context.Context,body *comatprototypes.ServerRevokeAppPassword_Input) error 1298 + handleErr = s.handleComAtprotoServerRevokeAppPassword(ctx, &body) 1210 1299 if handleErr != nil { 1211 1300 return handleErr 1212 1301 }
+1 -1
testing/utils.go
··· 297 297 t.Helper() 298 298 299 299 ctx := context.TODO() 300 - resp, err := bsky.NotificationListNotifications(ctx, u.client, "", 100) 300 + resp, err := bsky.NotificationListNotifications(ctx, u.client, "", 100, "") 301 301 if err != nil { 302 302 t.Fatal(err) 303 303 }