CIRCL
/
AIL-framework
mirror of https://github.com/CIRCL/AIL-framework
2
1
Fork 0
Code Issues Releases Wiki Activity

chg: [feeder pystemon] add debug

pull/519/head
Terrtia 2020-07-02 08:31:47 +02:00
parent 25420005e7
commit be3446ff97
No known key found for this signature in database
GPG Key ID: 1E1B1F50D84613D0
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
bin/feeder/pystemon-feeder.py
View File

@ -57,14 +57,20 @@ topic = '102'
while True: while True:
time.sleep(base_sleeptime + sleep_inc) time.sleep(base_sleeptime + sleep_inc)
paste = r.lpop("pastes") item_id = r.lpop("pastes")
if paste is None: if item_id is None:
continue continue
try: try:
print(paste) print(item_id)
with open(pystemonpath+paste, 'rb') as f: #.read() full_item_path = os.path.join(pystemonpath, item_id)
if not os.path.isfile(full_item_path):
print('Error: {}, file not found'.format(full_item_path))
sleep_inc = 1
continue
with open(full_item_path, 'rb') as f: #.read()
messagedata = f.read() messagedata = f.read()
path_to_send = os.path.join(pastes_directory,paste) path_to_send = os.path.join(pastes_directory, item_id)
s = b' '.join( [ topic.encode(), path_to_send.encode(), base64.b64encode(messagedata) ] ) s = b' '.join( [ topic.encode(), path_to_send.encode(), base64.b64encode(messagedata) ] )
socket.send(s) socket.send(s)