# Prism

Prism是一个用于gmstn的[ATProto](https://atproto.com/) AppView服务。它从[TAP](https://docs.bsky.app/blog/introducing-tap)消费事件，并将其存储/缓存以供将来检索，这样查询就不会对其他PDS造成太大负担。

<a href="https://docs.bsky.app/docs/advanced-guides/federation-architecture#app-views">
    <img src="./assets/prism-appview-concept.png" width="400" alt="appview-prism-pinkfloyd"/>
</a>

Prism实现了用于访问缓存feed的XRPC端点。Lexicon定义可以在`lexicons/`目录中找到。

## 架构

```
ATProto Relay  →  TAP (backfill + firehose)  →  Prism (Rust/Axum)  →  PostgreSQL
                                                      ↓
                                               XRPC API + WebSocket
```

## 本地运行

### 前置条件

Rust, docker/podman

### 快速开始

1. 启动数据库:

```bash
docker compose up postgres tap
# or
podman-compose up postgres tap
```

2. 运行数据库迁移:

```bash
export DATABASE_URL=postgres://postgres:postgres@localhost:5432/prism
cargo sqlx migrate run --source migrations
```

3. 运行开发服务器:

```bash
cargo run
```

服务将在 http://localhost:3000 上可用

### 完整堆栈 (包含TAP)

```bash
docker compose up
```

这将启动:
- PostgreSQL 端口 5432
- TAP 端口 8080 (HTTP) 和 2480 (WebSocket)
- Prism 端口 3000

## API端点

| 端点 | 描述 |
|----------|-------------|
| `GET /xrpc/systems.gmstn.development.channel.listChannels?author=<did>` | 按作者列出频道 |
| `GET /xrpc/systems.gmstn.development.channel.listInvites?recipient=<did>` | 按接收者列出邀请 |
| `GET /xrpc/systems.gmstn.development.channel.listMemberships?recipient=<did>` | 按接收者列出成员资格 |
| `GET /xrpc/systems.gmstn.development.lattice.listLattices?author=<did>` | 按作者列出晶格 |
| `GET /xrpc/systems.gmstn.development.shard.listShards?author=<did>` | 按作者列出碎片 |
| `WS /ws` | 用于实时记录更新的WebSocket |

所有列表端点都支持`limit`（1-100，默认50）和`cursor`（ISO8601时间戳）参数。

## 配置

环境变量:

| 变量 | 默认值 | 描述 |
|----------|---------|-------------|
| `DATABASE_URL` | `postgres://postgres:postgres@localhost:5432/prism` | PostgreSQL连接字符串 |
| `TAP_WS_URL` | `ws://localhost:2480/channel` | TAP WebSocket URL |
| `HOST` | `0.0.0.0` | 服务器绑定地址 |
| `PORT` | `3000` | 服务器端口 |
| `RUST_LOG` | `prism=info` | 日志级别 |

## 开发

```bash
# 检查代码
cargo check

# 运行测试
cargo test

# 准备sqlx离线缓存（需要运行中的数据库）
cargo sqlx prepare
```