edge/pkg/storage/driver/rpc/client/error.go

package client

import (
	"forge.cadoles.com/arcad/edge/pkg/storage"
	"forge.cadoles.com/arcad/edge/pkg/storage/share"
	"github.com/pkg/errors"
)

func remapBlobError(err error) error {
	switch errors.Cause(err).Error() {
	case storage.ErrBlobNotFound.Error():
		return storage.ErrBlobNotFound
	case storage.ErrBucketClosed.Error():
		return storage.ErrBucketClosed
	default:
		return err
	}
}

func remapDocumentError(err error) error {
	switch errors.Cause(err).Error() {
	case storage.ErrDocumentNotFound.Error():
		return storage.ErrDocumentNotFound
	default:
		return err
	}
}

func remapShareError(err error) error {
	switch errors.Cause(err).Error() {
	case share.ErrAttributeRequired.Error():
		return share.ErrAttributeRequired
	case share.ErrNotFound.Error():
		return share.ErrNotFound
	default:
		return err
	}
}