Сетевые вызовы в Node.js с помощью Got

Как отправить POST запрос с JSON телом?

Для отправки данных методом POST используется опция json или body. Got автоматически устанавливает заголовок Content-Type: application/json при указании json.

import got from 'got';

async function createPost() {
  try {
    const response = await got.post('https://jsonplaceholder.typicode.com/posts', {
      json: {
        title: 'Новая запись',
        body: 'Текст записи',
        userId: 1
      }
    });
    console.log('Статус:', response.statusCode); // 201
    console.log('Создан:', response.body);
  } catch (error) {
    console.error('Ошибка POST:', error.message);
  }
}

createPost();

Если сервер ожидает другой формат (например, form-data), используйте опцию form или укажите body вручную с соответствующим Content-Type.

Как обрабатывать HTTP ошибки (4xx/5xx) и сетевые ошибки отдельно?

Got разделяет ошибки по типам. Для HTTP статусов генерируется HTTPError, для превышения таймаута — TimeoutError, для сетевых — RequestError. Каждую можно проверить через instanceof.

import got, { HTTPError, TimeoutError } from 'got';

async function safeRequest(url) {
  try {
    const response = await got(url);
    return response.body;
  } catch (error) {
    if (error instanceof HTTPError) {
      console.error('HTTP ошибка:', error.response.statusCode, error.response.body);
    } else if (error instanceof TimeoutError) {
      console.error('Таймаут запроса');
    } else {
      console.error('Сетевая ошибка:', error.message);
    }
    throw error;
  }
}

safeRequest('https://example.com/api');

Как скачать файл через потоки, не загружая его целиком в память?

Got предоставляет метод .stream(), который возвращает ReadableStream. Его можно направить в файл через fs.createWriteStream. Это эффективно для больших файлов.

import got from 'got';
import fs from 'fs';
import path from 'path';

const url = 'https://example.com/bigfile.zip';
const destination = path.resolve('download.zip');

const downloadStream = got.stream(url);
const fileStream = fs.createWriteStream(destination);

downloadStream.on('error', (err) => {
  console.error('Ошибка загрузки:', err.message);
});

fileStream.on('error', (err) => {
  console.error('Ошибка записи:', err.message);
});

fileStream.on('finish', () => {
  console.log('Файл успешно загружен:', destination);
});

downloadStream.pipe(fileStream);

Можно также использовать события .on('downloadProgress') для отслеживания прогресса.

Как добавить перехватчики (hooks) для логирования или модификации запроса?

Перехватчики позволяют вмешиваться в жизненный цикл запроса. С помощью got.extend() создается экземпляр с хуками beforeRequest, afterResponse и другими.

import got from 'got';

const client = got.extend({
  hooks: {
    beforeRequest: [
      (options) => {
        console.log('Запрос к:', options.url.href);
      }
    ],
    afterResponse: [
      (response) => {
        console.log('Статус ответа:', response.statusCode);
        return response;
      }
    ]
  }
});

async function testHook() {
  const response = await client.get('https://jsonplaceholder.typicode.com/todos/1');
  console.log('Результат:', response.body);
}

testHook();

Хуки можно комбинировать: добавлять авторизацию, изменять тело запроса, ретраить запросы при ошибках.

Как создать кастомный клиент с общими настройками (базовый URL, заголовки)?

got.extend() создаёт новый экземпляр с переопределёнными параметрами. Это удобно для работы с одним API.

import got from 'got';

const apiClient = got.extend({
  prefixUrl: 'https://api.example.com/v1',
  headers: {
    'Authorization': 'Bearer токен_доступа',
    'Accept': 'application/json'
  },
  timeout: {
    request: 5000
  },
  retry: {
    limit: 2
  }
});

async function getUser(id) {
  const response = await apiClient.get(`users/${id}`);
  return response.body;
}

getUser(42).then(console.log).catch(console.error);

Такой подход сокращает дублирование кода и централизует настройки.