Function testWebhookOperations

internal/storage/provider_test.go:326–376

(t *testing.T, ctx context.Context, provider Provider)

}

func testWebhookOperations(t *testing.T, ctx context.Context, provider Provider) {
	webhook := &schemas.Webhook{
		EventName: "test_event",
		EndPoint:  "https://test.com/webhook",
		Enabled:   true,
	}

	// Test AddWebhook
	created, err := provider.AddWebhook(ctx, webhook)
	assert.NoError(t, err)
	assert.NotNil(t, created)

	// Test GetWebhookByID
	fetched, err := provider.GetWebhookByID(ctx, created.ID)
	assert.NoError(t, err)
	assert.Equal(t, webhook.EventName, fetched.EventName)

	// Test GetWebhookByEventName
	fetchedByEventName, err := provider.GetWebhookByEventName(ctx, webhook.EventName)
	assert.NoError(t, err)
	assert.NotNil(t, fetchedByEventName)
	assert.Equal(t, created.ID, fetchedByEventName[0].ID)

	// Test UpdateWebhook
	webhook.EndPoint = "https://test.com/webhook_updated"
	updated, err := provider.UpdateWebhook(ctx, webhook)
	assert.NoError(t, err)
	assert.Equal(t, webhook.EndPoint, updated.EndPoint)

	// Test ListWebhook
	webhooks, _, err := provider.ListWebhook(ctx, &model.Pagination{
		Limit:  10,
		Offset: 0,
	})
	assert.NoError(t, err)
	assert.NotNil(t, webhooks)
	assert.Greater(t, len(webhooks), 0)

	// Test ListWebhookLogs
	logs, _, err := provider.ListWebhookLogs(ctx, &model.Pagination{
		Limit:  10,
		Offset: 0,
	}, webhook.ID)
	assert.NoError(t, err)
	assert.NotNil(t, logs)
	assert.Empty(t, len(logs))

	// Test DeleteWebhook
	err = provider.DeleteWebhook(ctx, updated)
	assert.NoError(t, err)
}

func testEmailTemplateOperations(t *testing.T, ctx context.Context, provider Provider) {
	template := &schemas.EmailTemplate{