Added option to connect to Europe server

Author: bgelatti

package-lock.json

@@ -20,7 +20,7 @@
     "url": "git+https://github.com/tago-io/tcore.git"
   },
   "dependencies": {
-    "@tago-io/sdk": "11.3.6",
+    "@tago-io/sdk": "11.3.10",
     "async": "3.2.6",
     "axios": "0.26.0",
     "body-parser": "2.0.1",

package.json

@@ -16,14 +16,15 @@ const pingInterval = 240000;
 
 /**
  */
-function startRealtimeCommunication(token: string) {
+async function startRealtimeCommunication(token: string) {
   if (!token || events) {
     return;
   }
 
   const channel = "commands";
   const params = new URLSearchParams({ token, channel });
-  const url = `${getConnectionURI.default.default("usa-1").sse}?${params.toString()}`;
+  const region = await pluginStorage.get("region") || "us-e1";
+  const url = `${getConnectionURI.default.default(region).sse}?${params.toString()}`;
 
   const connect = () => {
     events = new EventSource(url);

plugins/tagoio-integration/src/back/RealtimeConnection.ts

@@ -1,13 +1,15 @@
 import * as getConnectionURI from "@tago-io/sdk/lib/regions.js";
+import { pluginStorage } from "@tago-io/tcore-sdk";
 import axios from "axios";
 
 /**
  * Creates a new instance with the given data.
  */
 async function createTCore(token: string, data: any) {
   try {
+    const region = await pluginStorage.get("region") || "us-e1";
     const response = await axios({
-      url: `${getConnectionURI.default.default("usa-1").api}/tcore/instance`,
+      url: `${getConnectionURI.default.default(region).api}/tcore/instance`,
       method: "POST",
       headers: { token },
       data,
@@ -28,8 +30,9 @@ async function sendDataToTagoio(
   operation: string,
 ) {
   try {
+    const region = await pluginStorage.get("region") || "us-e1";
     const response = await axios({
-      url: `${getConnectionURI.default.default("usa-1").api}/tcore/sse/${connId}`,
+      url: `${getConnectionURI.default.default(region).api}/tcore/sse/${connId}`,
       method: "POST",
       headers: { token },
       data: {

plugins/tagoio-integration/src/back/Request.ts

@@ -83,6 +83,8 @@ async function routeStartTCore(req: Request, res: Response) {
   const tcoreStartTime = new Date(Date.now() - process.uptime() * 1000);
   const osInfo = await helpers.getOSInfo();
   const profileToken = "p-".concat(req.headers.token as string);
+  const region = req.headers.region as string;
+  await pluginStorage.set("region", region);
   const item = await pluginStorage.get("tcore").catch(() => null);
 
   if (item?.token) {