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

Commented Mixer.py for further multiple feeds support.

pull/96/head
Mokaddem 2016-12-26 16:23:18 +01:00
parent 1c2169d3bc
commit 3a298f0c7c
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
bin/Mixer.py
View File

@ -112,6 +112,7 @@ if __name__ == '__main__':
duplicated_paste_per_feeder[feeder_name] += 1 duplicated_paste_per_feeder[feeder_name] += 1
else: # New content else: # New content
p.populate_set_out(relay_message) p.populate_set_out(relay_message)
# OR populate another set based on the feeder_name
server.sadd(gzip64encoded, feeder_name) server.sadd(gzip64encoded, feeder_name)
server.expire(gzip64encoded, ttl_key) server.expire(gzip64encoded, ttl_key)
@ -128,6 +129,7 @@ if __name__ == '__main__':
server.expire(paste_name, ttl_key) server.expire(paste_name, ttl_key)
server.expire('HASH_'+paste_name, ttl_key) server.expire('HASH_'+paste_name, ttl_key)
p.populate_set_out(relay_message) p.populate_set_out(relay_message)
# OR populate another set based on the feeder_name
else: else:
if gzip64encoded != content: if gzip64encoded != content:
# Same paste name but different content # Same paste name but different content
@ -136,6 +138,7 @@ if __name__ == '__main__':
server.sadd(paste_name, feeder_name) server.sadd(paste_name, feeder_name)
server.expire(paste_name, ttl_key) server.expire(paste_name, ttl_key)
p.populate_set_out(relay_message) p.populate_set_out(relay_message)
# OR populate another set based on the feeder_name
else: else:
# Already processed # Already processed
# Keep track of processed pastes # Keep track of processed pastes