Software /
code /
prosody
Annotate
spec/util_pubsub_spec.lua @ 11942:b4f77a7bf8ab
mod_http_openmetrics: Serve HTTP from global context
Makes GET /metrics work regardless of the value of the Host header.
This was not possible before 220468f7a103 which added the ability to
have global HTTP modules, which was partly why the per-host part was
kept while the module lived among the community modules.
Another reason was to provide some semblance of security by obscurity by
only loading the module on e.g. a 'localhost' VirtualHost or Component.
The new IP limits obsoletes this.
author | Kim Alvefur <zash@zash.se> |
---|---|
date | Thu, 25 Nov 2021 16:57:01 +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); |