/Horizon/Database/SnapshotDatabase.cs |
@@ -382,7 +382,7 @@ |
} |
} |
|
public async Task ApplyTransferSnapshotAsync(TransferSnapshot transferSnapshot, CancellationToken cancellationToken) |
public async Task SetCompleteSnapshotAsync(TransferSnapshot transferSnapshot, CancellationToken cancellationToken) |
{ |
await _databaseLock.WaitAsync(cancellationToken); |
try |
@@ -392,7 +392,6 @@ |
{ |
await sqliteConnection.OpenAsync(cancellationToken); |
|
var color = Color.Empty; |
using (var dbTransaction = sqliteConnection.BeginTransaction()) |
{ |
try |
@@ -446,13 +445,11 @@ |
{ |
case 0: |
sqliteCommand.Parameters.Add( |
new SQLiteParameter("@color", DBNull.Value)); |
color = Color.Empty; |
new SQLiteParameter("@color", null)); |
break; |
default: |
sqliteCommand.Parameters.Add( |
new SQLiteParameter("@color", numeric)); |
color = Color.FromArgb(transferSnapshot.Color); |
break; |
} |
|
@@ -505,13 +502,10 @@ |
dbTransaction.Commit(); |
|
SnapshotCreate?.Invoke(this, |
new SnapshotCreateSuccessEventArgs( |
transferSnapshot.Name, |
transferSnapshot.Time, |
transferSnapshot.Path, |
color, |
transferSnapshot.Hash) |
); |
new SnapshotCreateSuccessEventArgs(transferSnapshot.Name, |
transferSnapshot.Time, transferSnapshot.Path, |
Color.FromArgb(transferSnapshot.Color), |
transferSnapshot.Hash)); |
} |
} |
} |
@@ -525,12 +519,8 @@ |
if (exception.ResultCode != SQLiteErrorCode.Constraint) |
{ |
SnapshotCreate?.Invoke(this, |
new SnapshotCreateFailureEventArgs( |
transferSnapshot.Name, |
transferSnapshot.Path, |
color, |
exception) |
); |
new SnapshotCreateFailureEventArgs(transferSnapshot.Name, transferSnapshot.Path, |
Color.FromArgb(transferSnapshot.Color), exception)); |
} |
|
throw; |
@@ -540,12 +530,8 @@ |
dbTransaction.Rollback(); |
|
SnapshotCreate?.Invoke(this, |
new SnapshotCreateFailureEventArgs( |
transferSnapshot.Name, |
transferSnapshot.Path, |
color, |
exception) |
); |
new SnapshotCreateFailureEventArgs(transferSnapshot.Name, transferSnapshot.Path, |
Color.FromArgb(transferSnapshot.Color), exception)); |
|
throw; |
} |
@@ -559,7 +545,7 @@ |
} |
|
|
public async Task<TransferSnapshot> GenerateTransferSnapshotAsync(string hash, CancellationToken cancellationToken) |
public async Task<TransferSnapshot> GetCompleteSnapshot(string hash, CancellationToken cancellationToken) |
{ |
await _databaseLock.WaitAsync(cancellationToken); |
try |
@@ -736,7 +722,7 @@ |
{ |
case 0: |
sqliteCommand.Parameters.Add( |
new SQLiteParameter("@color", DBNull.Value)); |
new SQLiteParameter("@color", null)); |
break; |
default: |
sqliteCommand.Parameters.Add( |
@@ -891,7 +877,7 @@ |
{ |
case 0: |
sqliteCommand.Parameters.Add( |
new SQLiteParameter("@color", DBNull.Value)); |
new SQLiteParameter("@color", null)); |
break; |
default: |
sqliteCommand.Parameters.Add( |
@@ -1281,22 +1267,10 @@ |
{ |
sqliteCommand.Parameters.AddRange(new[] |
{ |
new SQLiteParameter("@hash", hash) |
new SQLiteParameter("@hash", hash), |
new SQLiteParameter("@color", color.ToArgb()) |
}); |
|
var numeric = color.ToArgb(); |
switch (numeric) |
{ |
case 0: |
sqliteCommand.Parameters.Add( |
new SQLiteParameter("@color", DBNull.Value)); |
break; |
default: |
sqliteCommand.Parameters.Add( |
new SQLiteParameter("@color", numeric)); |
break; |
} |
|
sqliteCommand.Prepare(); |
|
try |