stack/components/payments/internal/messages/accounts.go

package messages

import (
	"encoding/json"
	"time"

	"github.com/formancehq/stack/libs/go-libs/publish"

	"github.com/formancehq/payments/internal/models"
	"github.com/formancehq/payments/pkg/events"
)

type accountMessagePayload struct {
	ID           string          `json:"id"`
	CreatedAt    time.Time       `json:"createdAt"`
	Reference    string          `json:"reference"`
	ConnectorID  string          `json:"connectorId"`
	Provider     string          `json:"provider"`
	DefaultAsset string          `json:"defaultAsset"`
	AccountName  string          `json:"accountName"`
	Type         string          `json:"type"`
	RawData      json.RawMessage `json:"rawData"`
}

func (m *Messages) NewEventSavedAccounts(provider models.ConnectorProvider, account *models.Account) publish.EventMessage {
	payload := accountMessagePayload{
		ID:           account.ID.String(),
		CreatedAt:    account.CreatedAt,
		Reference:    account.Reference,
		ConnectorID:  account.ConnectorID.String(),
		DefaultAsset: account.DefaultAsset.String(),
		AccountName:  account.AccountName,
		Type:         string(account.Type),
		Provider:     provider.String(),
		RawData:      account.RawData,
	}

	if account.Type == models.AccountTypeExternalFormance {
		payload.Type = models.AccountTypeExternal.String()
	}

	return publish.EventMessage{
		Date:    time.Now().UTC(),
		App:     events.EventApp,
		Version: events.EventVersion,
		Type:    events.EventTypeSavedAccounts,
		Payload: payload,
	}
}