WindhoverLabs / phoebus / #84

Committed 21 Sep 2023 02:26AM UTC coverage: 16.568% (+0.009%) from 16.559%

Build # #84

Build Type

push

Committed by

Commit Message

-Add packets viewer. WIP.

Run Details

129 of 129 new or added lines in 3 files covered. (100.0%)

17798 of 107426 relevant lines covered (16.57%)

0.17 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/core/commander-core/src/main/java/com/windhoverlabs/yamcs/core/WebSocketClientHandler.java

/*
 * Copyright 2012 The Netty Project
 *
 * The Netty Project licenses this file to you under the Apache License,
 * version 2.0 (the "License"); you may not use this file except in compliance
 * with the License. You may obtain a copy of the License at:
 *
 *   https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations
 * under the License.
 */
// The MIT License
//
// Copyright (c) 2009 Carl Bystršm
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.

package com.windhoverlabs.yamcs.core;

import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPromise;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.FullHttpResponse;
import io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
import io.netty.handler.codec.http.websocketx.PongWebSocketFrame;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
import io.netty.handler.codec.http.websocketx.WebSocketFrame;
import io.netty.handler.codec.http.websocketx.WebSocketHandshakeException;
import io.netty.util.CharsetUtil;

public class WebSocketClientHandler extends SimpleChannelInboundHandler<Object> {

  private final WebSocketClientHandshaker handshaker;
  private ChannelPromise handshakeFuture;

  public WebSocketClientHandler(WebSocketClientHandshaker handshaker) {
    this.handshaker = handshaker;
  }

  public ChannelFuture handshakeFuture() {
    return handshakeFuture;
  }

  @Override
  public void handlerAdded(ChannelHandlerContext ctx) {
    handshakeFuture = ctx.newPromise();
  }

  @Override
  public void channelActive(ChannelHandlerContext ctx) {
    handshaker.handshake(ctx.channel());
  }

  @Override
  public void channelInactive(ChannelHandlerContext ctx) {
    System.out.println("WebSocket Client disconnected!");
  }

  @Override
  public void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
    Channel ch = ctx.channel();
    if (!handshaker.isHandshakeComplete()) {
      try {
        handshaker.finishHandshake(ch, (FullHttpResponse) msg);
        System.out.println("WebSocket Client connected!");
        handshakeFuture.setSuccess();
      } catch (WebSocketHandshakeException e) {
        System.out.println("WebSocket Client failed to connect");
        handshakeFuture.setFailure(e);
      }
      return;
    }

    if (msg instanceof FullHttpResponse) {
      FullHttpResponse response = (FullHttpResponse) msg;
      throw new IllegalStateException(
          "Unexpected FullHttpResponse (getStatus="
              + response.status()
              + ", content="
              + response.content().toString(CharsetUtil.UTF_8)
              + ')');
    }

    WebSocketFrame frame = (WebSocketFrame) msg;
    if (frame instanceof TextWebSocketFrame) {
      TextWebSocketFrame textFrame = (TextWebSocketFrame) frame;
      System.out.println("WebSocket Client received message: " + textFrame.text());
    } else if (frame instanceof PongWebSocketFrame) {
      System.out.println("WebSocket Client received pong");
    } else if (frame instanceof CloseWebSocketFrame) {
      System.out.println("WebSocket Client received closing");
      ch.close();
    }
  }

  @Override
  public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
    cause.printStackTrace();
    if (!handshakeFuture.isDone()) {
      handshakeFuture.setFailure(cause);
    }
    ctx.close();
  }
}

1	/*
2	* Copyright 2012 The Netty Project
3	*
4	* The Netty Project licenses this file to you under the Apache License,
5	* version 2.0 (the "License"); you may not use this file except in compliance
6	* with the License. You may obtain a copy of the License at:
7	*
8	* https://www.apache.org/licenses/LICENSE-2.0
9	*
10	* Unless required by applicable law or agreed to in writing, software
11	* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12	* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13	* License for the specific language governing permissions and limitations
14	* under the License.
15	*/
16	// The MIT License
17	//
18	// Copyright (c) 2009 Carl Bystršm
19	//
20	// Permission is hereby granted, free of charge, to any person obtaining a copy
21	// of this software and associated documentation files (the "Software"), to deal
22	// in the Software without restriction, including without limitation the rights
23	// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
24	// copies of the Software, and to permit persons to whom the Software is
25	// furnished to do so, subject to the following conditions:
26	//
27	// The above copyright notice and this permission notice shall be included in
28	// all copies or substantial portions of the Software.
29	//
30	// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
31	// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
32	// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
33	// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
34	// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
35	// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
36	// THE SOFTWARE.
37
38	package com.windhoverlabs.yamcs.core;
39
40	import io.netty.channel.Channel;
41	import io.netty.channel.ChannelFuture;
42	import io.netty.channel.ChannelHandlerContext;
43	import io.netty.channel.ChannelPromise;
44	import io.netty.channel.SimpleChannelInboundHandler;
45	import io.netty.handler.codec.http.FullHttpResponse;
46	import io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
47	import io.netty.handler.codec.http.websocketx.PongWebSocketFrame;
48	import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
49	import io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
50	import io.netty.handler.codec.http.websocketx.WebSocketFrame;
51	import io.netty.handler.codec.http.websocketx.WebSocketHandshakeException;
52	import io.netty.util.CharsetUtil;
53
54	public class WebSocketClientHandler extends SimpleChannelInboundHandler<Object> {
55
56	private final WebSocketClientHandshaker handshaker;
57	private ChannelPromise handshakeFuture;
58
59	public WebSocketClientHandler(WebSocketClientHandshaker handshaker) {	×
60	this.handshaker = handshaker;	×
61	}	×
62
63	public ChannelFuture handshakeFuture() {
64	return handshakeFuture;	×
65	}
66
67	@Override
68	public void handlerAdded(ChannelHandlerContext ctx) {
69	handshakeFuture = ctx.newPromise();	×
70	}	×
71
72	@Override
73	public void channelActive(ChannelHandlerContext ctx) {
74	handshaker.handshake(ctx.channel());	×
75	}	×
76
77	@Override
78	public void channelInactive(ChannelHandlerContext ctx) {
79	System.out.println("WebSocket Client disconnected!");	×
80	}	×
81
82	@Override
83	public void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
84	Channel ch = ctx.channel();	×
85	if (!handshaker.isHandshakeComplete()) {	×
86	try {
87	handshaker.finishHandshake(ch, (FullHttpResponse) msg);	×
88	System.out.println("WebSocket Client connected!");	×
89	handshakeFuture.setSuccess();	×
90	} catch (WebSocketHandshakeException e) {	×
91	System.out.println("WebSocket Client failed to connect");	×
92	handshakeFuture.setFailure(e);	×
93	}	×
94	return;	×
95	}
96
97	if (msg instanceof FullHttpResponse) {	×
98	FullHttpResponse response = (FullHttpResponse) msg;	×
99	throw new IllegalStateException(	×
100	"Unexpected FullHttpResponse (getStatus="
101	+ response.status()	×
102	+ ", content="
103	+ response.content().toString(CharsetUtil.UTF_8)	×
104	+ ')');
105	}
106
107	WebSocketFrame frame = (WebSocketFrame) msg;	×
108	if (frame instanceof TextWebSocketFrame) {	×
109	TextWebSocketFrame textFrame = (TextWebSocketFrame) frame;	×
110	System.out.println("WebSocket Client received message: " + textFrame.text());	×
111	} else if (frame instanceof PongWebSocketFrame) {	×
112	System.out.println("WebSocket Client received pong");	×
113	} else if (frame instanceof CloseWebSocketFrame) {	×
114	System.out.println("WebSocket Client received closing");	×
115	ch.close();	×
116	}
117	}	×
118
119	@Override
120	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
121	cause.printStackTrace();	×
122	if (!handshakeFuture.isDone()) {	×
123	handshakeFuture.setFailure(cause);	×
124	}
125	ctx.close();	×
126	}	×
127	}

WindhoverLabs / phoebus / #84

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous