Moved machine studio update azure !!!

6 files changed, 230 insertions, 6 deletions

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..245c18b9b
--- /dev/null
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/MachineStudioController.cs
@@ -0,0 +1,186 @@
+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.MachineService.Helpers;
+using Tango.MachineService.Models;
+using Tango.MachineStudio.Common.Update;
+
+namespace Tango.MachineService.Controllers
+{
+    public class MachineStudioController : JsonController
+    {
+        private static List<MachineStudioPendingUpload> _pendingUploads;
+
+        static MachineStudioController()
+        {
+            _pendingUploads = new List<MachineStudioPendingUpload>();
+        }
+
+        [HttpPost]
+        public CheckForUpdatesResponse CheckForUpdates(CheckForUpdatesRequest request)
+        {
+            LogManager.Log("Request received...");
+
+            CheckForUpdatesResponse response = new CheckForUpdatesResponse();
+
+            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.RunMachineStudio) || (request.Email == "ForceUpdate"))
+                {
+                    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);
+
+                    bool isForcedUpdate = versions.Exists(x => x.ForceUpdate && Version.Parse(x.Version) > currentVersion);
+
+                    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 client = StorageHelper.GetStorageBlobClient();
+                        var container = StorageHelper.GetMachineStudioVersionsContainer(client);
+                        var blob = container.GetBlockBlobReference(latestVersion.BlobName);
+
+                        response.BlobAddress = StorageHelper.GenerateBlobReadSignature(blob, TimeSpan.FromMinutes(60));
+
+                        response.IsUpdateAvailable = true;
+                        response.Version = latestVersion.Version;
+                        response.Comments = latestVersion.Comments;
+                        response.ForcedUpdate = isForcedUpdate;
+                        response.IsStable = latestVersion.Stable;
+                    }
+                }
+                else
+                {
+                    throw new AuthenticationException("Invalid user credentials.");
+                }
+            }
+
+            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.PublishMachineStudioVersion))
+                {
+                    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 client = StorageHelper.GetStorageBlobClient();
+                        var container = StorageHelper.GetMachineStudioVersionsContainer(client);
+                        var blob = StorageHelper.CreateEmptyBlob(container, newVersionFileName);
+
+                        response.Token = Guid.NewGuid().ToString();
+                        response.BlobAddress = StorageHelper.GenerateBlobWriteSignature(blob, 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.Token);
+
+            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" };
+            }
+        }
+    }
+}
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs
index 45396e47a..9ce22bbb0 100644
--- a/Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Controllers/PPCController.cs
@@ -37,13 +37,13 @@ namespace Tango.MachineService.Controllers
 {
     public class PPCController : JsonController
     {
-        private static List<PendingUpload> _pendingUploads;
+        private static List<PPCPendingUpload> _pendingUploads;
 
         #region Constructors
 
         static PPCController()
         {
-            _pendingUploads = new List<PendingUpload>();
+            _pendingUploads = new List<PPCPendingUpload>();
         }
 
         #endregion
@@ -315,7 +315,7 @@ namespace Tango.MachineService.Controllers
                         response.Token = Guid.NewGuid().ToString();
                         response.BlobAddress = StorageHelper.GenerateBlobWriteSignature(blob, TimeSpan.FromMinutes(30));
 
-                        _pendingUploads.Add(new PendingUpload()
+                        _pendingUploads.Add(new PPCPendingUpload()
                         {
                             UserGuid = user.Guid,
                             Comments = request.Comments,
@@ -342,7 +342,7 @@ namespace Tango.MachineService.Controllers
         [HttpPost]
         public UploadCompletedResponse NotifyUploadCompleted(UploadCompletedRequest request)
         {
-            PendingUpload upload = _pendingUploads.FirstOrDefault(x => x.Token == request.Token);
+            PPCPendingUpload upload = _pendingUploads.FirstOrDefault(x => x.Token == request.Token);
 
             if (upload != null)
             {
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Helpers/StorageHelper.cs b/Software/Visual_Studio/Web/Tango.MachineService/Helpers/StorageHelper.cs
index 04d5bbffe..a2cc2a0dc 100644
--- a/Software/Visual_Studio/Web/Tango.MachineService/Helpers/StorageHelper.cs
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Helpers/StorageHelper.cs
@@ -24,6 +24,12 @@ namespace Tango.MachineService.Helpers
             return container;
         }
 
+        public static CloudBlobContainer GetMachineStudioVersionsContainer(CloudBlobClient client)
+        {
+            var container = client.GetContainerReference("machine-studio-versions");
+            return container;
+        }
+
         public static CloudBlockBlob CreateEmptyBlob(CloudBlobContainer container, String name)
         {
             CloudBlockBlob emptyBlob = container.GetBlockBlobReference(name);
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Models/MachineStudioPendingUpload.cs b/Software/Visual_Studio/Web/Tango.MachineService/Models/MachineStudioPendingUpload.cs
new file mode 100644
index 000000000..0347d35ea
--- /dev/null
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Models/MachineStudioPendingUpload.cs
@@ -0,0 +1,26 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Web;
+
+namespace Tango.MachineService.Models
+{
+    public class MachineStudioPendingUpload
+    {
+        public String Token { get; set; }
+
+        public String Version { get; set; }
+
+        public String UserGuid { get; set; }
+
+        public String Comments { get; set; }
+
+        public bool ForcedUpdate { get; set; }
+
+        public String FilePath { get; set; }
+
+        public bool IsStable { get; set; }
+
+        public String BlobName { get; set; }
+    }
+}
\ No newline at end of file
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Models/PendingUpload.cs b/Software/Visual_Studio/Web/Tango.MachineService/Models/PPCPendingUpload.cs
index f18b3756a..10797e758 100644
--- a/Software/Visual_Studio/Web/Tango.MachineService/Models/PendingUpload.cs
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Models/PPCPendingUpload.cs
@@ -5,7 +5,7 @@ using System.Web;
 
 namespace Tango.MachineService.Models
 {
-    public class PendingUpload
+    public class PPCPendingUpload
     {
         public String Token { get; set; }
 
diff --git a/Software/Visual_Studio/Web/Tango.MachineService/Tango.MachineService.csproj b/Software/Visual_Studio/Web/Tango.MachineService/Tango.MachineService.csproj
index acb4ad84e..c6245e18e 100644
--- a/Software/Visual_Studio/Web/Tango.MachineService/Tango.MachineService.csproj
+++ b/Software/Visual_Studio/Web/Tango.MachineService/Tango.MachineService.csproj
@@ -270,11 +270,13 @@
     <Compile Include="App_Start\BundleConfig.cs" />
     <Compile Include="App_Start\FilterConfig.cs" />
     <Compile Include="Config.cs" />
+    <Compile Include="Controllers\MachineStudioController.cs" />
     <Compile Include="Helpers\ObservablesContextHelper.cs" />
     <Compile Include="Helpers\StorageHelper.cs" />
     <Compile Include="JsonController.cs" />
     <Compile Include="JsonNetFormatter.cs" />
-    <Compile Include="Models\PendingUpload.cs" />
+    <Compile Include="Models\MachineStudioPendingUpload.cs" />
+    <Compile Include="Models\PPCPendingUpload.cs" />
     <Compile Include="ProtoBufFormatter.cs" />
     <Compile Include="App_Start\RouteConfig.cs" />
     <Compile Include="App_Start\WebApiConfig.cs" />
@@ -305,6 +307,10 @@
     <Content Include="packages.config" />
   </ItemGroup>
   <ItemGroup>
+    <ProjectReference Include="..\..\MachineStudio\Tango.MachineStudio.Common\Tango.MachineStudio.Common.csproj">
+      <Project>{CB0B0AA2-BB24-4BCA-A720-45E397684E12}</Project>
+      <Name>Tango.MachineStudio.Common</Name>
+    </ProjectReference>
     <ProjectReference Include="..\..\PPC\Tango.PPC.Common\Tango.PPC.Common.csproj">
       <Project>{0be74eee-22cb-4dba-b896-793b9e1a3ac0}</Project>
       <Name>Tango.PPC.Common</Name>