配置socket

hapi-think/index.js

@@ -585,12 +585,13 @@ module.exports = async (app) =>{
             },{
                 plugin: require('./cron'),
                 options: {}
-            },{
-                plugin:require('./socket'),   
-                options:{}
             }
         ]);
 
+        await server.register({
+            plugin:require('./socket'),   
+            options:{}
+        })
         return server;
     }
 };

hapi-think/lib/basic.js

@@ -10,7 +10,9 @@ module.exports = class{
     const xFF = headers['x-forwarded-for'];
     const remoteAddress = xFF ? xFF.split(',')[0] : info.remoteAddress;
     const user = request.auth.credentials;
-    const cookies = new Cookies(req, res)
+    const cookies = new Cookies(req, res);
+    const socketSetting = request.route.settings.plugins['socket'];
+    const socket = socketSetting && socketSetting.enabled && socketSetting.io ? socketSetting.io : {} 
     this.ctx = {
       db:(collection,options={})=>mongodb(request,collection,options),
       user:!_.isEmpty(user) ? {_id:user._id,name:user.username,source:user.source} : user,
@@ -35,7 +37,7 @@ module.exports = class{
       isGet:request.method === 'get' ? true : null,
       isPost:request.method === 'post' ? true : null,
       upload:uploadClient,
-      socket:request.socket || {},
+      socket,
       cookie:{             //see https://github.com/pillarjs/cookies#readme
         set:(key,value,options)=>{
           return cookies.set(key,value,options)

hapi-think/route.js

@@ -30,7 +30,7 @@ exports.plugin  = {
                     if(!route){
                         const options = collection === "api" ? {auth: 'auth'} : {}
                         server.route({
-                            method: collection === "api" ? ['POST','GET'] : "GET",
+                            method: collection === "api" ? 'GET' : "GET",
                             path: collection === "api" ? `/api/${_id}` : `/${_id}`,
                             options,
                             handler: async (request,h) => {
@@ -69,7 +69,7 @@ exports.plugin  = {
             let route = item.route ? JSON.parse(item.route) : {};
             const {method,path,options} = route;
             server.route({
-                method:method || ['POST','GET'],
+                method:method || 'GET',
                 path: `/api/${_id}`,                //不要支持修改path，如果多个path一样会出问题，需要的话只能单独写个短连接配置~
                 options:{auth: 'auth',...options},
                 handler: async (request,h) => {

hapi-think/socket.js

@@ -12,14 +12,21 @@ exports.plugin  = {
         // await server.register(require('@hapi/nes'));
 
         //see https://socket.io/docs/v4/server-options/
-        const io = new Server(server.listener,{});
-        io.on("connection", (socket) => {
-            // console.log('hello socket')
+        const table = server.table();
+        table.forEach(item => {
+            const settings = item.settings.plugins['socket'];
+            if(settings && settings.enabled){
+                const {path} = item;
+                const io = new Server(server.listener,{
+                    ...settings,
+                    path,
+                });
+                io.on("connection", (socket) => {
+                    // console.log('hello socket')
+                });
+                item.settings.plugins['socket'].io = io
+            }
         });
-        server.decorate('request', 'socket', io);
-
     }
-        
-      
        
 };

src/pages/api/ZhIWjVHdVLru7eFn.js

@@ -1,8 +1,9 @@
 
 
 export default async (req)=>{ 
-    const {send,reply,error,isGet,db,user,mongo,cookie,event} = await req.ctx();  
+    const {send,reply,error,isGet,db,user,mongo,cookie,event,socket} = await req.ctx();  
     try{
+        socket.emit('tttt','66666')
         send("success")
     }catch (e){
         error(e)

src/pages/web/ZhkJRJZe81m1AB-0/index.js

@@ -5,10 +5,11 @@ const io = require('socket.io-client');
 export default function App() {
     const start = async () => {
         
-        const ioClient = io.connect('http://localhost:3001/', {
+        const socket = io.connect('http://localhost:3001', {
+            path:"/api/ZhIWjVHdVLru7eFn",
             transports: ['websocket'] 
         });
-        ioClient.on("tttt", (value) => {
+        socket.on("tttt", (value) => {
             console.log(value)
         })
     };

src/pages/web/ZhovF-z7MBtcx2UQ/index.js

@@ -0,0 +1,26 @@
+import Container from './style';
+import {useState,useEffect} from 'react';
+const io = require('socket.io-client');
+
+export default function App() {
+    const start = async () => {
+        
+        const socket = io.connect('http://localhost:3001', {
+            path:"/api/ZhNE2aqY2Pr2uvqA",
+            transports: ['websocket'] 
+        });
+        socket.on("tttt", (value) => {
+            console.log(value)
+        })
+    };
+
+    useEffect(() => {
+        start();
+    },[]);
+
+    return (
+        <Container>
+           test111
+        </Container>
+    ) 
+}

src/pages/web/ZhovF-z7MBtcx2UQ/style.js

@@ -0,0 +1,4 @@
+import { styled } from '@mui/material/styles';
+                  export default styled('div')({
+                  
+                  });

src/pages/web/ZhovF-z7MBtcx2UQ/style.module.scss

@@ -0,0 +1 @@
+