lib/rules/new-developer.go

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
	principal     app.User
}

// NewDeveloperWorkflow is a workflow
func NewDeveloperWorkflow(ctx workflow.Context, payload *NewDeveloperWrapper) error {
	ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
		StartToCloseTimeout: time.Minute,
	})
	err := workflow.ExecuteActivity(ctx,
		StoreContactActivity,
		&app.ContactChannelWrapper{
			Obj:       payload.contact,
			Principal: payload.principal,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx,
		StoreAccountActivity,
		&app.AccountChannelWrapper{
			Obj:       payload.account,
			Principal: payload.principal,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx,
		StorePaymentMethodActivity,
		&app.PaymentMethodChannelWrapper{
			Obj:       payload.paymentMethod,
			Principal: payload.principal,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx,
		NotifyContactActivity,
		&app.ContactChannelWrapper{
			Obj:       payload.contact,
			Principal: payload.principal,
		}).Get(ctx, nil)
	if err != nil {
		return err
	}
	err = workflow.ExecuteActivity(ctx, NotifyLeadActivity, payload).Get(ctx, nil)
	if err != nil {
		return err
	}
	return nil
}