|
|
|
@ -454,9 +454,6 @@ class LNSerializer: |
|
|
|
try: |
|
|
|
try: |
|
|
|
field_value = kwargs[field_name] |
|
|
|
field_value = kwargs[field_name] |
|
|
|
except KeyError: |
|
|
|
except KeyError: |
|
|
|
if len(row) > 5: |
|
|
|
|
|
|
|
break # optional feature field not present |
|
|
|
|
|
|
|
else: |
|
|
|
|
|
|
|
field_value = 0 # default mandatory fields to zero |
|
|
|
field_value = 0 # default mandatory fields to zero |
|
|
|
#print(f">>> encode_msg. writing field: {field_name}. value={field_value!r}. field_type={field_type!r}. count={field_count!r}") |
|
|
|
#print(f">>> encode_msg. writing field: {field_name}. value={field_value!r}. field_type={field_type!r}. count={field_count!r}") |
|
|
|
_write_field(fd=fd, |
|
|
|
_write_field(fd=fd, |
|
|
|
@ -507,15 +504,10 @@ class LNSerializer: |
|
|
|
parsed[tlv_stream_name] = d |
|
|
|
parsed[tlv_stream_name] = d |
|
|
|
continue |
|
|
|
continue |
|
|
|
#print(f">> count={field_count}. parsed={parsed}") |
|
|
|
#print(f">> count={field_count}. parsed={parsed}") |
|
|
|
try: |
|
|
|
parsed[field_name] = _read_field( |
|
|
|
parsed[field_name] = _read_field(fd=fd, |
|
|
|
fd=fd, |
|
|
|
field_type=field_type, |
|
|
|
field_type=field_type, |
|
|
|
count=field_count) |
|
|
|
count=field_count) |
|
|
|
except UnexpectedEndOfStream as e: |
|
|
|
|
|
|
|
if len(row) > 5: |
|
|
|
|
|
|
|
break # optional feature field not present |
|
|
|
|
|
|
|
else: |
|
|
|
|
|
|
|
raise |
|
|
|
|
|
|
|
else: |
|
|
|
else: |
|
|
|
raise Exception(f"unexpected row in scheme: {row!r}") |
|
|
|
raise Exception(f"unexpected row in scheme: {row!r}") |
|
|
|
except FailedToParseMsg as e: |
|
|
|
except FailedToParseMsg as e: |
|
|
|
|