forked from golang/hotime
113 lines
3.0 KiB
Go
113 lines
3.0 KiB
Go
package main
|
|
|
|
import (
|
|
"../../hotime"
|
|
"./admin"
|
|
"errors"
|
|
"fmt"
|
|
"golang.org/x/net/websocket"
|
|
"time"
|
|
)
|
|
|
|
func main() {
|
|
|
|
appIns := hotime.Init("config/config.json")
|
|
//RESTfull接口适配
|
|
appIns.SetConnectListener(func(context *hotime.Context) bool {
|
|
if len(context.RouterString) < 2 || len(context.RouterString) > 3 ||
|
|
!(context.Router[context.RouterString[0]] != nil &&
|
|
context.Router[context.RouterString[0]][context.RouterString[1]] != nil) {
|
|
return true
|
|
}
|
|
//排除无效操作
|
|
if len(context.RouterString) == 2 &&
|
|
context.Req.Method != "GET" &&
|
|
context.Req.Method != "POST" {
|
|
return true
|
|
}
|
|
//列表检索
|
|
if len(context.RouterString) == 2 &&
|
|
context.Req.Method == "GET" {
|
|
context.Router[context.RouterString[0]][context.RouterString[1]]["search"](context)
|
|
}
|
|
//新建
|
|
if len(context.RouterString) == 2 &&
|
|
context.Req.Method == "POST" {
|
|
context.Router[context.RouterString[0]][context.RouterString[1]]["add"](context)
|
|
}
|
|
//查询单条
|
|
if len(context.RouterString) == 3 &&
|
|
context.Req.Method == "GET" {
|
|
context.Router[context.RouterString[0]][context.RouterString[1]]["info"](context)
|
|
}
|
|
//更新
|
|
if len(context.RouterString) == 3 &&
|
|
context.Req.Method == "PUT" {
|
|
context.Router[context.RouterString[0]][context.RouterString[1]]["update"](context)
|
|
}
|
|
//移除
|
|
if len(context.RouterString) == 3 &&
|
|
context.Req.Method == "DELETE" {
|
|
context.Router[context.RouterString[0]][context.RouterString[1]]["remove"](context)
|
|
}
|
|
context.View()
|
|
return false
|
|
})
|
|
|
|
//makeCode := code.MakeCode{}
|
|
//fmt.Println(common.ObjToStr(makeCode.Db2JSON("admin","test",appIns.Db)))
|
|
|
|
appIns.Run(hotime.Router{
|
|
"admin": admin.Project,
|
|
"app": hotime.Proj{
|
|
"index": hotime.Ctr{
|
|
"test": func(this *hotime.Context) {
|
|
|
|
data := this.Db.Get("cached", "*")
|
|
fmt.Println(data)
|
|
fmt.Println(this.Session("test").ToCeilInt())
|
|
this.Session("test1", 98984984)
|
|
fmt.Println(this.Session("test1").Data)
|
|
this.Error.SetError(errors.New("dasdasdas"))
|
|
//fmt.Println(this.Db.GetTag())
|
|
//this.Application.Log.Error("dasdasdas")
|
|
//this.Log.Error("dadasdasd")
|
|
//x:=this.Db.Action(func(db hotime.HoTimeDB) bool {
|
|
//
|
|
// db.Insert("user",hotime.Map{"unickname":"dasdas"})
|
|
//
|
|
// return true
|
|
//})
|
|
//hotime.LogError("dasdasdasdasdas")
|
|
this.Display(5, "dsadas")
|
|
},
|
|
"websocket": func(this *hotime.Context) {
|
|
hdler := websocket.Handler(func(ws *websocket.Conn) {
|
|
for true {
|
|
msg := make([]byte, 5120)
|
|
n, err := ws.Read(msg)
|
|
go func() {
|
|
time.Sleep(time.Second * 5)
|
|
ws.Write([]byte("dsadasdasgregergrerge"))
|
|
|
|
}()
|
|
if err != nil {
|
|
return
|
|
}
|
|
fmt.Printf("Receive: %s\n", msg[:n])
|
|
|
|
send_msg := "[" + string(msg[:n]) + "]"
|
|
m, err := ws.Write([]byte(send_msg))
|
|
if err != nil {
|
|
return
|
|
}
|
|
fmt.Printf("Send: %s\n", msg[:m])
|
|
}
|
|
})
|
|
hdler.ServeHTTP(this.Resp, this.Req)
|
|
},
|
|
},
|
|
},
|
|
})
|
|
}
|