ostreeuploader

type CheckReport struct {
	Checked   uint
	NotSynced uint
}

type CheckStatus struct {
	Check     <-chan uint
	NotSynced <-chan *RepoFile
}

type Checker interface {
	OSTreeHubAccessor
	Check(corId string) error
	Wait() (*CheckReport, error)
}

type FioToken string

type OAuth2 struct {
	Server string `json:"server"`
	ID     string `json:"client_id"`
	Secret string `json:"client_secret"`
}

type OAuth2Token string

type OAuthToken struct {
	Token   string `json:"access_token"`
	Expires uint64 `json:"expires_in"`
}

type OSTreeHub struct {
	URL     string
	Factory string
	Auth    *OAuth2
}

type OSTreeHubAccessor interface {
	Url() string
	Factory() string
}

type OSTreeInfo struct {
	Auth   OAuth2 `json:"oauth2"`
	NoAuth bool   `json:"no_auth"`
	Server struct {
		URL string `json:"server"`
	} `json:"ostree"`
}

type Puller interface {
	OSTreeHubAccessor
	Pull(commitHash string, corId string) error
}

type Pusher interface {
	OSTreeHubAccessor
	Push(corId string) error
	Wait() (*Report, error)
	UpdateSummary() error
}

type RepoFile struct {
	Path  string
	CRC32 uint32
}

type Report struct {
	Checked uint
	Sent    SendReport
	Synced  SyncReport
}

type SendReport struct {
	FileNumb uint
	ObjNumb  uint
	Bytes    int64
}

type Status struct {
	Check <-chan uint
	Send  <-chan *SendReport
	Sync  <-chan *SyncReport
}

type SyncReport struct {
	UploadedFileNumb     uint32 `json:"uploaded"`
	SyncedFileNumb       uint32 `json:"synced"`
	UploadSyncedFileNumb uint32 `json:"upload_synced"`
	SyncFailedNumb       uint32 `json:"sync_failed"`
}

type Token interface {
	SetAuthHeader(req *http.Request)
}