소셜 플랫폼 아키텍처: 피드/팔로우/알림

[User] 사용자
- profile, followers, following

[Post] 게시물
- text, media, hashtags, mentions

[Feed] 피드 (홈 타임라인)
- 자신 + 팔로잉 게시물

[Engagement] 참여
- like, comment, share, save

[Notification] 알림
- new follower, mention, reply, like

[Discovery] 탐색
- explore, trending, search

읽기 : 쓰기 = 100 : 1

[쓰기]
- 새 게시물: 분당 수백 건

[읽기]
- 피드 조회: 분당 수만 건
- 게시물 상세: 분당 수십만


→ 읽기 최적화 우선
→ 캐시 + CDN 적극

CREATE TABLE users (
  id UUID PRIMARY KEY,
  handle VARCHAR UNIQUE NOT NULL,    -- @alice
  name VARCHAR NOT NULL,
  bio TEXT,
  avatar_url VARCHAR,
  followers_count INT DEFAULT 0,     -- 비정규화 (캐시)
  following_count INT DEFAULT 0,
  posts_count INT DEFAULT 0,
  created_at TIMESTAMP DEFAULT NOW()
);

CREATE TABLE follows (
  follower_id UUID NOT NULL,
  followed_id UUID NOT NULL,
  created_at TIMESTAMP DEFAULT NOW(),
  PRIMARY KEY (follower_id, followed_id)
);

CREATE INDEX ON follows(followed_id, created_at DESC);
CREATE INDEX ON follows(follower_id, created_at DESC);


CREATE TABLE posts (
  id UUID PRIMARY KEY,
  user_id UUID NOT NULL,
  content TEXT,
  media JSONB,                       -- [{ url, type, ... }]
  parent_id UUID REFERENCES posts(id),  -- reply
  quote_id UUID REFERENCES posts(id),   -- quote post
  visibility VARCHAR DEFAULT 'public', -- public, followers, private
  likes_count INT DEFAULT 0,
  comments_count INT DEFAULT 0,
  shares_count INT DEFAULT 0,
  created_at TIMESTAMP DEFAULT NOW(),
  deleted_at TIMESTAMP
);

CREATE INDEX ON posts(user_id, created_at DESC) WHERE deleted_at IS NULL;
CREATE INDEX ON posts(parent_id) WHERE parent_id IS NOT NULL;

async function followUser(followerId: string, followedId: string) {
  if (followerId === followedId) {
    throw new BadRequestError('Cannot follow yourself');
  }

  return db.$transaction(async (tx) => {
    // 차단된 사용자인가?
    const blocked = await tx.block.findFirst({
      where: {
        OR: [
          { blockerId: followedId, blockedId: followerId },
          { blockerId: followerId, blockedId: followedId },
        ],
      },
    });
    if (blocked) throw new ForbiddenError('Blocked');

    await tx.follow.create({
      data: { followerId, followedId },
    });

    await tx.user.update({
      where: { id: followedId },
      data: { followersCount: { increment: 1 } },
    });
    await tx.user.update({
      where: { id: followerId },
      data: { followingCount: { increment: 1 } },
    });

    // 알림
    await notify({
      userId: followedId,
      type: 'new_follower',
      title: '새 팔로워',
      body: `@${followerHandle}님이 팔로우했습니다`,
      link: `/users/${followerHandle}`,
    });
  });
}

[Pull Model] (요청 시 계산)
- 피드 = 팔로잉 사용자의 최근 게시물 SELECT
- 쓰기 비용 0
- 읽기 비용 큼 (팔로잉 수 비례)

[Push Model] (Fan-out on write)
- 게시물 작성 시 모든 팔로워의 피드 캐시에 추가
- 읽기 빠름 (캐시만 조회)
- 쓰기 비용 큼 (팔로워 수 비례)


[Hybrid] (Twitter 방식)
- 일반 사용자: Push
- 메가 인플루언서 (팔로워 수만+): Pull
- 둘을 합쳐서 피드 구성