aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/Web/Tango.MachineService/Controllers
diff options
context:
space:
mode:
authorShlomo Hecht <shlomo@twine-s.com>2019-01-02 08:47:29 +0200
committerShlomo Hecht <shlomo@twine-s.com>2019-01-02 08:47:29 +0200
commit520e878bf98efcec9c75abcfe483175ff72620a2 (patch)
tree62a7221e3c22187821f6a5e399eca0f7bd31168a /Software/Visual_Studio/Web/Tango.MachineService/Controllers
parent30574fe4a6e1bb4f60a43e9000acaf919811689a (diff)
parent25f5e6ddef7ef2fa0a747305847eeb4ceee5a2c9 (diff)
downloadTango-520e878bf98efcec9c75abcfe483175ff72620a2.tar.gz
Tango-520e878bf98efcec9c75abcfe483175ff72620a2.zip
Merge branch 'master' of https://twinetfs.visualstudio.com/Tango/_git/Tango
Diffstat (limited to 'Software/Visual_Studio/Web/Tango.MachineService/Controllers')
-rw-r--r--Software/Visual_Studio/Web/Tango.MachineService/Controllers/HomeController.cs16
-rw-r--r--Software/Visual_Studio/Web/Tango.MachineService/Controllers/MachineStudioController.cs274
-rw-r--r--Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs414
-rw-r--r--Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs273
-rw-r--r--Software/Visual_Studio/Web/Tango.MachineService/Controllers/ValuesController.cs45
-rw-r--r--Software/Visual_Studio/Web/Tango.MachineService/Controllers/VersionUpdateController.cs168
6 files changed, 688 insertions, 502 deletions
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/HomeController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/HomeController.cs
deleted file mode 100644
index a7c526f67..000000000
--- a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/HomeController.cs
+++ /dev/null
@@ -1,16 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Web;
-using System.Web.Mvc;
-
-namespace Tango.MachineService.Controllers
-{
- public class HomeController : Controller
- {
- public String Index()
- {
- return "Machine Service Started!";
- }
- }
-}
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/MachineStudioController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/MachineStudioController.cs
new file mode 100644
index 000000000..c9d7ea8b6
--- /dev/null
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/MachineStudioController.cs
@@ -0,0 +1,274 @@
+using Microsoft.IdentityModel.Clients.ActiveDirectory;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Net.Http;
+using System.Security.Authentication;
+using System.Web.Http;
+using Tango.BL;
+using Tango.BL.Builders;
+using Tango.BL.Entities;
+using Tango.BL.Enumerations;
+using Tango.Core.Cryptography;
+using Tango.MachineService.Models;
+using Tango.MachineStudio.Common.Authentication;
+using System.Data.Entity;
+using Tango.MachineStudio.Common.Update;
+using Tango.Web.Controllers;
+using Tango.Web.Helpers;
+using Tango.Web.Storage;
+using Tango.Web.Authentication;
+using Tango.Web.ActiveDirectory;
+
+namespace Tango.MachineService.Controllers
+{
+ public class MachineStudioController : JsonController
+ {
+ private static TokensManager _tokens_manager;
+ private static List<MachineStudioPendingUpload> _pendingUploads;
+ private ActiveDirectoryManager _ad_manager;
+
+ static MachineStudioController()
+ {
+ _tokens_manager = new TokensManager();
+ _pendingUploads = new List<MachineStudioPendingUpload>();
+ }
+
+ public MachineStudioController() : base()
+ {
+ _ad_manager = new ActiveDirectoryManager();
+ }
+
+ #region Update
+
+ [HttpPost]
+ public CheckForUpdatesResponse CheckForUpdates(CheckForUpdatesRequest request)
+ {
+ LogManager.Log("Request received...");
+
+ CheckForUpdatesResponse response = new CheckForUpdatesResponse();
+
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ if (_tokens_manager.Exists(request.AccessToken))
+ {
+ var versions = db.MachineStudioVersions.ToList();
+
+ MachineStudioVersion latestVersion = null;
+
+ if (request.AcceptBetaRelease)
+ {
+ latestVersion = versions.OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault();
+ }
+ else
+ {
+ latestVersion = versions.Where(x => x.Stable).OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault();
+ }
+
+ Version currentVersion = Version.Parse(request.Version);
+
+ String comments = String.Join(Environment.NewLine, versions.OrderBy(x => Version.Parse(x.Version)).Where(x => Version.Parse(x.Version) > currentVersion).Select(x => x.Comments));
+
+ if (latestVersion != null && Version.Parse(latestVersion.Version) > currentVersion)
+ {
+ var manager = new StorageManager();
+ var container = manager.GetContainer(MachineServiceConfig.MACHINE_STUDIO_VERSIONS_CONTAINER);
+ var blob = container.GetBlockBlobReference(latestVersion.BlobName);
+
+ response.BlobAddress = blob.GenerateReadSignature(TimeSpan.FromMinutes(60));
+
+ response.IsUpdateAvailable = true;
+ response.Version = latestVersion.Version;
+ response.Comments = latestVersion.Comments;
+ response.IsStable = latestVersion.Stable;
+ }
+ }
+ else
+ {
+ throw new AuthenticationException("Invalid token.");
+ }
+ }
+
+ return response;
+ }
+
+ [HttpPost]
+ public UploadVersionResponse UploadVersion(UploadVersionRequest request)
+ {
+ UploadVersionResponse response = new UploadVersionResponse();
+
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ //Load relation first...
+ db.Roles.ToList();
+ db.Permissions.ToList();
+ db.UsersRoles.ToList();
+ db.RolesPermissions.ToList();
+
+ var user = db.Users.SingleOrDefault(x => x.Email.ToLower() == request.Email.ToLower() && x.Password == request.Password);
+
+ if (user != null && user.HasPermission(Permissions.PublishMachineStudioVersions))
+ {
+ var latestVersion = db.MachineStudioVersions.ToList().OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault();
+ Version currentVersion = Version.Parse(request.Version);
+
+ if (latestVersion == null || currentVersion > Version.Parse(latestVersion.Version))
+ {
+ String newVersionFileName = "Machine Studio Version" + " " + currentVersion.ToString() + ".zip";
+
+ var manager = new StorageManager();
+ var container = manager.GetContainer(MachineServiceConfig.MACHINE_STUDIO_VERSIONS_CONTAINER);
+ var blob = container.CreateEmptyBlob(newVersionFileName);
+
+ response.Token = Guid.NewGuid().ToString();
+ response.BlobAddress = blob.GenerateWriteSignature(TimeSpan.FromMinutes(30));
+
+ _pendingUploads.Add(new MachineStudioPendingUpload()
+ {
+ UserGuid = user.Guid,
+ Comments = request.Comments,
+ ForcedUpdate = request.ForcedUpdate,
+ Token = response.Token,
+ Version = request.Version,
+ IsStable = request.IsStable,
+ BlobName = blob.Name,
+ });
+ }
+ else
+ {
+ throw new ArgumentException("New version must be greater than latest version.");
+ }
+ }
+ else
+ {
+ throw new AuthenticationException("Invalid user credentials.");
+ }
+ }
+
+ return response;
+ }
+
+ [HttpPost]
+ public UploadCompletedResponse NotifyUploadCompleted(UploadCompletedRequest request)
+ {
+ MachineStudioPendingUpload upload = _pendingUploads.FirstOrDefault(x => x.Token == request.AccessToken);
+
+ if (upload != null)
+ {
+ _pendingUploads.RemoveAll(x => x.Token == upload.Token);
+
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ db.MachineStudioVersions.Add(new MachineStudioVersion()
+ {
+ Comments = upload.Comments,
+ BlobName = upload.BlobName,
+ UserGuid = upload.UserGuid,
+ Version = upload.Version,
+ ForceUpdate = upload.ForcedUpdate,
+ Stable = upload.IsStable,
+ });
+
+ db.SaveChanges();
+ }
+
+ return new UploadCompletedResponse();
+ }
+ else
+ {
+ throw new ArgumentException("Invalid Token.");
+ }
+ }
+
+ [HttpPost]
+ public LatestVersionResponse GetLatestVersion(LatestVersionRequest request)
+ {
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ var version = db.MachineStudioVersions.ToList().OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault();
+ return new LatestVersionResponse() { Version = version != null ? version.Version : "0.0.0.0" };
+ }
+ }
+
+ #endregion
+
+ [HttpPost]
+ public LoginResponse Login(LoginRequest request)
+ {
+ var authResult =_ad_manager.ValidateUserCredentials(request.Email, request.Password);
+
+ if (!_ad_manager.CanUserAccessCurrentEnvironment(request.Email))
+ {
+ throw new AuthenticationException($"You do not have permissions to access the {MachineServiceConfig.DEPLOYMENT_SLOT.ToDescription()} environment.");
+ }
+
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ db.Roles.ToList();
+ db.Permissions.ToList();
+ db.UsersRoles.ToList();
+ db.RolesPermissions.ToList();
+
+ var user = db.Users.SingleOrDefault(x => x.Email.ToLower() == request.Email.ToLower());
+
+ IHashGenerator g = new BasicHashGenerator();
+
+ if (user == null)
+ {
+ //Than add the user !!
+ User new_user = new User();
+ new_user.Email = request.Email;
+ new_user.Password = g.Encrypt(request.Password);
+ new_user.Organization = db.Organizations.Include(x => x.Address).Single(x => x.Name == "Twine");
+ new_user.Address = new_user.Organization.Address.Clone();
+ new_user.Contact = new Contact()
+ {
+ FirstName = authResult.UserInfo.GivenName,
+ LastName = authResult.UserInfo.FamilyName,
+ FullName = authResult.UserInfo.GivenName + " " + authResult.UserInfo.FamilyName,
+ Email = request.Email,
+ };
+
+ db.UsersRoles.Add(new UsersRole()
+ {
+ User = new_user,
+ Role = db.Roles.Single(x => (Roles)x.Code == Roles.User),
+ });
+
+ db.UsersRoles.Add(new UsersRole()
+ {
+ User = new_user,
+ Role = db.Roles.Single(x => (Roles)x.Code == Roles.MachineStudioUser),
+ });
+
+ new_user.LastLogin = DateTime.UtcNow;
+ db.Users.Add(new_user);
+ }
+ else
+ {
+ user.LastLogin = DateTime.UtcNow;
+ user.Password = g.Encrypt(request.Password);
+ }
+
+ db.SaveChanges();
+ }
+
+ return new LoginResponse()
+ {
+ DataSource = new Core.DataSource()
+ {
+ Address = MachineServiceConfig.DB_ADDRESS,
+ Catalog = MachineServiceConfig.DB_CATALOG,
+ Type = Core.DataSourceType.Azure,
+ IntegratedSecurity = false,
+ UserName = request.Email,
+ Password = request.Password,
+ },
+
+ Token = _tokens_manager.CreateNew()
+ };
+ }
+
+ }
+}
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs
new file mode 100644
index 000000000..6d591edd8
--- /dev/null
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs
@@ -0,0 +1,414 @@
+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.BL.Enumerations;
+using Tango.Core;
+using Tango.Core.DB;
+using Tango.Core.Helpers;
+using Tango.Core.IO;
+using Tango.Logging;
+using Tango.MachineService.Models;
+using Tango.PMR.Stubs;
+using Tango.PMR.Synchronization;
+using Tango.PPC.Common.MachineSetup;
+using Tango.PPC.Common.MachineUpdate;
+using Tango.PPC.Common.Update;
+using Tango.Synchronization.Local;
+using Tango.Synchronization.Remote;
+using Tango.Web.Controllers;
+using Tango.Web.Helpers;
+using Tango.Web.SMO;
+using Tango.Web.Storage;
+
+namespace Tango.MachineService.Controllers
+{
+ public class PPCController : JsonController
+ {
+ private static List<PPCPendingUpload> _pendingUploads;
+
+ #region Constructors
+
+ static PPCController()
+ {
+ _pendingUploads = new List<PPCPendingUpload>();
+ }
+
+ #endregion
+
+ #region Setup & Update
+
+ [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 manager = new StorageManager();
+ var container = manager.GetContainer(MachineServiceConfig.TANGO_VERSIONS_CONTAINER);
+ var blob = container.GetBlockBlobReference(latest_machine_version.BlobName);
+
+ response.BlobAddress = blob.GenerateReadSignature(TimeSpan.FromMinutes(60));
+
+ DbCredentials credentials = new DbCredentials();
+
+ using (SmoManager smo = new SmoManager())
+ {
+ credentials = smo.CreateRandomLoginAndUser();
+
+ Task.Delay(TimeSpan.FromMinutes(10)).ContinueWith((x) =>
+ {
+ using (SmoManager m = new SmoManager())
+ {
+ m.DeleteLoginAndUser(credentials.UserName);
+ }
+ });
+ }
+
+ response.DataSource = new DataSource()
+ {
+ Address = MachineServiceConfig.DB_ADDRESS,
+ Catalog = MachineServiceConfig.DB_CATALOG,
+ UserName = credentials.UserName,
+ Password = credentials.Password,
+ IntegratedSecurity = false,
+ Type = DataSourceType.SQLServer,
+ };
+
+ 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 manager = new StorageManager();
+ var container = manager.GetContainer(MachineServiceConfig.TANGO_VERSIONS_CONTAINER);
+ var blob = container.GetBlockBlobReference(latest_machine_version.BlobName);
+
+ response.BlobAddress = blob.GenerateReadSignature(TimeSpan.FromMinutes(60));
+
+ DbCredentials credentials = new DbCredentials();
+
+ using (SmoManager smo = new SmoManager())
+ {
+ credentials = smo.CreateRandomLoginAndUser();
+
+ Task.Delay(TimeSpan.FromMinutes(10)).ContinueWith((x) =>
+ {
+ using (SmoManager m = new SmoManager())
+ {
+ m.DeleteLoginAndUser(credentials.UserName);
+ }
+ });
+ }
+
+ response.DataSource = new DataSource()
+ {
+ Address = MachineServiceConfig.DB_ADDRESS,
+ Catalog = MachineServiceConfig.DB_CATALOG,
+ UserName = credentials.UserName,
+ Password = credentials.Password,
+ IntegratedSecurity = false,
+ Type = DataSourceType.SQLServer,
+ };
+ }
+
+ 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.DataSource = new DataSource()
+ {
+ Address = MachineServiceConfig.DB_ADDRESS,
+ Catalog = MachineServiceConfig.DB_CATALOG,
+ UserName = credentials.UserName,
+ Password = credentials.Password,
+ IntegratedSecurity = false,
+ Type = DataSourceType.SQLServer,
+ };
+ }
+
+ return response;
+ }
+
+ #endregion
+
+ #region Version Upload
+
+ [HttpPost]
+ public LatestVersionResponse GetLatestVersion(LatestVersionRequest request)
+ {
+ LatestVersionResponse response = new LatestVersionResponse();
+
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ var versions = db.TangoVersions.Where(x => x.MachineVersionGuid == request.MachineVersionGuid).ToList();
+
+ if (versions.Count == 0)
+ {
+ return new LatestVersionResponse()
+ {
+ Version = "0.0.0.0",
+ };
+ }
+
+ response.Version = versions.OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault().Version;
+ }
+
+ return response;
+ }
+
+ [HttpPost]
+ public UploadVersionResponse UploadVersion(UploadVersionRequest request)
+ {
+ UploadVersionResponse response = new UploadVersionResponse();
+
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ //Load relations first...
+ db.Roles.ToList();
+ db.Permissions.ToList();
+ db.UsersRoles.ToList();
+ db.RolesPermissions.ToList();
+
+ var user = db.Users.SingleOrDefault(x => x.Email.ToLower() == request.Email.ToLower() && x.Password == request.Password);
+
+ if (user != null && user.HasPermission(Permissions.PublishPPCVersions))
+ {
+ var versions = db.TangoVersions.ToList().Where(x => x.MachineVersionGuid == request.MachineVersionGuid).OrderByDescending(x => Version.Parse(x.Version)).ToList();
+
+ TangoVersion latestVersion = new TangoVersion();
+ latestVersion.Version = "0.0.0.0";
+
+ if (versions.Count > 0)
+ {
+ latestVersion = versions.FirstOrDefault();
+ }
+
+ Version currentVersion = Version.Parse(request.Version);
+
+ if (currentVersion > Version.Parse(latestVersion.Version))
+ {
+ String newVersionFileName = "Tango Version" + " " + currentVersion.ToString() + ".zip";
+
+ var manager = new StorageManager();
+ var container = manager.GetContainer(MachineServiceConfig.TANGO_VERSIONS_CONTAINER);
+ var blob = container.CreateEmptyBlob(newVersionFileName);
+
+ response.Token = Guid.NewGuid().ToString();
+ response.BlobAddress = blob.GenerateWriteSignature(TimeSpan.FromMinutes(30));
+
+ _pendingUploads.Add(new PPCPendingUpload()
+ {
+ UserGuid = user.Guid,
+ Comments = request.Comments,
+ Token = response.Token,
+ Version = request.Version,
+ BlobName = blob.Name,
+ MachineVersionGuid = request.MachineVersionGuid,
+ });
+ }
+ else
+ {
+ throw new ArgumentException("New version must be greater than latest version.");
+ }
+ }
+ else
+ {
+ throw new AuthenticationException("Invalid user credentials.");
+ }
+ }
+
+ return response;
+ }
+
+ [HttpPost]
+ public UploadCompletedResponse NotifyUploadCompleted(UploadCompletedRequest request)
+ {
+ PPCPendingUpload upload = _pendingUploads.FirstOrDefault(x => x.Token == request.AccessToken);
+
+ if (upload != null)
+ {
+ _pendingUploads.RemoveAll(x => x.Token == upload.Token);
+
+ using (ObservablesContext db = ObservablesContextHelper.CreateContext())
+ {
+ db.TangoVersions.Add(new TangoVersion()
+ {
+ Comments = upload.Comments,
+ BlobName = upload.BlobName,
+ UserGuid = upload.UserGuid,
+ Version = upload.Version,
+ MachineVersionGuid = upload.MachineVersionGuid
+ });
+
+ db.SaveChanges();
+ }
+
+ return new UploadCompletedResponse();
+ }
+ else
+ {
+ throw new AuthenticationException("Invalid upload token.");
+ }
+ }
+
+ [HttpPost]
+ public MachineVersionsResponse GetMachineVersions(MachineVersionsRequest request)
+ {
+ using (var db = ObservablesContextHelper.CreateContext())
+ {
+ return new MachineVersionsResponse()
+ {
+ MachineVersions = db.MachineVersions.ToList(),
+ };
+ }
+ }
+
+ #endregion
+
+ [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;
+ }
+ }
+ }
+}
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 304ea34f2..000000000
--- a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/SynchronizationController.cs
+++ /dev/null
@@ -1,273 +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.");
- }
-
- 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 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;
- }
- }
- }
-}
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/ValuesController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/ValuesController.cs
deleted file mode 100644
index f76d66836..000000000
--- a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/ValuesController.cs
+++ /dev/null
@@ -1,45 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Net;
-using System.Net.Http;
-using System.Web.Http;
-using Tango.MachineService.Models;
-
-namespace Tango.MachineService.Controllers
-{
- public class ValuesController : ApiController
- {
- private static List<Person> persons = new List<Person>();
-
- // GET api/values
- public IEnumerable<Person> Get()
- {
- return persons;
- }
-
- // GET api/values/5
- public Person Get(int id)
- {
- return persons[id];
- }
-
- // POST api/values
- public Person Post([FromBody]Person person)
- {
- persons.Add(person);
- return person;
- }
-
- // PUT api/values/5
- public void Put(Person person)
- {
-
- }
-
- // DELETE api/values/5
- public void Delete(int id)
- {
- }
- }
-}
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/VersionUpdateController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/VersionUpdateController.cs
deleted file mode 100644
index 2ad8bd735..000000000
--- a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/VersionUpdateController.cs
+++ /dev/null
@@ -1,168 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Net;
-using System.Net.Http;
-using System.Security.Authentication;
-using System.Web.Http;
-using Tango.BL;
-using Tango.BL.Entities;
-using Tango.BL.Enumerations;
-using Tango.Logging;
-using Tango.MachineService.Helpers;
-using Tango.PPC.Common.Update;
-
-namespace Tango.MachineService.Controllers
-{
- public class VersionUpdateController : JsonController
- {
- private class PendingUpload
- {
- public String Token { get; set; }
-
- public String Version { get; set; }
-
- public String UserGuid { get; set; }
-
- public String Comments { get; set; }
-
- public String MachineVersionGuid { get; set; }
-
- public String BlobName { get; set; }
- }
-
- private static List<PendingUpload> _pendingUploads;
-
- static VersionUpdateController()
- {
- _pendingUploads = new List<PendingUpload>();
- }
-
- [HttpPost]
- public LatestVersionResponse GetLatestVersion(LatestVersionRequest request)
- {
- LatestVersionResponse response = new LatestVersionResponse();
-
- using (ObservablesContext db = ObservablesContextHelper.CreateContext())
- {
- var versions = db.TangoVersions.ToList();
-
- if (versions.Count == 0)
- {
- return new LatestVersionResponse()
- {
- Version = "0.0.0.0",
- };
- }
-
- var machine_versions = versions.Where(x => x.MachineVersionGuid == request.MachineVersionGuid).ToList();
-
- if (machine_versions.Count > 0)
- {
- response.Version = db.TangoVersions.Where(x => x.MachineVersionGuid == request.MachineVersionGuid).ToList().OrderByDescending(x => Version.Parse(x.Version)).FirstOrDefault().Version;
- }
- else
- {
- throw new ArgumentException("The specified machine version was not found!");
- }
- }
-
- return response;
- }
-
- [HttpPost]
- public UploadVersionResponse UploadVersion(UploadVersionRequest request)
- {
- UploadVersionResponse response = new UploadVersionResponse();
-
- using (ObservablesContext db = ObservablesContextHelper.CreateContext())
- {
- //Load relations first...
- db.Roles.ToList();
- db.Permissions.ToList();
- db.UsersRoles.ToList();
- db.RolesPermissions.ToList();
-
- var user = db.Users.SingleOrDefault(x => x.Email.ToLower() == request.Email.ToLower() && x.Password == request.Password);
-
- if (user != null && user.HasPermission(Permissions.PublishMachineStudioVersion))
- {
- var versions = db.TangoVersions.ToList().Where(x => x.MachineVersionGuid == request.MachineVersionGuid).OrderByDescending(x => Version.Parse(x.Version)).ToList();
-
- TangoVersion latestVersion = new TangoVersion();
- latestVersion.Version = "0.0.0.0";
-
- if (versions.Count > 0)
- {
- latestVersion = versions.FirstOrDefault();
- }
-
- Version currentVersion = Version.Parse(request.Version);
-
- if (currentVersion > Version.Parse(latestVersion.Version))
- {
- String newVersionFileName = "Tango Version" + " " + currentVersion.ToString() + ".zip";
-
- var client = StorageHelper.GetStorageBlobClient();
- var container = StorageHelper.GetTangoVersionsContainer(client);
- var blob = StorageHelper.CreateEmptyBlob(container, newVersionFileName);
-
- response.Token = Guid.NewGuid().ToString();
- response.BlobAddress = StorageHelper.GenerateBlobWriteSignature(blob, TimeSpan.FromMinutes(30));
-
- _pendingUploads.Add(new PendingUpload()
- {
- UserGuid = user.Guid,
- Comments = request.Comments,
- Token = response.Token,
- Version = request.Version,
- BlobName = blob.Name,
- MachineVersionGuid = request.MachineVersionGuid,
- });
- }
- else
- {
- throw new ArgumentException("New version must be greater than latest version.");
- }
- }
- else
- {
- throw new AuthenticationException("Invalid user credentials.");
- }
- }
-
- return response;
- }
-
- [HttpPost]
- public UploadCompletedResponse NotifyUploadCompleted(UploadCompletedRequest request)
- {
- PendingUpload upload = _pendingUploads.FirstOrDefault(x => x.Token == request.Token);
-
- if (upload != null)
- {
- _pendingUploads.RemoveAll(x => x.Token == upload.Token);
-
- using (ObservablesContext db = ObservablesContextHelper.CreateContext())
- {
- db.TangoVersions.Add(new TangoVersion()
- {
- Comments = upload.Comments,
- BlobName = upload.BlobName,
- UserGuid = upload.UserGuid,
- Version = upload.Version,
- MachineVersionGuid = upload.MachineVersionGuid
- });
-
- db.SaveChanges();
- }
-
- return new UploadCompletedResponse();
- }
- else
- {
- throw new AuthenticationException("Invalid upload token.");
- }
- }
- }
-}