79 lines
1.8 KiB
TypeScript
79 lines
1.8 KiB
TypeScript
"use strict";
|
|
import {
|
|
Service,
|
|
ServiceBroker,
|
|
ServiceSchema
|
|
} from "moleculer";
|
|
const redisAdapter = require("socket.io-redis");
|
|
const SocketIOService = require("moleculer-io");
|
|
|
|
export default class SocketService extends Service {
|
|
// @ts-ignore
|
|
public constructor(
|
|
public broker: ServiceBroker,
|
|
schema: ServiceSchema<{}> = { name: "socket" }
|
|
) {
|
|
super(broker);
|
|
this.parseServiceSchema(
|
|
Service.mergeSchemas(
|
|
{
|
|
name: "socket",
|
|
mixins: [SocketIOService],
|
|
settings: {
|
|
port: process.env.PORT || 3001,
|
|
io: {
|
|
namespaces: {
|
|
"/": {
|
|
events: {
|
|
call: {
|
|
// whitelist: ["math.*", "say.*", "accounts.*", "rooms.*", "io.*"],
|
|
},
|
|
action: async (data, ack) => {
|
|
// write your handler function here.
|
|
console.log(
|
|
JSON.stringify(data, null, 2)
|
|
);
|
|
|
|
switch (data.type) {
|
|
case "LS_IMPORT":
|
|
console.log(
|
|
`Recieved ${data.type} event.`
|
|
);
|
|
// 1. Send task to queue
|
|
await this.broker.call(
|
|
"library.newImport",
|
|
data.data,
|
|
{}
|
|
);
|
|
break;
|
|
case "LS_TOGGLE_IMPORT_QUEUE":
|
|
await this.broker.call(
|
|
"importqueue.toggleImportQueue",
|
|
data.data,
|
|
{}
|
|
);
|
|
break;
|
|
|
|
}
|
|
}
|
|
},
|
|
},
|
|
},
|
|
options: {
|
|
adapter: redisAdapter({ host: process.env.REDIS_URI, port: 6379 }),
|
|
},
|
|
},
|
|
},
|
|
hooks: {},
|
|
actions: {},
|
|
methods: {},
|
|
async started() {
|
|
this.io.on("connection", (data) => console.log("socket.io server initialized."))
|
|
}
|
|
},
|
|
schema
|
|
)
|
|
);
|
|
}
|
|
}
|