feat: add function to read coordinate file

cmd/go.mod

@@ -1,3 +1,5 @@
 module github.com/Sosokker/openweather-dashboard
 
 go 1.23.5
+
+require github.com/joho/godotenv v1.5.1 // indirect

cmd/go.sum

@@ -0,0 +1,2 @@
+github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
+github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=

cmd/main.go

@@ -1,6 +1,21 @@
 package main
 
+import (
+	"encoding/csv"
+	"encoding/json"
+	"fmt"
+	"io"
+	"log"
+	"net/http"
+	"os"
+	"strconv"
+	"strings"
+
+	"github.com/joho/godotenv"
+)
+
 type Coordinate struct {
+	Place string  `json:"-"`
 	Lon   float32 `json:"lon"`
 	Lat   float32 `json:"lat"`
 }
@@ -13,13 +28,110 @@ type Weather struct {
 
 type DataEntry struct {
 	Name    string     `json:"name"`
-	Coord   Coordinate
+	Coord   Coordinate `json:"coord"`
-	Weather Weather
+	Weather []Weather  `json:"weather"`
 	Rain    struct {
 		PerHour float64 `json:"1h"`
 	} `json:"rain"`
 }
 
-func main() {
+func (c Coordinate) String() string {
-
+	return fmt.Sprintf("(%f, %f)", c.Lat, c.Lon)
+}
+
+func (w Weather) String() string {
+	return fmt.Sprintf("(%d, %s, %s)", w.Id, w.Main, w.Description)
+}
+
+func (d DataEntry) String() string {
+	return fmt.Sprintf("Place Name: %s\nCoordinate: %s\nWeather: %s\nRain per Hour: %f\n", d.Name, d.Coord, d.Weather, d.Rain.PerHour)
+}
+
+func loadEnv() string {
+	apiKeys, err := godotenv.Read()
+	if err != nil {
+		log.Fatalln("Error: can't load environment or .env file")
+	}
+
+	apiKey, exist := apiKeys["OPENWEATHERMAP_API_KEY"]
+	if !exist {
+		log.Fatalln("Error: OPENWEATHERMAP_API_KEY does not existed!")
+	}
+	if strings.TrimSpace(apiKey) == "" {
+		log.Fatalln("Error: OPENWEATHERMAP_API_KEY can't be empty!")
+	}
+	return apiKey
+}
+
+// Fetch weather data with specific latitude and longitude and decode into struct
+func fetchWeatherData(lat, lon float32, apiKey string) DataEntry {
+	var url = fmt.Sprintf("https://api.openweathermap.org/data/2.5/weather?lat=%f&lon=%f&appid=%s", lat, lon, strings.TrimSpace(apiKey))
+	fmt.Println(url)
+	resp, err := http.Get(url)
+	if err != nil {
+		log.Fatalln("Error:", err)
+	}
+
+	defer resp.Body.Close()
+
+	if resp.StatusCode != http.StatusOK {
+		log.Fatalln("Error: Status not okay: ", resp.StatusCode)
+	}
+
+	var entry DataEntry
+	err = json.NewDecoder(resp.Body).Decode(&entry)
+	if err != nil {
+		log.Fatalln("Error: error decode json to struct", err)
+	}
+
+	return entry
+}
+
+func readCoordData(filepath string, coordCh chan<- Coordinate) {
+	file, err := os.Open(filepath)
+	if err != nil {
+		log.Fatalln("Error: unable to read file", err)
+	}
+	defer file.Close()
+
+	r := csv.NewReader(file)
+	for {
+		line, err := r.Read()
+		if err == io.EOF {
+			break
+		}
+
+		if err != nil {
+			log.Fatalln("Error: error while reading file", err)
+		}
+
+		place, lat, lon := line[0], line[1], line[2]
+		place = strings.TrimSpace(place)
+		latf, err := strconv.ParseFloat(strings.TrimSpace(lat), 32)
+		if err != nil {
+			// log.Fatalln("Error: unable to convert string to float", err)
+			continue
+		}
+
+		lonf, err := strconv.ParseFloat(strings.TrimSpace(lon), 32)
+		if err != nil {
+			// log.Fatalln("Error: unable to convert string to float", err)
+			continue
+		}
+
+		coordCh <- Coordinate{place, float32(lonf), float32(latf)}
+	}
+	close(coordCh)
+}
+
+func main() {
+	apiKey := loadEnv()
+
+	coordCh := make(chan Coordinate)
+	go readCoordData("data/test.csv", coordCh)
+
+	for coord := range coordCh {
+		entry := fetchWeatherData(coord.Lat, coord.Lon, apiKey)
+		fmt.Println(entry)
+	}
 }