filemaintainer

type Blockchain interface {
	PublishFile(file *blockchain.PublishFileOptions) error
	ListFiles(opt *blockchain.ListFileOptions) ([]blockchain.File, error)
	GetFileByID(id string) (blockchain.File, error)
	ListFileNs(opt *blockchain.ListNsOptions) ([]blockchain.Namespace, error)
	UpdateFilePublicSliceMeta(opt *blockchain.UpdateFilePSMOptions) error
	SliceMigrateRecord(opt *blockchain.SliceMigrateOptions) error

	ListNodes() (blockchain.Nodes, error)
	GetNode(id []byte) (blockchain.Node, error)
	GetNodeHealth(id []byte) (string, error)
	GetHeartbeatNum(id []byte, timestamp int64) (int, error)
}

type Challenger interface {
	// merkle Challenge
	Setup(sliceData []byte, rangeAmount int) ([]ctype.RangeHash, error)
	Save(cms []ctype.Material) error
	Take(fileID string, sliceID string, nodeID []byte) (ctype.RangeHash, error)

	GetChallengeConf() (string, types.PairingChallengeConf)
	Close()
}

type Copier interface {
	Push(ctx context.Context, id, sourceID string, r io.Reader, node *blockchain.Node) (string, error)
	Pull(ctx context.Context, id, storIndex, fileID string, node *blockchain.Node) (io.ReadCloser, error)
	ReplicaExpansion(ctx context.Context, opt *copier.ReplicaExpOptions, enc common.CommonEncryptor,
		challengeAlgorithm, sourceID, fileID string) ([]blockchain.PublicSliceMeta, []encryptor.EncryptedSlice, error)
}

type Encryptor interface {
	Encrypt(r io.Reader, opt *encryptor.EncryptOptions) (encryptor.EncryptedSlice, error)
	Recover(r io.Reader, opt *encryptor.RecoverOptions) ([]byte, error)
}

type FileMaintainer struct {
	// contains filtered or unexported fields
}

type NewFileMaintainerOptions struct {
	LocalNode  peer.Local
	Blockchain Blockchain
	Copier     Copier
	Encryptor  Encryptor
	Challenger Challenger
}