1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package io.netty.handler.codec.socksx.v4;
18
19 import io.netty.buffer.ByteBuf;
20 import io.netty.buffer.ByteBufUtil;
21 import io.netty.channel.ChannelHandler.Sharable;
22 import io.netty.channel.ChannelHandlerContext;
23 import io.netty.handler.codec.MessageToByteEncoder;
24 import io.netty.util.NetUtil;
25
26
27
28
29 @Sharable
30 public final class Socks4ServerEncoder extends MessageToByteEncoder<Socks4CommandResponse> {
31
32 public static final Socks4ServerEncoder INSTANCE = new Socks4ServerEncoder();
33
34 private static final byte[] IPv4_HOSTNAME_ZEROED = { 0x00, 0x00, 0x00, 0x00 };
35
36 private Socks4ServerEncoder() { }
37
38 @Override
39 protected void encode(ChannelHandlerContext ctx, Socks4CommandResponse msg, ByteBuf out) throws Exception {
40 out.writeByte(0);
41 out.writeByte(msg.status().byteValue());
42 ByteBufUtil.writeShortBE(out, msg.dstPort());
43 out.writeBytes(msg.dstAddr() == null? IPv4_HOSTNAME_ZEROED
44 : NetUtil.createByteArrayFromIpAddressString(msg.dstAddr()));
45 }
46 }