using System; using System.Collections.Generic; namespace RoboidControl { /// /// A participant is a device which manages things. /// /// It can communicate with other participant to synchronise the state of things. /// This class is used to register the things the participant is managing. /// It also maintains the communcation information to contact the participant. /// It is used as a basis for the local participant, but also as a reference to remote participants. public class Participant { /// /// Default constructor /// public Participant() { } /// /// Create a new participant with the given communcation info /// /// The IP address of the participant /// The UDP port of the participant public Participant(string ipAddress, int port) { this.ipAddress = ipAddress; this.port = port; } /// /// The Ip Address of a participant. When the participant is local, this contains 0.0.0.0 /// public string ipAddress = "0.0.0.0"; /// /// The port number for UDP communication with the participant. This is 0 for isolated participants. /// public int port = 0; /// /// The network ID of the participant /// public byte networkId; /// /// The things managed by this participant /// protected readonly List things = new List(); /// /// Get a thing with the given ids /// /// The network ID of the thing /// The ID of the thing /// The thing when it is found, null in other cases. public Thing Get(byte networkId, byte thingId) { Thing thing = things.Find(aThing => aThing.id == thingId); //Thing thing = things.Find(aThing => Thing.IsThing(aThing, networkId, thingId)); // if (thing == null) // Console.WriteLine($"Could not find thing {ipAddress}:{port}[{networkId}/{thingId}]"); return thing; } /// /// Add a new thing for this participant /// /// The thing to add /// Invoke an notification event when the thing has been added public void Add(Thing thing, bool checkId = true, bool invokeEvent = true) { if (checkId && thing.id == 0) { thing.id = (byte)(this.things.Count + 1); things.Add(thing); } // Console.WriteLine($"added thing [{thing.networkId}/{thing.id}]"); Thing foundThing = Get(thing.networkId, thing.id); if (foundThing == null) { things.Add(thing); // if (invokeEvent) // Thing.InvokeNewThing(thing); // Console.Write($"Add thing {ipAddress}:{port}[{networkId}/{thing.id}]"); } // else { // if (thing != foundThing) { // // should be: find first non-existing id... // thing.id = (byte)this.things.Count; // things.Add(thing); // // Console.Write($"Add thing, updated thing id to [{thing.networkId}/{thing.id}]"); // } // } } /// /// Remove a thing for this participant /// /// The thing to remove public void Remove(Thing thing) { this.things.Remove(thing); } } }