|
@@ -15,8 +15,9 @@ const socket = defineStore('socket', ()=>{
|
|
|
})
|
|
})
|
|
|
|
|
|
|
|
async function connectSocket(){
|
|
async function connectSocket(){
|
|
|
- if(!clientStore.isClient) return;
|
|
|
|
|
|
|
+ if(socket.value) return socket.value;
|
|
|
await new Promise((resolve, reject) => {
|
|
await new Promise((resolve, reject) => {
|
|
|
|
|
+ if(!clientStore.isClient) resolve(true);
|
|
|
clientStore.ipc.removeAllListeners(icpList.socket.connect);
|
|
clientStore.ipc.removeAllListeners(icpList.socket.connect);
|
|
|
clientStore.ipc.send(icpList.socket.connect);
|
|
clientStore.ipc.send(icpList.socket.connect);
|
|
|
clientStore.ipc.on(icpList.socket.connect+'_open', async (event, result) => {
|
|
clientStore.ipc.on(icpList.socket.connect+'_open', async (event, result) => {
|
|
@@ -29,7 +30,7 @@ async function connectSocket(){
|
|
|
|
|
|
|
|
async function disconnectSocket(){
|
|
async function disconnectSocket(){
|
|
|
if(!clientStore.isClient) return;
|
|
if(!clientStore.isClient) return;
|
|
|
- new Promise((resolve,reject)=>{
|
|
|
|
|
|
|
+ await new Promise((resolve,reject)=>{
|
|
|
clientStore.ipc.removeAllListeners(icpList.socket.disconnect);
|
|
clientStore.ipc.removeAllListeners(icpList.socket.disconnect);
|
|
|
clientStore.ipc.send(icpList.socket.disconnect);
|
|
clientStore.ipc.send(icpList.socket.disconnect);
|
|
|
clientStore.ipc.on(icpList.socket.connect, async (event, result) => {
|
|
clientStore.ipc.on(icpList.socket.connect, async (event, result) => {
|
|
@@ -43,6 +44,8 @@ async function connectSocket(){
|
|
|
|
|
|
|
|
async function sendMessage(data){
|
|
async function sendMessage(data){
|
|
|
if(!clientStore.isClient) return;
|
|
if(!clientStore.isClient) return;
|
|
|
|
|
+ console.log('sendMessage');
|
|
|
|
|
+ console.log(data);
|
|
|
new Promise((resolve,reject)=>{
|
|
new Promise((resolve,reject)=>{
|
|
|
clientStore.ipc.removeAllListeners(icpList.socket.sendMessage);
|
|
clientStore.ipc.removeAllListeners(icpList.socket.sendMessage);
|
|
|
clientStore.ipc.send(icpList.socket.sendMessage,JSON.stringify(data));
|
|
clientStore.ipc.send(icpList.socket.sendMessage,JSON.stringify(data));
|