+11

src/lib/firehose.ts

reviewed

··· 108 108 case "com.atproto.sync.subscribeRepos#identity": 109 109 this.emit("identity", message); 110 110 break; 111 111 + case "com.atproto.sync.subscribeRepos#account": 112 112 + this.emit("account", message); 113 113 + break; 111 114 case "com.atproto.sync.subscribeRepos#info": 112 115 this.emit("info", message); 113 116 break; ··· 200 203 listener: ( 201 204 message: ComAtprotoSyncSubscribeRepos.Identity & { 202 205 $type: "com.atproto.sync.subscribeRepos#identity"; 206 206 + }, 207 207 + ) => void, 208 208 + ): this; 209 209 + override on( 210 210 + event: "account", 211 211 + listener: ( 212 212 + message: ComAtprotoSyncSubscribeRepos.Account & { 213 213 + $type: "com.atproto.sync.subscribeRepos#account"; 203 214 }, 204 215 ) => void, 205 216 ): this;

+3

src/views/subscribeRepos.tsx

reviewed

··· 60 60 firehose.on("identity", (identity) => { 61 61 setRecords(records().concat(identity).slice(-LIMIT)); 62 62 }); 63 63 + firehose.on("account", (account) => { 64 64 + setRecords(records().concat(account).slice(-LIMIT)); 65 65 + }); 63 66 firehose.start(); 64 67 }); 65 68