feat: disable venue header in ws connection, separate alerts

Author: lniepala

CHANGELOG.md

@@ -5,6 +5,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [2.6.1] - 2025-08-21
+
+- Fix: disable venue header in ws connection
+
 ## [2.6.0] - 2025-07-25
 
 - Feat: device code authorization support

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@orderingstack/pos-integrator-core",
-  "version": "2.6.0",
+  "version": "2.6.1",
   "description": "Ordering Stack POS integrator core - library for easy developing POS integrations with Ordering Stack platform.",
   "scripts": {
     "test": "jest",

src/alerts.ts

@@ -0,0 +1,44 @@
+import axios from 'axios';
+
+export enum AlertSeverity {
+  DEBUG,
+  INFO,
+  WARN,
+  ERROR,
+  CRITICAL,
+}
+
+export async function sendAlertMessage(
+  accessToken: string,
+  message: {
+    source: string;
+    eventName: string;
+    severity: AlertSeverity;
+    dateTime?: string;
+    user?: string;
+    tenant?: string;
+    orderId?: string;
+    venues?: string[];
+    params?: Record<string, string>;
+  },
+) {
+  if (!message.dateTime) message.dateTime = new Date().toISOString();
+  try {
+    const response = await axios.post(
+      `${process.env.BASE_URL}/alert-service/message`,
+      message,
+      {
+        headers: {
+          'Content-Type': 'application/json',
+          Authorization: `Bearer ${accessToken}`,
+        },
+      },
+    );
+    return { data: response.data };
+  } catch (error) {
+    return {
+      data: null,
+      error: error,
+    };
+  }
+}

src/authorization.ts

@@ -461,46 +461,3 @@ export const checkAndOptionallyAskForCredentials =
 export async function savePasswordForUser(user: string, password: string) {
   await keytar.setPassword(authService.service, user, password);
 }
-
-export enum AlertSeverity {
-  DEBUG,
-  INFO,
-  WARN,
-  ERROR,
-  CRITICAL,
-}
-
-export async function sendAlertMessage(
-  accessToken: string,
-  message: {
-    source: string;
-    eventName: string;
-    severity: AlertSeverity;
-    dateTime?: string;
-    user?: string;
-    tenant?: string;
-    orderId?: string;
-    venues?: string[];
-    params?: Record<string, string>;
-  },
-) {
-  if (!message.dateTime) message.dateTime = new Date().toISOString();
-  try {
-    const response = await axios.post(
-      `${process.env.BASE_URL}/alert-service/message`,
-      message,
-      {
-        headers: {
-          'Content-Type': 'application/json',
-          Authorization: `Bearer ${accessToken}`,
-        },
-      },
-    );
-    return { data: response.data };
-  } catch (error) {
-    return {
-      data: null,
-      error: error,
-    };
-  }
-}

src/index.ts

@@ -5,4 +5,5 @@ export * as helpers from './helpers';
 export { orderService } from './orders-service';
 export { getOrdersQueue } from './orders-local-queue-service';
 export * as productService from './products-service';
+export * from './alerts';
 export { setLogger, logger } from './logger';

src/ws-listener.ts

@@ -40,6 +40,8 @@ export async function connectWebSockets({
   onNotificationAsync,
   onSteeringCommandAsync,
 }: WebsocketConnectParams) {
+  const includeVenueHeader = process.env.WS_INCLUDE_VENUE_HEADER === 'true';
+
   const stompConfig = {
     brokerURL: `${process.env.BASE_URL}/ws`,
     connectHeaders: {
@@ -79,27 +81,25 @@ export async function connectWebSockets({
         },
       );
       if (onOrdersUpdateAsync) {
+        const headers = includeVenueHeader ? { 'x-venue': venue } : {};
         var subscriptionForOrdersUpdate = client.subscribe(
           `/order-changes/${tenant}/${stompConfig.userUUID}`,
           async function (data: any) {
             var message = JSON.parse(data.body);
             await onOrdersUpdateAsync(message);
           },
-          {
-            'x-venue': venue,
-          },
+          headers,
         );
       }
       if (onNotificationAsync) {
+        const headers = includeVenueHeader ? { 'x-venue': venue } : {};
         var subscriptionForNotifications = client.subscribe(
           `/notifications/${tenant}/${stompConfig.userUUID}`,
           async function (data: any) {
             var message = JSON.parse(data.body);
             await onNotificationAsync(message);
           },
-          {
-            'x-venue': venue,
-          },
+          headers,
         );
       }
       if (onSteeringCommandAsync) {