/* * Copyright (c) 2010-2017 Nathan Rajlich * * 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 org.java_websocket.client; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.nio.ByteBuffer; import java.nio.channels.ByteChannel; import org.java_websocket.AbstractWrappedByteChannel; public abstract class AbstractClientProxyChannel extends AbstractWrappedByteChannel { protected final ByteBuffer proxyHandshake; /** * @param towrap * The channel to the proxy server **/ public AbstractClientProxyChannel( ByteChannel towrap ) { super( towrap ); try { proxyHandshake = ByteBuffer.wrap( buildHandShake().getBytes( "ASCII" ) ); } catch ( UnsupportedEncodingException e ) { throw new RuntimeException( e ); } } @Override public int write( ByteBuffer src ) throws IOException { if( !proxyHandshake.hasRemaining() ) { return super.write( src ); } else { return super.write( proxyHandshake ); } } public abstract String buildHandShake(); }