···

       
52
       
 
       
	ID                int       `json:"id" db:"id"`

     

       
53
       
 
       
}

     

       
54
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
55
       
 
       
// Membership represents active participation with reputation tracking

     

       
56
       
 
       
type Membership struct {

     

       
57
       
 
       
	JoinedAt          time.Time `json:"joinedAt" db:"joined_at"`

     

···

       
52
       
 
       
	ID                int       `json:"id" db:"id"`

     

       
53
       
 
       
}

     

       
54
       
 
       


     

       
55
       
+
       
// CommunityBlock represents a user blocking a community

     

       
56
       
+
       
// Block records live in the user's repository (at://user_did/social.coves.community.block/{rkey})

     

       
57
       
+
       
type CommunityBlock struct {

     

       
58
       
+
       
	ID           int       `json:"id" db:"id"`

     

       
59
       
+
       
	UserDID      string    `json:"userDid" db:"user_did"`

     

       
60
       
+
       
	CommunityDID string    `json:"communityDid" db:"community_did"`

     

       
61
       
+
       
	BlockedAt    time.Time `json:"blockedAt" db:"blocked_at"`

     

       
62
       
+
       
	RecordURI    string    `json:"recordUri,omitempty" db:"record_uri"`

     

       
63
       
+
       
	RecordCID    string    `json:"recordCid,omitempty" db:"record_cid"`

     

       
64
       
+
       
}

     

       
65
       
+
       


     

       
66
       
 
       
// Membership represents active participation with reputation tracking

     

       
67
       
 
       
type Membership struct {

     

       
68
       
 
       
	JoinedAt          time.Time `json:"joinedAt" db:"joined_at"`

     

···

       
31
       
 
       
	// ErrSubscriptionNotFound is returned when subscription doesn't exist

     

       
32
       
 
       
	ErrSubscriptionNotFound = errors.New("subscription not found")

     

       
33
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
34
       
 
       
	// ErrMembershipNotFound is returned when membership doesn't exist

     

       
35
       
 
       
	ErrMembershipNotFound = errors.New("membership not found")

     

       
36
       
 
       


     
···

       
63
       
 
       
func IsNotFound(err error) bool {

     

       
64
       
 
       
	return errors.Is(err, ErrCommunityNotFound) ||

     

       
65
       
 
       
		errors.Is(err, ErrSubscriptionNotFound) ||

     

       
0
       
 
       

     

       
66
       
 
       
		errors.Is(err, ErrMembershipNotFound)

     

       
67
       
 
       
}

     

       
68
       
 
       


     

···

       
31
       
 
       
	// ErrSubscriptionNotFound is returned when subscription doesn't exist

     

       
32
       
 
       
	ErrSubscriptionNotFound = errors.New("subscription not found")

     

       
33
       
 
       


     

       
34
       
+
       
	// ErrBlockNotFound is returned when block doesn't exist

     

       
35
       
+
       
	ErrBlockNotFound = errors.New("block not found")

     

       
36
       
+
       


     

       
37
       
 
       
	// ErrMembershipNotFound is returned when membership doesn't exist

     

       
38
       
 
       
	ErrMembershipNotFound = errors.New("membership not found")

     

       
39
       
 
       


     
···

       
66
       
 
       
func IsNotFound(err error) bool {

     

       
67
       
 
       
	return errors.Is(err, ErrCommunityNotFound) ||

     

       
68
       
 
       
		errors.Is(err, ErrSubscriptionNotFound) ||

     

       
69
       
+
       
		errors.Is(err, ErrBlockNotFound) ||

     

       
70
       
 
       
		errors.Is(err, ErrMembershipNotFound)

     

       
71
       
 
       
}

     

       
72
       
 
       


     

···

       
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
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
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)

     
···

       
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)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
62
       
 
       


     

       
63
       
 
       
	// Membership operations (indexed from firehose, reputation managed internally)

     

       
64
       
 
       
	GetMembership(ctx context.Context, userDID, communityIdentifier string) (*Membership, error)

     

···

       
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
       
+
       
	// Community Blocks

     

       
30
       
+
       
	BlockCommunity(ctx context.Context, block *CommunityBlock) (*CommunityBlock, error)

     

       
31
       
+
       
	UnblockCommunity(ctx context.Context, userDID, communityDID string) error

     

       
32
       
+
       
	GetBlock(ctx context.Context, userDID, communityDID string) (*CommunityBlock, error)

     

       
33
       
+
       
	GetBlockByURI(ctx context.Context, recordURI string) (*CommunityBlock, error) // For Jetstream delete operations

     

       
34
       
+
       
	ListBlockedCommunities(ctx context.Context, userDID string, limit, offset int) ([]*CommunityBlock, error)

     

       
35
       
+
       
	IsBlocked(ctx context.Context, userDID, communityDID string) (bool, error)

     

       
36
       
+
       


     

       
37
       
 
       
	// Memberships (active participation with reputation)

     

       
38
       
 
       
	CreateMembership(ctx context.Context, membership *Membership) (*Membership, error)

     

       
39
       
 
       
	GetMembership(ctx context.Context, userDID, communityDID string) (*Membership, error)

     
···

       
67
       
 
       
	UnsubscribeFromCommunity(ctx context.Context, userDID, userAccessToken, communityIdentifier string) error

     

       
68
       
 
       
	GetUserSubscriptions(ctx context.Context, userDID string, limit, offset int) ([]*Subscription, error)

     

       
69
       
 
       
	GetCommunitySubscribers(ctx context.Context, communityIdentifier string, limit, offset int) ([]*Subscription, error)

     

       
70
       
+
       


     

       
71
       
+
       
	// Block operations (write-forward: creates record in user's PDS)

     

       
72
       
+
       
	BlockCommunity(ctx context.Context, userDID, userAccessToken, communityIdentifier string) (*CommunityBlock, error)

     

       
73
       
+
       
	UnblockCommunity(ctx context.Context, userDID, userAccessToken, communityIdentifier string) error

     

       
74
       
+
       
	GetBlockedCommunities(ctx context.Context, userDID string, limit, offset int) ([]*CommunityBlock, error)

     

       
75
       
+
       
	IsBlocked(ctx context.Context, userDID, communityIdentifier string) (bool, error)

     

       
76
       
 
       


     

       
77
       
 
       
	// Membership operations (indexed from firehose, reputation managed internally)

     

       
78
       
 
       
	GetMembership(ctx context.Context, userDID, communityIdentifier string) (*Membership, error)