From 7596d7e2da7a0945969fa1645dd08b382318eba4 Mon Sep 17 00:00:00 2001 From: Vernon Keenan Date: Tue, 19 Jan 2021 12:23:02 -0800 Subject: [PATCH] activitywrappers --- app/account.go | 4 ++-- app/accountingrule.go | 4 ++-- app/accountingruleset.go | 4 ++-- app/accountingrulesetitem.go | 4 ++-- app/backend.go | 4 ++-- app/cashreceipt.go | 4 ++-- app/charge.go | 4 ++-- app/cluster.go | 4 ++-- app/company.go | 4 ++-- app/contact.go | 4 ++-- app/coordinate.go | 8 ++++---- app/country.go | 4 ++-- app/county.go | 4 ++-- app/database.go | 4 ++-- app/domain.go | 4 ++-- app/eft.go | 4 ++-- app/eftitem.go | 4 ++-- app/emailmessage.go | 4 ++-- app/emaitemplate.go | 4 ++-- app/filing.go | 4 ++-- app/filingscheduleitem.go | 4 ++-- app/filingtype.go | 4 ++-- app/filingtypeinstance.go | 4 ++-- app/folder.go | 4 ++-- app/glaccount.go | 4 ++-- app/glbalance.go | 4 ++-- app/ingest.go | 4 ++-- app/invoice.go | 4 ++-- app/invoiceitem.go | 4 ++-- app/job.go | 4 ++-- app/journalentry.go | 4 ++-- app/journalitem.go | 4 ++-- app/lead.go | 4 ++-- app/license.go | 4 ++-- app/licensetype.go | 12 ++++++------ app/log.go | 4 ++-- app/notebook.go | 4 ++-- app/notebookitem.go | 4 ++-- app/order.go | 4 ++-- app/orderitem.go | 4 ++-- app/outgoingemail.go | 4 ++-- app/outgoingemailreceipt.go | 4 ++-- app/paymentmethod.go | 4 ++-- app/pdf.go | 4 ++-- app/period.go | 4 ++-- app/place.go | 4 ++-- app/po.go | 4 ++-- app/poitem.go | 4 ++-- app/product.go | 4 ++-- app/quote.go | 4 ++-- app/quoteitem.go | 4 ++-- app/ratingengine.go | 4 ++-- app/ratingengineitem.go | 4 ++-- app/role.go | 4 ++-- app/service.go | 4 ++-- app/state.go | 4 ++-- app/submission.go | 4 ++-- app/task.go | 4 ++-- app/taskrelation.go | 4 ++-- app/taskwhorelation.go | 4 ++-- app/taxinstance.go | 4 ++-- app/taxnexuscode.go | 4 ++-- app/taxrate.go | 4 ++-- app/taxtransaction.go | 4 ++-- app/taxtype.go | 4 ++-- app/taxtypeaccount.go | 4 ++-- app/template.go | 4 ++-- app/tenant.go | 4 ++-- app/tenantuser.go | 4 ++-- app/total.go | 4 ++-- app/totalitem.go | 4 ++-- app/totaltaxitem.go | 4 ++-- app/transaction.go | 4 ++-- app/user.go | 4 ++-- app/userrole.go | 4 ++-- rules/account.go | 2 +- rules/auth0.go | 2 +- rules/contact.go | 4 ++-- rules/lead.go | 4 ++-- rules/new-developer.go | 8 ++++---- rules/new-lead.go | 4 ++-- rules/new-user.go | 8 ++++---- rules/paymentmethod.go | 2 +- rules/user.go | 4 ++-- 84 files changed, 175 insertions(+), 175 deletions(-) diff --git a/app/account.go b/app/account.go index 90175bd..20a40c8 100644 --- a/app/account.go +++ b/app/account.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/crm/crm_models" ) -// AccountChannelWrapper wraps the object with workflow params -type AccountChannelWrapper struct { +// AccountActivityWrapper wraps the object with workflow params +type AccountActivityWrapper struct { Obj crm_models.Account APIKey string SagaID string diff --git a/app/accountingrule.go b/app/accountingrule.go index 0103539..dabfd39 100644 --- a/app/accountingrule.go +++ b/app/accountingrule.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// AccountingRuleChannelWrapper wraps the object with workflow params -type AccountingRuleChannelWrapper struct { +// AccountingRuleActivityWrapper wraps the object with workflow params +type AccountingRuleActivityWrapper struct { Obj ledger_models.AccountingRule APIKey string SagaID string diff --git a/app/accountingruleset.go b/app/accountingruleset.go index 00c77e1..332a6af 100644 --- a/app/accountingruleset.go +++ b/app/accountingruleset.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// AccountingRulesetChannelWrapper wraps the object with workflow params -type AccountingRulesetChannelWrapper struct { +// AccountingRulesetActivityWrapper wraps the object with workflow params +type AccountingRulesetActivityWrapper struct { Obj ledger_models.AccountingRuleset APIKey string SagaID string diff --git a/app/accountingrulesetitem.go b/app/accountingrulesetitem.go index b6d3782..93bbfc8 100644 --- a/app/accountingrulesetitem.go +++ b/app/accountingrulesetitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// AccountingRulesetItemChannelWrapper wraps the object with workflow params -type AccountingRulesetItemChannelWrapper struct { +// AccountingRulesetItemActivityWrapper wraps the object with workflow params +type AccountingRulesetItemActivityWrapper struct { Obj ledger_models.AccountingRulesetItem APIKey string SagaID string diff --git a/app/backend.go b/app/backend.go index 36ad405..93f56eb 100644 --- a/app/backend.go +++ b/app/backend.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// BackendChannelWrapper wraps the object with workflow params -type BackendChannelWrapper struct { +// BackendActivityWrapper wraps the object with workflow params +type BackendActivityWrapper struct { Obj regs_models.Backend APIKey string SagaID string diff --git a/app/cashreceipt.go b/app/cashreceipt.go index 5461366..df9e0a9 100644 --- a/app/cashreceipt.go +++ b/app/cashreceipt.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// CashReceiptChannelWrapper wraps the object with workflow params -type CashReceiptChannelWrapper struct { +// CashReceiptActivityWrapper wraps the object with workflow params +type CashReceiptActivityWrapper struct { Obj ops_models.CashReceipt APIKey string SagaID string diff --git a/app/charge.go b/app/charge.go index b6df56f..d259879 100644 --- a/app/charge.go +++ b/app/charge.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// ChargeChannelWrapper wraps the object with workflow params -type ChargeChannelWrapper struct { +// ChargeActivityWrapper wraps the object with workflow params +type ChargeActivityWrapper struct { Obj ops_models.Charge APIKey string SagaID string diff --git a/app/cluster.go b/app/cluster.go index 8e492a6..37dc815 100644 --- a/app/cluster.go +++ b/app/cluster.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// ClusterChannelWrapper wraps the object with workflow params -type ClusterChannelWrapper struct { +// ClusterActivityWrapper wraps the object with workflow params +type ClusterActivityWrapper struct { Obj devops_models.Cluster APIKey string SagaID string diff --git a/app/company.go b/app/company.go index 887dd0e..2fcb565 100644 --- a/app/company.go +++ b/app/company.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/crm/crm_models" ) -// CompanyChannelWrapper wraps the object with workflow params -type CompanyChannelWrapper struct { +// CompanyActivityWrapper wraps the object with workflow params +type CompanyActivityWrapper struct { Obj crm_models.Company APIKey string SagaID string diff --git a/app/contact.go b/app/contact.go index 206fb10..cb68014 100644 --- a/app/contact.go +++ b/app/contact.go @@ -9,8 +9,8 @@ import ( // NewContactActivity is an activity identifier const NewContactActivity = "NEW_CONTACT_ACTIVITY" -// ContactChannelWrapper wraps the object with workflow params -type ContactChannelWrapper struct { +// ContactActivityWrapper wraps the object with workflow params +type ContactActivityWrapper struct { Obj crm_models.Contact APIKey string SagaID string diff --git a/app/coordinate.go b/app/coordinate.go index 027dac8..2b34ab6 100644 --- a/app/coordinate.go +++ b/app/coordinate.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// CoordinateBasicChannelWrapper wraps the object with workflow params -type CoordinateBasicChannelWrapper struct { +// CoordinateBasicActivityWrapper wraps the object with workflow params +type CoordinateBasicActivityWrapper struct { Obj geo_models.CoordinateBasic APIKey string SagaID string @@ -29,8 +29,8 @@ type CoordinateBasic struct { TaxTypes []*string } -// CoordinateChannelWrapper wraps the object with workflow params -type CoordinateChannelWrapper struct { +// CoordinateActivityWrapper wraps the object with workflow params +type CoordinateActivityWrapper struct { Obj geo_models.Coordinate APIKey string SagaID string diff --git a/app/country.go b/app/country.go index 2fa6de4..1ea981a 100644 --- a/app/country.go +++ b/app/country.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// CountryChannelWrapper wraps the object with workflow params -type CountryChannelWrapper struct { +// CountryActivityWrapper wraps the object with workflow params +type CountryActivityWrapper struct { Obj geo_models.Country APIKey string SagaID string diff --git a/app/county.go b/app/county.go index 3672336..54f701d 100644 --- a/app/county.go +++ b/app/county.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// CountyChannelWrapper wraps the object with workflow params -type CountyChannelWrapper struct { +// CountyActivityWrapper wraps the object with workflow params +type CountyActivityWrapper struct { Obj geo_models.County APIKey string SagaID string diff --git a/app/database.go b/app/database.go index 4274071..3424bcf 100644 --- a/app/database.go +++ b/app/database.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// DatabaseChannelWrapper wraps the object with workflow params -type DatabaseChannelWrapper struct { +// DatabaseActivityWrapper wraps the object with workflow params +type DatabaseActivityWrapper struct { Obj devops_models.Database APIKey string SagaID string diff --git a/app/domain.go b/app/domain.go index 1c9aa5b..ab12d27 100644 --- a/app/domain.go +++ b/app/domain.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/geo/geo_models" -// DomainChannelWrapper wraps the object with workflow params -type DomainChannelWrapper struct { +// DomainActivityWrapper wraps the object with workflow params +type DomainActivityWrapper struct { Obj geo_models.Domain APIKey string SagaID string diff --git a/app/eft.go b/app/eft.go index 1342d9e..a64a020 100644 --- a/app/eft.go +++ b/app/eft.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// EftChannelWrapper wraps the object with workflow params -type EftChannelWrapper struct { +// EftActivityWrapper wraps the object with workflow params +type EftActivityWrapper struct { Obj ops_models.Eft APIKey string SagaID string diff --git a/app/eftitem.go b/app/eftitem.go index 52ee5a5..636bf64 100644 --- a/app/eftitem.go +++ b/app/eftitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// EftItemChannelWrapper wraps the object with workflow params -type EftItemChannelWrapper struct { +// EftItemActivityWrapper wraps the object with workflow params +type EftItemActivityWrapper struct { Obj ops_models.EftItem APIKey string SagaID string diff --git a/app/emailmessage.go b/app/emailmessage.go index fd1f4c7..3b41bb5 100644 --- a/app/emailmessage.go +++ b/app/emailmessage.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/workflow/workflow_models" ) -// EmailMessageChannelWrapper wraps the object with workflow params -type EmailMessageChannelWrapper struct { +// EmailMessageActivityWrapper wraps the object with workflow params +type EmailMessageActivityWrapper struct { Obj workflow_models.EmailMessage APIKey string SagaID string diff --git a/app/emaitemplate.go b/app/emaitemplate.go index 88361b8..ec7382e 100644 --- a/app/emaitemplate.go +++ b/app/emaitemplate.go @@ -4,8 +4,8 @@ import ( "database/sql" ) -// EmailTemplateChannelWrapper wraps the object with workflow params -type EmailTemplateChannelWrapper struct { +// EmailTemplateActivityWrapper wraps the object with workflow params +type EmailTemplateActivityWrapper struct { // Obj workflow_models.EmailTemplate APIKey string SagaID string diff --git a/app/filing.go b/app/filing.go index a82f6eb..68f9fa8 100644 --- a/app/filing.go +++ b/app/filing.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// FilingChannelWrapper wraps the object with workflow params -type FilingChannelWrapper struct { +// FilingActivityWrapper wraps the object with workflow params +type FilingActivityWrapper struct { Obj regs_models.Filing APIKey string SagaID string diff --git a/app/filingscheduleitem.go b/app/filingscheduleitem.go index 35b5bbc..139e2cb 100644 --- a/app/filingscheduleitem.go +++ b/app/filingscheduleitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// FilingScheduleItemChannelWrapper wraps the object with workflow params -type FilingScheduleItemChannelWrapper struct { +// FilingScheduleItemActivityWrapper wraps the object with workflow params +type FilingScheduleItemActivityWrapper struct { Obj regs_models.FilingScheduleItem APIKey string SagaID string diff --git a/app/filingtype.go b/app/filingtype.go index 0f526b5..f843ed8 100644 --- a/app/filingtype.go +++ b/app/filingtype.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// FilingTypeChannelWrapper wraps the object with workflow params -type FilingTypeChannelWrapper struct { +// FilingTypeActivityWrapper wraps the object with workflow params +type FilingTypeActivityWrapper struct { Obj regs_models.FilingType APIKey string SagaID string diff --git a/app/filingtypeinstance.go b/app/filingtypeinstance.go index b8fe2c6..3de5506 100644 --- a/app/filingtypeinstance.go +++ b/app/filingtypeinstance.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// FilingTypeInstanceChannelWrapper wraps the object with workflow params -type FilingTypeInstanceChannelWrapper struct { +// FilingTypeInstanceActivityWrapper wraps the object with workflow params +type FilingTypeInstanceActivityWrapper struct { Obj regs_models.FilingTypeInstance APIKey string SagaID string diff --git a/app/folder.go b/app/folder.go index 088836b..1dea191 100644 --- a/app/folder.go +++ b/app/folder.go @@ -4,8 +4,8 @@ import ( "database/sql" ) -// FolderChannelWrapper wraps the object with workflow params -type FolderChannelWrapper struct { +// FolderActivityWrapper wraps the object with workflow params +type FolderActivityWrapper struct { // Obj workflow_models.Folder APIKey string SagaID string diff --git a/app/glaccount.go b/app/glaccount.go index 4ca41df..1020a67 100644 --- a/app/glaccount.go +++ b/app/glaccount.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// GlAccountChannelWrapper wraps the object with workflow params -type GlAccountChannelWrapper struct { +// GlAccountActivityWrapper wraps the object with workflow params +type GlAccountActivityWrapper struct { Obj ledger_models.GlAccount APIKey string SagaID string diff --git a/app/glbalance.go b/app/glbalance.go index 127c208..a3d23a7 100644 --- a/app/glbalance.go +++ b/app/glbalance.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// GlBalanceChannelWrapper wraps the object with workflow params -type GlBalanceChannelWrapper struct { +// GlBalanceActivityWrapper wraps the object with workflow params +type GlBalanceActivityWrapper struct { Obj ledger_models.GlBalance APIKey string SagaID string diff --git a/app/ingest.go b/app/ingest.go index 1fbcb66..602d0d5 100644 --- a/app/ingest.go +++ b/app/ingest.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// IngestChannelWrapper wraps the object with workflow params -type IngestChannelWrapper struct { +// IngestActivityWrapper wraps the object with workflow params +type IngestActivityWrapper struct { Obj devops_models.Ingest APIKey string SagaID string diff --git a/app/invoice.go b/app/invoice.go index 2f71d25..12e7a11 100644 --- a/app/invoice.go +++ b/app/invoice.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// InvoiceChannelWrapper wraps the object with workflow params -type InvoiceChannelWrapper struct { +// InvoiceActivityWrapper wraps the object with workflow params +type InvoiceActivityWrapper struct { Obj ops_models.Invoice APIKey string SagaID string diff --git a/app/invoiceitem.go b/app/invoiceitem.go index 97f754d..42a56b6 100644 --- a/app/invoiceitem.go +++ b/app/invoiceitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// InvoiceItemChannelWrapper wraps the object with workflow params -type InvoiceItemChannelWrapper struct { +// InvoiceItemActivityWrapper wraps the object with workflow params +type InvoiceItemActivityWrapper struct { Obj ops_models.InvoiceItem APIKey string SagaID string diff --git a/app/job.go b/app/job.go index 9d00299..c4003ab 100644 --- a/app/job.go +++ b/app/job.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// JobChannelWrapper wraps the object with workflow params -type JobChannelWrapper struct { +// JobActivityWrapper wraps the object with workflow params +type JobActivityWrapper struct { Obj devops_models.Job APIKey string SagaID string diff --git a/app/journalentry.go b/app/journalentry.go index f6f9f2b..d7b06fc 100644 --- a/app/journalentry.go +++ b/app/journalentry.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// JournalEntryChannelWrapper wraps the object with workflow params -type JournalEntryChannelWrapper struct { +// JournalEntryActivityWrapper wraps the object with workflow params +type JournalEntryActivityWrapper struct { Obj ledger_models.JournalEntry APIKey string SagaID string diff --git a/app/journalitem.go b/app/journalitem.go index e2537bd..4888515 100644 --- a/app/journalitem.go +++ b/app/journalitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// JournalItemChannelWrapper wraps the object with workflow params -type JournalItemChannelWrapper struct { +// JournalItemActivityWrapper wraps the object with workflow params +type JournalItemActivityWrapper struct { Obj ledger_models.JournalItem APIKey string SagaID string diff --git a/app/lead.go b/app/lead.go index b3a1b33..569d5cf 100644 --- a/app/lead.go +++ b/app/lead.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/crm/crm_models" ) -// LeadChannelWrapper wraps the object with workflow params -type LeadChannelWrapper struct { +// LeadActivityWrapper wraps the object with workflow params +type LeadActivityWrapper struct { Obj crm_models.Lead APIKey string SagaID string diff --git a/app/license.go b/app/license.go index efd25b8..c2fa793 100644 --- a/app/license.go +++ b/app/license.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// LicenseChannelWrapper wraps the object with workflow params -type LicenseChannelWrapper struct { +// LicenseActivityWrapper wraps the object with workflow params +type LicenseActivityWrapper struct { Obj regs_models.License APIKey string SagaID string diff --git a/app/licensetype.go b/app/licensetype.go index fbb9c80..d1e0bc1 100644 --- a/app/licensetype.go +++ b/app/licensetype.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// LicenseTypeChannelWrapper wraps the object with workflow params -type LicenseTypeChannelWrapper struct { +// LicenseTypeActivityWrapper wraps the object with workflow params +type LicenseTypeActivityWrapper struct { Obj regs_models.LicenseType APIKey string SagaID string @@ -39,8 +39,8 @@ type LicenseType struct { Tier string } -// GeoLicenseTypeInstanceChannelWrapper wraps the object with workflow params -type GeoLicenseTypeInstanceChannelWrapper struct { +// GeoLicenseTypeInstanceActivityWrapper wraps the object with workflow params +type GeoLicenseTypeInstanceActivityWrapper struct { Obj regs_models.GeoLicenseTypeInstance APIKey string SagaID string @@ -64,8 +64,8 @@ type GeoLicenseTypeInstance struct { StateID string } -// DomainLicenseTypeInstanceChannelWrapper wraps the object with workflow params -type DomainLicenseTypeInstanceChannelWrapper struct { +// DomainLicenseTypeInstanceActivityWrapper wraps the object with workflow params +type DomainLicenseTypeInstanceActivityWrapper struct { // Obj regs_models.DomainLicenseTypeInstance APIKey string SagaID string diff --git a/app/log.go b/app/log.go index e356dfc..a267b5a 100644 --- a/app/log.go +++ b/app/log.go @@ -2,8 +2,8 @@ package app import "database/sql" -// LogChannelWrapper wraps the object with workflow params -type LogChannelWrapper struct { +// LogActivityWrapper wraps the object with workflow params +type LogActivityWrapper struct { // Obj devops_models.AppLog APIKey string SagaID string diff --git a/app/notebook.go b/app/notebook.go index 88572f7..18d42ec 100644 --- a/app/notebook.go +++ b/app/notebook.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// NotebookChannelWrapper wraps the object with workflow params -type NotebookChannelWrapper struct { +// NotebookActivityWrapper wraps the object with workflow params +type NotebookActivityWrapper struct { Obj regs_models.Notebook APIKey string SagaID string diff --git a/app/notebookitem.go b/app/notebookitem.go index 2b8dcb1..960cf52 100644 --- a/app/notebookitem.go +++ b/app/notebookitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// NotebookItemChannelWrapper wraps the object with workflow params -type NotebookItemChannelWrapper struct { +// NotebookItemActivityWrapper wraps the object with workflow params +type NotebookItemActivityWrapper struct { Obj regs_models.NotebookItem APIKey string SagaID string diff --git a/app/order.go b/app/order.go index e98e4e5..ff0e652 100644 --- a/app/order.go +++ b/app/order.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// OrderChannelWrapper wraps the object with workflow params -type OrderChannelWrapper struct { +// OrderActivityWrapper wraps the object with workflow params +type OrderActivityWrapper struct { Obj ops_models.Order APIKey string SagaID string diff --git a/app/orderitem.go b/app/orderitem.go index aeb5d9f..699da20 100644 --- a/app/orderitem.go +++ b/app/orderitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// OrderItemChannelWrapper wraps the object with workflow params -type OrderItemChannelWrapper struct { +// OrderItemActivityWrapper wraps the object with workflow params +type OrderItemActivityWrapper struct { Obj ops_models.OrderItem APIKey string SagaID string diff --git a/app/outgoingemail.go b/app/outgoingemail.go index 3b40003..d3539fb 100644 --- a/app/outgoingemail.go +++ b/app/outgoingemail.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/workflow/workflow_models" -// OutgoingEmailMessageChannelWrapper wraps the object with workflow params -type OutgoingEmailMessageChannelWrapper struct { +// OutgoingEmailMessageActivityWrapper wraps the object with workflow params +type OutgoingEmailMessageActivityWrapper struct { Obj workflow_models.OutgoingEmailMessage APIKey string SagaID string diff --git a/app/outgoingemailreceipt.go b/app/outgoingemailreceipt.go index 4e07280..2ac123a 100644 --- a/app/outgoingemailreceipt.go +++ b/app/outgoingemailreceipt.go @@ -1,7 +1,7 @@ package app -// OutgoingEmailMessageReceiptChannelWrapper wraps the object with workflow params -type OutgoingEmailMessageReceiptChannelWrapper struct { +// OutgoingEmailMessageReceiptActivityWrapper wraps the object with workflow params +type OutgoingEmailMessageReceiptActivityWrapper struct { // Obj workflow_models.OutgoingEmailMessageReceipt APIKey string SagaID string diff --git a/app/paymentmethod.go b/app/paymentmethod.go index fd0275a..8376a65 100644 --- a/app/paymentmethod.go +++ b/app/paymentmethod.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// PaymentMethodChannelWrapper wraps the object with workflow params -type PaymentMethodChannelWrapper struct { +// PaymentMethodActivityWrapper wraps the object with workflow params +type PaymentMethodActivityWrapper struct { Obj ops_models.PaymentMethod APIKey string SagaID string diff --git a/app/pdf.go b/app/pdf.go index 7d55cef..99f9105 100644 --- a/app/pdf.go +++ b/app/pdf.go @@ -2,8 +2,8 @@ package app import "database/sql" -// PDFChannelWrapper wraps the object with workflow params -type PDFChannelWrapper struct { +// PDFActivityWrapper wraps the object with workflow params +type PDFActivityWrapper struct { // Obj stash_models.Pdf APIKey string SagaID string diff --git a/app/period.go b/app/period.go index 676d95a..6a50d64 100644 --- a/app/period.go +++ b/app/period.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" ) -// PeriodChannelWrapper wraps the object with workflow params -type PeriodChannelWrapper struct { +// PeriodActivityWrapper wraps the object with workflow params +type PeriodActivityWrapper struct { Obj ledger_models.Period APIKey string SagaID string diff --git a/app/place.go b/app/place.go index 8362e98..d6cee9f 100644 --- a/app/place.go +++ b/app/place.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// PlaceChannelWrapper wraps the object with workflow params -type PlaceChannelWrapper struct { +// PlaceActivityWrapper wraps the object with workflow params +type PlaceActivityWrapper struct { Obj geo_models.Place APIKey string SagaID string diff --git a/app/po.go b/app/po.go index 59b078f..0ad29a8 100644 --- a/app/po.go +++ b/app/po.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// PurchaseOrderChannelWrapper wraps the object with workflow params -type PurchaseOrderChannelWrapper struct { +// PurchaseOrderActivityWrapper wraps the object with workflow params +type PurchaseOrderActivityWrapper struct { Obj ops_models.PurchaseOrder APIKey string SagaID string diff --git a/app/poitem.go b/app/poitem.go index 9866382..4a7b6f8 100644 --- a/app/poitem.go +++ b/app/poitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// PurchaseOrderItemChannelWrapper wraps the object with workflow params -type PurchaseOrderItemChannelWrapper struct { +// PurchaseOrderItemActivityWrapper wraps the object with workflow params +type PurchaseOrderItemActivityWrapper struct { Obj ops_models.PurchaseOrderItem APIKey string SagaID string diff --git a/app/product.go b/app/product.go index a4d2f0f..0746566 100644 --- a/app/product.go +++ b/app/product.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// ProductChannelWrapper wraps the object with workflow params -type ProductChannelWrapper struct { +// ProductActivityWrapper wraps the object with workflow params +type ProductActivityWrapper struct { Obj ops_models.Product APIKey string SagaID string diff --git a/app/quote.go b/app/quote.go index 70d88ef..9270a6d 100644 --- a/app/quote.go +++ b/app/quote.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// QuoteChannelWrapper wraps the object with workflow params -type QuoteChannelWrapper struct { +// QuoteActivityWrapper wraps the object with workflow params +type QuoteActivityWrapper struct { Obj ops_models.Quote APIKey string SagaID string diff --git a/app/quoteitem.go b/app/quoteitem.go index e5dfd7f..b28e568 100644 --- a/app/quoteitem.go +++ b/app/quoteitem.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// QuoteItemChannelWrapper wraps the object with workflow params -type QuoteItemChannelWrapper struct { +// QuoteItemActivityWrapper wraps the object with workflow params +type QuoteItemActivityWrapper struct { Obj ops_models.QuoteItem APIKey string SagaID string diff --git a/app/ratingengine.go b/app/ratingengine.go index 7ea4b6c..1ba03b9 100644 --- a/app/ratingengine.go +++ b/app/ratingengine.go @@ -5,8 +5,8 @@ import ( "github.com/go-sql-driver/mysql" ) -// RatingengineChannelWrapper wraps the object with workflow params -type RatingengineChannelWrapper struct { +// RatingengineActivityWrapper wraps the object with workflow params +type RatingengineActivityWrapper struct { Obj regs_models.RatingEngine APIKey string SagaID string diff --git a/app/ratingengineitem.go b/app/ratingengineitem.go index ce4c39c..26a2c6e 100644 --- a/app/ratingengineitem.go +++ b/app/ratingengineitem.go @@ -5,8 +5,8 @@ import ( "github.com/go-sql-driver/mysql" ) -// RatingEngineItemChannelWrapper wraps the object with workflow params -type RatingEngineItemChannelWrapper struct { +// RatingEngineItemActivityWrapper wraps the object with workflow params +type RatingEngineItemActivityWrapper struct { Obj regs_models.RatingEngineItem APIKey string SagaID string diff --git a/app/role.go b/app/role.go index 88581c8..921508d 100644 --- a/app/role.go +++ b/app/role.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// RoleChannelWrapper wraps the object with workflow params -type RoleChannelWrapper struct { +// RoleActivityWrapper wraps the object with workflow params +type RoleActivityWrapper struct { Obj devops_models.Role APIKey string SagaID string diff --git a/app/service.go b/app/service.go index b97a325..1529c94 100644 --- a/app/service.go +++ b/app/service.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// ServiceChannelWrapper wraps the object with workflow params -type ServiceChannelWrapper struct { +// ServiceActivityWrapper wraps the object with workflow params +type ServiceActivityWrapper struct { Obj devops_models.Service APIKey string SagaID string diff --git a/app/state.go b/app/state.go index ff19794..2e2de99 100644 --- a/app/state.go +++ b/app/state.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// StateChannelWrapper wraps the object with workflow params -type StateChannelWrapper struct { +// StateActivityWrapper wraps the object with workflow params +type StateActivityWrapper struct { Obj geo_models.State APIKey string SagaID string diff --git a/app/submission.go b/app/submission.go index f4e1bd9..69cc742 100644 --- a/app/submission.go +++ b/app/submission.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// SubmissionChannelWrapper wraps the object with workflow params -type SubmissionChannelWrapper struct { +// SubmissionActivityWrapper wraps the object with workflow params +type SubmissionActivityWrapper struct { Obj regs_models.Submission APIKey string SagaID string diff --git a/app/task.go b/app/task.go index 0ec067f..bbbea68 100644 --- a/app/task.go +++ b/app/task.go @@ -4,8 +4,8 @@ import ( "database/sql" ) -// TaskChannelWrapper wraps the object with workflow params -type TaskChannelWrapper struct { +// TaskActivityWrapper wraps the object with workflow params +type TaskActivityWrapper struct { // Obj workflow_models.Task APIKey string SagaID string diff --git a/app/taskrelation.go b/app/taskrelation.go index 00dfb2a..0b45c09 100644 --- a/app/taskrelation.go +++ b/app/taskrelation.go @@ -4,8 +4,8 @@ import ( "database/sql" ) -// TaskRelationChannelWrapper wraps the object with workflow params -type TaskRelationChannelWrapper struct { +// TaskRelationActivityWrapper wraps the object with workflow params +type TaskRelationActivityWrapper struct { // Obj workflow_models.TaskRelation APIKey string SagaID string diff --git a/app/taskwhorelation.go b/app/taskwhorelation.go index 9b74461..35b2756 100644 --- a/app/taskwhorelation.go +++ b/app/taskwhorelation.go @@ -4,8 +4,8 @@ import ( "database/sql" ) -// TaskWhoRelationChannelWrapper wraps the object with workflow params -type TaskWhoRelationChannelWrapper struct { +// TaskWhoRelationActivityWrapper wraps the object with workflow params +type TaskWhoRelationActivityWrapper struct { // Obj workflow_models.TaskWhoRelation APIKey string SagaID string diff --git a/app/taxinstance.go b/app/taxinstance.go index e3baa78..3b25728 100644 --- a/app/taxinstance.go +++ b/app/taxinstance.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// TaxInstanceChannelWrapper wraps the object with workflow params -type TaxInstanceChannelWrapper struct { +// TaxInstanceActivityWrapper wraps the object with workflow params +type TaxInstanceActivityWrapper struct { Obj geo_models.TaxInstance APIKey string SagaID string diff --git a/app/taxnexuscode.go b/app/taxnexuscode.go index 648ae56..b24db2f 100644 --- a/app/taxnexuscode.go +++ b/app/taxnexuscode.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// TaxnexusCodeChannelWrapper wraps the object with workflow params -type TaxnexusCodeChannelWrapper struct { +// TaxnexusCodeActivityWrapper wraps the object with workflow params +type TaxnexusCodeActivityWrapper struct { Obj geo_models.TaxnexusCode APIKey string SagaID string diff --git a/app/taxrate.go b/app/taxrate.go index 10cf37f..5547400 100644 --- a/app/taxrate.go +++ b/app/taxrate.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/geo/geo_models" -// TaxRateChannelWrapper wraps the object with workflow params -type TaxRateChannelWrapper struct { +// TaxRateActivityWrapper wraps the object with workflow params +type TaxRateActivityWrapper struct { Obj geo_models.TaxRate APIKey string SagaID string diff --git a/app/taxtransaction.go b/app/taxtransaction.go index 5416705..64d6a6a 100644 --- a/app/taxtransaction.go +++ b/app/taxtransaction.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/ops/ops_models" ) -// TaxTransactionChannelWrapper wraps the object with workflow params -type TaxTransactionChannelWrapper struct { +// TaxTransactionActivityWrapper wraps the object with workflow params +type TaxTransactionActivityWrapper struct { Obj ops_models.TaxTransaction APIKey string SagaID string diff --git a/app/taxtype.go b/app/taxtype.go index e5b559d..3a21462 100644 --- a/app/taxtype.go +++ b/app/taxtype.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/geo/geo_models" ) -// TaxTypeChannelWrapper wraps the object with workflow params -type TaxTypeChannelWrapper struct { +// TaxTypeActivityWrapper wraps the object with workflow params +type TaxTypeActivityWrapper struct { Obj geo_models.TaxType APIKey string SagaID string diff --git a/app/taxtypeaccount.go b/app/taxtypeaccount.go index 18e1f90..938f0dd 100644 --- a/app/taxtypeaccount.go +++ b/app/taxtypeaccount.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// TaxTypeAccountChannelWrapper wraps the object with workflow params -type TaxTypeAccountChannelWrapper struct { +// TaxTypeAccountActivityWrapper wraps the object with workflow params +type TaxTypeAccountActivityWrapper struct { Obj regs_models.TaxTypeAccount APIKey string SagaID string diff --git a/app/template.go b/app/template.go index 959b638..025523c 100644 --- a/app/template.go +++ b/app/template.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// TemplateChannelWrapper wraps the object with workflow params -type TemplateChannelWrapper struct { +// TemplateActivityWrapper wraps the object with workflow params +type TemplateActivityWrapper struct { Obj devops_models.Template APIKey string SagaID string diff --git a/app/tenant.go b/app/tenant.go index d8ce4df..a4042d1 100644 --- a/app/tenant.go +++ b/app/tenant.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/devops/devops_models" ) -// TenantChannelWrapper wraps the object with workflow params -type TenantChannelWrapper struct { +// TenantActivityWrapper wraps the object with workflow params +type TenantActivityWrapper struct { Obj devops_models.Tenant APIKey string SagaID string diff --git a/app/tenantuser.go b/app/tenantuser.go index 90f8ab4..ba0f9e6 100644 --- a/app/tenantuser.go +++ b/app/tenantuser.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/devops/devops_models" -// TenantUserChannelWrapper wraps the object with workflow params -type TenantUserChannelWrapper struct { +// TenantUserActivityWrapper wraps the object with workflow params +type TenantUserActivityWrapper struct { Obj devops_models.TenantUser APIKey string SagaID string diff --git a/app/total.go b/app/total.go index 84fa1ab..e924ad6 100644 --- a/app/total.go +++ b/app/total.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/ops/ops_models" -// TotalChannelWrapper wraps the object with workflow params -type TotalChannelWrapper struct { +// TotalActivityWrapper wraps the object with workflow params +type TotalActivityWrapper struct { Obj ops_models.Total APIKey string SagaID string diff --git a/app/totalitem.go b/app/totalitem.go index 0891cbd..6b25c2b 100644 --- a/app/totalitem.go +++ b/app/totalitem.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/ops/ops_models" -// TotalItemChannelWrapper wraps the object with workflow params -type TotalItemChannelWrapper struct { +// TotalItemActivityWrapper wraps the object with workflow params +type TotalItemActivityWrapper struct { Obj ops_models.TotalItem APIKey string SagaID string diff --git a/app/totaltaxitem.go b/app/totaltaxitem.go index b6f706f..668adfe 100644 --- a/app/totaltaxitem.go +++ b/app/totaltaxitem.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/ops/ops_models" -// TotalTaxItemChannelWrapper wraps the object with workflow params -type TotalTaxItemChannelWrapper struct { +// TotalTaxItemActivityWrapper wraps the object with workflow params +type TotalTaxItemActivityWrapper struct { Obj ops_models.TotalTaxItem APIKey string SagaID string diff --git a/app/transaction.go b/app/transaction.go index 6237612..c248b22 100644 --- a/app/transaction.go +++ b/app/transaction.go @@ -6,8 +6,8 @@ import ( "code.tnxs.net/taxnexus/lib/api/regs/regs_models" ) -// TransactionItemChannelWrapper wraps the object with workflow params -type TransactionItemChannelWrapper struct { +// TransactionItemActivityWrapper wraps the object with workflow params +type TransactionItemActivityWrapper struct { Obj regs_models.Transaction APIKey string SagaID string diff --git a/app/user.go b/app/user.go index 4e0408f..36c1db5 100644 --- a/app/user.go +++ b/app/user.go @@ -5,8 +5,8 @@ import ( "github.com/go-openapi/runtime" ) -// UserChannelWrapper wraps the object with workflow params -type UserChannelWrapper struct { +// UserActivityWrapper wraps the object with workflow params +type UserActivityWrapper struct { Obj devops_models.User APIKey string SagaID string diff --git a/app/userrole.go b/app/userrole.go index bc1b889..1c64e5d 100644 --- a/app/userrole.go +++ b/app/userrole.go @@ -2,8 +2,8 @@ package app import "code.tnxs.net/taxnexus/lib/api/devops/devops_models" -// UserRoleChannelWrapper wraps the object with workflow params -type UserRoleChannelWrapper struct { +// UserRoleActivityWrapper wraps the object with workflow params +type UserRoleActivityWrapper struct { Obj devops_models.UserRole APIKey string SagaID string diff --git a/rules/account.go b/rules/account.go index 4043d5d..c78ab37 100644 --- a/rules/account.go +++ b/rules/account.go @@ -12,7 +12,7 @@ import ( const StoreAccountActivityID = "STORE_ACCOUNT_ACTIVITY" // StoreAccountActivity posts a new account object to datastore -func StoreAccountActivity(ctx workflow.Context, w app.AccountChannelWrapper) error { //nolint:gocritic // what we want +func StoreAccountActivity(ctx workflow.Context, w app.AccountActivityWrapper) error { //nolint:gocritic // what we want postAccountParams := accounts.NewPostAccountsParamsWithTimeout(postTimeout) postAccountParams.AccountRequest = &crm_models.AccountRequest{ Data: []*crm_models.Account{&w.Obj}, diff --git a/rules/auth0.go b/rules/auth0.go index ddf6eca..15d4f6e 100644 --- a/rules/auth0.go +++ b/rules/auth0.go @@ -13,7 +13,7 @@ import ( ) // StoreAuth0UserActivity creates a new Auth0 user tied to a User record -func StoreAuth0UserActivity(ctx workflow.Context, w app.UserChannelWrapper) error { //nolint:gocritic // don't care +func StoreAuth0UserActivity(ctx workflow.Context, w app.UserActivityWrapper) error { //nolint:gocritic // don't care auth0UserID, err := app.GetAuth0UserByEmail(w.Obj.Email) if err != nil { return err diff --git a/rules/contact.go b/rules/contact.go index 75b38e9..0f14bdb 100644 --- a/rules/contact.go +++ b/rules/contact.go @@ -15,7 +15,7 @@ import ( ) // StoreContactActivity posts a new contact object to datastore -func StoreContactActivity(ctx workflow.Context, w app.ContactChannelWrapper) error { //nolint:gocritic // what we want +func StoreContactActivity(ctx workflow.Context, w app.ContactActivityWrapper) error { //nolint:gocritic // what we want postContactParams := contacts.NewPostContactsParamsWithTimeout(postTimeout) if w.Obj.Name == "" { w.Obj.Name = w.Obj.FirstName + " " + w.Obj.LastName @@ -37,7 +37,7 @@ func StoreContactActivity(ctx workflow.Context, w app.ContactChannelWrapper) err } // NotifyContactActivity sends an email to a new lead -func NotifyContactActivity(ctx context.Context, w *app.ContactChannelWrapper) error { +func NotifyContactActivity(ctx context.Context, w *app.ContactActivityWrapper) error { sugar.Info("workflow.notifyContact: 📥") var buf bytes.Buffer const textBody = ` diff --git a/rules/lead.go b/rules/lead.go index 2ab28f9..233ddb0 100644 --- a/rules/lead.go +++ b/rules/lead.go @@ -15,7 +15,7 @@ import ( ) // StoreLeadActivity posts a new lead object to datastore -func StoreLeadActivity(ctx workflow.Context, w app.LeadChannelWrapper) error { //nolint:gocritic // what we want +func StoreLeadActivity(ctx workflow.Context, w app.LeadActivityWrapper) error { //nolint:gocritic // what we want postLeadParams := leads.NewPostLeadsParamsWithTimeout(postTimeout) if w.Obj.Name == "" { w.Obj.Name = w.Obj.FirstName + " " + w.Obj.LastName @@ -37,7 +37,7 @@ func StoreLeadActivity(ctx workflow.Context, w app.LeadChannelWrapper) error { / } // NotifyLeadActivity sends an email to a new lead -func NotifyLeadActivity(ctx context.Context, w *app.LeadChannelWrapper) error { +func NotifyLeadActivity(ctx context.Context, w *app.LeadActivityWrapper) error { sugar.Info("workflow.notifyLead: 📥") var buf bytes.Buffer const textBody = ` diff --git a/rules/new-developer.go b/rules/new-developer.go index 697b306..c7c5bee 100644 --- a/rules/new-developer.go +++ b/rules/new-developer.go @@ -38,7 +38,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e }) err := workflow.ExecuteActivity(ctx, StoreContactActivity, - app.ContactChannelWrapper{ + app.ContactActivityWrapper{ Obj: crm_models.Contact{ AccountID: "", AssistantName: "", @@ -90,7 +90,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e } err = workflow.ExecuteActivity(ctx, StoreAccountActivity, - &app.AccountChannelWrapper{ + &app.AccountActivityWrapper{ Obj: crm_models.Account{ AccountNumber: "", AccountSource: "", @@ -184,7 +184,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e } err = workflow.ExecuteActivity(ctx, StorePaymentMethodActivity, - &app.PaymentMethodChannelWrapper{ + &app.PaymentMethodActivityWrapper{ Obj: ops_models.PaymentMethod{ AccountID: "todo fix this", AchAccountType: "", @@ -222,7 +222,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e } err = workflow.ExecuteActivity(ctx, NotifyContactActivity, - &app.ContactChannelWrapper{ + &app.ContactActivityWrapper{ Obj: crm_models.Contact{ Description: w.Description, Email: w.Email, diff --git a/rules/new-lead.go b/rules/new-lead.go index ff63a48..9652aa2 100644 --- a/rules/new-lead.go +++ b/rules/new-lead.go @@ -76,7 +76,7 @@ func NewLeadWorkflow(ctx temporal_workflow.Context, w NewLeadWorkflowWrapper) er ExecuteActivity( ctx, StoreLeadActivity, - app.LeadChannelWrapper{ + app.LeadActivityWrapper{ Obj: obj, SagaID: w.SagaID, SagaType: w.SagaType, @@ -89,7 +89,7 @@ func NewLeadWorkflow(ctx temporal_workflow.Context, w NewLeadWorkflowWrapper) er ExecuteActivity( ctx, NotifyLeadActivity, - app.LeadChannelWrapper{ + app.LeadActivityWrapper{ Obj: obj, APIKey: w.APIKey, }).Get(ctx, nil) diff --git a/rules/new-user.go b/rules/new-user.go index b7e9fe6..f30d29d 100644 --- a/rules/new-user.go +++ b/rules/new-user.go @@ -8,8 +8,8 @@ import ( "go.temporal.io/sdk/workflow" ) -// NewUserChannelWrapper wraps a contact, account, payment method and a user identifier (app.User) -type NewUserChannelWrapper struct { +// NewUserActivityWrapper wraps a contact, account, payment method and a user identifier (app.User) +type NewUserActivityWrapper struct { User devops_models.User Principal app.User SagaID string @@ -17,7 +17,7 @@ type NewUserChannelWrapper struct { } // NewUserWorkflow is a Temporal workflow -func NewUserWorkflow(ctx workflow.Context, payload *NewUserChannelWrapper) error { +func NewUserWorkflow(ctx workflow.Context, payload *NewUserActivityWrapper) error { ctx = workflow.WithActivityOptions( ctx, workflow.ActivityOptions{ @@ -25,7 +25,7 @@ func NewUserWorkflow(ctx workflow.Context, payload *NewUserChannelWrapper) error }) err := workflow.ExecuteActivity(ctx, StoreUserActivity, - &app.UserChannelWrapper{ + &app.UserActivityWrapper{ Obj: payload.User, APIKey: payload.Principal.APIKey, SagaID: payload.SagaID, diff --git a/rules/paymentmethod.go b/rules/paymentmethod.go index afe1b1c..0558972 100644 --- a/rules/paymentmethod.go +++ b/rules/paymentmethod.go @@ -11,7 +11,7 @@ import ( // StorePaymentMethodActivity posts a new paymentmethod object to datastore func StorePaymentMethodActivity( ctx workflow.Context, - w app.PaymentMethodChannelWrapper, //nolint:gocritic // what we want + w app.PaymentMethodActivityWrapper, //nolint:gocritic // what we want ) error { postPaymentMethodParams := payment_method.NewPostPaymentMethodsParamsWithTimeout(postTimeout) postPaymentMethodParams.PaymentMethodRequest = &ops_models.PaymentMethodRequest{ diff --git a/rules/user.go b/rules/user.go index 7af8119..55d5dfc 100644 --- a/rules/user.go +++ b/rules/user.go @@ -18,7 +18,7 @@ import ( ) // StoreUserActivity posts a new user object to datastore and creates the auth0 user -func StoreUserActivity(ctx workflow.Context, w app.UserChannelWrapper) error { //nolint:gocritic // what we want +func StoreUserActivity(ctx workflow.Context, w app.UserActivityWrapper) error { //nolint:gocritic // what we want postUserParams := user.NewPostUsersParamsWithTimeout(postTimeout) if w.Obj.Name == "" { w.Obj.Name = w.Obj.FirstName + " " + w.Obj.LastName @@ -86,7 +86,7 @@ func StoreUserActivity(ctx workflow.Context, w app.UserChannelWrapper) error { / } // NotifyUserActivity sends an email to a new lead -func NotifyUserActivity(ctx context.Context, w *app.UserChannelWrapper) error { +func NotifyUserActivity(ctx context.Context, w *app.UserActivityWrapper) error { sugar.Info("workflow.notifyUser: 📥") var buf bytes.Buffer const textBody = `