Fragmentation_Ack_Always.py

from SCHCPParserTool.compr_core import T_DIR_UP
from SCHCPParserTool.parser import SCHCParser
import binascii

parser = SCHCParser()
#parser.rule_file = "lorawan.json"
#parser.rm.Add(file=parser.rule_file)
#parser.rm.Print() # To Check the Rule

# We add a DevEUI and AppSKey to the parser object:
DevEUI = '1122334455667788'
AppSKey = '00AABBCCDDEEFF00AABBCCDDEEFFAABB'

parser.changeDevEUI (DevEUI=DevEUI)
parser.changeAppSKey (AppSKey=AppSKey)

no_comp_rule = 22
udp_data = bytearray(36)

# Create a No compress packet to be fragmented later
no_compress_pkt = no_comp_rule.to_bytes(1,'big') + parser.generateIPv6UDP(no_comp_rule, udp_data = udp_data, dir = "DW")
print ("no_compress_pkt", binascii.hexlify(no_compress_pkt), len(no_compress_pkt))

no_compress_pkt_parsed = SCHCParser.parse_schc_msg(parser, schc_pkt=no_compress_pkt, dir = "DW")
print(no_compress_pkt_parsed)

# Let's create fragments with AA
rule_id = 21 # AA Rule ID
JSON_Hint = {"RuleIDValue": rule_id, 
             "Direction": "DW",
             "MTU":30,
             }

# We generate the fragments to be sent, the parser is on json with all the values per fragment including RCS


json, fragments = SCHCParser.generate_schc_msg(parser, packet = no_compress_pkt ,hint = JSON_Hint, padding = "")
print(json)

ACK_OK_1 = binascii.unhexlify('1520')  # 00100000 ACK ok for first packet  15 in Fport
ACK_OK_2 = binascii.unhexlify('15a0')  # 10100000 ACK ok for second packet  
ACK_OK_3 = binascii.unhexlify('1540')  # 01000000 ACK ok for last packet  

ack_ok_1_parsed = SCHCParser.parse_schc_msg(parser, schc_pkt=ACK_OK_1, dir= T_DIR_UP)
print(ack_ok_1_parsed)

ack_ok_2_parsed = SCHCParser.parse_schc_msg(parser, schc_pkt=ACK_OK_2, dir= T_DIR_UP)
print(ack_ok_2_parsed)

ack_ok_3_parsed = SCHCParser.parse_schc_msg(parser, schc_pkt=ACK_OK_3, dir= T_DIR_UP)
print(ack_ok_3_parsed)


# For test 15, receiver abort:

REC_ABORT = binascii.unhexlify('15FFFF')  #  1111111111111111 ACK ok for first packet  15 in Fport

rec_abort_parsed = SCHCParser.parse_schc_msg(parser, schc_pkt=REC_ABORT, dir= T_DIR_UP)
#print(rec_abort_parsed)

# For test 16, ACK Request:

ACK_REQ = binascii.unhexlify('1580') # 10000000 ACK Request for w=1, Rule id 15 in fport