types

type ChunkHashReceiver interface {
	Recv() (chunkIndex uint64, hash uint64, err error)
}

type ChunkHasher interface {
	GetChunkHashes(ctx context.Context, path string, chunkSize, fromChunk, count uint64) (ChunkHashReceiver, error)
}

type FileAction int

type FileEvent struct {
	Path    string // Relative path in the FS; the new path for renames.
	OldPath string // Source path for renames.
	Action  FileAction
	Attr    *keibidrop.Attr // File attributes from Stat_t.
	// BaseMtimeNs is the newest peer version the sender accepted when the edit
	// session started. 0 means unknown; the receiver then keeps no conflict copy.
	BaseMtimeNs int64
}

type FileStreamProvider interface {
	OpenRemoteFile(ctx context.Context, inode uint64, path string) (RemoteFileStream, error)
	// StreamFile starts a push-based download. The server sends all chunks
	// from startOffset to EOF without per-chunk round-trips.
	StreamFile(ctx context.Context, path string, startOffset uint64) (StreamFileReceiver, error)
}

type RemoteFileStream interface {
	// ReadAt sends offset and size and receives exactly those bytes.
	ReadAt(ctx context.Context, offset int64, size int64) ([]byte, error)
	Close() error
}

type StreamFileReceiver interface {
	// Recv returns the next chunk. It returns io.EOF when the stream ends.
	Recv() (data []byte, offset uint64, totalSize uint64, err error)
}