blob: 28d0cd3f1d142734097042ce6410a9be13fe9f9a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
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.Core.IO;
using Tango.PMR.Stubs;
using Tango.PMR.Synchronization;
using Tango.Synchronization.Local;
using Tango.Synchronization.Remote;
namespace Tango.MachineService.Controllers
{
public class SynchronizationController : ApiController
{
/// <summary>
/// Expects a DB synchronization request from a remote machine and returns the synchronized version of the machine database.
/// </summary>
/// <param name="request">The request.</param>
/// <returns></returns>
[HttpPost]
public SynchronizeDBResponse Synchronize(SynchronizeDBRequest request)
{
var tempFolder = TemporaryManager.Default.CreateFolder();
try
{
//File path for the reflected remote data base SQLite.
String masterSQLiteFile = Path.Combine(tempFolder, "Remote.db");
//File path for the received machine SQLite db.
String slaveSQLiteFile = Path.Combine(tempFolder, "Local.db");
//Save the machine db to file.
File.WriteAllBytes(slaveSQLiteFile, request.LocalDB.ToByteArray());
//Copy an SQLite db template.
File.Copy(HostingEnvironment.MapPath(@"~/App_Data/Tango.db"), masterSQLiteFile);
//Synchronize the SQL Server db with the new SQLite template. (Overwrite basically)
RemoteDBSynchronizer.Synchronize(masterSQLiteFile, request.SerialNumber, true);
//Synchronize the received machine db with the filled template.
LocalDBSynchronizer.Synchronize(masterSQLiteFile, slaveSQLiteFile);
//Send the synchronized machine db to the machine to the machine.
SynchronizeDBResponse response = new SynchronizeDBResponse();
response.RemoteDB = ByteString.CopyFrom(File.ReadAllBytes(slaveSQLiteFile));
return response;
}
catch (Exception)
{
throw;
}
finally
{
//Remove all temporary files and folder.
tempFolder.Delete();
}
}
}
}
|
