A community based topic aggregation platform built on atproto
bretton.dev
1package communities
2
3import "context"
4
5// Repository defines the interface for community data persistence
6// This is the AppView's indexed view of communities from the firehose
7type Repository interface {
8 // Community CRUD
9 Create(ctx context.Context, community *Community) (*Community, error)
10 GetByDID(ctx context.Context, did string) (*Community, error)
11 GetByHandle(ctx context.Context, handle string) (*Community, error)
12 Update(ctx context.Context, community *Community) (*Community, error)
13 Delete(ctx context.Context, did string) error
14
15 // Listing & Search
16 List(ctx context.Context, req ListCommunitiesRequest) ([]*Community, int, error) // Returns communities + total count
17 Search(ctx context.Context, req SearchCommunitiesRequest) ([]*Community, int, error)
18
19 // Subscriptions (lightweight feed follows)
20 Subscribe(ctx context.Context, subscription *Subscription) (*Subscription, error)
21 SubscribeWithCount(ctx context.Context, subscription *Subscription) (*Subscription, error) // Atomic: subscribe + increment count
22 Unsubscribe(ctx context.Context, userDID, communityDID string) error
23 UnsubscribeWithCount(ctx context.Context, userDID, communityDID string) error // Atomic: unsubscribe + decrement count
24 GetSubscription(ctx context.Context, userDID, communityDID string) (*Subscription, error)
25 GetSubscriptionByURI(ctx context.Context, recordURI string) (*Subscription, error) // For Jetstream delete operations
26 ListSubscriptions(ctx context.Context, userDID string, limit, offset int) ([]*Subscription, error)
27 ListSubscribers(ctx context.Context, communityDID string, limit, offset int) ([]*Subscription, error)
28
29 // Memberships (active participation with reputation)
30 CreateMembership(ctx context.Context, membership *Membership) (*Membership, error)
31 GetMembership(ctx context.Context, userDID, communityDID string) (*Membership, error)
32 UpdateMembership(ctx context.Context, membership *Membership) (*Membership, error)
33 ListMembers(ctx context.Context, communityDID string, limit, offset int) ([]*Membership, error)
34
35 // Moderation (V2 feature, prepared interface)
36 CreateModerationAction(ctx context.Context, action *ModerationAction) (*ModerationAction, error)
37 ListModerationActions(ctx context.Context, communityDID string, limit, offset int) ([]*ModerationAction, error)
38
39 // Statistics
40 IncrementMemberCount(ctx context.Context, communityDID string) error
41 DecrementMemberCount(ctx context.Context, communityDID string) error
42 IncrementSubscriberCount(ctx context.Context, communityDID string) error
43 DecrementSubscriberCount(ctx context.Context, communityDID string) error
44 IncrementPostCount(ctx context.Context, communityDID string) error
45}
46
47// Service defines the interface for community business logic
48// Coordinates between Repository and external services (PDS, identity, etc.)
49type Service interface {
50 // Community operations (write-forward pattern: Service -> PDS -> Firehose -> Consumer -> Repository)
51 CreateCommunity(ctx context.Context, req CreateCommunityRequest) (*Community, error)
52 GetCommunity(ctx context.Context, identifier string) (*Community, error) // identifier can be DID or handle
53 UpdateCommunity(ctx context.Context, req UpdateCommunityRequest) (*Community, error)
54 ListCommunities(ctx context.Context, req ListCommunitiesRequest) ([]*Community, int, error)
55 SearchCommunities(ctx context.Context, req SearchCommunitiesRequest) ([]*Community, int, error)
56
57 // Subscription operations (write-forward: creates record in user's PDS)
58 SubscribeToCommunity(ctx context.Context, userDID, userAccessToken, communityIdentifier string, contentVisibility int) (*Subscription, error)
59 UnsubscribeFromCommunity(ctx context.Context, userDID, userAccessToken, communityIdentifier string) error
60 GetUserSubscriptions(ctx context.Context, userDID string, limit, offset int) ([]*Subscription, error)
61 GetCommunitySubscribers(ctx context.Context, communityIdentifier string, limit, offset int) ([]*Subscription, error)
62
63 // Membership operations (indexed from firehose, reputation managed internally)
64 GetMembership(ctx context.Context, userDID, communityIdentifier string) (*Membership, error)
65 ListCommunityMembers(ctx context.Context, communityIdentifier string, limit, offset int) ([]*Membership, error)
66
67 // Validation helpers
68 ValidateHandle(handle string) error
69 ResolveCommunityIdentifier(ctx context.Context, identifier string) (string, error) // Returns DID from handle or DID
70}