From d8f923ce798f337b4c03f701d10610067eb6f70b Mon Sep 17 00:00:00 2001
From: artaasadi <arta-c@kaytu.io>
Date: Tue, 5 Nov 2024 22:28:41 +0100
Subject: [PATCH] fix: change es message structure

---
 pkg/describer/resource_sender.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pkg/describer/resource_sender.go b/pkg/describer/resource_sender.go
index f816fbeb..04b21c4e 100755
--- a/pkg/describer/resource_sender.go
+++ b/pkg/describer/resource_sender.go
@@ -111,7 +111,7 @@ func (s *ResourceSender) ResourceHandler() {
 				return
 			}
 
-			s.resourceIDs = append(s.resourceIDs, resource.ID)
+			s.resourceIDs = append(s.resourceIDs, resource.ResourceID)
 			s.sendBuffer = append(s.sendBuffer, resource)
 
 			if len(s.sendBuffer) > MaxBufferSize {
@@ -169,7 +169,7 @@ func (s *ResourceSender) flushBuffer(force bool) {
 		kafkaResource.EsIndex = idx
 
 		lookupResource := es.LookupResource{
-			ProviderID:      resource.ProviderID,
+			PlatformID:      resource.PlatformID,
 			ResourceID:      resource.ResourceID,
 			ResourceName:    resource.ResourceName,
 			IntegrationType: configs.IntegrationName,