feat: asa.news RSS reader with developer tier, REST API, and webhooks

Full-stack RSS reader SaaS: Supabase + Next.js + Go worker.
Includes three subscription tiers (free/pro/developer), API key auth,
read-only REST API, webhook push notifications, Stripe billing with
proration, and PWA support.

1 files changed, 39 insertions, 0 deletions

diff --git a/services/worker/internal/database/database.go b/services/worker/internal/database/database.go
new file mode 100644
index 0000000..2b2900f
--- /dev/null
+++ b/services/worker/internal/database/database.go
@@ -0,0 +1,39 @@
+package database
+
+import (
+	"context"
+	"fmt"
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgxpool"
+	"time"
+)
+
+func CreateConnectionPool(parentContext context.Context, databaseURL string) (*pgxpool.Pool, error) {
+	poolConfiguration, parseError := pgxpool.ParseConfig(databaseURL)
+
+	if parseError != nil {
+		return nil, fmt.Errorf("failed to parse database URL: %w", parseError)
+	}
+
+	poolConfiguration.MaxConns = 25
+	poolConfiguration.MinConns = 5
+	poolConfiguration.MaxConnLifetime = 30 * time.Minute
+	poolConfiguration.MaxConnIdleTime = 5 * time.Minute
+	poolConfiguration.HealthCheckPeriod = 30 * time.Second
+	poolConfiguration.ConnConfig.DefaultQueryExecMode = pgx.QueryExecModeExec
+	connectionPool, connectionError := pgxpool.NewWithConfig(parentContext, poolConfiguration)
+
+	if connectionError != nil {
+		return nil, fmt.Errorf("failed to create connection pool: %w", connectionError)
+	}
+
+	pingError := connectionPool.Ping(parentContext)
+
+	if pingError != nil {
+		connectionPool.Close()
+
+		return nil, fmt.Errorf("failed to ping database: %w", pingError)
+	}
+
+	return connectionPool, nil
+}