larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

call backup on exchange collection (#172)

Browse Source 
Wires up the backupOperation to graphConnector and kopia to
fully run an end-to-end backup.
This commit is contained in:
Keepers 2022-06-09 01:07:04 -06:00 committed by GitHub
parent 0da0c786b5
commit 875e3cb517
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/internal/operations/backup.go
View File

@ -55,16 +55,21 @@ func (bo BackupOperation) validate() error {
// Run begins a synchronous backup operation. // Run begins a synchronous backup operation.
func (bo BackupOperation) Run(ctx context.Context) error { func (bo BackupOperation) Run(ctx context.Context) error {
_, err := connector.NewGraphConnector(bo.creds.TenantID, bo.creds.ClientID, bo.creds.ClientSecret) gc, err := connector.NewGraphConnector(bo.creds.TenantID, bo.creds.ClientID, bo.creds.ClientSecret)
if err != nil { if err != nil {
return errors.Wrap(err, "connecting to graph api") return errors.Wrap(err, "connecting to graph api")
} }
// todo - use the graphConnector to create datastreams c, err := gc.ExchangeDataCollection(bo.Targets[0])
// dStreams, err := bo.gc.BackupOp(bo.Targets) if err != nil {
return errors.Wrap(err, "retrieving application data")
}
// todo - send backup write request to BackupWriter // todo: utilize stats
// err = kopia.BackupWriter(ctx, bo.gc.TenantID, wg, prog, dStreams...) _, err = bo.kopia.BackupCollections(ctx, []connector.DataCollection{c})
if err != nil {
return errors.Wrap(err, "backing up application data")
}
bo.Status = Successful bo.Status = Successful
return nil return nil