commit 95650093f91fb479842ffd5e2e2ec9280f1717ea · bretton.dev/coves

+1 -11

internal/core/communities/service.go

···

       131
       131
        
       	// Build community profile record

     

       132
       132
        
       	profile := map[string]interface{}{

     

       133
       133
        
       		"$type":      "social.coves.community.profile",

     

       134
       134
       -
       		"handle":     pdsAccount.Handle, // atProto handle (e.g., gaming.community.coves.social)

     

       135
       135
       -
       		"name":       req.Name,          // Short name for !mentions (e.g., "gaming")

     

       134
       134
       +
       		"name":       req.Name, // Short name for !mentions (e.g., "gaming")

     

       136
       135
        
       		"visibility": req.Visibility,

     

       137
       136
        
       		"hostedBy":   s.instanceDID, // V2: Instance hosts, community owns

     

       138
       137
        
       		"createdBy":  req.CreatedByDID,

     
···

       158
       157
        
       	if req.Language != "" {

     

       159
       158
        
       		profile["language"] = req.Language

     

       160
       159
        
       	}

     

       161
       161
       -
       

     

       162
       162
       -
       	// Initialize counts

     

       163
       163
       -
       	profile["memberCount"] = 0

     

       164
       164
       -
       	profile["subscriberCount"] = 0

     

       165
       160
        
       

     

       166
       161
        
       	// TODO: Handle avatar and banner blobs

     

       167
       162
        
       	// For now, we'll skip blob uploads. This would require:

     
···

       290
       285
        
       	// Build updated profile record (start with existing)

     

       291
       286
        
       	profile := map[string]interface{}{

     

       292
       287
        
       		"$type":     "social.coves.community.profile",

     

       293
       293
       -
       		"handle":    existing.Handle,

     

       294
       288
        
       		"name":      existing.Name,

     

       295
       289
        
       		"owner":     existing.OwnerDID,

     

       296
       290
        
       		"createdBy": existing.CreatedByDID,

     
···

       340
       334
        
       	} else if len(existing.ContentWarnings) > 0 {

     

       341
       335
        
       		profile["contentWarnings"] = existing.ContentWarnings

     

       342
       336
        
       	}

     

       343
       343
       -
       

     

       344
       344
       -
       	// Preserve counts

     

       345
       345
       -
       	profile["memberCount"] = existing.MemberCount

     

       346
       346
       -
       	profile["subscriberCount"] = existing.SubscriberCount

     

       347
       337
        
       

     

       348
       338
        
       	// V2: Community profiles always use "self" as rkey

     

       349
       339
        
       	// (No need to extract from URI - it's always "self" for V2 communities)

+6 -10

tests/integration/community_consumer_test.go

···

       39
       39
        
       				RKey:       "self",

     

       40
       40
        
       				CID:        "bafy123abc",

     

       41
       41
        
       				Record: map[string]interface{}{

     

       42
       42
       -
       					"did":         communityDID, // Community's unique DID

     

       43
       43
       -
       					"handle":      fmt.Sprintf("!test-community-%s@coves.local", uniqueSuffix),

     

       42
       42
       +
       					// Note: No 'did', 'handle', 'memberCount', or 'subscriberCount' in record

     

       43
       43
       +
       					// These are resolved/computed by AppView, not stored in immutable records

     

       44
       44
        
       					"name":        "test-community",

     

       45
       45
        
       					"displayName": "Test Community",

     

       46
       46
        
       					"description": "A test community",

     
···

       51
       51
        
       					"federation": map[string]interface{}{

     

       52
       52
        
       						"allowExternalDiscovery": true,

     

       53
       53
        
       					},

     

       54
       54
       -
       					"memberCount":     0,

     

       55
       55
       -
       					"subscriberCount": 0,

     

       56
       56
       -
       					"createdAt":       time.Now().Format(time.RFC3339),

     

       54
       54
       +
       					"createdAt": time.Now().Format(time.RFC3339),

     

       57
       55
        
       				},

     

       58
       56
        
       			},

     

       59
       57
        
       		}

     
···

       117
       115
        
       				RKey:       "self",

     

       118
       116
        
       				CID:        "bafy456def",

     

       119
       117
        
       				Record: map[string]interface{}{

     

       120
       120
       -
       					"did":         communityDID, // Community's unique DID

     

       121
       121
       -
       					"handle":      handle,

     

       118
       118
       +
       					// Note: No 'did', 'handle', 'memberCount', or 'subscriberCount' in record

     

       119
       119
       +
       					// These are resolved/computed by AppView, not stored in immutable records

     

       122
       120
        
       					"name":        "update-test",

     

       123
       121
        
       					"displayName": "Updated Name",

     

       124
       122
        
       					"description": "Updated description",

     
···

       129
       127
        
       					"federation": map[string]interface{}{

     

       130
       128
        
       						"allowExternalDiscovery": false,

     

       131
       129
        
       					},

     

       132
       132
       -
       					"memberCount":     5,

     

       133
       133
       -
       					"subscriberCount": 10,

     

       134
       134
       -
       					"createdAt":       time.Now().Format(time.RFC3339),

     

       130
       130
       +
       					"createdAt": time.Now().Format(time.RFC3339),

     

       135
       131
        
       				},

     

       136
       132
        
       			},

     

       137
       133
        
       		}

+4 -7

tests/integration/community_e2e_test.go

···

       259
       259
        
       			t.Logf("   Record value:\n   %s", string(recordJSON))

     

       260
       260
        
       		}

     

       261
       261
        
       

     

       262
       262
       -
       		// V2: DID is NOT in the record - it's in the repository URI

     

       263
       263
       -
       		// The record should have handle, name, etc. but no 'did' field

     

       264
       264
       -
       		// This matches Bluesky's app.bsky.actor.profile pattern

     

       265
       265
       -
       		if pdsRecord.Value["handle"] != community.Handle {

     

       266
       266
       -
       			t.Errorf("Community handle mismatch in PDS record: expected %s, got %v",

     

       267
       267
       -
       				community.Handle, pdsRecord.Value["handle"])

     

       268
       268
       -
       		}

     

       262
       262
       +
       		// V2: DID and Handle are NOT in the record - they're resolved from the repository URI

     

       263
       263
       +
       		// The record should have name, hostedBy, createdBy, etc. but no 'did' or 'handle' fields

     

       264
       264
       +
       		// This matches Bluesky's app.bsky.actor.profile pattern (no handle in record)

     

       265
       265
       +
       		// Handles are mutable and resolved from DIDs via PLC, so they shouldn't be stored in immutable records

     

       269
       266
        
       

     

       270
       267
        
       		// ====================================================================================

     

       271
       268
        
       		// Part 2: TRUE E2E - Real Jetstream Firehose Consumer