mirror of
https://github.com/steinhobelgruen/netatmo-exporter.git
synced 2024-11-22 09:23:56 +00:00
300 lines
8.6 KiB
Go
300 lines
8.6 KiB
Go
package netatmo
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"net/url"
|
|
"strings"
|
|
|
|
"golang.org/x/oauth2"
|
|
)
|
|
|
|
const (
|
|
// DefaultBaseURL is netatmo api url
|
|
baseURL = "https://api.netatmo.net/"
|
|
// DefaultAuthURL is netatmo auth url
|
|
authURL = baseURL + "oauth2/token"
|
|
// DefaultDeviceURL is netatmo device url
|
|
deviceURL = baseURL + "/api/getstationsdata"
|
|
)
|
|
|
|
// Config is used to specify credential to Netatmo API
|
|
// ClientID : Client ID from netatmo app registration at http://dev.netatmo.com/dev/listapps
|
|
// ClientSecret : Client app secret
|
|
// Username : Your netatmo account username
|
|
// Password : Your netatmo account password
|
|
type Config struct {
|
|
ClientID string
|
|
ClientSecret string
|
|
Username string
|
|
Password string
|
|
}
|
|
|
|
// Client use to make request to Netatmo API
|
|
type Client struct {
|
|
oauth *oauth2.Config
|
|
httpClient *http.Client
|
|
httpResponse *http.Response
|
|
Dc *DeviceCollection
|
|
}
|
|
|
|
// DeviceCollection hold all devices from netatmo account
|
|
type DeviceCollection struct {
|
|
Body struct {
|
|
Devices []*Device `json:"devices"`
|
|
}
|
|
}
|
|
|
|
// Device is a station or a module
|
|
// ID : Mac address
|
|
// StationName : Station name (only for station)
|
|
// ModuleName : Module name
|
|
// BatteryPercent : Percentage of battery remaining
|
|
// WifiStatus : Wifi status per Base station
|
|
// RFStatus : Current radio status per module
|
|
// Type : Module type :
|
|
// "NAMain" : for the base station
|
|
// "NAModule1" : for the outdoor module
|
|
// "NAModule4" : for the additionnal indoor module
|
|
// "NAModule3" : for the rain gauge module
|
|
// "NAModule2" : for the wind gauge module
|
|
// DashboardData : Data collection from device sensors
|
|
// DataType : List of available datas
|
|
// LinkedModules : Associated modules (only for station)
|
|
type Device struct {
|
|
ID string `json:"_id"`
|
|
StationName string `json:"station_name"`
|
|
ModuleName string `json:"module_name"`
|
|
BatteryPercent *int32 `json:"battery_percent,omitempty"`
|
|
WifiStatus *int32 `json:"wifi_status,omitempty"`
|
|
RFStatus *int32 `json:"rf_status,omitempty"`
|
|
Type string
|
|
DashboardData DashboardData `json:"dashboard_data"`
|
|
//DataType []string `json:"data_type"`
|
|
LinkedModules []*Device `json:"modules"`
|
|
}
|
|
|
|
// DashboardData is used to store sensor values
|
|
// Temperature : Last temperature measure @ LastMeasure (in °C)
|
|
// Humidity : Last humidity measured @ LastMeasure (in %)
|
|
// CO2 : Last Co2 measured @ time_utc (in ppm)
|
|
// Noise : Last noise measured @ LastMeasure (in db)
|
|
// Pressure : Last Sea level pressure measured @ LastMeasure (in mb)
|
|
// AbsolutePressure : Real measured pressure @ LastMeasure (in mb)
|
|
// Rain : Last rain measured (in mm)
|
|
// Rain1Hour : Amount of rain in last hour
|
|
// Rain1Day : Amount of rain today
|
|
// WindAngle : Current 5 min average wind direction @ LastMeasure (in °)
|
|
// WindStrength : Current 5 min average wind speed @ LastMeasure (in km/h)
|
|
// GustAngle : Direction of the last 5 min highest gust wind @ LastMeasure (in °)
|
|
// GustStrength : Speed of the last 5 min highest gust wind @ LastMeasure (in km/h)
|
|
// LastMeasure : Contains timestamp of last data received
|
|
type DashboardData struct {
|
|
Temperature *float32 `json:"Temperature,omitempty"` // use pointer to detect ommitted field by json mapping
|
|
Humidity *int32 `json:"Humidity,omitempty"`
|
|
CO2 *int32 `json:"CO2,omitempty"`
|
|
Noise *int32 `json:"Noise,omitempty"`
|
|
Pressure *float32 `json:"Pressure,omitempty"`
|
|
AbsolutePressure *float32 `json:"AbsolutePressure,omitempty"`
|
|
Rain *float32 `json:"Rain,omitempty"`
|
|
Rain1Hour *float32 `json:"sum_rain_1,omitempty"`
|
|
Rain1Day *float32 `json:"sum_rain_24,omitempty"`
|
|
WindAngle *int32 `json:"WindAngle,omitempty"`
|
|
WindStrength *int32 `json:"WindStrength,omitempty"`
|
|
GustAngle *int32 `json:"GustAngle,omitempty"`
|
|
GustStrength *int32 `json:"GustStrength,omitempty"`
|
|
LastMeasure *int64 `json:"time_utc"`
|
|
}
|
|
|
|
// NewClient create a handle authentication to Netamo API
|
|
func NewClient(config Config) (*Client, error) {
|
|
oauth := &oauth2.Config{
|
|
ClientID: config.ClientID,
|
|
ClientSecret: config.ClientSecret,
|
|
Scopes: []string{"read_station"},
|
|
Endpoint: oauth2.Endpoint{
|
|
AuthURL: baseURL,
|
|
TokenURL: authURL,
|
|
},
|
|
}
|
|
|
|
token, err := oauth.PasswordCredentialsToken(oauth2.NoContext, config.Username, config.Password)
|
|
|
|
return &Client{
|
|
oauth: oauth,
|
|
httpClient: oauth.Client(oauth2.NoContext, token),
|
|
Dc: &DeviceCollection{},
|
|
}, err
|
|
}
|
|
|
|
// do a url encoded HTTP POST request
|
|
func (c *Client) doHTTPPostForm(url string, data url.Values) (*http.Response, error) {
|
|
|
|
req, err := http.NewRequest("POST", url, strings.NewReader(data.Encode()))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
//req.ContentLength = int64(reader.Len())
|
|
req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
|
|
|
|
return c.doHTTP(req)
|
|
}
|
|
|
|
// send http GET request
|
|
func (c *Client) doHTTPGet(url string, data url.Values) (*http.Response, error) {
|
|
if data != nil {
|
|
url = url + "?" + data.Encode()
|
|
}
|
|
req, err := http.NewRequest("GET", url, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return c.doHTTP(req)
|
|
}
|
|
|
|
// do a generic HTTP request
|
|
func (c *Client) doHTTP(req *http.Request) (*http.Response, error) {
|
|
|
|
// debug
|
|
//debug, _ := httputil.DumpRequestOut(req, true)
|
|
//fmt.Printf("%s\n\n", debug)
|
|
|
|
var err error
|
|
c.httpResponse, err = c.httpClient.Do(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return c.httpResponse, nil
|
|
}
|
|
|
|
// process HTTP response
|
|
// Unmarshall received data into holder struct
|
|
func processHTTPResponse(resp *http.Response, err error, holder interface{}) error {
|
|
defer resp.Body.Close()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// debug
|
|
//debug, _ := httputil.DumpResponse(resp, true)
|
|
//fmt.Printf("%s\n\n", debug)
|
|
|
|
// check http return code
|
|
if resp.StatusCode != 200 {
|
|
//bytes, _ := ioutil.ReadAll(resp.Body)
|
|
return fmt.Errorf("Bad HTTP return code %d", resp.StatusCode)
|
|
}
|
|
|
|
// Unmarshall response into given struct
|
|
if err = json.NewDecoder(resp.Body).Decode(holder); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// GetStations returns the list of stations owned by the user, and their modules
|
|
func (c *Client) Read() (*DeviceCollection, error) {
|
|
resp, err := c.doHTTPGet(deviceURL, url.Values{"app_type": {"app_station"}})
|
|
//dc := &DeviceCollection{}
|
|
|
|
if err = processHTTPResponse(resp, err, c.Dc); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return c.Dc, nil
|
|
}
|
|
|
|
// Devices returns the list of devices
|
|
func (dc *DeviceCollection) Devices() []*Device {
|
|
return dc.Body.Devices
|
|
}
|
|
|
|
// Stations is an alias of Devices
|
|
func (dc *DeviceCollection) Stations() []*Device {
|
|
return dc.Devices()
|
|
}
|
|
|
|
// Modules returns associated device module
|
|
func (d *Device) Modules() []*Device {
|
|
modules := d.LinkedModules
|
|
modules = append(modules, d)
|
|
|
|
return modules
|
|
}
|
|
|
|
// Data returns timestamp and the list of sensor value for this module
|
|
func (d *Device) Data() (int64, map[string]interface{}) {
|
|
|
|
// return only populate field of DashboardData
|
|
m := make(map[string]interface{})
|
|
|
|
if d.DashboardData.Temperature != nil {
|
|
m["Temperature"] = *d.DashboardData.Temperature
|
|
}
|
|
if d.DashboardData.Humidity != nil {
|
|
m["Humidity"] = *d.DashboardData.Humidity
|
|
}
|
|
if d.DashboardData.CO2 != nil {
|
|
m["CO2"] = *d.DashboardData.CO2
|
|
}
|
|
if d.DashboardData.Noise != nil {
|
|
m["Noise"] = *d.DashboardData.Noise
|
|
}
|
|
if d.DashboardData.Pressure != nil {
|
|
m["Pressure"] = *d.DashboardData.Pressure
|
|
}
|
|
if d.DashboardData.AbsolutePressure != nil {
|
|
m["AbsolutePressure"] = *d.DashboardData.AbsolutePressure
|
|
}
|
|
if d.DashboardData.Rain != nil {
|
|
m["Rain"] = *d.DashboardData.Rain
|
|
}
|
|
if d.DashboardData.Rain1Hour != nil {
|
|
m["Rain1Hour"] = *d.DashboardData.Rain1Hour
|
|
}
|
|
if d.DashboardData.Rain1Day != nil {
|
|
m["Rain1Day"] = *d.DashboardData.Rain1Day
|
|
}
|
|
if d.DashboardData.WindAngle != nil {
|
|
m["WindAngle"] = *d.DashboardData.WindAngle
|
|
}
|
|
if d.DashboardData.WindStrength != nil {
|
|
m["WindStrength"] = *d.DashboardData.WindStrength
|
|
}
|
|
if d.DashboardData.GustAngle != nil {
|
|
m["GustAngle"] = *d.DashboardData.GustAngle
|
|
}
|
|
if d.DashboardData.GustAngle != nil {
|
|
m["GustAngle"] = *d.DashboardData.GustAngle
|
|
}
|
|
if d.DashboardData.GustStrength != nil {
|
|
m["GustStrength"] = *d.DashboardData.GustStrength
|
|
}
|
|
|
|
return *d.DashboardData.LastMeasure, m
|
|
}
|
|
|
|
// Info returns timestamp and the list of info value for this module
|
|
func (d *Device) Info() (int64, map[string]interface{}) {
|
|
|
|
// return only populate field of DashboardData
|
|
m := make(map[string]interface{})
|
|
|
|
// Return data from module level
|
|
if d.BatteryPercent != nil {
|
|
m["BatteryPercent"] = *d.BatteryPercent
|
|
}
|
|
if d.WifiStatus != nil {
|
|
m["WifiStatus"] = *d.WifiStatus
|
|
}
|
|
if d.RFStatus != nil {
|
|
m["RFStatus"] = *d.RFStatus
|
|
}
|
|
|
|
return *d.DashboardData.LastMeasure, m
|
|
}
|