1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
|
/*
* Jitsi, the OpenSource Java VoIP and Instant Messaging client.
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package net.java.sip.communicator.plugin.otr;
import net.java.otr4j.*;
import net.java.sip.communicator.service.protocol.*;
import net.java.sip.communicator.service.protocol.event.*;
/**
* The Off-the-Record {@link TransformLayer} implementation.
*
* @author George Politis
*/
public class OtrTransformLayer
implements TransformLayer
{
/*
* Implements TransformLayer#messageDelivered(MessageDeliveredEvent).
*/
public MessageDeliveredEvent messageDelivered(MessageDeliveredEvent evt)
{
Contact contact = evt.getDestinationContact();
OtrPolicy policy = OtrActivator.scOtrEngine.getContactPolicy(contact);
ScSessionStatus sessionStatus =
OtrActivator.scOtrEngine.getSessionStatus(contact);
// If OTR is disabled and we are not over an encrypted session, don't
// process anything.
if (!policy.getEnableManual()
&& sessionStatus != ScSessionStatus.ENCRYPTED
&& sessionStatus != ScSessionStatus.FINISHED)
return evt;
if (OtrActivator.scOtrEngine.isMessageUIDInjected(evt
.getSourceMessage().getMessageUID()))
// If this is a message otr4j injected earlier, don't display it,
// this may have to change when we add support for fragmentation..
return null;
else
return evt;
}
/*
* Implements
* TransformLayer#messageDeliveryFailed(MessageDeliveryFailedEvent).
*/
public MessageDeliveryFailedEvent messageDeliveryFailed(
MessageDeliveryFailedEvent evt)
{
return evt;
}
/*
* Implements TransformLayer#messageDeliveryPending(MessageDeliveredEvent).
*/
public MessageDeliveredEvent messageDeliveryPending(
MessageDeliveredEvent evt)
{
Contact contact = evt.getDestinationContact();
OtrPolicy policy = OtrActivator.scOtrEngine.getContactPolicy(contact);
ScSessionStatus sessionStatus =
OtrActivator.scOtrEngine.getSessionStatus(contact);
// If OTR is disabled and we are not over an encrypted session, don't
// process anything.
if (!policy.getEnableManual()
&& sessionStatus != ScSessionStatus.ENCRYPTED
&& sessionStatus != ScSessionStatus.FINISHED)
return evt;
// If this is a message otr4j injected earlier, return the event as is.
if (OtrActivator.scOtrEngine.isMessageUIDInjected(evt
.getSourceMessage().getMessageUID()))
return evt;
// Process the outgoing message.
String msgContent = evt.getSourceMessage().getContent();
String processedMessageContent =
OtrActivator.scOtrEngine.transformSending(contact, msgContent);
if (processedMessageContent == null
|| processedMessageContent.length() < 1)
return null;
if (processedMessageContent.equals(msgContent))
return evt;
// Forge a new message based on the new contents.
OperationSetBasicInstantMessaging imOpSet =
contact.getProtocolProvider().getOperationSet(
OperationSetBasicInstantMessaging.class);
Message processedMessage =
imOpSet.createMessage(processedMessageContent);
// Create a new event and return.
MessageDeliveredEvent processedEvent =
new MessageDeliveredEvent(processedMessage, contact, evt
.getTimestamp());
return processedEvent;
}
/*
* Implements TransformLayer#messageReceived(MessageReceivedEvent).
*/
public MessageReceivedEvent messageReceived(MessageReceivedEvent evt)
{
Contact contact = evt.getSourceContact();
OtrPolicy policy = OtrActivator.scOtrEngine.getContactPolicy(contact);
ScSessionStatus sessionStatus =
OtrActivator.scOtrEngine.getSessionStatus(contact);
// If OTR is disabled and we are not over an encrypted session, don't
// process anything.
if (!policy.getEnableManual()
&& sessionStatus != ScSessionStatus.ENCRYPTED
&& sessionStatus != ScSessionStatus.FINISHED)
return evt;
// Process the incoming message.
String msgContent = evt.getSourceMessage().getContent();
String processedMessageContent =
OtrActivator.scOtrEngine.transformReceiving(contact, msgContent);
if (processedMessageContent == null
|| processedMessageContent.length() < 1)
return null;
if (processedMessageContent.equals(msgContent))
return evt;
// Forge a new message based on the new contents.
OperationSetBasicInstantMessaging imOpSet =
contact.getProtocolProvider().getOperationSet(
OperationSetBasicInstantMessaging.class);
Message processedMessage =
imOpSet.createMessage(processedMessageContent);
// Create a new event and return.
MessageReceivedEvent processedEvent =
new MessageReceivedEvent(processedMessage, contact, evt
.getTimestamp());
return processedEvent;
}
}
|
