From 875e3cb517b6050346c64c240b316899ce7b7e71 Mon Sep 17 00:00:00 2001
From: Keepers <104464746+ryanfkeepers@users.noreply.github.com>
Date: Thu, 9 Jun 2022 01:07:04 -0600
Subject: [PATCH] call backup on exchange collection (#172)

Wires up the backupOperation to graphConnector and kopia to
fully run an end-to-end backup.
---
 src/internal/operations/backup.go | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git a/src/internal/operations/backup.go b/src/internal/operations/backup.go
index a28f818c9..42077a3e8 100644
--- a/src/internal/operations/backup.go
+++ b/src/internal/operations/backup.go
@@ -55,16 +55,21 @@ func (bo BackupOperation) validate() error {
 
 // Run begins a synchronous backup operation.
 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 {
 		return errors.Wrap(err, "connecting to graph api")
 	}
 
-	// todo - use the graphConnector to create datastreams
-	// dStreams, err := bo.gc.BackupOp(bo.Targets)
+	c, err := gc.ExchangeDataCollection(bo.Targets[0])
+	if err != nil {
+		return errors.Wrap(err, "retrieving application data")
+	}
 
-	// todo - send backup write request to BackupWriter
-	// err = kopia.BackupWriter(ctx, bo.gc.TenantID, wg, prog, dStreams...)
+	// todo: utilize stats
+	_, err = bo.kopia.BackupCollections(ctx, []connector.DataCollection{c})
+	if err != nil {
+		return errors.Wrap(err, "backing up application data")
+	}
 
 	bo.Status = Successful
 	return nil