Source code for pipeline.src.entities.data_exchange_standards

from enum import Enum



[docs]
class ZippedFileType(Enum):

[docs]
    ERS3_JBE = "ERS3_JBE"


[docs]
    ERS3_ACK_JBE = "ERS3_ACK_JBE"


[docs]
    UN_JBE = "UN_JBE"


[docs]
    UN_NVE = "UN_NVE"


[docs]
    ERS3_NVE = "ERS3_NVE"





[docs]
class TransmissionFormat(Enum):

[docs]
    ERS = "ERS"


[docs]
    FLUX = "FLUX"


    @staticmethod

[docs]
    def from_zipped_file_type(t: ZippedFileType):
        mapping = {
            ZippedFileType.ERS3_JBE: TransmissionFormat.ERS,
            ZippedFileType.ERS3_ACK_JBE: TransmissionFormat.ERS,
            ZippedFileType.ERS3_NVE: TransmissionFormat.ERS,
            ZippedFileType.UN_JBE: TransmissionFormat.FLUX,
            ZippedFileType.UN_NVE: TransmissionFormat.FLUX,
        }
        return mapping[t]





[docs]
class DataDomain(Enum):

[docs]
    SALES = "SALES"


[docs]
    LOGBOOK = "LOGBOOK"


    @staticmethod

[docs]
    def from_zipped_file_type(t: ZippedFileType):
        mapping = {
            ZippedFileType.ERS3_JBE: DataDomain.LOGBOOK,
            ZippedFileType.ERS3_ACK_JBE: DataDomain.LOGBOOK,
            ZippedFileType.UN_JBE: DataDomain.LOGBOOK,
            ZippedFileType.UN_NVE: DataDomain.SALES,
            ZippedFileType.ERS3_NVE: DataDomain.SALES,
        }
        return mapping[t]