fix: loop on wise accounts (#79)

* fix: loop on wise accounts

Signed-off-by: Lawrence Zawila <[email protected]>

* fix: add task restart flag for wise

Signed-off-by: Lawrence Zawila <[email protected]>

Signed-off-by: Lawrence Zawila <[email protected]>

Author: darkmatterpool

internal/app/connectors/wise/connector.go

@@ -26,7 +26,7 @@ func (c *Connector) Install(ctx task.ConnectorContext) error {
 		return err
 	}
 
-	return ctx.Scheduler().Schedule(descriptor, false)
+	return ctx.Scheduler().Schedule(descriptor, true)
 }
 
 func (c *Connector) Uninstall(ctx context.Context) error {

internal/app/connectors/wise/task_fetch_profiles.go

@@ -33,7 +33,7 @@ func taskFetchProfiles(logger sharedlogging.Logger, client *client) task.Task {
 				return err
 			}
 
-			err = scheduler.Schedule(descriptor, false)
+			err = scheduler.Schedule(descriptor, true)
 			if err != nil {
 				return err
 			}

internal/app/connectors/wise/task_fetch_transfers.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"time"
 
 	"github.com/formancehq/payments/internal/app/models"
 
@@ -96,7 +97,24 @@ func taskFetchTransfers(logger sharedlogging.Logger, client *client, profileID u
 			}
 		}
 
-		return ingester.IngestPayments(ctx, paymentBatch, struct{}{})
+		err = ingester.IngestPayments(ctx, paymentBatch, struct{}{})
+		if err != nil {
+			return err
+		}
+
+		// TODO: Implement proper looper & abstract the logic
+
+		time.Sleep(time.Minute)
+
+		descriptor, err := models.EncodeTaskDescriptor(TaskDescriptor{
+			Name: "Fetch profiles from client",
+			Key:  taskNameFetchProfiles,
+		})
+		if err != nil {
+			return err
+		}
+
+		return scheduler.Schedule(descriptor, true)
 	}
 }