Working on synchronization...

1 files changed, 24 insertions, 14 deletions

diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs
index ce40e552f..8a4f94159 100644
--- a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs
@@ -1,34 +1,44 @@
-using System;
+using Google.Protobuf;
+using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Linq;
 using System.Net;
 using System.Net.Http;
 using System.Threading.Tasks;
+using System.Web.Hosting;
 using System.Web.Http;
+using Tango.Core.Helpers;
 using Tango.PMR.Stubs;
+using Tango.PMR.Synchronization;
+using Tango.Synchronization.Local;
+using Tango.Synchronization.Remote;
 
 namespace Tango.MachineService.Controllers
 {
     public class SynchronizationController : ApiController
     {
         [HttpPost]
-        public async Task<CalculateResponse> Upload(CalculateRequest request)
+        public SynchronizeDBResponse Synchronize(SynchronizeDBRequest request)
         {
-            //if (!Request.Content.IsMimeMultipartContent())
-            //    throw new HttpResponseException(HttpStatusCode.UnsupportedMediaType);
+            String tempFolder = PathHelper.GetTempFolderPath();
 
-            //var provider = new MultipartMemoryStreamProvider();
-            //await Request.Content.ReadAsMultipartAsync(provider);
-            //foreach (var file in provider.Contents)
-            //{
-            //    var filename = file.Headers.ContentDisposition.FileName.Trim('\"');
-            //    var buffer = await file.ReadAsByteArrayAsync();
-            //    //Do whatever you want with filename and its binaray data.
-            //}
+            String masterSQLiteFile = Path.Combine(tempFolder, "Remote.db");
+            String slaveSQLiteFile = Path.Combine(tempFolder, "Local.db");
 
-            //return Ok();
+            File.WriteAllBytes(slaveSQLiteFile, request.LocalDB.ToByteArray());
+            File.Copy(HostingEnvironment.MapPath(@"~/App_Data/Tango.db"), masterSQLiteFile);
 
-            return new CalculateResponse() { Sum = request.A + request.B };
+            RemoteDBSynchronizer.Synchronize(masterSQLiteFile, request.SerialNumber);
+
+            LocalDBSynchronizer.Synchronize(masterSQLiteFile, slaveSQLiteFile);
+
+            SynchronizeDBResponse response = new SynchronizeDBResponse();
+            response.ResponseDB = ByteString.CopyFrom(File.ReadAllBytes(slaveSQLiteFile));
+
+            PathHelper.TryDeleteFolder(tempFolder);
+
+            return response;
         }
     }
 }