payments/internal/connectors/plugins/public/mangopay/workflow.go

package mangopay

import "github.com/formancehq/payments/internal/models"

const (
	fetchUsersName = "fetch_users"
)

func workflow() models.ConnectorTasksTree {
	return []models.ConnectorTaskTree{
		{
			TaskType:     models.TASK_FETCH_OTHERS,
			Name:         fetchUsersName,
			Periodically: true,
			NextTasks: []models.ConnectorTaskTree{
				{
					TaskType:     models.TASK_FETCH_ACCOUNTS,
					Name:         "fetch_accounts",
					Periodically: true,
					NextTasks: []models.ConnectorTaskTree{
						{
							TaskType:     models.TASK_FETCH_PAYMENTS,
							Name:         "fetch_payments",
							Periodically: false, // We will be using webhooks after polling the history
							NextTasks:    []models.ConnectorTaskTree{},
						},
						{
							TaskType:     models.TASK_FETCH_BALANCES,
							Name:         "fetch_balances",
							Periodically: true,
							NextTasks:    []models.ConnectorTaskTree{},
						},
					},
				},
				{
					TaskType:     models.TASK_FETCH_EXTERNAL_ACCOUNTS,
					Name:         "fetch_external_accounts",
					Periodically: true,
					NextTasks:    []models.ConnectorTaskTree{},
				},
			},
		},
		{
			TaskType:     models.TASK_CREATE_WEBHOOKS,
			Name:         "create_webhooks",
			Periodically: false,
			NextTasks:    []models.ConnectorTaskTree{},
		},
	}
}