-
Notifications
You must be signed in to change notification settings - Fork 24
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #63 from scs/feature/lge570_integration
Feature/lge570 integration
- Loading branch information
Showing
5 changed files
with
121 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,43 @@ | ||
# | ||
# Copyright (C) 2022 Supercomputing Systems AG | ||
# This file is part of smartmeter-datacollector. | ||
# | ||
# SPDX-License-Identifier: GPL-2.0-only | ||
# See LICENSES/README.md for more information. | ||
# | ||
import logging | ||
from typing import Optional | ||
|
||
import serial | ||
|
||
from .cosem import Cosem | ||
from .meter import MeterError, SerialHdlcDlmsMeter | ||
from .reader import ReaderError | ||
from .serial_reader import SerialConfig | ||
|
||
LOGGER = logging.getLogger("smartmeter") | ||
|
||
|
||
class LGE570(SerialHdlcDlmsMeter): | ||
BAUDRATE = 2400 | ||
|
||
def __init__(self, port: str, | ||
baudrate: int = BAUDRATE, | ||
decryption_key: Optional[str] = None, | ||
use_system_time: bool = False) -> None: | ||
serial_config = SerialConfig( | ||
port=port, | ||
baudrate=baudrate, | ||
data_bits=serial.EIGHTBITS, | ||
parity=serial.PARITY_EVEN, | ||
stop_bits=serial.STOPBITS_ONE, | ||
termination=SerialHdlcDlmsMeter.HDLC_FLAG | ||
) | ||
cosem = Cosem(fallback_id=port) | ||
try: | ||
super().__init__(serial_config, cosem, decryption_key, use_system_time) | ||
except ReaderError as ex: | ||
LOGGER.fatal("Unable to setup serial reader for L+G E570. '%s'", ex) | ||
raise MeterError("Failed setting up L+G E570.") from ex | ||
|
||
LOGGER.info("Successfully set up L+G E570 smart meter on '%s'.", port) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,56 @@ | ||
# | ||
# Copyright (C) 2022 Supercomputing Systems AG | ||
# This file is part of smartmeter-datacollector. | ||
# | ||
# SPDX-License-Identifier: GPL-2.0-only | ||
# See LICENSES/README.md for more information. | ||
# | ||
import sys | ||
from typing import List | ||
|
||
import pytest | ||
from pytest_mock.plugin import MockerFixture | ||
|
||
from smartmeter_datacollector.smartmeter.lge570 import LGE570 | ||
from smartmeter_datacollector.smartmeter.meter_data import MeterDataPointTypes | ||
|
||
from .utils import * | ||
|
||
|
||
@pytest.mark.skipif(sys.version_info < (3, 8), reason="Python3.7 does not support AsyncMock.") | ||
@pytest.mark.asyncio | ||
async def test_lge570_parse_and_provide_encrypted_data(mocker: MockerFixture, | ||
encrypted_valid_data_lge570: List[bytes]): | ||
observer = mocker.stub("collector_mock") | ||
observer.mock_add_spec(['notify']) | ||
serial_mock = mocker.patch("smartmeter_datacollector.smartmeter.meter.SerialReader", | ||
autospec=True).return_value | ||
meter = LGE570("/test/port", decryption_key="101112131415161718191A1B1C1D1E1F") | ||
meter.register(observer) | ||
|
||
def data_received(): | ||
for frame in encrypted_valid_data_lge570: | ||
meter._data_received(frame) | ||
serial_mock.start_and_listen.side_effect = data_received | ||
|
||
await meter.start() | ||
|
||
serial_mock.start_and_listen.assert_awaited_once() | ||
observer.notify.assert_called_once() | ||
values = observer.notify.call_args.args[0] | ||
assert isinstance(values, list) | ||
assert any(data.type == MeterDataPointTypes.ACTIVE_POWER_P.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.ACTIVE_POWER_N.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.REACTIVE_POWER_P.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.REACTIVE_POWER_N.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.ACTIVE_ENERGY_P.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.ACTIVE_ENERGY_N.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.REACTIVE_ENERGY_Q1.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.REACTIVE_ENERGY_Q2.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.REACTIVE_ENERGY_Q3.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.REACTIVE_ENERGY_Q4.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.CURRENT_L1.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.CURRENT_L2.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.CURRENT_L3.value for data in values) | ||
assert any(data.type == MeterDataPointTypes.POWER_FACTOR.value for data in values) | ||
assert all(data.source == "LGZ1030769231253" for data in values) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters