Skip to content

Commit cd59536

Browse files
authored
Fixed bug where discovered intents were dropped in the mapper when collecting and parsing data from the sniffer (#295)
1 parent bec1b4c commit cd59536

File tree

6 files changed

+290
-30
lines changed

6 files changed

+290
-30
lines changed

src/mapper/pkg/clouduploader/cloud_uploader_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ func (s *CloudUploaderTestSuite) addIntent(source string, srcNamespace string, d
5050
testTimestamp,
5151
model.Intent{
5252
Client: &model.OtterizeServiceIdentity{Name: source, Namespace: srcNamespace},
53-
Server: &model.OtterizeServiceIdentity{Name: destination, Namespace: dstNamespace},
53+
Server: &model.OtterizeServiceIdentity{Name: destination, Namespace: dstNamespace, ResolutionData: lo.ToPtr(model.IdentityResolutionData{})},
5454
ResolutionData: lo.ToPtr("handleInternalTrafficTCPResult"),
5555
},
5656
[]int64{int64(20205)},
@@ -145,7 +145,7 @@ func (s *CloudUploaderTestSuite) TestUploadIncomingTrafficIntents() {
145145
func (s *CloudUploaderTestSuite) TestUploadIntentsWithOperations() {
146146
discoveredProduce := model.Intent{
147147
Client: &model.OtterizeServiceIdentity{Name: "client1", Namespace: s.testNamespace},
148-
Server: &model.OtterizeServiceIdentity{Name: "server1", Namespace: s.testNamespace},
148+
Server: &model.OtterizeServiceIdentity{Name: "server1", Namespace: s.testNamespace, ResolutionData: lo.ToPtr(model.IdentityResolutionData{})},
149149
Type: lo.ToPtr(model.IntentTypeKafka),
150150
KafkaTopics: []model.KafkaConfig{
151151
{
@@ -159,7 +159,7 @@ func (s *CloudUploaderTestSuite) TestUploadIntentsWithOperations() {
159159

160160
discoveredConsume := model.Intent{
161161
Client: &model.OtterizeServiceIdentity{Name: "client1", Namespace: s.testNamespace},
162-
Server: &model.OtterizeServiceIdentity{Name: "server1", Namespace: s.testNamespace},
162+
Server: &model.OtterizeServiceIdentity{Name: "server1", Namespace: s.testNamespace, ResolutionData: lo.ToPtr(model.IdentityResolutionData{})},
163163
Type: lo.ToPtr(model.IntentTypeKafka),
164164
KafkaTopics: []model.KafkaConfig{
165165
{

src/mapper/pkg/graph/generated/generated.go

Lines changed: 232 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/mapper/pkg/graph/model/models_gen.go

Lines changed: 15 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)