update
This commit is contained in:
+7
-2
@@ -32,14 +32,19 @@ func init() {
|
|||||||
server.SetMessageHandler(func(msg *message.MixMessage) *message.Reply {
|
server.SetMessageHandler(func(msg *message.MixMessage) *message.Reply {
|
||||||
sender := &Sender{}
|
sender := &Sender{}
|
||||||
sender.Message = msg.Content
|
sender.Message = msg.Content
|
||||||
|
fmt.Println(sender.Message)
|
||||||
sender.Wait = make(chan string)
|
sender.Wait = make(chan string)
|
||||||
sender.uid = u2i.GetInt(msg.FromUserName)
|
sender.uid = u2i.GetInt(msg.FromUserName)
|
||||||
if sender.uid == 0 {
|
if sender.uid == 0 {
|
||||||
sender.uid = int(time.Now().UnixNano())
|
sender.uid = int(time.Now().UnixNano())
|
||||||
u2i.Set(msg.FromUserName, sender.uid)
|
u2i.Set(msg.FromUserName, sender.uid)
|
||||||
}
|
}
|
||||||
|
end := <-sender.Wait
|
||||||
return &message.Reply{MsgType: message.MsgTypeText, MsgData: message.NewText(<-sender.Wait)}
|
fmt.Println(end)
|
||||||
|
if end == "" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return &message.Reply{MsgType: message.MsgTypeText, MsgData: message.NewText(end)}
|
||||||
})
|
})
|
||||||
err := server.Serve()
|
err := server.Serve()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user