ADIX7/FileTime2
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix binary data sending with SignalR

Browse Source
This commit is contained in:
Ádám Kovács
2023-07-27 15:29:59 +02:00
parent bfa971f352
commit 55b1747109
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/Server/FileTime.Server.Common/Connections/SignalR/SignalRConnection.cs
View File

@@ -69,7 +69,7 @@ public class SignalRConnection : IRemoteConnection, IAsyncInitable<string>
=> await _client.MoveItemAsync(contentProviderId, fullName.Path, newPath.Path); => await _client.MoveItemAsync(contentProviderId, fullName.Path, newPath.Path);
public async Task WriteBytesAsync(string transactionId, byte[] data, int? index) public async Task WriteBytesAsync(string transactionId, byte[] data, int? index)
=> await _client.WriteBytesAsync(transactionId, Encoding.UTF8.GetString(data), index ?? -1); => await _client.WriteBytesAsync(transactionId, Convert.ToBase64String(data), index ?? -1);
public async Task FlushWriterAsync(string transactionId) public async Task FlushWriterAsync(string transactionId)
=> await _client.FlushWriterAsync(transactionId); => await _client.FlushWriterAsync(transactionId);

4
src/Server/FileTime.Server.Web/ConnectionHub.cs
View File

@@ -74,8 +74,8 @@ public class ConnectionHub : Hub<ISignalRClient>, ISignalRHub
_contentAccessManager.AddContentWriter(transactionId, contentWriter); _contentAccessManager.AddContentWriter(transactionId, contentWriter);
} }
public async Task WriteBytesAsync(string transactionId, string data, int index) public async Task WriteBytesAsync(string transactionId, string data, int index)
=> await _contentAccessManager.GetContentWriter(transactionId).WriteBytesAsync(Encoding.UTF8.GetBytes(data), index == -1 ? null : index); => await _contentAccessManager.GetContentWriter(transactionId).WriteBytesAsync(Convert.FromBase64String(data), index == -1 ? null : index);
public async Task FlushWriterAsync(string transactionId) public async Task FlushWriterAsync(string transactionId)
=> await _contentAccessManager.GetContentWriter(transactionId).FlushAsync(); => await _contentAccessManager.GetContentWriter(transactionId).FlushAsync();