#---Creating measurement---------------------

ping = Ping(
    af=4,
    target="89.185.136.254",
    description="test",
    packets=1,
    interval=60)

source = AtlasSource(type="probes", value='16233', requested=1)

atlas_request = AtlasCreateRequest(
    start_time=datetime.utcnow(),
    key=ATLAS_API_KEY,
    measurements=[ping],
    sources=[source],
    is_oneoff=True
)

(is_success, response) = atlas_request.create()

print(is_success)
print(response)
mdata = Measurement(id=response['measurements'])
print(mdata)
print(mdata.status) #This prints 'None'

#-----------------------------------------------------------------
#--Getting results--------------------

def on_result_response(*args):
    """
    Function that will be called every time we receive a new result.
    Args is a tuple, so you should use args[0] to access the real message.
    """
    print(args)
    measurm = Measurement(id=args[0]['msm_id'])
    print(measurm)
    print(measurm.status)
    print(dir(measurm))

atlas_stream = AtlasStream()
atlas_stream.connect()

channel = "result"
# Bind function we want to run with every result message received
atlas_stream.bind_channel(channel, on_result_response)

# Subscribe to new stream for measurement results
stream_parameters = {"msm": response['measurements']}
print(datetime.utcnow())
atlas_stream.start_stream(stream_type="result", **stream_parameters)

# Timeout all subscriptions after 5 secs. Leave seconds empty for no timeout.
# Make sure you have this line after you start *all* your streams
atlas_stream.timeout(seconds=240)
print(datetime.utcnow())
# Shut down everything
atlas_stream.disconnect()