storage_mock.go

package cloudbackup

import (
	"context"
	"io"
	"log"
	"time"

	"github.com/admpub/nging/v5/application/dbschema"
	"github.com/webx-top/echo"
)

func newStorageMock(ctx echo.Context, cfg dbschema.NgingCloudBackup) (Storager, error) {
	return NewStorageMock(), nil
}

func NewStorageMock() Storager {
	return &StorageMock{}
}

type StorageMock struct {
}

func (s *StorageMock) Connect() (err error) {
	log.Println(`StorageMock: Connect`)
	return
}

func (s *StorageMock) Put(ctx context.Context, reader io.Reader, ppath string, size int64) (err error) {
	log.Println(`StorageMock: Put --->`, ppath)
	time.Sleep(time.Second * 2)
	return
}

func (s *StorageMock) RemoveDir(ctx context.Context, ppath string) error {
	log.Println(`StorageMock: RemoveDir --->`, ppath)
	return nil
}

func (s *StorageMock) Remove(ctx context.Context, ppath string) error {
	log.Println(`StorageMock: Remove --->`, ppath)
	return nil
}

func (s *StorageMock) Close() (err error) {
	log.Println(`StorageMock: Close`)
	return
}