Horizon – Diff between revs 24 and 27

Subversion Repositories:

?pathlinks?

Rev 24 – Details – Blame – Last modification – View Log

         private static ScheduledContinuation _searchTextBoxChangedContinuation;
-        #endregion
-        #region Public Events & Delegates
-        public event EventHandler<PreviewRetrievedEventArgs> PreviewRetrieved;
         #endregion
         #region Private Delegates, Events, Enums, Properties, Indexers and Fields
         private readonly MainForm _mainForm;
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
-                {
-                    var fileStream = await _snapshotDatabase.RetrieveFileStreamAsync(
+                {
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                        (string)rows[i].Cells["HashColumn"].Value,
-                        cancellationToken);
+                    var fileStream = await _snapshotDatabase.RetrieveFileStreamAsync(hash, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccessRetrieveFileStream(rows[i], i, fileStream));
+                }
+            }
+        }
         private void SnapshotManagerForm_Resize(object sender, EventArgs e)
         {
-            if (_snapshotPreviewForm != null)
+            if (_snapshotPreviewForm is { Visible: true })
+            {
                 _snapshotPreviewForm.WindowState = WindowState;
+            }
+            }
             Process.Start("explorer.exe", $"/select, \"{(string)row.Cells["PathColumn"].Value}\"");
         }
-        private async void DataGridView1_CellClick(object sender, DataGridViewCellEventArgs e)
+        private void DataGridView1_CellClick(object sender, DataGridViewCellEventArgs e)
-        {
-            var dataGridView = (DataGridView)sender;
-            if (_snapshotPreviewForm == null)
-            {
-                _snapshotPreviewForm = new SnapshotPreviewForm(this, _snapshotDatabase);
-                _snapshotPreviewForm.Owner = this;
-                _snapshotPreviewForm.Closing += SnapshotPreviewForm_Closing;
                 _snapshotPreviewForm.Show();
             var dataGridView = (DataGridView)sender;
             var row = GetSelectedDataGridViewRows(dataGridView).FirstOrDefault();
             if (row == null)
+            {
-                return;
-            }
-            var hash = (string)row.Cells["HashColumn"].Value;
+                return;
             var snapshotPreview =
-                await Task.Run(async () => await _snapshotDatabase.RetrievePreviewAsync(hash, _cancellationToken),
-                    _cancellationToken);
+            var hash = (string)row.Cells["HashColumn"].Value;
+            if (_snapshotPreviewForm is { Visible: true })
+            {
+                _snapshotPreviewForm.Close();
             if (snapshotPreview == null)
-                return;
+            _snapshotPreviewForm = new SnapshotPreviewForm(this, hash, _snapshotDatabase, _cancellationToken);
-            }
+            _snapshotPreviewForm.Owner = this;
             _snapshotPreviewForm.Closing += SnapshotPreviewForm_Closing;
-            PreviewRetrieved?.Invoke(this, new PreviewRetrievedEventArgs(snapshotPreview));
+            _snapshotPreviewForm.Show();
+        }
         private void SnapshotPreviewForm_Closing(object sender, CancelEventArgs e)
-        private void SnapshotPreviewForm_Closing(object sender, CancelEventArgs e)
+        {
-            if (_snapshotPreviewForm == null)
+            if (_snapshotPreviewForm is { Visible: false })
+            {
                 return;
         private async void SnapshotManagerForm_Load(object sender, EventArgs e)
+        {
             // Start browsing for network services.
             _horizonServiceBrowser.Browse("_horizon._tcp", "local");
+            int count;
+            try
+            {
+                count = (int)await _snapshotDatabase.CountSnapshotsAsync(_cancellationToken);
+            }
+            catch (Exception exception)
+            {
+                Log.Error(exception, "Could not count snapshots.");
+                return;
+            }
+            if (count == 0)
+            {
+                return;
+            }
             // Load snapshots.
             toolStripProgressBar1.Minimum = 0;
-            toolStripProgressBar1.Maximum = (int)await _snapshotDatabase.CountSnapshotsAsync(_cancellationToken);
+            toolStripProgressBar1.Maximum = count;
             var snapshotQueue = new ConcurrentQueue<Snapshot>();
         private void SnapshotManagerForm_Closing(object sender, FormClosingEventArgs e)
+        {
             _cancellationTokenSource.Cancel();
-            if (_snapshotPreviewForm != null)
+            if (_snapshotPreviewForm is { Visible: true })
-            {
                 _snapshotPreviewForm.Close();
-                _snapshotPreviewForm = null;
+                _snapshotPreviewForm.Close();
+            }
-            if (_hexViewForm != null)
             if (_hexViewForm is { Visible: true })
                 _hexViewForm.Close();
-                _hexViewForm = null;
+                _hexViewForm.Close();
+            }
                         var name = Path.GetFileName(directoryFile);
                         var path = Path.Combine(Path.GetDirectoryName(directoryFile), name);
                         try
                         {
-                            await _snapshotDatabase.CreateSnapshotAsync(name, path, screenCapture, color,
-                                _cancellationToken);
+                            await _snapshotDatabase.CreateSnapshotAsync(name, path, screenCapture, color, _cancellationToken);
                             progress.Report(new CreateSnapshotProgressSuccess(file));
+                        }
                     return;
+                }
                 var fileName = Path.GetFileName(file);
                 var fileName = Path.GetFileName(file);
                 var pathName = Path.Combine(Path.GetDirectoryName(file), fileName);
                 toolStripProgressBar1.Value = toolStripProgressBar1.Maximum;
                 toolStripStatusLabel1.Text = "Done.";
+            }
+        }
-        private async void NoteToolStripMenuItem_Click(object sender, EventArgs e)
+        private void NoteToolStripMenuItem_Click(object sender, EventArgs e)
-        {
-            if (_snapshotNote != null)
-            {
-                return;
-            }
+        {
             var row = GetSelectedDataGridViewRows(dataGridView1).FirstOrDefault();
             if (row == null)
+            {
                 return;
-            }
-            try
-            {
+            }
-                var snapshotPreview = await _snapshotDatabase.RetrievePreviewAsync(
-                    (string)row.Cells["HashColumn"].Value, _cancellationToken);
-                if (snapshotPreview == null)
-                {
-                    return;
-                }
-                _snapshotNote = new SnapshotNoteForm(this, snapshotPreview);
-                _snapshotNote.Owner = this;
-                _snapshotNote.SaveNote += SnapshotNote_SaveNote;
-                _snapshotNote.Closing += SnapshotNote_Closing;
-                _snapshotNote.Show();
+            var hash = (string)row.Cells["HashColumn"].Value;
-            }
-            catch (Exception exception)
+            if (_snapshotNoteForm is { Visible: true })
+            {
+                _snapshotNoteForm.Close();
+            }
+            _snapshotNoteForm = new SnapshotNoteForm(hash, _snapshotDatabase, _cancellationToken);
+            _snapshotNoteForm.Owner = this;
             _snapshotNoteForm.SaveNote += SnapshotNoteFormSaveNoteForm;
-                Log.Error(exception, "Could not open notes form.");
+            _snapshotNoteForm.Closing += SnapshotNoteForm_Closing;
             _snapshotNoteForm.Show();
+        }
                 toolStripProgressBar1.Value = toolStripProgressBar1.Maximum;
                 toolStripStatusLabel1.Text = "Done.";
+            }
+        }
-        private void SnapshotNote_Closing(object sender, CancelEventArgs e)
+        private void SnapshotNoteForm_Closing(object sender, CancelEventArgs e)
         {
-            if (_snapshotNote == null)
+            if (_snapshotNoteForm is { Visible: false })
+            {
                 return;
             }
-            _snapshotNote.Closing -= SnapshotNote_Closing;
+            _snapshotNoteForm.SaveNote -= SnapshotNoteFormSaveNoteForm;
-            _snapshotNote.Close();
+            _snapshotNoteForm.Closing -= SnapshotNoteForm_Closing;
-            _snapshotNote = null;
+            _snapshotNoteForm.Dispose();
+        }
-        private async void ViewHexToolStripMenuItem_Click(object sender, EventArgs e)
+        private void ViewHexToolStripMenuItem_Click(object sender, EventArgs e)
+        {
             var rows = GetSelectedDataGridViewRows(dataGridView1);
             var row = rows.FirstOrDefault();
             if (row == null)
+            {
                 return;
+            }
-            var hash = (string)row.Cells["HashColumn"].Value;
-            using (var memoryStream = await _snapshotDatabase.RetrieveFileStreamAsync(hash, _cancellationToken))
-            {
-                if (memoryStream == null)
-                {
-                    return;
-                }
-                if (_hexViewForm != null)
-                {
-                    _hexViewForm.UpdateData(memoryStream.ToArray());
-                    _hexViewForm.Activate();
-                    return;
-                }
-                _hexViewForm = new HexViewForm(_snapshotDatabase, hash, memoryStream.ToArray());
-                _hexViewForm.Owner = this;
+            var hash = (string)row.Cells["HashColumn"].Value;
+            if (_hexViewForm is { Visible: true })
+            {
+                _hexViewForm.Close();
+            }
-                _hexViewForm.Closing += HexViewForm_Closing;
+            _hexViewForm = new HexViewForm(hash, _snapshotDatabase, _cancellationToken);
-                _hexViewForm.SaveData += HexViewForm_SaveData;
+            _hexViewForm.Owner = this;
             _hexViewForm.Closing += HexViewForm_Closing;
+            _hexViewForm.SaveData += HexViewForm_SaveData;
+            _hexViewForm.Show();
+        }
-                _hexViewForm.Show();
+        private async void HexViewForm_SaveData(object sender, SaveDataEventArgs e)
+        {
+            string hash;
+            try
+            {
+                hash = await _snapshotDatabase.UpdateFileAsync(e.Hash, e.Data, _cancellationToken);
+            }
             catch (Exception exception)
+            {
-        private async void HexViewForm_SaveData(object sender, SaveDataEventArgs e)
+                Log.Error(exception, "Could not update snapshot data.");
             });
+        }
         private void HexViewForm_Closing(object sender, CancelEventArgs e)
         {
-            if (_hexViewForm == null)
+            if (_hexViewForm is { Visible: false })
+            {
                 return;
+            }
             _hexViewForm.SaveData -= HexViewForm_SaveData;
-            _hexViewForm.Closing -= HexViewForm_Closing;
-            _hexViewForm.Close();
+            _hexViewForm.Closing -= HexViewForm_Closing;
-            _hexViewForm = null;
+            _hexViewForm.Dispose();
+        }
             for (var index = 0; index < count && !cancellationToken.IsCancellationRequested; ++index)
+            {
                 try
                 {
+                    var hash = (string)rows[index].Cells["HashColumn"].Value;
-                    await _snapshotDatabase.RemoveFileAsync((string)rows[index].Cells["HashColumn"].Value,
-                        cancellationToken);
+                    await _snapshotDatabase.RemoveFileAsync(hash, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[index], index));
+                }
         private async Task DeleteFilesFast(IReadOnlyList<DataGridViewRow> rows, CancellationToken cancellationToken)
+        {
+            var hashes = rows.Select(row => (string)row.Cells["HashColumn"].Value);
-            var hashes = rows.Select(row => (string)row.Cells["HashColumn"].Value);
+            try
+            {
+                await _snapshotDatabase.RemoveFileFastAsync(hashes, cancellationToken);
+            }
+            catch (Exception exception)
+            {
                 Log.Error(exception, "Failed to remove files.");
             await _snapshotDatabase.RemoveFileFastAsync(hashes, cancellationToken);
+        }
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
                 {
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                    await _snapshotDatabase.UpdateNoteAsync((string)rows[i].Cells["HashColumn"].Value, note,
-                        cancellationToken);
+                    await _snapshotDatabase.UpdateNoteAsync(hash, note,cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
+                }
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
                 {
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                    await _snapshotDatabase.RemoveColorAsync((string)rows[i].Cells["HashColumn"].Value,
-                        cancellationToken);
+                    await _snapshotDatabase.RemoveColorAsync(hash, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
+                }
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
                 {
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                    await _snapshotDatabase.UpdateColorAsync((string)rows[i].Cells["HashColumn"].Value, color,
-                        cancellationToken);
+                    await _snapshotDatabase.UpdateColorAsync(hash, color, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
+                }
                 for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+                {
                     try
+                    {
+                        var hash = (string)rows[i].Cells["HashColumn"].Value;
                         var completeSnapshot =
-                            await _snapshotDatabase.GenerateTransferSnapshotAsync(
-                                (string)rows[i].Cells["HashColumn"].Value, cancellationToken);
+                            await _snapshotDatabase.GenerateTransferSnapshotAsync(hash, cancellationToken);
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
                 {
-                    await _snapshotDatabase.RevertFileAsync((string)rows[i].Cells["NameColumn"].Value,
+                    var path = (string)rows[i].Cells["NameColumn"].Value;
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                        (string)rows[i].Cells["HashColumn"].Value,
-                        cancellationToken, _mainForm.Configuration.AtomicOperations);
+                    await _snapshotDatabase.RevertFileAsync(path, hash, cancellationToken, _mainForm.Configuration.AtomicOperations);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
+                }
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
+                {
                     var hash = (string)rows[i].Cells["HashColumn"].Value;
                     var fileInfo = new FileInfo((string)rows[i].Cells["NameColumn"].Value);
                     var file = fileInfo.Name;
                     var path = Path.Combine(directory, file);
                     await _snapshotDatabase.SaveFileAsync(path, (string)rows[i].Cells["HashColumn"].Value,
-                        cancellationToken);
+                    await _snapshotDatabase.SaveFileAsync(path, hash, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
+                {
                     var hash = (string)rows[i].Cells["HashColumn"].Value;
                     var path = Path.Combine(directory, (string)rows[i].Cells["NameColumn"].Value);
                     await _snapshotDatabase.RelocateFileAsync((string)rows[i].Cells["HashColumn"].Value, path,
-                        cancellationToken);
+                    await _snapshotDatabase.RelocateFileAsync(hash, path, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
                 {
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                    using (var memoryStream =
-                           await _snapshotDatabase.RetrieveFileStreamAsync((string)rows[i].Cells["HashColumn"].Value,
+                    using var memoryStream = await _snapshotDatabase.RetrieveFileStreamAsync(hash, cancellationToken);
-                               cancellationToken))
+                    if (memoryStream == null)
-                    {
-                        if (memoryStream == null)
-                        {
+                    {
-                            continue;
+                        continue;
-                        }
+                    }
-                        using (var md5 = MD5.Create())
-                        {
-                            var recomputedHash = md5.ComputeHash(memoryStream);
+                    using var md5 = MD5.Create();
+                    var recomputedHash = md5.ComputeHash(memoryStream);
-                            var hashHex = BitConverter.ToString(recomputedHash).Replace("-", "")
+                    var hashHex = BitConverter.ToString(recomputedHash).Replace("-", "")
-                                .ToLowerInvariant();
+                        .ToLowerInvariant();
-                            await _snapshotDatabase.UpdateHashAsync((string)rows[i].Cells["HashColumn"].Value, hashHex,
+                    await _snapshotDatabase.UpdateHashAsync(hash, hashHex,
-                                cancellationToken);
-                            rows[i].Cells["HashColumn"].Value = hashHex;
+                        cancellationToken);
-                            progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
+                    rows[i].Cells["HashColumn"].Value = hashHex;
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
                     var rootPath = new DirectoryInfo(basePath).Name;
                     var relPath = rowPath.Remove(0, basePath.Length).Trim('\\');
                     var newPath = Path.Combine(targetPath, rootPath, relPath);
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
                     var hash = (string)rows[i].Cells["HashColumn"].Value;
                     await _snapshotDatabase.SaveFileAsync(newPath, hash, cancellationToken);
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
                 {
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                    await _snapshotDatabase.NormalizeTimeAsync((string)rows[i].Cells["HashColumn"].Value,
-                        cancellationToken);
+                    await _snapshotDatabase.NormalizeTimeAsync(hash, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
+                }
             for (var i = 0; i < count && !cancellationToken.IsCancellationRequested; ++i)
+            {
                 try
                 {
+                    var hash = (string)rows[i].Cells["HashColumn"].Value;
-                    await _snapshotDatabase.DeleteScreenshotAsync((string)rows[i].Cells["HashColumn"].Value,
-                        cancellationToken);
+                    await _snapshotDatabase.DeleteScreenshotAsync(hash, cancellationToken);
                     progress.Report(new DataGridViewRowProgressSuccess(rows[i], i));
+                }