chore: refresh worker docs and source defaults

Author: minkinad

README.md

@@ -1,73 +1,63 @@
 # processing-worker
 
-![CI](https://img.shields.io/badge/CI-GitHub_Actions-2088FF?logo=githubactions&logoColor=white)
-![CD](https://img.shields.io/badge/CD-GitHub_Deploy-2ea44f?logo=github&logoColor=white)
-![Container](https://img.shields.io/badge/Container-GHCR-2496ED?logo=docker&logoColor=white)
+Сервис нормализации и ingest для пайплайна NPPWEB.
 
-Сервис асинхронной обработки и нормализации собранных данных.
-
-## Что делает этот репозиторий
+## Что делает
 
 - читает `source.raw.v1` из RabbitMQ;
 - валидирует raw-события;
 - нормализует payload до формата `source.normalized.v1`;
-- отправляет ingest mutation `ingestNormalizedItem` в `backend-api` с заголовком `x-ingest-token`;
-- после успешного ingest публикует нормализованные события в `source.normalized.v1`;
-- при transient ошибках отправляет сообщение в retry queue, а poison messages складывает в DLQ.
-
-## Черновая реализация
-
-- consumer RabbitMQ (`src/messaging/queue-client.ts`);
-- нормализатор (`src/normalize.ts`);
-- валидация raw/normalized схем через Ajv;
-- GraphQL-клиент отправки в backend (`src/backend-client.ts`);
-- Dockerfile и CI workflow.
+- отправляет `ingestNormalizedItem` в `npp-backend` с заголовком `x-ingest-token`;
+- публикует успешные нормализованные события в `source.normalized.v1`;
+- при transient ошибках использует retry queue, а poison messages отправляет в DLQ.
 
 ## Переменные окружения
 
-- `RABBITMQ_URL` - адрес RabbitMQ.
-- `QUEUE_RAW_EVENT` - основная очередь входящих raw-событий, по умолчанию `source.raw.v1`.
-- `QUEUE_RETRY_EVENT` - очередь retry, по умолчанию `source.raw.retry.v1`.
-- `QUEUE_DEAD_LETTER_EVENT` - очередь dead-letter, по умолчанию `source.raw.dlq.v1`.
-- `QUEUE_NORMALIZED_EVENT` - очередь нормализованных событий, по умолчанию `source.normalized.v1`.
-- `API_BASE_URL` - базовый URL `backend-api`, по умолчанию `http://localhost:3000`.
-- `GRAPHQL_PATH` - GraphQL path, по умолчанию `/graphql`.
-- `API_GRAPHQL_URL` - явный GraphQL URL. Если задан, имеет приоритет над `API_BASE_URL + GRAPHQL_PATH`.
-- `API_INGEST_TOKEN` - токен для заголовка `x-ingest-token`. Должен совпадать с `INGEST_API_TOKEN` в `backend-api`.
-- `SHARED_CONTRACTS_DIR` - путь к `shared-contracts`.
-- `RETRY_ATTEMPTS`, `RETRY_BASE_DELAY_MS`, `PREFETCH`, `LOG_LEVEL` - параметры обработки и логирования.
+- `RABBITMQ_URL`
+- `QUEUE_RAW_EVENT`
+- `QUEUE_RETRY_EVENT`
+- `QUEUE_DEAD_LETTER_EVENT`
+- `QUEUE_NORMALIZED_EVENT`
+- `API_BASE_URL`
+- `GRAPHQL_PATH`
+- `API_GRAPHQL_URL`
+- `API_INGEST_TOKEN`
+- `SHARED_CONTRACTS_DIR`
+- `RETRY_ATTEMPTS`
+- `RETRY_BASE_DELAY_MS`
+- `PREFETCH`
+
+По умолчанию `SHARED_CONTRACTS_DIR` указывает на `../contracts`.
 
 ## Локальный запуск
 
 ```bash
+cd ../infra
 cp .env.example .env
+docker compose --env-file .env -f docker-compose.yml -f docker-compose.apps.yml up -d rabbitmq backend-api
+
+cd ../processing-worker
 npm install
 npm run start:dev
 ```
 
-Для Docker Compose сервис ожидает:
-
-- RabbitMQ на `RABBITMQ_URL`;
-- `backend-api` на `API_BASE_URL` или `API_GRAPHQL_URL`;
-- смонтированный `shared-contracts` в `SHARED_CONTRACTS_DIR`.
-
 ## Ожидаемые очереди
 
-- `source.raw.v1` - входящие события.
-- `source.raw.retry.v1` - delayed retry queue.
-- `source.raw.dlq.v1` - dead-letter queue.
-- `source.normalized.v1` - успешно обработанные нормализованные события.
+- `source.raw.v1`
+- `source.raw.retry.v1`
+- `source.raw.dlq.v1`
+- `source.normalized.v1`
 
-## Как проверить обработку
+## Проверка качества
 
-1. Опубликуй валидное сообщение в `source.raw.v1`.
-2. В логах worker должны появиться строки `connected to rabbitmq`, `consuming queue`, `raw event validated`, `normalized event created`, `ingest success`, `published normalized event`, `message acknowledged`.
-3. Проверь, что сообщение появилось в `source.normalized.v1`, а запись создалась в `backend-api`.
-4. Для transient ошибки временно выключи `backend-api`: worker должен логировать `ingest failed` и `retry scheduled`, а не падать.
-5. Для poison message отправь невалидный JSON или payload, нарушающий schema: worker должен логировать `message dead-lettered`, сообщение должно уйти в `source.raw.dlq.v1`.
+```bash
+npm run check
+npm run test
+npm run build
+```
 
-## Связи с другими репозиториями
+## Связи
 
-- получает события от `scraper-service`;
-- использует схемы из `shared-contracts`;
-- отправляет результаты в `backend-api`.
+- получает события от `scrape-helper`;
+- использует схемы из `contracts`;
+- отправляет результаты в `npp-backend`.

package.json

@@ -2,7 +2,7 @@
   "name": "processing-worker",
   "version": "1.0.0",
   "private": true,
-  "description": "Production-ready normalization worker for AIMSORA with retry/DLQ handling and strict contract validation.",
+  "description": "Production-ready normalization worker for NPPWEB with retry/DLQ handling and strict contract validation.",
   "scripts": {
     "build": "tsc -p tsconfig.json",
     "start": "node dist/main.js",

src/config.ts

@@ -11,7 +11,7 @@ const envSchema = z.object({
   QUEUE_RETRY_EVENT: z.string().default("source.raw.retry.v1"),
   QUEUE_DEAD_LETTER_EVENT: z.string().default("source.raw.dlq.v1"),
   QUEUE_NORMALIZED_EVENT: z.string().default("source.normalized.v1"),
-  SHARED_CONTRACTS_DIR: z.string().default("../shared-contracts"),
+  SHARED_CONTRACTS_DIR: z.string().default("../contracts"),
   RETRY_ATTEMPTS: z.coerce.number().int().positive().default(5),
   RETRY_BASE_DELAY_MS: z.coerce.number().int().positive().default(5000),
   PREFETCH: z.coerce.number().int().positive().default(10)

src/normalize.spec.ts

@@ -3,59 +3,6 @@ import { normalizeRawEvent } from "./normalize";
 import type { RawSourceEvent } from "./types";
 
 describe("normalizeRawEvent", () => {
-  it("normalizes demo-source payload", () => {
-    const input: RawSourceEvent = {
-      eventId: "evt-1",
-      runKey: "demo-run",
-      source: "demo-source",
-      collectedAt: "2026-03-30T10:00:00.000Z",
-      url: "https://example.org",
-      payloadVersion: "v1",
-      artifacts: [],
-      raw: {
-        externalId: "demo-1",
-        title: "Поставка оборудования",
-        customer: "АО Демонстрационная АЭС",
-        amount: 1200
-      }
-    };
-
-    const normalized = normalizeRawEvent(input);
-
-    expect(normalized.externalId).toBe("demo-1");
-    expect(normalized.title).toBe("Поставка оборудования");
-    expect(normalized.customer).toBe("АО Демонстрационная АЭС");
-    expect(normalized.amount).toBe(1200);
-    expect(normalized.sourceUrl).toBe("https://example.org");
-  });
-
-  it("normalizes find-tender payload using ocid", () => {
-    const input: RawSourceEvent = {
-      eventId: "evt-2",
-      runKey: "find-tender-run",
-      source: "find-tender",
-      collectedAt: "2026-03-30T10:00:00.000Z",
-      url: "https://www.find-tender.service.gov.uk/Notice/008889-2026",
-      payloadVersion: "v1",
-      artifacts: [],
-      raw: {
-        ocid: "ocds-h6vhtk-061410",
-        title: "E-Disclosure Services",
-        buyer: "Care Quality Commission",
-        supplier: "KLDISCOVERY LIMITED",
-        amount: 150000,
-        currency: "GBP"
-      }
-    };
-
-    const normalized = normalizeRawEvent(input);
-
-    expect(normalized.externalId).toBe("ocds-h6vhtk-061410");
-    expect(normalized.title).toBe("E-Disclosure Services");
-    expect(normalized.customer).toBe("Care Quality Commission");
-    expect(normalized.sourceUrl).toContain("find-tender.service.gov.uk");
-  });
-
   it("normalizes eis payload using procurement-specific fields", () => {
     const input: RawSourceEvent = {
       eventId: "evt-3",