@@ -29,62 +29,65 @@ const me = {
29
29
} ;
30
30
31
31
// set up user data
32
+ const fred = {
33
+
34
+ full_name : "Fred" ,
35
+ user_id : 101 ,
36
+ } ;
37
+ const gail = {
38
+
39
+ full_name : "Gail" ,
40
+ user_id : 102 ,
41
+ } ;
42
+ const george = {
43
+
44
+ full_name : "George" ,
45
+ user_id : 103 ,
46
+ } ;
47
+
48
+ people . add_active_user ( fred ) ;
49
+ people . add_active_user ( gail ) ;
50
+ people . add_active_user ( george ) ;
32
51
people . add_active_user ( me ) ;
33
52
people . initialize_current_user ( me . user_id ) ;
34
53
54
+ const devel = { name : "devel" , subscribed : false , stream_id : 1 } ;
55
+ const rome = { name : "Rome" , subscribed : true , stream_id : 1001 } ;
56
+ stream_data . add_sub ( devel ) ;
57
+ stream_data . add_sub ( rome ) ;
58
+
35
59
function contains_sub ( subs , sub ) {
36
60
return subs . some ( ( s ) => s . name === sub . name ) ;
37
61
}
38
62
39
63
run_test ( "unsubscribe" , ( ) => {
40
- stream_data . clear_subscriptions ( ) ;
41
-
42
- let sub = { name : "devel" , subscribed : false , stream_id : 1 } ;
64
+ // verify clean slate
65
+ assert ( ! stream_data . is_subscribed ( "devel" ) ) ;
43
66
44
67
// set up our subscription
45
- stream_data . add_sub ( sub ) ;
46
- sub . subscribed = true ;
47
- peer_data . set_subscribers ( sub . stream_id , [ me . user_id ] ) ;
68
+ devel . subscribed = true ;
69
+ peer_data . set_subscribers ( devel . stream_id , [ me . user_id ] ) ;
48
70
49
71
// ensure our setup is accurate
50
72
assert ( stream_data . is_subscribed ( "devel" ) ) ;
51
73
52
74
// DO THE UNSUBSCRIBE HERE
53
- stream_data . unsubscribe_myself ( sub ) ;
54
- assert ( ! sub . subscribed ) ;
75
+ stream_data . unsubscribe_myself ( devel ) ;
76
+ assert ( ! devel . subscribed ) ;
55
77
assert ( ! stream_data . is_subscribed ( "devel" ) ) ;
56
- assert ( ! contains_sub ( stream_data . subscribed_subs ( ) , sub ) ) ;
57
- assert ( contains_sub ( stream_data . unsubscribed_subs ( ) , sub ) ) ;
78
+ assert ( ! contains_sub ( stream_data . subscribed_subs ( ) , devel ) ) ;
79
+ assert ( contains_sub ( stream_data . unsubscribed_subs ( ) , devel ) ) ;
58
80
59
81
// make sure subsequent calls work
60
- sub = stream_data . get_sub ( "devel" ) ;
82
+ const sub = stream_data . get_sub ( "devel" ) ;
61
83
assert ( ! sub . subscribed ) ;
62
84
} ) ;
63
85
64
86
run_test ( "subscribers" , ( ) => {
65
- stream_data . clear_subscriptions ( ) ;
66
- let sub = { name : "Rome" , subscribed : true , stream_id : 1001 } ;
87
+ const sub = rome ;
67
88
68
- stream_data . add_sub ( sub ) ;
69
-
70
- const fred = {
71
-
72
- full_name : "Fred" ,
73
- user_id : 101 ,
74
- } ;
75
- const not_fred = {
76
-
77
- full_name : "Not Fred" ,
78
- user_id : 102 ,
79
- } ;
80
- const george = {
81
-
82
- full_name : "George" ,
83
- user_id : 103 ,
84
- } ;
85
- people . add_active_user ( fred ) ;
86
- people . add_active_user ( not_fred ) ;
87
- people . add_active_user ( george ) ;
89
+ // verify setup
90
+ assert ( stream_data . is_subscribed ( sub . name ) ) ;
88
91
89
92
function potential_subscriber_ids ( ) {
90
93
const users = peer_data . potential_subscribers ( sub . stream_id ) ;
@@ -94,7 +97,7 @@ run_test("subscribers", () => {
94
97
assert . deepEqual ( potential_subscriber_ids ( ) , [
95
98
me . user_id ,
96
99
fred . user_id ,
97
- not_fred . user_id ,
100
+ gail . user_id ,
98
101
george . user_id ,
99
102
] ) ;
100
103
@@ -103,9 +106,9 @@ run_test("subscribers", () => {
103
106
assert ( stream_data . is_user_subscribed ( sub . stream_id , me . user_id ) ) ;
104
107
assert ( stream_data . is_user_subscribed ( sub . stream_id , fred . user_id ) ) ;
105
108
assert ( stream_data . is_user_subscribed ( sub . stream_id , george . user_id ) ) ;
106
- assert ( ! stream_data . is_user_subscribed ( sub . stream_id , not_fred . user_id ) ) ;
109
+ assert ( ! stream_data . is_user_subscribed ( sub . stream_id , gail . user_id ) ) ;
107
110
108
- assert . deepEqual ( potential_subscriber_ids ( ) , [ not_fred . user_id ] ) ;
111
+ assert . deepEqual ( potential_subscriber_ids ( ) , [ gail . user_id ] ) ;
109
112
110
113
peer_data . set_subscribers ( sub . stream_id , [ ] ) ;
111
114
@@ -120,7 +123,6 @@ run_test("subscribers", () => {
120
123
// add
121
124
peer_data . add_subscriber ( sub . stream_id , brutus . user_id ) ;
122
125
assert ( stream_data . is_user_subscribed ( sub . stream_id , brutus . user_id ) ) ;
123
- sub = stream_data . get_sub ( "Rome" ) ;
124
126
assert . equal ( peer_data . get_subscriber_count ( sub . stream_id ) , 1 ) ;
125
127
const sub_email = "Rome:[email protected] :9991" ;
126
128
stream_data . update_stream_email_address ( sub , sub_email ) ;
@@ -129,14 +131,12 @@ run_test("subscribers", () => {
129
131
// verify that adding an already-added subscriber is a noop
130
132
peer_data . add_subscriber ( sub . stream_id , brutus . user_id ) ;
131
133
assert ( stream_data . is_user_subscribed ( sub . stream_id , brutus . user_id ) ) ;
132
- sub = stream_data . get_sub ( "Rome" ) ;
133
134
assert . equal ( peer_data . get_subscriber_count ( sub . stream_id ) , 1 ) ;
134
135
135
136
// remove
136
137
let ok = peer_data . remove_subscriber ( sub . stream_id , brutus . user_id ) ;
137
138
assert ( ok ) ;
138
139
assert ( ! stream_data . is_user_subscribed ( sub . stream_id , brutus . user_id ) ) ;
139
- sub = stream_data . get_sub ( "Rome" ) ;
140
140
assert . equal ( peer_data . get_subscriber_count ( sub . stream_id ) , 0 ) ;
141
141
142
142
// verify that checking subscription with undefined user id
@@ -158,7 +158,6 @@ run_test("subscribers", () => {
158
158
ok = peer_data . remove_subscriber ( sub . stream_id , brutus . user_id ) ;
159
159
assert ( ! ok ) ;
160
160
assert ( ! stream_data . is_user_subscribed ( sub . stream_id , brutus . user_id ) ) ;
161
- sub = stream_data . get_sub ( "Rome" ) ;
162
161
assert . equal ( peer_data . get_subscriber_count ( sub . stream_id ) , 0 ) ;
163
162
blueslip . reset ( ) ;
164
163
@@ -217,24 +216,12 @@ run_test("get_subscriber_count", () => {
217
216
stream_data . add_sub ( india ) ;
218
217
assert . equal ( peer_data . get_subscriber_count ( india . stream_id ) , 0 ) ;
219
218
220
- const fred = {
221
-
222
- full_name : "Fred" ,
223
- user_id : 101 ,
224
- } ;
225
- people . add_active_user ( fred ) ;
226
- peer_data . add_subscriber ( india . stream_id , 102 ) ;
219
+ peer_data . add_subscriber ( india . stream_id , fred . user_id ) ;
227
220
assert . equal ( peer_data . get_subscriber_count ( india . stream_id ) , 1 ) ;
228
- const george = {
229
-
230
- full_name : "George" ,
231
- user_id : 103 ,
232
- } ;
233
- people . add_active_user ( george ) ;
234
- peer_data . add_subscriber ( india . stream_id , 103 ) ;
221
+ peer_data . add_subscriber ( india . stream_id , george . user_id ) ;
235
222
assert . equal ( peer_data . get_subscriber_count ( india . stream_id ) , 2 ) ;
236
223
237
- peer_data . remove_subscriber ( india . stream_id , 103 ) ;
224
+ peer_data . remove_subscriber ( india . stream_id , george . user_id ) ;
238
225
assert . deepStrictEqual ( peer_data . get_subscriber_count ( india . stream_id ) , 1 ) ;
239
226
} ) ;
240
227
0 commit comments