Skip to content

Commit 4c7a15c

Browse files
authored
refactor(sync): drop storeHeaders helper (#193)
## Overview Make `store` field usage explicit. Plus `storeHeaders` was just a wrapper around `store.Append` without any logic.
1 parent cd70c84 commit 4c7a15c

File tree

2 files changed

+3
-14
lines changed

2 files changed

+3
-14
lines changed

sync/sync.go

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -290,7 +290,7 @@ func (s *Syncer[H]) processHeaders(
290290
}
291291

292292
// apply cached headers
293-
if err = s.storeHeaders(ctx, headers...); err != nil {
293+
if err := s.store.Append(ctx, headers...); err != nil {
294294
return err
295295
}
296296

@@ -325,7 +325,7 @@ func (s *Syncer[H]) requestHeaders(
325325
return err
326326
}
327327

328-
if err := s.storeHeaders(ctx, headers...); err != nil {
328+
if err := s.store.Append(ctx, headers...); err != nil {
329329
return err
330330
}
331331

@@ -334,14 +334,3 @@ func (s *Syncer[H]) requestHeaders(
334334
}
335335
return nil
336336
}
337-
338-
// storeHeaders updates store with new headers and updates current syncStore's Head.
339-
func (s *Syncer[H]) storeHeaders(ctx context.Context, headers ...H) error {
340-
// we don't expect any issues in storing right now, as all headers are now verified.
341-
// So, we should return immediately in case an error appears.
342-
err := s.store.Append(ctx, headers...)
343-
if err != nil {
344-
return err
345-
}
346-
return nil
347-
}

sync/sync_head.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ func (s *Syncer[H]) setSubjectiveHead(ctx context.Context, netHead H) {
118118
// * Allow storing any valid header here in Store
119119
// * Remove ErrNonAdjacent
120120
// * Remove writeHead from the canonical store implementation
121-
err := s.storeHeaders(ctx, netHead)
121+
err := s.store.Append(ctx, netHead)
122122
var nonAdj *header.ErrNonAdjacent
123123
if err != nil && !errors.As(err, &nonAdj) {
124124
// might be a storage error or something else, but we can still try to continue processing netHead

0 commit comments

Comments
 (0)