@@ -0,0 +13,4 @@
+}
+
+type DemoPlcMetric = DemoPlcPayload & {
+  edge: string

@@ -0,0 +18,4 @@
+}
+
+function isDemoPlcPayload(value: unknown): value is DemoPlcPayload {
+  if (!value || typeof value !== 'object') {

@@ -0,0 +25,4 @@
+  const candidate = value as Partial<DemoPlcPayload>
+
+  return (
+    typeof candidate.tag === 'string' &&

@@ -0,0 +51,4 @@
+  })
+
+  if (!response.ok) {
+    const text = await response.text()

@@ -0,0 +75,4 @@
+    return
+  }
+
+  if (!isDemoPlcPayload(value)) {

@@ -0,0 +42,4 @@
+  })
+
+  if (!response.ok) {
+    const text = await response.text()

@@ -0,0 +68,4 @@
+
+  let value: unknown
+
+  try {

@@ -0,0 +59,4 @@
+
+  let values: number[]
+
+  try {

@@ -0,0 +26,4 @@
+  filePath: string | URL
+}
+
+function resolveMappingPath(filePath: string | URL): string {

@@ -0,0 +38,4 @@
+  const resolvedPath = resolveMappingPath(filePath)
+  let raw: unknown
+
+  try {

@@ -0,0 +59,4 @@
+  const candidate = value as Partial<MappingConfig>
+
+  return (
+    typeof candidate.edge === 'string' &&

@@ -0,0 +67,4 @@
+  )
+}
+
+function isMappingTagEntry(value: unknown): value is MappingTagEntry {

@@ -0,0 +79,4 @@
+  )
+}
+
+function getTag(entry: MappingTagEntry): string {

@@ -0,0 +95,4 @@
+    edge: config.edge,
+    tagCount: tags.length,
+    mapValues: (values, timestamp) => {
+      if (values.length !== tags.length) {

@@ -0,0 +39,4 @@
+  let raw: unknown
+
+  try {
+    raw = JSON.parse(readFileSync(resolvedPath, 'utf8')) as unknown

@@ -0,0 +15,4 @@
+function parseValues(payload: Buffer): number[] {
+  let value: unknown
+
+  try {

@@ -0,0 +3,4 @@
+export const cloudIngestUrl =
+  process.env.CLOUD_INGEST_URL ?? DEFAULT_CLOUD_INGEST_URL
+
+function getHeaders(): Record<string, string> {

@@ -0,0 +19,4 @@
+export function postCloudIngest(body: unknown): Promise<Response> {
+  return fetch(cloudIngestUrl, {
+    method: 'POST',
+    headers: getHeaders(),

@@ -5,3 +5,2 @@
   "scripts": {
-    "dev": "tsx watch src/index.ts",
-    "start": "tsx src/index.ts",
+    "dev": "node --env-file-if-exists=.env ./node_modules/tsx/dist/cli.mjs watch src/index.ts",

@@ -6,2 +6,2 @@
-    "dev": "tsx watch src/index.ts",
-    "start": "tsx src/index.ts",
+    "dev": "node --env-file-if-exists=.env ./node_modules/tsx/dist/cli.mjs watch src/index.ts",
+    "start": "node --env-file-if-exists=.env ./node_modules/tsx/dist/cli.mjs src/index.ts",

@@ -7,2 +6,3 @@
-    "start": "tsx src/index.ts",
+    "dev": "node --env-file-if-exists=.env ./node_modules/tsx/dist/cli.mjs watch src/index.ts",
+    "start": "node --env-file-if-exists=.env ./node_modules/tsx/dist/cli.mjs src/index.ts",
     "build": "tsc",

@@ -0,0 +1,15 @@
+const DEFAULT_CLOUD_INGEST_URL = 'http://localhost:3101/ingest'