Some improvements

Author: Fatme Havaluova

lib/services/usb-livesync-service.ts

@@ -207,32 +207,31 @@ export class IOSUsbLiveSyncService implements IiOSUsbLiveSyncService {
 			let timeout = 9000;
 			this.$iOSSocketRequestExecutor.executeAttachRequest(this.device, timeout).wait();
 			let socket = this.device.connectToPort(IOSUsbLiveSyncService.BACKEND_PORT);
-			this.sendReloadMessage(socket);
+			this.sendPageReloadMessage(socket);
 		}).future<void>()();
 	}
 
 	public sendPageReloadMessageToSimulator(): IFuture<void> {
-		helpers.connectEventually(() => net.connect(IOSUsbLiveSyncService.BACKEND_PORT), (socket: net.Socket) => this.sendReloadMessage(socket));
+		helpers.connectEventually(() => net.connect(IOSUsbLiveSyncService.BACKEND_PORT), (socket: net.Socket) => this.sendPageReloadMessage(socket));
 		return this.$iOSEmulatorServices.postDarwinNotification(this.$iOSNotification.attachRequest);
 	}
 
-	private sendReloadMessage(socket: net.Socket): void {
+	private sendPageReloadMessage(socket: net.Socket): void {
 		try {
-			this.sendReloadMessageCore(socket);
+			this.sendPageReloadMessageCore(socket);
 		} finally {
 			socket.destroy();
 		}
 	}
 
-	private sendReloadMessageCore(socket: net.Socket): void {
+	private sendPageReloadMessageCore(socket: net.Socket): void {
 		let message = `{ "method":"Page.reload","params":{"ignoreCache":false},"id":${++currentPageReloadId} }`;
 		let length = Buffer.byteLength(message, "utf16le");
 		let payload = new Buffer(length + 4);
 		payload.writeInt32BE(length, 0);
 		payload.write(message, 4, length, "utf16le");
 		socket.write(payload);
 	}
-
 }
 $injector.register("iosUsbLiveSyncServiceLocator", {factory: IOSUsbLiveSyncService});
 
@@ -248,8 +247,7 @@ export class AndroidUsbLiveSyncService extends androidLiveSyncServiceLib.Android
 
 	public restartApplication(deviceAppData: Mobile.IDeviceAppData, localToDevicePaths: Mobile.ILocalToDevicePathData[]): IFuture<void> {
 		return (() => {
-			this.device.adb.executeShellCommand(["chmod", "777", deviceAppData.deviceProjectRootPath]).wait();
-			this.device.adb.executeShellCommand(["chmod", "777",  `/data/local/tmp/${deviceAppData.appIdentifier}`]).wait();
+			this.device.adb.executeShellCommand(["chmod", "777", deviceAppData.deviceProjectRootPath, `/data/local/tmp/${deviceAppData.appIdentifier}`]).wait();
 
 			if(this.$options.companion) {
 				let commands = [ this.liveSyncCommands.SyncFilesCommand() ];
@@ -267,21 +265,35 @@ export class AndroidUsbLiveSyncService extends androidLiveSyncServiceLib.Android
 	public beforeLiveSyncAction(deviceAppData: Mobile.IDeviceAppData): IFuture<void> {
 		return (() => {
 			let deviceRootPath = `/data/local/tmp/${deviceAppData.appIdentifier}`;
-			this.device.adb.executeShellCommand(["rm", "-rf", this.$mobileHelper.buildDevicePath(deviceRootPath, "fullsync")]).wait();
-			this.device.adb.executeShellCommand(["rm", "-rf", this.$mobileHelper.buildDevicePath(deviceRootPath, "sync")]).wait();
-			this.device.adb.executeShellCommand(["rm", "-rf", this.$mobileHelper.buildDevicePath(deviceRootPath, "removedsync")]).wait();
+			this.device.adb.executeShellCommand(["rm", "-rf", this.$mobileHelper.buildDevicePath(deviceRootPath, "fullsync"),
+				this.$mobileHelper.buildDevicePath(deviceRootPath, "sync"),
+				this.$mobileHelper.buildDevicePath(deviceRootPath, "removedsync")]).wait();
 		}).future<void>()();
 	}
 
 	public sendPageReloadMessageToDevice(deviceAppData: Mobile.IDeviceAppData): IFuture<void> {
 		return (() => {
-			let socket = new net.Socket();
-			socket.connect(AndroidUsbLiveSyncService.BACKEND_PORT, '127.0.0.1', () => {
-				socket.write(new Buffer([0, 0, 0, 1, 1]));
-				socket.destroy();
-			});
 			this.device.adb.executeCommand(["forward", `tcp:${AndroidUsbLiveSyncService.BACKEND_PORT.toString()}`, `localabstract:${deviceAppData.appIdentifier}-livesync`]).wait();
+			this.sendPageReloadMessage().wait();
 		}).future<void>()();
 	}
+
+	private sendPageReloadMessage(): IFuture<void> {
+		let future = new Future<void>();
+
+		let socket = new net.Socket();
+		socket.connect(AndroidUsbLiveSyncService.BACKEND_PORT, '127.0.0.1', () => {
+			try {
+				socket.write(new Buffer([0, 0, 0, 1, 1]));
+ 				future.return();
+			} catch(e) {
+				future.throw(e);
+			} finally {
+				socket.destroy();
+			}
+		});
+
+		return future;
+	}
 }
 $injector.register("androidUsbLiveSyncServiceLocator", {factory: AndroidUsbLiveSyncService});