Function slaveTaskPropsFromContext

service/node/task.go:90–124

(ctx context.Context)

}

func slaveTaskPropsFromContext(ctx context.Context) (*types.SlaveTaskProps, error) {
	nodeIdStr, ok := ctx.Value(cluster.SlaveNodeIDCtx{}).(string)
	if !ok {
		return nil, fmt.Errorf("failed to get node ID from context")
	}

	nodeId, err := strconv.Atoi(nodeIdStr)
	if err != nil {
		return nil, fmt.Errorf("failed to convert node ID to int: %w", err)
	}

	masterSiteUrl := cluster.MasterSiteUrlFromContext(ctx)
	if masterSiteUrl == "" {
		return nil, fmt.Errorf("failed to get master site URL from context")
	}

	masterSiteVersion, ok := ctx.Value(cluster.MasterSiteVersionCtx{}).(string)
	if !ok {
		return nil, fmt.Errorf("failed to get master site version from context")
	}

	masterSiteId, ok := ctx.Value(cluster.MasterSiteIDCtx{}).(string)
	if !ok {
		return nil, fmt.Errorf("failed to convert master site ID to int: %w", err)
	}

	props := &types.SlaveTaskProps{
		NodeID:            nodeId,
		MasterSiteID:      masterSiteId,
		MasterSiteURl:     masterSiteUrl,
		MasterSiteVersion: masterSiteVersion,
	}

	return props, nil
}

type (
	FolderCleanupParamCtx struct{}