Skip to content

Commit e47cd74

Browse files
authored
Merge pull request #27 from Arkiv-Network/fix-expiry-on-extend
fix bug where BTL extension extends relative to the current block
2 parents 2339784 + b8f030a commit e47cd74

3 files changed

Lines changed: 6 additions & 6 deletions

File tree

pusher/push_iterator_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -433,7 +433,7 @@ var _ = Describe("PushIterator", func() {
433433
return err
434434
}
435435
newExpiration := row.NumericAttributes.Values["$expiration"]
436-
Expect(newExpiration).To(Equal(uint64(1200)))
436+
Expect(newExpiration).To(Equal(uint64(1600)))
437437
return nil
438438
})
439439
Expect(err).NotTo(HaveOccurred())

sqlitestore.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -374,13 +374,13 @@ func (s *SQLiteStore) FollowEvents(ctx context.Context, iterator arkivevents.Bat
374374

375375
oldNumericAttributes := latestPayload.NumericAttributes
376376

377-
newToBlock := block.Number + operation.ExtendBTL.BTL
377+
oldExpiration := oldNumericAttributes.Values["$expiration"]
378+
379+
newToBlock := oldExpiration + operation.ExtendBTL.BTL
378380

379381
numericAttributes := maps.Clone(oldNumericAttributes.Values)
380382
numericAttributes["$expiration"] = uint64(newToBlock)
381383

382-
oldExpiration := oldNumericAttributes.Values["$expiration"]
383-
384384
id, err := st.UpsertPayload(ctx, store.UpsertPayloadParams{
385385
EntityKey: key,
386386
Payload: latestPayload.Payload,

sqlitestore_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -598,7 +598,7 @@ var _ = Describe("SQLiteStore", func() {
598598
row, err := q.GetPayloadForEntityKey(ctx, key.Bytes())
599599
Expect(err).NotTo(HaveOccurred())
600600
newExpiration := row.NumericAttributes.Values["$expiration"]
601-
Expect(newExpiration).To(Equal(uint64(1200))) // 200 + 1000
601+
Expect(newExpiration).To(Equal(uint64(1600)))
602602

603603
// Verify old expiration bitmap is removed
604604
oldExpBitmap, err := q.EvaluateNumericAttributeValueEqual(ctx, store.EvaluateNumericAttributeValueEqualParams{
@@ -610,7 +610,7 @@ var _ = Describe("SQLiteStore", func() {
610610
// Verify new expiration bitmap exists
611611
newExpBitmap, err := q.EvaluateNumericAttributeValueEqual(ctx, store.EvaluateNumericAttributeValueEqualParams{
612612
Name: "$expiration",
613-
Value: 1200,
613+
Value: 1600,
614614
})
615615
Expect(err).NotTo(HaveOccurred())
616616
Expect(newExpBitmap.ToArray()).To(HaveLen(1))

0 commit comments

Comments
 (0)