cartaid/shopping-assistant-web-client
1
0
Fork 0
mirror of https://github.com/Shchoholiev/shopping-assistant-web-client.git synced 2025-04-04 16:49:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

SA-148 sse processing method created

Browse Source
This commit is contained in:
Mykhailo Bilodid 2023-11-09 02:25:08 +02:00
parent 606fc820da
commit 7e72a1323b
4 changed files with 72 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
ShoppingAssistantWebClient.Web/Models/Enums/SearchEventType.cs Normal file
View File

@ -0,0 +1,9 @@
namespace ShoppingAssistantWebClient.Web.Models.Enums;
public enum SearchEventType
{
Wishlist = 0,
Message = 1,
Suggestion = 2,
Product = 3
}

6
ShoppingAssistantWebClient.Web/Models/Input/MessageCreateDto.cs Normal file
View File

@ -0,0 +1,6 @@
namespace ShoppingAssistantWebClient.Web.Models.Input;
public class MessageCreateDto
{
public required string Text { get; set; }
}

10
ShoppingAssistantWebClient.Web/Models/ProductSearch/ServerSentEvent.cs Normal file
View File

@ -0,0 +1,10 @@
using ShoppingAssistantWebClient.Web.Models.Enums;
namespace ShoppingAssistantWebClient.Web.Models.ProductSearch;
public class ServerSentEvent
{
public SearchEventType Event { get; set; }
public string Data { get; set; }
}

47
ShoppingAssistantWebClient.Web/Network/ApiClient.cs
View File

@ -3,6 +3,9 @@ using GraphQL;
using Newtonsoft.Json;
using System.Net.Http.Headers;
using ShoppingAssistantWebClient.Web.Models.GlobalInstances;
using ShoppingAssistantWebClient.Web.Models.ProductSearch;
using System.Text;
using ShoppingAssistantWebClient.Web.Models.Enums;
namespace ShoppingAssistantWebClient.Web.Network;
@ -93,6 +96,50 @@ public class ApiClient
return model;
}
public async IAsyncEnumerable<ServerSentEvent> GetServerSentEventStreamed(string url, Object obj, CancellationToken cancellationToken)
{
await SetAuthenticationAsync();
var requestUrl = $"{_httpClient.BaseAddress}{url}";
var response = await _httpClient.PostAsJsonAsync(requestUrl, obj);
using var responseStream = await response.Content.ReadAsStreamAsync();
using var reader = new StreamReader(responseStream, Encoding.UTF8);
SearchEventType eventType = SearchEventType.Message;
while (!cancellationToken.IsCancellationRequested)
{
var jsonChunk = await reader.ReadLineAsync(cancellationToken);
if (jsonChunk == null) continue;
if (jsonChunk.StartsWith("event: "))
{
var type = jsonChunk.Substring("event: ".Length);
switch(type)
{
case "Message":
eventType = SearchEventType.Message;
break;
case "Suggestion":
eventType = SearchEventType.Suggestion;
break;
case "Product":
eventType = SearchEventType.Product;
break;
case "Wishlist":
eventType = SearchEventType.Wishlist;
break;
}
}
if (jsonChunk.StartsWith("data: "))
{
yield return new ServerSentEvent
{
Event = eventType,
Data = jsonChunk.Substring("data: ".Length),
};
}
}
}
private MultipartFormDataContent MapIFormCollectionToForm(IFormCollection formCollection)
{
var formDataContent = new MultipartFormDataContent();