X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pm-file-converter%2Fcommon%2FdataTypes%2FdataTypes.go;fp=pm-file-converter%2Fcommon%2FdataTypes%2FdataTypes.go;h=66b462cf487ee709c174b29c7daf06e8bdcd4042;hb=0bb219edead30bb0459abd2cd2163326c97ca92d;hp=0000000000000000000000000000000000000000;hpb=08e640604edf8056bfe35155c04e88653e1872c4;p=nonrtric%2Fplt%2Franpm.git

diff --git a/pm-file-converter/common/dataTypes/dataTypes.go b/pm-file-converter/common/dataTypes/dataTypes.go
new file mode 100644
index 0000000..66b462c
--- /dev/null
+++ b/pm-file-converter/common/dataTypes/dataTypes.go
@@ -0,0 +1,230 @@
+// -
+//
+//      ========================LICENSE_START=================================
+//      O-RAN-SC
+//      %%
+//      Copyright (C) 2023: Nordix Foundation
+//      %%
+//      Licensed under the Apache License, Version 2.0 (the "License");
+//      you may not use this file except in compliance with the License.
+//      You may obtain a copy of the License at
+//
+//           http://www.apache.org/licenses/LICENSE-2.0
+//
+//      Unless required by applicable law or agreed to in writing, software
+//      distributed under the License is distributed on an "AS IS" BASIS,
+//      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//      See the License for the specific language governing permissions and
+//      limitations under the License.
+//      ========================LICENSE_END===================================
+
+package dataTypes
+
+import (
+        "encoding/xml"
+	"github.com/confluentinc/confluent-kafka-go/kafka"
+)
+
+// // Data type for event xml file download
+type XmlFileEventHeader struct {
+	ProductName        string `json:"productName"`
+	VendorName         string `json:"vendorName"`
+	Location           string `json:"location"`
+	Compression        string `json:"compression"`
+	SourceName         string `json:"sourceName"`
+	FileFormatType     string `json:"fileFormatType"`
+	FileFormatVersion  string `json:"fileFormatVersion"`
+	StartEpochMicrosec int64  `json:"startEpochMicrosec"`
+	LastEpochMicrosec  int64  `json:"lastEpochMicrosec"`
+	Name               string `json:"name"`
+	ChangeIdentifier   string `json:"changeIdentifier"`
+	InternalLocation   string `json:"internalLocation"`
+	TimeZoneOffset     string `json:"timeZoneOffset"`
+	ObjectStoreBucket  string `json:"objectStoreBucket"`
+}
+
+// Data types for input xml file
+type MeasCollecFile struct {
+	XMLName        xml.Name `xml:"measCollecFile"`
+	Text           string   `xml:",chardata"`
+	Xmlns          string   `xml:"xmlns,attr"`
+	Xsi            string   `xml:"xsi,attr"`
+	SchemaLocation string   `xml:"schemaLocation,attr"`
+	FileHeader     struct {
+		Text              string `xml:",chardata"`
+		FileFormatVersion string `xml:"fileFormatVersion,attr"`
+		VendorName        string `xml:"vendorName,attr"`
+		DnPrefix          string `xml:"dnPrefix,attr"`
+		FileSender        struct {
+			Text        string `xml:",chardata"`
+			LocalDn     string `xml:"localDn,attr"`
+			ElementType string `xml:"elementType,attr"`
+		} `xml:"fileSender"`
+		MeasCollec struct {
+			Text      string `xml:",chardata"`
+			BeginTime string `xml:"beginTime,attr"`
+		} `xml:"measCollec"`
+	} `xml:"fileHeader"`
+	MeasData struct {
+		Text           string `xml:",chardata"`
+		ManagedElement struct {
+			Text      string `xml:",chardata"`
+			LocalDn   string `xml:"localDn,attr"`
+			SwVersion string `xml:"swVersion,attr"`
+		} `xml:"managedElement"`
+		MeasInfo []struct {
+			Text       string `xml:",chardata"`
+			MeasInfoId string `xml:"measInfoId,attr"`
+			Job        struct {
+				Text  string `xml:",chardata"`
+				JobId string `xml:"jobId,attr"`
+			} `xml:"job"`
+			GranPeriod struct {
+				Text     string `xml:",chardata"`
+				Duration string `xml:"duration,attr"`
+				EndTime  string `xml:"endTime,attr"`
+			} `xml:"granPeriod"`
+			RepPeriod struct {
+				Text     string `xml:",chardata"`
+				Duration string `xml:"duration,attr"`
+			} `xml:"repPeriod"`
+			MeasType []struct {
+				Text string `xml:",chardata"`
+				P    string `xml:"p,attr"`
+			} `xml:"measType"`
+			MeasValue []struct {
+				Text       string `xml:",chardata"`
+				MeasObjLdn string `xml:"measObjLdn,attr"`
+				R          []struct {
+					Text string `xml:",chardata"`
+					P    string `xml:"p,attr"`
+				} `xml:"r"`
+				Suspect string `xml:"suspect"`
+			} `xml:"measValue"`
+		} `xml:"measInfo"`
+	} `xml:"measData"`
+	FileFooter struct {
+		Text       string `xml:",chardata"`
+		MeasCollec struct {
+			Text    string `xml:",chardata"`
+			EndTime string `xml:"endTime,attr"`
+		} `xml:"measCollec"`
+	} `xml:"fileFooter"`
+}
+
+// Splitted in sevreal part to allow add/remove in lists
+type MeasResults struct {
+	P      int    `json:"p"`
+	SValue string `json:"sValue"`
+}
+
+type MeasValues struct {
+	MeasObjInstID   string        `json:"measObjInstId"`
+	SuspectFlag     string        `json:"suspectFlag"`
+	MeasResultsList []MeasResults `json:"measResults"`
+}
+
+type SMeasTypes struct {
+	SMeasType string `json:"sMeasTypesList"`
+}
+
+type MeasInfoList struct {
+	MeasInfoID struct {
+		SMeasInfoID string `json:"sMeasInfoId"`
+	} `json:"measInfoId"`
+	MeasTypes struct {
+		SMeasTypesList []string `json:"sMeasTypesList"`
+	} `json:"measTypes"`
+	MeasValuesList []MeasValues `json:"measValuesList"`
+}
+
+type PMJsonFile struct {
+	Event struct {
+		CommonEventHeader struct {
+			Domain                  string `json:"domain"`
+			EventID                 string `json:"eventId"`
+			Sequence                int    `json:"sequence"`
+			EventName               string `json:"eventName"`
+			SourceName              string `json:"sourceName"`
+			ReportingEntityName     string `json:"reportingEntityName"`
+			Priority                string `json:"priority"`
+			StartEpochMicrosec      int64  `json:"startEpochMicrosec"`
+			LastEpochMicrosec       int64  `json:"lastEpochMicrosec"`
+			Version                 string `json:"version"`
+			VesEventListenerVersion string `json:"vesEventListenerVersion"`
+			TimeZoneOffset          string `json:"timeZoneOffset"`
+		} `json:"commonEventHeader"`
+		Perf3GppFields struct {
+			Perf3GppFieldsVersion string `json:"perf3gppFieldsVersion"`
+			MeasDataCollection    struct {
+				GranularityPeriod             int            `json:"granularityPeriod"`
+				MeasuredEntityUserName        string         `json:"measuredEntityUserName"`
+				MeasuredEntityDn              string         `json:"measuredEntityDn"`
+				MeasuredEntitySoftwareVersion string         `json:"measuredEntitySoftwareVersion"`
+				SMeasInfoList                 []MeasInfoList `json:"measInfoList"`
+			} `json:"measDataCollection"`
+		} `json:"perf3gppFields"`
+	} `json:"event"`
+}
+
+type FileDownloadedEvt struct {
+	Filename string `json:"filename"`
+}
+
+type KafkaPayload struct {
+	Msg   *kafka.Message
+	Topic string
+}
+
+// Type for controlling the topic reader
+type ReaderControl struct {
+	Command string
+}
+
+// Type for controlling the topic writer
+type WriterControl struct {
+	Command string
+}
+
+// == API Datatypes ==//
+// Type for supported data types
+type DataType struct {
+	ID                 string `json:"id"`
+	KafkaInputTopic    string `json:"kafkaInputTopic"`
+	InputJobType       string `json:inputJobType`
+	InputJobDefinition struct {
+		KafkaOutputTopic string `json:kafkaOutputTopic`
+	} `json:inputJobDefinition`
+
+	Ext_job         *[]byte
+	Ext_job_created bool
+	Ext_job_id      string
+}
+
+// Type for controlling the job
+type JobControl struct {
+	Command string
+	//Filter  Filter
+}
+
+type AppStates int64
+
+var InfoTypes DataTypes
+
+// Keep all info type jobs, key == type id
+var TypeJobs map[string]TypeJobRecord = make(map[string]TypeJobRecord)
+
+// Type for an infojob
+type TypeJobRecord struct {
+	InfoType        string
+	InputTopic      string
+	Data_in_channel chan *KafkaPayload
+	Reader_control  chan ReaderControl
+	Job_control     chan JobControl
+	GroupId         string
+	ClientId        string
+}
+
+type DataTypes struct {
+	ProdDataTypes []DataType `json:"types"`
+}