commit 26005cea081ef17a0e8df86d59e672e2403ad7da · bretton.dev/coves

+148

internal/db/migrations/005_create_communities_tables.sql

···

       1
       +
       -- +goose Up

     

       2
       +
       -- Enable pg_trgm extension for fuzzy text search

     

       3
       +
       CREATE EXTENSION IF NOT EXISTS pg_trgm;

     

       4
       +
       

     

       5
       +
       -- Communities table: stores community metadata indexed from firehose

     

       6
       +
       CREATE TABLE communities (

     

       7
       +
           id SERIAL PRIMARY KEY,

     

       8
       +
           did TEXT UNIQUE NOT NULL,                                       -- Community DID (did:coves:xxx or did:plc:xxx)

     

       9
       +
           handle TEXT UNIQUE NOT NULL,                                    -- Scoped handle (!gaming@coves.social)

     

       10
       +
           name TEXT NOT NULL,                                             -- Short community name (local part of handle)

     

       11
       +
           display_name TEXT,                                              -- Display name for UI

     

       12
       +
           description TEXT,                                               -- Community description

     

       13
       +
           description_facets JSONB,                                       -- Rich text annotations

     

       14
       +
           avatar_cid TEXT,                                                -- CID of avatar image blob

     

       15
       +
           banner_cid TEXT,                                                -- CID of banner image blob

     

       16
       +
       

     

       17
       +
           -- Ownership & hosting

     

       18
       +
           owner_did TEXT NOT NULL,                                        -- DID of community owner (instance in V1)

     

       19
       +
           created_by_did TEXT NOT NULL,                                   -- DID of user who created community

     

       20
       +
           hosted_by_did TEXT NOT NULL,                                    -- DID of hosting instance

     

       21
       +
       

     

       22
       +
           -- Visibility & federation

     

       23
       +
           visibility TEXT NOT NULL DEFAULT 'public' CHECK (visibility IN ('public', 'unlisted', 'private')),

     

       24
       +
           allow_external_discovery BOOLEAN NOT NULL DEFAULT true,

     

       25
       +
       

     

       26
       +
           -- Moderation

     

       27
       +
           moderation_type TEXT CHECK (moderation_type IN ('moderator', 'sortition')),

     

       28
       +
           content_warnings TEXT[],                                        -- Array of content warning types

     

       29
       +
       

     

       30
       +
           -- Statistics (cached counts)

     

       31
       +
           member_count INTEGER DEFAULT 0,

     

       32
       +
           subscriber_count INTEGER DEFAULT 0,

     

       33
       +
           post_count INTEGER DEFAULT 0,

     

       34
       +
       

     

       35
       +
           -- Federation metadata (for future cross-platform support)

     

       36
       +
           federated_from TEXT,                                            -- 'lemmy', 'coves', etc.

     

       37
       +
           federated_id TEXT,                                              -- Original ID on federated platform

     

       38
       +
       

     

       39
       +
           -- Timestamps

     

       40
       +
           created_at TIMESTAMP WITH TIME ZONE NOT NULL,

     

       41
       +
           updated_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,

     

       42
       +
       

     

       43
       +
           -- AT-Proto metadata

     

       44
       +
           record_uri TEXT,                                                -- AT-URI of the community profile record

     

       45
       +
           record_cid TEXT                                                 -- CID of the community profile record

     

       46
       +
       );

     

       47
       +
       

     

       48
       +
       -- Indexes for efficient queries

     

       49
       +
       CREATE INDEX idx_communities_handle ON communities(handle);

     

       50
       +
       CREATE INDEX idx_communities_visibility ON communities(visibility);

     

       51
       +
       CREATE INDEX idx_communities_hosted_by ON communities(hosted_by_did);

     

       52
       +
       CREATE INDEX idx_communities_created_by ON communities(created_by_did);

     

       53
       +
       CREATE INDEX idx_communities_created_at ON communities(created_at);

     

       54
       +
       CREATE INDEX idx_communities_name_trgm ON communities USING gin(name gin_trgm_ops);  -- For fuzzy search

     

       55
       +
       CREATE INDEX idx_communities_description_trgm ON communities USING gin(description gin_trgm_ops);

     

       56
       +
       

     

       57
       +
       -- Subscriptions table: lightweight feed following

     

       58
       +
       CREATE TABLE community_subscriptions (

     

       59
       +
           id SERIAL PRIMARY KEY,

     

       60
       +
           user_did TEXT NOT NULL,

     

       61
       +
           community_did TEXT NOT NULL REFERENCES communities(did) ON DELETE CASCADE,

     

       62
       +
           subscribed_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,

     

       63
       +
       

     

       64
       +
           -- AT-Proto metadata (subscription is a record in user's repo)

     

       65
       +
           record_uri TEXT,                                                -- AT-URI of the subscription record

     

       66
       +
           record_cid TEXT,                                                -- CID of the subscription record

     

       67
       +
       

     

       68
       +
           UNIQUE(user_did, community_did)

     

       69
       +
       );

     

       70
       +
       

     

       71
       +
       -- Indexes for subscription queries

     

       72
       +
       CREATE INDEX idx_subscriptions_user ON community_subscriptions(user_did);

     

       73
       +
       CREATE INDEX idx_subscriptions_community ON community_subscriptions(community_did);

     

       74
       +
       CREATE INDEX idx_subscriptions_user_community ON community_subscriptions(user_did, community_did); -- Composite index for GetSubscription

     

       75
       +
       CREATE INDEX idx_subscriptions_subscribed_at ON community_subscriptions(subscribed_at);

     

       76
       +
       

     

       77
       +
       -- Memberships table: active participation & reputation tracking

     

       78
       +
       CREATE TABLE community_memberships (

     

       79
       +
           id SERIAL PRIMARY KEY,

     

       80
       +
           user_did TEXT NOT NULL,

     

       81
       +
           community_did TEXT NOT NULL REFERENCES communities(did) ON DELETE CASCADE,

     

       82
       +
       

     

       83
       +
           -- Reputation system

     

       84
       +
           reputation_score INTEGER DEFAULT 0,                            -- Gained through participation

     

       85
       +
           contribution_count INTEGER DEFAULT 0,                          -- Total posts + comments + actions

     

       86
       +
       

     

       87
       +
           -- Activity tracking

     

       88
       +
           joined_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,

     

       89
       +
           last_active_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,

     

       90
       +
       

     

       91
       +
           -- Moderation status

     

       92
       +
           is_banned BOOLEAN DEFAULT false,

     

       93
       +
           is_moderator BOOLEAN DEFAULT false,

     

       94
       +
       

     

       95
       +
           UNIQUE(user_did, community_did)

     

       96
       +
       );

     

       97
       +
       

     

       98
       +
       -- Indexes for membership queries

     

       99
       +
       CREATE INDEX idx_memberships_user ON community_memberships(user_did);

     

       100
       +
       CREATE INDEX idx_memberships_community ON community_memberships(community_did);

     

       101
       +
       CREATE INDEX idx_memberships_reputation ON community_memberships(community_did, reputation_score DESC);

     

       102
       +
       CREATE INDEX idx_memberships_last_active ON community_memberships(last_active_at);

     

       103
       +
       

     

       104
       +
       -- Community moderation actions table (V2 feature, schema prepared)

     

       105
       +
       CREATE TABLE community_moderation (

     

       106
       +
           id SERIAL PRIMARY KEY,

     

       107
       +
           community_did TEXT NOT NULL REFERENCES communities(did) ON DELETE CASCADE,

     

       108
       +
           action TEXT NOT NULL CHECK (action IN ('delist', 'quarantine', 'remove')),

     

       109
       +
           reason TEXT,

     

       110
       +
           instance_did TEXT NOT NULL,                                    -- Which instance took this action

     

       111
       +
           broadcast BOOLEAN DEFAULT false,                               -- Share moderation signal with network?

     

       112
       +
           created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,

     

       113
       +
           expires_at TIMESTAMP WITH TIME ZONE                            -- Optional: temporary moderation

     

       114
       +
       );

     

       115
       +
       

     

       116
       +
       -- Indexes for moderation queries

     

       117
       +
       CREATE INDEX idx_moderation_community ON community_moderation(community_did);

     

       118
       +
       CREATE INDEX idx_moderation_instance ON community_moderation(instance_did);

     

       119
       +
       CREATE INDEX idx_moderation_action ON community_moderation(action);

     

       120
       +
       CREATE INDEX idx_moderation_created_at ON community_moderation(created_at);

     

       121
       +
       

     

       122
       +
       -- +goose Down

     

       123
       +
       DROP INDEX IF EXISTS idx_moderation_created_at;

     

       124
       +
       DROP INDEX IF EXISTS idx_moderation_action;

     

       125
       +
       DROP INDEX IF EXISTS idx_moderation_instance;

     

       126
       +
       DROP INDEX IF EXISTS idx_moderation_community;

     

       127
       +
       DROP TABLE IF EXISTS community_moderation;

     

       128
       +
       

     

       129
       +
       DROP INDEX IF EXISTS idx_memberships_last_active;

     

       130
       +
       DROP INDEX IF EXISTS idx_memberships_reputation;

     

       131
       +
       DROP INDEX IF EXISTS idx_memberships_community;

     

       132
       +
       DROP INDEX IF EXISTS idx_memberships_user;

     

       133
       +
       DROP TABLE IF EXISTS community_memberships;

     

       134
       +
       

     

       135
       +
       DROP INDEX IF EXISTS idx_subscriptions_subscribed_at;

     

       136
       +
       DROP INDEX IF EXISTS idx_subscriptions_user_community;

     

       137
       +
       DROP INDEX IF EXISTS idx_subscriptions_community;

     

       138
       +
       DROP INDEX IF EXISTS idx_subscriptions_user;

     

       139
       +
       DROP TABLE IF EXISTS community_subscriptions;

     

       140
       +
       

     

       141
       +
       DROP INDEX IF EXISTS idx_communities_description_trgm;

     

       142
       +
       DROP INDEX IF EXISTS idx_communities_name_trgm;

     

       143
       +
       DROP INDEX IF EXISTS idx_communities_created_at;

     

       144
       +
       DROP INDEX IF EXISTS idx_communities_created_by;

     

       145
       +
       DROP INDEX IF EXISTS idx_communities_hosted_by;

     

       146
       +
       DROP INDEX IF EXISTS idx_communities_visibility;

     

       147
       +
       DROP INDEX IF EXISTS idx_communities_handle;

     

       148
       +
       DROP TABLE IF EXISTS communities;

+495

internal/db/postgres/community_repo.go

···

       1
       +
       package postgres

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"context"

     

       5
       +
       	"database/sql"

     

       6
       +
       	"fmt"

     

       7
       +
       	"strings"

     

       8
       +
       

     

       9
       +
       	"Coves/internal/core/communities"

     

       10
       +
       	"github.com/lib/pq"

     

       11
       +
       )

     

       12
       +
       

     

       13
       +
       type postgresCommunityRepo struct {

     

       14
       +
       	db *sql.DB

     

       15
       +
       }

     

       16
       +
       

     

       17
       +
       // NewCommunityRepository creates a new PostgreSQL community repository

     

       18
       +
       func NewCommunityRepository(db *sql.DB) communities.Repository {

     

       19
       +
       	return &postgresCommunityRepo{db: db}

     

       20
       +
       }

     

       21
       +
       

     

       22
       +
       // Create inserts a new community into the communities table

     

       23
       +
       func (r *postgresCommunityRepo) Create(ctx context.Context, community *communities.Community) (*communities.Community, error) {

     

       24
       +
       	query := `

     

       25
       +
       		INSERT INTO communities (

     

       26
       +
       			did, handle, name, display_name, description, description_facets,

     

       27
       +
       			avatar_cid, banner_cid, owner_did, created_by_did, hosted_by_did,

     

       28
       +
       			visibility, allow_external_discovery, moderation_type, content_warnings,

     

       29
       +
       			member_count, subscriber_count, post_count,

     

       30
       +
       			federated_from, federated_id, created_at, updated_at,

     

       31
       +
       			record_uri, record_cid

     

       32
       +
       		) VALUES (

     

       33
       +
       			$1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15,

     

       34
       +
       			$16, $17, $18, $19, $20, $21, $22, $23, $24

     

       35
       +
       		)

     

       36
       +
       		RETURNING id, created_at, updated_at`

     

       37
       +
       

     

       38
       +
       	// Handle JSONB field - use sql.NullString with valid JSON or NULL

     

       39
       +
       	var descFacets interface{}

     

       40
       +
       	if community.DescriptionFacets != nil && len(community.DescriptionFacets) > 0 {

     

       41
       +
       		descFacets = community.DescriptionFacets

     

       42
       +
       	} else {

     

       43
       +
       		descFacets = nil

     

       44
       +
       	}

     

       45
       +
       

     

       46
       +
       	err := r.db.QueryRowContext(ctx, query,

     

       47
       +
       		community.DID,

     

       48
       +
       		community.Handle,

     

       49
       +
       		community.Name,

     

       50
       +
       		nullString(community.DisplayName),

     

       51
       +
       		nullString(community.Description),

     

       52
       +
       		descFacets,

     

       53
       +
       		nullString(community.AvatarCID),

     

       54
       +
       		nullString(community.BannerCID),

     

       55
       +
       		community.OwnerDID,

     

       56
       +
       		community.CreatedByDID,

     

       57
       +
       		community.HostedByDID,

     

       58
       +
       		community.Visibility,

     

       59
       +
       		community.AllowExternalDiscovery,

     

       60
       +
       		nullString(community.ModerationType),

     

       61
       +
       		pq.Array(community.ContentWarnings),

     

       62
       +
       		community.MemberCount,

     

       63
       +
       		community.SubscriberCount,

     

       64
       +
       		community.PostCount,

     

       65
       +
       		nullString(community.FederatedFrom),

     

       66
       +
       		nullString(community.FederatedID),

     

       67
       +
       		community.CreatedAt,

     

       68
       +
       		community.UpdatedAt,

     

       69
       +
       		nullString(community.RecordURI),

     

       70
       +
       		nullString(community.RecordCID),

     

       71
       +
       	).Scan(&community.ID, &community.CreatedAt, &community.UpdatedAt)

     

       72
       +
       

     

       73
       +
       	if err != nil {

     

       74
       +
       		// Check for unique constraint violations

     

       75
       +
       		if strings.Contains(err.Error(), "duplicate key") {

     

       76
       +
       			if strings.Contains(err.Error(), "communities_did_key") {

     

       77
       +
       				return nil, communities.ErrCommunityAlreadyExists

     

       78
       +
       			}

     

       79
       +
       			if strings.Contains(err.Error(), "communities_handle_key") {

     

       80
       +
       				return nil, communities.ErrHandleTaken

     

       81
       +
       			}

     

       82
       +
       		}

     

       83
       +
       		return nil, fmt.Errorf("failed to create community: %w", err)

     

       84
       +
       	}

     

       85
       +
       

     

       86
       +
       	return community, nil

     

       87
       +
       }

     

       88
       +
       

     

       89
       +
       // GetByDID retrieves a community by its DID

     

       90
       +
       func (r *postgresCommunityRepo) GetByDID(ctx context.Context, did string) (*communities.Community, error) {

     

       91
       +
       	community := &communities.Community{}

     

       92
       +
       	query := `

     

       93
       +
       		SELECT id, did, handle, name, display_name, description, description_facets,

     

       94
       +
       			avatar_cid, banner_cid, owner_did, created_by_did, hosted_by_did,

     

       95
       +
       			visibility, allow_external_discovery, moderation_type, content_warnings,

     

       96
       +
       			member_count, subscriber_count, post_count,

     

       97
       +
       			federated_from, federated_id, created_at, updated_at,

     

       98
       +
       			record_uri, record_cid

     

       99
       +
       		FROM communities

     

       100
       +
       		WHERE did = $1`

     

       101
       +
       

     

       102
       +
       	var displayName, description, avatarCID, bannerCID, moderationType sql.NullString

     

       103
       +
       	var federatedFrom, federatedID, recordURI, recordCID sql.NullString

     

       104
       +
       	var descFacets []byte

     

       105
       +
       	var contentWarnings []string

     

       106
       +
       

     

       107
       +
       	err := r.db.QueryRowContext(ctx, query, did).Scan(

     

       108
       +
       		&community.ID, &community.DID, &community.Handle, &community.Name,

     

       109
       +
       		&displayName, &description, &descFacets,

     

       110
       +
       		&avatarCID, &bannerCID,

     

       111
       +
       		&community.OwnerDID, &community.CreatedByDID, &community.HostedByDID,

     

       112
       +
       		&community.Visibility, &community.AllowExternalDiscovery,

     

       113
       +
       		&moderationType, pq.Array(&contentWarnings),

     

       114
       +
       		&community.MemberCount, &community.SubscriberCount, &community.PostCount,

     

       115
       +
       		&federatedFrom, &federatedID,

     

       116
       +
       		&community.CreatedAt, &community.UpdatedAt,

     

       117
       +
       		&recordURI, &recordCID,

     

       118
       +
       	)

     

       119
       +
       

     

       120
       +
       	if err == sql.ErrNoRows {

     

       121
       +
       		return nil, communities.ErrCommunityNotFound

     

       122
       +
       	}

     

       123
       +
       	if err != nil {

     

       124
       +
       		return nil, fmt.Errorf("failed to get community by DID: %w", err)

     

       125
       +
       	}

     

       126
       +
       

     

       127
       +
       	// Map nullable fields

     

       128
       +
       	community.DisplayName = displayName.String

     

       129
       +
       	community.Description = description.String

     

       130
       +
       	community.AvatarCID = avatarCID.String

     

       131
       +
       	community.BannerCID = bannerCID.String

     

       132
       +
       	community.ModerationType = moderationType.String

     

       133
       +
       	community.ContentWarnings = contentWarnings

     

       134
       +
       	community.FederatedFrom = federatedFrom.String

     

       135
       +
       	community.FederatedID = federatedID.String

     

       136
       +
       	community.RecordURI = recordURI.String

     

       137
       +
       	community.RecordCID = recordCID.String

     

       138
       +
       	if descFacets != nil {

     

       139
       +
       		community.DescriptionFacets = descFacets

     

       140
       +
       	}

     

       141
       +
       

     

       142
       +
       	return community, nil

     

       143
       +
       }

     

       144
       +
       

     

       145
       +
       // GetByHandle retrieves a community by its scoped handle

     

       146
       +
       func (r *postgresCommunityRepo) GetByHandle(ctx context.Context, handle string) (*communities.Community, error) {

     

       147
       +
       	community := &communities.Community{}

     

       148
       +
       	query := `

     

       149
       +
       		SELECT id, did, handle, name, display_name, description, description_facets,

     

       150
       +
       			avatar_cid, banner_cid, owner_did, created_by_did, hosted_by_did,

     

       151
       +
       			visibility, allow_external_discovery, moderation_type, content_warnings,

     

       152
       +
       			member_count, subscriber_count, post_count,

     

       153
       +
       			federated_from, federated_id, created_at, updated_at,

     

       154
       +
       			record_uri, record_cid

     

       155
       +
       		FROM communities

     

       156
       +
       		WHERE handle = $1`

     

       157
       +
       

     

       158
       +
       	var displayName, description, avatarCID, bannerCID, moderationType sql.NullString

     

       159
       +
       	var federatedFrom, federatedID, recordURI, recordCID sql.NullString

     

       160
       +
       	var descFacets []byte

     

       161
       +
       	var contentWarnings []string

     

       162
       +
       

     

       163
       +
       	err := r.db.QueryRowContext(ctx, query, handle).Scan(

     

       164
       +
       		&community.ID, &community.DID, &community.Handle, &community.Name,

     

       165
       +
       		&displayName, &description, &descFacets,

     

       166
       +
       		&avatarCID, &bannerCID,

     

       167
       +
       		&community.OwnerDID, &community.CreatedByDID, &community.HostedByDID,

     

       168
       +
       		&community.Visibility, &community.AllowExternalDiscovery,

     

       169
       +
       		&moderationType, pq.Array(&contentWarnings),

     

       170
       +
       		&community.MemberCount, &community.SubscriberCount, &community.PostCount,

     

       171
       +
       		&federatedFrom, &federatedID,

     

       172
       +
       		&community.CreatedAt, &community.UpdatedAt,

     

       173
       +
       		&recordURI, &recordCID,

     

       174
       +
       	)

     

       175
       +
       

     

       176
       +
       	if err == sql.ErrNoRows {

     

       177
       +
       		return nil, communities.ErrCommunityNotFound

     

       178
       +
       	}

     

       179
       +
       	if err != nil {

     

       180
       +
       		return nil, fmt.Errorf("failed to get community by handle: %w", err)

     

       181
       +
       	}

     

       182
       +
       

     

       183
       +
       	// Map nullable fields

     

       184
       +
       	community.DisplayName = displayName.String

     

       185
       +
       	community.Description = description.String

     

       186
       +
       	community.AvatarCID = avatarCID.String

     

       187
       +
       	community.BannerCID = bannerCID.String

     

       188
       +
       	community.ModerationType = moderationType.String

     

       189
       +
       	community.ContentWarnings = contentWarnings

     

       190
       +
       	community.FederatedFrom = federatedFrom.String

     

       191
       +
       	community.FederatedID = federatedID.String

     

       192
       +
       	community.RecordURI = recordURI.String

     

       193
       +
       	community.RecordCID = recordCID.String

     

       194
       +
       	if descFacets != nil {

     

       195
       +
       		community.DescriptionFacets = descFacets

     

       196
       +
       	}

     

       197
       +
       

     

       198
       +
       	return community, nil

     

       199
       +
       }

     

       200
       +
       

     

       201
       +
       // Update modifies an existing community's metadata

     

       202
       +
       func (r *postgresCommunityRepo) Update(ctx context.Context, community *communities.Community) (*communities.Community, error) {

     

       203
       +
       	query := `

     

       204
       +
       		UPDATE communities

     

       205
       +
       		SET display_name = $2, description = $3, description_facets = $4,

     

       206
       +
       			avatar_cid = $5, banner_cid = $6,

     

       207
       +
       			visibility = $7, allow_external_discovery = $8,

     

       208
       +
       			moderation_type = $9, content_warnings = $10,

     

       209
       +
       			updated_at = NOW(),

     

       210
       +
       			record_uri = $11, record_cid = $12

     

       211
       +
       		WHERE did = $1

     

       212
       +
       		RETURNING updated_at`

     

       213
       +
       

     

       214
       +
       	// Handle JSONB field - use sql.NullString with valid JSON or NULL

     

       215
       +
       	var descFacets interface{}

     

       216
       +
       	if community.DescriptionFacets != nil && len(community.DescriptionFacets) > 0 {

     

       217
       +
       		descFacets = community.DescriptionFacets

     

       218
       +
       	} else {

     

       219
       +
       		descFacets = nil

     

       220
       +
       	}

     

       221
       +
       

     

       222
       +
       	err := r.db.QueryRowContext(ctx, query,

     

       223
       +
       		community.DID,

     

       224
       +
       		nullString(community.DisplayName),

     

       225
       +
       		nullString(community.Description),

     

       226
       +
       		descFacets,

     

       227
       +
       		nullString(community.AvatarCID),

     

       228
       +
       		nullString(community.BannerCID),

     

       229
       +
       		community.Visibility,

     

       230
       +
       		community.AllowExternalDiscovery,

     

       231
       +
       		nullString(community.ModerationType),

     

       232
       +
       		pq.Array(community.ContentWarnings),

     

       233
       +
       		nullString(community.RecordURI),

     

       234
       +
       		nullString(community.RecordCID),

     

       235
       +
       	).Scan(&community.UpdatedAt)

     

       236
       +
       

     

       237
       +
       	if err == sql.ErrNoRows {

     

       238
       +
       		return nil, communities.ErrCommunityNotFound

     

       239
       +
       	}

     

       240
       +
       	if err != nil {

     

       241
       +
       		return nil, fmt.Errorf("failed to update community: %w", err)

     

       242
       +
       	}

     

       243
       +
       

     

       244
       +
       	return community, nil

     

       245
       +
       }

     

       246
       +
       

     

       247
       +
       // Delete removes a community from the database

     

       248
       +
       func (r *postgresCommunityRepo) Delete(ctx context.Context, did string) error {

     

       249
       +
       	query := `DELETE FROM communities WHERE did = $1`

     

       250
       +
       

     

       251
       +
       	result, err := r.db.ExecContext(ctx, query, did)

     

       252
       +
       	if err != nil {

     

       253
       +
       		return fmt.Errorf("failed to delete community: %w", err)

     

       254
       +
       	}

     

       255
       +
       

     

       256
       +
       	rowsAffected, err := result.RowsAffected()

     

       257
       +
       	if err != nil {

     

       258
       +
       		return fmt.Errorf("failed to check delete result: %w", err)

     

       259
       +
       	}

     

       260
       +
       

     

       261
       +
       	if rowsAffected == 0 {

     

       262
       +
       		return communities.ErrCommunityNotFound

     

       263
       +
       	}

     

       264
       +
       

     

       265
       +
       	return nil

     

       266
       +
       }

     

       267
       +
       

     

       268
       +
       // List retrieves communities with filtering and pagination

     

       269
       +
       func (r *postgresCommunityRepo) List(ctx context.Context, req communities.ListCommunitiesRequest) ([]*communities.Community, int, error) {

     

       270
       +
       	// Build query with filters

     

       271
       +
       	whereClauses := []string{}

     

       272
       +
       	args := []interface{}{}

     

       273
       +
       	argCount := 1

     

       274
       +
       

     

       275
       +
       	if req.Visibility != "" {

     

       276
       +
       		whereClauses = append(whereClauses, fmt.Sprintf("visibility = $%d", argCount))

     

       277
       +
       		args = append(args, req.Visibility)

     

       278
       +
       		argCount++

     

       279
       +
       	}

     

       280
       +
       

     

       281
       +
       	if req.HostedBy != "" {

     

       282
       +
       		whereClauses = append(whereClauses, fmt.Sprintf("hosted_by_did = $%d", argCount))

     

       283
       +
       		args = append(args, req.HostedBy)

     

       284
       +
       		argCount++

     

       285
       +
       	}

     

       286
       +
       

     

       287
       +
       	whereClause := ""

     

       288
       +
       	if len(whereClauses) > 0 {

     

       289
       +
       		whereClause = "WHERE " + strings.Join(whereClauses, " AND ")

     

       290
       +
       	}

     

       291
       +
       

     

       292
       +
       	// Get total count

     

       293
       +
       	countQuery := fmt.Sprintf("SELECT COUNT(*) FROM communities %s", whereClause)

     

       294
       +
       	var totalCount int

     

       295
       +
       	err := r.db.QueryRowContext(ctx, countQuery, args...).Scan(&totalCount)

     

       296
       +
       	if err != nil {

     

       297
       +
       		return nil, 0, fmt.Errorf("failed to count communities: %w", err)

     

       298
       +
       	}

     

       299
       +
       

     

       300
       +
       	// Build sort clause

     

       301
       +
       	sortColumn := "created_at"

     

       302
       +
       	if req.SortBy != "" {

     

       303
       +
       		switch req.SortBy {

     

       304
       +
       		case "member_count", "subscriber_count", "post_count", "created_at":

     

       305
       +
       			sortColumn = req.SortBy

     

       306
       +
       		}

     

       307
       +
       	}

     

       308
       +
       

     

       309
       +
       	sortOrder := "DESC"

     

       310
       +
       	if strings.ToUpper(req.SortOrder) == "ASC" {

     

       311
       +
       		sortOrder = "ASC"

     

       312
       +
       	}

     

       313
       +
       

     

       314
       +
       	// Get communities with pagination

     

       315
       +
       	query := fmt.Sprintf(`

     

       316
       +
       		SELECT id, did, handle, name, display_name, description, description_facets,

     

       317
       +
       			avatar_cid, banner_cid, owner_did, created_by_did, hosted_by_did,

     

       318
       +
       			visibility, allow_external_discovery, moderation_type, content_warnings,

     

       319
       +
       			member_count, subscriber_count, post_count,

     

       320
       +
       			federated_from, federated_id, created_at, updated_at,

     

       321
       +
       			record_uri, record_cid

     

       322
       +
       		FROM communities

     

       323
       +
       		%s

     

       324
       +
       		ORDER BY %s %s

     

       325
       +
       		LIMIT $%d OFFSET $%d`,

     

       326
       +
       		whereClause, sortColumn, sortOrder, argCount, argCount+1)

     

       327
       +
       

     

       328
       +
       	args = append(args, req.Limit, req.Offset)

     

       329
       +
       

     

       330
       +
       	rows, err := r.db.QueryContext(ctx, query, args...)

     

       331
       +
       	if err != nil {

     

       332
       +
       		return nil, 0, fmt.Errorf("failed to list communities: %w", err)

     

       333
       +
       	}

     

       334
       +
       	defer rows.Close()

     

       335
       +
       

     

       336
       +
       	result := []*communities.Community{}

     

       337
       +
       	for rows.Next() {

     

       338
       +
       		community := &communities.Community{}

     

       339
       +
       		var displayName, description, avatarCID, bannerCID, moderationType sql.NullString

     

       340
       +
       		var federatedFrom, federatedID, recordURI, recordCID sql.NullString

     

       341
       +
       		var descFacets []byte

     

       342
       +
       		var contentWarnings []string

     

       343
       +
       

     

       344
       +
       		err := rows.Scan(

     

       345
       +
       			&community.ID, &community.DID, &community.Handle, &community.Name,

     

       346
       +
       			&displayName, &description, &descFacets,

     

       347
       +
       			&avatarCID, &bannerCID,

     

       348
       +
       			&community.OwnerDID, &community.CreatedByDID, &community.HostedByDID,

     

       349
       +
       			&community.Visibility, &community.AllowExternalDiscovery,

     

       350
       +
       			&moderationType, pq.Array(&contentWarnings),

     

       351
       +
       			&community.MemberCount, &community.SubscriberCount, &community.PostCount,

     

       352
       +
       			&federatedFrom, &federatedID,

     

       353
       +
       			&community.CreatedAt, &community.UpdatedAt,

     

       354
       +
       			&recordURI, &recordCID,

     

       355
       +
       		)

     

       356
       +
       		if err != nil {

     

       357
       +
       			return nil, 0, fmt.Errorf("failed to scan community: %w", err)

     

       358
       +
       		}

     

       359
       +
       

     

       360
       +
       		// Map nullable fields

     

       361
       +
       		community.DisplayName = displayName.String

     

       362
       +
       		community.Description = description.String

     

       363
       +
       		community.AvatarCID = avatarCID.String

     

       364
       +
       		community.BannerCID = bannerCID.String

     

       365
       +
       		community.ModerationType = moderationType.String

     

       366
       +
       		community.ContentWarnings = contentWarnings

     

       367
       +
       		community.FederatedFrom = federatedFrom.String

     

       368
       +
       		community.FederatedID = federatedID.String

     

       369
       +
       		community.RecordURI = recordURI.String

     

       370
       +
       		community.RecordCID = recordCID.String

     

       371
       +
       		if descFacets != nil {

     

       372
       +
       			community.DescriptionFacets = descFacets

     

       373
       +
       		}

     

       374
       +
       

     

       375
       +
       		result = append(result, community)

     

       376
       +
       	}

     

       377
       +
       

     

       378
       +
       	if err = rows.Err(); err != nil {

     

       379
       +
       		return nil, 0, fmt.Errorf("error iterating communities: %w", err)

     

       380
       +
       	}

     

       381
       +
       

     

       382
       +
       	return result, totalCount, nil

     

       383
       +
       }

     

       384
       +
       

     

       385
       +
       // Search searches communities by name/description using fuzzy matching

     

       386
       +
       func (r *postgresCommunityRepo) Search(ctx context.Context, req communities.SearchCommunitiesRequest) ([]*communities.Community, int, error) {

     

       387
       +
       	// Build query with fuzzy search and visibility filter

     

       388
       +
       	whereClauses := []string{

     

       389
       +
       		"(name ILIKE '%' || $1 || '%' OR description ILIKE '%' || $1 || '%')",

     

       390
       +
       	}

     

       391
       +
       	args := []interface{}{req.Query}

     

       392
       +
       	argCount := 2

     

       393
       +
       

     

       394
       +
       	if req.Visibility != "" {

     

       395
       +
       		whereClauses = append(whereClauses, fmt.Sprintf("visibility = $%d", argCount))

     

       396
       +
       		args = append(args, req.Visibility)

     

       397
       +
       		argCount++

     

       398
       +
       	}

     

       399
       +
       

     

       400
       +
       	whereClause := "WHERE " + strings.Join(whereClauses, " AND ")

     

       401
       +
       

     

       402
       +
       	// Get total count

     

       403
       +
       	countQuery := fmt.Sprintf("SELECT COUNT(*) FROM communities %s", whereClause)

     

       404
       +
       	var totalCount int

     

       405
       +
       	err := r.db.QueryRowContext(ctx, countQuery, args...).Scan(&totalCount)

     

       406
       +
       	if err != nil {

     

       407
       +
       		return nil, 0, fmt.Errorf("failed to count search results: %w", err)

     

       408
       +
       	}

     

       409
       +
       

     

       410
       +
       	// Search with relevance ranking using pg_trgm similarity

     

       411
       +
       	// Filter out results with very low relevance (< 0.2) to avoid noise

     

       412
       +
       	query := fmt.Sprintf(`

     

       413
       +
       		SELECT id, did, handle, name, display_name, description, description_facets,

     

       414
       +
       			avatar_cid, banner_cid, owner_did, created_by_did, hosted_by_did,

     

       415
       +
       			visibility, allow_external_discovery, moderation_type, content_warnings,

     

       416
       +
       			member_count, subscriber_count, post_count,

     

       417
       +
       			federated_from, federated_id, created_at, updated_at,

     

       418
       +
       			record_uri, record_cid,

     

       419
       +
       			similarity(name, $1) + similarity(COALESCE(description, ''), $1) as relevance

     

       420
       +
       		FROM communities

     

       421
       +
       		%s AND (similarity(name, $1) + similarity(COALESCE(description, ''), $1)) > 0.2

     

       422
       +
       		ORDER BY relevance DESC, member_count DESC

     

       423
       +
       		LIMIT $%d OFFSET $%d`,

     

       424
       +
       		whereClause, argCount, argCount+1)

     

       425
       +
       

     

       426
       +
       	args = append(args, req.Limit, req.Offset)

     

       427
       +
       

     

       428
       +
       	rows, err := r.db.QueryContext(ctx, query, args...)

     

       429
       +
       	if err != nil {

     

       430
       +
       		return nil, 0, fmt.Errorf("failed to search communities: %w", err)

     

       431
       +
       	}

     

       432
       +
       	defer rows.Close()

     

       433
       +
       

     

       434
       +
       	result := []*communities.Community{}

     

       435
       +
       	for rows.Next() {

     

       436
       +
       		community := &communities.Community{}

     

       437
       +
       		var displayName, description, avatarCID, bannerCID, moderationType sql.NullString

     

       438
       +
       		var federatedFrom, federatedID, recordURI, recordCID sql.NullString

     

       439
       +
       		var descFacets []byte

     

       440
       +
       		var contentWarnings []string

     

       441
       +
       		var relevance float64

     

       442
       +
       

     

       443
       +
       		err := rows.Scan(

     

       444
       +
       			&community.ID, &community.DID, &community.Handle, &community.Name,

     

       445
       +
       			&displayName, &description, &descFacets,

     

       446
       +
       			&avatarCID, &bannerCID,

     

       447
       +
       			&community.OwnerDID, &community.CreatedByDID, &community.HostedByDID,

     

       448
       +
       			&community.Visibility, &community.AllowExternalDiscovery,

     

       449
       +
       			&moderationType, pq.Array(&contentWarnings),

     

       450
       +
       			&community.MemberCount, &community.SubscriberCount, &community.PostCount,

     

       451
       +
       			&federatedFrom, &federatedID,

     

       452
       +
       			&community.CreatedAt, &community.UpdatedAt,

     

       453
       +
       			&recordURI, &recordCID,

     

       454
       +
       			&relevance,

     

       455
       +
       		)

     

       456
       +
       		if err != nil {

     

       457
       +
       			return nil, 0, fmt.Errorf("failed to scan community: %w", err)

     

       458
       +
       		}

     

       459
       +
       

     

       460
       +
       		// Map nullable fields

     

       461
       +
       		community.DisplayName = displayName.String

     

       462
       +
       		community.Description = description.String

     

       463
       +
       		community.AvatarCID = avatarCID.String

     

       464
       +
       		community.BannerCID = bannerCID.String

     

       465
       +
       		community.ModerationType = moderationType.String

     

       466
       +
       		community.ContentWarnings = contentWarnings

     

       467
       +
       		community.FederatedFrom = federatedFrom.String

     

       468
       +
       		community.FederatedID = federatedID.String

     

       469
       +
       		community.RecordURI = recordURI.String

     

       470
       +
       		community.RecordCID = recordCID.String

     

       471
       +
       		if descFacets != nil {

     

       472
       +
       			community.DescriptionFacets = descFacets

     

       473
       +
       		}

     

       474
       +
       

     

       475
       +
       		result = append(result, community)

     

       476
       +
       	}

     

       477
       +
       

     

       478
       +
       	if err = rows.Err(); err != nil {

     

       479
       +
       		return nil, 0, fmt.Errorf("error iterating search results: %w", err)

     

       480
       +
       	}

     

       481
       +
       

     

       482
       +
       	return result, totalCount, nil

     

       483
       +
       }

     

       484
       +
       

     

       485
       +
       // Helper functions

     

       486
       +
       func nullString(s string) sql.NullString {

     

       487
       +
       	return sql.NullString{String: s, Valid: s != ""}

     

       488
       +
       }

     

       489
       +
       

     

       490
       +
       func nullBytes(b []byte) []byte {

     

       491
       +
       	if b == nil || len(b) == 0 {

     

       492
       +
       		return nil

     

       493
       +
       	}

     

       494
       +
       	return b

     

       495
       +
       }

+272

internal/db/postgres/community_repo_memberships.go

···

       1
       +
       package postgres

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"context"

     

       5
       +
       	"database/sql"

     

       6
       +
       	"fmt"

     

       7
       +
       	"strings"

     

       8
       +
       

     

       9
       +
       	"Coves/internal/core/communities"

     

       10
       +
       )

     

       11
       +
       

     

       12
       +
       // CreateMembership creates a new membership record

     

       13
       +
       func (r *postgresCommunityRepo) CreateMembership(ctx context.Context, membership *communities.Membership) (*communities.Membership, error) {

     

       14
       +
       	query := `

     

       15
       +
       		INSERT INTO community_memberships (

     

       16
       +
       			user_did, community_did, reputation_score, contribution_count,

     

       17
       +
       			joined_at, last_active_at, is_banned, is_moderator

     

       18
       +
       		)

     

       19
       +
       		VALUES ($1, $2, $3, $4, $5, $6, $7, $8)

     

       20
       +
       		RETURNING id, joined_at, last_active_at`

     

       21
       +
       

     

       22
       +
       	err := r.db.QueryRowContext(ctx, query,

     

       23
       +
       		membership.UserDID,

     

       24
       +
       		membership.CommunityDID,

     

       25
       +
       		membership.ReputationScore,

     

       26
       +
       		membership.ContributionCount,

     

       27
       +
       		membership.JoinedAt,

     

       28
       +
       		membership.LastActiveAt,

     

       29
       +
       		membership.IsBanned,

     

       30
       +
       		membership.IsModerator,

     

       31
       +
       	).Scan(&membership.ID, &membership.JoinedAt, &membership.LastActiveAt)

     

       32
       +
       

     

       33
       +
       	if err != nil {

     

       34
       +
       		if strings.Contains(err.Error(), "duplicate key") {

     

       35
       +
       			return nil, fmt.Errorf("membership already exists")

     

       36
       +
       		}

     

       37
       +
       		if strings.Contains(err.Error(), "foreign key") {

     

       38
       +
       			return nil, communities.ErrCommunityNotFound

     

       39
       +
       		}

     

       40
       +
       		return nil, fmt.Errorf("failed to create membership: %w", err)

     

       41
       +
       	}

     

       42
       +
       

     

       43
       +
       	return membership, nil

     

       44
       +
       }

     

       45
       +
       

     

       46
       +
       // GetMembership retrieves a specific membership

     

       47
       +
       func (r *postgresCommunityRepo) GetMembership(ctx context.Context, userDID, communityDID string) (*communities.Membership, error) {

     

       48
       +
       	membership := &communities.Membership{}

     

       49
       +
       	query := `

     

       50
       +
       		SELECT id, user_did, community_did, reputation_score, contribution_count,

     

       51
       +
       			joined_at, last_active_at, is_banned, is_moderator

     

       52
       +
       		FROM community_memberships

     

       53
       +
       		WHERE user_did = $1 AND community_did = $2`

     

       54
       +
       

     

       55
       +
       	err := r.db.QueryRowContext(ctx, query, userDID, communityDID).Scan(

     

       56
       +
       		&membership.ID,

     

       57
       +
       		&membership.UserDID,

     

       58
       +
       		&membership.CommunityDID,

     

       59
       +
       		&membership.ReputationScore,

     

       60
       +
       		&membership.ContributionCount,

     

       61
       +
       		&membership.JoinedAt,

     

       62
       +
       		&membership.LastActiveAt,

     

       63
       +
       		&membership.IsBanned,

     

       64
       +
       		&membership.IsModerator,

     

       65
       +
       	)

     

       66
       +
       

     

       67
       +
       	if err == sql.ErrNoRows {

     

       68
       +
       		return nil, communities.ErrMembershipNotFound

     

       69
       +
       	}

     

       70
       +
       	if err != nil {

     

       71
       +
       		return nil, fmt.Errorf("failed to get membership: %w", err)

     

       72
       +
       	}

     

       73
       +
       

     

       74
       +
       	return membership, nil

     

       75
       +
       }

     

       76
       +
       

     

       77
       +
       // UpdateMembership updates an existing membership

     

       78
       +
       func (r *postgresCommunityRepo) UpdateMembership(ctx context.Context, membership *communities.Membership) (*communities.Membership, error) {

     

       79
       +
       	query := `

     

       80
       +
       		UPDATE community_memberships

     

       81
       +
       		SET reputation_score = $3,

     

       82
       +
       			contribution_count = $4,

     

       83
       +
       			last_active_at = $5,

     

       84
       +
       			is_banned = $6,

     

       85
       +
       			is_moderator = $7

     

       86
       +
       		WHERE user_did = $1 AND community_did = $2

     

       87
       +
       		RETURNING last_active_at`

     

       88
       +
       

     

       89
       +
       	err := r.db.QueryRowContext(ctx, query,

     

       90
       +
       		membership.UserDID,

     

       91
       +
       		membership.CommunityDID,

     

       92
       +
       		membership.ReputationScore,

     

       93
       +
       		membership.ContributionCount,

     

       94
       +
       		membership.LastActiveAt,

     

       95
       +
       		membership.IsBanned,

     

       96
       +
       		membership.IsModerator,

     

       97
       +
       	).Scan(&membership.LastActiveAt)

     

       98
       +
       

     

       99
       +
       	if err == sql.ErrNoRows {

     

       100
       +
       		return nil, communities.ErrMembershipNotFound

     

       101
       +
       	}

     

       102
       +
       	if err != nil {

     

       103
       +
       		return nil, fmt.Errorf("failed to update membership: %w", err)

     

       104
       +
       	}

     

       105
       +
       

     

       106
       +
       	return membership, nil

     

       107
       +
       }

     

       108
       +
       

     

       109
       +
       // ListMembers retrieves members of a community ordered by reputation

     

       110
       +
       func (r *postgresCommunityRepo) ListMembers(ctx context.Context, communityDID string, limit, offset int) ([]*communities.Membership, error) {

     

       111
       +
       	query := `

     

       112
       +
       		SELECT id, user_did, community_did, reputation_score, contribution_count,

     

       113
       +
       			joined_at, last_active_at, is_banned, is_moderator

     

       114
       +
       		FROM community_memberships

     

       115
       +
       		WHERE community_did = $1

     

       116
       +
       		ORDER BY reputation_score DESC, joined_at ASC

     

       117
       +
       		LIMIT $2 OFFSET $3`

     

       118
       +
       

     

       119
       +
       	rows, err := r.db.QueryContext(ctx, query, communityDID, limit, offset)

     

       120
       +
       	if err != nil {

     

       121
       +
       		return nil, fmt.Errorf("failed to list members: %w", err)

     

       122
       +
       	}

     

       123
       +
       	defer rows.Close()

     

       124
       +
       

     

       125
       +
       	result := []*communities.Membership{}

     

       126
       +
       	for rows.Next() {

     

       127
       +
       		membership := &communities.Membership{}

     

       128
       +
       

     

       129
       +
       		err := rows.Scan(

     

       130
       +
       			&membership.ID,

     

       131
       +
       			&membership.UserDID,

     

       132
       +
       			&membership.CommunityDID,

     

       133
       +
       			&membership.ReputationScore,

     

       134
       +
       			&membership.ContributionCount,

     

       135
       +
       			&membership.JoinedAt,

     

       136
       +
       			&membership.LastActiveAt,

     

       137
       +
       			&membership.IsBanned,

     

       138
       +
       			&membership.IsModerator,

     

       139
       +
       		)

     

       140
       +
       		if err != nil {

     

       141
       +
       			return nil, fmt.Errorf("failed to scan member: %w", err)

     

       142
       +
       		}

     

       143
       +
       

     

       144
       +
       		result = append(result, membership)

     

       145
       +
       	}

     

       146
       +
       

     

       147
       +
       	if err = rows.Err(); err != nil {

     

       148
       +
       		return nil, fmt.Errorf("error iterating members: %w", err)

     

       149
       +
       	}

     

       150
       +
       

     

       151
       +
       	return result, nil

     

       152
       +
       }

     

       153
       +
       

     

       154
       +
       // CreateModerationAction records a moderation action

     

       155
       +
       func (r *postgresCommunityRepo) CreateModerationAction(ctx context.Context, action *communities.ModerationAction) (*communities.ModerationAction, error) {

     

       156
       +
       	query := `

     

       157
       +
       		INSERT INTO community_moderation (

     

       158
       +
       			community_did, action, reason, instance_did, broadcast, created_at, expires_at

     

       159
       +
       		)

     

       160
       +
       		VALUES ($1, $2, $3, $4, $5, $6, $7)

     

       161
       +
       		RETURNING id, created_at`

     

       162
       +
       

     

       163
       +
       	err := r.db.QueryRowContext(ctx, query,

     

       164
       +
       		action.CommunityDID,

     

       165
       +
       		action.Action,

     

       166
       +
       		nullString(action.Reason),

     

       167
       +
       		action.InstanceDID,

     

       168
       +
       		action.Broadcast,

     

       169
       +
       		action.CreatedAt,

     

       170
       +
       		action.ExpiresAt,

     

       171
       +
       	).Scan(&action.ID, &action.CreatedAt)

     

       172
       +
       

     

       173
       +
       	if err != nil {

     

       174
       +
       		if strings.Contains(err.Error(), "foreign key") {

     

       175
       +
       			return nil, communities.ErrCommunityNotFound

     

       176
       +
       		}

     

       177
       +
       		return nil, fmt.Errorf("failed to create moderation action: %w", err)

     

       178
       +
       	}

     

       179
       +
       

     

       180
       +
       	return action, nil

     

       181
       +
       }

     

       182
       +
       

     

       183
       +
       // ListModerationActions retrieves moderation actions for a community

     

       184
       +
       func (r *postgresCommunityRepo) ListModerationActions(ctx context.Context, communityDID string, limit, offset int) ([]*communities.ModerationAction, error) {

     

       185
       +
       	query := `

     

       186
       +
       		SELECT id, community_did, action, reason, instance_did, broadcast, created_at, expires_at

     

       187
       +
       		FROM community_moderation

     

       188
       +
       		WHERE community_did = $1

     

       189
       +
       		ORDER BY created_at DESC

     

       190
       +
       		LIMIT $2 OFFSET $3`

     

       191
       +
       

     

       192
       +
       	rows, err := r.db.QueryContext(ctx, query, communityDID, limit, offset)

     

       193
       +
       	if err != nil {

     

       194
       +
       		return nil, fmt.Errorf("failed to list moderation actions: %w", err)

     

       195
       +
       	}

     

       196
       +
       	defer rows.Close()

     

       197
       +
       

     

       198
       +
       	result := []*communities.ModerationAction{}

     

       199
       +
       	for rows.Next() {

     

       200
       +
       		action := &communities.ModerationAction{}

     

       201
       +
       		var reason sql.NullString

     

       202
       +
       

     

       203
       +
       		err := rows.Scan(

     

       204
       +
       			&action.ID,

     

       205
       +
       			&action.CommunityDID,

     

       206
       +
       			&action.Action,

     

       207
       +
       			&reason,

     

       208
       +
       			&action.InstanceDID,

     

       209
       +
       			&action.Broadcast,

     

       210
       +
       			&action.CreatedAt,

     

       211
       +
       			&action.ExpiresAt,

     

       212
       +
       		)

     

       213
       +
       		if err != nil {

     

       214
       +
       			return nil, fmt.Errorf("failed to scan moderation action: %w", err)

     

       215
       +
       		}

     

       216
       +
       

     

       217
       +
       		action.Reason = reason.String

     

       218
       +
       		result = append(result, action)

     

       219
       +
       	}

     

       220
       +
       

     

       221
       +
       	if err = rows.Err(); err != nil {

     

       222
       +
       		return nil, fmt.Errorf("error iterating moderation actions: %w", err)

     

       223
       +
       	}

     

       224
       +
       

     

       225
       +
       	return result, nil

     

       226
       +
       }

     

       227
       +
       

     

       228
       +
       // Statistics methods

     

       229
       +
       func (r *postgresCommunityRepo) IncrementMemberCount(ctx context.Context, communityDID string) error {

     

       230
       +
       	query := `UPDATE communities SET member_count = member_count + 1 WHERE did = $1`

     

       231
       +
       	_, err := r.db.ExecContext(ctx, query, communityDID)

     

       232
       +
       	if err != nil {

     

       233
       +
       		return fmt.Errorf("failed to increment member count: %w", err)

     

       234
       +
       	}

     

       235
       +
       	return nil

     

       236
       +
       }

     

       237
       +
       

     

       238
       +
       func (r *postgresCommunityRepo) DecrementMemberCount(ctx context.Context, communityDID string) error {

     

       239
       +
       	query := `UPDATE communities SET member_count = GREATEST(0, member_count - 1) WHERE did = $1`

     

       240
       +
       	_, err := r.db.ExecContext(ctx, query, communityDID)

     

       241
       +
       	if err != nil {

     

       242
       +
       		return fmt.Errorf("failed to decrement member count: %w", err)

     

       243
       +
       	}

     

       244
       +
       	return nil

     

       245
       +
       }

     

       246
       +
       

     

       247
       +
       func (r *postgresCommunityRepo) IncrementSubscriberCount(ctx context.Context, communityDID string) error {

     

       248
       +
       	query := `UPDATE communities SET subscriber_count = subscriber_count + 1 WHERE did = $1`

     

       249
       +
       	_, err := r.db.ExecContext(ctx, query, communityDID)

     

       250
       +
       	if err != nil {

     

       251
       +
       		return fmt.Errorf("failed to increment subscriber count: %w", err)

     

       252
       +
       	}

     

       253
       +
       	return nil

     

       254
       +
       }

     

       255
       +
       

     

       256
       +
       func (r *postgresCommunityRepo) DecrementSubscriberCount(ctx context.Context, communityDID string) error {

     

       257
       +
       	query := `UPDATE communities SET subscriber_count = GREATEST(0, subscriber_count - 1) WHERE did = $1`

     

       258
       +
       	_, err := r.db.ExecContext(ctx, query, communityDID)

     

       259
       +
       	if err != nil {

     

       260
       +
       		return fmt.Errorf("failed to decrement subscriber count: %w", err)

     

       261
       +
       	}

     

       262
       +
       	return nil

     

       263
       +
       }

     

       264
       +
       

     

       265
       +
       func (r *postgresCommunityRepo) IncrementPostCount(ctx context.Context, communityDID string) error {

     

       266
       +
       	query := `UPDATE communities SET post_count = post_count + 1 WHERE did = $1`

     

       267
       +
       	_, err := r.db.ExecContext(ctx, query, communityDID)

     

       268
       +
       	if err != nil {

     

       269
       +
       		return fmt.Errorf("failed to increment post count: %w", err)

     

       270
       +
       	}

     

       271
       +
       	return nil

     

       272
       +
       }

+292

internal/db/postgres/community_repo_subscriptions.go

···

       1
       +
       package postgres

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"context"

     

       5
       +
       	"database/sql"

     

       6
       +
       	"fmt"

     

       7
       +
       	"strings"

     

       8
       +
       

     

       9
       +
       	"Coves/internal/core/communities"

     

       10
       +
       )

     

       11
       +
       

     

       12
       +
       // Subscribe creates a new subscription record

     

       13
       +
       func (r *postgresCommunityRepo) Subscribe(ctx context.Context, subscription *communities.Subscription) (*communities.Subscription, error) {

     

       14
       +
       	query := `

     

       15
       +
       		INSERT INTO community_subscriptions (user_did, community_did, subscribed_at, record_uri, record_cid)

     

       16
       +
       		VALUES ($1, $2, $3, $4, $5)

     

       17
       +
       		RETURNING id, subscribed_at`

     

       18
       +
       

     

       19
       +
       	err := r.db.QueryRowContext(ctx, query,

     

       20
       +
       		subscription.UserDID,

     

       21
       +
       		subscription.CommunityDID,

     

       22
       +
       		subscription.SubscribedAt,

     

       23
       +
       		nullString(subscription.RecordURI),

     

       24
       +
       		nullString(subscription.RecordCID),

     

       25
       +
       	).Scan(&subscription.ID, &subscription.SubscribedAt)

     

       26
       +
       

     

       27
       +
       	if err != nil {

     

       28
       +
       		if strings.Contains(err.Error(), "duplicate key") {

     

       29
       +
       			return nil, communities.ErrSubscriptionAlreadyExists

     

       30
       +
       		}

     

       31
       +
       		if strings.Contains(err.Error(), "foreign key") {

     

       32
       +
       			return nil, communities.ErrCommunityNotFound

     

       33
       +
       		}

     

       34
       +
       		return nil, fmt.Errorf("failed to create subscription: %w", err)

     

       35
       +
       	}

     

       36
       +
       

     

       37
       +
       	return subscription, nil

     

       38
       +
       }

     

       39
       +
       

     

       40
       +
       // SubscribeWithCount atomically creates subscription and increments subscriber count

     

       41
       +
       // This is idempotent - safe for Jetstream replays

     

       42
       +
       func (r *postgresCommunityRepo) SubscribeWithCount(ctx context.Context, subscription *communities.Subscription) (*communities.Subscription, error) {

     

       43
       +
       	tx, err := r.db.BeginTx(ctx, nil)

     

       44
       +
       	if err != nil {

     

       45
       +
       		return nil, fmt.Errorf("failed to begin transaction: %w", err)

     

       46
       +
       	}

     

       47
       +
       	defer tx.Rollback()

     

       48
       +
       

     

       49
       +
       	// Insert subscription with ON CONFLICT DO NOTHING for idempotency

     

       50
       +
       	query := `

     

       51
       +
       		INSERT INTO community_subscriptions (user_did, community_did, subscribed_at, record_uri, record_cid)

     

       52
       +
       		VALUES ($1, $2, $3, $4, $5)

     

       53
       +
       		ON CONFLICT (user_did, community_did) DO NOTHING

     

       54
       +
       		RETURNING id, subscribed_at`

     

       55
       +
       

     

       56
       +
       	err = tx.QueryRowContext(ctx, query,

     

       57
       +
       		subscription.UserDID,

     

       58
       +
       		subscription.CommunityDID,

     

       59
       +
       		subscription.SubscribedAt,

     

       60
       +
       		nullString(subscription.RecordURI),

     

       61
       +
       		nullString(subscription.RecordCID),

     

       62
       +
       	).Scan(&subscription.ID, &subscription.SubscribedAt)

     

       63
       +
       

     

       64
       +
       	// If no rows returned, subscription already existed (idempotent behavior)

     

       65
       +
       	if err == sql.ErrNoRows {

     

       66
       +
       		// Get existing subscription

     

       67
       +
       		query = `SELECT id, subscribed_at FROM community_subscriptions WHERE user_did = $1 AND community_did = $2`

     

       68
       +
       		err = tx.QueryRowContext(ctx, query, subscription.UserDID, subscription.CommunityDID).Scan(&subscription.ID, &subscription.SubscribedAt)

     

       69
       +
       		if err != nil {

     

       70
       +
       			return nil, fmt.Errorf("failed to get existing subscription: %w", err)

     

       71
       +
       		}

     

       72
       +
       		// Don't increment count - subscription already existed

     

       73
       +
       		if err := tx.Commit(); err != nil {

     

       74
       +
       			return nil, fmt.Errorf("failed to commit transaction: %w", err)

     

       75
       +
       		}

     

       76
       +
       		return subscription, nil

     

       77
       +
       	}

     

       78
       +
       

     

       79
       +
       	if err != nil {

     

       80
       +
       		if strings.Contains(err.Error(), "foreign key") {

     

       81
       +
       			return nil, communities.ErrCommunityNotFound

     

       82
       +
       		}

     

       83
       +
       		return nil, fmt.Errorf("failed to create subscription: %w", err)

     

       84
       +
       	}

     

       85
       +
       

     

       86
       +
       	// Increment subscriber count only if insert succeeded

     

       87
       +
       	incrementQuery := `

     

       88
       +
       		UPDATE communities

     

       89
       +
       		SET subscriber_count = subscriber_count + 1, updated_at = NOW()

     

       90
       +
       		WHERE did = $1`

     

       91
       +
       

     

       92
       +
       	_, err = tx.ExecContext(ctx, incrementQuery, subscription.CommunityDID)

     

       93
       +
       	if err != nil {

     

       94
       +
       		return nil, fmt.Errorf("failed to increment subscriber count: %w", err)

     

       95
       +
       	}

     

       96
       +
       

     

       97
       +
       	if err := tx.Commit(); err != nil {

     

       98
       +
       		return nil, fmt.Errorf("failed to commit transaction: %w", err)

     

       99
       +
       	}

     

       100
       +
       

     

       101
       +
       	return subscription, nil

     

       102
       +
       }

     

       103
       +
       

     

       104
       +
       // Unsubscribe removes a subscription record

     

       105
       +
       func (r *postgresCommunityRepo) Unsubscribe(ctx context.Context, userDID, communityDID string) error {

     

       106
       +
       	query := `DELETE FROM community_subscriptions WHERE user_did = $1 AND community_did = $2`

     

       107
       +
       

     

       108
       +
       	result, err := r.db.ExecContext(ctx, query, userDID, communityDID)

     

       109
       +
       	if err != nil {

     

       110
       +
       		return fmt.Errorf("failed to unsubscribe: %w", err)

     

       111
       +
       	}

     

       112
       +
       

     

       113
       +
       	rowsAffected, err := result.RowsAffected()

     

       114
       +
       	if err != nil {

     

       115
       +
       		return fmt.Errorf("failed to check unsubscribe result: %w", err)

     

       116
       +
       	}

     

       117
       +
       

     

       118
       +
       	if rowsAffected == 0 {

     

       119
       +
       		return communities.ErrSubscriptionNotFound

     

       120
       +
       	}

     

       121
       +
       

     

       122
       +
       	return nil

     

       123
       +
       }

     

       124
       +
       

     

       125
       +
       // UnsubscribeWithCount atomically removes subscription and decrements subscriber count

     

       126
       +
       // This is idempotent - safe for Jetstream replays

     

       127
       +
       func (r *postgresCommunityRepo) UnsubscribeWithCount(ctx context.Context, userDID, communityDID string) error {

     

       128
       +
       	tx, err := r.db.BeginTx(ctx, nil)

     

       129
       +
       	if err != nil {

     

       130
       +
       		return fmt.Errorf("failed to begin transaction: %w", err)

     

       131
       +
       	}

     

       132
       +
       	defer tx.Rollback()

     

       133
       +
       

     

       134
       +
       	// Delete subscription

     

       135
       +
       	deleteQuery := `DELETE FROM community_subscriptions WHERE user_did = $1 AND community_did = $2`

     

       136
       +
       	result, err := tx.ExecContext(ctx, deleteQuery, userDID, communityDID)

     

       137
       +
       	if err != nil {

     

       138
       +
       		return fmt.Errorf("failed to unsubscribe: %w", err)

     

       139
       +
       	}

     

       140
       +
       

     

       141
       +
       	rowsAffected, err := result.RowsAffected()

     

       142
       +
       	if err != nil {

     

       143
       +
       		return fmt.Errorf("failed to check unsubscribe result: %w", err)

     

       144
       +
       	}

     

       145
       +
       

     

       146
       +
       	// If no rows deleted, subscription didn't exist (idempotent - not an error)

     

       147
       +
       	if rowsAffected == 0 {

     

       148
       +
       		if err := tx.Commit(); err != nil {

     

       149
       +
       			return fmt.Errorf("failed to commit transaction: %w", err)

     

       150
       +
       		}

     

       151
       +
       		return nil

     

       152
       +
       	}

     

       153
       +
       

     

       154
       +
       	// Decrement subscriber count only if delete succeeded

     

       155
       +
       	decrementQuery := `

     

       156
       +
       		UPDATE communities

     

       157
       +
       		SET subscriber_count = GREATEST(0, subscriber_count - 1), updated_at = NOW()

     

       158
       +
       		WHERE did = $1`

     

       159
       +
       

     

       160
       +
       	_, err = tx.ExecContext(ctx, decrementQuery, communityDID)

     

       161
       +
       	if err != nil {

     

       162
       +
       		return fmt.Errorf("failed to decrement subscriber count: %w", err)

     

       163
       +
       	}

     

       164
       +
       

     

       165
       +
       	if err := tx.Commit(); err != nil {

     

       166
       +
       		return fmt.Errorf("failed to commit transaction: %w", err)

     

       167
       +
       	}

     

       168
       +
       

     

       169
       +
       	return nil

     

       170
       +
       }

     

       171
       +
       

     

       172
       +
       // GetSubscription retrieves a specific subscription

     

       173
       +
       func (r *postgresCommunityRepo) GetSubscription(ctx context.Context, userDID, communityDID string) (*communities.Subscription, error) {

     

       174
       +
       	subscription := &communities.Subscription{}

     

       175
       +
       	query := `

     

       176
       +
       		SELECT id, user_did, community_did, subscribed_at, record_uri, record_cid

     

       177
       +
       		FROM community_subscriptions

     

       178
       +
       		WHERE user_did = $1 AND community_did = $2`

     

       179
       +
       

     

       180
       +
       	var recordURI, recordCID sql.NullString

     

       181
       +
       

     

       182
       +
       	err := r.db.QueryRowContext(ctx, query, userDID, communityDID).Scan(

     

       183
       +
       		&subscription.ID,

     

       184
       +
       		&subscription.UserDID,

     

       185
       +
       		&subscription.CommunityDID,

     

       186
       +
       		&subscription.SubscribedAt,

     

       187
       +
       		&recordURI,

     

       188
       +
       		&recordCID,

     

       189
       +
       	)

     

       190
       +
       

     

       191
       +
       	if err == sql.ErrNoRows {

     

       192
       +
       		return nil, communities.ErrSubscriptionNotFound

     

       193
       +
       	}

     

       194
       +
       	if err != nil {

     

       195
       +
       		return nil, fmt.Errorf("failed to get subscription: %w", err)

     

       196
       +
       	}

     

       197
       +
       

     

       198
       +
       	subscription.RecordURI = recordURI.String

     

       199
       +
       	subscription.RecordCID = recordCID.String

     

       200
       +
       

     

       201
       +
       	return subscription, nil

     

       202
       +
       }

     

       203
       +
       

     

       204
       +
       // ListSubscriptions retrieves all subscriptions for a user

     

       205
       +
       func (r *postgresCommunityRepo) ListSubscriptions(ctx context.Context, userDID string, limit, offset int) ([]*communities.Subscription, error) {

     

       206
       +
       	query := `

     

       207
       +
       		SELECT id, user_did, community_did, subscribed_at, record_uri, record_cid

     

       208
       +
       		FROM community_subscriptions

     

       209
       +
       		WHERE user_did = $1

     

       210
       +
       		ORDER BY subscribed_at DESC

     

       211
       +
       		LIMIT $2 OFFSET $3`

     

       212
       +
       

     

       213
       +
       	rows, err := r.db.QueryContext(ctx, query, userDID, limit, offset)

     

       214
       +
       	if err != nil {

     

       215
       +
       		return nil, fmt.Errorf("failed to list subscriptions: %w", err)

     

       216
       +
       	}

     

       217
       +
       	defer rows.Close()

     

       218
       +
       

     

       219
       +
       	result := []*communities.Subscription{}

     

       220
       +
       	for rows.Next() {

     

       221
       +
       		subscription := &communities.Subscription{}

     

       222
       +
       		var recordURI, recordCID sql.NullString

     

       223
       +
       

     

       224
       +
       		err := rows.Scan(

     

       225
       +
       			&subscription.ID,

     

       226
       +
       			&subscription.UserDID,

     

       227
       +
       			&subscription.CommunityDID,

     

       228
       +
       			&subscription.SubscribedAt,

     

       229
       +
       			&recordURI,

     

       230
       +
       			&recordCID,

     

       231
       +
       		)

     

       232
       +
       		if err != nil {

     

       233
       +
       			return nil, fmt.Errorf("failed to scan subscription: %w", err)

     

       234
       +
       		}

     

       235
       +
       

     

       236
       +
       		subscription.RecordURI = recordURI.String

     

       237
       +
       		subscription.RecordCID = recordCID.String

     

       238
       +
       

     

       239
       +
       		result = append(result, subscription)

     

       240
       +
       	}

     

       241
       +
       

     

       242
       +
       	if err = rows.Err(); err != nil {

     

       243
       +
       		return nil, fmt.Errorf("error iterating subscriptions: %w", err)

     

       244
       +
       	}

     

       245
       +
       

     

       246
       +
       	return result, nil

     

       247
       +
       }

     

       248
       +
       

     

       249
       +
       // ListSubscribers retrieves all subscribers for a community

     

       250
       +
       func (r *postgresCommunityRepo) ListSubscribers(ctx context.Context, communityDID string, limit, offset int) ([]*communities.Subscription, error) {

     

       251
       +
       	query := `

     

       252
       +
       		SELECT id, user_did, community_did, subscribed_at, record_uri, record_cid

     

       253
       +
       		FROM community_subscriptions

     

       254
       +
       		WHERE community_did = $1

     

       255
       +
       		ORDER BY subscribed_at DESC

     

       256
       +
       		LIMIT $2 OFFSET $3`

     

       257
       +
       

     

       258
       +
       	rows, err := r.db.QueryContext(ctx, query, communityDID, limit, offset)

     

       259
       +
       	if err != nil {

     

       260
       +
       		return nil, fmt.Errorf("failed to list subscribers: %w", err)

     

       261
       +
       	}

     

       262
       +
       	defer rows.Close()

     

       263
       +
       

     

       264
       +
       	result := []*communities.Subscription{}

     

       265
       +
       	for rows.Next() {

     

       266
       +
       		subscription := &communities.Subscription{}

     

       267
       +
       		var recordURI, recordCID sql.NullString

     

       268
       +
       

     

       269
       +
       		err := rows.Scan(

     

       270
       +
       			&subscription.ID,

     

       271
       +
       			&subscription.UserDID,

     

       272
       +
       			&subscription.CommunityDID,

     

       273
       +
       			&subscription.SubscribedAt,

     

       274
       +
       			&recordURI,

     

       275
       +
       			&recordCID,

     

       276
       +
       		)

     

       277
       +
       		if err != nil {

     

       278
       +
       			return nil, fmt.Errorf("failed to scan subscriber: %w", err)

     

       279
       +
       		}

     

       280
       +
       

     

       281
       +
       		subscription.RecordURI = recordURI.String

     

       282
       +
       		subscription.RecordCID = recordCID.String

     

       283
       +
       

     

       284
       +
       		result = append(result, subscription)

     

       285
       +
       	}

     

       286
       +
       

     

       287
       +
       	if err = rows.Err(); err != nil {

     

       288
       +
       		return nil, fmt.Errorf("error iterating subscribers: %w", err)

     

       289
       +
       	}

     

       290
       +
       

     

       291
       +
       	return result, nil

     

       292
       +
       }