mirror of
https://github.com/status-im/status-go.git
synced 2026-08-31 09:01:16 +00:00
Igor Sirotin
f9cc782a6f
Part of the Go project layout migration, item 31. Pure move plus import-path rewrite across 687 files. No API or behaviour change. The services keep their grouping under pkg/services/<name> rather than being promoted to pkg/<name>: 27 top-level directories in pkg/ would read worse than what we have, and the grouping is what makes "an RPC service" identifiable at a glance. Paths that follow the move: the logosstorage test target and generate step, the two wallet token-list tools, the migration-order check (and the pre-rebase hook symlinked to it), and the storage env helper. refs #7067
102 lines
2.6 KiB
Go
102 lines
2.6 KiB
Go
package updates
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/hashicorp/go-version"
|
|
"go.uber.org/zap"
|
|
|
|
"github.com/status-im/status-go/internal/logutils"
|
|
"github.com/status-im/status-go/internal/panics"
|
|
"github.com/status-im/status-go/internal/signal"
|
|
"github.com/status-im/status-go/pkg/services/ens"
|
|
)
|
|
|
|
func NewAPI(ensService *ens.Service) *API {
|
|
return &API{
|
|
ensService: ensService,
|
|
httpClient: &http.Client{Timeout: time.Minute},
|
|
}
|
|
}
|
|
|
|
type API struct {
|
|
ensService *ens.Service
|
|
httpClient *http.Client
|
|
}
|
|
|
|
func (api *API) Check(ctx context.Context, chainID uint64, ens string, currentVersion string) {
|
|
go func() {
|
|
defer panics.LogOnPanic()
|
|
ctx, cancel := context.WithTimeout(context.Background(), 45*time.Second)
|
|
defer cancel()
|
|
|
|
current, err := version.NewVersion(currentVersion)
|
|
if err != nil {
|
|
logutils.ZapLogger().Error("invalid current version", zap.Error(err))
|
|
return
|
|
}
|
|
|
|
uri, err := api.ensService.API().ResourceURL(ctx, chainID, ens)
|
|
if err != nil || uri.Host == "" {
|
|
logutils.ZapLogger().Error("can't get obtain the updates content hash url", zap.String("ens", ens))
|
|
signal.SendUpdateAvailable(false, "", "")
|
|
return
|
|
}
|
|
|
|
url := uri.Scheme + "://" + uri.Host + uri.Path
|
|
versionURL := url + "VERSION"
|
|
response, err := api.httpClient.Get(versionURL)
|
|
if err != nil {
|
|
logutils.ZapLogger().Error("can't get content", zap.String("any", versionURL))
|
|
signal.SendUpdateAvailable(false, "", "")
|
|
return
|
|
}
|
|
|
|
defer response.Body.Close()
|
|
if response.StatusCode != http.StatusOK {
|
|
logutils.ZapLogger().Error(fmt.Sprintf("version verification response status error: %v", response.StatusCode))
|
|
signal.SendUpdateAvailable(false, "", "")
|
|
return
|
|
}
|
|
|
|
data, err := ioutil.ReadAll(response.Body)
|
|
if err != nil {
|
|
logutils.ZapLogger().Error("version verification body err", zap.Error(err))
|
|
signal.SendUpdateAvailable(false, "", "")
|
|
return
|
|
}
|
|
|
|
c := make(map[string]interface{})
|
|
err = json.Unmarshal(data, &c)
|
|
if err != nil {
|
|
logutils.ZapLogger().Error("invalid json", zap.Error(err))
|
|
signal.SendUpdateAvailable(false, "", "")
|
|
return
|
|
}
|
|
|
|
latestStr := ""
|
|
switch c["version"].(type) {
|
|
case string:
|
|
latestStr = c["version"].(string)
|
|
default:
|
|
logutils.ZapLogger().Error("invalid latest version", zap.Any("val", c["version"]))
|
|
signal.SendUpdateAvailable(false, "", "")
|
|
return
|
|
}
|
|
|
|
latest, err := version.NewVersion(latestStr)
|
|
if err != nil {
|
|
logutils.ZapLogger().Error("invalid latest version", zap.Error(err))
|
|
signal.SendUpdateAvailable(false, "", "")
|
|
return
|
|
}
|
|
|
|
signal.SendUpdateAvailable(latest.GreaterThan(current), latestStr, url)
|
|
}()
|
|
}
|