feat: update SCEA datasource to Wolfx API

Author: TenkyuChimata

pkg/seisevent/scea_impl.go

@@ -1,14 +1,9 @@
 package seisevent
 
 import (
-	"crypto/md5"
-	"encoding/hex"
 	"encoding/json"
 	"errors"
 	"fmt"
-	"net/url"
-	"sort"
-	"strconv"
 	"time"
 
 	"github.com/anyshake/observer/pkg/cache"
@@ -20,6 +15,7 @@ import (
 )
 
 const SCEA_ID = "scea"
+const SCEAListURL = "https://api.wolfx.jp/sc_eew_list.json"
 
 type SCEA struct {
 	travelTimeTable *travel.AK135
@@ -28,65 +24,35 @@ type SCEA struct {
 	timeSource      *timesource.Source
 }
 
+type sceaListResponse struct {
+	Code int         `json:"code"`
+	Msg  string      `json:"msg"`
+	Data []sceaEvent `json:"data"`
+}
+
+type sceaEvent struct {
+	EventID      string   `json:"eventId"`
+	ShockTime    int64    `json:"shockTime"`
+	Longitude    float64  `json:"longitude"`
+	Latitude     float64  `json:"latitude"`
+	PlaceName    string   `json:"placeName"`
+	Magnitude    float64  `json:"magnitude"`
+	Depth        *float64 `json:"depth"`
+	InfoTypeName string   `json:"infoTypeName"`
+}
+
 func (s *SCEA) GetProperty() DataSourceProperty {
 	return DataSourceProperty{
 		ID:      SCEA_ID,
 		Country: "CN",
 		Default: "en-US",
 		Locales: map[string]string{
-			"en-US": "Sichuan Earthquake Administration (Early Warning)",
-			"zh-TW": "四川地震局預警",
+			"en-US": "Sichuan Earthquake Administration Early Warning (Wolfx)",
+			"zh-TW": "四川地震局預警（Wolfx）",
 		},
 	}
 }
 
-func (s *SCEA) buildUrlSign(params map[string]string) string {
-	const (
-		SIGN_TOKEN = "OMEoiAuaExMuTjpovqKrhYDkZMkUaoCE"
-		SLAT       = "earthquake_app"
-	)
-
-	keys := make([]string, 0, len(params))
-	for k := range params {
-		if k != "sign" && params[k] != "" {
-			keys = append(keys, k)
-		}
-	}
-	sort.Strings(keys)
-
-	raw := ""
-	for i, k := range keys {
-		if i > 0 {
-			raw += "&"
-		}
-		raw += k + "=" + params[k]
-	}
-	raw += "&token=" + SIGN_TOKEN
-
-	sum := md5.Sum([]byte(raw + SLAT))
-	return hex.EncodeToString(sum[:])
-}
-
-func (s *SCEA) getRequestUrl(lat, lon float64) string {
-	params := map[string]string{
-		"pageNo":    "1",
-		"pageSize":  "50",
-		"orderType": "1",
-		"userLng":   strconv.FormatFloat(lon, 'f', -1, 64),
-		"userLat":   strconv.FormatFloat(lat, 'f', -1, 64),
-		"timeStamp": strconv.FormatInt(s.timeSource.Now().UnixMilli(), 10),
-	}
-
-	params["sign"] = s.buildUrlSign(params)
-
-	values := url.Values{}
-	for k, v := range params {
-		values.Set(k, v)
-	}
-
-	return "http://118.113.105.29:8002/api/earlywarning/jsonPageList?" + values.Encode()
-}
-
 func (s *SCEA) GetEvents(latitude, longitude float64) ([]Event, error) {
 	var baseEvents []Event
 
@@ -99,49 +65,47 @@ func (s *SCEA) GetEvents(latitude, longitude float64) ([]Event, error) {
 			}
 
 			res, err := request.GET(
-				s.getRequestUrl(latitude, longitude),
+				SCEAListURL,
 				10*time.Second, time.Second, 3, false, nil,
 				map[string]string{"User-Agent": uarand.GetRandom()},
 			)
 			if err != nil {
 				return nil, err
 			}
 
-			// Parse SCEA_B JSON response
-			var dataMap map[string]any
-			err = json.Unmarshal(res, &dataMap)
-			if err != nil {
+			var data sceaListResponse
+			if err := json.Unmarshal(res, &data); err != nil {
 				return nil, err
 			}
 
-			// Check server response
-			if dataMap["code"].(float64) != 0 {
-				return nil, fmt.Errorf("server error: %s", dataMap["msg"])
+			if data.Code != 0 {
+				return nil, fmt.Errorf("server error: %s", data.Msg)
 			}
 
-			dataMapEvents, ok := dataMap["data"].([]any)
-			if !ok {
+			if len(data.Data) == 0 {
 				return nil, errors.New("seismic event data is not available")
 			}
 
-			// Ensure the response has the expected keys and values
-			expectedKeys := []string{"eventId", "shockTime", "longitude", "latitude", "placeName", "magnitude", "depth", "infoTypeName"}
-
-			var resultArr []Event
-			for _, event := range dataMapEvents {
-				if !isMapHasKeys(event.(map[string]any), expectedKeys) || !isMapKeysEmpty(event.(map[string]any), expectedKeys) {
+			resultArr := make([]Event, 0, len(data.Data))
+			for _, event := range data.Data {
+				if event.EventID == "" || event.ShockTime == 0 || event.PlaceName == "" {
 					continue
 				}
 
+				depth := -1.0
+				if event.Depth != nil {
+					depth = *event.Depth
+				}
+
 				resultArr = append(resultArr, Event{
-					Depth:     -1,
-					Verfied:   event.(map[string]any)["infoTypeName"].(string) == "[正式]",
-					Event:     event.(map[string]any)["eventId"].(string),
-					Region:    event.(map[string]any)["placeName"].(string),
-					Latitude:  event.(map[string]any)["latitude"].(float64),
-					Longitude: event.(map[string]any)["longitude"].(float64),
-					Magnitude: s.getMagnitude(event.(map[string]any)["magnitude"].(float64)),
-					Timestamp: time.UnixMilli(int64(event.(map[string]any)["shockTime"].(float64))).UnixMilli(),
+					Depth:     depth,
+					Verfied:   event.InfoTypeName == "[正式]",
+					Event:     event.EventID,
+					Region:    event.PlaceName,
+					Latitude:  event.Latitude,
+					Longitude: event.Longitude,
+					Magnitude: s.getMagnitude(event.Magnitude),
+					Timestamp: time.UnixMilli(event.ShockTime).UnixMilli(),
 				})
 			}