+82 -5

api/atproto/repoapplyWrites.go

reviewed

··· 25 25 Value *util.LexiconTypeDecoder `json:"value" cborgen:"value"` 26 26 } 27 27 28 28 + // RepoApplyWrites_CreateResult is a "createResult" in the com.atproto.repo.applyWrites schema. 29 29 + // 30 30 + // RECORDTYPE: RepoApplyWrites_CreateResult 31 31 + type RepoApplyWrites_CreateResult struct { 32 32 + LexiconTypeID string `json:"$type,const=com.atproto.repo.applyWrites#createResult" cborgen:"$type,const=com.atproto.repo.applyWrites#createResult"` 33 33 + Cid string `json:"cid" cborgen:"cid"` 34 34 + Uri string `json:"uri" cborgen:"uri"` 35 35 + ValidationStatus *string `json:"validationStatus,omitempty" cborgen:"validationStatus,omitempty"` 36 36 + } 37 37 + 28 38 // RepoApplyWrites_Delete is a "delete" in the com.atproto.repo.applyWrites schema. 29 39 // 30 40 // Operation which deletes an existing record. ··· 36 46 Rkey string `json:"rkey" cborgen:"rkey"` 37 47 } 38 48 49 49 + // RepoApplyWrites_DeleteResult is a "deleteResult" in the com.atproto.repo.applyWrites schema. 50 50 + // 51 51 + // RECORDTYPE: RepoApplyWrites_DeleteResult 52 52 + type RepoApplyWrites_DeleteResult struct { 53 53 + LexiconTypeID string `json:"$type,const=com.atproto.repo.applyWrites#deleteResult" cborgen:"$type,const=com.atproto.repo.applyWrites#deleteResult"` 54 54 + } 55 55 + 39 56 // RepoApplyWrites_Input is the input argument to a com.atproto.repo.applyWrites call. 40 57 type RepoApplyWrites_Input struct { 41 58 // repo: The handle or DID of the repo (aka, current account). 42 59 Repo string `json:"repo" cborgen:"repo"` 43 60 // swapCommit: If provided, the entire operation will fail if the current repo commit CID does not match this value. Used to prevent conflicting repo mutations. 44 61 SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"` 45 45 - // validate: Can be set to 'false' to skip Lexicon schema validation of record data, for all operations. 62 62 + // validate: Can be set to 'false' to skip Lexicon schema validation of record data across all operations, 'true' to require it, or leave unset to validate only for known Lexicons. 46 63 Validate *bool `json:"validate,omitempty" cborgen:"validate,omitempty"` 47 64 Writes []*RepoApplyWrites_Input_Writes_Elem `json:"writes" cborgen:"writes"` 48 65 } ··· 90 107 } 91 108 } 92 109 110 110 + // RepoApplyWrites_Output is the output of a com.atproto.repo.applyWrites call. 111 111 + type RepoApplyWrites_Output struct { 112 112 + Commit *RepoDefs_CommitMeta `json:"commit,omitempty" cborgen:"commit,omitempty"` 113 113 + Results []*RepoApplyWrites_Output_Results_Elem `json:"results,omitempty" cborgen:"results,omitempty"` 114 114 + } 115 115 + 116 116 + type RepoApplyWrites_Output_Results_Elem struct { 117 117 + RepoApplyWrites_CreateResult *RepoApplyWrites_CreateResult 118 118 + RepoApplyWrites_UpdateResult *RepoApplyWrites_UpdateResult 119 119 + RepoApplyWrites_DeleteResult *RepoApplyWrites_DeleteResult 120 120 + } 121 121 + 122 122 + func (t *RepoApplyWrites_Output_Results_Elem) MarshalJSON() ([]byte, error) { 123 123 + if t.RepoApplyWrites_CreateResult != nil { 124 124 + t.RepoApplyWrites_CreateResult.LexiconTypeID = "com.atproto.repo.applyWrites#createResult" 125 125 + return json.Marshal(t.RepoApplyWrites_CreateResult) 126 126 + } 127 127 + if t.RepoApplyWrites_UpdateResult != nil { 128 128 + t.RepoApplyWrites_UpdateResult.LexiconTypeID = "com.atproto.repo.applyWrites#updateResult" 129 129 + return json.Marshal(t.RepoApplyWrites_UpdateResult) 130 130 + } 131 131 + if t.RepoApplyWrites_DeleteResult != nil { 132 132 + t.RepoApplyWrites_DeleteResult.LexiconTypeID = "com.atproto.repo.applyWrites#deleteResult" 133 133 + return json.Marshal(t.RepoApplyWrites_DeleteResult) 134 134 + } 135 135 + return nil, fmt.Errorf("cannot marshal empty enum") 136 136 + } 137 137 + func (t *RepoApplyWrites_Output_Results_Elem) UnmarshalJSON(b []byte) error { 138 138 + typ, err := util.TypeExtract(b) 139 139 + if err != nil { 140 140 + return err 141 141 + } 142 142 + 143 143 + switch typ { 144 144 + case "com.atproto.repo.applyWrites#createResult": 145 145 + t.RepoApplyWrites_CreateResult = new(RepoApplyWrites_CreateResult) 146 146 + return json.Unmarshal(b, t.RepoApplyWrites_CreateResult) 147 147 + case "com.atproto.repo.applyWrites#updateResult": 148 148 + t.RepoApplyWrites_UpdateResult = new(RepoApplyWrites_UpdateResult) 149 149 + return json.Unmarshal(b, t.RepoApplyWrites_UpdateResult) 150 150 + case "com.atproto.repo.applyWrites#deleteResult": 151 151 + t.RepoApplyWrites_DeleteResult = new(RepoApplyWrites_DeleteResult) 152 152 + return json.Unmarshal(b, t.RepoApplyWrites_DeleteResult) 153 153 + 154 154 + default: 155 155 + return fmt.Errorf("closed enums must have a matching value") 156 156 + } 157 157 + } 158 158 + 93 159 // RepoApplyWrites_Update is a "update" in the com.atproto.repo.applyWrites schema. 94 160 // 95 161 // Operation which updates an existing record. ··· 102 168 Value *util.LexiconTypeDecoder `json:"value" cborgen:"value"` 103 169 } 104 170 171 171 + // RepoApplyWrites_UpdateResult is a "updateResult" in the com.atproto.repo.applyWrites schema. 172 172 + // 173 173 + // RECORDTYPE: RepoApplyWrites_UpdateResult 174 174 + type RepoApplyWrites_UpdateResult struct { 175 175 + LexiconTypeID string `json:"$type,const=com.atproto.repo.applyWrites#updateResult" cborgen:"$type,const=com.atproto.repo.applyWrites#updateResult"` 176 176 + Cid string `json:"cid" cborgen:"cid"` 177 177 + Uri string `json:"uri" cborgen:"uri"` 178 178 + ValidationStatus *string `json:"validationStatus,omitempty" cborgen:"validationStatus,omitempty"` 179 179 + } 180 180 + 105 181 // RepoApplyWrites calls the XRPC method "com.atproto.repo.applyWrites". 106 106 - func RepoApplyWrites(ctx context.Context, c *xrpc.Client, input *RepoApplyWrites_Input) error { 107 107 - if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.repo.applyWrites", nil, input, nil); err != nil { 108 108 - return err 182 182 + func RepoApplyWrites(ctx context.Context, c *xrpc.Client, input *RepoApplyWrites_Input) (*RepoApplyWrites_Output, error) { 183 183 + var out RepoApplyWrites_Output 184 184 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.repo.applyWrites", nil, input, &out); err != nil { 185 185 + return nil, err 109 186 } 110 187 111 111 - return nil 188 188 + return &out, nil 112 189 }

+5 -3

api/atproto/repocreateRecord.go

reviewed

··· 23 23 Rkey *string `json:"rkey,omitempty" cborgen:"rkey,omitempty"` 24 24 // swapCommit: Compare and swap with the previous commit by CID. 25 25 SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"` 26 26 - // validate: Can be set to 'false' to skip Lexicon schema validation of record data. 26 26 + // validate: Can be set to 'false' to skip Lexicon schema validation of record data, 'true' to require it, or leave unset to validate only for known Lexicons. 27 27 Validate *bool `json:"validate,omitempty" cborgen:"validate,omitempty"` 28 28 } 29 29 30 30 // RepoCreateRecord_Output is the output of a com.atproto.repo.createRecord call. 31 31 type RepoCreateRecord_Output struct { 32 32 - Cid string `json:"cid" cborgen:"cid"` 33 33 - Uri string `json:"uri" cborgen:"uri"` 32 32 + Cid string `json:"cid" cborgen:"cid"` 33 33 + Commit *RepoDefs_CommitMeta `json:"commit,omitempty" cborgen:"commit,omitempty"` 34 34 + Uri string `json:"uri" cborgen:"uri"` 35 35 + ValidationStatus *string `json:"validationStatus,omitempty" cborgen:"validationStatus,omitempty"` 34 36 } 35 37 36 38 // RepoCreateRecord calls the XRPC method "com.atproto.repo.createRecord".

+11

api/atproto/repodefs.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package atproto 4 4 + 5 5 + // schema: com.atproto.repo.defs 6 6 + 7 7 + // RepoDefs_CommitMeta is a "commitMeta" in the com.atproto.repo.defs schema. 8 8 + type RepoDefs_CommitMeta struct { 9 9 + Cid string `json:"cid" cborgen:"cid"` 10 10 + Rev string `json:"rev" cborgen:"rev"` 11 11 + }

+10 -4

api/atproto/repodeleteRecord.go

reviewed

··· 24 24 SwapRecord *string `json:"swapRecord,omitempty" cborgen:"swapRecord,omitempty"` 25 25 } 26 26 27 27 + // RepoDeleteRecord_Output is the output of a com.atproto.repo.deleteRecord call. 28 28 + type RepoDeleteRecord_Output struct { 29 29 + Commit *RepoDefs_CommitMeta `json:"commit,omitempty" cborgen:"commit,omitempty"` 30 30 + } 31 31 + 27 32 // RepoDeleteRecord calls the XRPC method "com.atproto.repo.deleteRecord". 28 28 - func RepoDeleteRecord(ctx context.Context, c *xrpc.Client, input *RepoDeleteRecord_Input) error { 29 29 - if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.repo.deleteRecord", nil, input, nil); err != nil { 30 30 - return err 33 33 + func RepoDeleteRecord(ctx context.Context, c *xrpc.Client, input *RepoDeleteRecord_Input) (*RepoDeleteRecord_Output, error) { 34 34 + var out RepoDeleteRecord_Output 35 35 + if err := c.Do(ctx, xrpc.Procedure, "application/json", "com.atproto.repo.deleteRecord", nil, input, &out); err != nil { 36 36 + return nil, err 31 37 } 32 38 33 33 - return nil 39 39 + return &out, nil 34 40 }

+5 -3

api/atproto/repoputRecord.go

reviewed

··· 25 25 SwapCommit *string `json:"swapCommit,omitempty" cborgen:"swapCommit,omitempty"` 26 26 // swapRecord: Compare and swap with the previous record by CID. WARNING: nullable and optional field; may cause problems with golang implementation 27 27 SwapRecord *string `json:"swapRecord" cborgen:"swapRecord"` 28 28 - // validate: Can be set to 'false' to skip Lexicon schema validation of record data. 28 28 + // validate: Can be set to 'false' to skip Lexicon schema validation of record data, 'true' to require it, or leave unset to validate only for known Lexicons. 29 29 Validate *bool `json:"validate,omitempty" cborgen:"validate,omitempty"` 30 30 } 31 31 32 32 // RepoPutRecord_Output is the output of a com.atproto.repo.putRecord call. 33 33 type RepoPutRecord_Output struct { 34 34 - Cid string `json:"cid" cborgen:"cid"` 35 35 - Uri string `json:"uri" cborgen:"uri"` 34 34 + Cid string `json:"cid" cborgen:"cid"` 35 35 + Commit *RepoDefs_CommitMeta `json:"commit,omitempty" cborgen:"commit,omitempty"` 36 36 + Uri string `json:"uri" cborgen:"uri"` 37 37 + ValidationStatus *string `json:"validationStatus,omitempty" cborgen:"validationStatus,omitempty"` 36 38 } 37 39 38 40 // RepoPutRecord calls the XRPC method "com.atproto.repo.putRecord".

+15

api/bsky/actordefs.go

reviewed

··· 35 35 type ActorDefs_BskyAppStatePref struct { 36 36 LexiconTypeID string `json:"$type,const=app.bsky.actor.defs#bskyAppStatePref" cborgen:"$type,const=app.bsky.actor.defs#bskyAppStatePref"` 37 37 ActiveProgressGuide *ActorDefs_BskyAppProgressGuide `json:"activeProgressGuide,omitempty" cborgen:"activeProgressGuide,omitempty"` 38 38 + // nuxs: Storage for NUXs the user has encountered. 39 39 + Nuxs []*ActorDefs_Nux `json:"nuxs,omitempty" cborgen:"nuxs,omitempty"` 38 40 // queuedNudges: An array of tokens which identify nudges (modals, popups, tours, highlight dots) that should be shown to the user. 39 41 QueuedNudges []string `json:"queuedNudges,omitempty" cborgen:"queuedNudges,omitempty"` 40 42 } ··· 130 132 LexiconTypeID string `json:"$type,const=app.bsky.actor.defs#mutedWordsPref" cborgen:"$type,const=app.bsky.actor.defs#mutedWordsPref"` 131 133 // items: A list of words the account owner has muted. 132 134 Items []*ActorDefs_MutedWord `json:"items" cborgen:"items"` 135 135 + } 136 136 + 137 137 + // ActorDefs_Nux is a "nux" in the app.bsky.actor.defs schema. 138 138 + // 139 139 + // A new user experiences (NUX) storage object 140 140 + type ActorDefs_Nux struct { 141 141 + Completed bool `json:"completed" cborgen:"completed"` 142 142 + // data: Arbitrary data for the NUX. The structure is defined by the NUX itself. Limited to 300 characters. 143 143 + Data *string `json:"data,omitempty" cborgen:"data,omitempty"` 144 144 + // expiresAt: The date and time at which the NUX will expire and should be considered completed. 145 145 + ExpiresAt *string `json:"expiresAt,omitempty" cborgen:"expiresAt,omitempty"` 146 146 + Id string `json:"id" cborgen:"id"` 133 147 } 134 148 135 149 // ActorDefs_PersonalDetailsPref is a "personalDetailsPref" in the app.bsky.actor.defs schema. ··· 311 325 IndexedAt *string `json:"indexedAt,omitempty" cborgen:"indexedAt,omitempty"` 312 326 JoinedViaStarterPack *GraphDefs_StarterPackViewBasic `json:"joinedViaStarterPack,omitempty" cborgen:"joinedViaStarterPack,omitempty"` 313 327 Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 328 328 + PinnedPost *comatprototypes.RepoStrongRef `json:"pinnedPost,omitempty" cborgen:"pinnedPost,omitempty"` 314 329 PostsCount *int64 `json:"postsCount,omitempty" cborgen:"postsCount,omitempty"` 315 330 Viewer *ActorDefs_ViewerState `json:"viewer,omitempty" cborgen:"viewer,omitempty"` 316 331 }

+2 -1

api/bsky/actorprofile.go

reviewed

··· 31 31 DisplayName *string `json:"displayName,omitempty" cborgen:"displayName,omitempty"` 32 32 JoinedViaStarterPack *comatprototypes.RepoStrongRef `json:"joinedViaStarterPack,omitempty" cborgen:"joinedViaStarterPack,omitempty"` 33 33 // labels: Self-label values, specific to the Bluesky application, on the overall account. 34 34 - Labels *ActorProfile_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"` 34 34 + Labels *ActorProfile_Labels `json:"labels,omitempty" cborgen:"labels,omitempty"` 35 35 + PinnedPost *comatprototypes.RepoStrongRef `json:"pinnedPost,omitempty" cborgen:"pinnedPost,omitempty"` 35 36 } 36 37 37 38 // Self-label values, specific to the Bluesky application, on the overall account.

+44 -1

api/bsky/cbor_gen.go

reviewed

··· 2091 2091 } 2092 2092 2093 2093 cw := cbg.NewCborWriter(w) 2094 2094 - fieldCount := 8 2094 2094 + fieldCount := 9 2095 2095 2096 2096 if t.Avatar == nil { 2097 2097 fieldCount-- ··· 2118 2118 } 2119 2119 2120 2120 if t.Labels == nil { 2121 2121 + fieldCount-- 2122 2122 + } 2123 2123 + 2124 2124 + if t.PinnedPost == nil { 2121 2125 fieldCount-- 2122 2126 } 2123 2127 ··· 2230 2234 if _, err := cw.WriteString(string(*t.CreatedAt)); err != nil { 2231 2235 return err 2232 2236 } 2237 2237 + } 2238 2238 + } 2239 2239 + 2240 2240 + // t.PinnedPost (atproto.RepoStrongRef) (struct) 2241 2241 + if t.PinnedPost != nil { 2242 2242 + 2243 2243 + if len("pinnedPost") > 1000000 { 2244 2244 + return xerrors.Errorf("Value in field \"pinnedPost\" was too long") 2245 2245 + } 2246 2246 + 2247 2247 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("pinnedPost"))); err != nil { 2248 2248 + return err 2249 2249 + } 2250 2250 + if _, err := cw.WriteString(string("pinnedPost")); err != nil { 2251 2251 + return err 2252 2252 + } 2253 2253 + 2254 2254 + if err := t.PinnedPost.MarshalCBOR(cw); err != nil { 2255 2255 + return err 2233 2256 } 2234 2257 } 2235 2258 ··· 2447 2470 2448 2471 t.CreatedAt = (*string)(&sval) 2449 2472 } 2473 2473 + } 2474 2474 + // t.PinnedPost (atproto.RepoStrongRef) (struct) 2475 2475 + case "pinnedPost": 2476 2476 + 2477 2477 + { 2478 2478 + 2479 2479 + b, err := cr.ReadByte() 2480 2480 + if err != nil { 2481 2481 + return err 2482 2482 + } 2483 2483 + if b != cbg.CborNull[0] { 2484 2484 + if err := cr.UnreadByte(); err != nil { 2485 2485 + return err 2486 2486 + } 2487 2487 + t.PinnedPost = new(atproto.RepoStrongRef) 2488 2488 + if err := t.PinnedPost.UnmarshalCBOR(cr); err != nil { 2489 2489 + return xerrors.Errorf("unmarshaling t.PinnedPost pointer: %w", err) 2490 2490 + } 2491 2491 + } 2492 2492 + 2450 2493 } 2451 2494 // t.Description (string) (string) 2452 2495 case "description":

+1

api/bsky/embedrecord.go

reviewed

··· 68 68 IndexedAt string `json:"indexedAt" cborgen:"indexedAt"` 69 69 Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 70 70 LikeCount *int64 `json:"likeCount,omitempty" cborgen:"likeCount,omitempty"` 71 71 + QuoteCount *int64 `json:"quoteCount,omitempty" cborgen:"quoteCount,omitempty"` 71 72 ReplyCount *int64 `json:"replyCount,omitempty" cborgen:"replyCount,omitempty"` 72 73 RepostCount *int64 `json:"repostCount,omitempty" cborgen:"repostCount,omitempty"` 73 74 Uri string `json:"uri" cborgen:"uri"`

+32

api/bsky/feeddefs.go

reviewed

··· 39 39 40 40 type FeedDefs_FeedViewPost_Reason struct { 41 41 FeedDefs_ReasonRepost *FeedDefs_ReasonRepost 42 42 + FeedDefs_ReasonPin *FeedDefs_ReasonPin 42 43 } 43 44 44 45 func (t *FeedDefs_FeedViewPost_Reason) MarshalJSON() ([]byte, error) { ··· 46 47 t.FeedDefs_ReasonRepost.LexiconTypeID = "app.bsky.feed.defs#reasonRepost" 47 48 return json.Marshal(t.FeedDefs_ReasonRepost) 48 49 } 50 50 + if t.FeedDefs_ReasonPin != nil { 51 51 + t.FeedDefs_ReasonPin.LexiconTypeID = "app.bsky.feed.defs#reasonPin" 52 52 + return json.Marshal(t.FeedDefs_ReasonPin) 53 53 + } 49 54 return nil, fmt.Errorf("cannot marshal empty enum") 50 55 } 51 56 func (t *FeedDefs_FeedViewPost_Reason) UnmarshalJSON(b []byte) error { ··· 58 63 case "app.bsky.feed.defs#reasonRepost": 59 64 t.FeedDefs_ReasonRepost = new(FeedDefs_ReasonRepost) 60 65 return json.Unmarshal(b, t.FeedDefs_ReasonRepost) 66 66 + case "app.bsky.feed.defs#reasonPin": 67 67 + t.FeedDefs_ReasonPin = new(FeedDefs_ReasonPin) 68 68 + return json.Unmarshal(b, t.FeedDefs_ReasonPin) 61 69 62 70 default: 63 71 return nil ··· 117 125 IndexedAt string `json:"indexedAt" cborgen:"indexedAt"` 118 126 Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 119 127 LikeCount *int64 `json:"likeCount,omitempty" cborgen:"likeCount,omitempty"` 128 128 + QuoteCount *int64 `json:"quoteCount,omitempty" cborgen:"quoteCount,omitempty"` 120 129 Record *util.LexiconTypeDecoder `json:"record" cborgen:"record"` 121 130 ReplyCount *int64 `json:"replyCount,omitempty" cborgen:"replyCount,omitempty"` 122 131 RepostCount *int64 `json:"repostCount,omitempty" cborgen:"repostCount,omitempty"` ··· 182 191 default: 183 192 return nil 184 193 } 194 194 + } 195 195 + 196 196 + // FeedDefs_ReasonPin is a "reasonPin" in the app.bsky.feed.defs schema. 197 197 + // 198 198 + // RECORDTYPE: FeedDefs_ReasonPin 199 199 + type FeedDefs_ReasonPin struct { 200 200 + LexiconTypeID string `json:"$type,const=app.bsky.feed.defs#reasonPin" cborgen:"$type,const=app.bsky.feed.defs#reasonPin"` 185 201 } 186 202 187 203 // FeedDefs_ReasonRepost is a "reasonRepost" in the app.bsky.feed.defs schema. ··· 297 313 298 314 type FeedDefs_SkeletonFeedPost_Reason struct { 299 315 FeedDefs_SkeletonReasonRepost *FeedDefs_SkeletonReasonRepost 316 316 + FeedDefs_SkeletonReasonPin *FeedDefs_SkeletonReasonPin 300 317 } 301 318 302 319 func (t *FeedDefs_SkeletonFeedPost_Reason) MarshalJSON() ([]byte, error) { ··· 304 321 t.FeedDefs_SkeletonReasonRepost.LexiconTypeID = "app.bsky.feed.defs#skeletonReasonRepost" 305 322 return json.Marshal(t.FeedDefs_SkeletonReasonRepost) 306 323 } 324 324 + if t.FeedDefs_SkeletonReasonPin != nil { 325 325 + t.FeedDefs_SkeletonReasonPin.LexiconTypeID = "app.bsky.feed.defs#skeletonReasonPin" 326 326 + return json.Marshal(t.FeedDefs_SkeletonReasonPin) 327 327 + } 307 328 return nil, fmt.Errorf("cannot marshal empty enum") 308 329 } 309 330 func (t *FeedDefs_SkeletonFeedPost_Reason) UnmarshalJSON(b []byte) error { ··· 316 337 case "app.bsky.feed.defs#skeletonReasonRepost": 317 338 t.FeedDefs_SkeletonReasonRepost = new(FeedDefs_SkeletonReasonRepost) 318 339 return json.Unmarshal(b, t.FeedDefs_SkeletonReasonRepost) 340 340 + case "app.bsky.feed.defs#skeletonReasonPin": 341 341 + t.FeedDefs_SkeletonReasonPin = new(FeedDefs_SkeletonReasonPin) 342 342 + return json.Unmarshal(b, t.FeedDefs_SkeletonReasonPin) 319 343 320 344 default: 321 345 return nil 322 346 } 347 347 + } 348 348 + 349 349 + // FeedDefs_SkeletonReasonPin is a "skeletonReasonPin" in the app.bsky.feed.defs schema. 350 350 + // 351 351 + // RECORDTYPE: FeedDefs_SkeletonReasonPin 352 352 + type FeedDefs_SkeletonReasonPin struct { 353 353 + LexiconTypeID string `json:"$type,const=app.bsky.feed.defs#skeletonReasonPin" cborgen:"$type,const=app.bsky.feed.defs#skeletonReasonPin"` 323 354 } 324 355 325 356 // FeedDefs_SkeletonReasonRepost is a "skeletonReasonRepost" in the app.bsky.feed.defs schema. ··· 440 471 type FeedDefs_ViewerState struct { 441 472 EmbeddingDisabled *bool `json:"embeddingDisabled,omitempty" cborgen:"embeddingDisabled,omitempty"` 442 473 Like *string `json:"like,omitempty" cborgen:"like,omitempty"` 474 474 + Pinned *bool `json:"pinned,omitempty" cborgen:"pinned,omitempty"` 443 475 ReplyDisabled *bool `json:"replyDisabled,omitempty" cborgen:"replyDisabled,omitempty"` 444 476 Repost *string `json:"repost,omitempty" cborgen:"repost,omitempty"` 445 477 ThreadMuted *bool `json:"threadMuted,omitempty" cborgen:"threadMuted,omitempty"`

+6 -5

api/bsky/feedgetAuthorFeed.go

reviewed

··· 19 19 // FeedGetAuthorFeed calls the XRPC method "app.bsky.feed.getAuthorFeed". 20 20 // 21 21 // filter: Combinations of post/repost types to include in response. 22 22 - func FeedGetAuthorFeed(ctx context.Context, c *xrpc.Client, actor string, cursor string, filter string, limit int64) (*FeedGetAuthorFeed_Output, error) { 22 22 + func FeedGetAuthorFeed(ctx context.Context, c *xrpc.Client, actor string, cursor string, filter string, includePins bool, limit int64) (*FeedGetAuthorFeed_Output, error) { 23 23 var out FeedGetAuthorFeed_Output 24 24 25 25 params := map[string]interface{}{ 26 26 - "actor": actor, 27 27 - "cursor": cursor, 28 28 - "filter": filter, 29 29 - "limit": limit, 26 26 + "actor": actor, 27 27 + "cursor": cursor, 28 28 + "filter": filter, 29 29 + "includePins": includePins, 30 30 + "limit": limit, 30 31 } 31 32 if err := c.Do(ctx, xrpc.Query, "", "app.bsky.feed.getAuthorFeed", params, nil, &out); err != nil { 32 33 return nil, err

+2 -1

api/bsky/feedgetPostThread.go

reviewed

··· 15 15 16 16 // FeedGetPostThread_Output is the output of a app.bsky.feed.getPostThread call. 17 17 type FeedGetPostThread_Output struct { 18 18 - Thread *FeedGetPostThread_Output_Thread `json:"thread" cborgen:"thread"` 18 18 + Thread *FeedGetPostThread_Output_Thread `json:"thread" cborgen:"thread"` 19 19 + Threadgate *FeedDefs_ThreadgateView `json:"threadgate,omitempty" cborgen:"threadgate,omitempty"` 19 20 } 20 21 21 22 type FeedGetPostThread_Output_Thread struct {

+39

api/bsky/feedgetQuotes.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package bsky 4 4 + 5 5 + // schema: app.bsky.feed.getQuotes 6 6 + 7 7 + import ( 8 8 + "context" 9 9 + 10 10 + "github.com/bluesky-social/indigo/xrpc" 11 11 + ) 12 12 + 13 13 + // FeedGetQuotes_Output is the output of a app.bsky.feed.getQuotes call. 14 14 + type FeedGetQuotes_Output struct { 15 15 + Cid *string `json:"cid,omitempty" cborgen:"cid,omitempty"` 16 16 + Cursor *string `json:"cursor,omitempty" cborgen:"cursor,omitempty"` 17 17 + Posts []*FeedDefs_PostView `json:"posts" cborgen:"posts"` 18 18 + Uri string `json:"uri" cborgen:"uri"` 19 19 + } 20 20 + 21 21 + // FeedGetQuotes calls the XRPC method "app.bsky.feed.getQuotes". 22 22 + // 23 23 + // cid: If supplied, filters to quotes of specific version (by CID) of the post record. 24 24 + // uri: Reference (AT-URI) of post record 25 25 + func FeedGetQuotes(ctx context.Context, c *xrpc.Client, cid string, cursor string, limit int64, uri string) (*FeedGetQuotes_Output, error) { 26 26 + var out FeedGetQuotes_Output 27 27 + 28 28 + params := map[string]interface{}{ 29 29 + "cid": cid, 30 30 + "cursor": cursor, 31 31 + "limit": limit, 32 32 + "uri": uri, 33 33 + } 34 34 + if err := c.Do(ctx, xrpc.Query, "", "app.bsky.feed.getQuotes", params, nil, &out); err != nil { 35 35 + return nil, err 36 36 + } 37 37 + 38 38 + return &out, nil 39 39 + }

+2

api/bsky/graphgetSuggestedFollowsByActor.go

reviewed

··· 12 12 13 13 // GraphGetSuggestedFollowsByActor_Output is the output of a app.bsky.graph.getSuggestedFollowsByActor call. 14 14 type GraphGetSuggestedFollowsByActor_Output struct { 15 15 + // isFallback: If true, response has fallen-back to generic results, and is not scoped using relativeToDid 16 16 + IsFallback *bool `json:"isFallback,omitempty" cborgen:"isFallback,omitempty"` 15 17 Suggestions []*ActorDefs_ProfileView `json:"suggestions" cborgen:"suggestions"` 16 18 } 17 19

+2

api/bsky/unspeccedgetSuggestionsSkeleton.go

reviewed

··· 14 14 type UnspeccedGetSuggestionsSkeleton_Output struct { 15 15 Actors []*UnspeccedDefs_SkeletonSearchActor `json:"actors" cborgen:"actors"` 16 16 Cursor *string `json:"cursor,omitempty" cborgen:"cursor,omitempty"` 17 17 + // relativeToDid: DID of the account these suggestions are relative to. If this is returned undefined, suggestions are based on the viewer. 18 18 + RelativeToDid *string `json:"relativeToDid,omitempty" cborgen:"relativeToDid,omitempty"` 17 19 } 18 20 19 21 // UnspeccedGetSuggestionsSkeleton calls the XRPC method "app.bsky.unspecced.getSuggestionsSkeleton".

+2

api/ozone/communicationcreateTemplate.go

reviewed

··· 16 16 ContentMarkdown string `json:"contentMarkdown" cborgen:"contentMarkdown"` 17 17 // createdBy: DID of the user who is creating the template. 18 18 CreatedBy *string `json:"createdBy,omitempty" cborgen:"createdBy,omitempty"` 19 19 + // lang: Message language. 20 20 + Lang *string `json:"lang,omitempty" cborgen:"lang,omitempty"` 19 21 // name: Name of the template. 20 22 Name string `json:"name" cborgen:"name"` 21 23 // subject: Subject of the message, used in emails.

+2

api/ozone/communicationdefs.go

reviewed

··· 11 11 CreatedAt string `json:"createdAt" cborgen:"createdAt"` 12 12 Disabled bool `json:"disabled" cborgen:"disabled"` 13 13 Id string `json:"id" cborgen:"id"` 14 14 + // lang: Message language. 15 15 + Lang *string `json:"lang,omitempty" cborgen:"lang,omitempty"` 14 16 // lastUpdatedBy: DID of the user who last updated the template. 15 17 LastUpdatedBy string `json:"lastUpdatedBy" cborgen:"lastUpdatedBy"` 16 18 // name: Name of the template.

+2

api/ozone/communicationupdateTemplate.go

reviewed

··· 17 17 Disabled *bool `json:"disabled,omitempty" cborgen:"disabled,omitempty"` 18 18 // id: ID of the template to be updated. 19 19 Id string `json:"id" cborgen:"id"` 20 20 + // lang: Message language. 21 21 + Lang *string `json:"lang,omitempty" cborgen:"lang,omitempty"` 20 22 // name: Name of the template. 21 23 Name *string `json:"name,omitempty" cborgen:"name,omitempty"` 22 24 // subject: Subject of the message, used in emails.

+18 -10

api/ozone/moderationdefs.go

reviewed

··· 212 212 // 213 213 // RECORDTYPE: ModerationDefs_ModEventTakedown 214 214 type ModerationDefs_ModEventTakedown struct { 215 215 - LexiconTypeID string `json:"$type,const=tools.ozone.moderation.defs#modEventTakedown" cborgen:"$type,const=tools.ozone.moderation.defs#modEventTakedown"` 216 216 - Comment *string `json:"comment,omitempty" cborgen:"comment,omitempty"` 215 215 + LexiconTypeID string `json:"$type,const=tools.ozone.moderation.defs#modEventTakedown" cborgen:"$type,const=tools.ozone.moderation.defs#modEventTakedown"` 216 216 + // acknowledgeAccountSubjects: If true, all other reports on content authored by this account will be resolved (acknowledged). 217 217 + AcknowledgeAccountSubjects *bool `json:"acknowledgeAccountSubjects,omitempty" cborgen:"acknowledgeAccountSubjects,omitempty"` 218 218 + Comment *string `json:"comment,omitempty" cborgen:"comment,omitempty"` 217 219 // durationInHours: Indicates how long the takedown should be in effect before automatically expiring. 218 220 DurationInHours *int64 `json:"durationInHours,omitempty" cborgen:"durationInHours,omitempty"` 219 221 } ··· 659 661 } 660 662 661 663 // ModerationDefs_RecordViewDetail is a "recordViewDetail" in the tools.ozone.moderation.defs schema. 664 664 + // 665 665 + // RECORDTYPE: ModerationDefs_RecordViewDetail 662 666 type ModerationDefs_RecordViewDetail struct { 663 663 - Blobs []*ModerationDefs_BlobView `json:"blobs" cborgen:"blobs"` 664 664 - Cid string `json:"cid" cborgen:"cid"` 665 665 - IndexedAt string `json:"indexedAt" cborgen:"indexedAt"` 666 666 - Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 667 667 - Moderation *ModerationDefs_ModerationDetail `json:"moderation" cborgen:"moderation"` 668 668 - Repo *ModerationDefs_RepoView `json:"repo" cborgen:"repo"` 669 669 - Uri string `json:"uri" cborgen:"uri"` 670 670 - Value *util.LexiconTypeDecoder `json:"value" cborgen:"value"` 667 667 + LexiconTypeID string `json:"$type,const=tools.ozone.moderation.defs#recordViewDetail" cborgen:"$type,const=tools.ozone.moderation.defs#recordViewDetail"` 668 668 + Blobs []*ModerationDefs_BlobView `json:"blobs" cborgen:"blobs"` 669 669 + Cid string `json:"cid" cborgen:"cid"` 670 670 + IndexedAt string `json:"indexedAt" cborgen:"indexedAt"` 671 671 + Labels []*comatprototypes.LabelDefs_Label `json:"labels,omitempty" cborgen:"labels,omitempty"` 672 672 + Moderation *ModerationDefs_ModerationDetail `json:"moderation" cborgen:"moderation"` 673 673 + Repo *ModerationDefs_RepoView `json:"repo" cborgen:"repo"` 674 674 + Uri string `json:"uri" cborgen:"uri"` 675 675 + Value *util.LexiconTypeDecoder `json:"value" cborgen:"value"` 671 676 } 672 677 673 678 // ModerationDefs_RecordViewNotFound is a "recordViewNotFound" in the tools.ozone.moderation.defs schema. ··· 696 701 } 697 702 698 703 // ModerationDefs_RepoViewDetail is a "repoViewDetail" in the tools.ozone.moderation.defs schema. 704 704 + // 705 705 + // RECORDTYPE: ModerationDefs_RepoViewDetail 699 706 type ModerationDefs_RepoViewDetail struct { 707 707 + LexiconTypeID string `json:"$type,const=tools.ozone.moderation.defs#repoViewDetail" cborgen:"$type,const=tools.ozone.moderation.defs#repoViewDetail"` 700 708 DeactivatedAt *string `json:"deactivatedAt,omitempty" cborgen:"deactivatedAt,omitempty"` 701 709 Did string `json:"did" cborgen:"did"` 702 710 Email *string `json:"email,omitempty" cborgen:"email,omitempty"`

+8

api/ozone/moderationemitEvent.go

reviewed

··· 34 34 ModerationDefs_ModEventMuteReporter *ModerationDefs_ModEventMuteReporter 35 35 ModerationDefs_ModEventUnmuteReporter *ModerationDefs_ModEventUnmuteReporter 36 36 ModerationDefs_ModEventReverseTakedown *ModerationDefs_ModEventReverseTakedown 37 37 + ModerationDefs_ModEventResolveAppeal *ModerationDefs_ModEventResolveAppeal 37 38 ModerationDefs_ModEventEmail *ModerationDefs_ModEventEmail 38 39 ModerationDefs_ModEventTag *ModerationDefs_ModEventTag 39 40 } ··· 83 84 t.ModerationDefs_ModEventReverseTakedown.LexiconTypeID = "tools.ozone.moderation.defs#modEventReverseTakedown" 84 85 return json.Marshal(t.ModerationDefs_ModEventReverseTakedown) 85 86 } 87 87 + if t.ModerationDefs_ModEventResolveAppeal != nil { 88 88 + t.ModerationDefs_ModEventResolveAppeal.LexiconTypeID = "tools.ozone.moderation.defs#modEventResolveAppeal" 89 89 + return json.Marshal(t.ModerationDefs_ModEventResolveAppeal) 90 90 + } 86 91 if t.ModerationDefs_ModEventEmail != nil { 87 92 t.ModerationDefs_ModEventEmail.LexiconTypeID = "tools.ozone.moderation.defs#modEventEmail" 88 93 return json.Marshal(t.ModerationDefs_ModEventEmail) ··· 133 138 case "tools.ozone.moderation.defs#modEventReverseTakedown": 134 139 t.ModerationDefs_ModEventReverseTakedown = new(ModerationDefs_ModEventReverseTakedown) 135 140 return json.Unmarshal(b, t.ModerationDefs_ModEventReverseTakedown) 141 141 + case "tools.ozone.moderation.defs#modEventResolveAppeal": 142 142 + t.ModerationDefs_ModEventResolveAppeal = new(ModerationDefs_ModEventResolveAppeal) 143 143 + return json.Unmarshal(b, t.ModerationDefs_ModEventResolveAppeal) 136 144 case "tools.ozone.moderation.defs#modEventEmail": 137 145 t.ModerationDefs_ModEventEmail = new(ModerationDefs_ModEventEmail) 138 146 return json.Unmarshal(b, t.ModerationDefs_ModEventEmail)

+68

api/ozone/moderationgetRecords.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package ozone 4 4 + 5 5 + // schema: tools.ozone.moderation.getRecords 6 6 + 7 7 + import ( 8 8 + "context" 9 9 + "encoding/json" 10 10 + "fmt" 11 11 + 12 12 + "github.com/bluesky-social/indigo/lex/util" 13 13 + "github.com/bluesky-social/indigo/xrpc" 14 14 + ) 15 15 + 16 16 + // ModerationGetRecords_Output is the output of a tools.ozone.moderation.getRecords call. 17 17 + type ModerationGetRecords_Output struct { 18 18 + Records []*ModerationGetRecords_Output_Records_Elem `json:"records" cborgen:"records"` 19 19 + } 20 20 + 21 21 + type ModerationGetRecords_Output_Records_Elem struct { 22 22 + ModerationDefs_RecordViewDetail *ModerationDefs_RecordViewDetail 23 23 + ModerationDefs_RecordViewNotFound *ModerationDefs_RecordViewNotFound 24 24 + } 25 25 + 26 26 + func (t *ModerationGetRecords_Output_Records_Elem) MarshalJSON() ([]byte, error) { 27 27 + if t.ModerationDefs_RecordViewDetail != nil { 28 28 + t.ModerationDefs_RecordViewDetail.LexiconTypeID = "tools.ozone.moderation.defs#recordViewDetail" 29 29 + return json.Marshal(t.ModerationDefs_RecordViewDetail) 30 30 + } 31 31 + if t.ModerationDefs_RecordViewNotFound != nil { 32 32 + t.ModerationDefs_RecordViewNotFound.LexiconTypeID = "tools.ozone.moderation.defs#recordViewNotFound" 33 33 + return json.Marshal(t.ModerationDefs_RecordViewNotFound) 34 34 + } 35 35 + return nil, fmt.Errorf("cannot marshal empty enum") 36 36 + } 37 37 + func (t *ModerationGetRecords_Output_Records_Elem) UnmarshalJSON(b []byte) error { 38 38 + typ, err := util.TypeExtract(b) 39 39 + if err != nil { 40 40 + return err 41 41 + } 42 42 + 43 43 + switch typ { 44 44 + case "tools.ozone.moderation.defs#recordViewDetail": 45 45 + t.ModerationDefs_RecordViewDetail = new(ModerationDefs_RecordViewDetail) 46 46 + return json.Unmarshal(b, t.ModerationDefs_RecordViewDetail) 47 47 + case "tools.ozone.moderation.defs#recordViewNotFound": 48 48 + t.ModerationDefs_RecordViewNotFound = new(ModerationDefs_RecordViewNotFound) 49 49 + return json.Unmarshal(b, t.ModerationDefs_RecordViewNotFound) 50 50 + 51 51 + default: 52 52 + return nil 53 53 + } 54 54 + } 55 55 + 56 56 + // ModerationGetRecords calls the XRPC method "tools.ozone.moderation.getRecords". 57 57 + func ModerationGetRecords(ctx context.Context, c *xrpc.Client, uris []string) (*ModerationGetRecords_Output, error) { 58 58 + var out ModerationGetRecords_Output 59 59 + 60 60 + params := map[string]interface{}{ 61 61 + "uris": uris, 62 62 + } 63 63 + if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.moderation.getRecords", params, nil, &out); err != nil { 64 64 + return nil, err 65 65 + } 66 66 + 67 67 + return &out, nil 68 68 + }

+68

api/ozone/moderationgetRepos.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package ozone 4 4 + 5 5 + // schema: tools.ozone.moderation.getRepos 6 6 + 7 7 + import ( 8 8 + "context" 9 9 + "encoding/json" 10 10 + "fmt" 11 11 + 12 12 + "github.com/bluesky-social/indigo/lex/util" 13 13 + "github.com/bluesky-social/indigo/xrpc" 14 14 + ) 15 15 + 16 16 + // ModerationGetRepos_Output is the output of a tools.ozone.moderation.getRepos call. 17 17 + type ModerationGetRepos_Output struct { 18 18 + Repos []*ModerationGetRepos_Output_Repos_Elem `json:"repos" cborgen:"repos"` 19 19 + } 20 20 + 21 21 + type ModerationGetRepos_Output_Repos_Elem struct { 22 22 + ModerationDefs_RepoViewDetail *ModerationDefs_RepoViewDetail 23 23 + ModerationDefs_RepoViewNotFound *ModerationDefs_RepoViewNotFound 24 24 + } 25 25 + 26 26 + func (t *ModerationGetRepos_Output_Repos_Elem) MarshalJSON() ([]byte, error) { 27 27 + if t.ModerationDefs_RepoViewDetail != nil { 28 28 + t.ModerationDefs_RepoViewDetail.LexiconTypeID = "tools.ozone.moderation.defs#repoViewDetail" 29 29 + return json.Marshal(t.ModerationDefs_RepoViewDetail) 30 30 + } 31 31 + if t.ModerationDefs_RepoViewNotFound != nil { 32 32 + t.ModerationDefs_RepoViewNotFound.LexiconTypeID = "tools.ozone.moderation.defs#repoViewNotFound" 33 33 + return json.Marshal(t.ModerationDefs_RepoViewNotFound) 34 34 + } 35 35 + return nil, fmt.Errorf("cannot marshal empty enum") 36 36 + } 37 37 + func (t *ModerationGetRepos_Output_Repos_Elem) UnmarshalJSON(b []byte) error { 38 38 + typ, err := util.TypeExtract(b) 39 39 + if err != nil { 40 40 + return err 41 41 + } 42 42 + 43 43 + switch typ { 44 44 + case "tools.ozone.moderation.defs#repoViewDetail": 45 45 + t.ModerationDefs_RepoViewDetail = new(ModerationDefs_RepoViewDetail) 46 46 + return json.Unmarshal(b, t.ModerationDefs_RepoViewDetail) 47 47 + case "tools.ozone.moderation.defs#repoViewNotFound": 48 48 + t.ModerationDefs_RepoViewNotFound = new(ModerationDefs_RepoViewNotFound) 49 49 + return json.Unmarshal(b, t.ModerationDefs_RepoViewNotFound) 50 50 + 51 51 + default: 52 52 + return nil 53 53 + } 54 54 + } 55 55 + 56 56 + // ModerationGetRepos calls the XRPC method "tools.ozone.moderation.getRepos". 57 57 + func ModerationGetRepos(ctx context.Context, c *xrpc.Client, dids []string) (*ModerationGetRepos_Output, error) { 58 58 + var out ModerationGetRepos_Output 59 59 + 60 60 + params := map[string]interface{}{ 61 61 + "dids": dids, 62 62 + } 63 63 + if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.moderation.getRepos", params, nil, &out); err != nil { 64 64 + return nil, err 65 65 + } 66 66 + 67 67 + return &out, nil 68 68 + }

+23 -20

api/ozone/moderationqueryStatuses.go

reviewed

··· 20 20 // 21 21 // appealed: Get subjects in unresolved appealed status 22 22 // comment: Search subjects by keyword from comments 23 23 + // includeAllUserRecords: All subjects belonging to the account specified in the 'subject' param will be returned. 23 24 // includeMuted: By default, we don't include muted subjects in the results. Set this to true to include them. 24 25 // lastReviewedBy: Get all subject statuses that were reviewed by a specific moderator 25 26 // onlyMuted: When set to true, only muted subjects and reporters will be returned. ··· 28 29 // reviewState: Specify when fetching subjects in a certain state 29 30 // reviewedAfter: Search subjects reviewed after a given timestamp 30 31 // reviewedBefore: Search subjects reviewed before a given timestamp 32 32 + // subject: The subject to get the status for. 31 33 // takendown: Get subjects that were taken down 32 32 - func ModerationQueryStatuses(ctx context.Context, c *xrpc.Client, appealed bool, comment string, cursor string, excludeTags []string, ignoreSubjects []string, includeMuted bool, lastReviewedBy string, limit int64, onlyMuted bool, reportedAfter string, reportedBefore string, reviewState string, reviewedAfter string, reviewedBefore string, sortDirection string, sortField string, subject string, tags []string, takendown bool) (*ModerationQueryStatuses_Output, error) { 34 34 + func ModerationQueryStatuses(ctx context.Context, c *xrpc.Client, appealed bool, comment string, cursor string, excludeTags []string, ignoreSubjects []string, includeAllUserRecords bool, includeMuted bool, lastReviewedBy string, limit int64, onlyMuted bool, reportedAfter string, reportedBefore string, reviewState string, reviewedAfter string, reviewedBefore string, sortDirection string, sortField string, subject string, tags []string, takendown bool) (*ModerationQueryStatuses_Output, error) { 33 35 var out ModerationQueryStatuses_Output 34 36 35 37 params := map[string]interface{}{ 36 36 - "appealed": appealed, 37 37 - "comment": comment, 38 38 - "cursor": cursor, 39 39 - "excludeTags": excludeTags, 40 40 - "ignoreSubjects": ignoreSubjects, 41 41 - "includeMuted": includeMuted, 42 42 - "lastReviewedBy": lastReviewedBy, 43 43 - "limit": limit, 44 44 - "onlyMuted": onlyMuted, 45 45 - "reportedAfter": reportedAfter, 46 46 - "reportedBefore": reportedBefore, 47 47 - "reviewState": reviewState, 48 48 - "reviewedAfter": reviewedAfter, 49 49 - "reviewedBefore": reviewedBefore, 50 50 - "sortDirection": sortDirection, 51 51 - "sortField": sortField, 52 52 - "subject": subject, 53 53 - "tags": tags, 54 54 - "takendown": takendown, 38 38 + "appealed": appealed, 39 39 + "comment": comment, 40 40 + "cursor": cursor, 41 41 + "excludeTags": excludeTags, 42 42 + "ignoreSubjects": ignoreSubjects, 43 43 + "includeAllUserRecords": includeAllUserRecords, 44 44 + "includeMuted": includeMuted, 45 45 + "lastReviewedBy": lastReviewedBy, 46 46 + "limit": limit, 47 47 + "onlyMuted": onlyMuted, 48 48 + "reportedAfter": reportedAfter, 49 49 + "reportedBefore": reportedBefore, 50 50 + "reviewState": reviewState, 51 51 + "reviewedAfter": reviewedAfter, 52 52 + "reviewedBefore": reviewedBefore, 53 53 + "sortDirection": sortDirection, 54 54 + "sortField": sortField, 55 55 + "subject": subject, 56 56 + "tags": tags, 57 57 + "takendown": takendown, 55 58 } 56 59 if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.moderation.queryStatuses", params, nil, &out); err != nil { 57 60 return nil, err

+11

api/ozone/signaturedefs.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package ozone 4 4 + 5 5 + // schema: tools.ozone.signature.defs 6 6 + 7 7 + // SignatureDefs_SigDetail is a "sigDetail" in the tools.ozone.signature.defs schema. 8 8 + type SignatureDefs_SigDetail struct { 9 9 + Property string `json:"property" cborgen:"property"` 10 10 + Value string `json:"value" cborgen:"value"` 11 11 + }

+30

api/ozone/signaturefindCorrelation.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package ozone 4 4 + 5 5 + // schema: tools.ozone.signature.findCorrelation 6 6 + 7 7 + import ( 8 8 + "context" 9 9 + 10 10 + "github.com/bluesky-social/indigo/xrpc" 11 11 + ) 12 12 + 13 13 + // SignatureFindCorrelation_Output is the output of a tools.ozone.signature.findCorrelation call. 14 14 + type SignatureFindCorrelation_Output struct { 15 15 + Details []*SignatureDefs_SigDetail `json:"details" cborgen:"details"` 16 16 + } 17 17 + 18 18 + // SignatureFindCorrelation calls the XRPC method "tools.ozone.signature.findCorrelation". 19 19 + func SignatureFindCorrelation(ctx context.Context, c *xrpc.Client, dids []string) (*SignatureFindCorrelation_Output, error) { 20 20 + var out SignatureFindCorrelation_Output 21 21 + 22 22 + params := map[string]interface{}{ 23 23 + "dids": dids, 24 24 + } 25 25 + if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.signature.findCorrelation", params, nil, &out); err != nil { 26 26 + return nil, err 27 27 + } 28 28 + 29 29 + return &out, nil 30 30 + }

+40

api/ozone/signaturefindRelatedAccounts.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package ozone 4 4 + 5 5 + // schema: tools.ozone.signature.findRelatedAccounts 6 6 + 7 7 + import ( 8 8 + "context" 9 9 + 10 10 + comatprototypes "github.com/bluesky-social/indigo/api/atproto" 11 11 + "github.com/bluesky-social/indigo/xrpc" 12 12 + ) 13 13 + 14 14 + // SignatureFindRelatedAccounts_Output is the output of a tools.ozone.signature.findRelatedAccounts call. 15 15 + type SignatureFindRelatedAccounts_Output struct { 16 16 + Accounts []*SignatureFindRelatedAccounts_RelatedAccount `json:"accounts" cborgen:"accounts"` 17 17 + Cursor *string `json:"cursor,omitempty" cborgen:"cursor,omitempty"` 18 18 + } 19 19 + 20 20 + // SignatureFindRelatedAccounts_RelatedAccount is a "relatedAccount" in the tools.ozone.signature.findRelatedAccounts schema. 21 21 + type SignatureFindRelatedAccounts_RelatedAccount struct { 22 22 + Account *comatprototypes.AdminDefs_AccountView `json:"account" cborgen:"account"` 23 23 + Similarities []*SignatureDefs_SigDetail `json:"similarities,omitempty" cborgen:"similarities,omitempty"` 24 24 + } 25 25 + 26 26 + // SignatureFindRelatedAccounts calls the XRPC method "tools.ozone.signature.findRelatedAccounts". 27 27 + func SignatureFindRelatedAccounts(ctx context.Context, c *xrpc.Client, cursor string, did string, limit int64) (*SignatureFindRelatedAccounts_Output, error) { 28 28 + var out SignatureFindRelatedAccounts_Output 29 29 + 30 30 + params := map[string]interface{}{ 31 31 + "cursor": cursor, 32 32 + "did": did, 33 33 + "limit": limit, 34 34 + } 35 35 + if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.signature.findRelatedAccounts", params, nil, &out); err != nil { 36 36 + return nil, err 37 37 + } 38 38 + 39 39 + return &out, nil 40 40 + }

+34

api/ozone/signaturesearchAccounts.go

reviewed

··· 1 1 + // Code generated by cmd/lexgen (see Makefile's lexgen); DO NOT EDIT. 2 2 + 3 3 + package ozone 4 4 + 5 5 + // schema: tools.ozone.signature.searchAccounts 6 6 + 7 7 + import ( 8 8 + "context" 9 9 + 10 10 + comatprototypes "github.com/bluesky-social/indigo/api/atproto" 11 11 + "github.com/bluesky-social/indigo/xrpc" 12 12 + ) 13 13 + 14 14 + // SignatureSearchAccounts_Output is the output of a tools.ozone.signature.searchAccounts call. 15 15 + type SignatureSearchAccounts_Output struct { 16 16 + Accounts []*comatprototypes.AdminDefs_AccountView `json:"accounts" cborgen:"accounts"` 17 17 + Cursor *string `json:"cursor,omitempty" cborgen:"cursor,omitempty"` 18 18 + } 19 19 + 20 20 + // SignatureSearchAccounts calls the XRPC method "tools.ozone.signature.searchAccounts". 21 21 + func SignatureSearchAccounts(ctx context.Context, c *xrpc.Client, cursor string, limit int64, values []string) (*SignatureSearchAccounts_Output, error) { 22 22 + var out SignatureSearchAccounts_Output 23 23 + 24 24 + params := map[string]interface{}{ 25 25 + "cursor": cursor, 26 26 + "limit": limit, 27 27 + "values": values, 28 28 + } 29 29 + if err := c.Do(ctx, xrpc.Query, "", "tools.ozone.signature.searchAccounts", params, nil, &out); err != nil { 30 30 + return nil, err 31 31 + } 32 32 + 33 33 + return &out, nil 34 34 + }

+2 -2

cmd/athome/handlers.go

reviewed

··· 85 85 did := pv.Did 86 86 data["did"] = did 87 87 88 88 - af, err := appbsky.FeedGetAuthorFeed(ctx, srv.xrpcc, handle.String(), "", "posts_no_replies", 100) 88 88 + af, err := appbsky.FeedGetAuthorFeed(ctx, srv.xrpcc, handle.String(), "", "posts_no_replies", false, 100) 89 89 if err != nil { 90 90 slog.Warn("failed to fetch author feed", "handle", handle, "err", err) 91 91 // TODO: show some error? ··· 126 126 //return err 127 127 } 128 128 129 129 - af, err := appbsky.FeedGetAuthorFeed(ctx, srv.xrpcc, handle.String(), "", "posts_no_replies", 30) 129 129 + af, err := appbsky.FeedGetAuthorFeed(ctx, srv.xrpcc, handle.String(), "", "posts_no_replies", false, 30) 130 130 if err != nil { 131 131 slog.Warn("failed to fetch author feed", "handle", handle, "err", err) 132 132 return err

+1 -1

cmd/goat/record.go

reviewed

··· 343 343 return err 344 344 } 345 345 346 346 - err = comatproto.RepoDeleteRecord(ctx, xrpcc, &comatproto.RepoDeleteRecord_Input{ 346 346 + _, err = comatproto.RepoDeleteRecord(ctx, xrpcc, &comatproto.RepoDeleteRecord_Input{ 347 347 Collection: collection.String(), 348 348 Repo: xrpcc.Auth.Did, 349 349 Rkey: rkey.String(),

+3 -2

cmd/gosky/bsky.go

reviewed

··· 178 178 author = xrpcc.Auth.Did 179 179 } 180 180 181 181 - tl, err := appbsky.FeedGetAuthorFeed(ctx, xrpcc, author, "", "", 99) 181 181 + tl, err := appbsky.FeedGetAuthorFeed(ctx, xrpcc, author, "", "", false, 99) 182 182 if err != nil { 183 183 return err 184 184 } ··· 314 314 rkey = parts[1] 315 315 } 316 316 317 317 - return comatproto.RepoDeleteRecord(context.TODO(), xrpcc, &comatproto.RepoDeleteRecord_Input{ 317 317 + _, err = comatproto.RepoDeleteRecord(context.TODO(), xrpcc, &comatproto.RepoDeleteRecord_Input{ 318 318 Repo: xrpcc.Auth.Did, 319 319 Collection: schema, 320 320 Rkey: rkey, 321 321 }) 322 322 + return err 322 323 }, 323 324 } 324 325

+2 -2

fakedata/generators.go

reviewed

··· 405 405 if err != nil { 406 406 return err 407 407 } 408 408 - _, err = appbsky.FeedGetAuthorFeed(context.TODO(), xrpcc, notif.Author.Did, "", "", 50) 408 408 + _, err = appbsky.FeedGetAuthorFeed(context.TODO(), xrpcc, notif.Author.Did, "", "", false, 50) 409 409 if err != nil { 410 410 return err 411 411 } ··· 447 447 if err != nil { 448 448 return err 449 449 } 450 450 - _, err = appbsky.FeedGetAuthorFeed(context.TODO(), xrpcc, post.Post.Author.Did, "", "", 50) 450 450 + _, err = appbsky.FeedGetAuthorFeed(context.TODO(), xrpcc, post.Post.Author.Did, "", "", false, 50) 451 451 if err != nil { 452 452 return err 453 453 }