Skip to content

Commit a8a314f

Browse files
committed
fix: subscriptions historical filtering
- a subscription always has a transport Signed-off-by: Enrique Lacal <[email protected]>
1 parent 5adbdfc commit a8a314f

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

internal/events/event_manager.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -311,8 +311,6 @@ func (em *eventManager) QueueBatchRewind(batchID *fftypes.UUID) {
311311
}
312312

313313
func (em *eventManager) FilterHistoricalEventsOnSubscription(ctx context.Context, events []*core.EnrichedEvent, sub *core.Subscription) ([]*core.EnrichedEvent, error) {
314-
// Transport must be provided for validation, but we're not using it for event delivery so fake the transport
315-
sub.Transport = "websockets"
316314
subscriptionDef, err := em.subManager.parseSubscriptionDef(ctx, sub)
317315
if err != nil {
318316
return nil, err

internal/events/event_manager_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -664,6 +664,7 @@ func TestEventFilterOnSubscriptionMatchesEventType(t *testing.T) {
664664
}
665665

666666
subscription := &core.Subscription{
667+
Transport: "websockets",
667668
Filter: core.SubscriptionFilter{
668669
Events: core.EventTypeIdentityConfirmed.String(),
669670
},

0 commit comments

Comments
 (0)