Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
746fbc4fff | ||
|
|
7610646e10 | ||
|
|
a6bc66667b | ||
|
|
0340b25733 |
@@ -1,6 +1,3 @@
|
|||||||
**Notice:** this repository is in need of a new maintainer. If you are interested or have ideas about this, please let me know.
|
|
||||||
|
|
||||||
|
|
||||||
DSMR Parser
|
DSMR Parser
|
||||||
===========
|
===========
|
||||||
|
|
||||||
|
|||||||
@@ -64,8 +64,11 @@ class FileReader(object):
|
|||||||
with open(self._file, "rb") as file_handle:
|
with open(self._file, "rb") as file_handle:
|
||||||
while True:
|
while True:
|
||||||
data = file_handle.readline()
|
data = file_handle.readline()
|
||||||
str = data.decode()
|
|
||||||
self.telegram_buffer.append(str)
|
if not data:
|
||||||
|
break
|
||||||
|
|
||||||
|
self.telegram_buffer.append(data.decode())
|
||||||
|
|
||||||
for telegram in self.telegram_buffer.get_all():
|
for telegram in self.telegram_buffer.get_all():
|
||||||
try:
|
try:
|
||||||
|
|||||||
@@ -0,0 +1,21 @@
|
|||||||
|
import unittest
|
||||||
|
import tempfile
|
||||||
|
|
||||||
|
from dsmr_parser.clients.filereader import FileReader
|
||||||
|
from dsmr_parser.telegram_specifications import V5
|
||||||
|
from test.example_telegrams import TELEGRAM_V5
|
||||||
|
|
||||||
|
|
||||||
|
class FileReaderTest(unittest.TestCase):
|
||||||
|
def test_read_as_object(self):
|
||||||
|
with tempfile.NamedTemporaryFile() as file:
|
||||||
|
with open(file.name, "w") as f:
|
||||||
|
f.write(TELEGRAM_V5)
|
||||||
|
|
||||||
|
telegrams = []
|
||||||
|
reader = FileReader(file=file.name, telegram_specification=V5)
|
||||||
|
# Call
|
||||||
|
for telegram in reader.read_as_object():
|
||||||
|
telegrams.append(telegram)
|
||||||
|
|
||||||
|
self.assertEqual(len(telegrams), 1)
|
||||||
Reference in New Issue
Block a user