aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs')
-rw-r--r--Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs285
1 files changed, 0 insertions, 285 deletions
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs
deleted file mode 100644
index d675a348f..000000000
--- a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs
+++ /dev/null
@@ -1,285 +0,0 @@
-using Google.Protobuf;
-using Microsoft.Azure;
-using Microsoft.Azure.Management.Sql;
-using Microsoft.SqlServer.Management.Smo;
-using Newtonsoft.Json.Linq;
-using System;
-using System.Collections.Generic;
-using System.Configuration;
-using System.IO;
-using System.Linq;
-using System.Net;
-using System.Net.Http;
-using System.Security.Authentication;
-using System.Threading.Tasks;
-using System.Web.Hosting;
-using System.Web.Http;
-using Tango.BL;
-using Tango.BL.Builders;
-using Tango.BL.Entities;
-using Tango.Core.DB;
-using Tango.Core.Helpers;
-using Tango.Core.IO;
-using Tango.Logging;
-using Tango.MachineService.Helpers;
-using Tango.MachineService.Models;
-using Tango.MachineService.SMO;
-using Tango.PMR.Stubs;
-using Tango.PMR.Synchronization;
-using Tango.Synchronization.Local;
-using Tango.Synchronization.Remote;
-
-namespace Tango.MachineService.Controllers
-{
- public class SynchronizationController : ProtoController
- {
- ///// <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();
- // }
- //}
-
- [HttpPost]
- public MachineSetupResponse MachineSetup(MachineSetupRequest request)
- {
- MachineSetupResponse response = new MachineSetupResponse();
-
- LogManager.Log("Setup request received: " + request.ToString());
-
- using (ObservablesContext db = ObservablesContextHelper.CreateContext())
- {
- db.Configuration.LazyLoadingEnabled = false;
- String serial_number = request.SerialNumber;
-
- var machine = db.Machines.SingleOrDefault(x => x.SerialNumber == serial_number);
-
- if (machine == null)
- {
- throw new AuthenticationException("The specified serial number could not be found.");
- }
-
- if (machine.SetupActivation && machine.OsKey == null)
- {
- throw new InvalidDataException("The specified machine is configured to perform an OS activation but is not associated with an OS activation key.");
- }
-
- var machine_version = db.MachineVersions.SingleOrDefault(x => x.Guid == machine.MachineVersionGuid);
-
- var latest_machine_version = db.TangoVersions.Where(x => x.MachineVersionGuid == machine_version.Guid).ToList().OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault();
-
- response.Version = latest_machine_version.Version;
-
- var client = StorageHelper.GetStorageBlobClient();
- var container = StorageHelper.GetTangoVersionsContainer(client);
- var blob = container.GetBlockBlobReference(latest_machine_version.BlobName);
-
- response.BlobAddress = StorageHelper.GenerateBlobReadSignature(blob, TimeSpan.FromMinutes(60));
-
- DbCredentials credentials = new DbCredentials();
-
- using (SmoManager manager = new SmoManager())
- {
- credentials = manager.CreateRandomLoginAndUser();
-
- Task.Delay(TimeSpan.FromMinutes(10)).ContinueWith((x) =>
- {
- using (SmoManager m = new SmoManager())
- {
- m.DeleteLoginAndUser(credentials.UserName);
- }
- });
- }
-
- response.DbAddress = Config.DB_ADDRESS;
- response.DbUserName = credentials.UserName;
- response.DbPassword = credentials.Password;
- response.OSKey = machine.OsKey;
- response.SetupActivation = machine.SetupActivation;
- response.SetupRemoteAssistance = machine.SetupRemoteAssistance;
- response.SetupUWF = machine.SetupUwf;
- response.SetupFirmware = machine.SetupFirmware;
- response.IsDemo = machine.IsDemo;
-
- }
-
- return response;
- }
-
- [HttpPost]
- public DownloadUpdateResponse MachineUpdate(DownloadUpdateRequest request)
- {
- DownloadUpdateResponse response = new DownloadUpdateResponse();
-
- using (ObservablesContext db = ObservablesContextHelper.CreateContext())
- {
- db.Configuration.LazyLoadingEnabled = false;
- String serial_number = request.SerialNumber;
-
- var machine = db.Machines.SingleOrDefault(x => x.SerialNumber == serial_number);
-
- if (machine == null)
- {
- throw new AuthenticationException("The specified serial number could not be found.");
- }
-
- var machine_version = db.MachineVersions.SingleOrDefault(x => x.Guid == machine.MachineVersionGuid);
-
- var latest_machine_version = db.TangoVersions.Where(x => x.MachineVersionGuid == machine_version.Guid).ToList().OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault();
-
- response.Version = latest_machine_version.Version;
-
- var client = StorageHelper.GetStorageBlobClient();
- var container = StorageHelper.GetTangoVersionsContainer(client);
- var blob = container.GetBlockBlobReference(latest_machine_version.BlobName);
-
- response.BlobAddress = StorageHelper.GenerateBlobReadSignature(blob, TimeSpan.FromMinutes(60));
-
- DbCredentials credentials = new DbCredentials();
-
- using (SmoManager manager = new SmoManager())
- {
- credentials = manager.CreateRandomLoginAndUser();
-
- Task.Delay(TimeSpan.FromMinutes(10)).ContinueWith((x) =>
- {
- using (SmoManager m = new SmoManager())
- {
- m.DeleteLoginAndUser(credentials.UserName);
- }
- });
- }
-
- response.DbAddress = Config.DB_ADDRESS;
- response.DbUserName = credentials.UserName;
- response.DbPassword = credentials.Password;
- }
-
- return response;
- }
-
- [HttpPost]
- public CheckForUpdateResponse CheckForUpdate(CheckForUpdateRequest request)
- {
- CheckForUpdateResponse response = new CheckForUpdateResponse();
-
- using (ObservablesContext db = ObservablesContextHelper.CreateContext())
- {
- db.Configuration.LazyLoadingEnabled = false;
-
- var machine = db.Machines.SingleOrDefault(x => x.SerialNumber == request.SerialNumber);
-
- if (machine == null)
- {
- throw new AuthenticationException("The specified serial number could not be found.");
- }
-
- var machine_version = db.MachineVersions.SingleOrDefault(x => x.Guid == machine.MachineVersionGuid);
-
- var latest_machine_version = db.TangoVersions.Where(x => x.MachineVersionGuid == machine_version.Guid).ToList().OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault();
-
- if (Version.Parse(latest_machine_version.Version) > Version.Parse(request.Version))
- {
- response.IsUpdateAvailable = true;
- }
-
- response.Version = latest_machine_version.Version;
- }
-
- return response;
- }
-
- [HttpPost]
- public UpdateDBResponse UpdateDB(UpdateDBRequest request)
- {
- UpdateDBResponse response = new UpdateDBResponse();
-
- using (ObservablesContext db = ObservablesContextHelper.CreateContext())
- {
- db.Configuration.LazyLoadingEnabled = false;
- String serial_number = request.SerialNumber;
-
- var machine = db.Machines.SingleOrDefault(x => x.SerialNumber == serial_number);
-
- if (machine == null)
- {
- throw new AuthenticationException("The specified serial number could not be found.");
- }
-
- DbCredentials credentials = new DbCredentials();
-
- using (SmoManager manager = new SmoManager())
- {
- credentials = manager.CreateRandomLoginAndUser();
-
- Task.Delay(TimeSpan.FromMinutes(10)).ContinueWith((x) =>
- {
- using (SmoManager m = new SmoManager())
- {
- m.DeleteLoginAndUser(credentials.UserName);
- }
- });
- }
-
- response.DbAddress = Config.DB_ADDRESS;
- response.DbUserName = credentials.UserName;
- response.DbPassword = credentials.Password;
- }
-
- return response;
- }
-
- [HttpPost]
- public Machine PersonTest(Person p)
- {
- using (var db = ObservablesContextHelper.CreateContext())
- {
- var machine = new MachineBuilder(db)
- .Set(x => x.SerialNumber == "1111")
- .WithOrganization()
- .WithConfiguration().Build();
-
- return machine;
- }
- }
- }
-}
generated by cgit v1.3.1 (git 2.54.0) at 2026-06-19 23:49:47 +0000