bretton.dev / coves
A community based topic aggregation platform built on atproto
fork atom

docs: update documentation for completed namespace migration

Update COMMENT_SYSTEM_IMPLEMENTATION.md to reflect the completed
migration from social.coves.feed.comment to
social.coves.community.comment.

Changes:
- Mark Phase 4 (Namespace Migration) as COMPLETED (2025-11-16)
- Update all namespace references throughout the document
- Add migration completion details and scope

Documentation now accurately reflects the current implementation
using the community.comment namespace for all comment records.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

bretton.dev 7ad8afb0 f2082c1a

options
unified split
Changed files
+18 -15
docs
COMMENT_SYSTEM_IMPLEMENTATION.md
+18 -15
docs/COMMENT_SYSTEM_IMPLEMENTATION.md 
···

       
308

       
 

       
```json


     

       
309

       
 

       
{


     

       
310

       
 

       
  "lexicon": 1,


     

       
311

       
-

       
  "id": "social.coves.feed.comment",


     

       
312

       
 

       
  "defs": {


     

       
313

       
 

       
    "main": {


     

       
314

       
 

       
      "type": "record",


     
···

       
365

       
 

       
```sql


     

       
366

       
 

       
CREATE TABLE comments (


     

       
367

       
 

       
    id BIGSERIAL PRIMARY KEY,


     

       
368

       
-

       
    uri TEXT UNIQUE NOT NULL,               -- AT-URI (at://commenter_did/social.coves.feed.comment/rkey)


     

       
369

       
 

       
    cid TEXT NOT NULL,                      -- Content ID


     

       
370

       
 

       
    rkey TEXT NOT NULL,                     -- Record key (TID)


     

       
371

       
 

       
    commenter_did TEXT NOT NULL,            -- User who commented (from AT-URI repo field)


     
···

       
559

       
 

       
        return nil


     

       
560

       
 

       
    }


     

       
561

       
 

       



     

       
562

       
-

       
    if event.Commit.Collection == "social.coves.feed.comment" {


     

       
563

       
 

       
        switch event.Commit.Operation {


     

       
564

       
 

       
        case "create":


     

       
565

       
 

       
            return c.createComment(ctx, event.Did, commit)


     
···

       
653

       
 

       
- Auto-reconnect on errors (5-second retry)


     

       
654

       
 

       
- Ping/pong keepalive (30-second ping, 60-second read deadline)


     

       
655

       
 

       
- Graceful shutdown via context cancellation


     

       
656

       
-

       
- Subscribes to: `wantedCollections=social.coves.feed.comment`


     

       
657

       
 

       



     

       
658

       
 

       
---


     

       
659

       
 

       



     
···

       
669

       
 

       
// Start Jetstream consumer for comments


     

       
670

       
 

       
commentJetstreamURL := os.Getenv("COMMENT_JETSTREAM_URL")


     

       
671

       
 

       
if commentJetstreamURL == "" {


     

       
672

       
-

       
    commentJetstreamURL = "ws://localhost:6008/subscribe?wantedCollections=social.coves.feed.comment"


     

       
673

       
 

       
}


     

       
674

       
 

       



     

       
675

       
 

       
commentEventConsumer := jetstream.NewCommentEventConsumer(commentRepo, db)


     
···

       
682

       
 

       
}()


     

       
683

       
 

       



     

       
684

       
 

       
log.Printf("Started Jetstream comment consumer: %s", commentJetstreamURL)


     

       
685

       
-

       
log.Println("  - Indexing: social.coves.feed.comment CREATE/UPDATE/DELETE operations")


     

       
686

       
 

       
log.Println("  - Updating: Post comment counts and comment reply counts atomically")


     

       
687

       
 

       
```


     

       
688

       
 

       



     
···

       
835

       
 

       
| Aspect | Votes | Comments |


     

       
836

       
 

       
|--------|-------|----------|


     

       
837

       
 

       
| **Location** | User repositories | User repositories |


     

       
838

       
-

       
| **Lexicon** | `social.coves.feed.vote` | `social.coves.feed.comment` |


     

       
839

       
 

       
| **Operations** | CREATE, DELETE | CREATE, UPDATE, DELETE |


     

       
840

       
 

       
| **Mutability** | Immutable | Editable |


     

       
841

       
 

       
| **Foreign Keys** | None (out-of-order indexing) | None (out-of-order indexing) |


     
···

       
1197

       
 

       



     

       
1198

       
 

       
---


     

       
1199

       
 

       



     

       
1200

       
-

       
### 📋 Phase 4: Namespace Migration (Separate Task)


     

       

       

       
     

       

       

       
     

       
1201

       
 

       



     

       
1202

       
 

       
**Scope:**


     

       
1203

       
-

       
- Migrate existing `social.coves.feed.comment` records to `social.coves.community.comment`


     

       
1204

       
-

       
- Update all AT-URIs in database


     

       
1205

       
-

       
- Update Jetstream consumer collection filter


     

       
1206

       
-

       
- Migration script with rollback capability


     

       
1207

       
-

       
- Zero-downtime deployment strategy


     

       

       

       
     

       
1208

       
 

       



     

       
1209

       
-

       
**Note:** Currently out of scope - will be tackled separately when needed.


     

       
1210

       
 

       



     

       
1211

       
 

       
---


     

       
1212

       
 

       



     
···

       
1456

       
 

       
### Environment Variables


     

       
1457

       
 

       
```bash


     

       
1458

       
 

       
# Jetstream URL (optional, defaults to localhost:6008)


     

       
1459

       
-

       
export COMMENT_JETSTREAM_URL="ws://localhost:6008/subscribe?wantedCollections=social.coves.feed.comment"


     

       
1460

       
 

       



     

       
1461

       
 

       
# Database URL


     

       
1462

       
 

       
export TEST_DATABASE_URL="postgres://test_user:test_password@localhost:5434/coves_test?sslmode=disable"


     
···

       
308

       
 

       
```json


     

       
309

       
 

       
{


     

       
310

       
 

       
  "lexicon": 1,


     

       
311

       
+

       
  "id": "social.coves.community.comment",


     

       
312

       
 

       
  "defs": {


     

       
313

       
 

       
    "main": {


     

       
314

       
 

       
      "type": "record",


     
···

       
365

       
 

       
```sql


     

       
366

       
 

       
CREATE TABLE comments (


     

       
367

       
 

       
    id BIGSERIAL PRIMARY KEY,


     

       
368

       
+

       
    uri TEXT UNIQUE NOT NULL,               -- AT-URI (at://commenter_did/social.coves.community.comment/rkey)


     

       
369

       
 

       
    cid TEXT NOT NULL,                      -- Content ID


     

       
370

       
 

       
    rkey TEXT NOT NULL,                     -- Record key (TID)


     

       
371

       
 

       
    commenter_did TEXT NOT NULL,            -- User who commented (from AT-URI repo field)


     
···

       
559

       
 

       
        return nil


     

       
560

       
 

       
    }


     

       
561

       
 

       



     

       
562

       
+

       
    if event.Commit.Collection == "social.coves.community.comment" {


     

       
563

       
 

       
        switch event.Commit.Operation {


     

       
564

       
 

       
        case "create":


     

       
565

       
 

       
            return c.createComment(ctx, event.Did, commit)


     
···

       
653

       
 

       
- Auto-reconnect on errors (5-second retry)


     

       
654

       
 

       
- Ping/pong keepalive (30-second ping, 60-second read deadline)


     

       
655

       
 

       
- Graceful shutdown via context cancellation


     

       
656

       
+

       
- Subscribes to: `wantedCollections=social.coves.community.comment`


     

       
657

       
 

       



     

       
658

       
 

       
---


     

       
659

       
 

       



     
···

       
669

       
 

       
// Start Jetstream consumer for comments


     

       
670

       
 

       
commentJetstreamURL := os.Getenv("COMMENT_JETSTREAM_URL")


     

       
671

       
 

       
if commentJetstreamURL == "" {


     

       
672

       
+

       
    commentJetstreamURL = "ws://localhost:6008/subscribe?wantedCollections=social.coves.community.comment"


     

       
673

       
 

       
}


     

       
674

       
 

       



     

       
675

       
 

       
commentEventConsumer := jetstream.NewCommentEventConsumer(commentRepo, db)


     
···

       
682

       
 

       
}()


     

       
683

       
 

       



     

       
684

       
 

       
log.Printf("Started Jetstream comment consumer: %s", commentJetstreamURL)


     

       
685

       
+

       
log.Println("  - Indexing: social.coves.community.comment CREATE/UPDATE/DELETE operations")


     

       
686

       
 

       
log.Println("  - Updating: Post comment counts and comment reply counts atomically")


     

       
687

       
 

       
```


     

       
688

       
 

       



     
···

       
835

       
 

       
| Aspect | Votes | Comments |


     

       
836

       
 

       
|--------|-------|----------|


     

       
837

       
 

       
| **Location** | User repositories | User repositories |


     

       
838

       
+

       
| **Lexicon** | `social.coves.feed.vote` | `social.coves.community.comment` |


     

       
839

       
 

       
| **Operations** | CREATE, DELETE | CREATE, UPDATE, DELETE |


     

       
840

       
 

       
| **Mutability** | Immutable | Editable |


     

       
841

       
 

       
| **Foreign Keys** | None (out-of-order indexing) | None (out-of-order indexing) |


     
···

       
1197

       
 

       



     

       
1198

       
 

       
---


     

       
1199

       
 

       



     

       
1200

       
+

       
### ✅ Phase 4: Namespace Migration (COMPLETED)


     

       
1201

       
+

       



     

       
1202

       
+

       
**Completed:** 2025-11-16


     

       
1203

       
 

       



     

       
1204

       
 

       
**Scope:**


     

       
1205

       
+

       
- ✅ Migrated `social.coves.community.comment` namespace to `social.coves.community.comment`


     

       
1206

       
+

       
- ✅ Updated lexicon definitions (record and query schemas)


     

       
1207

       
+

       
- ✅ Updated Jetstream consumer collection filter


     

       
1208

       
+

       
- ✅ Updated all code references (consumer, service, validation layers)


     

       
1209

       
+

       
- ✅ Updated integration tests and test data generation scripts


     

       
1210

       
+

       
- ✅ Created database migration (018_migrate_comment_namespace.sql)


     

       
1211

       
 

       



     

       
1212

       
+

       
**Note:** Since we're pre-production, no historical data migration was needed. Migration script updates URIs in comments table (uri, root_uri, parent_uri columns).


     

       
1213

       
 

       



     

       
1214

       
 

       
---


     

       
1215

       
 

       



     
···

       
1459

       
 

       
### Environment Variables


     

       
1460

       
 

       
```bash


     

       
1461

       
 

       
# Jetstream URL (optional, defaults to localhost:6008)


     

       
1462

       
+

       
export COMMENT_JETSTREAM_URL="ws://localhost:6008/subscribe?wantedCollections=social.coves.community.comment"


     

       
1463

       
 

       



     

       
1464

       
 

       
# Database URL


     

       
1465

       
 

       
export TEST_DATABASE_URL="postgres://test_user:test_password@localhost:5434/coves_test?sslmode=disable"