selery.event.node.node source code

1 /*
2  * Copyright (c) 2017-2019 sel-project
3  *
4  * Permission is hereby granted, free of charge, to any person obtaining a copy
5  * of this software and associated documentation files (the "Software"), to deal
6  * in the Software without restriction, including without limitation the rights
7  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
8  * copies of the Software, and to permit persons to whom the Software is
9  * furnished to do so, subject to the following conditions:
10  *
11  * The above copyright notice and this permission notice shall be included in all
12  * copies or substantial portions of the Software.
13  *
14  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
18  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
19  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
20  * SOFTWARE.
21  *
22  */
23 /**
24  * Copyright: Copyright (c) 2017-2019 sel-project
25  * License: MIT
26  * Authors: Kripth
27  * Source: $(HTTP github.com/sel-project/selery/source/selery/event/node/node.d, selery/event/node/node.d)
28  */
29 module selery.event.node.node;
30 
31 import selery.event.node.server : NodeServerEvent;
32 import selery.node.node : Node;
33 import selery.node.server : NodeServer;
34 
35 abstract class NodeEvent : NodeServerEvent {
36 
37 	protected Node _node;
38 
39 	public pure nothrow @safe @nogc this(Node node) {
40 		super(node.server);
41 		this._node = node;
42 	}
43 
44 	public final pure nothrow @property @safe @nogc const(Node) node() {
45 		return this._node;
46 	}
47 
48 }
49 
50 final class NodeAddedEvent : NodeEvent {
51 
52 	public pure nothrow @safe @nogc this(Node node) {
53 		super(node);
54 	}
55 
56 }
57 
58 final class NodeRemovedEvent : NodeEvent {
59 
60 	public pure nothrow @safe @nogc this(Node node) {
61 		super(node);
62 	}
63 
64 }
65 
66 class NodeMessageEvent : NodeEvent {
67 
68 	private ubyte[] _payload;
69 
70 	public pure nothrow @safe @nogc this(Node node, ubyte[] payload) {
71 		super(node);
72 		this._payload = payload;
73 	}
74 
75 	public final pure nothrow @property @safe @nogc ubyte[] payload() {
76 		return this._payload;
77 	}
78 
79 	alias message = payload;
80 
81 	public void reply(ubyte[] message) {
82 		this._node.sendMessage(message);
83 	}
84 
85 }