blob: f566fd039a96e8f530d6c3a937d7f984a7b8b45d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
package main
import (
"encoding/json"
"net"
)
const (
MESSAGE = "message"
AUTHENTICATE = "authenticate"
RENAME = "rename"
)
const (
SUCCESS = "success"
FAILURE = "failure"
)
type Message struct {
Type string
Data string
User string
}
func (msg *Message) serialize() string {
data, _ := json.Marshal(msg)
return string(data)
}
type Response struct {
Status string
Data string
}
func toBytes(num uint32) []byte {
buf := make([]byte, 4)
var mask uint32 = 0x00FF
for i := 0; i < 4; i += 1 {
buf[4-i-1] = byte(num & mask)
num >>= 8
}
return buf
}
func fromBytes(data []byte) uint32 {
var num uint32
for i := 0; i < 4; i += 1 {
num += uint32(data[i] << ((4 - i - 1) * 8))
}
return num
}
func sendMessage(conn net.Conn, message []byte) error {
size := uint32(len(message))
data := append(toBytes(size), message...)
_, err := conn.Write(data)
if err != nil {
return err
}
return nil
}
func parseMessage(data []byte) (Message, error) {
var m Message
// TODO(andrew): Добавить обработку ошибок
err := json.Unmarshal(data, &m)
return m, err
}
|
