import datetime
import glob
import logging
import os
import pickle
import speedtest
import sys

from sqlalchemy import Column, Integer, String, Float, DateTime, Boolean
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker


class Measurement(declarative_base()):
    __tablename__ = 'speed_measurement'
    id = Column(Integer, primary_key=True)
    client_name = Column(String)
    client_ip = Column(String)
    client_lat = Column(Float)
    client_lon = Column(Float)
    client_isp = Column(String)
    client_cc = Column(String)
    server_url = Column(String)
    server_lat = Column(Float)
    server_lon = Column(Float)
    server_cc = Column(String)
    server_city = Column(String)
    server_ping = Column(Float)
    upload = Column(Float)
    download = Column(Float)
    timestamp = Column(DateTime)
    success = Column(Boolean)
    message = Column(String)


def take_measurement(process):
    speed_test = speedtest.Speedtest()
    best_server = speed_test.get_best_server()

    download = speed_test.download()
    upload = speed_test.upload()
    config = speed_test.get_config()

    measurement = Measurement(
        client_name=process,
        client_ip=config['client']['ip'],
        client_lat=config['client']['lat'],
        client_lon=config['client']['lon'],
        client_isp=config['client']['isp'],
        client_cc=config['client']['country'],
        server_url=best_server['host'],
        server_lat=best_server['lat'],
        server_lon=best_server['lon'],
        server_cc=best_server['cc'],
        server_city=best_server['name'],
        server_ping=best_server['latency'],
        upload=upload / 1000000.0,
        download=download / 1000000.0,
        timestamp=datetime.datetime.now(),
        success=True,
        message='Pass.')

    file = "{}.pickle".format(
        measurement.timestamp.strftime("%Y_%d_%m-%H_%M_%S-%f"))
    pickle.dump(measurement, open(file, "wb"))
    logging.info("Measurement {} SAVED\n".format(file))


def get_session(db, user, schema, host, password):
    session = sessionmaker()
    engine = create_engine(
        '{}://{}:{}@{}/{}'.format(db, user, password, host, schema))
    session.configure(bind=engine)
    return session()


def persist_measurement(measurement, file, session):
    session.add(measurement)
    session.commit()
    logging.info("Measurement {} PERSISTED id {}".format(file, measurement.id))


def record_measurements(session):
    for file in glob.glob("*.pickle"):
        logging.info("Measurement {} RECORDED".format(file))
        measurement = pickle.load(open(file, "rb"))
        persist_measurement(measurement, file, session)
        os.remove(file)
        logging.info("Measurement {} CLEARED\n".format(file))


def exception_handler(exc_type, exc_value, traceback):
    logging.error("Uncaught Exception",
                  exc_info=(exc_type, exc_value, traceback))
    logging.info("STOPPED {}\n\n".format(datetime.datetime.now()))


def measure(process, db, user, schema, host, password):
    sys.excepthook = exception_handler
    logging.basicConfig(filename='measurements.log', level=logging.DEBUG)
    logging.info("STARTED {}\n".format(datetime.datetime.now()))
    take_measurement(process)
    session = get_session(db, user, schema, host, password)
    record_measurements(session)
    logging.info("STOPPED {}\n\n".format(datetime.datetime.now()))


if __name__ == '__main__':
    measure(sys.argv[1], sys.argv[2], sys.argv[3], sys.argv[4], sys.argv[5],
            sys.argv[6])

import datetime
import glob
import logging
import os
import pickle
import speedtest
import sys

from sqlalchemy import Column, Integer, String, Float, DateTime, Boolean
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker


class Measurement(declarative_base()):
    __tablename__ = 'speed_measurement'
    id = Column(Integer, primary_key=True)
    client_name = Column(String)
    client_ip = Column(String)
    client_lat = Column(Float)
    client_lon = Column(Float)
    client_isp = Column(String)
    client_cc = Column(String)
    server_url = Column(String)
    server_lat = Column(Float)
    server_lon = Column(Float)
    server_cc = Column(String)
    server_city = Column(String)
    server_ping = Column(Float)
    upload = Column(Float)
    download = Column(Float)
    timestamp = Column(DateTime)
    success = Column(Boolean)
    message = Column(String)


def take_measurement(process):
    speed_test = speedtest.Speedtest()
    best_server = speed_test.get_best_server()

    download = speed_test.download()
    upload = speed_test.upload()
    config = speed_test.get_config()

    measurement = Measurement(
        client_name=process,
        client_ip=config['client']['ip'],
        client_lat=config['client']['lat'],
        client_lon=config['client']['lon'],
        client_isp=config['client']['isp'],
        client_cc=config['client']['country'],
        server_url=best_server['host'],
        server_lat=best_server['lat'],
        server_lon=best_server['lon'],
        server_cc=best_server['cc'],
        server_city=best_server['name'],
        server_ping=best_server['latency'],
        upload=upload / 1000000.0,
        download=download / 1000000.0,
        timestamp=datetime.datetime.now(),
        success=True,
        message='Pass.')

    file = "{}.pickle".format(
        measurement.timestamp.strftime("%Y_%d_%m-%H_%M_%S-%f"))
    pickle.dump(measurement, open(file, "wb"))
    logging.info("Measurement {} SAVED\n".format(file))


def get_session(db, user, schema, host, password):
    session = sessionmaker()
    engine = create_engine(
        '{}://{}:{}@{}/{}'.format(db, user, password, host, schema))
    session.configure(bind=engine)
    return session()


def persist_measurement(measurement, file, session):
    session.add(measurement)
    session.commit()
    logging.info("Measurement {} PERSISTED id {}".format(file, measurement.id))


def record_measurements(session):
    for file in glob.glob("*.pickle"):
        logging.info("Measurement {} RECORDED".format(file))
        measurement = pickle.load(open(file, "rb"))
        persist_measurement(measurement, file, session)
        os.remove(file)
        logging.info("Measurement {} CLEARED\n".format(file))


def exception_handler(exc_type, exc_value, traceback):
    logging.error("Uncaught Exception",
                  exc_info=(exc_type, exc_value, traceback))
    logging.info("STOPPED {}\n\n".format(datetime.datetime.now()))


def measure(process, db, user, schema, host, password):
    sys.excepthook = exception_handler
    logging.basicConfig(filename='measurements.log', level=logging.DEBUG)
    logging.info("STARTED {}\n".format(datetime.datetime.now()))
    take_measurement(process)
    session = get_session(db, user, schema, host, password)
    record_measurements(session)
    logging.info("STOPPED {}\n\n".format(datetime.datetime.now()))


if __name__ == '__main__':
    measure(sys.argv[1], sys.argv[2], sys.argv[3], sys.argv[4], sys.argv[5],
            sys.argv[6])
