feat: use newCommandTimeoutSec for manual device control (#1672)

BREAKING CHANGE: Following changes are added
- Added authentication module with user and team management
- Enhanced automation runs with access key authentication
- Improved device and server management capabilities
- Database schema changes that may result in loss of existing data

Author: sudharsan-selvaraj

src/device-utils.ts

@@ -187,9 +187,6 @@ export async function allocateDeviceForSession(
     await blockDevice(device.udid, device.host);
     log.info(`📱 Blocking device ${device.udid} at host ${device.host} for new session`);
 
-    // FIXME: convert this into a return value
-    await updateCapabilityForDevice(capability, device, { liveVideo });
-
     // update newCommandTimeout for the device.
     // This is required so it won't get unblocked by prematurely.
     let newCommandTimeout = firstMatch['appium:newCommandTimeout'];
@@ -198,6 +195,12 @@ export async function allocateDeviceForSession(
     }
     await updatedAllocatedDevice(device, { newCommandTimeout });
 
+    // FIXME: convert this into a return value
+    await updateCapabilityForDevice(capability, device, {
+      liveVideo,
+      newCommandTimeout: newCommandTimeout,
+    });
+
     return device;
   } else {
     throw new Error(`No device found for filters: ${JSON.stringify(filters)}`);
@@ -213,13 +216,22 @@ export async function allocateDeviceForSession(
 export async function updateCapabilityForDevice(
   capability: any,
   device: IDevice,
-  options: { liveVideo: boolean },
+  options: { liveVideo: boolean; newCommandTimeout?: number },
 ) {
   const mergedCapabilites = Object.assign(
     {},
     capability.alwaysMatch,
     capability.firstMatch[0] || {},
   );
+
+  if (!mergedCapabilites['appium:newCommandTimeout'] && options.newCommandTimeout) {
+    try {
+      capability.firstMatch[0]['appium:newCommandTimeout'] = options.newCommandTimeout;
+    } catch (err) {
+      capability.alwaysMatch['appium:newCommandTimeout'] = options.newCommandTimeout;
+    }
+  }
+
   if (!device.hasOwnProperty('cloud')) {
     if (mergedCapabilites['appium:automationName']?.toLowerCase() === 'flutterintegration') {
       capability.firstMatch[0]['appium:flutterSystemPort'] = await getPort();