11980927100

Committed 22 Nov 2024 10:11PM UTC coverage: 78.471% (-0.02%) from 78.492%

Build # 11980927100

Build Type

Pull #657

github

Committed by

goto-bus-stop

Commit Message

SQLite Key-value store to replace Redis

Pull Request Pull Request #657: SQLite Key-value store to replace Redis

Run Details

760 of 915 branches covered (83.06%)

Branch coverage included in aggregate %.

26 of 37 new or added lines in 2 files covered. (70.27%)

117 existing lines in 4 files now uncovered.

8691 of 11129 relevant lines covered (78.09%)

70.74 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

75.93

/src/plugins/waitlist.js

import fs from 'node:fs';
import {
  PermissionError,
  UserNotFoundError,
  EmptyPlaylistError,
  WaitlistLockedError,
  AlreadyInWaitlistError,
  UserNotInWaitlistError,
  UserIsPlayingError,
} from '../errors/index.js';
import routes from '../routes/waitlist.js';
import { Permissions } from './acl.js';

const schema = JSON.parse(
  fs.readFileSync(new URL('../schemas/waitlist.json', import.meta.url), 'utf8'),
);

/**
 * @typedef {import('../schema.js').UserID} UserID
 * @typedef {import('../schema.js').User} User
 * @typedef {{ cycle: boolean, locked: boolean }} WaitlistSettings
 */

const ADD_TO_WAITLIST_SCRIPT = {
  keys: ['waitlist', 'booth:currentDJ'],
  lua: `
    local k_waitlist = KEYS[1]
    local k_dj = KEYS[2]
    local user_id = ARGV[1]
    local position = ARGV[2]
    local is_in_waitlist = redis.call('LPOS', k_waitlist, user_id)
    local current_dj = redis.call('GET', k_dj)
    if is_in_waitlist or current_dj == user_id then
      return { err = '${AlreadyInWaitlistError.code}' }
    end

    local before_id = nil
    if position then
      before_id = redis.call('LINDEX', k_waitlist, position)
    end

    if before_id then
      redis.call('LINSERT', k_waitlist, 'BEFORE', before_id)
    else
      redis.call('RPUSH', k_waitlist, user_id)
    end

    return redis.call('LRANGE', k_waitlist, 0, -1)
  `,
};

const MOVE_WAITLIST_SCRIPT = {
  keys: ['waitlist', 'booth:currentDJ'],
  lua: `
    local k_waitlist = KEYS[1]
    local k_dj = KEYS[2]
    local user_id = ARGV[1]
    local position = ARGV[2]
    local is_in_waitlist = redis.call('LPOS', k_waitlist, user_id)
    if not is_in_waitlist then
      return { err = '${UserNotInWaitlistError.code}' }
    end
    local current_dj = redis.call('GET', k_dj)
    if current_dj == user_id then
      return { err = '${UserIsPlayingError.code}' }
    end

    local before_id = redis.call('LINDEX', k_waitlist, position)

    redis.call('LREM', k_waitlist, 0, user_id);
    if before_id then
      redis.call('LINSERT', k_waitlist, 'BEFORE', before_id, user_id);
    else
      redis.call('RPUSH', k_waitlist, user_id)
    end

    return redis.call('LRANGE', k_waitlist, 0, -1)
  `,
};

class Waitlist {
  #uw;

  /**
   * @param {import('../Uwave.js').Boot} uw
   */
  constructor(uw) {
    this.#uw = uw;

    uw.config.register(schema['uw:key'], schema);
    uw.redis.defineCommand('uw:addToWaitlist', {
      numberOfKeys: ADD_TO_WAITLIST_SCRIPT.keys.length,
      lua: ADD_TO_WAITLIST_SCRIPT.lua,
    });
    uw.redis.defineCommand('uw:moveWaitlist', {
      numberOfKeys: MOVE_WAITLIST_SCRIPT.keys.length,
      lua: MOVE_WAITLIST_SCRIPT.lua,
    });

    const unsubscribe = uw.config.subscribe(
      schema['uw:key'],
      /**
       * @param {WaitlistSettings} _settings
       * @param {UserID|null} userID
       * @param {Partial<WaitlistSettings>} patch
       */
      (_settings, userID, patch) => {
        // TODO This userID != null check is wrong. It should always pass as
        // long as all the cases where waitlist settings can be updated provide
        // the moderator's user ID. There's no type level guarantee of that happening
        // though and if it doesn't, clients will get out of sync because of this check.
        if ('locked' in patch && patch.locked != null && userID != null) {
          this.#uw.publish('waitlist:lock', {
            moderatorID: userID,
            locked: patch.locked,
          });
        }
      },
    );
    uw.onClose(unsubscribe);
  }

  async #isBoothEmpty() {
    return !(await this.#uw.redis.get('booth:historyID'));
  }

  /**
   * @param {User} user
   * @returns {Promise<boolean>}
   */
  async #hasPlayablePlaylist(user) {
    const { playlists } = this.#uw;
    if (!user.activePlaylistID) {
      return false;
    }

    const playlist = await playlists.getUserPlaylist(user, user.activePlaylistID);
    return playlist && playlist.size > 0;
  }

  /**
   * @returns {Promise<WaitlistSettings>}
   */
  async #getSettings() {
    const { config } = this.#uw;

    const settings = /** @type {WaitlistSettings} */ (await config.get(schema['uw:key']));
    return settings;
  }

  /**
   * @returns {Promise<boolean>}
   */
  async isLocked() {
    const settings = await this.#getSettings();
    return settings.locked;
  }

  /**
   * @returns {Promise<boolean>}
   */
  async isCycleEnabled() {
    const settings = await this.#getSettings();
    return settings.cycle;
  }

  /**
   * @returns {Promise<UserID[]>}
   */
  getUserIDs() {
    return /** @type {Promise<UserID[]>} */ (this.#uw.redis.lrange('waitlist', 0, -1));
  }

  /**
   * used both for joining the waitlist, and for
   * adding someone else to the waitlist.
   * TODO maybe split this up and let http-api handle the difference
   *
   * @param {UserID} userID
   * @param {{moderator?: User}} [options]
   */
  async addUser(userID, options = {}) {
    const { moderator } = options;
    const { acl, users } = this.#uw;

    const user = await users.getUser(userID);
    if (!user) throw new UserNotFoundError({ id: userID });

    const isAddingOtherUser = moderator && user.id !== moderator.id;
    if (isAddingOtherUser) {
      if (!(await acl.isAllowed(moderator, Permissions.WaitlistAdd))) {
        throw new PermissionError({
          requiredRole: 'waitlist.add',
        });
      }
    }

    const canForceJoin = await acl.isAllowed(user, Permissions.WaitlistJoinLocked);
    if (!isAddingOtherUser && !canForceJoin && await this.isLocked()) {
      throw new WaitlistLockedError();
    }

    if (!(await this.#hasPlayablePlaylist(user))) {
      throw new EmptyPlaylistError();
    }

    try {
      const waitlist = /** @type {UserID[]} */ (await this.#uw.redis['uw:addToWaitlist'](...ADD_TO_WAITLIST_SCRIPT.keys, user.id));

      if (isAddingOtherUser) {
        this.#uw.publish('waitlist:add', {
          userID: user.id,
          moderatorID: moderator.id,
          position: waitlist.indexOf(user.id),
          waitlist,
        });
      } else {
        this.#uw.publish('waitlist:join', {
          userID: user.id,
          waitlist,
        });
      }
    } catch (error) {
      if (error.message === AlreadyInWaitlistError.code) {
        throw new AlreadyInWaitlistError();
      }
      throw error;
    }

    if (await this.#isBoothEmpty()) {
      await this.#uw.booth.advance();
    }
  }

  /**
   * @param {UserID} userID
   * @param {number} position
   * @param {{moderator: User}} options
   * @returns {Promise<void>}
   */
  async moveUser(userID, position, { moderator }) {
    const { users } = this.#uw;

    const user = await users.getUser(userID);
    if (!user) {
      throw new UserNotFoundError({ id: userID });
    }

    if (!(await this.#hasPlayablePlaylist(user))) {
      throw new EmptyPlaylistError();
    }

    try {
      const waitlist = /** @type {UserID[]} */ (await this.#uw.redis['uw:moveWaitlist'](...MOVE_WAITLIST_SCRIPT.keys, user.id, position));

      this.#uw.publish('waitlist:move', {
        userID: user.id,
        moderatorID: moderator.id,
        position: waitlist.indexOf(user.id),
        waitlist,
      });
    } catch (error) {
      if (error.message === UserNotInWaitlistError.code) {
        throw new UserNotInWaitlistError({ id: user.id });
      }
      if (error.message === UserIsPlayingError.code) {
        throw new UserIsPlayingError({ id: user.id });
      }
      throw error;
    }
  }

  /**
   * @param {UserID} userID
   * @param {{moderator: User}} options
   * @returns {Promise<void>}
   */
  async removeUser(userID, { moderator }) {
    const { acl, users } = this.#uw;
    const user = await users.getUser(userID);
    if (!user) {
      throw new UserNotFoundError({ id: userID });
    }

    const isRemoving = moderator && user.id !== moderator.id;
    if (isRemoving && !(await acl.isAllowed(moderator, Permissions.WaitlistRemove))) {
      throw new PermissionError({
        requiredRole: 'waitlist.remove',
      });
    }

    const removedCount = await this.#uw.redis.lrem('waitlist', 0, user.id);
    if (removedCount === 0) {
      throw new UserNotInWaitlistError({ id: user.id });
    }

    const waitlist = await this.getUserIDs();
    if (isRemoving) {
      this.#uw.publish('waitlist:remove', {
        userID: user.id,
        moderatorID: moderator.id,
        waitlist,
      });
    } else {
      this.#uw.publish('waitlist:leave', {
        userID: user.id,
        waitlist,
      });
    }
  }

  /**
   * @param {{moderator: User}} options
   * @returns {Promise<void>}
   */
  async clear({ moderator }) {
    await this.#uw.redis.del('waitlist');

    const waitlist = await this.getUserIDs();
    if (waitlist.length !== 0) {
      throw new Error('Could not clear the waitlist. Please try again.');
    }

    this.#uw.publish('waitlist:clear', {
      moderatorID: moderator.id,
    });
  }

  /**
   * @param {boolean} lock
   * @param {User} moderator
   * @returns {Promise<void>}
   */
  async #setWaitlistLocked(lock, moderator) {
    const settings = await this.#getSettings();
    await this.#uw.config.set(schema['uw:key'], { ...settings, locked: lock }, { user: moderator });
  }

  /**
   * Lock the waitlist. Only users with the `waitlist.join.locked` permission
   * will be able to join.
   *
   * @param {{moderator: User}} options
   * @returns {Promise<void>}
   */
  lock({ moderator }) {
    return this.#setWaitlistLocked(true, moderator);
  }

  /**
   * Unlock the waitlist. All users with the `waitlist.join` permission
   * will be able to join.
   *
   * @param {{moderator: User}} options
   * @returns {Promise<void>}
   */
  unlock({ moderator }) {
    return this.#setWaitlistLocked(false, moderator);
  }
}

/**
 * @param {import('../Uwave.js').Boot} uw
 * @returns {Promise<void>}
 */
async function waitlistPlugin(uw) {
  uw.waitlist = new Waitlist(uw);
  uw.httpApi.use('/waitlist', routes());
}

export default waitlistPlugin;
export { Waitlist };

1	import fs from 'node:fs';	1✔
2	import {	1✔
3	PermissionError,	1✔
4	UserNotFoundError,	1✔
5	EmptyPlaylistError,	1✔
6	WaitlistLockedError,	1✔
7	AlreadyInWaitlistError,	1✔
8	UserNotInWaitlistError,	1✔
9	UserIsPlayingError,	1✔
10	} from '../errors/index.js';	1✔
11	import routes from '../routes/waitlist.js';	1✔
12	import { Permissions } from './acl.js';	1✔
13		1✔
14	const schema = JSON.parse(	1✔
15	fs.readFileSync(new URL('../schemas/waitlist.json', import.meta.url), 'utf8'),	1✔
16	);	1✔
17		1✔
18	/**	1✔
19	* @typedef {import('../schema.js').UserID} UserID	1✔
20	* @typedef {import('../schema.js').User} User	1✔
21	* @typedef {{ cycle: boolean, locked: boolean }} WaitlistSettings	1✔
22	*/	1✔
23		1✔
24	const ADD_TO_WAITLIST_SCRIPT = {	1✔
25	keys: ['waitlist', 'booth:currentDJ'],	1✔
26	lua: `	1✔
27	local k_waitlist = KEYS[1]	1✔
28	local k_dj = KEYS[2]	1✔
29	local user_id = ARGV[1]	1✔
30	local position = ARGV[2]	1✔
31	local is_in_waitlist = redis.call('LPOS', k_waitlist, user_id)	1✔
32	local current_dj = redis.call('GET', k_dj)	1✔
33	if is_in_waitlist or current_dj == user_id then	1✔
34	return { err = '${AlreadyInWaitlistError.code}' }	1✔
35	end	1✔
36		1✔
37	local before_id = nil	1✔
38	if position then	1✔
39	before_id = redis.call('LINDEX', k_waitlist, position)	1✔
40	end	1✔
41		1✔
42	if before_id then	1✔
43	redis.call('LINSERT', k_waitlist, 'BEFORE', before_id)	1✔
44	else	1✔
45	redis.call('RPUSH', k_waitlist, user_id)	1✔
46	end	1✔
47		1✔
48	return redis.call('LRANGE', k_waitlist, 0, -1)	1✔
49	`,	1✔
50	};	1✔
51		1✔
52	const MOVE_WAITLIST_SCRIPT = {	1✔
53	keys: ['waitlist', 'booth:currentDJ'],	1✔
54	lua: `	1✔
55	local k_waitlist = KEYS[1]	1✔
56	local k_dj = KEYS[2]	1✔
57	local user_id = ARGV[1]	1✔
58	local position = ARGV[2]	1✔
59	local is_in_waitlist = redis.call('LPOS', k_waitlist, user_id)	1✔
60	if not is_in_waitlist then	1✔
61	return { err = '${UserNotInWaitlistError.code}' }	1✔
62	end	1✔
63	local current_dj = redis.call('GET', k_dj)	1✔
64	if current_dj == user_id then	1✔
65	return { err = '${UserIsPlayingError.code}' }	1✔
66	end	1✔
67		1✔
68	local before_id = redis.call('LINDEX', k_waitlist, position)	1✔
69		1✔
70	redis.call('LREM', k_waitlist, 0, user_id);	1✔
71	if before_id then	1✔
72	redis.call('LINSERT', k_waitlist, 'BEFORE', before_id, user_id);	1✔
73	else	1✔
74	redis.call('RPUSH', k_waitlist, user_id)	1✔
75	end	1✔
76		1✔
77	return redis.call('LRANGE', k_waitlist, 0, -1)	1✔
78	`,	1✔
79	};	1✔
80		1✔
81	class Waitlist {	92✔
82	#uw;	92✔
83		92✔
84	/**	92✔
85	* @param {import('../Uwave.js').Boot} uw	92✔
86	*/	92✔
87	constructor(uw) {	92✔
88	this.#uw = uw;	92✔
89		92✔
90	uw.config.register(schema['uw:key'], schema);	92✔
91	uw.redis.defineCommand('uw:addToWaitlist', {	92✔
92	numberOfKeys: ADD_TO_WAITLIST_SCRIPT.keys.length,	92✔
93	lua: ADD_TO_WAITLIST_SCRIPT.lua,	92✔
94	});	92✔
95	uw.redis.defineCommand('uw:moveWaitlist', {	92✔
96	numberOfKeys: MOVE_WAITLIST_SCRIPT.keys.length,	92✔
97	lua: MOVE_WAITLIST_SCRIPT.lua,	92✔
98	});	92✔
99		92✔
100	const unsubscribe = uw.config.subscribe(	92✔
101	schema['uw:key'],	92✔
102	/**	92✔
103	* @param {WaitlistSettings} _settings	92✔
104	* @param {UserID\|null} userID	92✔
105	* @param {Partial<WaitlistSettings>} patch	92✔
106	*/	92✔
107	(_settings, userID, patch) => {	92✔
UNCOV 108	// TODO This userID != null check is wrong. It should always pass as	×
109	// long as all the cases where waitlist settings can be updated provide	×
110	// the moderator's user ID. There's no type level guarantee of that happening	×
111	// though and if it doesn't, clients will get out of sync because of this check.	×
112	if ('locked' in patch && patch.locked != null && userID != null) {	×
113	this.#uw.publish('waitlist:lock', {	×
114	moderatorID: userID,	×
115	locked: patch.locked,	×
116	});	×
117	}	×
118	},	92✔
119	);	92✔
120	uw.onClose(unsubscribe);	92✔
121	}	92✔
122		92✔
123	async #isBoothEmpty() {	92✔
124	return !(await this.#uw.redis.get('booth:historyID'));	9✔
125	}	9✔
126		92✔
127	/**	92✔
128	* @param {User} user	92✔
129	* @returns {Promise<boolean>}	92✔
130	*/	92✔
131	async #hasPlayablePlaylist(user) {	92✔
132	const { playlists } = this.#uw;	12✔
133	if (!user.activePlaylistID) {	12✔
134	return false;	1✔
135	}	1✔
136		11✔
137	const playlist = await playlists.getUserPlaylist(user, user.activePlaylistID);	11✔
138	return playlist && playlist.size > 0;	12✔
139	}	12✔
140		92✔
141	/**	92✔
142	* @returns {Promise<WaitlistSettings>}	92✔
143	*/	92✔
144	async #getSettings() {	92✔
145	const { config } = this.#uw;	21✔
146		21✔
147	const settings = /** @type {WaitlistSettings} */ (await config.get(schema['uw:key']));	21✔
148	return settings;	21✔
149	}	21✔
150		92✔
151	/**	92✔
152	* @returns {Promise<boolean>}	92✔
153	*/	92✔
154	async isLocked() {	92✔
155	const settings = await this.#getSettings();	15✔
156	return settings.locked;	15✔
157	}	15✔
158		92✔
159	/**	92✔
160	* @returns {Promise<boolean>}	92✔
161	*/	92✔
162	async isCycleEnabled() {	92✔
163	const settings = await this.#getSettings();	6✔
164	return settings.cycle;	6✔
165	}	6✔
166		92✔
167	/**	92✔
168	* @returns {Promise<UserID[]>}	92✔
169	*/	92✔
170	getUserIDs() {	92✔
171	return /** @type {Promise<UserID[]>} */ (this.#uw.redis.lrange('waitlist', 0, -1));	17✔
172	}	17✔
173		92✔
174	/**	92✔
175	* used both for joining the waitlist, and for	92✔
176	* adding someone else to the waitlist.	92✔
177	* TODO maybe split this up and let http-api handle the difference	92✔
178	*	92✔
179	* @param {UserID} userID	92✔
180	* @param {{moderator?: User}} [options]	92✔
181	*/	92✔
182	async addUser(userID, options = {}) {	92✔
183	const { moderator } = options;	13✔
184	const { acl, users } = this.#uw;	13✔
185		13✔
186	const user = await users.getUser(userID);	13✔
187	if (!user) throw new UserNotFoundError({ id: userID });	13!
188		13✔
189	const isAddingOtherUser = moderator && user.id !== moderator.id;	13✔
190	if (isAddingOtherUser) {	13✔
191	if (!(await acl.isAllowed(moderator, Permissions.WaitlistAdd))) {	2✔
192	throw new PermissionError({	1✔
193	requiredRole: 'waitlist.add',	1✔
194	});	1✔
195	}	1✔
196	}	2✔
197		12✔
198	const canForceJoin = await acl.isAllowed(user, Permissions.WaitlistJoinLocked);	12✔
199	if (!isAddingOtherUser && !canForceJoin && await this.isLocked()) {	13!
UNCOV 200	throw new WaitlistLockedError();	×
UNCOV 201	}	×
202		12✔
203	if (!(await this.#hasPlayablePlaylist(user))) {	13✔
204	throw new EmptyPlaylistError();	2✔
205	}	2✔
206		10✔
207	try {	10✔
208	const waitlist = /** @type {UserID[]} */ (await this.#uw.redis['uw:addToWaitlist'](...ADD_TO_WAITLIST_SCRIPT.keys, user.id));	13✔
209		9✔
210	if (isAddingOtherUser) {	13✔
211	this.#uw.publish('waitlist:add', {	1✔
212	userID: user.id,	1✔
213	moderatorID: moderator.id,	1✔
214	position: waitlist.indexOf(user.id),	1✔
215	waitlist,	1✔
216	});	1✔
217	} else {	13✔
218	this.#uw.publish('waitlist:join', {	8✔
219	userID: user.id,	8✔
220	waitlist,	8✔
221	});	8✔
222	}	8✔
223	} catch (error) {	13✔
224	if (error.message === AlreadyInWaitlistError.code) {	1✔
225	throw new AlreadyInWaitlistError();	1✔
226	}	1✔
227	throw error;	×
228	}	×
229		9✔
230	if (await this.#isBoothEmpty()) {	13✔
231	await this.#uw.booth.advance();	6✔
232	}	6✔
233	}	13✔
234		92✔
235	/**	92✔
236	* @param {UserID} userID	92✔
237	* @param {number} position	92✔
238	* @param {{moderator: User}} options	92✔
239	* @returns {Promise<void>}	92✔
240	*/	92✔
241	async moveUser(userID, position, { moderator }) {	92✔
UNCOV 242	const { users } = this.#uw;	×
UNCOV 243		×
UNCOV 244	const user = await users.getUser(userID);	×
UNCOV 245	if (!user) {	×
UNCOV 246	throw new UserNotFoundError({ id: userID });	×
UNCOV 247	}	×
UNCOV 248		×
249	if (!(await this.#hasPlayablePlaylist(user))) {	×
250	throw new EmptyPlaylistError();	×
251	}	×
252		×
253	try {	×
254	const waitlist = /** @type {UserID[]} */ (await this.#uw.redis['uw:moveWaitlist'](...MOVE_WAITLIST_SCRIPT.keys, user.id, position));	×
255		×
256	this.#uw.publish('waitlist:move', {	×
257	userID: user.id,	×
258	moderatorID: moderator.id,	×
259	position: waitlist.indexOf(user.id),	×
260	waitlist,	×
261	});	×
262	} catch (error) {	×
263	if (error.message === UserNotInWaitlistError.code) {	×
264	throw new UserNotInWaitlistError({ id: user.id });	×
265	}	×
266	if (error.message === UserIsPlayingError.code) {	×
267	throw new UserIsPlayingError({ id: user.id });	×
268	}	×
269	throw error;	×
270	}	×
271	}	×
272		92✔
273	/**	92✔
274	* @param {UserID} userID	92✔
275	* @param {{moderator: User}} options	92✔
276	* @returns {Promise<void>}	92✔
277	*/	92✔
278	async removeUser(userID, { moderator }) {	92✔
279	const { acl, users } = this.#uw;	×
280	const user = await users.getUser(userID);	×
281	if (!user) {	×
282	throw new UserNotFoundError({ id: userID });	×
283	}	×
284		×
285	const isRemoving = moderator && user.id !== moderator.id;	×
286	if (isRemoving && !(await acl.isAllowed(moderator, Permissions.WaitlistRemove))) {	×
287	throw new PermissionError({	×
288	requiredRole: 'waitlist.remove',	×
289	});	×
290	}	×
291		×
UNCOV 292	const removedCount = await this.#uw.redis.lrem('waitlist', 0, user.id);	×
UNCOV 293	if (removedCount === 0) {	×
UNCOV 294	throw new UserNotInWaitlistError({ id: user.id });	×
UNCOV 295	}	×
296		×
UNCOV 297	const waitlist = await this.getUserIDs();	×
298	if (isRemoving) {	×
299	this.#uw.publish('waitlist:remove', {	×
300	userID: user.id,	×
301	moderatorID: moderator.id,	×
302	waitlist,	×
303	});	×
304	} else {	×
305	this.#uw.publish('waitlist:leave', {	×
306	userID: user.id,	×
307	waitlist,	×
308	});	×
UNCOV 309	}	×
UNCOV 310	}	×
311		92✔
312	/**	92✔
313	* @param {{moderator: User}} options	92✔
314	* @returns {Promise<void>}	92✔
315	*/	92✔
316	async clear({ moderator }) {	92✔
317	await this.#uw.redis.del('waitlist');	×
318		×
UNCOV 319	const waitlist = await this.getUserIDs();	×
UNCOV 320	if (waitlist.length !== 0) {	×
UNCOV 321	throw new Error('Could not clear the waitlist. Please try again.');	×
UNCOV 322	}	×
UNCOV 323		×
UNCOV 324	this.#uw.publish('waitlist:clear', {	×
UNCOV 325	moderatorID: moderator.id,	×
UNCOV 326	});	×
UNCOV 327	}	×
328		92✔
329	/**	92✔
330	* @param {boolean} lock	92✔
331	* @param {User} moderator	92✔
332	* @returns {Promise<void>}	92✔
333	*/	92✔
334	async #setWaitlistLocked(lock, moderator) {	92✔
UNCOV 335	const settings = await this.#getSettings();	×
UNCOV 336	await this.#uw.config.set(schema['uw:key'], { ...settings, locked: lock }, { user: moderator });	×
UNCOV 337	}	×
338		92✔
339	/**	92✔
340	* Lock the waitlist. Only users with the `waitlist.join.locked` permission	92✔
341	* will be able to join.	92✔
342	*	92✔
343	* @param {{moderator: User}} options	92✔
344	* @returns {Promise<void>}	92✔
345	*/	92✔
346	lock({ moderator }) {	92✔
UNCOV 347	return this.#setWaitlistLocked(true, moderator);	×
UNCOV 348	}	×
349		92✔
350	/**	92✔
351	* Unlock the waitlist. All users with the `waitlist.join` permission	92✔
352	* will be able to join.	92✔
353	*	92✔
354	* @param {{moderator: User}} options	92✔
355	* @returns {Promise<void>}	92✔
356	*/	92✔
357	unlock({ moderator }) {	92✔
UNCOV 358	return this.#setWaitlistLocked(false, moderator);	×
UNCOV 359	}	×
360	}	92✔
361		1✔
362	/**	1✔
363	* @param {import('../Uwave.js').Boot} uw	1✔
364	* @returns {Promise<void>}	1✔
365	*/	1✔
366	async function waitlistPlugin(uw) {	92✔
367	uw.waitlist = new Waitlist(uw);	92✔
368	uw.httpApi.use('/waitlist', routes());	92✔
369	}	92✔
370		1✔
371	export default waitlistPlugin;	1✔
372	export { Waitlist };	1✔

u-wave / core / 11980927100

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous