aboutsummaryrefslogtreecommitdiff
path: root/src/com
diff options
context:
space:
mode:
authorGravatar Ugnich Anton2013-09-07 19:34:34 +0700
committerGravatar Ugnich Anton2013-09-07 19:34:34 +0700
commit265e629e5bc5ad8f9d2a8e94dce864ebe995bcef (patch)
treee2c00dbbdefc32da439f41ec9156ff6e46e46b9c /src/com
parent0f51682e893ee75f387617daa1dccd51e2ae95c5 (diff)
onJuickPM
Diffstat (limited to 'src/com')
-rw-r--r--src/com/juick/jabber/ws/XMPPConnection.java48
1 files changed, 47 insertions, 1 deletions
diff --git a/src/com/juick/jabber/ws/XMPPConnection.java b/src/com/juick/jabber/ws/XMPPConnection.java
index 0eef26bf..a8af8c44 100644
--- a/src/com/juick/jabber/ws/XMPPConnection.java
+++ b/src/com/juick/jabber/ws/XMPPConnection.java
@@ -62,7 +62,16 @@ public class XMPPConnection implements Runnable, Stream.StreamListener, Message.
JuickMessage jmsg = (JuickMessage) msg.getChild(JuickMessage.XMLNS);
if (jmsg != null) {
System.err.println("MID=" + jmsg.MID + "; RID=" + jmsg.RID);
- if (jmsg.RID == 0) {
+ if (jmsg.MID == 0) {
+ int uid_to = 0;
+ try {
+ uid_to = Integer.parseInt(msg.to.Username);
+ } catch (Exception e) {
+ }
+ if (uid_to > 0) {
+ onJuickPM(uid_to, jmsg);
+ }
+ } else if (jmsg.RID == 0) {
onJuickMessagePost(jmsg);
} else {
onJuickMessageReply(jmsg);
@@ -70,6 +79,43 @@ public class XMPPConnection implements Runnable, Stream.StreamListener, Message.
}
}
+ private void onJuickPM(int uid_to, com.juick.Message jmsg) {
+ String json = com.juick.json.Message.toJSON(jmsg).toString();
+ ByteBuffer jsonbytes = Charset.forName("UTF-8").encode(json);
+ ByteBuffer bbMsg = ByteBuffer.allocate(10240);
+ bbMsg.put((byte) 0x81);
+ if (jsonbytes.limit() <= 125) {
+ bbMsg.put((byte) jsonbytes.limit());
+ } else {
+ bbMsg.put((byte) 126);
+ bbMsg.putShort((short) jsonbytes.limit());
+ }
+ bbMsg.put(jsonbytes);
+ bbMsg.flip();
+
+ synchronized (Main.clients) {
+ for (Iterator<SocketSubscribed> i = Main.clients.iterator(); i.hasNext();) {
+ SocketSubscribed s = i.next();
+ if (s.VUID == uid_to) {
+ bbMsg.rewind();
+ try {
+ s.sock.write(bbMsg);
+ } catch (Exception e) {
+ try {
+ s.sock.socket().close();
+ } catch (Exception ex) {
+ }
+ try {
+ s.sock.close();
+ } catch (Exception ex) {
+ }
+ i.remove();
+ }
+ }
+ }
+ }
+ }
+
private void onJuickMessagePost(com.juick.Message jmsg) {
String json = com.juick.json.Message.toJSON(jmsg).toString();
ByteBuffer jsonbytes = Charset.forName("UTF-8").encode(json);