import json, base64, socket, wx

#AXUDP=("127.0.0.1",4020)
#AXUDP=("192.168.1.24",4020)
#AXUDP=("192.168.1.32",2300)
AXUDP=("192.168.1.24",4020)
JSONPORT=5200                                # from lorarx
IP=("0.0.0.0",JSONPORT)
metainfo=True
longcalls=False                              # True for 7..9 char calls or ssid >15 if axudp2 destination is able to read this



def num(c):
  if (c<"0") or (c>"9"): return
  return ord(c)-ord("0")

def getpos(s):
  if len(s)!=19: return

  lat=num(s[0])*10 + num(s[1]) + (num(s[2])*1000 + num(s[3])*100 + num(s[5])*10 + num(s[6]))/6000.0 
  if s[7]=="S": lat=-lat
  elif s[7]!="N": return
  
  long=num(s[9])*100 + num(s[10])*10 + num(s[11]) + (num(s[12])*1000 + num(s[13])*100 + num(s[15])*10 + num(s[16]))/6000.0 
  if s[17]=="W": long=-long
  elif s[17]!="E": return
  return lat, long, s[8]+s[18]

sock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
sock.bind(IP)

while True:
  data, addr=sock.recvfrom(1500)
# print(data)
      
  try:
    obj = json.loads(data.decode())
#   print(obj)
    payload=base64.b64decode(obj["payload"])                    #base64 coded frame
    try: print("payload=", payload)
    except: print("print error")
  except: print("json decode error")
  else:
#    s=""
#    for i in range(j,len(payload)): s+=chr(payload[i])        #remove junk and make string type
    if obj["crc"]!=1:  print("no crc or crc error")
##  elif obj["net"]!=0x22 & obj["net"]!=0x23 & obj["net"]!=0x2B: print("wrong net-id")
    elif (len(payload)>5) & (payload[0]==ord("!")):
###fcs
      i=0 
      te=0
      while (te+3<len(payload)) & ((te<6) or (payload[te]!=0)):
        i+=payload[te]
        te+=1
      i+=payload[te+1] + payload[te+2]
      ok=(te+5<len(payload)) & (i == payload[te+3]*256 + payload[te+4])
#fcs                              
      if ok:
        morp=0
        sm=""
        eos=6
        while (eos<len(payload)) & (payload[eos]!=0):
          sm+=chr(payload[eos])
          eos+=1

        i=0
        my=""
        while (i<len(sm)) & (sm[i]!=",") & (sm[i]!=">"):
          my+=sm[i]
          i+=1

        pat=""
        if sm[i]==",":
          i+=1
          while (i<len(sm)) & (sm[i]!=">"):
            pat+=sm[i]
            i+=1
        
        dst=""
        if sm[i]==">":
          i+=1
          while (i<len(sm)) & (sm[i]!="!") & (sm[i]!=":"):
            dst+=sm[i]
            i+=1
          morp=i

        s=my+">APMESH"
        if len(pat)>0:
           s+=","+pat+"*"
           
        s+=":"  
        prmsg=""
        if morp>0:           
          if sm[morp]=="!":                                                 # position           
             try: lat,long,sym=getpos(sm[morp+1:morp+20])
             except: 
               lat=0.0
               long=0.0
               sym="  "
               ok=False
             s+="!"+sm[morp+1:morp+20]
             s+=sm[morp+20:]
             print("pos:",ok,sym,lat,long)
          elif (sm[morp]==":") & (dst!="*"):                                # message
             print("msg")
             msgto=dst+"         "
             s+=":"+dst[0:10]+":"+sm[morp+1:]
             prmsg=s
          else: ok=False
        else: ok=False

           
        mid=payload[1] + payload[2]*0x100 + payload[3]*0x10000 + payload[4]*0x1000000
        hop=payload[5] & 7
        vmq=payload[5] & 0x80 != 0
        tra=payload[5] & 0x40 != 0
        s+=" MID:" + "{:X}".format(mid) + " HOPS:" + str(hop)
        if eos+2<len(payload):
          hw=payload[eos+1]
          mod=payload[eos+2]
          s+=" HW=" + str(hw) + " MOD=" +str(mod)
        if eos+6<len(payload):
          fwl=payload[eos+5]
          fwh=payload[eos+6]
          s+=" FW=" + str(fwh) + "." +str(fwl)

        if vmq: s+=" viaMQTT"
        if tra: s+=" TRACE"
        if ok:
          ms=""
          axmeta={}
          if longcalls: axmeta["longcalls"]=2
          try: v=obj["snr"]
          except: pass
          else:
            ms+=" snr="+"{:.1f}".format(v)+"dB"
            axmeta["snr"]=v
          try: v=obj["afc"]
          except: pass
          else:
            ms+=" afc="+"{:.0f}".format(v)+"Hz"
            axmeta["afc"]=v
          try: v=obj["preamb"]
          except: pass
          else:
            ms+=" txd="+"{:.0f}".format(v)+"ms"
            axmeta["txdel"]=v
          try: v=obj["level"]
          except: pass
          else:
            ms+=" lev="+"{:.0f}".format(v)+"dB"
            axmeta["level"]=v
          try: v=obj["eye"]
          except: pass
          else:
            ms+=" q="+"{:.0f}".format(v)+"%"
            axmeta["quality"]=v
          try: v=obj["bw"]
          except: pass
          else: ms+=" bw="+"{:.0f}".format(v)+"Hz"
          try: v=obj["net"]
          except: pass
          else: ms+=" net="+"{:X}".format(v)
          try: v=obj["rxmhz"]
          except: pass
          else: ms+=" rx="+"{:.3f}".format(v)+"MHz"
          try:
            v=obj["sf"]
            vi=obj["invers"]
          except: pass
          else:
            ms+=" sf="+"{:.0f}".format(v)
            if vi: ms+="(inv)"
          try: v=obj["cr"]
          except: pass
          else: ms+=" cr="+"{:.0f}".format(v)
          try: v=obj["ver"]
          except: pass
          else: ms+=" vers="+v
#          if metainfo and not (s.find(",") in range(0,s.find(":"))):    # only if no digi path
#            s+=ms
#          print("frame:",s)
#          try:  wx.sendax(sock, s, AXUDP, axmeta) 
#          except: print("axudp encode error")

          if metainfo: s+=ms
          try: print(s)
          except: print("print error")
          print()
          if prmsg: s=prmsg
          try:  wx.sendax(sock, s, AXUDP, axmeta) 
          except: print("axudp encode error")
      else: print("fcs error")