astarte-platform / astarte-device-sdk-csharp Goto Github PK

Extend AstarteServerPropertyInterface to inherit IAstarteServerValueBuilder and IAstarteServerValuePublisher and implement its methods.

• Update astarte verison in e2e-test work flow from 1.0.4 to 1.1.1
• Allow all data type for sending and receiving

At this moment the pairing URL must be terminated with a slash /, otherwise all pairing requests fails with 404.

Maybe the issue regarding this code:

From C# URI docs:
This constructor creates a Uri instance by combining the baseUri and the relativeUri. If relativeUri is an absolute URI (containing a scheme, host name, and optionally a port number), the Uri instance is created using only relativeUri.

If the baseUri has relative parts (like /api), then the relative part must be terminated with a slash, (like /api/), if the relative part of baseUri is to be preserved in the constructed Uri.

Additionally, if the relativeUri begins with a slash, then it will replace any relative part of the baseUri

This constructor does not ensure that the Uri refers to an accessible resource.
Dotnet-Uri-docs

Check the URL construction with the following URL examples:

• http://localhost:4003
• https://astarte.instance.test/pairing

Implement a logger with four log levels (Info, Error, Warn, Debug) and a standardized log message format: DateTime : LogLevel : Class name : Log message.

Replace all instances of Trace.WriteLine with the AstarteLogger.

The chars /, + and # should not be allowed in endpoint parameters.
This is due to MQTT specifications. As + and # are used as wildcards and / is used as a path separator.

Add to the example:

• How to receive an individual datastream
• How to transmit/receive an object datastream
• How to set/unset a property

Make a new global event listener abstract class and inherit IAstartePropertyEventListener, IAstarteDatastreamEventListener, and IAstarteAggregateDatastreamEventListener.
Create methods for adding and removing event listeners for all interfaces on the device.

Handle the MQTT persistent session in the Astarte way.
Astarte has support for the concept of properties, which are kept synchronized between the server and the device.
Astarte (or the broker) might be inconsistent with a Device's known status and its known properties. Although unlikely, as Astarte should always keep knowledge about remote device status, this might happen, for example, after an internal error. Astarte performs this task by telling the broker to disconnect the device and clear its session. After this, when the device will attempt reconnection, session present will be false.

After a clean session properties might be purged.
https://docs.astarte-platform.org/latest/080-mqtt-v1-protocol.html#session-present

Rename
namespace AstarteDeviceSDKCSharp.Protocol.AstarteExeption to
namespace AstarteDeviceSDKCSharp.Protocol.AstarteException

Astarte action
Create GitHub action using Astarte cluster workflow.

Method Build in AstarteServerAggregateDatastreamInterface class thow exemption. The exemption is "Can not explicitly casting the object to byte[]".

using (MemoryStream ms = new MemoryStream((byte[])serverValue))
            {
                using (BsonDataReader reader = new BsonDataReader(ms))
                {
                    JsonSerializer serializer = new JsonSerializer();
                    astartePayload = serializer.Deserialize<Dictionary<string, object>>(reader);
                }
            }

MemoryStream change with this code

            astartePayload = JsonConvert.DeserializeObject
            <Dictionary<string, object>>(JsonConvert.SerializeObject(serverValue));

Check if the Connect function, when the certificate expires, requests a new certificate to the Astarte Instance.

For testing, you can run an Astarte instance locally and reduce the certificate expiration for example to 5 minutes after that:

1. Connect a device
2. Send some data
3. Disconnect a device for six minutes
4. Reconnect the device
5. Check if the connection was successful
6. Check if the device sends data without issue