alice.mosphere.at / indigo
this repo has no description
0
fork

Configure Feed

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

lexgen (2025-04-06) (#1011)

Ran lexgen against the `atproto` repo today (2025-04-06). Need to do
this periodically as maintenance; also I thought some Ozone event
changes needed to be pulled in, but maybe not.

Made two manual changes:

- did not include the removal of deprecated event types on
`subscribeRepos` (handle, tombstone, etc). that will have a broad impact
on the `events/` package, which persists events to disk using those
types
- manually commented out a `_Profile` type in the ozone types. I think
this is related to an open union thing

authored by

bnewbold and committed by
GitHub 9822a588 bfc7f487

+968 -52
+1 -5
api/agnostic/repolistRecords.go
··· 31 31 // limit: The number of records to return. 32 32 // repo: The handle or DID of the repo. 33 33 // reverse: Flag to reverse the order of the returned records. 34 - // rkeyEnd: DEPRECATED: The highest sort-ordered rkey to stop at (exclusive) 35 - // rkeyStart: DEPRECATED: The lowest sort-ordered rkey to start from (exclusive) 36 - func RepoListRecords(ctx context.Context, c *xrpc.Client, collection string, cursor string, limit int64, repo string, reverse bool, rkeyEnd string, rkeyStart string) (*RepoListRecords_Output, error) { 34 + func RepoListRecords(ctx context.Context, c *xrpc.Client, collection string, cursor string, limit int64, repo string, reverse bool) (*RepoListRecords_Output, error) { 37 35 var out RepoListRecords_Output 38 36 39 37 params := map[string]interface{}{ ··· 42 40 "limit": limit, 43 41 "repo": repo, 44 42 "reverse": reverse, 45 - "rkeyEnd": rkeyEnd, 46 - "rkeyStart": rkeyStart, 47 43 } 48 44 if err := c.Do(ctx, xrpc.Query, "", "com.atproto.repo.listRecords", params, nil, &out); err != nil { 49 45 return nil, err
+27
api/atproto/adminupdateAccountSigningKey.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package atproto 4 + 5 + // schema: com.atproto.admin.updateAccountSigningKey 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // AdminUpdateAccountSigningKey_Input is the input argument to a com.atproto.admin.updateAccountSigningKey call. 14 + type AdminUpdateAccountSigningKey_Input struct { 15 + Did string `json:"did" cborgen:"did"` 16 + // signingKey: Did-key formatted public key 17 + SigningKey string `json:"signingKey" cborgen:"signingKey"` 18 + } 19 + 20 + // AdminUpdateAccountSigningKey calls the XRPC method "com.atproto.admin.updateAccountSigningKey". 21 + func AdminUpdateAccountSigningKey(ctx context.Context, c *xrpc.Client, input *AdminUpdateAccountSigningKey_Input) error { 22 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.admin.updateAccountSigningKey", nil, input, nil); err != nil { 23 + return err 24 + } 25 + 26 + return nil 27 + }
+1 -5
api/atproto/repolistRecords.go
··· 30 30 // limit: The number of records to return. 31 31 // repo: The handle or DID of the repo. 32 32 // reverse: Flag to reverse the order of the returned records. 33 - // rkeyEnd: DEPRECATED: The highest sort-ordered rkey to stop at (exclusive) 34 - // rkeyStart: DEPRECATED: The lowest sort-ordered rkey to start from (exclusive) 35 - func RepoListRecords(ctx context.Context, c *xrpc.Client, collection string, cursor string, limit int64, repo string, reverse bool, rkeyEnd string, rkeyStart string) (*RepoListRecords_Output, error) { 33 + func RepoListRecords(ctx context.Context, c *xrpc.Client, collection string, cursor string, limit int64, repo string, reverse bool) (*RepoListRecords_Output, error) { 36 34 var out RepoListRecords_Output 37 35 38 36 params := map[string]interface{}{ ··· 41 39 "limit": limit, 42 40 "repo": repo, 43 41 "reverse": reverse, 44 - "rkeyEnd": rkeyEnd, 45 - "rkeyStart": rkeyStart, 46 42 } 47 43 if err := c.Do(ctx, xrpc.Query, "", "com.atproto.repo.listRecords", params, nil, &out); err != nil { 48 44 return nil, err
+1 -3
api/atproto/syncgetRecord.go
··· 13 13 14 14 // SyncGetRecord calls the XRPC method "com.atproto.sync.getRecord". 15 15 // 16 - // commit: DEPRECATED: referenced a repo commit by CID, and retrieved record as of that commit 17 16 // did: The DID of the repo. 18 17 // rkey: Record Key 19 - func SyncGetRecord(ctx context.Context, c *xrpc.Client, collection string, commit string, did string, rkey string) ([]byte, error) { 18 + func SyncGetRecord(ctx context.Context, c *xrpc.Client, collection string, did string, rkey string) ([]byte, error) { 20 19 buf := new(bytes.Buffer) 21 20 22 21 params := map[string]interface{}{ 23 22 "collection": collection, 24 - "commit": commit, 25 23 "did": did, 26 24 "rkey": rkey, 27 25 }
+274 -2
api/bsky/cbor_gen.go
··· 6921 6921 } 6922 6922 6923 6923 cw := cbg.NewCborWriter(w) 6924 - fieldCount := 4 6924 + fieldCount := 7 6925 6925 6926 6926 if t.Labels == nil { 6927 + fieldCount-- 6928 + } 6929 + 6930 + if t.ReasonTypes == nil { 6931 + fieldCount-- 6932 + } 6933 + 6934 + if t.SubjectCollections == nil { 6935 + fieldCount-- 6936 + } 6937 + 6938 + if t.SubjectTypes == nil { 6927 6939 fieldCount-- 6928 6940 } 6929 6941 ··· 7007 7019 if _, err := cw.WriteString(string(t.CreatedAt)); err != nil { 7008 7020 return err 7009 7021 } 7022 + 7023 + // t.ReasonTypes ([]*string) (slice) 7024 + if t.ReasonTypes != nil { 7025 + 7026 + if len("reasonTypes") > 1000000 { 7027 + return xerrors.Errorf("Value in field \"reasonTypes\" was too long") 7028 + } 7029 + 7030 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("reasonTypes"))); err != nil { 7031 + return err 7032 + } 7033 + if _, err := cw.WriteString(string("reasonTypes")); err != nil { 7034 + return err 7035 + } 7036 + 7037 + if len(t.ReasonTypes) > 8192 { 7038 + return xerrors.Errorf("Slice value in field t.ReasonTypes was too long") 7039 + } 7040 + 7041 + if err := cw.WriteMajorTypeHeader(cbg.MajArray, uint64(len(t.ReasonTypes))); err != nil { 7042 + return err 7043 + } 7044 + for _, v := range t.ReasonTypes { 7045 + if v == nil { 7046 + if _, err := cw.Write(cbg.CborNull); err != nil { 7047 + return err 7048 + } 7049 + } else { 7050 + if len(*v) > 1000000 { 7051 + return xerrors.Errorf("Value in field v was too long") 7052 + } 7053 + 7054 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(*v))); err != nil { 7055 + return err 7056 + } 7057 + if _, err := cw.WriteString(string(*v)); err != nil { 7058 + return err 7059 + } 7060 + } 7061 + 7062 + } 7063 + } 7064 + 7065 + // t.SubjectTypes ([]*string) (slice) 7066 + if t.SubjectTypes != nil { 7067 + 7068 + if len("subjectTypes") > 1000000 { 7069 + return xerrors.Errorf("Value in field \"subjectTypes\" was too long") 7070 + } 7071 + 7072 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("subjectTypes"))); err != nil { 7073 + return err 7074 + } 7075 + if _, err := cw.WriteString(string("subjectTypes")); err != nil { 7076 + return err 7077 + } 7078 + 7079 + if len(t.SubjectTypes) > 8192 { 7080 + return xerrors.Errorf("Slice value in field t.SubjectTypes was too long") 7081 + } 7082 + 7083 + if err := cw.WriteMajorTypeHeader(cbg.MajArray, uint64(len(t.SubjectTypes))); err != nil { 7084 + return err 7085 + } 7086 + for _, v := range t.SubjectTypes { 7087 + if v == nil { 7088 + if _, err := cw.Write(cbg.CborNull); err != nil { 7089 + return err 7090 + } 7091 + } else { 7092 + if len(*v) > 1000000 { 7093 + return xerrors.Errorf("Value in field v was too long") 7094 + } 7095 + 7096 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(*v))); err != nil { 7097 + return err 7098 + } 7099 + if _, err := cw.WriteString(string(*v)); err != nil { 7100 + return err 7101 + } 7102 + } 7103 + 7104 + } 7105 + } 7106 + 7107 + // t.SubjectCollections ([]string) (slice) 7108 + if t.SubjectCollections != nil { 7109 + 7110 + if len("subjectCollections") > 1000000 { 7111 + return xerrors.Errorf("Value in field \"subjectCollections\" was too long") 7112 + } 7113 + 7114 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("subjectCollections"))); err != nil { 7115 + return err 7116 + } 7117 + if _, err := cw.WriteString(string("subjectCollections")); err != nil { 7118 + return err 7119 + } 7120 + 7121 + if len(t.SubjectCollections) > 8192 { 7122 + return xerrors.Errorf("Slice value in field t.SubjectCollections was too long") 7123 + } 7124 + 7125 + if err := cw.WriteMajorTypeHeader(cbg.MajArray, uint64(len(t.SubjectCollections))); err != nil { 7126 + return err 7127 + } 7128 + for _, v := range t.SubjectCollections { 7129 + if len(v) > 1000000 { 7130 + return xerrors.Errorf("Value in field v was too long") 7131 + } 7132 + 7133 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(v))); err != nil { 7134 + return err 7135 + } 7136 + if _, err := cw.WriteString(string(v)); err != nil { 7137 + return err 7138 + } 7139 + 7140 + } 7141 + } 7010 7142 return nil 7011 7143 } 7012 7144 ··· 7035 7167 7036 7168 n := extra 7037 7169 7038 - nameBuf := make([]byte, 9) 7170 + nameBuf := make([]byte, 18) 7039 7171 for i := uint64(0); i < n; i++ { 7040 7172 nameLen, ok, err := cbg.ReadFullStringIntoBuf(cr, nameBuf, 1000000) 7041 7173 if err != nil { ··· 7112 7244 } 7113 7245 7114 7246 t.CreatedAt = string(sval) 7247 + } 7248 + // t.ReasonTypes ([]*string) (slice) 7249 + case "reasonTypes": 7250 + 7251 + maj, extra, err = cr.ReadHeader() 7252 + if err != nil { 7253 + return err 7254 + } 7255 + 7256 + if extra > 8192 { 7257 + return fmt.Errorf("t.ReasonTypes: array too large (%d)", extra) 7258 + } 7259 + 7260 + if maj != cbg.MajArray { 7261 + return fmt.Errorf("expected cbor array") 7262 + } 7263 + 7264 + if extra > 0 { 7265 + t.ReasonTypes = make([]*string, extra) 7266 + } 7267 + 7268 + for i := 0; i < int(extra); i++ { 7269 + { 7270 + var maj byte 7271 + var extra uint64 7272 + var err error 7273 + _ = maj 7274 + _ = extra 7275 + _ = err 7276 + 7277 + { 7278 + b, err := cr.ReadByte() 7279 + if err != nil { 7280 + return err 7281 + } 7282 + if b != cbg.CborNull[0] { 7283 + if err := cr.UnreadByte(); err != nil { 7284 + return err 7285 + } 7286 + 7287 + sval, err := cbg.ReadStringWithMax(cr, 1000000) 7288 + if err != nil { 7289 + return err 7290 + } 7291 + 7292 + t.ReasonTypes[i] = (*string)(&sval) 7293 + } 7294 + } 7295 + 7296 + } 7297 + } 7298 + // t.SubjectTypes ([]*string) (slice) 7299 + case "subjectTypes": 7300 + 7301 + maj, extra, err = cr.ReadHeader() 7302 + if err != nil { 7303 + return err 7304 + } 7305 + 7306 + if extra > 8192 { 7307 + return fmt.Errorf("t.SubjectTypes: array too large (%d)", extra) 7308 + } 7309 + 7310 + if maj != cbg.MajArray { 7311 + return fmt.Errorf("expected cbor array") 7312 + } 7313 + 7314 + if extra > 0 { 7315 + t.SubjectTypes = make([]*string, extra) 7316 + } 7317 + 7318 + for i := 0; i < int(extra); i++ { 7319 + { 7320 + var maj byte 7321 + var extra uint64 7322 + var err error 7323 + _ = maj 7324 + _ = extra 7325 + _ = err 7326 + 7327 + { 7328 + b, err := cr.ReadByte() 7329 + if err != nil { 7330 + return err 7331 + } 7332 + if b != cbg.CborNull[0] { 7333 + if err := cr.UnreadByte(); err != nil { 7334 + return err 7335 + } 7336 + 7337 + sval, err := cbg.ReadStringWithMax(cr, 1000000) 7338 + if err != nil { 7339 + return err 7340 + } 7341 + 7342 + t.SubjectTypes[i] = (*string)(&sval) 7343 + } 7344 + } 7345 + 7346 + } 7347 + } 7348 + // t.SubjectCollections ([]string) (slice) 7349 + case "subjectCollections": 7350 + 7351 + maj, extra, err = cr.ReadHeader() 7352 + if err != nil { 7353 + return err 7354 + } 7355 + 7356 + if extra > 8192 { 7357 + return fmt.Errorf("t.SubjectCollections: array too large (%d)", extra) 7358 + } 7359 + 7360 + if maj != cbg.MajArray { 7361 + return fmt.Errorf("expected cbor array") 7362 + } 7363 + 7364 + if extra > 0 { 7365 + t.SubjectCollections = make([]string, extra) 7366 + } 7367 + 7368 + for i := 0; i < int(extra); i++ { 7369 + { 7370 + var maj byte 7371 + var extra uint64 7372 + var err error 7373 + _ = maj 7374 + _ = extra 7375 + _ = err 7376 + 7377 + { 7378 + sval, err := cbg.ReadStringWithMax(cr, 1000000) 7379 + if err != nil { 7380 + return err 7381 + } 7382 + 7383 + t.SubjectCollections[i] = string(sval) 7384 + } 7385 + 7386 + } 7115 7387 } 7116 7388 7117 7389 default:
+2 -1
api/bsky/embedvideo.go
··· 18 18 Alt *string `json:"alt,omitempty" cborgen:"alt,omitempty"` 19 19 AspectRatio *EmbedDefs_AspectRatio `json:"aspectRatio,omitempty" cborgen:"aspectRatio,omitempty"` 20 20 Captions []*EmbedVideo_Caption `json:"captions,omitempty" cborgen:"captions,omitempty"` 21 - Video *util.LexBlob `json:"video" cborgen:"video"` 21 + // video: The mp4 video file. May be up to 100mb, formerly limited to 50mb. 22 + Video *util.LexBlob `json:"video" cborgen:"video"` 22 23 } 23 24 24 25 // EmbedVideo_Caption is a "caption" in the app.bsky.embed.video schema.
+8 -2
api/bsky/labelerdefs.go
··· 41 41 Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 42 42 LikeCount *int64 `json:"likeCount,omitempty" cborgen:"likeCount,omitempty"` 43 43 Policies *LabelerDefs_LabelerPolicies `json:"policies" cborgen:"policies"` 44 - Uri string `json:"uri" cborgen:"uri"` 45 - Viewer *LabelerDefs_LabelerViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"` 44 + // reasonTypes: The set of report reason 'codes' which are in-scope for this service to review and action. These usually align to policy categories. If not defined (distinct from empty array), all reason types are allowed. 45 + ReasonTypes []*string `json:"reasonTypes,omitempty" cborgen:"reasonTypes,omitempty"` 46 + // subjectCollections: Set of record types (collection NSIDs) which can be reported to this service. If not defined (distinct from empty array), default is any record type. 47 + SubjectCollections []string `json:"subjectCollections,omitempty" cborgen:"subjectCollections,omitempty"` 48 + // subjectTypes: The set of subject types (account, record, etc) this service accepts reports on. 49 + SubjectTypes []*string `json:"subjectTypes,omitempty" cborgen:"subjectTypes,omitempty"` 50 + Uri string `json:"uri" cborgen:"uri"` 51 + Viewer *LabelerDefs_LabelerViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"` 46 52 } 47 53 48 54 // LabelerDefs_LabelerViewerState is a "labelerViewerState" in the app.bsky.labeler.defs schema.
+6
api/bsky/labelerservice.go
··· 24 24 CreatedAt string `json:"createdAt" cborgen:"createdAt"` 25 25 Labels *LabelerService_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"` 26 26 Policies *LabelerDefs_LabelerPolicies `json:"policies" cborgen:"policies"` 27 + // reasonTypes: The set of report reason 'codes' which are in-scope for this service to review and action. These usually align to policy categories. If not defined (distinct from empty array), all reason types are allowed. 28 + ReasonTypes []*string `json:"reasonTypes,omitempty" cborgen:"reasonTypes,omitempty"` 29 + // subjectCollections: Set of record types (collection NSIDs) which can be reported to this service. If not defined (distinct from empty array), default is any record type. 30 + SubjectCollections []string `json:"subjectCollections,omitempty" cborgen:"subjectCollections,omitempty"` 31 + // subjectTypes: The set of subject types (account, record, etc) this service accepts reports on. 32 + SubjectTypes []*string `json:"subjectTypes,omitempty" cborgen:"subjectTypes,omitempty"` 27 33 } 28 34 29 35 type LabelerService_Labels struct {
+24
api/bsky/unspecceddefs.go
··· 19 19 Uri string `json:"uri" cborgen:"uri"` 20 20 } 21 21 22 + // UnspeccedDefs_SkeletonTrend is a "skeletonTrend" in the app.bsky.unspecced.defs schema. 23 + type UnspeccedDefs_SkeletonTrend struct { 24 + Category *string `json:"category,omitempty" cborgen:"category,omitempty"` 25 + Dids []string `json:"dids" cborgen:"dids"` 26 + DisplayName string `json:"displayName" cborgen:"displayName"` 27 + Link string `json:"link" cborgen:"link"` 28 + PostCount int64 `json:"postCount" cborgen:"postCount"` 29 + StartedAt string `json:"startedAt" cborgen:"startedAt"` 30 + Status *string `json:"status,omitempty" cborgen:"status,omitempty"` 31 + Topic string `json:"topic" cborgen:"topic"` 32 + } 33 + 34 + // UnspeccedDefs_TrendView is a "trendView" in the app.bsky.unspecced.defs schema. 35 + type UnspeccedDefs_TrendView struct { 36 + Actors []*ActorDefs_ProfileViewBasic `json:"actors" cborgen:"actors"` 37 + Category *string `json:"category,omitempty" cborgen:"category,omitempty"` 38 + DisplayName string `json:"displayName" cborgen:"displayName"` 39 + Link string `json:"link" cborgen:"link"` 40 + PostCount int64 `json:"postCount" cborgen:"postCount"` 41 + StartedAt string `json:"startedAt" cborgen:"startedAt"` 42 + Status *string `json:"status,omitempty" cborgen:"status,omitempty"` 43 + Topic string `json:"topic" cborgen:"topic"` 44 + } 45 + 22 46 // UnspeccedDefs_TrendingTopic is a "trendingTopic" in the app.bsky.unspecced.defs schema. 23 47 type UnspeccedDefs_TrendingTopic struct { 24 48 Description *string `json:"description,omitempty" cborgen:"description,omitempty"`
+30
api/bsky/unspeccedgetSuggestedFeeds.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getSuggestedFeeds 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetSuggestedFeeds_Output is the output of a app.bsky.unspecced.getSuggestedFeeds call. 14 + type UnspeccedGetSuggestedFeeds_Output struct { 15 + Feeds []*FeedDefs_GeneratorView `json:"feeds" cborgen:"feeds"` 16 + } 17 + 18 + // UnspeccedGetSuggestedFeeds calls the XRPC method "app.bsky.unspecced.getSuggestedFeeds". 19 + func UnspeccedGetSuggestedFeeds(ctx context.Context, c *xrpc.Client, limit int64) (*UnspeccedGetSuggestedFeeds_Output, error) { 20 + var out UnspeccedGetSuggestedFeeds_Output 21 + 22 + params := map[string]interface{}{ 23 + "limit": limit, 24 + } 25 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getSuggestedFeeds", params, nil, &out); err != nil { 26 + return nil, err 27 + } 28 + 29 + return &out, nil 30 + }
+33
api/bsky/unspeccedgetSuggestedFeedsSkeleton.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getSuggestedFeedsSkeleton 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetSuggestedFeedsSkeleton_Output is the output of a app.bsky.unspecced.getSuggestedFeedsSkeleton call. 14 + type UnspeccedGetSuggestedFeedsSkeleton_Output struct { 15 + Feeds []string `json:"feeds" cborgen:"feeds"` 16 + } 17 + 18 + // UnspeccedGetSuggestedFeedsSkeleton calls the XRPC method "app.bsky.unspecced.getSuggestedFeedsSkeleton". 19 + // 20 + // viewer: DID of the account making the request (not included for public/unauthenticated queries). 21 + func UnspeccedGetSuggestedFeedsSkeleton(ctx context.Context, c *xrpc.Client, limit int64, viewer string) (*UnspeccedGetSuggestedFeedsSkeleton_Output, error) { 22 + var out UnspeccedGetSuggestedFeedsSkeleton_Output 23 + 24 + params := map[string]interface{}{ 25 + "limit": limit, 26 + "viewer": viewer, 27 + } 28 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getSuggestedFeedsSkeleton", params, nil, &out); err != nil { 29 + return nil, err 30 + } 31 + 32 + return &out, nil 33 + }
+30
api/bsky/unspeccedgetSuggestedStarterPacks.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getSuggestedStarterPacks 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetSuggestedStarterPacks_Output is the output of a app.bsky.unspecced.getSuggestedStarterPacks call. 14 + type UnspeccedGetSuggestedStarterPacks_Output struct { 15 + StarterPacks []*GraphDefs_StarterPackView `json:"starterPacks" cborgen:"starterPacks"` 16 + } 17 + 18 + // UnspeccedGetSuggestedStarterPacks calls the XRPC method "app.bsky.unspecced.getSuggestedStarterPacks". 19 + func UnspeccedGetSuggestedStarterPacks(ctx context.Context, c *xrpc.Client, limit int64) (*UnspeccedGetSuggestedStarterPacks_Output, error) { 20 + var out UnspeccedGetSuggestedStarterPacks_Output 21 + 22 + params := map[string]interface{}{ 23 + "limit": limit, 24 + } 25 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getSuggestedStarterPacks", params, nil, &out); err != nil { 26 + return nil, err 27 + } 28 + 29 + return &out, nil 30 + }
+33
api/bsky/unspeccedgetSuggestedStarterPacksSkeleton.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getSuggestedStarterPacksSkeleton 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetSuggestedStarterPacksSkeleton_Output is the output of a app.bsky.unspecced.getSuggestedStarterPacksSkeleton call. 14 + type UnspeccedGetSuggestedStarterPacksSkeleton_Output struct { 15 + StarterPacks []string `json:"starterPacks" cborgen:"starterPacks"` 16 + } 17 + 18 + // UnspeccedGetSuggestedStarterPacksSkeleton calls the XRPC method "app.bsky.unspecced.getSuggestedStarterPacksSkeleton". 19 + // 20 + // viewer: DID of the account making the request (not included for public/unauthenticated queries). 21 + func UnspeccedGetSuggestedStarterPacksSkeleton(ctx context.Context, c *xrpc.Client, limit int64, viewer string) (*UnspeccedGetSuggestedStarterPacksSkeleton_Output, error) { 22 + var out UnspeccedGetSuggestedStarterPacksSkeleton_Output 23 + 24 + params := map[string]interface{}{ 25 + "limit": limit, 26 + "viewer": viewer, 27 + } 28 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getSuggestedStarterPacksSkeleton", params, nil, &out); err != nil { 29 + return nil, err 30 + } 31 + 32 + return &out, nil 33 + }
+33
api/bsky/unspeccedgetSuggestedUsers.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getSuggestedUsers 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetSuggestedUsers_Output is the output of a app.bsky.unspecced.getSuggestedUsers call. 14 + type UnspeccedGetSuggestedUsers_Output struct { 15 + Actors []*ActorDefs_ProfileViewBasic `json:"actors" cborgen:"actors"` 16 + } 17 + 18 + // UnspeccedGetSuggestedUsers calls the XRPC method "app.bsky.unspecced.getSuggestedUsers". 19 + // 20 + // category: Category of users to get suggestions for. 21 + func UnspeccedGetSuggestedUsers(ctx context.Context, c *xrpc.Client, category string, limit int64) (*UnspeccedGetSuggestedUsers_Output, error) { 22 + var out UnspeccedGetSuggestedUsers_Output 23 + 24 + params := map[string]interface{}{ 25 + "category": category, 26 + "limit": limit, 27 + } 28 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getSuggestedUsers", params, nil, &out); err != nil { 29 + return nil, err 30 + } 31 + 32 + return &out, nil 33 + }
+35
api/bsky/unspeccedgetSuggestedUsersSkeleton.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getSuggestedUsersSkeleton 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetSuggestedUsersSkeleton_Output is the output of a app.bsky.unspecced.getSuggestedUsersSkeleton call. 14 + type UnspeccedGetSuggestedUsersSkeleton_Output struct { 15 + Dids []string `json:"dids" cborgen:"dids"` 16 + } 17 + 18 + // UnspeccedGetSuggestedUsersSkeleton calls the XRPC method "app.bsky.unspecced.getSuggestedUsersSkeleton". 19 + // 20 + // category: Category of users to get suggestions for. 21 + // viewer: DID of the account making the request (not included for public/unauthenticated queries). 22 + func UnspeccedGetSuggestedUsersSkeleton(ctx context.Context, c *xrpc.Client, category string, limit int64, viewer string) (*UnspeccedGetSuggestedUsersSkeleton_Output, error) { 23 + var out UnspeccedGetSuggestedUsersSkeleton_Output 24 + 25 + params := map[string]interface{}{ 26 + "category": category, 27 + "limit": limit, 28 + "viewer": viewer, 29 + } 30 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getSuggestedUsersSkeleton", params, nil, &out); err != nil { 31 + return nil, err 32 + } 33 + 34 + return &out, nil 35 + }
+30
api/bsky/unspeccedgetTrends.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getTrends 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetTrends_Output is the output of a app.bsky.unspecced.getTrends call. 14 + type UnspeccedGetTrends_Output struct { 15 + Trends []*UnspeccedDefs_TrendView `json:"trends" cborgen:"trends"` 16 + } 17 + 18 + // UnspeccedGetTrends calls the XRPC method "app.bsky.unspecced.getTrends". 19 + func UnspeccedGetTrends(ctx context.Context, c *xrpc.Client, limit int64) (*UnspeccedGetTrends_Output, error) { 20 + var out UnspeccedGetTrends_Output 21 + 22 + params := map[string]interface{}{ 23 + "limit": limit, 24 + } 25 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getTrends", params, nil, &out); err != nil { 26 + return nil, err 27 + } 28 + 29 + return &out, nil 30 + }
+33
api/bsky/unspeccedgetTrendsSkeleton.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package bsky 4 + 5 + // schema: app.bsky.unspecced.getTrendsSkeleton 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // UnspeccedGetTrendsSkeleton_Output is the output of a app.bsky.unspecced.getTrendsSkeleton call. 14 + type UnspeccedGetTrendsSkeleton_Output struct { 15 + Trends []*UnspeccedDefs_SkeletonTrend `json:"trends" cborgen:"trends"` 16 + } 17 + 18 + // UnspeccedGetTrendsSkeleton calls the XRPC method "app.bsky.unspecced.getTrendsSkeleton". 19 + // 20 + // viewer: DID of the account making the request (not included for public/unauthenticated queries). 21 + func UnspeccedGetTrendsSkeleton(ctx context.Context, c *xrpc.Client, limit int64, viewer string) (*UnspeccedGetTrendsSkeleton_Output, error) { 22 + var out UnspeccedGetTrendsSkeleton_Output 23 + 24 + params := map[string]interface{}{ 25 + "limit": limit, 26 + "viewer": viewer, 27 + } 28 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.unspecced.getTrendsSkeleton", params, nil, &out); err != nil { 29 + return nil, err 30 + } 31 + 32 + return &out, nil 33 + }
+33
api/chat/convoaddReaction.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package chat 4 + 5 + // schema: chat.bsky.convo.addReaction 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // ConvoAddReaction_Input is the input argument to a chat.bsky.convo.addReaction call. 14 + type ConvoAddReaction_Input struct { 15 + ConvoId string `json:"convoId" cborgen:"convoId"` 16 + MessageId string `json:"messageId" cborgen:"messageId"` 17 + Value string `json:"value" cborgen:"value"` 18 + } 19 + 20 + // ConvoAddReaction_Output is the output of a chat.bsky.convo.addReaction call. 21 + type ConvoAddReaction_Output struct { 22 + Message *ConvoDefs_MessageView `json:"message" cborgen:"message"` 23 + } 24 + 25 + // ConvoAddReaction calls the XRPC method "chat.bsky.convo.addReaction". 26 + func ConvoAddReaction(ctx context.Context, c *xrpc.Client, input *ConvoAddReaction_Input) (*ConvoAddReaction_Output, error) { 27 + var out ConvoAddReaction_Output 28 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "chat.bsky.convo.addReaction", nil, input, &out); err != nil { 29 + return nil, err 30 + } 31 + 32 + return &out, nil 33 + }
+170 -18
api/chat/convodefs.go
··· 14 14 15 15 // ConvoDefs_ConvoView is a "convoView" in the chat.bsky.convo.defs schema. 16 16 type ConvoDefs_ConvoView struct { 17 - Id string `json:"id" cborgen:"id"` 18 - LastMessage *ConvoDefs_ConvoView_LastMessage `json:"lastMessage,omitempty" cborgen:"lastMessage,omitempty"` 19 - Members []*ActorDefs_ProfileViewBasic `json:"members" cborgen:"members"` 20 - Muted bool `json:"muted" cborgen:"muted"` 21 - Rev string `json:"rev" cborgen:"rev"` 22 - Status *string `json:"status,omitempty" cborgen:"status,omitempty"` 23 - UnreadCount int64 `json:"unreadCount" cborgen:"unreadCount"` 17 + Id string `json:"id" cborgen:"id"` 18 + LastMessage *ConvoDefs_ConvoView_LastMessage `json:"lastMessage,omitempty" cborgen:"lastMessage,omitempty"` 19 + LastReaction *ConvoDefs_ConvoView_LastReaction `json:"lastReaction,omitempty" cborgen:"lastReaction,omitempty"` 20 + Members []*ActorDefs_ProfileViewBasic `json:"members" cborgen:"members"` 21 + Muted bool `json:"muted" cborgen:"muted"` 22 + Rev string `json:"rev" cborgen:"rev"` 23 + Status *string `json:"status,omitempty" cborgen:"status,omitempty"` 24 + UnreadCount int64 `json:"unreadCount" cborgen:"unreadCount"` 24 25 } 25 26 26 27 type ConvoDefs_ConvoView_LastMessage struct { ··· 58 59 } 59 60 } 60 61 62 + type ConvoDefs_ConvoView_LastReaction struct { 63 + ConvoDefs_MessageAndReactionView *ConvoDefs_MessageAndReactionView 64 + } 65 + 66 + func (t *ConvoDefs_ConvoView_LastReaction) MarshalJSON() ([]byte, error) { 67 + if t.ConvoDefs_MessageAndReactionView != nil { 68 + t.ConvoDefs_MessageAndReactionView.LexiconTypeID = "chat.bsky.convo.defs#messageAndReactionView" 69 + return json.Marshal(t.ConvoDefs_MessageAndReactionView) 70 + } 71 + return nil, fmt.Errorf("cannot marshal empty enum") 72 + } 73 + func (t *ConvoDefs_ConvoView_LastReaction) UnmarshalJSON(b []byte) error { 74 + typ, err := util.TypeExtract(b) 75 + if err != nil { 76 + return err 77 + } 78 + 79 + switch typ { 80 + case "chat.bsky.convo.defs#messageAndReactionView": 81 + t.ConvoDefs_MessageAndReactionView = new(ConvoDefs_MessageAndReactionView) 82 + return json.Unmarshal(b, t.ConvoDefs_MessageAndReactionView) 83 + 84 + default: 85 + return nil 86 + } 87 + } 88 + 61 89 // ConvoDefs_DeletedMessageView is a "deletedMessageView" in the chat.bsky.convo.defs schema. 62 90 // 63 91 // RECORDTYPE: ConvoDefs_DeletedMessageView ··· 78 106 Rev string `json:"rev" cborgen:"rev"` 79 107 } 80 108 109 + // ConvoDefs_LogAddReaction is a "logAddReaction" in the chat.bsky.convo.defs schema. 110 + // 111 + // RECORDTYPE: ConvoDefs_LogAddReaction 112 + type ConvoDefs_LogAddReaction struct { 113 + LexiconTypeID string `json:"$type,const=chat.bsky.convo.defs#logAddReaction" cborgen:"$type,const=chat.bsky.convo.defs#logAddReaction"` 114 + ConvoId string `json:"convoId" cborgen:"convoId"` 115 + Message *ConvoDefs_LogAddReaction_Message `json:"message" cborgen:"message"` 116 + Reaction *ConvoDefs_ReactionView `json:"reaction" cborgen:"reaction"` 117 + Rev string `json:"rev" cborgen:"rev"` 118 + } 119 + 120 + type ConvoDefs_LogAddReaction_Message struct { 121 + ConvoDefs_MessageView *ConvoDefs_MessageView 122 + ConvoDefs_DeletedMessageView *ConvoDefs_DeletedMessageView 123 + } 124 + 125 + func (t *ConvoDefs_LogAddReaction_Message) MarshalJSON() ([]byte, error) { 126 + if t.ConvoDefs_MessageView != nil { 127 + t.ConvoDefs_MessageView.LexiconTypeID = "chat.bsky.convo.defs#messageView" 128 + return json.Marshal(t.ConvoDefs_MessageView) 129 + } 130 + if t.ConvoDefs_DeletedMessageView != nil { 131 + t.ConvoDefs_DeletedMessageView.LexiconTypeID = "chat.bsky.convo.defs#deletedMessageView" 132 + return json.Marshal(t.ConvoDefs_DeletedMessageView) 133 + } 134 + return nil, fmt.Errorf("cannot marshal empty enum") 135 + } 136 + func (t *ConvoDefs_LogAddReaction_Message) UnmarshalJSON(b []byte) error { 137 + typ, err := util.TypeExtract(b) 138 + if err != nil { 139 + return err 140 + } 141 + 142 + switch typ { 143 + case "chat.bsky.convo.defs#messageView": 144 + t.ConvoDefs_MessageView = new(ConvoDefs_MessageView) 145 + return json.Unmarshal(b, t.ConvoDefs_MessageView) 146 + case "chat.bsky.convo.defs#deletedMessageView": 147 + t.ConvoDefs_DeletedMessageView = new(ConvoDefs_DeletedMessageView) 148 + return json.Unmarshal(b, t.ConvoDefs_DeletedMessageView) 149 + 150 + default: 151 + return nil 152 + } 153 + } 154 + 81 155 // ConvoDefs_LogBeginConvo is a "logBeginConvo" in the chat.bsky.convo.defs schema. 82 156 // 83 157 // RECORDTYPE: ConvoDefs_LogBeginConvo ··· 187 261 } 188 262 189 263 // ConvoDefs_LogMuteConvo is a "logMuteConvo" in the chat.bsky.convo.defs schema. 264 + // 265 + // RECORDTYPE: ConvoDefs_LogMuteConvo 190 266 type ConvoDefs_LogMuteConvo struct { 191 - ConvoId string `json:"convoId" cborgen:"convoId"` 192 - Rev string `json:"rev" cborgen:"rev"` 267 + LexiconTypeID string `json:"$type,const=chat.bsky.convo.defs#logMuteConvo" cborgen:"$type,const=chat.bsky.convo.defs#logMuteConvo"` 268 + ConvoId string `json:"convoId" cborgen:"convoId"` 269 + Rev string `json:"rev" cborgen:"rev"` 193 270 } 194 271 195 272 // ConvoDefs_LogReadMessage is a "logReadMessage" in the chat.bsky.convo.defs schema. 273 + // 274 + // RECORDTYPE: ConvoDefs_LogReadMessage 196 275 type ConvoDefs_LogReadMessage struct { 197 - ConvoId string `json:"convoId" cborgen:"convoId"` 198 - Message *ConvoDefs_LogReadMessage_Message `json:"message" cborgen:"message"` 199 - Rev string `json:"rev" cborgen:"rev"` 276 + LexiconTypeID string `json:"$type,const=chat.bsky.convo.defs#logReadMessage" cborgen:"$type,const=chat.bsky.convo.defs#logReadMessage"` 277 + ConvoId string `json:"convoId" cborgen:"convoId"` 278 + Message *ConvoDefs_LogReadMessage_Message `json:"message" cborgen:"message"` 279 + Rev string `json:"rev" cborgen:"rev"` 200 280 } 201 281 202 282 type ConvoDefs_LogReadMessage_Message struct { ··· 234 314 } 235 315 } 236 316 317 + // ConvoDefs_LogRemoveReaction is a "logRemoveReaction" in the chat.bsky.convo.defs schema. 318 + // 319 + // RECORDTYPE: ConvoDefs_LogRemoveReaction 320 + type ConvoDefs_LogRemoveReaction struct { 321 + LexiconTypeID string `json:"$type,const=chat.bsky.convo.defs#logRemoveReaction" cborgen:"$type,const=chat.bsky.convo.defs#logRemoveReaction"` 322 + ConvoId string `json:"convoId" cborgen:"convoId"` 323 + Message *ConvoDefs_LogRemoveReaction_Message `json:"message" cborgen:"message"` 324 + Reaction *ConvoDefs_ReactionView `json:"reaction" cborgen:"reaction"` 325 + Rev string `json:"rev" cborgen:"rev"` 326 + } 327 + 328 + type ConvoDefs_LogRemoveReaction_Message struct { 329 + ConvoDefs_MessageView *ConvoDefs_MessageView 330 + ConvoDefs_DeletedMessageView *ConvoDefs_DeletedMessageView 331 + } 332 + 333 + func (t *ConvoDefs_LogRemoveReaction_Message) MarshalJSON() ([]byte, error) { 334 + if t.ConvoDefs_MessageView != nil { 335 + t.ConvoDefs_MessageView.LexiconTypeID = "chat.bsky.convo.defs#messageView" 336 + return json.Marshal(t.ConvoDefs_MessageView) 337 + } 338 + if t.ConvoDefs_DeletedMessageView != nil { 339 + t.ConvoDefs_DeletedMessageView.LexiconTypeID = "chat.bsky.convo.defs#deletedMessageView" 340 + return json.Marshal(t.ConvoDefs_DeletedMessageView) 341 + } 342 + return nil, fmt.Errorf("cannot marshal empty enum") 343 + } 344 + func (t *ConvoDefs_LogRemoveReaction_Message) UnmarshalJSON(b []byte) error { 345 + typ, err := util.TypeExtract(b) 346 + if err != nil { 347 + return err 348 + } 349 + 350 + switch typ { 351 + case "chat.bsky.convo.defs#messageView": 352 + t.ConvoDefs_MessageView = new(ConvoDefs_MessageView) 353 + return json.Unmarshal(b, t.ConvoDefs_MessageView) 354 + case "chat.bsky.convo.defs#deletedMessageView": 355 + t.ConvoDefs_DeletedMessageView = new(ConvoDefs_DeletedMessageView) 356 + return json.Unmarshal(b, t.ConvoDefs_DeletedMessageView) 357 + 358 + default: 359 + return nil 360 + } 361 + } 362 + 237 363 // ConvoDefs_LogUnmuteConvo is a "logUnmuteConvo" in the chat.bsky.convo.defs schema. 364 + // 365 + // RECORDTYPE: ConvoDefs_LogUnmuteConvo 238 366 type ConvoDefs_LogUnmuteConvo struct { 239 - ConvoId string `json:"convoId" cborgen:"convoId"` 240 - Rev string `json:"rev" cborgen:"rev"` 367 + LexiconTypeID string `json:"$type,const=chat.bsky.convo.defs#logUnmuteConvo" cborgen:"$type,const=chat.bsky.convo.defs#logUnmuteConvo"` 368 + ConvoId string `json:"convoId" cborgen:"convoId"` 369 + Rev string `json:"rev" cborgen:"rev"` 370 + } 371 + 372 + // ConvoDefs_MessageAndReactionView is a "messageAndReactionView" in the chat.bsky.convo.defs schema. 373 + // 374 + // RECORDTYPE: ConvoDefs_MessageAndReactionView 375 + type ConvoDefs_MessageAndReactionView struct { 376 + LexiconTypeID string `json:"$type,const=chat.bsky.convo.defs#messageAndReactionView" cborgen:"$type,const=chat.bsky.convo.defs#messageAndReactionView"` 377 + Message *ConvoDefs_MessageView `json:"message" cborgen:"message"` 378 + Reaction *ConvoDefs_ReactionView `json:"reaction" cborgen:"reaction"` 241 379 } 242 380 243 381 // ConvoDefs_MessageInput is the input argument to a chat.bsky.convo.defs call. ··· 294 432 // facets: Annotations of text (mentions, URLs, hashtags, etc) 295 433 Facets []*appbskytypes.RichtextFacet `json:"facets,omitempty" cborgen:"facets,omitempty"` 296 434 Id string `json:"id" cborgen:"id"` 297 - Rev string `json:"rev" cborgen:"rev"` 298 - Sender *ConvoDefs_MessageViewSender `json:"sender" cborgen:"sender"` 299 - SentAt string `json:"sentAt" cborgen:"sentAt"` 300 - Text string `json:"text" cborgen:"text"` 435 + // reactions: Reactions to this message, in ascending order of creation time. 436 + Reactions []*ConvoDefs_ReactionView `json:"reactions,omitempty" cborgen:"reactions,omitempty"` 437 + Rev string `json:"rev" cborgen:"rev"` 438 + Sender *ConvoDefs_MessageViewSender `json:"sender" cborgen:"sender"` 439 + SentAt string `json:"sentAt" cborgen:"sentAt"` 440 + Text string `json:"text" cborgen:"text"` 301 441 } 302 442 303 443 // ConvoDefs_MessageViewSender is a "messageViewSender" in the chat.bsky.convo.defs schema. ··· 331 471 return nil 332 472 } 333 473 } 474 + 475 + // ConvoDefs_ReactionView is a "reactionView" in the chat.bsky.convo.defs schema. 476 + type ConvoDefs_ReactionView struct { 477 + CreatedAt string `json:"createdAt" cborgen:"createdAt"` 478 + Sender *ConvoDefs_ReactionViewSender `json:"sender" cborgen:"sender"` 479 + Value string `json:"value" cborgen:"value"` 480 + } 481 + 482 + // ConvoDefs_ReactionViewSender is a "reactionViewSender" in the chat.bsky.convo.defs schema. 483 + type ConvoDefs_ReactionViewSender struct { 484 + Did string `json:"did" cborgen:"did"` 485 + }
+45 -5
api/chat/convogetLog.go
··· 20 20 } 21 21 22 22 type ConvoGetLog_Output_Logs_Elem struct { 23 - ConvoDefs_LogBeginConvo *ConvoDefs_LogBeginConvo 24 - ConvoDefs_LogAcceptConvo *ConvoDefs_LogAcceptConvo 25 - ConvoDefs_LogLeaveConvo *ConvoDefs_LogLeaveConvo 26 - ConvoDefs_LogCreateMessage *ConvoDefs_LogCreateMessage 27 - ConvoDefs_LogDeleteMessage *ConvoDefs_LogDeleteMessage 23 + ConvoDefs_LogBeginConvo *ConvoDefs_LogBeginConvo 24 + ConvoDefs_LogAcceptConvo *ConvoDefs_LogAcceptConvo 25 + ConvoDefs_LogLeaveConvo *ConvoDefs_LogLeaveConvo 26 + ConvoDefs_LogMuteConvo *ConvoDefs_LogMuteConvo 27 + ConvoDefs_LogUnmuteConvo *ConvoDefs_LogUnmuteConvo 28 + ConvoDefs_LogCreateMessage *ConvoDefs_LogCreateMessage 29 + ConvoDefs_LogDeleteMessage *ConvoDefs_LogDeleteMessage 30 + ConvoDefs_LogReadMessage *ConvoDefs_LogReadMessage 31 + ConvoDefs_LogAddReaction *ConvoDefs_LogAddReaction 32 + ConvoDefs_LogRemoveReaction *ConvoDefs_LogRemoveReaction 28 33 } 29 34 30 35 func (t *ConvoGetLog_Output_Logs_Elem) MarshalJSON() ([]byte, error) { ··· 40 45 t.ConvoDefs_LogLeaveConvo.LexiconTypeID = "chat.bsky.convo.defs#logLeaveConvo" 41 46 return json.Marshal(t.ConvoDefs_LogLeaveConvo) 42 47 } 48 + if t.ConvoDefs_LogMuteConvo != nil { 49 + t.ConvoDefs_LogMuteConvo.LexiconTypeID = "chat.bsky.convo.defs#logMuteConvo" 50 + return json.Marshal(t.ConvoDefs_LogMuteConvo) 51 + } 52 + if t.ConvoDefs_LogUnmuteConvo != nil { 53 + t.ConvoDefs_LogUnmuteConvo.LexiconTypeID = "chat.bsky.convo.defs#logUnmuteConvo" 54 + return json.Marshal(t.ConvoDefs_LogUnmuteConvo) 55 + } 43 56 if t.ConvoDefs_LogCreateMessage != nil { 44 57 t.ConvoDefs_LogCreateMessage.LexiconTypeID = "chat.bsky.convo.defs#logCreateMessage" 45 58 return json.Marshal(t.ConvoDefs_LogCreateMessage) ··· 48 61 t.ConvoDefs_LogDeleteMessage.LexiconTypeID = "chat.bsky.convo.defs#logDeleteMessage" 49 62 return json.Marshal(t.ConvoDefs_LogDeleteMessage) 50 63 } 64 + if t.ConvoDefs_LogReadMessage != nil { 65 + t.ConvoDefs_LogReadMessage.LexiconTypeID = "chat.bsky.convo.defs#logReadMessage" 66 + return json.Marshal(t.ConvoDefs_LogReadMessage) 67 + } 68 + if t.ConvoDefs_LogAddReaction != nil { 69 + t.ConvoDefs_LogAddReaction.LexiconTypeID = "chat.bsky.convo.defs#logAddReaction" 70 + return json.Marshal(t.ConvoDefs_LogAddReaction) 71 + } 72 + if t.ConvoDefs_LogRemoveReaction != nil { 73 + t.ConvoDefs_LogRemoveReaction.LexiconTypeID = "chat.bsky.convo.defs#logRemoveReaction" 74 + return json.Marshal(t.ConvoDefs_LogRemoveReaction) 75 + } 51 76 return nil, fmt.Errorf("cannot marshal empty enum") 52 77 } 53 78 func (t *ConvoGetLog_Output_Logs_Elem) UnmarshalJSON(b []byte) error { ··· 66 91 case "chat.bsky.convo.defs#logLeaveConvo": 67 92 t.ConvoDefs_LogLeaveConvo = new(ConvoDefs_LogLeaveConvo) 68 93 return json.Unmarshal(b, t.ConvoDefs_LogLeaveConvo) 94 + case "chat.bsky.convo.defs#logMuteConvo": 95 + t.ConvoDefs_LogMuteConvo = new(ConvoDefs_LogMuteConvo) 96 + return json.Unmarshal(b, t.ConvoDefs_LogMuteConvo) 97 + case "chat.bsky.convo.defs#logUnmuteConvo": 98 + t.ConvoDefs_LogUnmuteConvo = new(ConvoDefs_LogUnmuteConvo) 99 + return json.Unmarshal(b, t.ConvoDefs_LogUnmuteConvo) 69 100 case "chat.bsky.convo.defs#logCreateMessage": 70 101 t.ConvoDefs_LogCreateMessage = new(ConvoDefs_LogCreateMessage) 71 102 return json.Unmarshal(b, t.ConvoDefs_LogCreateMessage) 72 103 case "chat.bsky.convo.defs#logDeleteMessage": 73 104 t.ConvoDefs_LogDeleteMessage = new(ConvoDefs_LogDeleteMessage) 74 105 return json.Unmarshal(b, t.ConvoDefs_LogDeleteMessage) 106 + case "chat.bsky.convo.defs#logReadMessage": 107 + t.ConvoDefs_LogReadMessage = new(ConvoDefs_LogReadMessage) 108 + return json.Unmarshal(b, t.ConvoDefs_LogReadMessage) 109 + case "chat.bsky.convo.defs#logAddReaction": 110 + t.ConvoDefs_LogAddReaction = new(ConvoDefs_LogAddReaction) 111 + return json.Unmarshal(b, t.ConvoDefs_LogAddReaction) 112 + case "chat.bsky.convo.defs#logRemoveReaction": 113 + t.ConvoDefs_LogRemoveReaction = new(ConvoDefs_LogRemoveReaction) 114 + return json.Unmarshal(b, t.ConvoDefs_LogRemoveReaction) 75 115 76 116 default: 77 117 return nil
+33
api/chat/convoremoveReaction.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package chat 4 + 5 + // schema: chat.bsky.convo.removeReaction 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // ConvoRemoveReaction_Input is the input argument to a chat.bsky.convo.removeReaction call. 14 + type ConvoRemoveReaction_Input struct { 15 + ConvoId string `json:"convoId" cborgen:"convoId"` 16 + MessageId string `json:"messageId" cborgen:"messageId"` 17 + Value string `json:"value" cborgen:"value"` 18 + } 19 + 20 + // ConvoRemoveReaction_Output is the output of a chat.bsky.convo.removeReaction call. 21 + type ConvoRemoveReaction_Output struct { 22 + Message *ConvoDefs_MessageView `json:"message" cborgen:"message"` 23 + } 24 + 25 + // ConvoRemoveReaction calls the XRPC method "chat.bsky.convo.removeReaction". 26 + func ConvoRemoveReaction(ctx context.Context, c *xrpc.Client, input *ConvoRemoveReaction_Input) (*ConvoRemoveReaction_Output, error) { 27 + var out ConvoRemoveReaction_Output 28 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "chat.bsky.convo.removeReaction", nil, input, &out); err != nil { 29 + return nil, err 30 + } 31 + 32 + return &out, nil 33 + }
+32
api/chat/convoupdateAllRead.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package chat 4 + 5 + // schema: chat.bsky.convo.updateAllRead 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // ConvoUpdateAllRead_Input is the input argument to a chat.bsky.convo.updateAllRead call. 14 + type ConvoUpdateAllRead_Input struct { 15 + Status *string `json:"status,omitempty" cborgen:"status,omitempty"` 16 + } 17 + 18 + // ConvoUpdateAllRead_Output is the output of a chat.bsky.convo.updateAllRead call. 19 + type ConvoUpdateAllRead_Output struct { 20 + // updatedCount: The count of updated convos. 21 + UpdatedCount int64 `json:"updatedCount" cborgen:"updatedCount"` 22 + } 23 + 24 + // ConvoUpdateAllRead calls the XRPC method "chat.bsky.convo.updateAllRead". 25 + func ConvoUpdateAllRead(ctx context.Context, c *xrpc.Client, input *ConvoUpdateAllRead_Input) (*ConvoUpdateAllRead_Output, error) { 26 + var out ConvoUpdateAllRead_Output 27 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "chat.bsky.convo.updateAllRead", nil, input, &out); err != nil { 28 + return nil, err 29 + } 30 + 31 + return &out, nil 32 + }
+15 -3
api/ozone/moderationdefs.go
··· 136 136 137 137 // ModerationDefs_ModEventComment is a "modEventComment" in the tools.ozone.moderation.defs schema. 138 138 // 139 - // # Add a comment to a subject 139 + // Add a comment to a subject. An empty comment will clear any previously set sticky comment. 140 140 // 141 141 // RECORDTYPE: ModerationDefs_ModEventComment 142 142 type ModerationDefs_ModEventComment struct { 143 - LexiconTypeID string `json:"$type,const=tools.ozone.moderation.defs#modEventComment" cborgen:"$type,const=tools.ozone.moderation.defs#modEventComment"` 144 - Comment string `json:"comment" cborgen:"comment"` 143 + LexiconTypeID string `json:"$type,const=tools.ozone.moderation.defs#modEventComment" cborgen:"$type,const=tools.ozone.moderation.defs#modEventComment"` 144 + Comment *string `json:"comment,omitempty" cborgen:"comment,omitempty"` 145 145 // sticky: Make the comment persistent on the subject 146 146 Sticky *bool `json:"sticky,omitempty" cborgen:"sticky,omitempty"` 147 147 } ··· 1037 1037 default: 1038 1038 return nil 1039 1039 } 1040 + } 1041 + 1042 + // ModerationDefs_SubjectView is a "subjectView" in the tools.ozone.moderation.defs schema. 1043 + // 1044 + // Detailed view of a subject. For record subjects, the author's repo and profile will be returned. 1045 + type ModerationDefs_SubjectView struct { 1046 + //Profile *ModerationDefs_SubjectView_Profile `json:"profile,omitempty" cborgen:"profile,omitempty"` 1047 + Record *ModerationDefs_RecordViewDetail `json:"record,omitempty" cborgen:"record,omitempty"` 1048 + Repo *ModerationDefs_RepoViewDetail `json:"repo,omitempty" cborgen:"repo,omitempty"` 1049 + Status *ModerationDefs_SubjectStatusView `json:"status,omitempty" cborgen:"status,omitempty"` 1050 + Subject string `json:"subject" cborgen:"subject"` 1051 + Type *string `json:"type" cborgen:"type"` 1040 1052 } 1041 1053 1042 1054 // ModerationDefs_VideoDetails is a "videoDetails" in the tools.ozone.moderation.defs schema.
+30
api/ozone/moderationgetSubjects.go
··· 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 + 3 + package ozone 4 + 5 + // schema: tools.ozone.moderation.getSubjects 6 + 7 + import ( 8 + "context" 9 + 10 + "github.com/bluesky-social/indigo/xrpc" 11 + ) 12 + 13 + // ModerationGetSubjects_Output is the output of a tools.ozone.moderation.getSubjects call. 14 + type ModerationGetSubjects_Output struct { 15 + Subjects []*ModerationDefs_SubjectView `json:"subjects" cborgen:"subjects"` 16 + } 17 + 18 + // ModerationGetSubjects calls the XRPC method "tools.ozone.moderation.getSubjects". 19 + func ModerationGetSubjects(ctx context.Context, c *xrpc.Client, subjects []string) (*ModerationGetSubjects_Output, error) { 20 + var out ModerationGetSubjects_Output 21 + 22 + params := map[string]interface{}{ 23 + "subjects": subjects, 24 + } 25 + if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.moderation.getSubjects", params, nil, &out); err != nil { 26 + return nil, err 27 + } 28 + 29 + return &out, nil 30 + }
+2 -1
api/ozone/teamlistMembers.go
··· 17 17 } 18 18 19 19 // TeamListMembers calls the XRPC method "tools.ozone.team.listMembers". 20 - func TeamListMembers(ctx context.Context, c *xrpc.Client, cursor string, disabled bool, limit int64, roles []string) (*TeamListMembers_Output, error) { 20 + func TeamListMembers(ctx context.Context, c *xrpc.Client, cursor string, disabled bool, limit int64, q string, roles []string) (*TeamListMembers_Output, error) { 21 21 var out TeamListMembers_Output 22 22 23 23 params := map[string]interface{}{ 24 24 "cursor": cursor, 25 25 "disabled": disabled, 26 26 "limit": limit, 27 + "q": q, 27 28 "roles": roles, 28 29 } 29 30 if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.team.listMembers", params, nil, &out); err != nil {
+1 -1
automod/capture/fetch.go
··· 63 63 } 64 64 pdsClient := xrpc.Client{Host: pdsURL} 65 65 66 - resp, err := comatproto.RepoListRecords(ctx, &pdsClient, "app.bsky.feed.post", "", int64(limit), ident.DID.String(), false, "", "") 66 + resp, err := comatproto.RepoListRecords(ctx, &pdsClient, "app.bsky.feed.post", "", int64(limit), ident.DID.String(), false) 67 67 if err != nil { 68 68 return nil, nil, fmt.Errorf("failed to fetch record list: %v", err) 69 69 }
+2 -2
cmd/astrolabe/handlers.go
··· 164 164 } 165 165 166 166 cursor := c.QueryParam("cursor") 167 - // collection string, cursor string, limit int64, repo string, reverse bool, rkeyEnd string, rkeyStart string 168 - resp, err := agnostic.RepoListRecords(ctx, &xrpcc, collection.String(), cursor, 100, ident.DID.String(), false, "", "") 167 + // collection string, cursor string, limit int64, repo string, reverse bool 168 + resp, err := agnostic.RepoListRecords(ctx, &xrpcc, collection.String(), cursor, 100, ident.DID.String(), false) 169 169 if err != nil { 170 170 return err 171 171 }
+2 -2
cmd/goat/lexicon.go
··· 242 242 // NOTE: much of this code is copied from runRecordList 243 243 cursor := "" 244 244 for { 245 - // collection string, cursor string, limit int64, repo string, reverse bool, rkeyEnd string, rkeyStart string 246 - resp, err := agnostic.RepoListRecords(ctx, &xrpcc, "com.atproto.lexicon.schema", cursor, 100, ident.DID.String(), false, "", "") 245 + // collection string, cursor string, limit int64, repo string, reverse bool 246 + resp, err := agnostic.RepoListRecords(ctx, &xrpcc, "com.atproto.lexicon.schema", cursor, 100, ident.DID.String(), false) 247 247 if err != nil { 248 248 return err 249 249 }
+2 -2
cmd/goat/record.go
··· 179 179 for _, nsid := range collections { 180 180 cursor := "" 181 181 for { 182 - // collection string, cursor string, limit int64, repo string, reverse bool, rkeyEnd string, rkeyStart string 183 - resp, err := agnostic.RepoListRecords(ctx, &xrpcc, nsid, cursor, 100, ident.DID.String(), false, "", "") 182 + // collection string, cursor string, limit int64, repo string, reverse bool 183 + resp, err := agnostic.RepoListRecords(ctx, &xrpcc, nsid, cursor, 100, ident.DID.String(), false) 184 184 if err != nil { 185 185 return err 186 186 }