@@ -16,40 +16,70 @@ def __init__(self):
1616
1717 async def reload_config (self ):
1818 from . import models
19+
1920 self .config = await models .Config .load_async ()
2021
21- #logging.info("reload config: mode=" + str(self.config.rfid_2_server_mode) + " test="+str(self.config.rfid_2_server_test) + " url="+self.config.rfid_2_server_url)
22- if self .config .rfid_2_server_test : self .send_rfid_2_url ("rfid_uid_test" ,"event_test" ,"app_test" ,"support_test" ,"packet_test" )
22+ # logging.info("reload config: mode=" + str(
23+ # self.config.rfid_2_server_mode) + " test=" + str(
24+ # self.config.rfid_2_server_test) + " url=" + \
25+ # self.config.rfid_2_server_url)
26+ if self .config .rfid_2_server_test :
27+ self .send_rfid_2_url (
28+ "rfid_uid_test" ,
29+ "event_test" ,
30+ "app_test" ,
31+ "support_test" ,
32+ "packet_test" ,
33+ )
2334
2435 async def process_nabd_packet (self , packet ):
25- if ( self .config .rfid_2_server_mode == 0 or (packet ["type" ] != "rfid_event" ) ): return # Never send url
36+ if self .config .rfid_2_server_mode == 0 or (
37+ packet ["type" ] != "rfid_event"
38+ ):
39+ return # Never send url
2640
27- if "app" not in packet : app = "none"
28- else : app = packet ["app" ]
29- if "support" not in packet : supp = "support unknown"
30- else : supp = packet ["support" ]
31- if "event" not in packet : _event = "no event"
32- else : _event = packet ["event" ]
41+ if "app" not in packet :
42+ app = "none"
43+ else :
44+ app = packet ["app" ]
45+ if "support" not in packet :
46+ supp = "support unknown"
47+ else :
48+ supp = packet ["support" ]
49+ if "event" not in packet :
50+ _event = "no event"
51+ else :
52+ _event = packet ["event" ]
3353
34- if (self .config .rfid_2_server_mode == 1 ) and (supp == "formatted" ) and (app == "none" ) : return # Send only unknown tags
35- self .send_rfid_2_url (packet ["uid" ],_event ,app ,supp ,packet )
54+ if (
55+ (self .config .rfid_2_server_mode == 1 )
56+ and (supp == "formatted" )
57+ and (app == "none" )
58+ ):
59+ return # Send only unknown tags
60+ self .send_rfid_2_url (packet ["uid" ], _event , app , supp , packet )
3661
37- def send_rfid_2_url (self , uid ,_event ,app ,supp ,packet ):
38- #logging.info("send rfid 2 url: mode=" + str(self.config.rfid_2_server_mode) + " test="+str(self.config.rfid_2_server_test) + " url="+self.config.rfid_2_server_url)
39- url_message = self .config .rfid_2_server_url .replace ("#RFID_TAG#" ,uid )
40- url_message = url_message .replace ("#RFID_APP#" ,app )
41- url_message = url_message .replace ("#RFID_FLAGS#" ,supp )
42- url_message = url_message .replace ("#RFID_STATE#" ,_event )
43- str_pack = json .dumps (packet );
44- url_message = url_message .replace ("#RFID_PACK#" ,str_pack )
62+ def send_rfid_2_url (self , uid , _event , app , supp , packet ):
63+ # logging.info("send rfid 2 url: mode=" + str(
64+ # self.config.rfid_2_server_mode) + " test=" + str(
65+ # self.config.rfid_2_server_test) + " url=" + \
66+ # self.config.rfid_2_server_url)
67+ url_message = self .config .rfid_2_server_url .replace ("#RFID_TAG#" , uid )
68+ url_message = url_message .replace ("#RFID_APP#" , app )
69+ url_message = url_message .replace ("#RFID_FLAGS#" , supp )
70+ url_message = url_message .replace ("#RFID_STATE#" , _event )
71+ str_pack = json .dumps (packet )
72+ url_message = url_message .replace ("#RFID_PACK#" , str_pack )
4573 str_pack = str_pack .lower ()
46- str_pack = str_pack .replace ('\ " ' ,'' )
47- url_message = url_message .replace ("#RFID_JEEPACK#" ,str_pack )
48- f = requests .get (url_message )
74+ str_pack = str_pack .replace ('"' , "" )
75+ url_message = url_message .replace ("#RFID_JEEPACK#" , str_pack )
76+ requests .get (url_message )
4977
5078 async def client_loop (self ):
5179 try :
52- idle_packet = '{"type":"mode","mode":"idle","events":["rfid/*"]}\r \n '
80+ idle_packet = (
81+ '{"type":"mode","mode":"idle","events":["rfid/*"]}\r \n '
82+ )
5383 self .writer .write (idle_packet .encode ())
5484 while self .running and not self .reader .at_eof ():
5585 line = await self .reader .readline ()
@@ -70,5 +100,6 @@ async def client_loop(self):
70100 if self .running :
71101 self .loop .stop ()
72102
103+
73104if __name__ == "__main__" :
74105 NabRfid2server .main (sys .argv [1 :])
0 commit comments