| | | 1 | | // The message is a base class for the different types of messages being sent and received among the |
| | | 2 | | // agents. It always carries a sender, a receiver, a message type, and a payload. |
| | | 3 | | |
| | | 4 | | using System; |
| | | 5 | | |
| | | 6 | | // Message type enumeration that defines the message payload. |
| | | 7 | | public enum MessageType { |
| | | 8 | | AssignTargetRequest, |
| | | 9 | | AssignTargetResponse, |
| | | 10 | | ReassignTargetRequest, |
| | | 11 | | } |
| | | 12 | | |
| | | 13 | | public abstract class Message { |
| | 1 | 14 | | public CommsNode Sender { get; } |
| | 5 | 15 | | public CommsNode Receiver { get; } |
| | 0 | 16 | | public MessageType Type { get; } |
| | | 17 | | |
| | | 18 | | public abstract IMessagePayload Payload { get; } |
| | | 19 | | |
| | 4 | 20 | | protected Message(CommsNode sender, CommsNode receiver, MessageType type) { |
| | 2 | 21 | | Sender = sender ?? throw new ArgumentNullException(nameof(sender)); |
| | 2 | 22 | | Receiver = receiver ?? throw new ArgumentNullException(nameof(receiver)); |
| | 2 | 23 | | Type = type; |
| | 2 | 24 | | } |
| | | 25 | | } |
| | | 26 | | |
| | | 27 | | // Generic message that stores a payload. The generic type refers to the payloa type. |
| | | 28 | | public abstract class Message<TPayload> : Message |
| | | 29 | | where TPayload : class, IMessagePayload { |
| | | 30 | | public TPayload PayloadData { get; } |
| | | 31 | | public sealed override IMessagePayload Payload => PayloadData; |
| | | 32 | | protected Message(CommsNode sender, CommsNode receiver, MessageType type, TPayload payload) |
| | | 33 | | : base(sender, receiver, type) { |
| | | 34 | | PayloadData = payload ?? throw new ArgumentNullException(nameof(payload)); |
| | | 35 | | } |
| | | 36 | | } |
| | | 37 | | |
| | | 38 | | // This message is sent upwards to a parent interceptor or IADS when a sub-interceptor has no target |
| | | 39 | | // and is requesting a new target. |
| | | 40 | | public sealed class AssignTargetRequestMessage : Message<AssignTargetRequestPayload> { |
| | | 41 | | public AssignTargetRequestMessage(CommsNode sender, CommsNode receiver, |
| | | 42 | | IInterceptor subInterceptor) |
| | | 43 | | : base(sender, receiver, MessageType.AssignTargetRequest, |
| | | 44 | | new AssignTargetRequestPayload(subInterceptor)) {} |
| | | 45 | | } |
| | | 46 | | |
| | | 47 | | // This message is sent downwards from the IADS or a parent interceptor to inform the |
| | | 48 | | // sub-interceptor of a new target. |
| | | 49 | | public sealed class AssignTargetResponseMessage : Message<AssignTargetResponsePayload> { |
| | | 50 | | public AssignTargetResponseMessage(CommsNode sender, CommsNode receiver, IHierarchical target) |
| | | 51 | | : base(sender, receiver, MessageType.AssignTargetResponse, |
| | | 52 | | new AssignTargetResponsePayload(target)) {} |
| | | 53 | | } |
| | | 54 | | |
| | | 55 | | // This message is sent upwards to a parent interceptor or IADS when a sub-interceptor can no longer |
| | | 56 | | // pursue the current target and is requesting the parent interceptor or IADS to reassign that |
| | | 57 | | // target elsewhere. |
| | | 58 | | public sealed class ReassignTargetRequestMessage : Message<ReassignTargetRequestPayload> { |
| | | 59 | | public ReassignTargetRequestMessage(CommsNode sender, CommsNode receiver, IHierarchical target) |
| | | 60 | | : base(sender, receiver, MessageType.ReassignTargetRequest, |
| | | 61 | | new ReassignTargetRequestPayload(target)) {} |
| | | 62 | | } |