diff --git a/pkg/probo/meeting_service.go b/pkg/probo/meeting_service.go index 6f7e25a74..179afc5a4 100644 --- a/pkg/probo/meeting_service.go +++ b/pkg/probo/meeting_service.go @@ -210,7 +210,7 @@ func (s MeetingService) Create( } } - if err := webhook.InsertEvent(ctx, conn, s.svc.scope, organization.ID, coredata.WebhookEventTypeMeetingCreated, webhooktypes.NewMeeting(meeting)); err != nil { + if err := webhook.InsertData(ctx, conn, s.svc.scope, organization.ID, coredata.WebhookEventTypeMeetingCreated, webhooktypes.NewMeeting(meeting)); err != nil { return fmt.Errorf("cannot insert webhook event: %w", err) } @@ -290,7 +290,7 @@ func (s MeetingService) Update( } } - if err := webhook.InsertEvent(ctx, conn, s.svc.scope, meeting.OrganizationID, coredata.WebhookEventTypeMeetingUpdated, webhooktypes.NewMeeting(meeting)); err != nil { + if err := webhook.InsertData(ctx, conn, s.svc.scope, meeting.OrganizationID, coredata.WebhookEventTypeMeetingUpdated, webhooktypes.NewMeeting(meeting)); err != nil { return fmt.Errorf("cannot insert webhook event: %w", err) } @@ -318,7 +318,7 @@ func (s MeetingService) Delete( return fmt.Errorf("cannot load meeting: %w", err) } - if err := webhook.InsertEvent(ctx, conn, s.svc.scope, meeting.OrganizationID, coredata.WebhookEventTypeMeetingDeleted, webhooktypes.NewMeeting(meeting)); err != nil { + if err := webhook.InsertData(ctx, conn, s.svc.scope, meeting.OrganizationID, coredata.WebhookEventTypeMeetingDeleted, webhooktypes.NewMeeting(meeting)); err != nil { return fmt.Errorf("cannot insert webhook event: %w", err) } diff --git a/pkg/probo/vendor_service.go b/pkg/probo/vendor_service.go index c729d78ac..b71808c2e 100644 --- a/pkg/probo/vendor_service.go +++ b/pkg/probo/vendor_service.go @@ -394,7 +394,7 @@ func (s VendorService) Update( return fmt.Errorf("cannot update vendor: %w", err) } - if err := webhook.InsertEvent(ctx, conn, s.svc.scope, vendor.OrganizationID, coredata.WebhookEventTypeVendorUpdated, webhooktypes.NewVendor(vendor)); err != nil { + if err := webhook.InsertData(ctx, conn, s.svc.scope, vendor.OrganizationID, coredata.WebhookEventTypeVendorUpdated, webhooktypes.NewVendor(vendor)); err != nil { return fmt.Errorf("cannot insert webhook event: %w", err) } @@ -442,7 +442,7 @@ func (s VendorService) Delete( return fmt.Errorf("cannot load vendor: %w", err) } - if err := webhook.InsertEvent(ctx, conn, s.svc.scope, vendor.OrganizationID, coredata.WebhookEventTypeVendorDeleted, webhooktypes.NewVendor(vendor)); err != nil { + if err := webhook.InsertData(ctx, conn, s.svc.scope, vendor.OrganizationID, coredata.WebhookEventTypeVendorDeleted, webhooktypes.NewVendor(vendor)); err != nil { return fmt.Errorf("cannot insert webhook event: %w", err) } @@ -519,7 +519,7 @@ func (s VendorService) Create( return fmt.Errorf("cannot insert vendor: %w", err) } - if err := webhook.InsertEvent(ctx, conn, s.svc.scope, organization.ID, coredata.WebhookEventTypeVendorCreated, webhooktypes.NewVendor(vendor)); err != nil { + if err := webhook.InsertData(ctx, conn, s.svc.scope, organization.ID, coredata.WebhookEventTypeVendorCreated, webhooktypes.NewVendor(vendor)); err != nil { return fmt.Errorf("cannot insert webhook event: %w", err) } diff --git a/pkg/webhook/data.go b/pkg/webhook/data.go index 564771c24..0a2d35203 100644 --- a/pkg/webhook/data.go +++ b/pkg/webhook/data.go @@ -25,7 +25,7 @@ import ( "go.probo.inc/probo/pkg/gid" ) -func InsertEvent( +func InsertData( ctx context.Context, conn pg.Conn, scope coredata.Scoper,