1package eu.siacs.conversations.generator;
2
3import java.text.SimpleDateFormat;
4import java.util.Date;
5import java.util.Locale;
6import java.util.TimeZone;
7
8import net.java.otr4j.OtrException;
9import net.java.otr4j.session.Session;
10import eu.siacs.conversations.entities.Account;
11import eu.siacs.conversations.entities.Conversation;
12import eu.siacs.conversations.entities.Message;
13import eu.siacs.conversations.services.XmppConnectionService;
14import eu.siacs.conversations.xml.Element;
15import eu.siacs.conversations.xmpp.chatstate.ChatState;
16import eu.siacs.conversations.xmpp.jid.Jid;
17import eu.siacs.conversations.xmpp.stanzas.MessagePacket;
18
19public class MessageGenerator extends AbstractGenerator {
20 public MessageGenerator(XmppConnectionService service) {
21 super(service);
22 }
23
24 private MessagePacket preparePacket(Message message, boolean addDelay) {
25 Conversation conversation = message.getConversation();
26 Account account = conversation.getAccount();
27 MessagePacket packet = new MessagePacket();
28 if (conversation.getMode() == Conversation.MODE_SINGLE) {
29 packet.setTo(message.getCounterpart());
30 packet.setType(MessagePacket.TYPE_CHAT);
31 packet.addChild("markable", "urn:xmpp:chat-markers:0");
32 if (this.mXmppConnectionService.indicateReceived()) {
33 packet.addChild("request", "urn:xmpp:receipts");
34 }
35 } else if (message.getType() == Message.TYPE_PRIVATE) {
36 packet.setTo(message.getCounterpart());
37 packet.setType(MessagePacket.TYPE_CHAT);
38 } else {
39 packet.setTo(message.getCounterpart().toBareJid());
40 packet.setType(MessagePacket.TYPE_GROUPCHAT);
41 }
42 packet.setFrom(account.getJid());
43 packet.setId(message.getUuid());
44 if (addDelay) {
45 addDelay(packet, message.getTimeSent());
46 }
47 return packet;
48 }
49
50 private void addDelay(MessagePacket packet, long timestamp) {
51 final SimpleDateFormat mDateFormat = new SimpleDateFormat(
52 "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'", Locale.US);
53 mDateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
54 Element delay = packet.addChild("delay", "urn:xmpp:delay");
55 Date date = new Date(timestamp);
56 delay.setAttribute("stamp", mDateFormat.format(date));
57 }
58
59 public MessagePacket generateOtrChat(Message message) {
60 return generateOtrChat(message, false);
61 }
62
63 public MessagePacket generateOtrChat(Message message, boolean addDelay) {
64 Session otrSession = message.getConversation().getOtrSession();
65 if (otrSession == null) {
66 return null;
67 }
68 MessagePacket packet = preparePacket(message, addDelay);
69 packet.addChild("private", "urn:xmpp:carbons:2");
70 packet.addChild("no-copy", "urn:xmpp:hints");
71 try {
72 packet.setBody(otrSession.transformSending(message.getBody())[0]);
73 return packet;
74 } catch (OtrException e) {
75 return null;
76 }
77 }
78
79 public MessagePacket generateChat(Message message) {
80 return generateChat(message, false);
81 }
82
83 public MessagePacket generateChat(Message message, boolean addDelay) {
84 MessagePacket packet = preparePacket(message, addDelay);
85 packet.setBody(message.getBody());
86 return packet;
87 }
88
89 public MessagePacket generatePgpChat(Message message) {
90 return generatePgpChat(message, false);
91 }
92
93 public MessagePacket generatePgpChat(Message message, boolean addDelay) {
94 MessagePacket packet = preparePacket(message, addDelay);
95 packet.setBody("This is an XEP-0027 encryted message");
96 if (message.getEncryption() == Message.ENCRYPTION_DECRYPTED) {
97 packet.addChild("x", "jabber:x:encrypted").setContent(
98 message.getEncryptedBody());
99 } else if (message.getEncryption() == Message.ENCRYPTION_PGP) {
100 packet.addChild("x", "jabber:x:encrypted").setContent(
101 message.getBody());
102 }
103 return packet;
104 }
105
106 public MessagePacket generateChatState(Conversation conversation) {
107 final Account account = conversation.getAccount();
108 MessagePacket packet = new MessagePacket();
109 packet.setTo(conversation.getJid().toBareJid());
110 packet.setFrom(account.getJid());
111 packet.addChild(ChatState.toElement(conversation.getOutgoingChatState()));
112 return packet;
113 }
114
115 public MessagePacket confirm(final Account account, final Jid to, final String id) {
116 MessagePacket packet = new MessagePacket();
117 packet.setType(MessagePacket.TYPE_NORMAL);
118 packet.setTo(to);
119 packet.setFrom(account.getJid());
120 Element received = packet.addChild("displayed",
121 "urn:xmpp:chat-markers:0");
122 received.setAttribute("id", id);
123 return packet;
124 }
125
126 public MessagePacket conferenceSubject(Conversation conversation,
127 String subject) {
128 MessagePacket packet = new MessagePacket();
129 packet.setType(MessagePacket.TYPE_GROUPCHAT);
130 packet.setTo(conversation.getJid().toBareJid());
131 Element subjectChild = new Element("subject");
132 subjectChild.setContent(subject);
133 packet.addChild(subjectChild);
134 packet.setFrom(conversation.getAccount().getJid().toBareJid());
135 return packet;
136 }
137
138 public MessagePacket directInvite(final Conversation conversation, final Jid contact) {
139 MessagePacket packet = new MessagePacket();
140 packet.setType(MessagePacket.TYPE_NORMAL);
141 packet.setTo(contact);
142 packet.setFrom(conversation.getAccount().getJid());
143 Element x = packet.addChild("x", "jabber:x:conference");
144 x.setAttribute("jid", conversation.getJid().toBareJid().toString());
145 return packet;
146 }
147
148 public MessagePacket invite(Conversation conversation, Jid contact) {
149 MessagePacket packet = new MessagePacket();
150 packet.setTo(conversation.getJid().toBareJid());
151 packet.setFrom(conversation.getAccount().getJid());
152 Element x = new Element("x");
153 x.setAttribute("xmlns", "http://jabber.org/protocol/muc#user");
154 Element invite = new Element("invite");
155 invite.setAttribute("to", contact.toBareJid().toString());
156 x.addChild(invite);
157 packet.addChild(x);
158 return packet;
159 }
160
161 public MessagePacket received(Account account,
162 MessagePacket originalMessage, String namespace) {
163 MessagePacket receivedPacket = new MessagePacket();
164 receivedPacket.setType(MessagePacket.TYPE_NORMAL);
165 receivedPacket.setTo(originalMessage.getFrom());
166 receivedPacket.setFrom(account.getJid());
167 Element received = receivedPacket.addChild("received", namespace);
168 received.setAttribute("id", originalMessage.getId());
169 return receivedPacket;
170 }
171}