12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- import { forEachIn } from "@common/utils/forEachIn";
- import Job, { JobOptions } from "@/Job";
- import EventsModule from "@/modules/EventsModule";
- export default class SubscribeMany extends Job {
- public constructor(payload?: unknown, options?: JobOptions) {
- super(EventsModule, payload, options);
- }
- protected override async _validate() {
- if (typeof this._payload !== "object" || this._payload === null)
- throw new Error("Payload must be an object");
- if (!Array.isArray(this._payload.channels))
- throw new Error("Channels must be an array");
- this._payload.channels.forEach((channel: unknown) => {
- if (typeof channel !== "string")
- throw new Error("Channel must be a string");
- });
- }
- protected override async _authorize() {
- await forEachIn(this._payload.channels, async (channel: string) => {
- const [, moduleName, modelName, event, modelId] =
- /^([a-z]+)\.([A-z]+)\.([A-z]+)\.?([A-z0-9]+)?$/.exec(channel) ??
- [];
- let permission = `event.${channel}`;
- if (
- moduleName === "model" &&
- modelName &&
- (modelId || event === "created")
- ) {
- if (event === "created")
- permission = `event.model.${modelName}.created`;
- else permission = `data.${modelName}.findById.${modelId}`;
- }
- await this._context.assertPermission(permission);
- });
- }
- protected async _execute() {
- const socketId = this._context.getSocketId();
- if (!socketId) throw new Error("No socketId specified");
- await EventsModule.subscribeManySocket(
- this._payload.channels,
- socketId
- );
- }
- }
|