package main

import (
	"bytes"
	"fmt"
	"github.com/gin-gonic/gin"
	"log"
	"mp_server/user"
)

func main() {
	e := gin.Default()

	e.GET("/", execSingleCode)
	e.GET("/ws", WebsocketServer)
	e.Run("0.0.0.0:8848")
}
func WebsocketServer(c *gin.Context) {

	err := user.UserModule.AddConn(c.Writer, c.Request, nil)
	if err != nil {
		fmt.Println("conn add failed,err:", err)
		c.Writer.Write([]byte("conn add failed,err:"))
		return
	}
}

func execSingleCode(ctx *gin.Context) {

	data := ctx.Request.Body
	resWriter := ctx.Writer
	bf := bytes.Buffer{}
	_, err := bf.ReadFrom(data)
	if err != nil {
		log.Println("read failed from context err:", err)
		resWriter.Write([]byte("处理失败，数据接受异常"))
		return
	}
	
}