Method CopyObject

common/nodes/version/handler-version.go:250–290

CopyObject intercept request with a SrcVersionId to read original from Version Store

(ctx context.Context, from *tree.Node, to *tree.Node, requestData *models.CopyRequestData)

// CopyObject intercept request with a SrcVersionId to read original from Version Store
func (v *Handler) CopyObject(ctx context.Context, from *tree.Node, to *tree.Node, requestData *models.CopyRequestData) (models.ObjectInfo, error) {
	ctx, err := v.WrapContext(ctx)
	if err != nil {
		return models.ObjectInfo{}, err
	}
	log.Logger(ctx).Debug("CopyObject Has VersionId?", zap.Any("from", from), zap.Any("to", to), zap.Any("requestData", requestData))
	if len(requestData.SrcVersionId) > 0 {

		// We are trying to load a specific versionId => switch to vID store
		if len(from.Uuid) == 0 {
			resp, e := v.Next.ReadNode(ctx, &tree.ReadNodeRequest{Node: from})
			if e != nil {
				return models.ObjectInfo{}, e
			}
			from = resp.Node
		}
		vResp, err := v.getVersionClient(ctx).HeadVersion(ctx, &tree.HeadVersionRequest{NodeUuid: from.GetUuid(), VersionId: requestData.SrcVersionId})
		if err != nil {
			return models.ObjectInfo{}, err
		}
		if requestData.Metadata == nil {
			requestData.Metadata = make(map[string]string, 1)
		}
		requestData.Metadata[common.XAmzMetaNodeUuid] = from.Uuid // Make sure to keep Uuid!
		if h := vResp.GetVersion().GetContentHash(); h != "" {
			// log.Logger(ctx).Info("Setting MetaNamespaceHash in CopyRequest meta")
			requestData.Metadata[common.MetaNamespaceHash] = h
		}
		from = vResp.GetVersion().GetLocation()
		// Refresh context from location
		source, e := nodes.GetSourcesPool(ctx).GetDataSourceInfo(from.GetStringMeta(common.MetaNamespaceDatasourceName))
		if e != nil {
			return models.ObjectInfo{}, e
		}
		srcInfo := nodes.BranchInfo{LoadedSource: source}
		ctx = nodes.WithBranchInfo(ctx, "from", srcInfo)
		log.Logger(ctx).Debug("CopyObject With VersionId", zap.Any("from", from), zap.Any("branchInfo", srcInfo), zap.Any("to", to))
	}

	return v.Next.CopyObject(ctx, from, to, requestData)
}

func (v *Handler) PutObject(ctx context.Context, node *tree.Node, reader io.Reader, requestData *models.PutRequestData) (models.ObjectInfo, error) {
	ctx, err := v.WrapContext(ctx)