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
152
153
154
155
156
157
158
159
|
/* Any copyright is dedicated to the Public Domain.
* http://creativecommons.org/publicdomain/zero/1.0/ */
var { GenericConvIMPrototype } = ChromeUtils.importESModule(
"resource:///modules/jsProtoHelper.sys.mjs"
);
var _id = 0;
function Conversation(name) {
this._name = name;
this._observers = [];
this._date = Date.now() * 1000;
this.id = ++_id;
}
Conversation.prototype = {
__proto__: GenericConvIMPrototype,
_account: {
imAccount: {
protocol: { name: "Fake Protocol" },
alias: "",
name: "Fake Account",
},
ERROR(e) {
throw e;
},
DEBUG() {},
},
};
// ROT13, used as an example transformation.
function rot13(aString) {
return aString.replace(/[a-zA-Z]/g, function (c) {
return String.fromCharCode(
c.charCodeAt(0) + (c.toLowerCase() < "n" ? 1 : -1) * 13
);
});
}
// A test that cancels a message before it can be sent.
add_task(function test_cancel_send_message() {
let conv = new Conversation();
conv.dispatchMessage = function (aMsg) {
ok(
false,
"The message should have been halted in the conversation service."
);
};
let sending = false;
conv.addObserver({
observe(aObject, aTopic, aMsg) {
switch (aTopic) {
case "sending-message":
ok(
aObject.QueryInterface(Ci.imIOutgoingMessage),
"Wrong message type."
);
aObject.cancelled = true;
sending = true;
break;
case "new-text":
ok(
false,
"No other notification should be fired for a cancelled message."
);
break;
}
},
});
conv.sendMsg("Hi!");
ok(sending, "The sending-message notification was never fired.");
});
// A test that ensures protocols get a chance to prepare a message before
// sending and displaying.
add_task(function test_prpl_message_prep() {
let conv = new Conversation();
conv.dispatchMessage = function (aMsg) {
this.writeMessage("user", aMsg, { outgoing: true });
};
conv.prepareForSending = function (aMsg) {
ok(aMsg.QueryInterface(Ci.imIOutgoingMessage), "Wrong message type.");
equal(aMsg.message, msg, "Expected the original message.");
prepared = true;
return [prefix + aMsg.message];
};
conv.prepareForDisplaying = function (aMsg) {
equal(aMsg.displayMessage, prefix + msg, "Expected the prefixed message.");
aMsg.displayMessage = aMsg.displayMessage.slice(prefix.length);
};
let msg = "Hi!";
let prefix = "test> ";
let prepared = false;
let receivedMsg = false;
conv.addObserver({
observe(aObject, aTopic) {
if (aTopic === "preparing-message") {
equal(aObject.message, msg, "Expected the original message");
} else if (aTopic === "sending-message") {
equal(aObject.message, prefix + msg, "Expected the prefixed message.");
} else if (aTopic === "new-text") {
ok(aObject.QueryInterface(Ci.prplIMessage), "Wrong message type.");
ok(prepared, "The message was not prepared before sending.");
equal(aObject.message, prefix + msg, "Expected the prefixed message.");
receivedMsg = true;
aObject.displayMessage = aObject.originalMessage;
conv.prepareForDisplaying(aObject);
equal(aObject.displayMessage, msg, "Expected the original message");
}
},
});
conv.sendMsg(msg);
ok(receivedMsg, "The new-text notification was never fired.");
});
// A test that ensures protocols can split messages before they are sent.
add_task(function test_split_message_before_sending() {
let msgCount = 0;
let prepared = false;
let msg = "This is a looo\nooong message.\nThis one is short.";
let msgs = msg.split("\n");
let conv = new Conversation();
conv.dispatchMessage = function (aMsg) {
equal(aMsg, msgs[msgCount++], "Sending an unexpected message.");
};
conv.prepareForSending = function (aMsg) {
ok(aMsg.QueryInterface(Ci.imIOutgoingMessage), "Wrong message type.");
prepared = true;
return aMsg.message.split("\n");
};
conv.sendMsg(msg);
ok(prepared, "Message wasn't prepared for sending.");
equal(msgCount, 3, "Not enough messages were sent.");
});
add_task(function test_removeMessage() {
let didRemove = false;
let conv = new Conversation();
conv.addObserver({
observe(subject, topic, data) {
if (topic === "remove-text") {
equal(data, "foo");
didRemove = true;
}
},
});
conv.removeMessage("foo");
ok(didRemove);
});
|
