Neeraj Gupta 1 rok temu
rodzic
commit
cab929da2b
2 zmienionych plików z 11 dodań i 3 usunięć
  1. 5 2
      pkg/remote_sync.go
  2. 6 1
      pkg/sync.go

+ 5 - 2
pkg/remote_sync.go

@@ -10,7 +10,6 @@ import (
 )
 
 func (c *ClICtrl) SyncAccount(account model.Account) error {
-	log.SetPrefix(fmt.Sprintf("[%s] ", account.Email))
 	secretInfo, err := c.KeyHolder.LoadSecrets(account, c.CliKey)
 	if err != nil {
 		return err
@@ -21,7 +20,11 @@ func (c *ClICtrl) SyncAccount(account model.Account) error {
 		return err
 	}
 	c.Client.AddToken(account.AccountKey(), base64.URLEncoding.EncodeToString(secretInfo.Token))
-	return c.fetchRemoteCollections(ctx, account)
+	err = c.fetchRemoteCollections(ctx, account)
+	if err != nil {
+		log.Printf("Error fetching collections: %s", err)
+	}
+	return nil
 }
 
 func (c *ClICtrl) buildRequestContext(ctx context.Context, account model.Account) context.Context {

+ 6 - 1
pkg/sync.go

@@ -3,6 +3,7 @@ package pkg
 import (
 	"context"
 	"fmt"
+	"log"
 )
 
 func (c *ClICtrl) StartSync() error {
@@ -15,12 +16,16 @@ func (c *ClICtrl) StartSync() error {
 		return nil
 	}
 	for _, account := range accounts {
-		fmt.Printf("Syncing account %s\n", account.Email)
+		log.SetPrefix(fmt.Sprintf("[%s-%s] ", account.App, account.Email))
+		log.Println("start sync")
 		err = c.SyncAccount(account)
 		if err != nil {
 			fmt.Printf("Error syncing account %s: %s\n", account.Email, err)
 			return err
+		} else {
+			log.Println("sync done")
 		}
+
 	}
 	return nil
 }