Software `/` code `/` prosody

Annotate

spec/util_pubsub_spec.lua @ 12115:94de6b7596cc

mod_tombstones: Remember deleted accounts #1307 Presence subscriptions are normally revoked on account deletion, which informs the contact. Sometimes this notification gets lost e.g. due to s2s problems. The accounts JID may also be present e.g. in MUC affiliations, chat group member lists, pubsub subscriptions or other systems. These may grant privileges which would fall to someone who creates the same account again, which this module is meant to prevent.

author	Kim Alvefur <zash@zash.se>
date	Thu, 23 Dec 2021 14:08:20 +0100
parent	11767:5610f7c5b261
child	12153:26af75c20163

rev	line source
8564 fd41dc4a78e9 util_pubsub_spec: Move util.pubsub import into a setup block Kim Alvefur <zash@zash.se> parents: 8558 diff changeset	1 local pubsub;
fd41dc4a78e9 util_pubsub_spec: Move util.pubsub import into a setup block Kim Alvefur <zash@zash.se> parents: 8558 diff changeset	2 setup(function ()
fd41dc4a78e9 util_pubsub_spec: Move util.pubsub import into a setup block Kim Alvefur <zash@zash.se> parents: 8558 diff changeset	3 pubsub = require "util.pubsub";
fd41dc4a78e9 util_pubsub_spec: Move util.pubsub import into a setup block Kim Alvefur <zash@zash.se> parents: 8558 diff changeset	4 end);
fd41dc4a78e9 util_pubsub_spec: Move util.pubsub import into a setup block Kim Alvefur <zash@zash.se> parents: 8558 diff changeset	5
9176 1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	6 --[[TODO:
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	7 Retract
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	8 Purge
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	9 auto-create/auto-subscribe
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	10 Item store/node store
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	11 resize on max_items change
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	12 service creation config provides alternative node_defaults
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	13 get subscriptions
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	14 ]]
1068f9b82e2b util.pubsub tests: Add TODO Matthew Wild <mwild1@gmail.com> parents: 9175 diff changeset	15
8558 5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	16 describe("util.pubsub", function ()
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	17 describe("simple node creation and deletion", function ()
9451 db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	18 randomize(false); -- These tests are ordered
db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	19
8558 5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	20 -- Roughly a port of scansion/scripts/pubsub_createdelete.scs
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	21 local service = pubsub.new();
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	22
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	23 describe("#create", function ()
9451 db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	24 randomize(false); -- These tests are ordered
8558 5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	25 it("creates a new node", function ()
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	26 assert.truthy(service:create("princely_musings", true));
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	27 end);
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	28
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	29 it("fails to create the same node again", function ()
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	30 assert.falsy(service:create("princely_musings", true));
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	31 end);
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	32 end);
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	33
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	34 describe("#delete", function ()
9451 db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	35 randomize(false); -- These tests are ordered
8558 5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	36 it("deletes the node", function ()
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	37 assert.truthy(service:delete("princely_musings", true));
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	38 end);
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	39
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	40 it("can't delete an already deleted node", function ()
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	41 assert.falsy(service:delete("princely_musings", true));
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	42 end);
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	43 end);
5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	44 end);
8647 638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	45
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	46 describe("simple publishing", function ()
9451 db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	47 randomize(false); -- These tests are ordered
db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	48
9173 c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	49 local notified;
9178 f226b7b5486b util.pubsub: Silence warnings in tests [luacheck] Kim Alvefur <zash@zash.se> parents: 9176 diff changeset	50 local broadcaster = spy.new(function (notif_type, node_name, subscribers, item) -- luacheck: ignore 212
9173 c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	51 notified = subscribers;
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	52 end);
8817 9a3066a580ad spec/util_pubsub: Test whether someone can subscribe to a node Kim Alvefur <zash@zash.se> parents: 8647 diff changeset	53 local service = pubsub.new({
9a3066a580ad spec/util_pubsub: Test whether someone can subscribe to a node Kim Alvefur <zash@zash.se> parents: 8647 diff changeset	54 broadcaster = broadcaster;
9a3066a580ad spec/util_pubsub: Test whether someone can subscribe to a node Kim Alvefur <zash@zash.se> parents: 8647 diff changeset	55 });
8647 638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	56
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	57 it("creates a node", function ()
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	58 assert.truthy(service:create("node", true));
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	59 end);
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	60
8817 9a3066a580ad spec/util_pubsub: Test whether someone can subscribe to a node Kim Alvefur <zash@zash.se> parents: 8647 diff changeset	61 it("lets someone subscribe", function ()
9a3066a580ad spec/util_pubsub: Test whether someone can subscribe to a node Kim Alvefur <zash@zash.se> parents: 8647 diff changeset	62 assert.truthy(service:add_subscription("node", true, "someone"));
9a3066a580ad spec/util_pubsub: Test whether someone can subscribe to a node Kim Alvefur <zash@zash.se> parents: 8647 diff changeset	63 end);
9a3066a580ad spec/util_pubsub: Test whether someone can subscribe to a node Kim Alvefur <zash@zash.se> parents: 8647 diff changeset	64
8647 638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	65 it("publishes an item", function ()
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	66 assert.truthy(service:publish("node", true, "1", "item 1"));
9173 c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	67 assert.truthy(notified["someone"]);
8647 638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	68 end);
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	69
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	70 it("called the broadcaster", function ()
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	71 assert.spy(broadcaster).was_called();
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	72 end);
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	73
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	74 it("should return one item", function ()
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	75 local ok, ret = service:get_items("node", true);
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	76 assert.truthy(ok);
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	77 assert.same({ "1", ["1"] = "item 1" }, ret);
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	78 end);
638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	79
9173 c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	80 it("lets someone unsubscribe", function ()
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	81 assert.truthy(service:remove_subscription("node", true, "someone"));
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	82 end);
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	83
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	84 it("does not send notifications after subscription is removed", function ()
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	85 assert.truthy(service:publish("node", true, "1", "item 1"));
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	86 assert.is_nil(notified["someone"]);
c53663e13b51 util.pubsub tests: Extend publishing tests to check for correct notification behaviour on subscribe/unsubscribe Matthew Wild <mwild1@gmail.com> parents: 9171 diff changeset	87 end);
8647 638ff2ad98e6 util.pubsub: Add simple test covering publishing and retrieving an item Kim Alvefur <zash@zash.se> parents: 8564 diff changeset	88 end);
9004 50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	89
9516 038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	90 describe("publish with config", function ()
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	91 randomize(false); -- These tests are ordered
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	92
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	93 local broadcaster = spy.new(function (notif_type, node_name, subscribers, item) -- luacheck: ignore 212
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	94 end);
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	95 local service = pubsub.new({
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	96 broadcaster = broadcaster;
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	97 autocreate_on_publish = true;
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	98 });
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	99
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	100 it("automatically creates node with requested config", function ()
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	101 assert(service:publish("node", true, "1", "item 1", { myoption = true }));
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	102
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	103 local ok, config = assert(service:get_node_config("node", true));
10541 6c6ff4509082 tests: Silence [luacheck] warnings Kim Alvefur <zash@zash.se> parents: 10356 diff changeset	104 assert.truthy(ok);
9516 038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	105 assert.equals(true, config.myoption);
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	106 end);
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	107
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	108 it("fails to publish to a node with differing config", function ()
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	109 local ok, err = service:publish("node", true, "1", "item 2", { myoption = false });
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	110 assert.falsy(ok);
10356 0a2d7efca039 util.pubsub, pubsub.lib and tests: Add text to precondition-not-met error (fixes #1455) Matthew Wild <mwild1@gmail.com> parents: 9840 diff changeset	111 assert.equals("precondition-not-met", err.pubsub_condition);
9516 038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	112 end);
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	113
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	114 it("allows to publish to a node with differing config when only defaults are suggested", function ()
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	115 assert(service:publish("node", true, "1", "item 2", { _defaults_only = true, myoption = false }));
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	116 end);
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	117 end);
038446c50630 util.pubsub: Allow publishing with a config that should be used as defaults only Matthew Wild <mwild1@gmail.com> parents: 9451 diff changeset	118
9004 50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	119 describe("#issue1082", function ()
9451 db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	120 randomize(false); -- These tests are ordered
db82b096b842 util.pubsub tests: Ensure necessary tests run in the defined order Matthew Wild <mwild1@gmail.com> parents: 9209 diff changeset	121
9004 50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	122 local service = pubsub.new();
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	123
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	124 it("creates a node with max_items = 1", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	125 assert.truthy(service:create("node", true, { max_items = 1 }));
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	126 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	127
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	128 it("changes max_items to 2", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	129 assert.truthy(service:set_node_config("node", true, { max_items = 2 }));
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	130 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	131
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	132 it("publishes one item", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	133 assert.truthy(service:publish("node", true, "1", "item 1"));
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	134 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	135
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	136 it("should return one item", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	137 local ok, ret = service:get_items("node", true);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	138 assert.truthy(ok);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	139 assert.same({ "1", ["1"] = "item 1" }, ret);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	140 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	141
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	142 it("publishes another item", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	143 assert.truthy(service:publish("node", true, "2", "item 2"));
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	144 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	145
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	146 it("should return two items", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	147 local ok, ret = service:get_items("node", true);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	148 assert.truthy(ok);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	149 assert.same({
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	150 "2",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	151 "1",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	152 ["1"] = "item 1",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	153 ["2"] = "item 2",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	154 }, ret);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	155 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	156
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	157 it("publishes yet another item", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	158 assert.truthy(service:publish("node", true, "3", "item 3"));
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	159 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	160
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	161 it("should still return only two items", function ()
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	162 local ok, ret = service:get_items("node", true);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	163 assert.truthy(ok);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	164 assert.same({
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	165 "3",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	166 "2",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	167 ["2"] = "item 2",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	168 ["3"] = "item 3",
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	169 }, ret);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	170 end);
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	171
50a0f405e6c9 util_pubsub_spec: Add test for #1082 Kim Alvefur <zash@zash.se> parents: 8817 diff changeset	172 end);
9169 3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	173
9816 7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	174 describe("the thing", function ()
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	175 randomize(false); -- These tests are ordered
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	176
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	177 local service = pubsub.new();
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	178
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	179 it("creates a node with some items", function ()
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	180 assert.truthy(service:create("node", true, { max_items = 3 }));
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	181 assert.truthy(service:publish("node", true, "1", "item 1"));
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	182 assert.truthy(service:publish("node", true, "2", "item 2"));
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	183 assert.truthy(service:publish("node", true, "3", "item 3"));
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	184 end);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	185
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	186 it("should return the requested item", function ()
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	187 local ok, ret = service:get_items("node", true, "1");
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	188 assert.truthy(ok);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	189 assert.same({ "1", ["1"] = "item 1" }, ret);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	190 end);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	191
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	192 it("should return multiple requested items", function ()
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	193 local ok, ret = service:get_items("node", true, { "1", "2" });
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	194 assert.truthy(ok);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	195 assert.same({
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	196 "1",
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	197 "2",
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	198 ["1"] = "item 1",
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	199 ["2"] = "item 2",
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	200 }, ret);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	201 end);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	202 end);
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	203
7f84d7f77a00 util.pubsub: Add support for requesting multiple specific items (needed for #1305) Kim Alvefur <zash@zash.se> parents: 9742 diff changeset	204
9174 160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	205 describe("node config", function ()
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	206 local service;
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	207 before_each(function ()
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	208 service = pubsub.new();
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	209 service:create("test", true);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	210 end);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	211 it("access is forbidden for unaffiliated entities", function ()
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	212 local ok, err = service:get_node_config("test", "stranger");
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	213 assert.is_falsy(ok);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	214 assert.equals("forbidden", err);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	215 end);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	216 it("returns an error for nodes that do not exist", function ()
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	217 local ok, err = service:get_node_config("nonexistent", true);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	218 assert.is_falsy(ok);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	219 assert.equals("item-not-found", err);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	220 end);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	221 end);
160032d55ff1 util.pubsub tests: Add initial node config tests Matthew Wild <mwild1@gmail.com> parents: 9173 diff changeset	222
9169 3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	223 describe("access model", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	224 describe("open", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	225 local service;
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	226 before_each(function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	227 service = pubsub.new();
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	228 -- Do not supply any config, 'open' should be default
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	229 service:create("test", true);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	230 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	231 it("should be the default", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	232 local ok, config = service:get_node_config("test", true);
10541 6c6ff4509082 tests: Silence [luacheck] warnings Kim Alvefur <zash@zash.se> parents: 10356 diff changeset	233 assert.truthy(ok);
9169 3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	234 assert.equal("open", config.access_model);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	235 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	236 it("should allow anyone to subscribe", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	237 local ok = service:add_subscription("test", "stranger", "stranger");
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	238 assert.is_true(ok);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	239 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	240 it("should still reject outcast-affiliated entities", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	241 assert(service:set_affiliation("test", true, "enemy", "outcast"));
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	242 local ok, err = service:add_subscription("test", "enemy", "enemy");
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	243 assert.is_falsy(ok);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	244 assert.equal("forbidden", err);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	245 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	246 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	247 describe("whitelist", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	248 local service;
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	249 before_each(function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	250 service = assert(pubsub.new());
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	251 assert.is_true(service:create("test", true, { access_model = "whitelist" }));
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	252 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	253 it("should be present in the configuration", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	254 local ok, config = service:get_node_config("test", true);
10541 6c6ff4509082 tests: Silence [luacheck] warnings Kim Alvefur <zash@zash.se> parents: 10356 diff changeset	255 assert.truthy(ok);
9169 3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	256 assert.equal("whitelist", config.access_model);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	257 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	258 it("should not allow anyone to subscribe", function ()
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	259 local ok, err = service:add_subscription("test", "stranger", "stranger");
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	260 assert.is_false(ok);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	261 assert.equals("forbidden", err);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	262 end);
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	263 end);
9175 43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	264 describe("change", function ()
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	265 local service;
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	266 before_each(function ()
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	267 service = pubsub.new();
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	268 service:create("test", true, { access_model = "open" });
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	269 end);
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	270 it("affects existing subscriptions", function ()
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	271 do
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	272 local ok = service:add_subscription("test", "stranger", "stranger");
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	273 assert.is_true(ok);
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	274 end
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	275 do
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	276 local ok, sub = service:get_subscription("test", "stranger", "stranger");
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	277 assert.is_true(ok);
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	278 assert.is_true(sub);
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	279 end
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	280 assert(service:set_node_config("test", true, { access_model = "whitelist" }));
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	281 do
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	282 local ok, sub = service:get_subscription("test", "stranger", "stranger");
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	283 assert.is_true(ok);
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	284 assert.is_nil(sub);
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	285 end
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	286 end);
43b6f67aba05 util.pubsub tests: Add tests to confirm new access model is enforced on config change Matthew Wild <mwild1@gmail.com> parents: 9174 diff changeset	287 end);
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	288 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	289
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	290 describe("publish model", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	291 describe("publishers", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	292 local service;
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	293 before_each(function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	294 service = pubsub.new();
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	295 -- Do not supply any config, 'publishers' should be default
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	296 service:create("test", true);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	297 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	298 it("should be the default", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	299 local ok, config = service:get_node_config("test", true);
10541 6c6ff4509082 tests: Silence [luacheck] warnings Kim Alvefur <zash@zash.se> parents: 10356 diff changeset	300 assert.truthy(ok);
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	301 assert.equal("publishers", config.publish_model);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	302 end);
9169 3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	303 it("should not allow anyone to publish", function ()
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	304 assert.is_true(service:add_subscription("test", "stranger", "stranger"));
9169 3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	305 local ok, err = service:publish("test", "stranger", "item1", "foo");
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	306 assert.is_falsy(ok);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	307 assert.equals("forbidden", err);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	308 end);
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	309 it("should allow publishers to publish", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	310 assert(service:set_affiliation("test", true, "mypublisher", "publisher"));
10541 6c6ff4509082 tests: Silence [luacheck] warnings Kim Alvefur <zash@zash.se> parents: 10356 diff changeset	311 -- luacheck: ignore 211/err
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	312 local ok, err = service:publish("test", "mypublisher", "item1", "foo");
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	313 assert.is_true(ok);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	314 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	315 it("should allow owners to publish", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	316 assert(service:set_affiliation("test", true, "myowner", "owner"));
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	317 local ok = service:publish("test", "myowner", "item1", "foo");
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	318 assert.is_true(ok);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	319 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	320 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	321 describe("open", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	322 local service;
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	323 before_each(function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	324 service = pubsub.new();
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	325 service:create("test", true, { publish_model = "open" });
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	326 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	327 it("should allow anyone to publish", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	328 local ok = service:publish("test", "stranger", "item1", "foo");
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	329 assert.is_true(ok);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	330 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	331 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	332 describe("subscribers", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	333 local service;
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	334 before_each(function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	335 service = pubsub.new();
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	336 service:create("test", true, { publish_model = "subscribers" });
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	337 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	338 it("should not allow non-subscribers to publish", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	339 local ok, err = service:publish("test", "stranger", "item1", "foo");
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	340 assert.is_falsy(ok);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	341 assert.equals("forbidden", err);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	342 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	343 it("should allow subscribers to publish without an affiliation", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	344 assert.is_true(service:add_subscription("test", "stranger", "stranger"));
9209 69e17edf8796 util.pubsub tests: Fix whitespace Kim Alvefur <zash@zash.se> parents: 9208 diff changeset	345 local ok = service:publish("test", "stranger", "item1", "foo");
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	346 assert.is_true(ok);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	347 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	348 it("should allow publishers to publish without a subscription", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	349 assert(service:set_affiliation("test", true, "mypublisher", "publisher"));
10541 6c6ff4509082 tests: Silence [luacheck] warnings Kim Alvefur <zash@zash.se> parents: 10356 diff changeset	350 -- luacheck: ignore 211/err
9171 5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	351 local ok, err = service:publish("test", "mypublisher", "item1", "foo");
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	352 assert.is_true(ok);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	353 end);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	354 it("should allow owners to publish without a subscription", function ()
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	355 assert(service:set_affiliation("test", true, "myowner", "owner"));
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	356 local ok = service:publish("test", "myowner", "item1", "foo");
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	357 assert.is_true(ok);
5f03fe90704f util.pubsub tests: Add tests for publish_model (publishers, open, subscribers) Matthew Wild <mwild1@gmail.com> parents: 9169 diff changeset	358 end);
9169 3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	359 end);
3ec013185c15 util.pubsub tests: Add some initial access model tests (open and whitelist) Matthew Wild <mwild1@gmail.com> parents: 9159 diff changeset	360 end);
9206 33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	361
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	362 describe("item API", function ()
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	363 local service;
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	364 before_each(function ()
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	365 service = pubsub.new();
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	366 service:create("test", true, { publish_model = "subscribers" });
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	367 end);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	368 describe("get_last_item()", function ()
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	369 it("succeeds with nil on empty nodes", function ()
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	370 local ok, id, item = service:get_last_item("test", true);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	371 assert.is_true(ok);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	372 assert.is_nil(id);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	373 assert.is_nil(item);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	374 end);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	375 it("succeeds and returns the last item", function ()
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	376 service:publish("test", true, "one", "hello world");
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	377 service:publish("test", true, "two", "hello again");
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	378 service:publish("test", true, "three", "hey");
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	379 service:publish("test", true, "one", "bye");
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	380 local ok, id, item = service:get_last_item("test", true);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	381 assert.is_true(ok);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	382 assert.equal("one", id);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	383 assert.equal("bye", item);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	384 end);
33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	385 end);
9208 d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	386 describe("get_items()", function ()
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	387 it("fails on non-existent nodes", function ()
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	388 local ok, err = service:get_items("no-node", true);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	389 assert.is_falsy(ok);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	390 assert.equal("item-not-found", err);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	391 end);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	392 it("returns no items on an empty node", function ()
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	393 local ok, items = service:get_items("test", true);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	394 assert.is_true(ok);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	395 assert.equal(0, #items);
9209 69e17edf8796 util.pubsub tests: Fix whitespace Kim Alvefur <zash@zash.se> parents: 9208 diff changeset	396 assert.is_nil(next(items));
9208 d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	397 end);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	398 it("returns no items on an empty node", function ()
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	399 local ok, items = service:get_items("test", true);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	400 assert.is_true(ok);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	401 assert.equal(0, #items);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	402 assert.is_nil((next(items)));
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	403 end);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	404 it("returns all published items", function ()
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	405 service:publish("test", true, "one", "hello world");
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	406 service:publish("test", true, "two", "hello again");
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	407 service:publish("test", true, "three", "hey");
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	408 service:publish("test", true, "one", "bye");
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	409 local ok, items = service:get_items("test", true);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	410 assert.is_true(ok);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	411 assert.same({ "one", "three", "two", two = "hello again", three = "hey", one = "bye" }, items);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	412 end);
d3bb59ec0173 util.pubsub tests: Add tests for get_items() Matthew Wild <mwild1@gmail.com> parents: 9206 diff changeset	413 end);
9206 33ee40dc3e25 Pubsub: Add tests for :get_last_item() and fix for non-persistent nodes Matthew Wild <mwild1@gmail.com> parents: 9178 diff changeset	414 end);
9742 18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	415
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	416 describe("restoring data from nodestore", function ()
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	417 local nodestore = {
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	418 data = {
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	419 test = {
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	420 name = "test";
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	421 config = {};
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	422 affiliations = {};
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	423 subscribers = {
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	424 ["someone"] = true;
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	425 };
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	426 }
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	427 }
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	428 };
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	429 function nodestore:users()
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	430 return pairs(self.data)
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	431 end
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	432 function nodestore:get(key)
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	433 return self.data[key];
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	434 end
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	435 local service = pubsub.new({
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	436 nodestore = nodestore;
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	437 });
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	438 it("subscriptions", function ()
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	439 local ok, ret = service:get_subscriptions(nil, true, nil)
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	440 assert.is_true(ok);
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	441 assert.same({ { node = "test", jid = "someone", subscription = true, } }, ret);
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	442 end);
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	443 end);
18eca6afb367 util.pubsub: Restore subscription index from stored data (fixes #1281) Kim Alvefur <zash@zash.se> parents: 9516 diff changeset	444
9840 ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	445 describe("node config checking", function ()
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	446 local service;
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	447 before_each(function ()
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	448 service = pubsub.new({
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	449 check_node_config = function (node, actor, config) -- luacheck: ignore 212
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	450 return config["max_items"] <= 20;
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	451 end;
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	452 });
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	453 end);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	454
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	455 it("defaults, then configure", function ()
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	456 local ok, err = service:create("node", true);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	457 assert.is_true(ok, err);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	458
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	459 local ok, err = service:set_node_config("node", true, { max_items = 10 });
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	460 assert.is_true(ok, err);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	461
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	462 local ok, err = service:set_node_config("node", true, { max_items = 100 });
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	463 assert.falsy(ok, err);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	464 assert.equals(err, "not-acceptable");
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	465 end);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	466
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	467 it("create with ok config, then configure", function ()
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	468 local ok, err = service:create("node", true, { max_items = 10 });
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	469 assert.is_true(ok, err);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	470
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	471 local ok, err = service:set_node_config("node", true, { max_items = 100 });
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	472 assert.falsy(ok, err);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	473
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	474 local ok, err = service:set_node_config("node", true, { max_items = 10 });
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	475 assert.is_true(ok, err);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	476 end);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	477
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	478 it("create with unacceptable config", function ()
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	479 local ok, err = service:create("node", true, { max_items = 100 });
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	480 assert.falsy(ok, err);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	481 end);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	482
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	483
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	484 end);
ec353524b739 util.pubsub: Validate node configuration on node creation (fixes #1328) Kim Alvefur <zash@zash.se> parents: 9816 diff changeset	485
10572 d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	486 describe("subscriber filter", function ()
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	487 it("works", function ()
10573 3b8431eed785 util.pubsub: Ignore unused argument in tests [luacheck] Kim Alvefur <zash@zash.se> parents: 10572 diff changeset	488 local filter = spy.new(function (subs) -- luacheck: ignore 212/subs
10572 d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	489 return {["modified"] = true};
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	490 end);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	491 local broadcaster = spy.new(function (notif_type, node_name, subscribers, item) -- luacheck: ignore 212
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	492 end);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	493 local service = pubsub.new({
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	494 subscriber_filter = filter;
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	495 broadcaster = broadcaster;
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	496 });
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	497
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	498 local ok = service:create("node", true);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	499 assert.truthy(ok);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	500
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	501 local ok = service:add_subscription("node", true, "someone");
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	502 assert.truthy(ok);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	503
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	504 local ok = service:publish("node", true, "1", "item");
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	505 assert.truthy(ok);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	506 -- TODO how to match table arguments?
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	507 assert.spy(filter).was_called();
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	508 assert.spy(broadcaster).was_called();
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	509 end);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	510 end);
d960c703e6b3 util.pubsub: Cover subscription filter in a partial test Kim Alvefur <zash@zash.se> parents: 10541 diff changeset	511
11721 7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	512 describe("persist_items", function()
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	513 it("can be disabled", function()
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	514 local broadcaster = spy.new(function(notif_type, node_name, subscribers, item) -- luacheck: ignore 212
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	515 end);
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	516 local service = pubsub.new { node_defaults = { persist_items = false }, broadcaster = broadcaster }
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	517
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	518 local ok = service:create("node", true)
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	519 assert.truthy(ok);
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	520
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	521 local ok = service:publish("node", true, "1", "item");
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	522 assert.truthy(ok);
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	523 assert.spy(broadcaster).was_called();
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	524
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	525 local ok, items = service:get_items("node", true);
11723 3ead0967e04d util.pubsub: Signal that 'persistent-items' is unsupported when disabled Kim Alvefur <zash@zash.se> parents: 11721 diff changeset	526 assert.not_truthy(ok);
3ead0967e04d util.pubsub: Signal that 'persistent-items' is unsupported when disabled Kim Alvefur <zash@zash.se> parents: 11721 diff changeset	527 assert.equal(items, "persistent-items-unsupported");
11721 7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	528 end);
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	529
7a77f0c05382 util.pubsub: Fix behavior of persist_items disabled Kim Alvefur <zash@zash.se> parents: 10573 diff changeset	530 end)
11767 5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	531
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	532 describe("max_items", function ()
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	533 it("works", function ()
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	534 local service = pubsub.new { };
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	535
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	536 local ok = service:create("node", true)
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	537 assert.truthy(ok);
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	538
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	539 for i = 1, 20 do
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	540 assert.truthy(service:publish("node", true, "item"..tostring(i), "data"..tostring(i)));
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	541 end
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	542
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	543 do
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	544 local ok, items = service:get_items("node", true, nil, { max = 3 });
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	545 assert.truthy(ok, items);
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	546 assert.equal(3, #items);
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	547 assert.same({
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	548 "item20",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	549 "item19",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	550 "item18",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	551 item20 = "data20",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	552 item19 = "data19",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	553 item18 = "data18",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	554 }, items, "items should be ordered by oldest first");
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	555 end
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	556
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	557 do
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	558 local ok, items = service:get_items("node", true, nil, { max = 10 });
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	559 assert.truthy(ok, items);
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	560 assert.equal(10, #items);
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	561 assert.same({
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	562 "item20",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	563 "item19",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	564 "item18",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	565 "item17",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	566 "item16",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	567 "item15",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	568 "item14",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	569 "item13",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	570 "item12",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	571 "item11",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	572 item20 = "data20",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	573 item19 = "data19",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	574 item18 = "data18",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	575 item17 = "data17",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	576 item16 = "data16",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	577 item15 = "data15",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	578 item14 = "data14",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	579 item13 = "data13",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	580 item12 = "data12",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	581 item11 = "data11",
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	582 }, items, "items should be ordered by oldest first");
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	583 end
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	584
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	585 end);
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	586
5610f7c5b261 util.pubsub: Add support for limiting number of items to retrieve Kim Alvefur <zash@zash.se> parents: 11723 diff changeset	587 end)
8558 5de663cef508 util_pubsub_spec: Beginnings of tests for util.pubsub Kim Alvefur <zash@zash.se> parents: diff changeset	588 end);

prosody

94de6b7596cc

spec/util_pubsub_spec.lua

Software / code / prosody

Annotate

spec/util_pubsub_spec.lua @ 12115:94de6b7596cc

Software `/` code `/` prosody