388
}
389
391
>
treeID := uuid.NewString()
392
>
branchID := uuid.NewString()
393
>
branchToken, err := s.store.GetHistoryBranchUtil().NewHistoryBranch(
394
>
uuid.NewString(),
395
>
uuid.NewString(),
396
>
uuid.NewString(),
397
>
treeID,
398
>
&branchID,
399
>
[]*persistencespb.HistoryBranchRange{},
400
>
time.Duration(0),
401
>
time.Duration(0),
402
>
time.Duration(0),
403
>
)
404
>
s.NoError(err)
405
>
var events []*historypb.HistoryEvent
406
>
407
>
eventsPacket0 := s.newHistoryEvents(
408
>
[]int64{1, 2, 3},
409
>
rand.Int63(),
410
>
0,
411
>
)
412
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket0)
413
>
events = append(events, eventsPacket0.events...)
414
>
415
>
eventsPacket1 := s.newHistoryEvents(
416
>
[]int64{4, 5},
417
>
eventsPacket0.transactionID+1,
418
>
eventsPacket0.transactionID,
419
>
)
420
>
s.appendHistoryEvents(s.ShardID, branchToken, eventsPacket1)
421
>
events = append(events, eventsPacket1.events...)
422
>
423
>
s.appendHistoryEvents(s.ShardID, branchToken, s.newHistoryEvents(
424
>
[]int64{4, 5},
425
>
eventsPacket0.transactionID+2,
426
>
eventsPacket0.transactionID,
427
>
))
428
>
429
>
s.trimHistoryBranch(s.ShardID, branchToken, eventsPacket1.nodeID, eventsPacket1.transactionID)
430
>
431
>
protorequire.ProtoSliceEqual(s.T(), events, s.listAllHistoryEvents(s.ShardID, branchToken))
432
>
}
433
434
func (s *HistoryEventsSuite) TestAppendForkSelectTrim_NonLastBranch() {