zulip/web/tests/transmit.test.js

187 lines
4.4 KiB
JavaScript
Raw Normal View History

"use strict";
const {strict: assert} = require("assert");
const {mock_esm, zrequire} = require("./lib/namespace");
const {run_test} = require("./lib/test");
const blueslip = require("./lib/zblueslip");
const {page_params} = require("./lib/zpage_params");
const noop = () => {};
const channel = mock_esm("../src/channel");
const reload = mock_esm("../src/reload");
const reload_state = mock_esm("../src/reload_state");
const sent_messages = mock_esm("../src/sent_messages", {
start_tracking_message: noop,
report_server_ack: noop,
start_send: noop,
});
2020-08-20 21:24:06 +02:00
const people = zrequire("people");
const transmit = zrequire("transmit");
run_test("transmit_message_ajax", () => {
let success_func_called;
const success = () => {
success_func_called = true;
};
const request = {foo: "bar"};
channel.post = (opts) => {
assert.equal(opts.url, "/json/messages");
assert.equal(opts.data.foo, "bar");
opts.success();
};
transmit.send_message(request, success);
assert.ok(success_func_called);
channel.xhr_error_message = (msg) => {
assert.equal(msg, "Error sending message");
return msg;
};
channel.post = (opts) => {
assert.equal(opts.url, "/json/messages");
assert.equal(opts.data.foo, "bar");
const xhr = "whatever";
opts.error(xhr, "timeout");
};
let error_func_called;
const error = (response) => {
assert.equal(response, "Error sending message");
error_func_called = true;
};
transmit.send_message(request, success, error);
assert.ok(error_func_called);
});
run_test("transmit_message_ajax_reload_pending", () => {
/* istanbul ignore next */
const success = () => {
throw new Error("unexpected success");
};
/* istanbul ignore next */
const error = () => {
throw new Error("unexpected error");
};
reload_state.is_pending = () => true;
let reload_initiated;
reload.initiate = (opts) => {
reload_initiated = true;
assert.deepEqual(opts, {
immediate: true,
save_pointer: true,
save_narrow: true,
save_compose: true,
send_after_reload: true,
});
};
const request = {foo: "bar"};
channel.post = (opts) => {
assert.equal(opts.url, "/json/messages");
assert.equal(opts.data.foo, "bar");
const xhr = "whatever";
opts.error(xhr, "bad request");
};
transmit.send_message(request, success, error);
assert.ok(reload_initiated);
});
2018-02-23 16:18:27 +01:00
run_test("reply_message_stream", ({override}) => {
2018-02-23 16:18:27 +01:00
const stream_message = {
type: "stream",
stream: "social",
topic: "lunch",
sender_full_name: "Alice",
sender_id: 123,
2018-02-23 16:18:27 +01:00
};
const content = "hello";
2018-02-23 16:18:27 +01:00
let send_message_args;
2018-02-23 16:18:27 +01:00
override(channel, "post", ({data}) => {
send_message_args = data;
});
2018-02-23 16:18:27 +01:00
page_params.user_id = 44;
page_params.queue_id = 66;
sent_messages.get_new_local_id = () => "99";
2018-02-23 16:18:27 +01:00
transmit.reply_message({
message: stream_message,
content,
2018-02-23 16:18:27 +01:00
});
assert.deepEqual(send_message_args, {
sender_id: 44,
queue_id: 66,
local_id: "99",
type: "stream",
to: "social",
content: "@**Alice** hello",
topic: "lunch",
2018-02-23 16:18:27 +01:00
});
});
run_test("reply_message_private", ({override}) => {
2018-02-23 16:18:27 +01:00
const fred = {
user_id: 3,
email: "fred@example.com",
full_name: "Fred Frost",
2018-02-23 16:18:27 +01:00
};
people.add_active_user(fred);
2018-02-23 16:18:27 +01:00
const pm_message = {
type: "private",
display_recipient: [{id: fred.user_id}],
2018-02-23 16:18:27 +01:00
};
const content = "hello";
2018-02-23 16:18:27 +01:00
let send_message_args;
2018-02-23 16:18:27 +01:00
override(channel, "post", ({data}) => {
send_message_args = data;
});
2018-02-23 16:18:27 +01:00
page_params.user_id = 155;
page_params.queue_id = 177;
sent_messages.get_new_local_id = () => "199";
2018-02-23 16:18:27 +01:00
transmit.reply_message({
message: pm_message,
content,
2018-02-23 16:18:27 +01:00
});
assert.deepEqual(send_message_args, {
sender_id: 155,
queue_id: 177,
local_id: "199",
type: "private",
2018-02-23 16:18:27 +01:00
to: '["fred@example.com"]',
content: "hello",
2018-02-23 16:18:27 +01:00
});
});
run_test("reply_message_errors", () => {
2018-02-23 16:18:27 +01:00
const bogus_message = {
type: "bogus",
2018-02-23 16:18:27 +01:00
};
blueslip.expect("error", "unknown message type");
2018-02-23 16:18:27 +01:00
transmit.reply_message({
message: bogus_message,
});
});