Add post pinning, flair tags, and suggested follows

Post pinning: Submolt moderators/owners can pin posts. Pinned posts
appear first in submolt feeds. Toggle pin/unpin via POST /social/pin/{id}.

Post flair: Posts can have optional flair tags (question, discussion,
announcement, etc.) for content categorization.

Suggested follows: GET /social/suggested recommends entities by trust
score, excluding already-followed and blocked entities.

8 new tests (297 total), all passing.

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

Author: kenneives

migrations/versions/56d8b92830a1_add_post_pinning_and_flair.py

@@ -0,0 +1,30 @@
+"""add_post_pinning_and_flair
+
+Revision ID: 56d8b92830a1
+Revises: a43957244158
+Create Date: 2026-02-17 16:24:11.658661
+"""
+from __future__ import annotations
+
+from alembic import op
+import sqlalchemy as sa
+
+
+revision = '56d8b92830a1'
+down_revision = 'a43957244158'
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column('posts', sa.Column('is_pinned', sa.Boolean(), nullable=True))
+    op.add_column('posts', sa.Column('flair', sa.String(length=50), nullable=True))
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('posts', 'flair')
+    op.drop_column('posts', 'is_pinned')
+    # ### end Alembic commands ###

src/api/feed_router.py

@@ -34,6 +34,7 @@ class CreatePostRequest(BaseModel):
     content: str = Field(..., min_length=1, max_length=10000)
     parent_post_id: uuid.UUID | None = None
     submolt_id: uuid.UUID | None = None
+    flair: str | None = Field(None, max_length=50)
 
 
 class EditPostRequest(BaseModel):
@@ -63,6 +64,8 @@ class PostResponse(BaseModel):
     vote_count: int
     reply_count: int = 0
     is_edited: bool = False
+    is_pinned: bool = False
+    flair: str | None = None
     user_vote: str | None = None  # "up", "down", or None
     is_bookmarked: bool = False
     author_trust_score: float | None = None
@@ -123,6 +126,7 @@ async def create_post(
         content=body.content,
         parent_post_id=body.parent_post_id,
         submolt_id=body.submolt_id,
+        flair=body.flair,
     )
     db.add(post)
     await db.flush()
@@ -943,6 +947,8 @@ def _build_post_response(
         vote_count=post.vote_count,
         reply_count=reply_count,
         is_edited=post.is_edited or False,
+        is_pinned=post.is_pinned or False,
+        flair=post.flair,
         user_vote=user_vote,
         is_bookmarked=is_bookmarked,
         author_trust_score=author_trust_score,

src/api/social_router.py

@@ -10,7 +10,15 @@
 from src.api.deps import get_current_entity
 from src.api.rate_limit import rate_limit_writes
 from src.database import get_db
-from src.models import Entity, EntityBlock, EntityRelationship, RelationshipType
+from src.models import (
+    Entity,
+    EntityBlock,
+    EntityRelationship,
+    Post,
+    RelationshipType,
+    SubmoltMembership,
+    TrustScore,
+)
 
 router = APIRouter(prefix="/social", tags=["social"])
 
@@ -317,3 +325,108 @@ async def list_blocked(
         ],
         "count": len(rows),
     }
+
+
+# --- Suggested Follows ---
+
+
+@router.get("/suggested")
+async def get_suggested_follows(
+    limit: int = 10,
+    current_entity: Entity = Depends(get_current_entity),
+    db: AsyncSession = Depends(get_db),
+):
+    """Suggest entities to follow based on trust score and activity.
+
+    Excludes already-followed entities, blocked entities, and self.
+    """
+    # Get already followed IDs
+    following = await db.execute(
+        select(EntityRelationship.target_entity_id).where(
+            EntityRelationship.source_entity_id == current_entity.id,
+            EntityRelationship.type == RelationshipType.FOLLOW,
+        )
+    )
+    followed_ids = {row[0] for row in following.all()}
+    followed_ids.add(current_entity.id)
+
+    # Get blocked IDs
+    blocked = await db.execute(
+        select(EntityBlock.blocked_id).where(
+            EntityBlock.blocker_id == current_entity.id,
+        )
+    )
+    blocked_ids = {row[0] for row in blocked.all()}
+    exclude_ids = followed_ids | blocked_ids
+
+    # Find top entities by trust score that aren't followed
+    query = (
+        select(Entity, TrustScore.score)
+        .outerjoin(TrustScore, TrustScore.entity_id == Entity.id)
+        .where(
+            Entity.is_active.is_(True),
+            Entity.id.notin_(exclude_ids) if exclude_ids else True,
+        )
+        .order_by(
+            func.coalesce(TrustScore.score, 0).desc(),
+            Entity.created_at.desc(),
+        )
+        .limit(limit)
+    )
+
+    result = await db.execute(query)
+    rows = result.all()
+
+    return {
+        "suggestions": [
+            {
+                "id": str(entity.id),
+                "type": entity.type.value,
+                "display_name": entity.display_name,
+                "did_web": entity.did_web,
+                "bio_markdown": entity.bio_markdown or "",
+                "trust_score": score,
+            }
+            for entity, score in rows
+        ],
+    }
+
+
+# --- Pin/Unpin Posts ---
+
+
+@router.post("/pin/{post_id}")
+async def pin_post(
+    post_id: uuid.UUID,
+    current_entity: Entity = Depends(get_current_entity),
+    db: AsyncSession = Depends(get_db),
+):
+    """Pin a post in its submolt. Requires submolt moderator/owner role."""
+    post = await db.get(Post, post_id)
+    if post is None:
+        raise HTTPException(status_code=404, detail="Post not found")
+    if post.submolt_id is None:
+        raise HTTPException(
+            status_code=400,
+            detail="Only submolt posts can be pinned",
+        )
+
+    # Check submolt role
+    membership = await db.scalar(
+        select(SubmoltMembership).where(
+            SubmoltMembership.submolt_id == post.submolt_id,
+            SubmoltMembership.entity_id == current_entity.id,
+        )
+    )
+    if not membership or membership.role not in ("owner", "moderator"):
+        raise HTTPException(
+            status_code=403,
+            detail="Must be a submolt moderator or owner to pin posts",
+        )
+
+    post.is_pinned = not post.is_pinned
+    await db.flush()
+    return {
+        "post_id": str(post_id),
+        "is_pinned": post.is_pinned,
+    }

src/api/submolt_router.py

@@ -78,6 +78,8 @@ class SubmoltFeedPost(BaseModel):
     author_type: str
     vote_count: int
     reply_count: int
+    is_pinned: bool = False
+    flair: str | None = None
     user_vote: str | None = None
     created_at: str
 
@@ -446,7 +448,9 @@ async def get_submolt_feed(
         query = query.where(Post.id < cursor_id)
 
     query = query.order_by(
-        Post.created_at.desc(), Post.id.desc()
+        Post.is_pinned.desc(),
+        Post.created_at.desc(),
+        Post.id.desc(),
     ).limit(limit + 1)
 
     result = await db.execute(query)
@@ -490,6 +494,8 @@ async def get_submolt_feed(
             author_type=author.type.value,
             vote_count=post.vote_count,
             reply_count=reply_counts.get(post.id, 0),
+            is_pinned=post.is_pinned or False,
+            flair=post.flair,
             user_vote=user_votes.get(post.id),
             created_at=post.created_at.isoformat(),
         ))

src/models.py

@@ -168,7 +168,9 @@ class Post(Base):
     )
     is_hidden = Column(Boolean, default=False)
     is_edited = Column(Boolean, default=False)
+    is_pinned = Column(Boolean, default=False)
     edit_count = Column(Integer, default=0)
+    flair = Column(String(50), nullable=True)  # e.g. "discussion", "question", "announcement"
 
     vote_count = Column(Integer, default=0)  # denormalized for feed performance