eavanvalkenburg / sia Goto Github PK

Logger: pysiaalarm.base_server
Source: /usr/local/lib/python3.8/site-packages/pysiaalarm/base_server.py:126
First occurred: 8:37:33 AM (45 occurrences)
Last logged: 8:45:28 AM

Event timestamp is no longer valid: 2021-05-09 06:47:23+00:00
Event timestamp is no longer valid: 2021-05-09 06:47:33+00:00
Event timestamp is no longer valid: 2021-05-09 06:47:43+00:00
Event timestamp is no longer valid: 2021-05-09 06:47:53+00:00
Event timestamp is no longer valid: 2021-05-09 06:48:04+00:00

---

2021-05-09 08:37:33 DEBUG (MainThread) [pysiaalarm.base_server] Incoming line: xxx
2021-05-09 08:37:33 DEBUG (MainThread) [pysiaalarm.event] Content matches: {'account': 'xxx', 'ti': None, 'id': None, 'ri': '1', 'code': 'OP', 'message': '1', 'xdata': None, 'timestamp': '06:40:08,05-09-2021'}
2021-05-09 08:37:33 WARNING (MainThread) [pysiaalarm.base_server] Event timestamp is no longer valid: 2021-05-09 06:40:08+00:00

logger:
  default: info
  logs:
    custom_components.sia: debug

alarm_control_panel.8124_aaa_1_alarm | unavailable | friendly_name: 8124 - AAA - zone 1 - alarm

sensor.8124_aaa_last_heartbeat | 2020-07-15T10:58:57.401882+00:00 (last HA restart was at 14h28)

Logger: pysiaalarm.base_sia_server
Source: __main__.py:356
First occurred: 2:28:41 PM (43 occurrences)
Last logged: 2:36:23 PM

CRC mismatch, ignoring message.

Logger: pysiaalarm.aio.sia_server
Source: runner.py:119
First occurred: July 24, 2020, 1:31:58 PM (1646 occurrences)
Last logged: 6:56:06 PM

Last event: Content: }lf|#xxxxxxx|Nri0/RP0000]_16:51:49,07-25-2020, Zone: 0, Code: RP, Message: 0000, Concerns: Unused, Type: Automatic Test, Description: Automatic communication test report, Account: xxxxxx, Receiver: None, Prefix: L0, Timestamp: 2020-07-25 16:51:49, Length: 007C, Sequence: 2609, CRC: 7B87, Calc CRC: 7B87, Message type: Automatic Test, Encrypted Content: BEF91305810054267EF69DAD8xxxxxxxxxxxxxxF31FF28373F2850DF80F40F218A689A2886F, Full Message: "*SIA-DCS"xxxxx#xxxxxxxxx[BEF913058xxxxxxxxxxxEED6B70B86AEC82C7062F31FF28373F2850DF80F40F218A689A2886F., gave error in user function: Attribute hass is None for <Entity 8124 - xxxxxxxxxxxx- Last Heartbeat: 2020-07-25T16:51:50.147913+00:00>.
Last event: Content: at|#xxxxxxxxxx|Nri0/RP0000]_16:52:53,07-25-2020, Zone: 0, Code: RP, Message: 0000, Concerns: Unused, Type: Automatic Test, Description: Automatic communication test report, Account: xxxxxxxx, Receiver: None, Prefix: L0, Timestamp: 2020-07-25 16:52:53, Length: 007C, Sequence: 2610, CRC: 8F86, Calc CRC: 8F86, Message type: Automatic Test, Encrypted Content: E7B8FB3FD4EF41B73A3E97B1xxxxxxxxxxxxxBE5B3389ECAE860F0C7E9D9295FBE, Full Message: "*SIA-DCS"2610L0#xxxxxxxxxxxx[E7B8FB3FD4EF41xxxxxxxxxxxxxxB8B8798FE49EA786CE793730FE348306BE5B3389ECAE860F0C7E9D9295FBE., gave error in user function: Attribute hass is None for <Entity 8124 - xxxxxxxx- Last Heartbeat: 2020-07-25T16:52:54.022472+00:00>.
Last event: Content: W|#xxxxxxxxxxx|Nri0/RP0000]_16:53:57,07-25-2020, Zone: 0, Code: RP, Message: 0000, Concerns: Unused, Type: Automatic Test, Description: Automatic communication test report, Account: xxxxxxxx, Receiver: None, Prefix: L0, Timestamp: 2020-07-25 16:53:57, Length: 007C, Sequence: 2611, CRC: 405E, Calc CRC: 405E, Message type: Automatic Test, Encrypted Content: 47501481CCAE96D35726138AxxxxxxxxxxxxxA92455A6FF321459A9FD01A27C68D527B12FBBD3D4D, Full Message: "*SIA-DCS"2611L0#xxxxxxxxxxx[47501481CCAE96D35726138ABxxxxxxxxxxxxxxxxxxxx6E0207D15BDA92455A6FF321459A9FD01A27C68D527B12FBBD3D4D., gave error in user function: Attribute hass is None for <Entity 8124 - xxxxxxx- Last Heartbeat: 2020-07-25T16:53:58.135404+00:00>.
Last event: Content: 0|#xxxxxxxxxxxx|Nri0/RP0000]_16:55:01,07-25-2020, Zone: 0, Code: RP, Message: 0000, Concerns: Unused, Type: Automatic Test, Description: Automatic communication test report, Account: xxxxxxx, Receiver: None, Prefix: L0, Timestamp: 2020-07-25 16:55:01, Length: 007C, Sequence: 2612, CRC: CA39, Calc CRC: CA39, Message type: Automatic Test, Encrypted Content: 0634C833E6C4E561934EB85E2A2B1EEF7xxxxxxxxxxxxxxx029896F874DBB072F4069969C72, Full Message: "*SIA-DCS"2612L0#xxxxxxxxxxx[0634C833E6C4E561934xxxxxxxxxxxxxE41EDEF2DC99B55B815BD029896F874DBB072F4069969C72., gave error in user function: Attribute hass is None for <Entity 8124 - xxxxxxx- Last Heartbeat: 2020-07-25T16:55:02.251481+00:00>.
Last event: Content: h|#xxxxxxxxxxx|Nri0/RP0000]_16:56:05,07-25-2020, Zone: 0, Code: RP, Message: 0000, Concerns: Unused, Type: Automatic Test, Description: Automatic communication test report, Account: xxxxxxxx, Receiver: None, Prefix: L0, Timestamp: 2020-07-25 16:56:05, Length: 007C, Sequence: 2613, CRC: 0209, Calc CRC: 0209, Message type: Automatic Test, Encrypted Content: 65F65B2B95AB8401D519F67641E5Fxxxxxxxxxxxxxxxx05B11C81980D81E1D78034C160FBD13A37, Full Message: "*SIA-DCS"2613L0#xxxxxxxxxxx[65F65B2B95AB840xxxxxxxxxxxxxxD82FFAF7D05B11C81980D81E1D78034C160FBD13A37., gave error in user function: Attribute hass is None for <Entity 8124 - xxxxxxxx- Last Heartbeat: 2020-07-25T16:56:06.111182+00:00>.

Logger: pysiaalarm.base_sia_server
Source: runner.py:119
First occurred: July 24, 2020, 2:35:51 PM (22 occurrences)
Last logged: 5:17:58 PM

Decrypting last line: xxxxxxxx"*SIA-DCS"2360L0#xxxxxxx[77DA3324B82261B28F632699FxxxxxxxxxxxxB20924251A0862538D0744C70BD39110C3ED7EA could not be parsed as a SIAEvent, content: � i|#xxxxxxxxxxxxxxxx|Nri0/RP0000]_12:26:24,07-25-2020
Decrypting last line: D170007C"*SIA-DCS"2391L0#xxxxxxxx[46E4226BFDC8145D00E6FA869C4038xxxxxxxxxxxxxF16AA247B3240680941D33767207FF051 could not be parsed as a SIAEvent, content: J |#xxxxxxxxxxxx|Nri0/RP0000]_12:59:57,07-25-2020
Decrypting last line: 00D3007C"*SIA-DCS"2473L0#xxxxxxxx[D1964C62F90AA8B197349C5D0BBxxxxxxxxxxxxxE42EA233A23650FB3FF72B5DD306300111D1B could not be parsed as a SIAEvent, content: p |#xxxxxxxxxxx|Nri0/RP0000]_14:27:47,07-25-2020
Decrypting last line: 76D3007C"*SIA-DCS"2476L0#xxxxxxxxxx[0B60D25CCDF01205EEC4330BBxxxxxxxxxxxxxxxxxE95BDC19F766F778CB8DC1D48FD725162CDA63 could not be parsed as a SIAEvent, content: 9 k|#xxxxxxxxxxx|Nri0/RP0000]_14:31:00,07-25-2020
Decrypting last line: 909D007C"*SIA-DCS"2521L0#xxxxxxxxx[9172995D1F0FFxxxxxxxxxxxxxxx96415490A560C3F055C69C098F92E4939446832D917DBE899 could not be parsed as a SIAEvent, content: k|#xxxxxxxxxxxx|Nri0/RP0000]_15:17:57,07-25-2020

2020-08-17 14:09:25 DEBUG (MainThread) [pysiaalarm.aio.sia_server] Incoming line: 2C6B00A2"*SIA-DCS"5252L0#XXXXXXX[312FD4F843E8A4D356A23F65503250E38F5B15BDCEE458944C9BB98C0990EE54D65429926465E344D8D52375D76B753B09497CECEF405034DCCB62CA0D700CF9
2020-08-17 14:09:25 DEBUG (MainThread) [pysiaalarm.base_sia_server] Parsed event: Content:  ;@3;7ej|#XXXXXXX|Nri1/NL501]_12:09:26,08-17-2020, Zone: 1, Code: NL, Message: 501, Concerns: Area number, Type: Perimeter Armed, Description: An area has been perimeter armed, Account: XXXXXXX, Receiver: None, Prefix: L0, Timestamp: 2020-08-17 12:09:26, Length: 00A2, Sequence: 5252, CRC: 2C6B, Calc CRC: 2C6B, Message type: Perimeter Armed, Encrypted Content: 312FD4F843E8A4D356A23F65503250E38F5B15BDCEE458944C9BB98C0990EE54D65429926465E344D8D52375D76B753B09497CECEF405034DCCB62CA0D700CF9, Full Message: "*SIA-DCS"5252L0#XXXXXXX[312FD4F843E8A4D356A23F65503250E38F5B15BDCEE458944C9BB98C0990EE54D65429926465E344D8D52375D76B753B09497CECEF405034DCCB62CA0D700CF9..
2020-08-17 14:09:26 DEBUG (MainThread) [pysiaalarm.aio.sia_server] Incoming line: 00CA00A2"*SIA-DCS"5253L0#XXXXXXX[6F786CD1EBA073B307E3831E3429570FCF64C9775F71A45B77CF3934ADE9864EF192C3DE114503761E95AEFE17240B9D6DC018F1BA2263E736A1736824858BEC
2020-08-17 14:09:26 DEBUG (MainThread) [pysiaalarm.base_sia_server] Parsed event: Content: u(+*mk|#XXXXXXX|Nri2/NL501]_12:09:27,08-17-2020, Zone: 2, Code: NL, Message: 501, Concerns: Area number, Type: Perimeter Armed, Description: An area has been perimeter armed, Account: XXXXXXX, Receiver: None, Prefix: L0, Timestamp: 2020-08-17 12:09:27, Length: 00A2, Sequence: 5253, CRC: 00CA, Calc CRC: 00CA, Message type: Perimeter Armed, Encrypted Content: 6F786CD1EBA073B307E3831E3429570FCF64C9775F71A45B77CF3934ADE9864EF192C3DE114503761E95AEFE17240B9D6DC018F1BA2263E736A1736824858BEC, Full Message: "*SIA-DCS"5253L0#XXXXXXX[6F786CD1EBA073B307E3831E3429570FCF64C9775F71A45B77CF3934ADE9864EF192C3DE114503761E95AEFE17240B9D6DC018F1BA2263E736A1736824858BEC..
2020-08-17 14:09:26 DEBUG (MainThread) [pysiaalarm.aio.sia_server] Incoming line: 0F3900A2"*SIA-DCS"5254L0#XXXXXXX[12CB567D7DC462A9C00A8555030C617B3B302634466202A9BAB3D9EBEEAFA2337FF3E933FF4EEDE7C74BC0C1A510D9D6C0064AF9A97FDA412D625A05B22F68BD
2020-08-17 14:09:26 DEBUG (MainThread) [pysiaalarm.base_sia_server] Parsed event: Content:  %l)/|#XXXXXXX|Nri0/RP0000]_12:09:27,08-17-2020, Zone: 0, Code: RP, Message: 0000, Concerns: Unused, Type: Automatic Test, Description: Automatic communication test report, Account: XXXXXXX, Receiver: None, Prefix: L0, Timestamp: 2020-08-17 12:09:27, Length: 00A2, Sequence: 5254, CRC: 0F39, Calc CRC: 0F39, Message type: Automatic Test, Encrypted Content: 12CB567D7DC462A9C00A8555030C617B3B302634466202A9BAB3D9EBEEAFA2337FF3E933FF4EEDE7C74BC0C1A510D9D6C0064AF9A97FDA412D625A05B22F68BD, Full Message: "*SIA-DCS"5254L0#XXXXXXX[12CB567D7DC462A9C00A8555030C617B3B302634466202A9BAB3D9EBEEAFA2337FF3E933FF4EEDE7C74BC0C1A510D9D6C0064AF9A97FDA412D625A05B22F68BD..

2020-08-17 14:09:35 DEBUG (MainThread) [pysiaalarm.aio.sia_server] Incoming line: 714A00A2"*SIA-DCS"5255L0#XXXXXXX[500FE215294956F389BAC0030ACDDD1F038A6ABDF49723C4B3E0B8E150735E69DF8A20D7F394CC1C43B0F0F12B3858C5984F67112CF28A1336714BB2B7142E53
2020-08-17 14:09:35 DEBUG (MainThread) [pysiaalarm.base_sia_server] Parsed event: Content: RODk6|#XXXXXXX|Nri1/NP501]_12:09:36,08-17-2020, Zone: 1, Code: NP, Message: 501, Concerns: Zone or point, Type: Arming Event, Description: Night mode deactivated using device, Account: XXXXXXX, Receiver: None, Prefix: L0, Timestamp: 2020-08-17 12:09:36, Length: 00A2, Sequence: 5255, CRC: 714A, Calc CRC: 714A, Message type: Arming Event, Encrypted Content: 500FE215294956F389BAC0030ACDDD1F038A6ABDF49723C4B3E0B8E150735E69DF8A20D7F394CC1C43B0F0F12B3858C5984F67112CF28A1336714BB2B7142E53, Full Message: "*SIA-DCS"5255L0#XXXXXXX[500FE215294956F389BAC0030ACDDD1F038A6ABDF49723C4B3E0B8E150735E69DF8A20D7F394CC1C43B0F0F12B3858C5984F67112CF28A1336714BB2B7142E53..
2020-08-17 14:09:35 INFO (MainThread) [custom_components.sia] Unhandled event code, will be set as attribute in the heartbeat sensor. Code is: NP, Message: 501, Full event: Code: NP, Type: Arming Event,             Description: Night mode deactivated using device
2020-08-17 14:09:36 DEBUG (MainThread) [pysiaalarm.aio.sia_server] Incoming line: 9C2400A2"*SIA-DCS"5256L0#XXXXXXX[71C5C2895F6B5282905C7D0BB5485A09098F25D5C3C43603A4C3290429622186F0F90AC41615473BE02C89F014B8D0730E64813EA709B2529E05075EFA426532
2020-08-17 14:09:36 DEBUG (MainThread) [pysiaalarm.base_sia_server] Parsed event: Content: Q,TMN|#XXXXXXX|Nri2/NP501]_12:09:37,08-17-2020, Zone: 2, Code: NP, Message: 501, Concerns: Zone or point, Type: Arming Event, Description: Night mode deactivated using device, Account: XXXXXXX, Receiver: None, Prefix: L0, Timestamp: 2020-08-17 12:09:37, Length: 00A2, Sequence: 5256, CRC: 9C24, Calc CRC: 9C24, Message type: Arming Event, Encrypted Content: 71C5C2895F6B5282905C7D0BB5485A09098F25D5C3C43603A4C3290429622186F0F90AC41615473BE02C89F014B8D0730E64813EA709B2529E05075EFA426532, Full Message: "*SIA-DCS"5256L0#XXXXXXX[71C5C2895F6B5282905C7D0BB5485A09098F25D5C3C43603A4C3290429622186F0F90AC41615473BE02C89F014B8D0730E64813EA709B2529E05075EFA426532..
2020-08-17 14:09:36 INFO (MainThread) [custom_components.sia] Unhandled event code, will be set as attribute in the heartbeat sensor. Code is: NP, Message: 501, Full event: Code: NP, Type: Arming Event,             Description: Night mode deactivated using device

Add your logs here.

import asyncio
import logging
import json
import voluptuous as vol
import sseclient
import requests
import time
from collections import defaultdict
from requests_toolbelt.utils import dump
from homeassistant.core import callback
import voluptuous as vol
from datetime import timedelta
from homeassistant.exceptions import TemplateError
import homeassistant.helpers.config_validation as cv
from homeassistant.helpers.entity import Entity, async_generate_entity_id
from homeassistant.helpers.event import async_track_state_change

from threading import Thread
from homeassistant.helpers import discovery
from homeassistant.components.binary_sensor import BinarySensorDevice
from homeassistant.helpers.restore_state import RestoreEntity
_LOGGER = logging.getLogger(__name__)
from homeassistant.const import (STATE_ON, STATE_OFF)

from homeassistant.const import (
    CONF_NAME, CONF_PORT, CONF_PASSWORD)
import socketserver 
from datetime import datetime
import time
import logging
import threading
import sys
import re

from Crypto.Cipher import AES
from binascii import unhexlify,hexlify
from Crypto import Random
import random, string, base64
from homeassistant.helpers.event import async_track_point_in_utc_time
from homeassistant.util.dt import utcnow

DOMAIN = 'sia'
CONF_HUBS = 'hubs'
CONF_ACCOUNT = 'account'

HUB_CONFIG = vol.Schema({
    vol.Required(CONF_NAME): cv.string,
    vol.Required(CONF_ACCOUNT): cv.string,
    vol.Optional(CONF_PASSWORD):cv.string,
})



CONFIG_SCHEMA = vol.Schema({
    DOMAIN: vol.Schema({
        vol.Required(CONF_PORT): cv.string,
        vol.Required(CONF_HUBS, default={}):
            vol.All(cv.ensure_list, [HUB_CONFIG]),
    }),
}, extra=vol.ALLOW_EXTRA)

ID_STRING = '"SIA-DCS"'.encode()
ID_STRING_ENCODED = '"*SIA-DCS"'.encode()

TIME_TILL_UNAVAILABLE = timedelta(minutes=3)

ID_R='\r'.encode()

hass_platform = None


def setup(hass, config):
    global hass_platform
    socketserver.TCPServer.allow_reuse_address = True
    hass_platform = hass

    hass_platform.data[DOMAIN] = {}

    port = int(config[DOMAIN][CONF_PORT])

    for hub_config in config[DOMAIN][CONF_HUBS]:
        if CONF_PASSWORD in hub_config:
            hass.data[DOMAIN][hub_config[CONF_ACCOUNT]] = EncryptedHub(hass, hub_config)
        else:
            hass.data[DOMAIN][hub_config[CONF_ACCOUNT]] = Hub(hass, hub_config)
          
    for component in ['binary_sensor']:
       discovery.load_platform(hass, component, DOMAIN, {}, config)

    server = socketserver.TCPServer(("", port), AlarmTCPHandler)

    t = threading.Thread(target=server.serve_forever)
    t.start()
    
    return True

class Hub:
    reactions = {            

            # Zone 1 - Hem
            "Nri1/BA" : [{"state":"ALARM_ZONE1","value":True}],
            "Nri1/BR" : [{"state":"ALARM_ZONE1","value":False}],
            "Nri1/TA" : [{"state":"ALARM_ZONE1","value":True}],
            "Nri1/TR" : [{"state":"ALARM_ZONE1","value":False}],
            "Nri1/CG" : [{"state":"STATUS_ZONE1","value":False}],
            "Nri1/CF" : [{"state":"STATUS_ZONE1","value":False}],
            "Nri1/CL" : [{"state":"STATUS_ZONE1","value":False}],
            "Nri1/OG" : [{"state":"STATUS_ZONE1","value":True}],
            "Nri1/OP" : [{"state":"STATUS_ZONE1","value":True}],
            "Nri1/NF" : [{"state":"STATUS_NIGHT_MODE","value":False}],
            "Nri1/NL" : [{"state":"STATUS_NIGHT_MODE","value":False}],
            "Nri1/NP" : [{"state":"STATUS_NIGHT_MODE","value":True}],
            "Nri1/WA":  [{"state":"LEAK_ZONE1","value":True}],
            "Nri1/WH":  [{"state":"LEAK_ZONE1","value":False}],
            "Nri1/GA":  [{"state":"GAS_ZONE1","value":True}],
            "Nri1/GH":  [{"state":"GAS_ZONE1","value":False}],
            "Nri1/XC" : [],
            "Nri1/XL" : [],

            # Zone 2 - Förråd
            "Nri2/BA" : [{"state":"ALARM_ZONE2","value":True}],
            "Nri2/BR" : [{"state":"ALARM_ZONE2","value":False}],
            "Nri2/TA" : [{"state":"ALARM_ZONE2","value":True}],
            "Nri2/TR" : [{"state":"ALARM_ZONE2","value":False}],
            "Nri2/CG" : [{"state":"STATUS_ZONE2","value":False}],
            "Nri2/CF" : [{"state":"STATUS_ZONE2","value":False}],
            "Nri2/CL" : [{"state":"STATUS_ZONE2","value":False}],
            "Nri2/OG" : [{"state":"STATUS_ZONE2","value":True}],
            "Nri2/OP" : [{"state":"STATUS_ZONE2","value":True}],
            "Nri2/NF" : [],
            "Nri2/NL" : [],
            "Nri2/NP" : [],
            "Nri2/WA":  [],
            "Nri2/WH":  [],
            "Nri2/GA":  [],
            "Nri2/GH":  [],
            "Nri2/NF" : [],
            "Nri2/XC" : [],
            "Nri2/XL" : [],

            # Zone 3 - Uteplats
            "Nri3/BA" : [{"state":"ALARM_ZONE3","value":True}],
            "Nri3/BR" : [{"state":"ALARM_ZONE3","value":False}],
            "Nri3/TA" : [{"state":"ALARM_ZONE3","value":True}],
            "Nri3/TR" : [{"state":"ALARM_ZONE3","value":False}],
            "Nri3/CG" : [{"state":"STATUS_ZONE3","value":False}],
            "Nri3/CF" : [{"state":"STATUS_ZONE3","value":False}],
            "Nri3/CL" : [{"state":"STATUS_ZONE3","value":False}],
            "Nri3/OG" : [{"state":"STATUS_ZONE3","value":True}],
            "Nri3/OP" : [{"state":"STATUS_ZONE3","value":True}],
            "Nri3/NF" : [],
            "Nri3/NL" : [],
            "Nri3/NP" : [],
            "Nri3/WA":  [],
            "Nri3/WH":  [],
            "Nri3/GA":  [],
            "Nri3/GH":  [],
            "Nri3/NF" : [],
            "Nri3/XC" : [],
            "Nri3/XL" : [],

            # Other
            "Nri0/RP" : [],
            "Nri0/RS" : [],
            "Nri0/YG" : []
        }

    # -----------------------------------------------------------------------------------------------
    # Mod: reset alarm state when disarmed
    reactions_reset_alarm_state_on_disarm = {            

            # Zone 1 - Hem
            "Nri1/OG" : [{"state":"ALARM_ZONE1","value":False}],
            "Nri1/OP" : [{"state":"ALARM_ZONE1","value":False}],

            # Zone 2 - Förråd
            "Nri2/OG" : [{"state":"ALARM_ZONE2","value":False}],
            "Nri2/OP" : [{"state":"ALARM_ZONE2","value":False}],

            # Zone 3 - Uteplats
            "Nri3/OG" : [{"state":"ALARM_ZONE3","value":False}],
            "Nri3/OP" : [{"state":"ALARM_ZONE3","value":False}],
        }
    # -----------------------------------------------------------------------------------------------

    def __init__(self, hass, hub_config):
        self._name = hub_config[CONF_NAME]
        self._accountId = hub_config[CONF_ACCOUNT]
        self._hass = hass
        self._states = {}
        self._states["LEAK_ZONE1"] = SIABinarySensor("sia_leak_zone1_" + self._name,"moisture" , hass)
        self._states["GAS_ZONE1"] = SIABinarySensor("sia_gas_zone1_" + self._name,"smoke", hass)
        self._states["ALARM_ZONE1"]  = SIABinarySensor("sia_alarm_zone1_" + self._name,"safety", hass)
        self._states["STATUS_ZONE1"]  = SIABinarySensor("sia_status_zone1_" + self._name, "lock", hass)
        self._states["STATUS_NIGHT_MODE"]  = SIABinarySensor("sia_status_night_mode_" + self._name, "lock", hass)
        # self._states["LEAK_ZONE2"] = SIABinarySensor("sia_leak_zone2_" + self._name,"moisture" , hass)
        # self._states["GAS_ZONE2"] = SIABinarySensor("sia_gas_zone2_" + self._name,"smoke", hass)
        self._states["ALARM_ZONE2"]  = SIABinarySensor("sia_alarm_zone2_" + self._name,"safety", hass)
        self._states["STATUS_ZONE2"]  = SIABinarySensor("sia_status_zone2_" + self._name, "lock", hass)
        # self._states["LEAK_ZONE3"] = SIABinarySensor("sia_leak_zone3_" + self._name,"moisture" , hass)
        # self._states["GAS_ZONE3"] = SIABinarySensor("sia_gas_zone3_" + self._name,"smoke", hass)
        self._states["ALARM_ZONE3"]  = SIABinarySensor("sia_alarm_zone3_" + self._name,"safety", hass)
        self._states["STATUS_ZONE3"]  = SIABinarySensor("sia_status_zone3_" + self._name, "lock", hass)
    
    def manage_string(self, msg):
        _LOGGER.debug("manage_string: " + msg)
        
        pos = msg.find('/')        
        assert pos>=0, "Can't find '/', message is possibly encrypted"
        # tipo = msg[pos+1:pos+3]
        tipo = msg[pos-4:pos+3]

        if tipo in self.reactions:
            reactions = self.reactions[tipo]
            for reaction in reactions:
                state = reaction["state"]
                value = reaction["value"]
             
                self._states[state].new_state(value)

            # -----------------------------------------------------------------------------------------------
            # Mod: reset alarm state when disarmed
            if tipo in self.reactions_reset_alarm_state_on_disarm:
                reactions_reset_alarm_state_on_disarm = self.reactions_reset_alarm_state_on_disarm[tipo]
                for reaction in reactions_reset_alarm_state_on_disarm:
                    state = reaction["state"]
                    value = reaction["value"]
                 
                    self._states[state].new_state(value)
            # -----------------------------------------------------------------------------------------------

        else:
            _LOGGER.error("unknown event: " + tipo )
        
        for device in self._states:
           self._states[device].assume_available()



    def process_line(self, line):
        _LOGGER.debug("Hub.process_line" + line.decode())
        pos = line.find(ID_STRING)
        assert pos>=0, "Can't find ID_STRING, check encryption configs"
        seq = line[pos+len(ID_STRING) : pos+len(ID_STRING)+4]
        data = line[line.index(b'[') :]
        _LOGGER.debug("Hub.process_line found data: " + data.decode())
        self.manage_string(data.decode())
        return '"ACK"'  + (seq.decode()) + 'L0#' + (self._accountId) + '[]'
        

class EncryptedHub(Hub):
    def __init__(self, hass, hub_config):
        self._key = hub_config[CONF_PASSWORD].encode("utf8")
        iv = Random.new().read(AES.block_size)
        _cipher = AES.new(self._key, AES.MODE_CBC, iv)
        self.iv2 = None
        self._ending = hexlify(_cipher.encrypt( "00000000000000|]".encode("utf8") )).decode(encoding='UTF-8').upper()
        Hub.__init__(self, hass, hub_config)

    def manage_string(self, msg):
        iv = unhexlify("00000000000000000000000000000000") #where i need to find proper IV ? Only this works good.
        _cipher = AES.new(self._key, AES.MODE_CBC, iv)
        data = _cipher.decrypt(unhexlify(msg[1:]))
        _LOGGER.debug("EncryptedHub.manage_string data: " + data.decode(encoding='UTF-8',errors='replace'))

        data = data[data.index(b'|'):]
        resmsg = data.decode(encoding='UTF-8',errors='replace')
               
        Hub.manage_string(self, resmsg)

    def process_line(self, line):
        _LOGGER.debug("EncryptedHub.process_line" + line.decode())
        pos = line.find(ID_STRING_ENCODED)
        assert pos>=0, "Can't find ID_STRING_ENCODED, is SIA encryption enabled?"
        seq = line[pos+len(ID_STRING_ENCODED) : pos+len(ID_STRING_ENCODED)+4]
        data = line[line.index(b'[') :]
        _LOGGER.debug("EncryptedHub.process_line found data: " + data.decode())
        self.manage_string(data.decode())
        return '"*ACK"'  + (seq.decode()) + 'L0#' + (self._accountId) + '[' + self._ending
  
        

class SIABinarySensor( RestoreEntity):
    def __init__(self,  name, device_class, hass):
        self._device_class = device_class
        self._should_poll = False
        self._name = name
        self.hass = hass
        self._is_available = True
        self._remove_unavailability_tracker = None

    async def async_added_to_hass(self):
        await super().async_added_to_hass()
        state = await self.async_get_last_state()        
        if state is not None and state.state is not None:
            self._state = state.state == STATE_ON
        else:
            self._state = None
        self._async_track_unavailable()

    @property
    def name(self):
        return self._name

    @property
    def state(self):
        return STATE_ON if self.is_on else STATE_OFF

    @property
    def unique_id(self) -> str:
        return self._name

    @property
    def available(self):
        return self._is_available

    @property
    def device_state_attributes(self):
        attrs = {}
        return attrs

    @property
    def device_class(self):
        return self._device_class

    @property
    def is_on(self):
        return self._state

    def new_state(self, state):   
        self._state = state
        self.async_schedule_update_ha_state()

    def assume_available(self):
        self._async_track_unavailable()

    @callback
    def _async_track_unavailable(self):
        if self._remove_unavailability_tracker:
            self._remove_unavailability_tracker()
        self._remove_unavailability_tracker = async_track_point_in_utc_time(
            self.hass, self._async_set_unavailable,
            utcnow() + TIME_TILL_UNAVAILABLE)
        if not self._is_available:
            self._is_available = True
            return True
        return False

    @callback
    def _async_set_unavailable(self, now):
        self._remove_unavailability_tracker = None
        self._is_available = False
        self.async_schedule_update_ha_state()

class AlarmTCPHandler(socketserver.BaseRequestHandler):
    _received_data = "".encode()

    def handle_line(self, line):   
        _LOGGER.debug("Income raw string: " + line.decode())     
        accountId = line[line.index(b'#') +1: line.index(b'[')].decode()

        pos = line.find(b'"')
        assert pos>=0, "Can't find message beginning"
        inputMessage=line[pos:]
        msgcrc = line[0:4] 
        codecrc = str.encode(AlarmTCPHandler.CRCCalc(inputMessage))   
        try:
            if msgcrc != codecrc:
                raise Exception('CRC mismatch')            
            if(accountId not in hass_platform.data[DOMAIN]):
                raise Exception('Not supported account ' + accountId)
            response = hass_platform.data[DOMAIN][accountId].process_line(line)
        except Exception as e:
            _LOGGER.error(str(e))
            timestamp = datetime.fromtimestamp(time.time()).strftime('_%H:%M:%S,%m-%d-%Y')
            response = '"NAK"0000L0R0A0[]' + timestamp

        header = ('%04x' % len(response)).upper()
        CRC = AlarmTCPHandler.CRCCalc2(response)
        response="\n" + CRC + header + response + "\r"

        byte_response = str.encode(response)
        self.request.sendall(byte_response)


    def handle(self):
        line = b''
        try:
            while True:
                raw = self.request.recv(1024)
                if (not raw) or (len(raw) == 0):
                    return
                raw = bytearray(raw)
                while True:
                    splitter = raw.find(b'\r')
                    if splitter> -1:
                        line = raw[1:splitter]
                        raw = raw[splitter+1:]
                    else:
                        break
                    
                    self.handle_line(line)
        except Exception as e: 
            _LOGGER.error(str(e)+" last line: " + line.decode())
            return

    @staticmethod
    def CRCCalc(msg):
        CRC=0
        for letter in msg:
            temp=(letter)
            for j in range(0,8):  # @UnusedVariable
                temp ^= CRC & 1
                CRC >>= 1
                if (temp & 1) != 0:
                    CRC ^= 0xA001
                temp >>= 1
                
        return ('%x' % CRC).upper().zfill(4)
    
    @staticmethod
    def CRCCalc2(msg):
        CRC=0
        for letter in msg:
            temp=ord(letter)
            for j in range(0,8):  # @UnusedVariable
                temp ^= CRC & 1
                CRC >>= 1
                if (temp & 1) != 0:
                    CRC ^= 0xA001
                temp >>= 1
                
        return ('%x' % CRC).upper().zfill(4)

sia:
  port:  port
  hubs:
    - name: hubname
      account: account
      encryption_key: password
      zones:
        - zone: 1
          name: zonename
          sensors:
           - alarm
           - moisture
           - smoke

Dear client,
 
When you receive a notification about, for example, opening/closing a door, the SIA line should also indicate the group number and the number of the device that generated the event.

2020-10-28 19:14:25 ERROR (MainThread) [homeassistant] Error doing job: Task exception was never retrieved
Traceback (most recent call last):
  File "/usr/local/lib/python3.8/site-packages/pysiaalarm/aio/sia_server.py", line 50, in handle_line
    line = str.strip(data.decode())
UnicodeDecodeError: 'utf-8' codec can't decode byte 0x81 in position 2: invalid start byte

2021-01-18 20:50:04 ERROR (MainThread) [homeassistant] Error doing job: Task exception was never retrieved
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/pysiaalarm/aio/sia_server.py", line 50, in handle_line
line = str.strip(data.decode("ascii"))
UnicodeDecodeError: 'ascii' codec can't decode byte 0x89 in position 20: ordinal not in range(128)

2019-09-15 23:27:43 DEBUG (Thread-2) [custom_components.sia] Will set state for entity: SwinglineAX_1_alarm to state: armed_night
2019-09-15 23:27:56 ERROR (Thread-2) [custom_components.sia] 
2019-09-15 23:28:15 DEBUG (Thread-2) [custom_components.sia] Incoming parsed: |#xxxx|Nri0/RP0000]_21:28:20,09-15-2019 to sia: Code: RP, Type: Automatic Test, Description: Automatic communication test report, Concerns: Unused for zone: 0 with message: RP0000
2019-09-15 23:28:15 DEBUG (Thread-2) [custom_components.sia] Will set state for entity: SwinglineAX_last_heartbeat to state: utcnow()
2019-09-15 23:28:28 DEBUG (Thread-2) [custom_components.sia] Incoming parsed: |#xxxx|Nri1/NL501]_21:28:33,09-15-2019 to sia: Code: NL, Type: Perimeter Armed, Description: An area has been perimeter armed, Concerns: Area number for zone: 1 with message: NL501
2019-09-15 23:28:28 DEBUG (Thread-2) [custom_components.sia] Will set state for entity: SwinglineAX_1_alarm to state: armed_night
2019-09-15 23:29:04 ERROR (Thread-2) [custom_components.sia] 
2019-09-15 23:29:15 DEBUG (Thread-2) [custom_components.sia] Incoming parsed: |#xxxx|Nri0/RP0000]_21:29:20,09-15-2019 to sia: Code: RP, Type: Automatic Test, Description: Automatic communication test report, Concerns: Unused for zone: 0 with message: RP0000
2019-09-15 23:29:15 DEBUG (Thread-2) [custom_components.sia] Will set state for entity: SwinglineAX_last_heartbeat to state: utcnow()
2019-09-15 23:29:28 DEBUG (Thread-2) [custom_components.sia] Incoming parsed: |#xxxx|Nri1/CG501]_21:29:33,09-15-2019 to sia: Code: CG, Type: Close Area, Description: System has been partially armed, Concerns: Area number for zone: 1 with message: CG501
2019-09-15 23:29:28 DEBUG (Thread-2) [custom_components.sia] Will set state for entity: SwinglineAX_1_alarm to state: armed_away
2019-09-15 23:29:29 DEBUG (Thread-2) [custom_components.sia] Incoming parsed: |#xxxx|Nri1/OG501]_21:29:34,09-15-2019 to sia: Code: OG, Type: Open Area, Description: System has been partially disarmed, Concerns: Area number for zone: 1 with message: OG501
2019-09-15 23:29:29 DEBUG (Thread-2) [custom_components.sia] Will set state for entity: SwinglineAX_1_alarm to state: disarmed

Add your configuration here.
sia:
  port: 1241
  hubs:
    - name: Ajax
      account: AAA

May 08 09:38:12 pi hass[15841]: 2021-05-08 09:38:12 ERROR (MainThread) [custom_components.sia.config_flow] Unexpected exception
May 08 09:38:12 pi hass[15841]: Traceback (most recent call last):
May 08 09:38:12 pi hass[15841]:   File "/home/homeassistant/.homeassistant/custom_components/sia/config_flow.py", line 108, in async_step_user
May 08 09:38:12 pi hass[15841]:     await self.async_set_unique_id(f"{DOMAIN}_{self.data[CONF_PORT]}")
May 08 09:38:12 pi hass[15841]: TypeError: 'NoneType' object is not subscriptable

Add your logs here.