95 lines
2.2 KiB
Go
95 lines
2.2 KiB
Go
package cmd
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
xj "github.com/basgys/goxml2json"
|
|
"io"
|
|
"log"
|
|
"net/http"
|
|
"strings"
|
|
)
|
|
|
|
type root struct {
|
|
Base struct {
|
|
Nombre string `json:"nombre"`
|
|
Prediccion struct {
|
|
Dia []struct {
|
|
Fecha string `json:"-fecha"`
|
|
Temperatura struct {
|
|
Maxima string `json:"maxima"`
|
|
Minima string `json:"minima"`
|
|
Dato []struct {
|
|
Valor string `json:"#content"`
|
|
Hora string `json:"-hora"`
|
|
}
|
|
}
|
|
Sens_Termica struct {
|
|
Maxima string `json:"maxima"`
|
|
Minima string `json:"minima"`
|
|
Dato []struct {
|
|
Valor string `json:"#content"`
|
|
Hora string `json:"-hora"`
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} `json:"root"`
|
|
}
|
|
|
|
func client() {
|
|
jsonData, err := getJSON()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
textBytes := []byte(jsonData)
|
|
aemetRequest := root{}
|
|
err = json.Unmarshal(textBytes, &aemetRequest)
|
|
if err != nil {
|
|
log.Fatalf("Error occurred unmarshalling data: %v\n", err)
|
|
}
|
|
|
|
fmt.Println(aemetRequest.Base.Nombre)
|
|
fmt.Println(aemetRequest.Base.Prediccion.Dia[0].Fecha)
|
|
fmt.Printf("Temperatura máxima: %v°C\n", aemetRequest.Base.Prediccion.Dia[0].Temperatura.Maxima)
|
|
fmt.Printf("Temperatura mínima: %v°C\n", aemetRequest.Base.Prediccion.Dia[0].Temperatura.Minima)
|
|
}
|
|
|
|
func getJSON() (s string, err error) {
|
|
client := &http.Client{}
|
|
req, err := http.NewRequest("GET", "https://www.aemet.es/xml/municipios/localidad_46250.xml", nil)
|
|
if err != nil {
|
|
e := fmt.Errorf("Error occurred pulling data: %v\n", err)
|
|
return "", e
|
|
}
|
|
req.Header.Set("User-Agent", "AEMET-Client/1.0 (https://git.bulgariu.xyz/raul/aemet)")
|
|
|
|
resp, err := client.Do(req)
|
|
|
|
if err != nil {
|
|
e := fmt.Errorf("Error occurred pulling data: %v\n", err)
|
|
return "", e
|
|
}
|
|
|
|
defer resp.Body.Close()
|
|
if resp.StatusCode != http.StatusOK {
|
|
e := fmt.Errorf("Error occurred accessing upstream website: %v\n", resp.Status)
|
|
return "", e
|
|
}
|
|
|
|
data, err := io.ReadAll(resp.Body)
|
|
if err != nil {
|
|
e := fmt.Errorf("Error occurred reading data: %v\n", err)
|
|
return "", e
|
|
}
|
|
|
|
xml := strings.NewReader(string(data))
|
|
json, err := xj.Convert(xml)
|
|
if err != nil {
|
|
e := fmt.Errorf("Error occurred converting XML to JSON: %v\n", err)
|
|
return "", e
|
|
}
|
|
|
|
return json.String(), nil
|
|
}
|