Function fetch

apps/collab/src/index.ts:251–320

({ documentName })

  extensions: [
    new Database({
      async fetch({ documentName }) {
        const boardUuid = extractBoardUuid(documentName)
        if (!boardUuid) return null

        // 1. Try Redis first
        try {
          const r = getRedis()
          const cached = await r.getBuffer(redisYdocKey(boardUuid))
          if (cached && cached.byteLength > 0) {
            console.log(
              `[collab] Redis hit for ${boardUuid}: ${cached.byteLength} bytes`,
            )
            return new Uint8Array(cached)
          }
        } catch (err) {
          console.error(
            `[collab] Redis fetch error for ${boardUuid}:`,
            err,
          )
        }

        // 2. Fall back to database (with timeout)
        try {
          const url = `${API_URL}/api/v1/boards/${boardUuid}/ydoc`
          console.log(`[collab] Fetching ydoc from DB for ${boardUuid}`)
          const response = await fetchWithTimeout(url, {
            headers: {
              'X-Internal-Key': INTERNAL_KEY,
            },
          })

          if (!response.ok) {
            console.error(
              `[collab] Failed to fetch ydoc for ${boardUuid}: ${response.status} ${response.statusText}`,
            )
            return null
          }

          const buffer = await response.arrayBuffer()
          if (buffer.byteLength === 0) return null

          const state = new Uint8Array(buffer)
          console.log(
            `[collab] Fetched ydoc from DB for ${boardUuid}: ${buffer.byteLength} bytes`,
          )

          // Warm the Redis cache
          try {
            const r = getRedis()
            await r.setex(
              redisYdocKey(boardUuid),
              REDIS_YDOC_TTL,
              Buffer.from(state),
            )
          } catch (err) {
            console.error(
              `[collab] Redis warm error for ${boardUuid}:`,
              err,