package rules import ( "time" "code.tnxs.net/taxnexus/lib/app" "go.temporal.io/sdk/workflow" ) // NewDeveloperWorkflowWrapper wraps a contact, account, payment method with auth and saga info type NewDeveloperWorkflowWrapper struct { AccountName string BillingStreet string BillingCity string BillingState string BillingPostalCode string Company string Description string Email string FirstName string LastName string MobilePhone string Name string Phone string Title string Website string APIKey string SagaID string SagaType string } // NewDeveloperWorkflow is a Temporal workflow func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) error { //nolint:funlen,gocritic,lll // don't care ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{ StartToCloseTimeout: time.Minute, }) err := workflow.ExecuteActivity(ctx, StoreContactActivity, app.ContactActivityWrapper{ Description: w.Description, Email: w.Email, FirstName: w.FirstName, LastName: w.LastName, MobilePhone: w.MobilePhone, Name: w.Name, Phone: w.Phone, Title: w.Title, APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, }).Get(ctx, nil) if err != nil { return err } err = workflow.ExecuteActivity(ctx, StoreAccountActivity, &app.AccountActivityWrapper{ APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, // Description: w.Description, Email: w.Email, Name: w.AccountName, }).Get(ctx, nil) if err != nil { return err } err = workflow.ExecuteActivity(ctx, StorePaymentMethodActivity, &app.PaymentMethodActivityWrapper{ APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, // AccountID: "todo fix this", AchAccountType: "", AchBankAccount: "", AchRouting: "", Active: false, Autopay: false, BankName: "", BillingContactID: "", CCnumber: "", CCtype: "", ContractID: "", Default: false, ExpirationMonth: "", ExpirationYear: "", Gateway: "", GatewayKey: "", Nickname: "", RecordType: "", Ref: "", TenantID: "", }).Get(ctx, nil) if err != nil { return err } err = workflow.ExecuteActivity(ctx, NotifyContactActivity, &app.ContactActivityWrapper{ APIKey: w.APIKey, SagaID: w.SagaID, SagaType: w.SagaType, // Description: w.Description, Email: w.Email, FirstName: w.FirstName, LastName: w.LastName, MobilePhone: w.MobilePhone, Name: w.Name, Phone: w.Phone, Title: w.Title, }).Get(ctx, nil) if err != nil { return err } err = workflow.ExecuteActivity(ctx, NotifyLeadActivity, w).Get(ctx, nil) if err != nil { return err } return nil }