NBizyaev/mqtt-ingest
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add mapper. add v2 handler. add tag description short and full versions. delete topic[1-5]. #5

Merged
APervov merged 5 commits from edge5modbus into main 2026-06-19 06:15:29 +00:00
Conversation 22 Commits 5 Files Changed 17 +7 -18
2 changed files with 7 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 10dbdb2120 - Show all commits

5
app/package.json
View File

@@ -3,10 +3,9 @@
"private": true, "private": true,
"type": "module", "type": "module",
"scripts": { "scripts": {
"dev": "node --env-file-if-exists=.env ./node_modules/tsx/dist/cli.mjs watch src/index.ts", "dev": "tsx watch --env-file=.env src/index.ts",
"start": "node --env-file-if-exists=.env ./node_modules/tsx/dist/cli.mjs src/index.ts",
"build": "tsc", "build": "tsc",
"typecheck": "tsc --noEmit" "start": "node --env-file=.env dist/index.js"
}, },
"dependencies": { "dependencies": {
"@types/node": "^25.9.1", "@types/node": "^25.9.1",

20
app/src/cloud-ingest.ts
View File

@@ -1,25 +1,15 @@
const DEFAULT_CLOUD_INGEST_URL = 'http://localhost:3100/ingest' const DEFAULT_CLOUD_INGEST_URL = 'http://localhost:3101/ingest'
NBizyaev commented 2026-06-19 05:50:16 +00:00
Review
Copy Link

Значения по умолчанию для переменных окружения должны быть вынесены в отдельный модуль валидации значений переменных окружения.

Значение переменной CLOUD_INGEST_URL является критическим для такого сервиса как mqtt-ingest, при не указанном значении CLOUD_INGEST_URL сервис не сможет отправлять данные, а значит - выполнять свою функцию, а значит в случае отсутствия значения CLOUD_INGEST_URL - приложение при старте должно ругнуться и не запуститься вовсе, чтобы при деплое на продакшн, это сразу было заметно.

Значения по умолчанию для переменных окружения должны быть вынесены в отдельный модуль валидации значений переменных окружения. Значение переменной CLOUD_INGEST_URL является критическим для такого сервиса как mqtt-ingest, при не указанном значении CLOUD_INGEST_URL сервис не сможет отправлять данные, а значит - выполнять свою функцию, а значит в случае отсутствия значения CLOUD_INGEST_URL - приложение при старте должно ругнуться и не запуститься вовсе, чтобы при деплое на продакшн, это сразу было заметно.
export const cloudIngestUrl = export const cloudIngestUrl =
process.env.CLOUD_INGEST_URL ?? DEFAULT_CLOUD_INGEST_URL process.env.CLOUD_INGEST_URL ?? DEFAULT_CLOUD_INGEST_URL
function getHeaders(): Record<string, string> {
const headers: Record<string, string> = {
'content-type': 'application/json',
}
const apiKey = process.env.CLOUD_INGEST_API_KEY?.trim()
if (apiKey) {
headers['x-api-key'] = apiKey
}
return headers
}
export function postCloudIngest(body: unknown): Promise<Response> { export function postCloudIngest(body: unknown): Promise<Response> {
NBizyaev marked this conversation as resolved
NBizyaev commented 2026-06-17 06:56:16 +00:00
Review
Copy Link

function getHeaders(): Record<string, string> {
return {
'content-type': 'application/json',
'x-api-key': process.env.CLOUD_INGEST_API_KEY
}
}

function getHeaders(): Record<string, string> { return { 'content-type': 'application/json', 'x-api-key': process.env.CLOUD_INGEST_API_KEY } }
return fetch(cloudIngestUrl, { return fetch(cloudIngestUrl, {
method: 'POST', method: 'POST',
headers: getHeaders(), headers: {
'content-type': 'application/json',
'x-api-key': process.env.CLOUD_INGEST_API_KEY as string,
},
body: JSON.stringify(body), body: JSON.stringify(body),
}) })
} }