replace timezone with time

time/handler/time.go

@@ -0,0 +1,148 @@
+package handler
+
+import (
+	"context"
+	"encoding/json"
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"time"
+
+	"github.com/micro/micro/v3/service/config"
+	"github.com/micro/micro/v3/service/errors"
+	"github.com/micro/micro/v3/service/logger"
+	pb "github.com/micro/services/time/proto"
+	"github.com/tkuchiki/go-timezone"
+)
+
+type Time struct {
+	Api string
+	Key string
+	TZ  *timezone.Timezone
+}
+
+func New() *Time {
+	// TODO: look for "weather.provider" to determine the handler
+	v, err := config.Get("weatherapi.api")
+	if err != nil {
+		logger.Fatalf("weatherapi.api config not found: %v", err)
+	}
+	api := v.String("")
+	if len(api) == 0 {
+		logger.Fatal("weatherapi.api config not found")
+	}
+	v, err = config.Get("weatherapi.key")
+	if err != nil {
+		logger.Fatalf("weatherapi.key config not found: %v", err)
+	}
+	key := v.String("")
+	if len(key) == 0 {
+		logger.Fatal("weatherapi.key config not found")
+	}
+
+	return &Time{
+		Api: api,
+		Key: key,
+		TZ:  timezone.New(),
+	}
+}
+
+func (t *Time) Now(ctx context.Context, req *pb.NowRequest, rsp *pb.NowResponse) error {
+	if len(req.Location) == 0 {
+		ti := time.Now().In(time.UTC)
+		rsp.Localtime = ti.Format("15:04:05")
+		rsp.Timestamp = ti.Format(time.RFC3339Nano)
+		rsp.Location = "Prime Meridian"
+		rsp.Timezone = "UTC"
+		rsp.Unix = ti.Unix()
+		return nil
+	}
+
+	vals := url.Values{}
+	vals.Set("key", t.Key)
+	vals.Set("q", req.Location)
+
+	resp, err := http.Get(t.Api + "timezone.json?" + vals.Encode())
+	if err != nil {
+		logger.Errorf("Failed to get time zone: %v\n", err)
+		return errors.InternalServerError("time.now", "failed to get time")
+	}
+	defer resp.Body.Close()
+
+	b, _ := ioutil.ReadAll(resp.Body)
+
+	if resp.StatusCode != 200 {
+		logger.Errorf("Failed to get time zone (non 200): %d %v\n", resp.StatusCode, string(b))
+		return errors.InternalServerError("time.now", "failed to get time")
+	}
+
+	var respBody map[string]interface{}
+
+	if err := json.Unmarshal(b, &respBody); err != nil {
+		logger.Errorf("Failed to unmarshal current: %v\n", err)
+		return errors.InternalServerError("time.now", "failed to get time")
+	}
+
+	location := respBody["location"].(map[string]interface{})
+
+	loc, _ := time.LoadLocation(location["tz_id"].(string))
+	ti := time.Now().In(loc)
+	isDST := t.TZ.IsDST(ti)
+
+	rsp.Localtime = ti.Format("15:04:05")
+	rsp.Timezone, _ = t.TZ.GetTimezoneAbbreviation(location["tz_id"].(string), isDST)
+	rsp.Location = ti.Location().String()
+	rsp.Timestamp = ti.Format(time.RFC3339Nano)
+	rsp.Unix = ti.Unix()
+
+	return nil
+}
+
+func (t *Time) Zone(ctx context.Context, req *pb.ZoneRequest, rsp *pb.ZoneResponse) error {
+	if len(req.Location) == 0 {
+		return errors.BadRequest("time.zone", "invalid location")
+	}
+
+	vals := url.Values{}
+	vals.Set("key", t.Key)
+	vals.Set("q", req.Location)
+
+	resp, err := http.Get(t.Api + "timezone.json?" + vals.Encode())
+	if err != nil {
+		logger.Errorf("Failed to get time zone: %v\n", err)
+		return errors.InternalServerError("time.zone", "failed to get time zone")
+	}
+	defer resp.Body.Close()
+
+	b, _ := ioutil.ReadAll(resp.Body)
+
+	if resp.StatusCode != 200 {
+		logger.Errorf("Failed to get time zone (non 200): %d %v\n", resp.StatusCode, string(b))
+		return errors.InternalServerError("time.zone", "failed to get time zone")
+	}
+
+	var respBody map[string]interface{}
+
+	if err := json.Unmarshal(b, &respBody); err != nil {
+		logger.Errorf("Failed to unmarshal current: %v\n", err)
+		return errors.InternalServerError("time.zone", "failed to get current")
+	}
+
+	location := respBody["location"].(map[string]interface{})
+
+	rsp.Location = location["name"].(string)
+	rsp.Region = location["region"].(string)
+	rsp.Country = location["country"].(string)
+	rsp.Latitude = location["lat"].(float64)
+	rsp.Longitude = location["lon"].(float64)
+	rsp.Timezone = location["tz_id"].(string)
+	rsp.Localtime = location["localtime"].(string)
+
+	loc, _ := time.LoadLocation(rsp.Timezone)
+	ti := time.Now().In(loc)
+	isDST := t.TZ.IsDST(ti)
+	rsp.Abbreviation, _ = t.TZ.GetTimezoneAbbreviation(rsp.Timezone, isDST)
+	rsp.Dst = isDST
+
+	return nil
+}