mirror of
https://github.com/ail-project/ail-framework.git
synced 2024-11-23 14:37:17 +00:00
33 lines
674 B
Python
33 lines
674 B
Python
|
#!/usr/bin/env python
|
||
|
|
# -*- coding: utf-8 -*-
|
||
|
|
#
|
||
|
|
# This file is part of AIL framework - Analysis Information Leak framework
|
||
|
|
#
|
||
|
|
#
|
||
|
|
# Python script to test if the ZMQ feed works as expected
|
||
|
|
#
|
||
|
|
|
||
|
|
import sys
|
||
|
|
import zmq
|
||
|
|
|
||
|
|
port = "5556"
|
||
|
|
|
||
|
|
context = zmq.Context()
|
||
|
|
socket = context.socket(zmq.SUB)
|
||
|
|
socket.connect ("tcp://crf.circl.lu:%s" % port)
|
||
|
|
|
||
|
|
# 101 Name of the pastes only
|
||
|
|
# 102 Full pastes in raw base64(gz)
|
||
|
|
|
||
|
|
topicfilter = "102"
|
||
|
|
socket.setsockopt(zmq.SUBSCRIBE, topicfilter)
|
||
|
|
|
||
|
|
while True:
|
||
|
|
message = socket.recv()
|
||
|
|
print (message)
|
||
|
|
if topicfilter == "102":
|
||
|
|
topic, paste, messagedata = message.split()
|
||
|
|
print paste, messagedata
|
||
|
|
else:
|
||
|
|
print (message)
|