Make watch optional

Author: skadefro

OpenFlow/src/Config.ts

@@ -26,6 +26,8 @@ export class Config {
         Config.stripe_api_key = Config.getEnv("stripe_api_key", "");
         Config.stripe_api_secret = Config.getEnv("stripe_api_secret", "");
 
+        Config.supports_watch = Config.parseBoolean(Config.getEnv("supports_watch", "false"));
+
         Config.auto_create_users = Config.parseBoolean(Config.getEnv("auto_create_users", "false"));
         Config.auto_create_domains = Config.parseArray(Config.getEnv("auto_create_domains", ""));
         Config.allow_user_registration = Config.parseBoolean(Config.getEnv("allow_user_registration", "false"));
@@ -95,6 +97,8 @@ export class Config {
     public static stripe_api_key: string = Config.getEnv("stripe_api_key", "");
     public static stripe_api_secret: string = Config.getEnv("stripe_api_secret", "");
 
+    public static supports_watch: boolean = Config.parseBoolean(Config.getEnv("supports_watch", "false"));
+
     public static auto_create_users: boolean = Config.parseBoolean(Config.getEnv("auto_create_users", "false"));
     public static auto_create_domains: string[] = Config.parseArray(Config.getEnv("auto_create_domains", ""));
     public static allow_user_registration: boolean = Config.parseBoolean(Config.getEnv("allow_user_registration", "false"));

OpenFlow/src/Messages/Message.ts

@@ -476,7 +476,11 @@ export class Message {
         try {
             msg = WatchMessage.assign(this.data);
             if (NoderedUtil.IsNullEmpty(msg.jwt)) { msg.jwt = cli.jwt; }
-            msg.id = await cli.Watch(msg.aggregates, msg.collectionname, msg.jwt);
+            if (Config.supports_watch) {
+                msg.id = await cli.Watch(msg.aggregates, msg.collectionname, msg.jwt);
+            } else {
+                msg.error = "Watch is not supported by this openflow";
+            }
             msg.result = null;
         } catch (error) {
             if (NoderedUtil.IsNullUndefinded(msg)) { (msg as any) = {}; }
@@ -781,6 +785,7 @@ export class Message {
                 if (msg.impersonate === undefined || msg.impersonate === null || msg.impersonate === "") {
                     user.lastseen = new Date(new Date().toISOString());
                 }
+                msg.supports_watch = Config.supports_watch;
                 user._lastclientagent = cli.clientagent;
                 user._lastclientversion = cli.clientversion;
                 if (cli.clientagent == "openrpa") {