Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Fixes #112 and cleans up readers and stream #114

Open
wants to merge 6 commits into
base: dev
Choose a base branch
from
Open

Fixes #112 and cleans up readers and stream #114

Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
1e0de8c
Fixes #112 and cleans up readers and stream
danielwertheim Mar 22, 2020
e4e8a36
Reduces one try-catch and uses Switch expression
danielwertheim Mar 22, 2020
d1578d1
Reverts to oldish switch statement to satisfy CI-builds.
danielwertheim Mar 22, 2020
731a26b
Use normal using statements to get CI-build to work
danielwertheim Mar 22, 2020
dd7ed27
Adds check of the TokenType
danielwertheim Mar 28, 2020
53cbc22
simplify
Y-Sindo May 24, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
47 changes: 15 additions & 32 deletions src/Microsoft.Azure.SignalR.Serverless.Protocols/JsonServerlessProtocol.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
using System;
using System.Buffers;
using System.IO;

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

Expand All @@ -18,42 +17,26 @@ public class JsonServerlessProtocol : IServerlessProtocol

public bool TryParseMessage(ref ReadOnlySequence<byte> input, out ServerlessMessage message)
{
var textReader = new JsonTextReader(new StreamReader(new ReadOnlySequenceStream(input)));
var jObject = JObject.Load(textReader);
if (jObject.TryGetValue(TypePropertyName, StringComparison.OrdinalIgnoreCase, out var token))
{
var type = token.Value<int>();
switch (type)
{
case ServerlessProtocolConstants.InvocationMessageType:
message = SafeParseMessage<InvocationMessage>(jObject);
break;
case ServerlessProtocolConstants.OpenConnectionMessageType:
message = SafeParseMessage<OpenConnectionMessage>(jObject);
break;
case ServerlessProtocolConstants.CloseConnectionMessageType:
message = SafeParseMessage<CloseConnectionMessage>(jObject);
break;
default:
message = null;
break;
}
return message != null;
}
message = null;
return false;
}
using var inputStream = new ReadOnlySequenceStream(input);
using var streamReader = new StreamReader(inputStream);
using var textReader = new JsonTextReader(streamReader);

private ServerlessMessage SafeParseMessage<T>(JObject jObject) where T : ServerlessMessage
{
try
{
return jObject.ToObject<T>();
}
catch
{
return null;
var jObject = JObject.Load(textReader);
if (jObject.TryGetValue(TypePropertyName, StringComparison.OrdinalIgnoreCase, out var token)
&& token.Type == JTokenType.Integer)
message = token.Value<int>() switch
{
ServerlessProtocolConstants.InvocationMessageType => jObject.ToObject<InvocationMessage>(),
ServerlessProtocolConstants.OpenConnectionMessageType => jObject.ToObject<OpenConnectionMessage>(),
ServerlessProtocolConstants.CloseConnectionMessageType => jObject.ToObject<CloseConnectionMessage>(),
_ => null,
};
}
catch { }
return message != null;
}
}
}