Skip to content

Commit

Permalink
* json formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
ChrisMisztur committed Jul 27, 2021
1 parent 31c6ad6 commit abe26bc
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions fanuc/handlers/Native.cs
Original file line number Diff line number Diff line change
Expand Up @@ -2,13 +2,16 @@
using System.Collections.Generic;
using System.Threading.Tasks;
using l99.driver.@base;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NJsonSchema;

namespace l99.driver.fanuc.handlers
{
public class Native: Handler
{
private readonly Formatting jsonFormatting = Formatting.None;

private Dictionary<string,string> _publishedSchemas = new Dictionary<string, string>();

public Native(Machine machine) : base(machine)
Expand Down Expand Up @@ -49,7 +52,7 @@ public Native(Machine machine) : base(machine)
protected override async Task afterDataArrivalAsync(Veneers veneers, Veneer veneer, dynamic? onArrival)
{
var topic = $"fanuc/{veneers.Machine.Id}-all/{veneer.Name}{(veneer.SliceKey == null ? string.Empty : "/" + veneer.SliceKey.ToString())}";
string payload = JObject.FromObject(onArrival).ToString();
string payload = JObject.FromObject(onArrival).ToString(jsonFormatting);
await veneers.Machine.Broker.PublishArrivalAsync(topic, payload);
}

Expand Down Expand Up @@ -86,7 +89,7 @@ protected override async Task afterDataArrivalAsync(Veneers veneers, Veneer vene
protected override async Task afterDataChangeAsync(Veneers veneers, Veneer veneer, dynamic? onChange)
{
var topic = $"fanuc/{veneers.Machine.Id}/{veneer.Name}{(veneer.SliceKey == null ? string.Empty : "/" + veneer.SliceKey.ToString())}";
string payload = JObject.FromObject(onChange).ToString();
string payload = JObject.FromObject(onChange).ToString(jsonFormatting);
await veneers.Machine.Broker.PublishChangeAsync(topic, payload);

if (!_publishedSchemas.ContainsKey(veneer.Name))
Expand Down Expand Up @@ -125,7 +128,7 @@ protected override async Task afterSweepCompleteAsync(Machine machine, dynamic?
{
string topic_all = $"fanuc/{machine.Id}-all/ping";
string topic = $"fanuc/{machine.Id}/ping";
string payload = JObject.FromObject(onSweepComplete).ToString();
string payload = JObject.FromObject(onSweepComplete).ToString(jsonFormatting);

await machine.Broker.PublishArrivalStatusAsync(topic_all, payload);
await machine.Broker.PublishChangeStatusAsync(topic, payload);
Expand Down

0 comments on commit abe26bc

Please sign in to comment.