From 3c94cd92c11fa41544f0b21130bdd684055f5130 Mon Sep 17 00:00:00 2001
From: Nikita Biziaev <cap7goo@gmail.com>
Date: Sun, 5 Jul 2026 18:54:33 +0500
Subject: [PATCH] clone data for demo/dev env

---
 app/src/cloud-ingest.ts             | 12 ++++++++++++
 app/src/handlers/edge5-modbus-v3.ts |  5 ++++-
 2 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/app/src/cloud-ingest.ts b/app/src/cloud-ingest.ts
index abd18bc..b35f7f2 100644
--- a/app/src/cloud-ingest.ts
+++ b/app/src/cloud-ingest.ts
@@ -1,4 +1,5 @@
 export const cloudIngestUrl = process.env.CLOUD_INGEST_URL as string
+export const demoCloudIngestUrl = process.env.DEMO_CLOUD_INGEST_URL as string
 
 export function postCloudIngest(body: unknown): Promise<Response> {
   return fetch(cloudIngestUrl, {
@@ -10,3 +11,14 @@ export function postCloudIngest(body: unknown): Promise<Response> {
     body: JSON.stringify(body),
   })
 }
+
+export function postDemoCloudIngest(body: unknown): Promise<Response> {
+  return fetch(demoCloudIngestUrl, {
+    method: 'POST',
+    headers: {
+      'content-type': 'application/json',
+      'x-api-key': process.env.CLOUD_INGEST_API_KEY as string,
+    },
+    body: JSON.stringify(body),
+  })
+}
diff --git a/app/src/handlers/edge5-modbus-v3.ts b/app/src/handlers/edge5-modbus-v3.ts
index 314e99f..42eee96 100644
--- a/app/src/handlers/edge5-modbus-v3.ts
+++ b/app/src/handlers/edge5-modbus-v3.ts
@@ -1,4 +1,4 @@
-import { postCloudIngest } from '../cloud-ingest.js'
+import { postCloudIngest, postDemoCloudIngest } from '../cloud-ingest.js'
 import { log } from '../helpers/log.js'
 import type { TopicHandler } from '../types.js'
 
@@ -97,6 +97,9 @@ async function postMetrics(metrics: Edge5ModbusV3Metric[]): Promise<void> {
         const text = await response.text()
         throw new Error(text || `${response.status} ${response.statusText}`)
       }
+
+      void postDemoCloudIngest(metric); // для демо-системы
+
     } catch (error) {
       const message = error instanceof Error ? error.message : String(error)
       errors.push(new Error(`${metric.tag}: ${message}`))