> ## Documentation Index
> Fetch the complete documentation index at: https://docs.orbitflare.com/llms.txt
> Use this file to discover all available pages before exploring further.

# Быстрый старт Yellowstone

> Установите gRPC-клиент, подключитесь к OrbitFlare и отправьте первую подписку

## Предварительные требования

Вам понадобится:

* Node.js 18+ (или среда Rust для Rust-клиента)
* URL эндпоинта gRPC OrbitFlare и токен (доступны в разделе **Лицензии** вашей [Панели управления](https://orbitflare.com/dashboard))

## Установка

Установите официальный TypeScript-клиент Yellowstone gRPC:

```bash theme={null}
npm install @triton-one/yellowstone-grpc
```

Или через yarn:

```bash theme={null}
yarn add @triton-one/yellowstone-grpc
```

## Подключение к эндпоинту

```typescript theme={null}
import Client, { CommitmentLevel, SubscribeRequest } from "@triton-one/yellowstone-grpc";

const GRPC_URL = "https://your-endpoint.grpc.orbitflare.com";
const X_TOKEN = "YOUR_GRPC_TOKEN";

const client = new Client(GRPC_URL, X_TOKEN, {
  "grpc.max_receive_message_length": 64 * 1024 * 1024, // 64 МиБ
});
```

<Note>
  URL gRPC и токен находятся в разделе **Лицензии** Панели управления OrbitFlare. Токен передаётся вторым аргументом в `new Client()`.
</Note>

## Открытие потока

```typescript theme={null}
const stream = await client.subscribe();

const streamClosed = new Promise<void>((resolve, reject) => {
  stream.on("error", (error) => {
    console.error("Ошибка потока:", error);
    reject(error);
    stream.end();
  });
  stream.on("end", () => resolve());
  stream.on("close", () => resolve());
});

stream.on("data", (data) => {
  if (data.slot) {
    console.log("Обновление слота:", data.slot.slot);
  } else if (data.transaction) {
    console.log("Транзакция:", data.transaction);
  } else if (data.account) {
    console.log("Обновление аккаунта:", data.account);
  } else if (data.pong) {
    console.log("Получен pong");
  }
});
```

## Отправка первой подписки

Подписка на все обновления слотов на уровне подтверждения `confirmed`:

```typescript theme={null}
const subscribeRequest: SubscribeRequest = {
  slots: {
    slot: { filterByCommitment: true },
  },
  commitment: CommitmentLevel.CONFIRMED,
  accounts: {},
  accountsDataSlice: [],
  transactions: {},
  transactionsStatus: {},
  blocks: {},
  blocksMeta: {},
  entry: {},
};

await new Promise<void>((resolve, reject) => {
  stream.write(subscribeRequest, (err) => {
    if (err == null) resolve();
    else reject(err);
  });
});

await streamClosed;
```

## Поддержание соединения

Облачные балансировщики нагрузки завершают незанятые соединения gRPC примерно через 10 минут. Отправляйте ping каждые 30 секунд:

```typescript theme={null}
const pingRequest: SubscribeRequest = {
  ping: { id: 1 },
  accounts: {},
  accountsDataSlice: [],
  transactions: {},
  transactionsStatus: {},
  blocks: {},
  blocksMeta: {},
  slots: {},
  entry: {},
};

const pingInterval = setInterval(async () => {
  await new Promise<void>((resolve, reject) => {
    stream.write(pingRequest, (err) => {
      if (err == null) resolve();
      else reject(err);
    });
  });
}, 30_000);

streamClosed.finally(() => clearInterval(pingInterval));
```

## Автоматическое переподключение

Для production-приложений реализуйте автоматическое переподключение с экспоненциальной задержкой:

```typescript theme={null}
async function connectWithRetry(maxRetries = 10) {
  let attempt = 0;
  let delay = 1000;

  while (attempt < maxRetries) {
    try {
      const stream = await client.subscribe();
      // ... подключить обработчики и отправить подписку
      await streamClosed;
      break;
    } catch (err) {
      attempt++;
      console.error(`Ошибка потока (попытка ${attempt}):`, err);
      if (attempt >= maxRetries) throw err;
      await new Promise((r) => setTimeout(r, delay));
      delay = Math.min(delay * 2, 30_000);
    }
  }
}
```

## Следующие шаги

<CardGroup cols={2}>
  <Card title="Мониторинг аккаунтов" icon="user" href="/ru/data-streaming/yellowstone-account-monitoring">
    Потоковая передача балансов токенов, изменений кошельков и обновлений программных аккаунтов.
  </Card>

  <Card title="Мониторинг транзакций" icon="receipt" href="/ru/data-streaming/yellowstone-transaction-monitoring">
    Фильтрация и обработка живых транзакций по программе или аккаунту.
  </Card>

  <Card title="Слоты и блоки" icon="cube" href="/ru/data-streaming/yellowstone-slot-block-monitoring">
    Отслеживание прогресса консенсуса и полных данных блоков.
  </Card>

  <Card title="Мониторинг записей" icon="code" href="/ru/data-streaming/yellowstone-entry-monitoring">
    Доступ к низкоуровневым записям блоков.
  </Card>
</CardGroup>