1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package org.apache.directory.server.changepw.io;
22
23
24 import java.io.IOException;
25 import java.nio.ByteBuffer;
26
27 import org.apache.directory.server.changepw.messages.ChangePasswordReply;
28 import org.apache.directory.server.kerberos.shared.io.encoder.ApplicationReplyEncoder;
29 import org.apache.directory.server.kerberos.shared.io.encoder.PrivateMessageEncoder;
30 import org.apache.directory.server.kerberos.shared.messages.application.ApplicationReply;
31 import org.apache.directory.server.kerberos.shared.messages.application.PrivateMessage;
32
33
34
35
36
37
38 public class ChangePasswordReplyEncoder
39 {
40 private static final int HEADER_LENGTH = 6;
41
42
43
44
45
46
47
48
49
50 public void encode( ByteBuffer buf, ChangePasswordReply message ) throws IOException
51 {
52
53 ApplicationReply appReply = message.getApplicationReply();
54 ApplicationReplyEncoder appEncoder = new ApplicationReplyEncoder();
55 byte[] encodedAppReply = appEncoder.encode( appReply );
56
57
58 PrivateMessage privateMessage = message.getPrivateMessage();
59 PrivateMessageEncoder privateEncoder = new PrivateMessageEncoder();
60 byte[] privateBytes = privateEncoder.encode( privateMessage );
61
62 short messageLength = ( short ) ( HEADER_LENGTH + encodedAppReply.length + privateBytes.length );
63
64 short protocolVersion = 1;
65
66 buf.putShort( messageLength );
67 buf.putShort( protocolVersion );
68 buf.putShort( ( short ) encodedAppReply.length );
69
70 buf.put( encodedAppReply );
71 buf.put( privateBytes );
72 }
73 }