123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172 |
- package example_chat_test
- import (
- "context"
- "testing"
- "time"
- "git.ali33.ru/fcg-xvii/rest"
- "git.ali33.ru/fcg-xvii/rest/example_chat/chat"
- ws "git.ali33.ru/fcg-xvii/rest/rest_websocket"
- )
- func TestChat(t *testing.T) {
- addr := "192.168.88.27:40000"
- core := chat.New()
- server := rest.NewServer(addr, []byte("top-secret"))
- if err := server.Listen(time.Second, context.Background()); err != nil {
- t.Fatal(err)
- }
- app := NewApplication(core)
- restEngine := ws.New(app, core)
- restEngine.Prepare(server, "/ws")
- ch := make(chan struct{})
- <-ch
- //ch := make(chan struct{})
- //<-ch
- /*
- clAddr := "ws://127.0.0.1:40000/ws"
- cl, err := ws.NewClient(clAddr)
- if err != nil {
- t.Fatal(err)
- }
- t.Log(cl)
- mes := &rest.RequestStream{
- Timeout: time.Now().Add(time.Second),
- Request: &rest.Request{
- Type: rest.RequestTypeIn,
- Command: "/users/register",
- Data: json.Map{
- "name": "LETO",
- "password": "my-pass-99",
- },
- },
- }
- answ, err := cl.SendMessage(mes)
- if err != nil {
- t.Fatal(err)
- }
- resp, ok := <-answ
- if !ok {
- t.Log("answer is not received")
- } else {
- t.Log("resp", resp.Data)
- }
- time.Sleep(time.Second * 5)
- cl.Close()
- */
- }
|