rohit/probo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change insert event name

Browse Source 
Signed-off-by: Sacha Al Himdani <sacha@getprobo.com>
This commit is contained in:
Sacha Al Himdani
2026-02-13 18:27:37 +01:00
parent 60538ef2bb
commit 754bc6d222
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/probo/meeting_service.go
View File

@@ -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) 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) 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) 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) return fmt.Errorf("cannot insert webhook event: %w", err)
} }

6
pkg/probo/vendor_service.go
View File

@@ -394,7 +394,7 @@ func (s VendorService) Update(
return fmt.Errorf("cannot update vendor: %w", err) 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) 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) 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) 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) 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) return fmt.Errorf("cannot insert webhook event: %w", err)
} }

2
pkg/webhook/data.go
View File

@@ -25,7 +25,7 @@ import (
"go.probo.inc/probo/pkg/gid" "go.probo.inc/probo/pkg/gid"
) )
func InsertEvent( func InsertData(
ctx context.Context, ctx context.Context,
conn pg.Conn, conn pg.Conn,
scope coredata.Scoper, scope coredata.Scoper,