package rules

import (
	"time"

	"code.tnxs.net/taxnexus/lib/api/crm/crm_models"
	"code.tnxs.net/taxnexus/lib/api/ops/ops_models"
	"code.tnxs.net/taxnexus/lib/app"
	"go.temporal.io/sdk/workflow"
)

// NewDeveloperWrapper wraps a contact, account, payment method and a user identifier (app.User)
type NewDeveloperWrapper struct {
	Contact       crm_models.Contact
	Account       crm_models.Account
	PaymentMethod ops_models.PaymentMethod
	APIKey        string
	SagaID        string
	SagaType      string
}

// NewDeveloperWorkflow is a Temporal workflow
func NewDeveloperWorkflow(
	ctx workflow.Context,
	w *NewDeveloperWrapper,
) error {
	ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
		StartToCloseTimeout: time.Minute,
	})
	err := workflow.ExecuteActivity(ctx,
		StoreContactActivity,
		&app.ContactChannelWrapper{
			Obj:      w.Contact,
			APIKey:   w.APIKey,
			SagaID:   w.SagaID,
			SagaType: w.SagaType,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx,
		StoreAccountActivity,
		&app.AccountChannelWrapper{
			Obj:      w.Account,
			APIKey:   w.APIKey,
			SagaID:   w.SagaID,
			SagaType: w.SagaType,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx,
		StorePaymentMethodActivity,
		&app.PaymentMethodChannelWrapper{
			Obj:      w.PaymentMethod,
			APIKey:   w.APIKey,
			SagaID:   w.SagaID,
			SagaType: w.SagaType,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx,
		NotifyContactActivity,
		&app.ContactChannelWrapper{
			Obj:      w.Contact,
			APIKey:   w.APIKey,
			SagaID:   w.SagaID,
			SagaType: w.SagaType,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx, NotifyLeadActivity, w).Get(ctx, nil)
	if err != nil {
		return err
	}
	return nil
}