fix: change es message structure

opengovern · Nov 5, 2024 · 149c160 · 149c160
1 parent d8f923c
commit 149c160
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 3 deletions.
diff --git a/go.mod b/go.mod
@@ -112,7 +112,7 @@ require (
 	github.com/microsoftgraph/msgraph-sdk-go v1.51.0
 	github.com/microsoftgraph/msgraph-sdk-go-core v1.2.1
 	github.com/nats-io/nats.go v1.36.0
-	github.com/opengovern/og-util v1.0.6-0.20241105205341-26a7e2e86ae7
+	github.com/opengovern/og-util v1.0.6-0.20241105213733-96098f54d56c
 	github.com/spf13/cobra v1.7.0
 	github.com/tombuildsstuff/giovanni v0.18.0
 	github.com/turbot/steampipe-plugin-sdk/v5 v5.10.1

diff --git a/go.sum b/go.sum
@@ -988,6 +988,8 @@ github.com/opengovern/og-util v1.0.6-0.20241105204626-bdedd0f03692 h1:oCH5XPdAfq
 github.com/opengovern/og-util v1.0.6-0.20241105204626-bdedd0f03692/go.mod h1:7l7fNhK6uewIwA0cs7QagJuhjt/E6hEAC01SR8Y0kKk=
 github.com/opengovern/og-util v1.0.6-0.20241105205341-26a7e2e86ae7 h1:uhGtBSoYsn4ZPNeKMSAc11x5UXPQb2Y+LJNvg6KF4kE=
 github.com/opengovern/og-util v1.0.6-0.20241105205341-26a7e2e86ae7/go.mod h1:7l7fNhK6uewIwA0cs7QagJuhjt/E6hEAC01SR8Y0kKk=
+github.com/opengovern/og-util v1.0.6-0.20241105213733-96098f54d56c h1:ZVMl52XNCTnL3Ye6zleHakK2QB27CON8PL17yEShUhI=
+github.com/opengovern/og-util v1.0.6-0.20241105213733-96098f54d56c/go.mod h1:7l7fNhK6uewIwA0cs7QagJuhjt/E6hEAC01SR8Y0kKk=
 github.com/opensearch-project/opensearch-go/v2 v2.3.0 h1:nQIEMr+A92CkhHrZgUhcfsrZjibvB3APXf2a1VwCmMQ=
 github.com/opensearch-project/opensearch-go/v2 v2.3.0/go.mod h1:8LDr9FCgUTVoT+5ESjc2+iaZuldqE+23Iq0r1XeNue8=
 github.com/pganalyze/pg_query_go/v4 v4.2.3 h1:cNLqyiVMasV7YGWyYV+fkXyHp32gDfXVNCqoHztEGNk=

diff --git a/pkg/describer/resource_sender.go b/pkg/describer/resource_sender.go
@@ -174,7 +174,6 @@ func (s *ResourceSender) flushBuffer(force bool) {
 			ResourceName:    resource.ResourceName,
 			IntegrationType: configs.IntegrationName,
 			ResourceType:    strings.ToLower(resource.ResourceType),
-			Location:        resource.Location,
 			IntegrationID:   resource.IntegrationID,
 			DescribedBy:     resource.DescribedBy,
 			DescribedAt:     resource.DescribedAt,

diff --git a/pkg/describer/worker.go b/pkg/describer/worker.go
@@ -150,7 +150,6 @@ func doDescribe(
 			PlatformID:          uuid.New().String(),
 			ResourceID:          resource.UniqueID(),
 			ResourceName:        resource.Name,
-			Location:            resource.Location,
 			Description:         description,
 			IntegrationType:     configs.IntegrationName,
 			ResourceType:        strings.ToLower(job.ResourceType),