import type { Cs } from "../types";
|
import { defineStore } from "pinia";
|
import io, { type Socket } from "socket.io-client";
|
import { useSession } from "./session";
|
import { useBase } from "/$/base";
|
import { config } from "/@/config";
|
import { useMessage } from "./message";
|
import { useCool } from "/@/cool";
|
|
export const useSocket = defineStore("cs.socket", () => {
|
const { mitt } = useCool();
|
const { user } = useBase();
|
const session = useSession();
|
const message = useMessage();
|
|
let client = undefined as Socket | undefined;
|
|
function connect() {
|
if (!user.token) {
|
return false;
|
}
|
|
if (client) {
|
client.disconnect();
|
client = undefined;
|
}
|
|
if (!client) {
|
client = io(config.host + "/cs", {
|
transports: ["websocket", "polling"]
|
});
|
|
client.auth = {
|
isAdmin: true,
|
token: user.token
|
};
|
|
client.on("connect", () => {
|
console.log("[cs] connect");
|
});
|
|
client.on("disconnect", () => {
|
console.log("[cs] disconnect");
|
});
|
|
client.on("msg", (data: Cs.Msg) => {
|
if ((data.type == 1 && data.userId != user.info?.id) || data.type == 0) {
|
// 判断是否是当前会话
|
if (data.sessionId == session.info?.id) {
|
message.append({
|
...data.user,
|
...data
|
});
|
} else {
|
// 设置其他会话信息
|
session.list.forEach((e) => {
|
if (e.id == data.sessionId) {
|
if (!e.adminUnreadCount) {
|
e.adminUnreadCount = 0;
|
}
|
|
e.adminUnreadCount += 1;
|
e.lastMsg = data;
|
}
|
});
|
}
|
|
// 发送事件
|
mitt.emit("cs.msg", data);
|
}
|
});
|
}
|
}
|
|
function send(content: Cs.Content) {
|
if (client) {
|
// 发送事件
|
client.emit("send", {
|
sessionId: session.info?.id,
|
content
|
});
|
|
// 追加消息
|
message.append({ content });
|
} else {
|
console.log("[cs] client error");
|
}
|
}
|
|
return {
|
connect,
|
client,
|
send
|
};
|
});
|
