Method TestWithAnyFilter

database/watcher/watcher_test.go:172–252

()

}

func (s *WatcherTestSuite) TestWithAnyFilter() {
	producer, err := watcher.RegisterProducer(s.ctx, "test-producer")
	s.Require().NoError(err)
	s.Require().NotNil(producer)

	consumer, err := watcher.RegisterConsumer(
		s.ctx, "test-consumer",
		watcher.WithAny(
			watcher.WithEntityTypeFilter(common.ControllerEntityType),
			watcher.WithEntityFilter(params.ForgeEntity{
				EntityType: params.ForgeEntityTypeRepository,
				Owner:      "test",
				Name:       "test",
				ID:         "test",
			}),
		))
	s.Require().NoError(err)
	s.Require().NotNil(consumer)
	consumeEvents(consumer)

	payload := common.ChangePayload{
		EntityType: common.ControllerEntityType,
		Operation:  common.UpdateOperation,
		Payload:    "test",
	}
	err = producer.Notify(payload)
	s.Require().NoError(err)

	receivedPayload := waitForPayload(consumer.Watch(), 100*time.Millisecond)
	s.Require().NotNil(receivedPayload)
	s.Require().Equal(payload, *receivedPayload)

	payload = common.ChangePayload{
		EntityType: common.RepositoryEntityType,
		Operation:  common.UpdateOperation,
		Payload: params.Repository{
			Owner: "test",
			Name:  "test",
			ID:    "test",
		},
	}

	err = producer.Notify(payload)
	s.Require().NoError(err)

	receivedPayload = waitForPayload(consumer.Watch(), 100*time.Millisecond)
	s.Require().NotNil(receivedPayload)
	s.Require().Equal(payload, *receivedPayload)

	// We're not watching for this repo
	payload = common.ChangePayload{
		EntityType: common.RepositoryEntityType,
		Operation:  common.UpdateOperation,
		Payload: params.Repository{
			Owner: "test",
			Name:  "test",
			ID:    "test2",
		},