MessageGenerator.java

 1package eu.siacs.conversations.generator;
 2
 3import java.text.SimpleDateFormat;
 4import java.util.Date;
 5import java.util.TimeZone;
 6
 7import net.java.otr4j.OtrException;
 8import net.java.otr4j.session.Session;
 9import eu.siacs.conversations.entities.Account;
10import eu.siacs.conversations.entities.Conversation;
11import eu.siacs.conversations.entities.Message;
12import eu.siacs.conversations.xml.Element;
13import eu.siacs.conversations.xmpp.stanzas.MessagePacket;
14
15public class MessageGenerator {
16	private MessagePacket preparePacket(Message message, boolean addDelay) {
17		Conversation conversation = message.getConversation();
18		Account account = conversation.getAccount();
19		MessagePacket packet = new MessagePacket();
20		if (conversation.getMode() == Conversation.MODE_SINGLE) {
21			packet.setTo(message.getCounterpart());
22			packet.setType(MessagePacket.TYPE_CHAT);
23		} else {
24			packet.setTo(message.getCounterpart().split("/")[0]);
25			packet.setType(MessagePacket.TYPE_GROUPCHAT);
26		}
27		packet.setFrom(account.getFullJid());
28		packet.setId(message.getUuid());
29		if (addDelay) {
30			addDelay(packet,message.getTimeSent());
31		}
32		return packet;
33	}
34	
35	private void addDelay(MessagePacket packet, long timestamp) {
36		final SimpleDateFormat mDateFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
37		mDateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
38		Element delay = packet.addChild("delay", "urn:xmpp:delay");
39		Date date = new Date(timestamp);
40		delay.setAttribute("stamp", mDateFormat.format(date));
41	}
42	
43	public MessagePacket generateOtrChat(Message message) throws OtrException {
44		return generateOtrChat(message, false);
45	}
46	
47	public MessagePacket generateOtrChat(Message message, boolean addDelay) throws OtrException {
48		Session otrSession = message.getConversation().getOtrSession();
49		if (otrSession==null) {
50			throw new OtrException(null);
51		}
52		MessagePacket packet = preparePacket(message,addDelay);
53		packet.addChild("private", "urn:xmpp:carbons:2");
54		packet.addChild("no-copy", "urn:xmpp:hints");
55		packet.setBody(otrSession.transformSending(message
56				.getBody()));
57		return packet;
58	}
59	
60	public MessagePacket generateChat(Message message) {
61		return generateChat(message, false);
62	}
63	
64	public MessagePacket generateChat(Message message, boolean addDelay) {
65		MessagePacket packet = preparePacket(message,addDelay);
66		packet.setBody(message.getBody());
67		return packet;
68	}
69	
70	public MessagePacket generatePgpChat(Message message) {
71		return generatePgpChat(message, false);
72	}
73	
74	public MessagePacket generatePgpChat(Message message, boolean addDelay) {
75		MessagePacket packet = preparePacket(message,addDelay);
76		packet.setBody("This is an XEP-0027 encryted message");
77		if (message.getEncryption() == Message.ENCRYPTION_DECRYPTED) {
78			packet.addChild("x", "jabber:x:encrypted").setContent(
79					message.getEncryptedBody());
80		} else if (message.getEncryption() == Message.ENCRYPTION_PGP) {
81			packet.setBody(message.getBody());
82		}
83		return packet;
84	}
85}