m365

type BrowseEntry struct {
	Subject        string `json:"subject"`
	From           string `json:"from,omitempty"`
	Received       string `json:"received,omitempty"`
	HasAttachments bool   `json:"has_attachments,omitempty"`
}

type ChannelIndex struct {
	Name string `json:"name"`
	// Months: "2026-10" → message id → message JSON as Graph returned it
	Months map[string]map[string]json.RawMessage `json:"months"`
}

type Client struct {

	// Stats counts what the client did (read after the run)
	Stats Stats
	// contains filtered or unexported fields
}

type Dir struct {
	Path  string
	Mtime time.Time
}

type DriveEntry struct {
	Path  string `json:"path"`
	Dir   bool   `json:"dir,omitempty"`
	Size  int64  `json:"size"`
	Mtime int64  `json:"mtime"`
	CTag  string `json:"ctag,omitempty"`
	// Metadata for the .fallbck/items.json sidecar
	WebURL     string `json:"web_url,omitempty"`
	CreatedBy  string `json:"created_by,omitempty"`
	ModifiedBy string `json:"modified_by,omitempty"`
}

type DriveIndex struct {
	ID     string `json:"id"`
	Name   string `json:"name"`
	WebURL string `json:"web_url,omitempty"`
	// Prefix is the archive directory the drive's items live under (onedrive, or
	// files/<library>)
	Prefix string                 `json:"prefix"`
	Delta  string                 `json:"delta,omitempty"`
	Items  map[string]*DriveEntry `json:"items"`
}

type Entry struct {
	// Path is the archive path with '/' separators, no leading slash
	Path  string
	Size  int64
	Mtime time.Time
	Open  func() (io.ReadCloser, error)
}

type FolderIndex struct {
	ID       string `json:"id"`
	Name     string `json:"name"`
	ParentID string `json:"parent_id,omitempty"`
	Class    string `json:"class,omitempty"`
	// Path is the folder's archive path below mailbox/ (computed from the parents)
	Path       string                `json:"path"`
	ItemsDelta string                `json:"items_delta,omitempty"`
	Items      map[string]*ItemEntry `json:"items"`
	// Browse is the human-readable index of the folder (subject, from, dates) kept
	// through the standard messages delta; BrowseDelta its link
	BrowseDelta string                  `json:"browse_delta,omitempty"`
	Browse      map[string]*BrowseEntry `json:"browse,omitempty"`
}

type GraphError struct {
	Status  int
	Code    string
	Message string
	URL     string
	// contains filtered or unexported fields
}

type HostedEntry struct {
	URL   string `json:"url"`
	Size  int64  `json:"size"`
	Mtime int64  `json:"mtime"`
}

type ItemEntry struct {
	// Size is the export stream size (what the archive declares); -1 until exported
	Size      int64  `json:"size"`
	ChangeKey string `json:"change_key"`
	// Mtime is lastModifiedDateTime (unix seconds); Created is createdDateTime, used
	// in the file name
	Mtime   int64  `json:"mtime"`
	Created int64  `json:"created"`
	Class   string `json:"class"`
	// EstSize is the mailboxItem.size Graph reported (packing estimate for exports)
	EstSize int64 `json:"est_size,omitempty"`
	// Dirty: the item must be exported again (new, changed or a failed export)
	Dirty bool `json:"dirty,omitempty"`
}

type MailboxIndex struct {
	MailboxID    string                  `json:"mailbox_id"`
	FoldersDelta string                  `json:"folders_delta,omitempty"`
	Folders      map[string]*FolderIndex `json:"folders"`
}

type Page struct {
	Value     []json.RawMessage `json:"value"`
	NextLink  string            `json:"@odata.nextLink"`
	DeltaLink string            `json:"@odata.deltaLink"`
}

type Principal struct {
	ID          string `json:"id"`
	UPN         string `json:"userPrincipalName"`
	DisplayName string `json:"displayName"`
	Mail        string `json:"mail"`
	UserType    string `json:"userType"`
	Enabled     bool   `json:"accountEnabled"`
	Licenses    []struct {
		SKU string `json:"skuId"`
	} `json:"assignedLicenses"`
}

type RunOptions struct {
	Session     *temporal.BackupSessionInfo
	Spec        *spec.Spec
	Credentials spec.Credentials
	// StateDir holds the job's unit indexes (<data>/m365-state/<job id>)
	StateDir string
	// SpoolDir receives exported mailbox items while a unit uploads (<spool>/<run id>)
	SpoolDir string
	Upload   UploadFunc
	Progress func(phase string)
	Items    func(items map[string]rundetail.ProgressItem)
	Hostname string
	Version  string
	// Client overrides the Graph client (tests); Authority / GraphURL point at a fake
	Client    *Client
	Authority string
	GraphURL  string
	Now       func() time.Time
}

type Site struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	DisplayName string `json:"displayName"`
	WebURL      string `json:"webUrl"`
}

type State struct{ Dir string }

type Stats struct {
	Requests   atomic.Int64
	Retries    atomic.Int64
	Downloaded atomic.Uint64
}

type Team struct {
	ID          string `json:"id"`
	DisplayName string `json:"displayName"`
}

type TeamsIndex struct {
	// Since is the newest lastModifiedDateTime seen (the next run filters from here)
	Since    string                   `json:"since,omitempty"`
	Channels map[string]*ChannelIndex `json:"channels"`
	// Hosted are inline images and files by archive path (hosted/<message>-<id>)
	Hosted map[string]*HostedEntry `json:"hosted,omitempty"`
}

type Unit struct {
	Kind     string
	Name     string
	ObjectID string
	Group    string
	// Archive is the pxar name of the unit
	Archive string
	// Principal / Site / Team carry the Graph object
	Principal *Principal
	Site      *Site
	Team      *Team
}

type UnitIndex struct {
	Version  int    `json:"version"`
	Kind     string `json:"kind"`
	Name     string `json:"name"`
	ObjectID string `json:"object_id"`
	Group    string `json:"group"`
	// LastRunID / LastStatus / LastSnapshot describe the newest finished snapshot; an
	// activity retry skips units whose LastRunID is the current run
	LastRunID    string `json:"last_run_id,omitempty"`
	LastStatus   string `json:"last_status,omitempty"`
	LastSnapshot int64  `json:"last_snapshot,omitempty"`

	Mailbox *MailboxIndex          `json:"mailbox,omitempty"`
	Drives  map[string]*DriveIndex `json:"drives,omitempty"`
	Teams   *TeamsIndex            `json:"teams,omitempty"`
}

type UploadFunc func(ctx context.Context, unit *Unit, tree *scan.Node, blobs []gopbs.Blob) (*temporal.BackupExecutionResult, error)