Major refactor of the webserver

Added support for setting listening interface for the webserver Added support for starting the webserver with a password
2014-06-27 13:23:05 +02:00
parent 53aaf32455
commit 6203ed849c
22 changed files with 2303 additions and 1654 deletions
@@ -0,0 +1,155 @@
+//  Copyright (C) 2014, Kenneth Skovhede
+
+//  http://www.hexad.dk, opensource@hexad.dk
+//
+//  This library is free software; you can redistribute it and/or modify
+//  it under the terms of the GNU Lesser General Public License as
+//  published by the Free Software Foundation; either version 2.1 of the
+//  License, or (at your option) any later version.
+//
+//  This library is distributed in the hope that it will be useful, but
+//  WITHOUT ANY WARRANTY; without even the implied warranty of
+//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+//  Lesser General Public License for more details.
+//
+//  You should have received a copy of the GNU Lesser General Public
+//  License along with this library; if not, write to the Free Software
+//  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+using System;
+using System.Linq;
+using Duplicati.Server.Serialization;
+using System.IO;
+
+namespace Duplicati.Server.WebServer
+{
+    partial class ControlHandler
+    {
+        private class AddOrUpdateBackupData
+        {
+            public Database.Schedule Schedule {get; set;}
+            public Database.Backup Backup {get; set;}
+        }
+
+        private void UpdateBackup(HttpServer.IHttpRequest request, HttpServer.IHttpResponse response, HttpServer.Sessions.IHttpSession session, BodyWriter bw)
+        {
+            string str = request.Form["data"].Value;
+            if (string.IsNullOrWhiteSpace(str))
+            {
+                ReportError(response, bw, "Missing backup object");
+                return;
+            }
+
+            AddOrUpdateBackupData data = null;
+            try
+            {
+                data = Serializer.Deserialize<AddOrUpdateBackupData>(new StringReader(str));
+                if (data.Backup == null)
+                {
+                    ReportError(response, bw, "Data object had no backup entry");
+                    return;
+                }
+
+                if (data.Backup.ID == null)
+                {
+                    ReportError(response, bw, "Invalid or missing backup id");
+                    return;
+                }                    
+
+                if (data.Backup.IsTemporary)
+                {
+                    var backup = Program.DataConnection.GetBackup(data.Backup.ID);
+                    if (backup.IsTemporary)
+                        throw new InvalidDataException("External is temporary but internal is not?");
+
+                    Program.DataConnection.UpdateTemporaryBackup(backup);
+                    bw.WriteJsonObject(new { status = "OK" });
+                }
+                else
+                {                    
+                    lock(Program.DataConnection.m_lock)
+                    {
+                        var backup = Program.DataConnection.GetBackup(data.Backup.ID);
+                        if (backup == null)
+                        {
+                            ReportError(response, bw, "Invalid or missing backup id");
+                            return;
+                        }
+
+                        if (Program.DataConnection.Backups.Where(x => x.Name.Equals(data.Backup.Name, StringComparison.InvariantCultureIgnoreCase) && x.ID != data.Backup.ID).Any())
+                        {
+                            ReportError(response, bw, "There already exists a backup with the name: " + data.Backup.Name);
+                            return;
+                        }
+
+                        //TODO: Merge in real passwords where the placeholder is found
+                        Program.DataConnection.AddOrUpdateBackupAndSchedule(data.Backup, data.Schedule);
+
+                    }
+
+                    bw.WriteJsonObject(new { status = "OK" });
+                }
+            }
+            catch (Exception ex)
+            {
+                if (data == null)
+                    ReportError(response, bw, string.Format("Unable to parse backup or schedule object: {0}", ex.Message));
+                else
+                    ReportError(response, bw, string.Format("Unable to save backup or schedule: {0}", ex.Message));
+
+            }
+        }
+
+        private void AddBackup(HttpServer.IHttpRequest request, HttpServer.IHttpResponse response, HttpServer.Sessions.IHttpSession session, BodyWriter bw)
+        {
+            var str = request.Form["data"].Value;
+            if (string.IsNullOrWhiteSpace(str))
+            {
+                ReportError(response, bw, "Missing backup object");
+                return;
+            }
+
+            AddOrUpdateBackupData data = null;
+            try
+            {
+                data = Serializer.Deserialize<AddOrUpdateBackupData>(new StringReader(str));
+                if (data.Backup == null)
+                {
+                    ReportError(response, bw, "Data object had no backup entry");
+                    return;
+                }
+
+                data.Backup.ID = null;
+
+                if (Duplicati.Library.Utility.Utility.ParseBool(request.Form["temporary"].Value, false))
+                {
+                    Program.DataConnection.RegisterTemporaryBackup(data.Backup);
+
+                    bw.WriteJsonObject(new { status = "OK", ID = data.Backup.ID });
+                }
+                else
+                {
+                    lock(Program.DataConnection.m_lock)
+                    {
+                        if (Program.DataConnection.Backups.Where(x => x.Name.Equals(data.Backup.Name, StringComparison.InvariantCultureIgnoreCase)).Any())
+                        {
+                            ReportError(response, bw, "There already exists a backup with the name: " + data.Backup.Name);
+                            return;
+                        }
+
+                        Program.DataConnection.AddOrUpdateBackupAndSchedule(data.Backup, data.Schedule);
+                    }
+
+                    bw.WriteJsonObject(new { status = "OK", ID = data.Backup.ID });
+                }
+            }
+            catch (Exception ex)
+            {
+                if (data == null)
+                    ReportError(response, bw, string.Format("Unable to parse backup or schedule object: {0}", ex.Message));
+                else
+                    ReportError(response, bw, string.Format("Unable to save schedule or backup object: {0}", ex.Message));
+            }
+        }
+    }
+}
+