activitywrappers

v0.1.21 v0.1.21
Vernon Keenan 2021-01-19 12:23:02 -08:00
parent be55d9117a
commit 7596d7e2da
84 changed files with 175 additions and 175 deletions

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/crm/crm_models" "code.tnxs.net/taxnexus/lib/api/crm/crm_models"
) )
// AccountChannelWrapper wraps the object with workflow params // AccountActivityWrapper wraps the object with workflow params
type AccountChannelWrapper struct { type AccountActivityWrapper struct {
Obj crm_models.Account Obj crm_models.Account
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// AccountingRuleChannelWrapper wraps the object with workflow params // AccountingRuleActivityWrapper wraps the object with workflow params
type AccountingRuleChannelWrapper struct { type AccountingRuleActivityWrapper struct {
Obj ledger_models.AccountingRule Obj ledger_models.AccountingRule
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// AccountingRulesetChannelWrapper wraps the object with workflow params // AccountingRulesetActivityWrapper wraps the object with workflow params
type AccountingRulesetChannelWrapper struct { type AccountingRulesetActivityWrapper struct {
Obj ledger_models.AccountingRuleset Obj ledger_models.AccountingRuleset
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// AccountingRulesetItemChannelWrapper wraps the object with workflow params // AccountingRulesetItemActivityWrapper wraps the object with workflow params
type AccountingRulesetItemChannelWrapper struct { type AccountingRulesetItemActivityWrapper struct {
Obj ledger_models.AccountingRulesetItem Obj ledger_models.AccountingRulesetItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// BackendChannelWrapper wraps the object with workflow params // BackendActivityWrapper wraps the object with workflow params
type BackendChannelWrapper struct { type BackendActivityWrapper struct {
Obj regs_models.Backend Obj regs_models.Backend
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// CashReceiptChannelWrapper wraps the object with workflow params // CashReceiptActivityWrapper wraps the object with workflow params
type CashReceiptChannelWrapper struct { type CashReceiptActivityWrapper struct {
Obj ops_models.CashReceipt Obj ops_models.CashReceipt
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// ChargeChannelWrapper wraps the object with workflow params // ChargeActivityWrapper wraps the object with workflow params
type ChargeChannelWrapper struct { type ChargeActivityWrapper struct {
Obj ops_models.Charge Obj ops_models.Charge
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// ClusterChannelWrapper wraps the object with workflow params // ClusterActivityWrapper wraps the object with workflow params
type ClusterChannelWrapper struct { type ClusterActivityWrapper struct {
Obj devops_models.Cluster Obj devops_models.Cluster
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/crm/crm_models" "code.tnxs.net/taxnexus/lib/api/crm/crm_models"
) )
// CompanyChannelWrapper wraps the object with workflow params // CompanyActivityWrapper wraps the object with workflow params
type CompanyChannelWrapper struct { type CompanyActivityWrapper struct {
Obj crm_models.Company Obj crm_models.Company
APIKey string APIKey string
SagaID string SagaID string

View File

@ -9,8 +9,8 @@ import (
// NewContactActivity is an activity identifier // NewContactActivity is an activity identifier
const NewContactActivity = "NEW_CONTACT_ACTIVITY" const NewContactActivity = "NEW_CONTACT_ACTIVITY"
// ContactChannelWrapper wraps the object with workflow params // ContactActivityWrapper wraps the object with workflow params
type ContactChannelWrapper struct { type ContactActivityWrapper struct {
Obj crm_models.Contact Obj crm_models.Contact
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// CoordinateBasicChannelWrapper wraps the object with workflow params // CoordinateBasicActivityWrapper wraps the object with workflow params
type CoordinateBasicChannelWrapper struct { type CoordinateBasicActivityWrapper struct {
Obj geo_models.CoordinateBasic Obj geo_models.CoordinateBasic
APIKey string APIKey string
SagaID string SagaID string
@ -29,8 +29,8 @@ type CoordinateBasic struct {
TaxTypes []*string TaxTypes []*string
} }
// CoordinateChannelWrapper wraps the object with workflow params // CoordinateActivityWrapper wraps the object with workflow params
type CoordinateChannelWrapper struct { type CoordinateActivityWrapper struct {
Obj geo_models.Coordinate Obj geo_models.Coordinate
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// CountryChannelWrapper wraps the object with workflow params // CountryActivityWrapper wraps the object with workflow params
type CountryChannelWrapper struct { type CountryActivityWrapper struct {
Obj geo_models.Country Obj geo_models.Country
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// CountyChannelWrapper wraps the object with workflow params // CountyActivityWrapper wraps the object with workflow params
type CountyChannelWrapper struct { type CountyActivityWrapper struct {
Obj geo_models.County Obj geo_models.County
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// DatabaseChannelWrapper wraps the object with workflow params // DatabaseActivityWrapper wraps the object with workflow params
type DatabaseChannelWrapper struct { type DatabaseActivityWrapper struct {
Obj devops_models.Database Obj devops_models.Database
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/geo/geo_models" import "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
// DomainChannelWrapper wraps the object with workflow params // DomainActivityWrapper wraps the object with workflow params
type DomainChannelWrapper struct { type DomainActivityWrapper struct {
Obj geo_models.Domain Obj geo_models.Domain
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// EftChannelWrapper wraps the object with workflow params // EftActivityWrapper wraps the object with workflow params
type EftChannelWrapper struct { type EftActivityWrapper struct {
Obj ops_models.Eft Obj ops_models.Eft
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// EftItemChannelWrapper wraps the object with workflow params // EftItemActivityWrapper wraps the object with workflow params
type EftItemChannelWrapper struct { type EftItemActivityWrapper struct {
Obj ops_models.EftItem Obj ops_models.EftItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/workflow/workflow_models" "code.tnxs.net/taxnexus/lib/api/workflow/workflow_models"
) )
// EmailMessageChannelWrapper wraps the object with workflow params // EmailMessageActivityWrapper wraps the object with workflow params
type EmailMessageChannelWrapper struct { type EmailMessageActivityWrapper struct {
Obj workflow_models.EmailMessage Obj workflow_models.EmailMessage
APIKey string APIKey string
SagaID string SagaID string

View File

@ -4,8 +4,8 @@ import (
"database/sql" "database/sql"
) )
// EmailTemplateChannelWrapper wraps the object with workflow params // EmailTemplateActivityWrapper wraps the object with workflow params
type EmailTemplateChannelWrapper struct { type EmailTemplateActivityWrapper struct {
// Obj workflow_models.EmailTemplate // Obj workflow_models.EmailTemplate
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// FilingChannelWrapper wraps the object with workflow params // FilingActivityWrapper wraps the object with workflow params
type FilingChannelWrapper struct { type FilingActivityWrapper struct {
Obj regs_models.Filing Obj regs_models.Filing
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// FilingScheduleItemChannelWrapper wraps the object with workflow params // FilingScheduleItemActivityWrapper wraps the object with workflow params
type FilingScheduleItemChannelWrapper struct { type FilingScheduleItemActivityWrapper struct {
Obj regs_models.FilingScheduleItem Obj regs_models.FilingScheduleItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// FilingTypeChannelWrapper wraps the object with workflow params // FilingTypeActivityWrapper wraps the object with workflow params
type FilingTypeChannelWrapper struct { type FilingTypeActivityWrapper struct {
Obj regs_models.FilingType Obj regs_models.FilingType
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// FilingTypeInstanceChannelWrapper wraps the object with workflow params // FilingTypeInstanceActivityWrapper wraps the object with workflow params
type FilingTypeInstanceChannelWrapper struct { type FilingTypeInstanceActivityWrapper struct {
Obj regs_models.FilingTypeInstance Obj regs_models.FilingTypeInstance
APIKey string APIKey string
SagaID string SagaID string

View File

@ -4,8 +4,8 @@ import (
"database/sql" "database/sql"
) )
// FolderChannelWrapper wraps the object with workflow params // FolderActivityWrapper wraps the object with workflow params
type FolderChannelWrapper struct { type FolderActivityWrapper struct {
// Obj workflow_models.Folder // Obj workflow_models.Folder
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// GlAccountChannelWrapper wraps the object with workflow params // GlAccountActivityWrapper wraps the object with workflow params
type GlAccountChannelWrapper struct { type GlAccountActivityWrapper struct {
Obj ledger_models.GlAccount Obj ledger_models.GlAccount
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// GlBalanceChannelWrapper wraps the object with workflow params // GlBalanceActivityWrapper wraps the object with workflow params
type GlBalanceChannelWrapper struct { type GlBalanceActivityWrapper struct {
Obj ledger_models.GlBalance Obj ledger_models.GlBalance
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// IngestChannelWrapper wraps the object with workflow params // IngestActivityWrapper wraps the object with workflow params
type IngestChannelWrapper struct { type IngestActivityWrapper struct {
Obj devops_models.Ingest Obj devops_models.Ingest
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// InvoiceChannelWrapper wraps the object with workflow params // InvoiceActivityWrapper wraps the object with workflow params
type InvoiceChannelWrapper struct { type InvoiceActivityWrapper struct {
Obj ops_models.Invoice Obj ops_models.Invoice
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// InvoiceItemChannelWrapper wraps the object with workflow params // InvoiceItemActivityWrapper wraps the object with workflow params
type InvoiceItemChannelWrapper struct { type InvoiceItemActivityWrapper struct {
Obj ops_models.InvoiceItem Obj ops_models.InvoiceItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// JobChannelWrapper wraps the object with workflow params // JobActivityWrapper wraps the object with workflow params
type JobChannelWrapper struct { type JobActivityWrapper struct {
Obj devops_models.Job Obj devops_models.Job
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// JournalEntryChannelWrapper wraps the object with workflow params // JournalEntryActivityWrapper wraps the object with workflow params
type JournalEntryChannelWrapper struct { type JournalEntryActivityWrapper struct {
Obj ledger_models.JournalEntry Obj ledger_models.JournalEntry
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// JournalItemChannelWrapper wraps the object with workflow params // JournalItemActivityWrapper wraps the object with workflow params
type JournalItemChannelWrapper struct { type JournalItemActivityWrapper struct {
Obj ledger_models.JournalItem Obj ledger_models.JournalItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/crm/crm_models" "code.tnxs.net/taxnexus/lib/api/crm/crm_models"
) )
// LeadChannelWrapper wraps the object with workflow params // LeadActivityWrapper wraps the object with workflow params
type LeadChannelWrapper struct { type LeadActivityWrapper struct {
Obj crm_models.Lead Obj crm_models.Lead
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// LicenseChannelWrapper wraps the object with workflow params // LicenseActivityWrapper wraps the object with workflow params
type LicenseChannelWrapper struct { type LicenseActivityWrapper struct {
Obj regs_models.License Obj regs_models.License
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// LicenseTypeChannelWrapper wraps the object with workflow params // LicenseTypeActivityWrapper wraps the object with workflow params
type LicenseTypeChannelWrapper struct { type LicenseTypeActivityWrapper struct {
Obj regs_models.LicenseType Obj regs_models.LicenseType
APIKey string APIKey string
SagaID string SagaID string
@ -39,8 +39,8 @@ type LicenseType struct {
Tier string Tier string
} }
// GeoLicenseTypeInstanceChannelWrapper wraps the object with workflow params // GeoLicenseTypeInstanceActivityWrapper wraps the object with workflow params
type GeoLicenseTypeInstanceChannelWrapper struct { type GeoLicenseTypeInstanceActivityWrapper struct {
Obj regs_models.GeoLicenseTypeInstance Obj regs_models.GeoLicenseTypeInstance
APIKey string APIKey string
SagaID string SagaID string
@ -64,8 +64,8 @@ type GeoLicenseTypeInstance struct {
StateID string StateID string
} }
// DomainLicenseTypeInstanceChannelWrapper wraps the object with workflow params // DomainLicenseTypeInstanceActivityWrapper wraps the object with workflow params
type DomainLicenseTypeInstanceChannelWrapper struct { type DomainLicenseTypeInstanceActivityWrapper struct {
// Obj regs_models.DomainLicenseTypeInstance // Obj regs_models.DomainLicenseTypeInstance
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "database/sql" import "database/sql"
// LogChannelWrapper wraps the object with workflow params // LogActivityWrapper wraps the object with workflow params
type LogChannelWrapper struct { type LogActivityWrapper struct {
// Obj devops_models.AppLog // Obj devops_models.AppLog
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// NotebookChannelWrapper wraps the object with workflow params // NotebookActivityWrapper wraps the object with workflow params
type NotebookChannelWrapper struct { type NotebookActivityWrapper struct {
Obj regs_models.Notebook Obj regs_models.Notebook
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// NotebookItemChannelWrapper wraps the object with workflow params // NotebookItemActivityWrapper wraps the object with workflow params
type NotebookItemChannelWrapper struct { type NotebookItemActivityWrapper struct {
Obj regs_models.NotebookItem Obj regs_models.NotebookItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// OrderChannelWrapper wraps the object with workflow params // OrderActivityWrapper wraps the object with workflow params
type OrderChannelWrapper struct { type OrderActivityWrapper struct {
Obj ops_models.Order Obj ops_models.Order
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// OrderItemChannelWrapper wraps the object with workflow params // OrderItemActivityWrapper wraps the object with workflow params
type OrderItemChannelWrapper struct { type OrderItemActivityWrapper struct {
Obj ops_models.OrderItem Obj ops_models.OrderItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/workflow/workflow_models" import "code.tnxs.net/taxnexus/lib/api/workflow/workflow_models"
// OutgoingEmailMessageChannelWrapper wraps the object with workflow params // OutgoingEmailMessageActivityWrapper wraps the object with workflow params
type OutgoingEmailMessageChannelWrapper struct { type OutgoingEmailMessageActivityWrapper struct {
Obj workflow_models.OutgoingEmailMessage Obj workflow_models.OutgoingEmailMessage
APIKey string APIKey string
SagaID string SagaID string

View File

@ -1,7 +1,7 @@
package app package app
// OutgoingEmailMessageReceiptChannelWrapper wraps the object with workflow params // OutgoingEmailMessageReceiptActivityWrapper wraps the object with workflow params
type OutgoingEmailMessageReceiptChannelWrapper struct { type OutgoingEmailMessageReceiptActivityWrapper struct {
// Obj workflow_models.OutgoingEmailMessageReceipt // Obj workflow_models.OutgoingEmailMessageReceipt
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// PaymentMethodChannelWrapper wraps the object with workflow params // PaymentMethodActivityWrapper wraps the object with workflow params
type PaymentMethodChannelWrapper struct { type PaymentMethodActivityWrapper struct {
Obj ops_models.PaymentMethod Obj ops_models.PaymentMethod
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "database/sql" import "database/sql"
// PDFChannelWrapper wraps the object with workflow params // PDFActivityWrapper wraps the object with workflow params
type PDFChannelWrapper struct { type PDFActivityWrapper struct {
// Obj stash_models.Pdf // Obj stash_models.Pdf
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ledger/ledger_models" "code.tnxs.net/taxnexus/lib/api/ledger/ledger_models"
) )
// PeriodChannelWrapper wraps the object with workflow params // PeriodActivityWrapper wraps the object with workflow params
type PeriodChannelWrapper struct { type PeriodActivityWrapper struct {
Obj ledger_models.Period Obj ledger_models.Period
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// PlaceChannelWrapper wraps the object with workflow params // PlaceActivityWrapper wraps the object with workflow params
type PlaceChannelWrapper struct { type PlaceActivityWrapper struct {
Obj geo_models.Place Obj geo_models.Place
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// PurchaseOrderChannelWrapper wraps the object with workflow params // PurchaseOrderActivityWrapper wraps the object with workflow params
type PurchaseOrderChannelWrapper struct { type PurchaseOrderActivityWrapper struct {
Obj ops_models.PurchaseOrder Obj ops_models.PurchaseOrder
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// PurchaseOrderItemChannelWrapper wraps the object with workflow params // PurchaseOrderItemActivityWrapper wraps the object with workflow params
type PurchaseOrderItemChannelWrapper struct { type PurchaseOrderItemActivityWrapper struct {
Obj ops_models.PurchaseOrderItem Obj ops_models.PurchaseOrderItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// ProductChannelWrapper wraps the object with workflow params // ProductActivityWrapper wraps the object with workflow params
type ProductChannelWrapper struct { type ProductActivityWrapper struct {
Obj ops_models.Product Obj ops_models.Product
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// QuoteChannelWrapper wraps the object with workflow params // QuoteActivityWrapper wraps the object with workflow params
type QuoteChannelWrapper struct { type QuoteActivityWrapper struct {
Obj ops_models.Quote Obj ops_models.Quote
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// QuoteItemChannelWrapper wraps the object with workflow params // QuoteItemActivityWrapper wraps the object with workflow params
type QuoteItemChannelWrapper struct { type QuoteItemActivityWrapper struct {
Obj ops_models.QuoteItem Obj ops_models.QuoteItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -5,8 +5,8 @@ import (
"github.com/go-sql-driver/mysql" "github.com/go-sql-driver/mysql"
) )
// RatingengineChannelWrapper wraps the object with workflow params // RatingengineActivityWrapper wraps the object with workflow params
type RatingengineChannelWrapper struct { type RatingengineActivityWrapper struct {
Obj regs_models.RatingEngine Obj regs_models.RatingEngine
APIKey string APIKey string
SagaID string SagaID string

View File

@ -5,8 +5,8 @@ import (
"github.com/go-sql-driver/mysql" "github.com/go-sql-driver/mysql"
) )
// RatingEngineItemChannelWrapper wraps the object with workflow params // RatingEngineItemActivityWrapper wraps the object with workflow params
type RatingEngineItemChannelWrapper struct { type RatingEngineItemActivityWrapper struct {
Obj regs_models.RatingEngineItem Obj regs_models.RatingEngineItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// RoleChannelWrapper wraps the object with workflow params // RoleActivityWrapper wraps the object with workflow params
type RoleChannelWrapper struct { type RoleActivityWrapper struct {
Obj devops_models.Role Obj devops_models.Role
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// ServiceChannelWrapper wraps the object with workflow params // ServiceActivityWrapper wraps the object with workflow params
type ServiceChannelWrapper struct { type ServiceActivityWrapper struct {
Obj devops_models.Service Obj devops_models.Service
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// StateChannelWrapper wraps the object with workflow params // StateActivityWrapper wraps the object with workflow params
type StateChannelWrapper struct { type StateActivityWrapper struct {
Obj geo_models.State Obj geo_models.State
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// SubmissionChannelWrapper wraps the object with workflow params // SubmissionActivityWrapper wraps the object with workflow params
type SubmissionChannelWrapper struct { type SubmissionActivityWrapper struct {
Obj regs_models.Submission Obj regs_models.Submission
APIKey string APIKey string
SagaID string SagaID string

View File

@ -4,8 +4,8 @@ import (
"database/sql" "database/sql"
) )
// TaskChannelWrapper wraps the object with workflow params // TaskActivityWrapper wraps the object with workflow params
type TaskChannelWrapper struct { type TaskActivityWrapper struct {
// Obj workflow_models.Task // Obj workflow_models.Task
APIKey string APIKey string
SagaID string SagaID string

View File

@ -4,8 +4,8 @@ import (
"database/sql" "database/sql"
) )
// TaskRelationChannelWrapper wraps the object with workflow params // TaskRelationActivityWrapper wraps the object with workflow params
type TaskRelationChannelWrapper struct { type TaskRelationActivityWrapper struct {
// Obj workflow_models.TaskRelation // Obj workflow_models.TaskRelation
APIKey string APIKey string
SagaID string SagaID string

View File

@ -4,8 +4,8 @@ import (
"database/sql" "database/sql"
) )
// TaskWhoRelationChannelWrapper wraps the object with workflow params // TaskWhoRelationActivityWrapper wraps the object with workflow params
type TaskWhoRelationChannelWrapper struct { type TaskWhoRelationActivityWrapper struct {
// Obj workflow_models.TaskWhoRelation // Obj workflow_models.TaskWhoRelation
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// TaxInstanceChannelWrapper wraps the object with workflow params // TaxInstanceActivityWrapper wraps the object with workflow params
type TaxInstanceChannelWrapper struct { type TaxInstanceActivityWrapper struct {
Obj geo_models.TaxInstance Obj geo_models.TaxInstance
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// TaxnexusCodeChannelWrapper wraps the object with workflow params // TaxnexusCodeActivityWrapper wraps the object with workflow params
type TaxnexusCodeChannelWrapper struct { type TaxnexusCodeActivityWrapper struct {
Obj geo_models.TaxnexusCode Obj geo_models.TaxnexusCode
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/geo/geo_models" import "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
// TaxRateChannelWrapper wraps the object with workflow params // TaxRateActivityWrapper wraps the object with workflow params
type TaxRateChannelWrapper struct { type TaxRateActivityWrapper struct {
Obj geo_models.TaxRate Obj geo_models.TaxRate
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/ops/ops_models" "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
) )
// TaxTransactionChannelWrapper wraps the object with workflow params // TaxTransactionActivityWrapper wraps the object with workflow params
type TaxTransactionChannelWrapper struct { type TaxTransactionActivityWrapper struct {
Obj ops_models.TaxTransaction Obj ops_models.TaxTransaction
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/geo/geo_models" "code.tnxs.net/taxnexus/lib/api/geo/geo_models"
) )
// TaxTypeChannelWrapper wraps the object with workflow params // TaxTypeActivityWrapper wraps the object with workflow params
type TaxTypeChannelWrapper struct { type TaxTypeActivityWrapper struct {
Obj geo_models.TaxType Obj geo_models.TaxType
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// TaxTypeAccountChannelWrapper wraps the object with workflow params // TaxTypeAccountActivityWrapper wraps the object with workflow params
type TaxTypeAccountChannelWrapper struct { type TaxTypeAccountActivityWrapper struct {
Obj regs_models.TaxTypeAccount Obj regs_models.TaxTypeAccount
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// TemplateChannelWrapper wraps the object with workflow params // TemplateActivityWrapper wraps the object with workflow params
type TemplateChannelWrapper struct { type TemplateActivityWrapper struct {
Obj devops_models.Template Obj devops_models.Template
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/devops/devops_models" "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
) )
// TenantChannelWrapper wraps the object with workflow params // TenantActivityWrapper wraps the object with workflow params
type TenantChannelWrapper struct { type TenantActivityWrapper struct {
Obj devops_models.Tenant Obj devops_models.Tenant
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/devops/devops_models" import "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
// TenantUserChannelWrapper wraps the object with workflow params // TenantUserActivityWrapper wraps the object with workflow params
type TenantUserChannelWrapper struct { type TenantUserActivityWrapper struct {
Obj devops_models.TenantUser Obj devops_models.TenantUser
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/ops/ops_models" import "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
// TotalChannelWrapper wraps the object with workflow params // TotalActivityWrapper wraps the object with workflow params
type TotalChannelWrapper struct { type TotalActivityWrapper struct {
Obj ops_models.Total Obj ops_models.Total
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/ops/ops_models" import "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
// TotalItemChannelWrapper wraps the object with workflow params // TotalItemActivityWrapper wraps the object with workflow params
type TotalItemChannelWrapper struct { type TotalItemActivityWrapper struct {
Obj ops_models.TotalItem Obj ops_models.TotalItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/ops/ops_models" import "code.tnxs.net/taxnexus/lib/api/ops/ops_models"
// TotalTaxItemChannelWrapper wraps the object with workflow params // TotalTaxItemActivityWrapper wraps the object with workflow params
type TotalTaxItemChannelWrapper struct { type TotalTaxItemActivityWrapper struct {
Obj ops_models.TotalTaxItem Obj ops_models.TotalTaxItem
APIKey string APIKey string
SagaID string SagaID string

View File

@ -6,8 +6,8 @@ import (
"code.tnxs.net/taxnexus/lib/api/regs/regs_models" "code.tnxs.net/taxnexus/lib/api/regs/regs_models"
) )
// TransactionItemChannelWrapper wraps the object with workflow params // TransactionItemActivityWrapper wraps the object with workflow params
type TransactionItemChannelWrapper struct { type TransactionItemActivityWrapper struct {
Obj regs_models.Transaction Obj regs_models.Transaction
APIKey string APIKey string
SagaID string SagaID string

View File

@ -5,8 +5,8 @@ import (
"github.com/go-openapi/runtime" "github.com/go-openapi/runtime"
) )
// UserChannelWrapper wraps the object with workflow params // UserActivityWrapper wraps the object with workflow params
type UserChannelWrapper struct { type UserActivityWrapper struct {
Obj devops_models.User Obj devops_models.User
APIKey string APIKey string
SagaID string SagaID string

View File

@ -2,8 +2,8 @@ package app
import "code.tnxs.net/taxnexus/lib/api/devops/devops_models" import "code.tnxs.net/taxnexus/lib/api/devops/devops_models"
// UserRoleChannelWrapper wraps the object with workflow params // UserRoleActivityWrapper wraps the object with workflow params
type UserRoleChannelWrapper struct { type UserRoleActivityWrapper struct {
Obj devops_models.UserRole Obj devops_models.UserRole
APIKey string APIKey string
SagaID string SagaID string

View File

@ -12,7 +12,7 @@ import (
const StoreAccountActivityID = "STORE_ACCOUNT_ACTIVITY" const StoreAccountActivityID = "STORE_ACCOUNT_ACTIVITY"
// StoreAccountActivity posts a new account object to datastore // 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 := accounts.NewPostAccountsParamsWithTimeout(postTimeout)
postAccountParams.AccountRequest = &crm_models.AccountRequest{ postAccountParams.AccountRequest = &crm_models.AccountRequest{
Data: []*crm_models.Account{&w.Obj}, Data: []*crm_models.Account{&w.Obj},

View File

@ -13,7 +13,7 @@ import (
) )
// StoreAuth0UserActivity creates a new Auth0 user tied to a User record // 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) auth0UserID, err := app.GetAuth0UserByEmail(w.Obj.Email)
if err != nil { if err != nil {
return err return err

View File

@ -15,7 +15,7 @@ import (
) )
// StoreContactActivity posts a new contact object to datastore // 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) postContactParams := contacts.NewPostContactsParamsWithTimeout(postTimeout)
if w.Obj.Name == "" { if w.Obj.Name == "" {
w.Obj.Name = w.Obj.FirstName + " " + w.Obj.LastName 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 // 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: 📥") sugar.Info("workflow.notifyContact: 📥")
var buf bytes.Buffer var buf bytes.Buffer
const textBody = ` const textBody = `

View File

@ -15,7 +15,7 @@ import (
) )
// StoreLeadActivity posts a new lead object to datastore // 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) postLeadParams := leads.NewPostLeadsParamsWithTimeout(postTimeout)
if w.Obj.Name == "" { if w.Obj.Name == "" {
w.Obj.Name = w.Obj.FirstName + " " + w.Obj.LastName 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 // 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: 📥") sugar.Info("workflow.notifyLead: 📥")
var buf bytes.Buffer var buf bytes.Buffer
const textBody = ` const textBody = `

View File

@ -38,7 +38,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e
}) })
err := workflow.ExecuteActivity(ctx, err := workflow.ExecuteActivity(ctx,
StoreContactActivity, StoreContactActivity,
app.ContactChannelWrapper{ app.ContactActivityWrapper{
Obj: crm_models.Contact{ Obj: crm_models.Contact{
AccountID: "", AccountID: "",
AssistantName: "", AssistantName: "",
@ -90,7 +90,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e
} }
err = workflow.ExecuteActivity(ctx, err = workflow.ExecuteActivity(ctx,
StoreAccountActivity, StoreAccountActivity,
&app.AccountChannelWrapper{ &app.AccountActivityWrapper{
Obj: crm_models.Account{ Obj: crm_models.Account{
AccountNumber: "", AccountNumber: "",
AccountSource: "", AccountSource: "",
@ -184,7 +184,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e
} }
err = workflow.ExecuteActivity(ctx, err = workflow.ExecuteActivity(ctx,
StorePaymentMethodActivity, StorePaymentMethodActivity,
&app.PaymentMethodChannelWrapper{ &app.PaymentMethodActivityWrapper{
Obj: ops_models.PaymentMethod{ Obj: ops_models.PaymentMethod{
AccountID: "todo fix this", AccountID: "todo fix this",
AchAccountType: "", AchAccountType: "",
@ -222,7 +222,7 @@ func NewDeveloperWorkflow(ctx workflow.Context, w NewDeveloperWorkflowWrapper) e
} }
err = workflow.ExecuteActivity(ctx, err = workflow.ExecuteActivity(ctx,
NotifyContactActivity, NotifyContactActivity,
&app.ContactChannelWrapper{ &app.ContactActivityWrapper{
Obj: crm_models.Contact{ Obj: crm_models.Contact{
Description: w.Description, Description: w.Description,
Email: w.Email, Email: w.Email,

View File

@ -76,7 +76,7 @@ func NewLeadWorkflow(ctx temporal_workflow.Context, w NewLeadWorkflowWrapper) er
ExecuteActivity( ExecuteActivity(
ctx, ctx,
StoreLeadActivity, StoreLeadActivity,
app.LeadChannelWrapper{ app.LeadActivityWrapper{
Obj: obj, Obj: obj,
SagaID: w.SagaID, SagaID: w.SagaID,
SagaType: w.SagaType, SagaType: w.SagaType,
@ -89,7 +89,7 @@ func NewLeadWorkflow(ctx temporal_workflow.Context, w NewLeadWorkflowWrapper) er
ExecuteActivity( ExecuteActivity(
ctx, ctx,
NotifyLeadActivity, NotifyLeadActivity,
app.LeadChannelWrapper{ app.LeadActivityWrapper{
Obj: obj, Obj: obj,
APIKey: w.APIKey, APIKey: w.APIKey,
}).Get(ctx, nil) }).Get(ctx, nil)

View File

@ -8,8 +8,8 @@ import (
"go.temporal.io/sdk/workflow" "go.temporal.io/sdk/workflow"
) )
// NewUserChannelWrapper wraps a contact, account, payment method and a user identifier (app.User) // NewUserActivityWrapper wraps a contact, account, payment method and a user identifier (app.User)
type NewUserChannelWrapper struct { type NewUserActivityWrapper struct {
User devops_models.User User devops_models.User
Principal app.User Principal app.User
SagaID string SagaID string
@ -17,7 +17,7 @@ type NewUserChannelWrapper struct {
} }
// NewUserWorkflow is a Temporal workflow // 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.WithActivityOptions(
ctx, ctx,
workflow.ActivityOptions{ workflow.ActivityOptions{
@ -25,7 +25,7 @@ func NewUserWorkflow(ctx workflow.Context, payload *NewUserChannelWrapper) error
}) })
err := workflow.ExecuteActivity(ctx, err := workflow.ExecuteActivity(ctx,
StoreUserActivity, StoreUserActivity,
&app.UserChannelWrapper{ &app.UserActivityWrapper{
Obj: payload.User, Obj: payload.User,
APIKey: payload.Principal.APIKey, APIKey: payload.Principal.APIKey,
SagaID: payload.SagaID, SagaID: payload.SagaID,

View File

@ -11,7 +11,7 @@ import (
// StorePaymentMethodActivity posts a new paymentmethod object to datastore // StorePaymentMethodActivity posts a new paymentmethod object to datastore
func StorePaymentMethodActivity( func StorePaymentMethodActivity(
ctx workflow.Context, ctx workflow.Context,
w app.PaymentMethodChannelWrapper, //nolint:gocritic // what we want w app.PaymentMethodActivityWrapper, //nolint:gocritic // what we want
) error { ) error {
postPaymentMethodParams := payment_method.NewPostPaymentMethodsParamsWithTimeout(postTimeout) postPaymentMethodParams := payment_method.NewPostPaymentMethodsParamsWithTimeout(postTimeout)
postPaymentMethodParams.PaymentMethodRequest = &ops_models.PaymentMethodRequest{ postPaymentMethodParams.PaymentMethodRequest = &ops_models.PaymentMethodRequest{

View File

@ -18,7 +18,7 @@ import (
) )
// StoreUserActivity posts a new user object to datastore and creates the auth0 user // 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) postUserParams := user.NewPostUsersParamsWithTimeout(postTimeout)
if w.Obj.Name == "" { if w.Obj.Name == "" {
w.Obj.Name = w.Obj.FirstName + " " + w.Obj.LastName 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 // 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: 📥") sugar.Info("workflow.notifyUser: 📥")
var buf bytes.Buffer var buf bytes.Buffer
const textBody = ` const textBody = `