hat.drivers.iec60870.encodings.iec101

12class AsduTypeError(Exception):
13    pass

 8class CauseSize(enum.Enum):
 9    ONE = 1
10    TWO = 2

13class AsduAddressSize(enum.Enum):
14    ONE = 1
15    TWO = 2

18class IoAddressSize(enum.Enum):
19    ONE = 1
20    TWO = 2
21    THREE = 3

24class TimeSize(enum.Enum):
25    TWO = 2
26    THREE = 3
27    FOUR = 4
28    SEVEN = 7

31class Time(typing.NamedTuple):
32    size: TimeSize
33    milliseconds: int
34    """milliseconds in range [0, 59999]"""
35    invalid: bool | None
36    """available for size THREE, FOUR, SEVEN"""
37    minutes: int | None
38    """available for size THREE, FOUR, SEVEN (minutes in range [0, 59])"""
39    summer_time: bool | None
40    """available for size FOUR, SEVEN"""
41    hours: int | None
42    """available for size FOUR, SEVEN (hours in range [0, 23])"""
43    day_of_week: int | None
44    """available for size SEVEN (day_of_week in range [1, 7])"""
45    day_of_month: int | None
46    """available for size SEVEN (day_of_month in range [1, 31])"""
47    months: int | None
48    """available for size SEVEN (months in range [1, 12])"""
49    years: int | None
50    """available for size SEVEN (years in range [0, 99])"""

66def time_from_datetime(dt: datetime.datetime,
67                       invalid: bool = False
68                       ) -> Time:
69    """Create Time from datetime.datetime"""
70    # TODO document edge cases (local time, os implementation, ...)
71    #  rounding microseconds to the nearest millisecond
72    dt_rounded = (
73        dt.replace(microsecond=0) +
74        datetime.timedelta(milliseconds=round(dt.microsecond / 1000)))
75    local_time = time.localtime(dt_rounded.timestamp())
76
77    return Time(
78        size=TimeSize.SEVEN,
79        milliseconds=(local_time.tm_sec * 1000 +
80                      dt_rounded.microsecond // 1000),
81        invalid=invalid,
82        minutes=local_time.tm_min,
83        summer_time=bool(local_time.tm_isdst),
84        hours=local_time.tm_hour,
85        day_of_week=local_time.tm_wday + 1,
86        day_of_month=local_time.tm_mday,
87        months=local_time.tm_mon,
88        years=local_time.tm_year % 100)

 91def time_to_datetime(t: Time
 92                     ) -> datetime.datetime:
 93    """Convert Time to datetime.datetime"""
 94    # TODO document edge cases (local time, os implementation, ...)
 95    # TODO maybe allow diferent time size (use now for time)
 96    if t.size != TimeSize.SEVEN:
 97        raise ValueError('unsupported time size')
 98
 99    local_dt = datetime.datetime(
100        year=2000 + t.years if t.years < 70 else 1900 + t.years,
101        month=t.months,
102        day=t.day_of_month,
103        hour=t.hours,
104        minute=t.minutes,
105        second=int(t.milliseconds / 1000),
106        microsecond=(t.milliseconds % 1000) * 1000,
107        fold=not t.summer_time)
108
109    return local_dt.astimezone(tz=datetime.timezone.utc)

29class AsduType(enum.Enum):
30    M_SP_NA = 1
31    M_SP_TA = 2
32    M_DP_NA = 3
33    M_DP_TA = 4
34    M_ST_NA = 5
35    M_ST_TA = 6
36    M_BO_NA = 7
37    M_BO_TA = 8
38    M_ME_NA = 9
39    M_ME_TA = 10
40    M_ME_NB = 11
41    M_ME_TB = 12
42    M_ME_NC = 13
43    M_ME_TC = 14
44    M_IT_NA = 15
45    M_IT_TA = 16
46    M_EP_TA = 17
47    M_EP_TB = 18
48    M_EP_TC = 19
49    M_PS_NA = 20
50    M_ME_ND = 21
51    M_SP_TB = 30
52    M_DP_TB = 31
53    M_ST_TB = 32
54    M_BO_TB = 33
55    M_ME_TD = 34
56    M_ME_TE = 35
57    M_ME_TF = 36
58    M_IT_TB = 37
59    M_EP_TD = 38
60    M_EP_TE = 39
61    M_EP_TF = 40
62    C_SC_NA = 45
63    C_DC_NA = 46
64    C_RC_NA = 47
65    C_SE_NA = 48
66    C_SE_NB = 49
67    C_SE_NC = 50
68    C_BO_NA = 51
69    M_EI_NA = 70
70    C_IC_NA = 100
71    C_CI_NA = 101
72    C_RD_NA = 102
73    C_CS_NA = 103
74    C_TS_NA = 104
75    C_RP_NA = 105
76    C_CD_NA = 106
77    P_ME_NA = 110
78    P_ME_NB = 111
79    P_ME_NC = 112
80    P_AC_NA = 113
81    F_FR_NA = 120
82    F_SR_NA = 121
83    F_SC_NA = 122
84    F_LS_NA = 123
85    F_AF_NA = 124
86    F_SG_NA = 125
87    F_DR_TA = 126

 90class CauseType(enum.Enum):
 91    UNDEFINED = 0
 92    PERIODIC = 1
 93    BACKGROUND_SCAN = 2
 94    SPONTANEOUS = 3
 95    INITIALIZED = 4
 96    REQUEST = 5
 97    ACTIVATION = 6
 98    ACTIVATION_CONFIRMATION = 7
 99    DEACTIVATION = 8
100    DEACTIVATION_CONFIRMATION = 9
101    ACTIVATION_TERMINATION = 10
102    REMOTE_COMMAND = 11
103    LOCAL_COMMAND = 12
104    FILE_TRANSFER = 13
105    INTERROGATED_STATION = 20
106    INTERROGATED_GROUP01 = 21
107    INTERROGATED_GROUP02 = 22
108    INTERROGATED_GROUP03 = 23
109    INTERROGATED_GROUP04 = 24
110    INTERROGATED_GROUP05 = 25
111    INTERROGATED_GROUP06 = 26
112    INTERROGATED_GROUP07 = 27
113    INTERROGATED_GROUP08 = 28
114    INTERROGATED_GROUP09 = 29
115    INTERROGATED_GROUP10 = 30
116    INTERROGATED_GROUP11 = 31
117    INTERROGATED_GROUP12 = 32
118    INTERROGATED_GROUP13 = 33
119    INTERROGATED_GROUP14 = 34
120    INTERROGATED_GROUP15 = 35
121    INTERROGATED_GROUP16 = 36
122    INTERROGATED_COUNTER = 37
123    INTERROGATED_COUNTER01 = 38
124    INTERROGATED_COUNTER02 = 39
125    INTERROGATED_COUNTER03 = 40
126    INTERROGATED_COUNTER04 = 41
127    UNKNOWN_TYPE = 44
128    UNKNOWN_CAUSE = 45
129    UNKNOWN_ASDU_ADDRESS = 46
130    UNKNOWN_IO_ADDRESS = 47

133class Cause(typing.NamedTuple):
134    type: CauseType | OtherCauseType
135    is_negative_confirm: bool
136    is_test: bool
137    originator_address: OriginatorAddress

140class QualityType(enum.Enum):
141    INDICATION = 0
142    MEASUREMENT = 1
143    COUNTER = 2
144    PROTECTION = 3

147class IndicationQuality(typing.NamedTuple):
148    invalid: bool
149    not_topical: bool
150    substituted: bool
151    blocked: bool

154class MeasurementQuality(typing.NamedTuple):
155    invalid: bool
156    not_topical: bool
157    substituted: bool
158    blocked: bool
159    overflow: bool

162class CounterQuality(typing.NamedTuple):
163    invalid: bool
164    adjusted: bool
165    overflow: bool
166    sequence: int
167    """sequence in range [0, 31]"""

170class ProtectionQuality(typing.NamedTuple):
171    invalid: bool
172    not_topical: bool
173    substituted: bool
174    blocked: bool
175    time_invalid: bool

184class FreezeCode(enum.Enum):
185    READ = 0
186    FREEZE = 1
187    FREEZE_AND_RESET = 2
188    RESET = 3

191class SingleValue(enum.Enum):
192    OFF = 0
193    ON = 1

196class DoubleValue(enum.Enum):
197    """DoubleDataValue
198
199    `FAULT` stands for value 3, defined in the protocol as *INDETERMINATE*.
200    This is in order to make it more distinguishable from ``INTERMEDIATE``.
201
202    """
203    INTERMEDIATE = 0
204    OFF = 1
205    ON = 2
206    FAULT = 3

209class RegulatingValue(enum.Enum):
210    LOWER = 1
211    HIGHER = 2

214class StepPositionValue(typing.NamedTuple):
215    value: int
216    """value in range [-64, 63]"""
217    transient: bool

220class BitstringValue(typing.NamedTuple):
221    value: util.Bytes
222    """bitstring encoded as 4 bytes"""

225class NormalizedValue(typing.NamedTuple):
226    value: float
227    """value in range [-1.0, 1.0)"""

230class ScaledValue(typing.NamedTuple):
231    value: int
232    """value in range [-2^15, 2^15-1]"""

235class FloatingValue(typing.NamedTuple):
236    value: float

239class BinaryCounterValue(typing.NamedTuple):
240    value: int
241    """value in range [-2^31, 2^31-1]"""

244class ProtectionValue(enum.Enum):
245    OFF = 1
246    ON = 2

249class ProtectionStartValue(typing.NamedTuple):
250    general: bool
251    l1: bool
252    l2: bool
253    l3: bool
254    ie: bool
255    reverse: bool

258class ProtectionCommandValue(typing.NamedTuple):
259    general: bool
260    l1: bool
261    l2: bool
262    l3: bool

265class StatusValue(typing.NamedTuple):
266    value: list[bool]
267    """value length is 16"""
268    change: list[bool]
269    """change length is 16"""

272class IoElement_M_SP_NA(typing.NamedTuple):
273    value: SingleValue
274    quality: IndicationQuality

277class IoElement_M_SP_TA(typing.NamedTuple):
278    value: SingleValue
279    quality: IndicationQuality

282class IoElement_M_DP_NA(typing.NamedTuple):
283    value: DoubleValue
284    quality: IndicationQuality

287class IoElement_M_DP_TA(typing.NamedTuple):
288    value: DoubleValue
289    quality: IndicationQuality

292class IoElement_M_ST_NA(typing.NamedTuple):
293    value: StepPositionValue
294    quality: MeasurementQuality

297class IoElement_M_ST_TA(typing.NamedTuple):
298    value: StepPositionValue
299    quality: MeasurementQuality

302class IoElement_M_BO_NA(typing.NamedTuple):
303    value: BitstringValue
304    quality: MeasurementQuality

307class IoElement_M_BO_TA(typing.NamedTuple):
308    value: BitstringValue
309    quality: MeasurementQuality

312class IoElement_M_ME_NA(typing.NamedTuple):
313    value: NormalizedValue
314    quality: MeasurementQuality

317class IoElement_M_ME_TA(typing.NamedTuple):
318    value: NormalizedValue
319    quality: MeasurementQuality

322class IoElement_M_ME_NB(typing.NamedTuple):
323    value: ScaledValue
324    quality: MeasurementQuality

327class IoElement_M_ME_TB(typing.NamedTuple):
328    value: ScaledValue
329    quality: MeasurementQuality

332class IoElement_M_ME_NC(typing.NamedTuple):
333    value: FloatingValue
334    quality: MeasurementQuality

337class IoElement_M_ME_TC(typing.NamedTuple):
338    value: FloatingValue
339    quality: MeasurementQuality

342class IoElement_M_IT_NA(typing.NamedTuple):
343    value: BinaryCounterValue
344    quality: CounterQuality

347class IoElement_M_IT_TA(typing.NamedTuple):
348    value: BinaryCounterValue
349    quality: CounterQuality

352class IoElement_M_EP_TA(typing.NamedTuple):
353    value: ProtectionValue
354    quality: ProtectionQuality
355    elapsed_time: int
356    """elapsed_time in range [0, 65535]"""

359class IoElement_M_EP_TB(typing.NamedTuple):
360    value: ProtectionStartValue
361    quality: ProtectionQuality
362    duration_time: int
363    """duration_time in range [0, 65535]"""

366class IoElement_M_EP_TC(typing.NamedTuple):
367    value: ProtectionCommandValue
368    quality: ProtectionQuality
369    operating_time: int
370    """operating_time in range [0, 65535]"""

373class IoElement_M_PS_NA(typing.NamedTuple):
374    value: StatusValue
375    quality: MeasurementQuality

378class IoElement_M_ME_ND(typing.NamedTuple):
379    value: NormalizedValue

382class IoElement_M_SP_TB(typing.NamedTuple):
383    value: SingleValue
384    quality: IndicationQuality

387class IoElement_M_DP_TB(typing.NamedTuple):
388    value: DoubleValue
389    quality: IndicationQuality

392class IoElement_M_ST_TB(typing.NamedTuple):
393    value: StepPositionValue
394    quality: MeasurementQuality

397class IoElement_M_BO_TB(typing.NamedTuple):
398    value: BitstringValue
399    quality: MeasurementQuality

402class IoElement_M_ME_TD(typing.NamedTuple):
403    value: NormalizedValue
404    quality: MeasurementQuality

407class IoElement_M_ME_TE(typing.NamedTuple):
408    value: ScaledValue
409    quality: MeasurementQuality

412class IoElement_M_ME_TF(typing.NamedTuple):
413    value: FloatingValue
414    quality: MeasurementQuality

417class IoElement_M_IT_TB(typing.NamedTuple):
418    value: BinaryCounterValue
419    quality: CounterQuality

422class IoElement_M_EP_TD(typing.NamedTuple):
423    value: ProtectionValue
424    quality: ProtectionQuality
425    elapsed_time: int
426    """elapsed_time in range [0, 65535]"""

429class IoElement_M_EP_TE(typing.NamedTuple):
430    value: ProtectionStartValue
431    quality: ProtectionQuality
432    duration_time: int
433    """duration_time in range [0, 65535]"""

436class IoElement_M_EP_TF(typing.NamedTuple):
437    value: ProtectionCommandValue
438    quality: ProtectionQuality
439    operating_time: int
440    """operating_time in range [0, 65535]"""

443class IoElement_C_SC_NA(typing.NamedTuple):
444    value: SingleValue
445    select: bool
446    qualifier: int
447    """qualifier in range [0, 31]"""