Merge branch 'master' into QT-344

Author: can-angun

CHANGELOG.md

@@ -1,8 +1,24 @@
+## Version 25.03.xx
+Fixes:
+- [push] Fixed timeout setting
+
+Dependencies:
+- Bump axios from 1.12.2 to 1.13.1 in /plugins/cognito
+- Bump csvtojson from 1.1.12 to 2.0.14
+- Bump eslint-plugin-vue from 10.5.0 to 10.5.1
+- Bump express-rate-limit from 8.1.0 to 8.2.0
+- Bump get-random-values from 4.0.0 to 4.1.0
+- Bump lint-staged from 16.2.4 to 16.2.6
+- Bump mockttp from 4.2.0 to 4.2.1 in /plugins/crash_symbolication
+- Bump nodemailer from 7.0.9 to 7.0.10
+- Bump puppeteer from 24.25.0 to 24.27.0
+- Bump vite from 7.1.10 to 7.1.12
+
 ## Version 25.03.25
 Fixes:
 - [crashes] Fixed resolving audit log recording
 - [location] Fixed updating none gps coordinate location after gps location was used
-- 
+
 Enterprise Fixes:
 - [ab-testing] Add script for fixing variant cohort
 - [groups] Fix user permission update after updating user group permission

bin/scripts/device_list/package-lock.json

@@ -65,6 +65,7 @@ plugins.setConfigs(FEATURE_NAME, {
     pool_concurrency: 5, // max number of same type connections
     pool_pools: 10, // max number of connections in total
     default_content_available: false, // sets content-available: 1 by default for ios
+    message_timeout: 3600000, // timeout for a message not sent yet (for TooLateToSend error)
 });
 
 plugins.internalEvents.push('[CLY]_push_sent');

plugins/push/api/api.js

@@ -169,7 +169,7 @@ class Connector extends DoFinish {
                         }
                     }, callback);
             }
-            else if (push._id.getTimestamp().getTime() < Date.now() - 3600000) {
+            else if (push._id.getTimestamp().getTime() < (Date.now() - this.state.cfg.message_timeout)) {
                 this.tooLateToSend.addAffected(push._id, 1);
                 this.do_flush(callback, true);
                 return;

plugins/push/api/jobs/util/connector.js

@@ -119,21 +119,29 @@ class Sender {
                     auth: !(plugins.push.proxyunauthorized || false),
                 };
             }
+            if (plugins.push.message_timeout) {
+                if (typeof plugins.push.message_timeout === "number") {
+                    cfg.message_timeout = plugins.push.message_timeout;
+                }
+                else {
+                    common.log(`push:send`).w('Invalid message timeout configuration: %j', plugins.push.message_timeout);
+                }
+            }
         }
 
         return cfg;
     }
 
     /**
-     * Watch push collection for pushes to send, 
+     * Watch push collection for pushes to send,
      */
     async watch() {
         let oid = dbext.oidBlankWithDate(new Date()),
             count = await common.db.collection('push').count({_id: {$lte: oid}});
         return count > 0;
     }
     // /**
-    //  * Watch push collection for pushes to send, 
+    //  * Watch push collection for pushes to send,
     //  */
     //  async watch() {
     //     let oid = dbext.oidBlankWithDate(new Date());

plugins/push/api/send/sender.js

@@ -394,6 +394,7 @@ push.pool_pushes = Number of notifications in stream batches
 push.pool_bytes = Bytes in binary stream batches
 push.pool_concurrency = Maximum number of same type connections
 push.pool_pools = Maximum number of connections in total
+push.message_timeout = Timeout of a message to be send (in milliseconds)
 push.default_content_available = Set content-available to 1 by default for IOS
 
 #Drawer from other views