// Copyright (c) .NET Foundation. All rights reserved. // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information. using System.Buffers; using System.IO; using System.Threading.Tasks; using Microsoft.AspNetCore.Connections; using Microsoft.Extensions.Logging; namespace SocialWeather { public class SocialWeatherConnectionHandler : ConnectionHandler { private readonly PersistentConnectionLifeTimeManager _lifetimeManager; private readonly FormatterResolver _formatterResolver; private readonly ILogger _logger; public SocialWeatherConnectionHandler(PersistentConnectionLifeTimeManager lifetimeManager, FormatterResolver formatterResolver, ILogger logger) { _lifetimeManager = lifetimeManager; _formatterResolver = formatterResolver; _logger = logger; } public async override Task OnConnectedAsync(ConnectionContext connection) { _lifetimeManager.OnConnectedAsync(connection); await ProcessRequests(connection); _lifetimeManager.OnDisconnectedAsync(connection); } public async Task ProcessRequests(ConnectionContext connection) { var formatter = _formatterResolver.GetFormatter( (string)connection.Items["format"]); while (true) { var result = await connection.Transport.Input.ReadAsync(); var buffer = result.Buffer; try { if (!buffer.IsEmpty) { var stream = new MemoryStream(); var data = buffer.ToArray(); await stream.WriteAsync(data, 0, data.Length); stream.Position = 0; var weatherReport = await formatter.ReadAsync(stream); await _lifetimeManager.SendToAllAsync(weatherReport); } else if (result.IsCompleted) { break; } } finally { connection.Transport.Input.AdvanceTo(buffer.End); } } } } }