dfs_copier_batch

type BatchSessions interface {
	// NewSession Start a new session with the commit information.
	// The operation might blocked depends on the backlog size.
	NewSession(commit CommitInfo, callback SessionCallback) (sessionId string, err error)

	// AbortSession Abort uploading session for the session Id.
	// The sessionId will be removed from the batch.
	// The func callbacks OnFailure event.
	AbortSession(sessionId string, err error)

	// FinishBlockUploads Report finish for all block uploads.
	// The func should not block the operation.
	FinishBlockUploads(sessionId string)

	// Shutdown Flush and finish all sessions.
	// The operation might blocked when the backlog exists.
	Shutdown() (err dbx_error.DropboxError)

	// FinishBatchCommit Process upload session commit.
	FinishBatchCommit(batch *FinishBatch)

	// FinishBatchEntry Entry upload session commit batch.
	FinishBatchEntry(count int)
}

type BlockSession interface {
	// AddBlock Add block
	AddBlock(sessionId string, offset int64)

	// FinishSuccess Tell finish operation
	FinishSuccess(sessionId string, offset int64)

	// FinishFailure Tell failure
	FinishFailure(sessionId string, err error)
}

type CommitInfo struct {
	Path           string `json:"path"`
	Mode           string `json:"mode"`
	Autorename     bool   `json:"autorename"`
	ClientModified string `json:"client_modified"`
	Mute           bool   `json:"mute"`
	StrictConflict bool   `json:"strict_conflict"`
}

type CopyBatchUploadBlock struct {
	SessionId string `json:"session_id"`
	Path      string `json:"path"`
	Offset    int64  `json:"offset"`
}

type FinishBatch struct {
	Batch []string `json:"batch"`
}

type SessionCallback struct {
	CopyPair  es_filesystem.CopyPair
	OnSuccess func(pair es_filesystem.CopyPair, copied es_filesystem.Entry)
	OnFailure func(pair es_filesystem.CopyPair, err es_filesystem.FileSystemError)
}

type SessionCheck struct {
	SessionId string `json:"session_id"`
	Path      string `json:"path"`
}

type SessionId struct {
	SessionId string `json:"session_id" path:"session_id"`
}

type UploadAppend struct {
	Cursor UploadCursor `json:"cursor"`
	Close  bool         `json:"close"`
}

type UploadCursor struct {
	SessionId string `json:"session_id" path:"session_id"`
	Offset    int64  `json:"offset" path:"offset"`
}

type UploadFinish struct {
	Cursor UploadCursor `json:"cursor"`
	Commit CommitInfo   `json:"commit"`
}

type UploadFinishBatch struct {
	Entries []UploadFinish `json:"entries"`
}