Method Test

service/admin/node.go:129–159

(c *gin.Context)

)

func (service *TestNodeDownloaderService) Test(c *gin.Context) (string, error) {
	dep := dependency.FromContext(c)
	settings := dep.SettingProvider()
	var (
		dl  downloader.Downloader
		err error
	)
	if service.Node.Type == node.TypeMaster {
		dl, err = cluster.NewDownloader(c, dep.RequestClient(request.WithContext(c)), dep.SettingProvider(), service.Node.Settings)
	} else {
		dl = slave.NewSlaveDownloader(dep.RequestClient(
			request.WithContext(c),
			request.WithCorrelationID(),
			request.WithSlaveMeta(service.Node.ID),
			request.WithMasterMeta(settings.SiteBasic(c).ID, settings.SiteURL(setting.UseFirstSiteUrl(c)).String()),
			request.WithCredential(auth.HMACAuth{[]byte(service.Node.SlaveKey)}, int64(settings.SlaveRequestSignTTL(c))),
			request.WithEndpoint(service.Node.Server),
		), service.Node.Settings)
	}

	if err != nil {
		return "", serializer.NewError(serializer.CodeParamErr, "Failed to create downloader", err)
	}

	version, err := dl.Test(c)
	if err != nil {
		return "", serializer.NewError(serializer.CodeParamErr, "Failed to test downloader: "+err.Error(), nil)
	}

	return version, nil
}

type (
	UpsertNodeService struct {