# Sean Corrigan 2020

from influxdb import InfluxDBClient
import json
import requests


## Influx Settings
serverip = "192.168.0.13"
serverport = 8086
serverdatabase = "telegraf"
servernickname = 'Yoo01pn.ddns.net' # Comes up as host in grafana/influx


## OpenWeatherMap Settings
lat = '43.8970929'
lon = '-78.865791'
api = '5292f0a17ecbe4b523fe0609ed2c556f'
jsonurl = "https://api.openweathermap.org/data/2.5/onecall?lat=" + lat + "&lon=" + lon + "&units=metric&appid=" + api

def weather():    # Actual Speedtest using speedtest-cli 
    response = json.loads(requests.get(jsonurl).text)
    return response
    
def uploadInfluxdata(host='192.168.0.13', port=8086): # Main upload section
    query = 'select Float_value from cpu_load_short;'
    query_where = 'select Int_value from cpu_load_short where host=$host;'
    bind_params = {'host': servernickname}
    response = weather()
    json_body = [
        {
            "measurement": "OpenWeather",
            "tags": {
                "host": servernickname,
            },
            
            "fields": {
                "Current Temp": response['current']['temp'],
                "Humidity": response['current']['humidity'],
                "Weather": response['current']['weather'][0]['main'],
                
            }
        }
    ]

    client = InfluxDBClient(host, port, database = serverdatabase)  # Init connection to Influx Server
    client.write_points(json_body)  # Write Speedtest results

uploadInfluxdata()