+11

src/utils/firehose.ts

reviewed

··· 108 108 case "com.atproto.sync.subscribeRepos#commit": 109 109 this.emit("commit", message); 110 110 break; 111 111 + case "com.atproto.sync.subscribeRepos#sync": 112 112 + this.emit("sync", message); 113 113 + break; 111 114 default: 112 115 this.emit("unknown", message); 113 116 break; ··· 166 169 listener: ( 167 170 message: ComAtprotoSyncSubscribeRepos.Account & { 168 171 $type: "com.atproto.sync.subscribeRepos#account"; 172 172 + }, 173 173 + ) => void, 174 174 + ): this; 175 175 + override on( 176 176 + event: "sync", 177 177 + listener: ( 178 178 + message: ComAtprotoSyncSubscribeRepos.Sync & { 179 179 + $type: "com.atproto.sync.subscribeRepos#sync"; 169 180 }, 170 181 ) => void, 171 182 ): this;

+10

src/views/stream.tsx

reviewed

··· 115 115 firehose.on("account", (account) => { 116 116 setRecords(records().concat(account).slice(-LIMIT)); 117 117 }); 118 118 + firehose.on("sync", (sync) => { 119 119 + const event = { 120 120 + $type: sync.$type, 121 121 + did: sync.did, 122 122 + rev: sync.rev, 123 123 + seq: sync.seq, 124 124 + time: sync.time, 125 125 + }; 126 126 + setRecords(records().concat(event).slice(-LIMIT)); 127 127 + }); 118 128 firehose.start(); 119 129 } 120 130 };