Skip to content

Commit

Permalink
FIX : Unpacking causes socks5proxy init failure (netty#9582)
Browse files Browse the repository at this point in the history
Motivation:

Socks5InitialRequestDecoder does not correctly handle fragmentation

Modifications:

- Delete detection of not enough bytes as ReplyingDecoder already handles all of this correctly.
- Add unit test

Result:

Fixes netty#9574.
  • Loading branch information
switchYello authored and normanmaurer committed Sep 20, 2019
1 parent 2b9f69a commit ec34fce
Show file tree
Hide file tree
Showing 2 changed files with 38 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -56,9 +56,6 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) t
}

final int authMethodCnt = in.readUnsignedByte();
if (actualReadableBytes() < authMethodCnt) {
break;
}

final Socks5AuthMethod[] authMethods = new Socks5AuthMethod[authMethodCnt];
for (int i = 0; i < authMethodCnt; i++) {
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
/*
* Copyright 2019 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:
*
* http://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.
*/
package io.netty.handler.codec.socksx.v5;

import io.netty.buffer.Unpooled;
import io.netty.channel.embedded.EmbeddedChannel;
import io.netty.handler.codec.DecoderResult;
import org.junit.Test;

import static org.junit.Assert.*;

public class Socks5InitialRequestDecoderTest {
@Test
public void testUnpackingCausesDecodeFail() {
EmbeddedChannel e = new EmbeddedChannel(new Socks5InitialRequestDecoder());
assertFalse(e.writeInbound(Unpooled.wrappedBuffer(new byte[]{5, 2, 0})));
assertTrue(e.writeInbound(Unpooled.wrappedBuffer(new byte[]{1})));
Object o = e.readInbound();

assertTrue(o instanceof DefaultSocks5InitialRequest);
DefaultSocks5InitialRequest req = (DefaultSocks5InitialRequest) o;
assertSame(req.decoderResult(), DecoderResult.SUCCESS);
assertFalse(e.finish());
}
}

0 comments on commit ec34fce

Please sign in to comment.