BUG-58: refactor to take advantage of netty
[bgpcep.git] / bgp / rib-impl / src / test / java / org / opendaylight / protocol / bgp / rib / impl / SpeakerSessionMock.java
1 /*
2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
3  *
4  * This program and the accompanying materials are made available under the
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6  * and is available at http://www.eclipse.org/legal/epl-v10.html
7  */
8 package org.opendaylight.protocol.bgp.rib.impl;
9
10 import io.netty.buffer.ByteBufAllocator;
11 import io.netty.channel.Channel;
12 import io.netty.channel.ChannelConfig;
13 import io.netty.channel.ChannelFuture;
14 import io.netty.channel.ChannelMetadata;
15 import io.netty.channel.ChannelPipeline;
16 import io.netty.channel.ChannelProgressivePromise;
17 import io.netty.channel.ChannelPromise;
18 import io.netty.channel.EventLoop;
19 import io.netty.util.Attribute;
20 import io.netty.util.AttributeKey;
21 import io.netty.util.HashedWheelTimer;
22
23 import java.net.SocketAddress;
24
25 import org.opendaylight.protocol.bgp.parser.BGPMessage;
26 import org.opendaylight.protocol.bgp.parser.BGPSessionListener;
27 import org.opendaylight.protocol.bgp.parser.message.BGPOpenMessage;
28
29 /**
30  * Mock of the BGP speakers session.
31  */
32 public class SpeakerSessionMock extends BGPSessionImpl {
33
34         private final BGPSessionListener client;
35
36         SpeakerSessionMock(final BGPSessionListener listener, final BGPSessionListener client) {
37                 super(new HashedWheelTimer(), listener, new Channel() {
38
39                         @Override
40                         public <T> Attribute<T> attr(final AttributeKey<T> key) {
41                                 // TODO Auto-generated method stub
42                                 return null;
43                         }
44
45                         @Override
46                         public ChannelFuture bind(final SocketAddress localAddress) {
47                                 // TODO Auto-generated method stub
48                                 return null;
49                         }
50
51                         @Override
52                         public ChannelFuture connect(final SocketAddress remoteAddress) {
53                                 // TODO Auto-generated method stub
54                                 return null;
55                         }
56
57                         @Override
58                         public ChannelFuture connect(final SocketAddress remoteAddress,
59                                         final SocketAddress localAddress) {
60                                 // TODO Auto-generated method stub
61                                 return null;
62                         }
63
64                         @Override
65                         public ChannelFuture disconnect() {
66                                 // TODO Auto-generated method stub
67                                 return null;
68                         }
69
70                         @Override
71                         public ChannelFuture close() {
72                                 // TODO Auto-generated method stub
73                                 return null;
74                         }
75
76                         @Override
77                         public ChannelFuture deregister() {
78                                 // TODO Auto-generated method stub
79                                 return null;
80                         }
81
82                         @Override
83                         public ChannelFuture bind(final SocketAddress localAddress,
84                                         final ChannelPromise promise) {
85                                 // TODO Auto-generated method stub
86                                 return null;
87                         }
88
89                         @Override
90                         public ChannelFuture connect(final SocketAddress remoteAddress,
91                                         final ChannelPromise promise) {
92                                 // TODO Auto-generated method stub
93                                 return null;
94                         }
95
96                         @Override
97                         public ChannelFuture connect(final SocketAddress remoteAddress,
98                                         final SocketAddress localAddress, final ChannelPromise promise) {
99                                 // TODO Auto-generated method stub
100                                 return null;
101                         }
102
103                         @Override
104                         public ChannelFuture disconnect(final ChannelPromise promise) {
105                                 // TODO Auto-generated method stub
106                                 return null;
107                         }
108
109                         @Override
110                         public ChannelFuture close(final ChannelPromise promise) {
111                                 // TODO Auto-generated method stub
112                                 return null;
113                         }
114
115                         @Override
116                         public ChannelFuture deregister(final ChannelPromise promise) {
117                                 // TODO Auto-generated method stub
118                                 return null;
119                         }
120
121                         @Override
122                         public ChannelFuture write(final Object msg) {
123                                 // TODO Auto-generated method stub
124                                 return null;
125                         }
126
127                         @Override
128                         public ChannelFuture write(final Object msg, final ChannelPromise promise) {
129                                 // TODO Auto-generated method stub
130                                 return null;
131                         }
132
133                         @Override
134                         public ChannelFuture writeAndFlush(final Object msg,
135                                         final ChannelPromise promise) {
136                                 // TODO Auto-generated method stub
137                                 return null;
138                         }
139
140                         @Override
141                         public ChannelFuture writeAndFlush(final Object msg) {
142                                 // TODO Auto-generated method stub
143                                 return null;
144                         }
145
146                         @Override
147                         public ChannelPipeline pipeline() {
148                                 // TODO Auto-generated method stub
149                                 return null;
150                         }
151
152                         @Override
153                         public ByteBufAllocator alloc() {
154                                 // TODO Auto-generated method stub
155                                 return null;
156                         }
157
158                         @Override
159                         public ChannelPromise newPromise() {
160                                 // TODO Auto-generated method stub
161                                 return null;
162                         }
163
164                         @Override
165                         public ChannelProgressivePromise newProgressivePromise() {
166                                 // TODO Auto-generated method stub
167                                 return null;
168                         }
169
170                         @Override
171                         public ChannelFuture newSucceededFuture() {
172                                 // TODO Auto-generated method stub
173                                 return null;
174                         }
175
176                         @Override
177                         public ChannelFuture newFailedFuture(final Throwable cause) {
178                                 // TODO Auto-generated method stub
179                                 return null;
180                         }
181
182                         @Override
183                         public ChannelPromise voidPromise() {
184                                 // TODO Auto-generated method stub
185                                 return null;
186                         }
187
188                         @Override
189                         public int compareTo(final Channel o) {
190                                 // TODO Auto-generated method stub
191                                 return 0;
192                         }
193
194                         @Override
195                         public EventLoop eventLoop() {
196                                 // TODO Auto-generated method stub
197                                 return null;
198                         }
199
200                         @Override
201                         public Channel parent() {
202                                 // TODO Auto-generated method stub
203                                 return null;
204                         }
205
206                         @Override
207                         public ChannelConfig config() {
208                                 // TODO Auto-generated method stub
209                                 return null;
210                         }
211
212                         @Override
213                         public boolean isOpen() {
214                                 // TODO Auto-generated method stub
215                                 return false;
216                         }
217
218                         @Override
219                         public boolean isRegistered() {
220                                 // TODO Auto-generated method stub
221                                 return false;
222                         }
223
224                         @Override
225                         public boolean isActive() {
226                                 // TODO Auto-generated method stub
227                                 return false;
228                         }
229
230                         @Override
231                         public ChannelMetadata metadata() {
232                                 // TODO Auto-generated method stub
233                                 return null;
234                         }
235
236                         @Override
237                         public SocketAddress localAddress() {
238                                 // TODO Auto-generated method stub
239                                 return null;
240                         }
241
242                         @Override
243                         public SocketAddress remoteAddress() {
244                                 // TODO Auto-generated method stub
245                                 return null;
246                         }
247
248                         @Override
249                         public ChannelFuture closeFuture() {
250                                 // TODO Auto-generated method stub
251                                 return null;
252                         }
253
254                         @Override
255                         public boolean isWritable() {
256                                 // TODO Auto-generated method stub
257                                 return false;
258                         }
259
260                         @Override
261                         public Channel flush() {
262                                 // TODO Auto-generated method stub
263                                 return null;
264                         }
265
266                         @Override
267                         public Channel read() {
268                                 // TODO Auto-generated method stub
269                                 return null;
270                         }
271
272                         @Override
273                         public Unsafe unsafe() {
274                                 // TODO Auto-generated method stub
275                                 return null;
276                         }
277
278                 }, (short)3, new BGPOpenMessage(null, (short)5, null, null));
279                 this.client = client;
280         }
281
282         @Override
283         public void sendMessage(final BGPMessage msg) {
284                 this.lastMessageSentAt = System.nanoTime();
285                 this.client.onMessage(this, msg);
286         }
287 }