From 3fefcfcd9aa677fa8482e4e1c6485edb1bfe7cc2 Mon Sep 17 00:00:00 2001 From: Lakhan Samani Date: Tue, 1 Aug 2023 17:37:34 +0530 Subject: [PATCH] fix: refs for dynamo db --- server/db/providers/dynamodb/verification_requests.go | 2 +- server/db/providers/dynamodb/webhook.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/server/db/providers/dynamodb/verification_requests.go b/server/db/providers/dynamodb/verification_requests.go index 0ae0365..5fdf078 100644 --- a/server/db/providers/dynamodb/verification_requests.go +++ b/server/db/providers/dynamodb/verification_requests.go @@ -93,7 +93,7 @@ func (p *provider) ListVerificationRequests(ctx context.Context, pagination *mod // DeleteVerificationRequest to delete verification request from database func (p *provider) DeleteVerificationRequest(ctx context.Context, verificationRequest *models.VerificationRequest) error { collection := p.db.Table(models.Collections.VerificationRequest) - if verificationRequest.ID != "" { + if verificationRequest != nil { err := collection.Delete("id", verificationRequest.ID).RunWithContext(ctx) if err != nil { diff --git a/server/db/providers/dynamodb/webhook.go b/server/db/providers/dynamodb/webhook.go index 920173b..c50e1fb 100644 --- a/server/db/providers/dynamodb/webhook.go +++ b/server/db/providers/dynamodb/webhook.go @@ -114,14 +114,14 @@ func (p *provider) GetWebhookByEventName(ctx context.Context, eventName string) // DeleteWebhook to delete webhook func (p *provider) DeleteWebhook(ctx context.Context, webhook *model.Webhook) error { // Also delete webhook logs for given webhook id - if webhook.ID != "" { + if webhook != nil { webhookCollection := p.db.Table(models.Collections.Webhook) - var pagination *model.Pagination webhookLogCollection := p.db.Table(models.Collections.WebhookLog) err := webhookCollection.Delete("id", webhook.ID).RunWithContext(ctx) if err != nil { return err } + pagination := &model.Pagination{} webhookLogs, errIs := p.ListWebhookLogs(ctx, pagination, webhook.ID) for _, webhookLog := range webhookLogs.WebhookLogs { err = webhookLogCollection.Delete("id", webhookLog.ID).RunWithContext(ctx)