fix: make list webhooks params optional

Author: lakhansamani

server/graph/generated/generated.go

@@ -355,7 +355,7 @@ type TestEndpointResponse {
 }
 
 input ListWebhookLogRequest {
-	pagination: PaginationInput!
+	pagination: PaginationInput
 	webhook_id: String
 }
 
@@ -429,5 +429,5 @@ type Query {
 	_env: Env!
 	_webhook(params: WebhookRequest!): Webhook!
 	_webhooks(params: PaginatedInput): Webhooks!
-	_webhook_logs(params: ListWebhookLogRequest!): WebhookLogs!
+	_webhook_logs(params: ListWebhookLogRequest): WebhookLogs!
 }

server/graph/schema.graphqls

@@ -147,7 +147,7 @@ func (r *queryResolver) Webhooks(ctx context.Context, params *model.PaginatedInp
 	return resolvers.WebhooksResolver(ctx, params)
 }
 
-func (r *queryResolver) WebhookLogs(ctx context.Context, params model.ListWebhookLogRequest) (*model.WebhookLogs, error) {
+func (r *queryResolver) WebhookLogs(ctx context.Context, params *model.ListWebhookLogRequest) (*model.WebhookLogs, error) {
 	return resolvers.WebhookLogsResolver(ctx, params)
 }
 

server/graph/schema.resolvers.go

@@ -12,7 +12,7 @@ import (
 )
 
 // WebhookLogsResolver resolver for getting the list of webhook_logs based on pagination & webhook identifier
-func WebhookLogsResolver(ctx context.Context, params model.ListWebhookLogRequest) (*model.WebhookLogs, error) {
+func WebhookLogsResolver(ctx context.Context, params *model.ListWebhookLogRequest) (*model.WebhookLogs, error) {
 	gc, err := utils.GinContextFromContext(ctx)
 	if err != nil {
 		log.Debug("Failed to get GinContext: ", err)
@@ -24,11 +24,20 @@ func WebhookLogsResolver(ctx context.Context, params model.ListWebhookLogRequest
 		return nil, fmt.Errorf("unauthorized")
 	}
 
-	pagination := utils.GetPagination(&model.PaginatedInput{
-		Pagination: params.Pagination,
-	})
+	var pagination model.Pagination
+	var webhookID string
 
-	webhookLogs, err := db.Provider.ListWebhookLogs(ctx, pagination, utils.StringValue(params.WebhookID))
+	if params != nil {
+		pagination = utils.GetPagination(&model.PaginatedInput{
+			Pagination: params.Pagination,
+		})
+		webhookID = utils.StringValue(params.WebhookID)
+	} else {
+		pagination = utils.GetPagination(nil)
+		webhookID = ""
+	}
+
+	webhookLogs, err := db.Provider.ListWebhookLogs(ctx, pagination, webhookID)
 	if err != nil {
 		log.Debug("failed to get webhook logs: ", err)
 		return nil, err

server/resolvers/webhook_logs.go

@@ -27,12 +27,12 @@ func webhookLogsTest(t *testing.T, s TestSetup) {
 		assert.NoError(t, err)
 		assert.NotEmpty(t, webhooks)
 
-		webhookLogs, err := resolvers.WebhookLogsResolver(ctx, model.ListWebhookLogRequest{})
+		webhookLogs, err := resolvers.WebhookLogsResolver(ctx, nil)
 		assert.NoError(t, err)
 		assert.Greater(t, len(webhookLogs.WebhookLogs), 1)
 
 		for _, w := range webhooks.Webhooks {
-			webhookLogs, err := resolvers.WebhookLogsResolver(ctx, model.ListWebhookLogRequest{
+			webhookLogs, err := resolvers.WebhookLogsResolver(ctx, &model.ListWebhookLogRequest{
 				WebhookID: &w.ID,
 			})
 			assert.NoError(t, err)