Messages in SSE receive to help debug missing data - no progress yet

This commit is contained in:
Heath Volmer
2018-03-02 13:32:48 -07:00
parent 45ac17622a
commit 2e78191e33
5 changed files with 14 additions and 4 deletions

View File

@@ -4,5 +4,5 @@
[assembly: AssemblyCompany("PepperDash Technology Corp")] [assembly: AssemblyCompany("PepperDash Technology Corp")]
[assembly: AssemblyProduct("PepperDashEssentials")] [assembly: AssemblyProduct("PepperDashEssentials")]
[assembly: AssemblyCopyright("Copyright © PepperDash Technology Corp 2017")] [assembly: AssemblyCopyright("Copyright © PepperDash Technology Corp 2017")]
[assembly: AssemblyVersion("1.0.38.*")] [assembly: AssemblyVersion("1.0.39.*")]

View File

@@ -19,6 +19,8 @@ namespace PepperDash.Essentials
{ {
public class CotijaSystemController : Device public class CotijaSystemController : Device
{ {
int SseMessageLengthBeforeFailureCount;
GenericHttpSseClient SseClient; GenericHttpSseClient SseClient;
/// <summary> /// <summary>
@@ -452,9 +454,13 @@ namespace PepperDash.Essentials
/// <param name="content"></param> /// <param name="content"></param>
void HandleHeartBeat(JToken content) void HandleHeartBeat(JToken content)
{ {
foreach (var b in RoomBridges) var code = content["userCode"];
if(code != null)
{ {
b.SetUserCode(content["userCode"].Value<string>()); foreach (var b in RoomBridges)
{
b.SetUserCode(code.Value<string>());
}
} }
ResetOrStartHearbeatTimer(); ResetOrStartHearbeatTimer();
} }
@@ -468,6 +474,8 @@ namespace PepperDash.Essentials
{ {
if(e.Text.IndexOf("data:") > -1) if(e.Text.IndexOf("data:") > -1)
{ {
SseMessageLengthBeforeFailureCount += e.Text.Length;
var message = e.Text.Substring(6); var message = e.Text.Substring(6);
Debug.Console(1, this, "Message RX: '{0}'", message); Debug.Console(1, this, "Message RX: '{0}'", message);
@@ -582,7 +590,9 @@ namespace PepperDash.Essentials
} }
catch (Exception err) catch (Exception err)
{ {
Debug.Console(1, this, "Unable to parse message: {0}", err); Debug.Console(1, "SseMessageLengthBeforeFailureCount: {0}", SseMessageLengthBeforeFailureCount);
SseMessageLengthBeforeFailureCount = 0;
Debug.Console(1, this, "Unable to parse message: {0}", err);
} }
} }
} }