TTNet.Data 6.2.1

TTNet.Data

A .NET library for The Things Stack MQTT Data API

Install

Available at NuGet:

dotnet add package TTNet.Data

Usage

Create an instance:

var app = new App("Your app ID");

Listen to events:

app.Connected += (s, e) => Console.WriteLine("Connected");

app.Up += (s, e) =>
{
    Console.WriteLine(e.DeviceID);
    foreach (JsonProperty f in e.Message.UplinkMessage.DecodedPayload.EnumerateObject())
        Console.WriteLine($"\t{f.Name}: {f.Value}");

    // Or you can convert it to your data type
    var myObject = e.Message.UplinkMessage.DecodedPayload.Deserialize<MyClass>();
};

Listen to specific devices:

app["deviceId"].Up += (s, e) =>
{
    foreach (JsonProperty f in e.Message.UplinkMessage.DecodedPayload.EnumerateObject())
        Console.WriteLine($"\t{f.Name}: {f.Value}");
};

Connect:

var c = await app.ConnectAsync(cluster, port, withTls, username, apiKey);

See how to create an API key

Example:

var c = await app.ConnectAsync("eu1.cloud.thethings.network", 8883, true, "username@ttn", "XXXXX.XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX.XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX");

You can add or remove events wether connected or disconnected.

Publish messages:

// Raw payload
await app[deviceID].PublishAsync(new Downlink {
    FPort = port,
    FrmPayload = new byte[] { 0x10, 0xF1 }
}, default(CancellationToken));
// JSON payload
await app[deviceID].PublishAsync(new Downlink {
    FPort = port,
    DecodedPayload = JsonSerializer.SerializeToElement(myObject)
}, default(CancellationToken));

Managed

Managed mode is also available. The client is started once and will mantain the connection automatically including reconnecting.

Create a managed instance:

var app = new ManagedApp("Your app ID");

Use StartAsync/StopAsync instead of ConnectAsync/DisconnectAsync:

await app.StartAsync(cluster, port, withTls, username, apiKey, autoReconnectDelay);

Publish messages:

// Raw payload
await app[deviceID].PublishAsync(new Downlink {
    FPort = port,
    FrmPayload = new byte[] { 0x10, 0xF1 }
});
// JSON payload
await app[deviceID].PublishAsync(new Downlink {
    FPort = port,
    DecodedPayload = JsonSerializer.SerializeToElement(myObject)
});