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.

consumer: enforce seq number ordering (drop replays at socket level)

bryan newbold c5ee16bf 3185880b

+24 -16
+24 -16
cmd/relay/stream/consumer.go
··· 218 218 return fmt.Errorf("reading repoCommit event: %w", err) 219 219 } 220 220 221 - if evt.Seq < lastSeq { 222 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 221 + if evt.Seq <= lastSeq { 222 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 223 + continue 223 224 } 224 225 225 226 lastSeq = evt.Seq ··· 235 236 return fmt.Errorf("reading repoSync event: %w", err) 236 237 } 237 238 238 - if evt.Seq < lastSeq { 239 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 239 + if evt.Seq <= lastSeq { 240 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 241 + continue 240 242 } 241 243 242 244 lastSeq = evt.Seq ··· 253 255 return err 254 256 } 255 257 256 - if evt.Seq < lastSeq { 257 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 258 + if evt.Seq <= lastSeq { 259 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 260 + continue 258 261 } 259 262 lastSeq = evt.Seq 260 263 ··· 269 272 return err 270 273 } 271 274 272 - if evt.Seq < lastSeq { 273 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 275 + if evt.Seq <= lastSeq { 276 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 277 + continue 274 278 } 275 279 lastSeq = evt.Seq 276 280 ··· 285 289 return err 286 290 } 287 291 288 - if evt.Seq < lastSeq { 289 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 292 + if evt.Seq <= lastSeq { 293 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 294 + continue 290 295 } 291 296 lastSeq = evt.Seq 292 297 ··· 314 319 return err 315 320 } 316 321 317 - if evt.Seq < lastSeq { 318 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 322 + if evt.Seq <= lastSeq { 323 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 324 + continue 319 325 } 320 326 lastSeq = evt.Seq 321 327 ··· 331 337 return err 332 338 } 333 339 334 - if evt.Seq < lastSeq { 335 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 340 + if evt.Seq <= lastSeq { 341 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 342 + continue 336 343 } 337 344 lastSeq = evt.Seq 338 345 ··· 347 354 return fmt.Errorf("reading Labels event: %w", err) 348 355 } 349 356 350 - if evt.Seq < lastSeq { 351 - logger.Error("Got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 357 + if evt.Seq <= lastSeq { 358 + logger.Error("got events out of order from stream", "seq", evt.Seq, "prev", lastSeq) 359 + continue 352 360 } 353 361 354 362 lastSeq = evt.Seq