fixed schema & logs

pkg/port/cli/integration.go

@@ -5,10 +5,27 @@ import (
 	"github.com/port-labs/port-k8s-exporter/pkg/port"
 )
 
+func parseIntegration(i *port.Integration) *port.Integration {
+	x := &port.Integration{
+		Title:               i.Title,
+		InstallationAppType: i.InstallationAppType,
+		InstallationId:      i.InstallationId,
+		Config:              i.Config,
+	}
+
+	if i.EventListener.Type == "KAFKA" {
+		x.EventListener = port.EventListenerSettings{
+			Type: i.EventListener.Type,
+		}
+	}
+
+	return x
+}
+
 func (c *PortClient) CreateIntegration(i *port.Integration) (*port.Integration, error) {
 	pb := &port.ResponseBody{}
 	resp, err := c.Client.R().
-		SetBody(i).
+		SetBody(parseIntegration(i)).
 		SetResult(&pb).
 		SetQueryParam("upsert", "true").
 		Post("v1/integration")

pkg/port/cli/kafka_crednetials.go

@@ -14,7 +14,7 @@ func (c *PortClient) GetKafkaCredentials() (*port.OrgKafkaCredentials, error) {
 		return nil, err
 	}
 	if !pb.OK {
-		return nil, fmt.Errorf("failed to create integration, got: %s", resp.Body())
+		return nil, fmt.Errorf("failed to get kafka crednetials, got: %s", resp.Body())
 	}
 	return &pb.KafkaCredentials, nil
 }

pkg/port/cli/org_details.go

@@ -19,7 +19,7 @@ func (c *PortClient) GetOrgId() (string, error) {
 		return "", err
 	}
 	if !pb.OK {
-		return "", fmt.Errorf("failed to create integration, got: %s", resp.Body())
+		return "", fmt.Errorf("failed to get orgId, got: %s", resp.Body())
 	}
 	return pb.OrgDetails.OrgId, nil
 }

pkg/port/models.go

@@ -144,34 +144,34 @@ type ResponseBody struct {
 }
 
 type EntityMapping struct {
-	Identifier string
-	Title      string
-	Blueprint  string
-	Team       string
-	Properties map[string]string
-	Relations  map[string]string
+	Identifier string            `json:"identifier"`
+	Title      string            `json:"title"`
+	Blueprint  string            `json:"blueprint"`
+	Team       string            `json:"team"`
+	Properties map[string]string `json:"properties,omitempty"`
+	Relations  map[string]string `json:"relations,omitempty"`
 }
 
 type EntityMappings struct {
-	Mappings []EntityMapping
+	Mappings []EntityMapping `json:"mappings"`
 }
 
 type Port struct {
-	Entity EntityMappings
+	Entity EntityMappings `json:"entity"`
 }
 
 type Selector struct {
 	Query string
 }
 
 type Resource struct {
-	Kind     string
-	Selector Selector
-	Port     Port
+	Kind     string   `json:"kind"`
+	Selector Selector `json:"selector,omitempty"`
+	Port     Port     `json:"port"`
 }
 
 type EventListenerSettings struct {
-	Type string `json:"type"`
+	Type string `json:"type,omitempty"`
 }
 
 type KindConfig struct {