Method Test

service/admin/node.go:81–120

(c *gin.Context)

)

func (service *TestNodeService) Test(c *gin.Context) error {
	dep := dependency.FromContext(c)
	settings := dep.SettingProvider()

	slave, err := url.Parse(service.Node.Server)
	if err != nil {
		return serializer.NewError(serializer.CodeParamErr, "Failed to parse node URL", err)
	}

	primaryURL := settings.SiteURL(setting.UseFirstSiteUrl(c)).String()
	body := map[string]string{
		"callback": primaryURL,
	}
	bodyByte, _ := json.Marshal(body)

	r := dep.RequestClient()
	res, err := r.Request(
		"POST",
		routes.SlavePingRoute(slave),
		bytes.NewReader(bodyByte),
		request.WithTimeout(time.Duration(10)*time.Second),
		request.WithCredential(
			auth.HMACAuth{SecretKey: []byte(service.Node.SlaveKey)},
			int64(settings.SlaveRequestSignTTL(c)),
		),
		request.WithSlaveMeta(int(service.Node.ID)),
		request.WithMasterMeta(settings.SiteBasic(c).ID, primaryURL),
		request.WithCorrelationID(),
	).CheckHTTPResponse(http.StatusOK).DecodeResponse()

	if err != nil {
		return serializer.NewError(serializer.CodeParamErr, "Failed to connect to node: "+err.Error(), nil)
	}

	if res.Code != 0 {
		return serializer.NewError(serializer.CodeParamErr, "Successfully connected to slave node, but slave returns: "+res.Msg, nil)
	}

	return nil
}

type (
	TestNodeDownloaderService struct {