blob: 41c78ecd7d618b781730e394a5738ea0118f1009 (
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
71
72
73
74
75
76
77
|
package main
import (
"encoding/json"
"net"
)
const (
MESSAGE = "message"
AUTHENTICATE = "authenticate"
EXIT = "exit"
REGISTER = "register"
)
const (
SUCCESS = "success"
FAILURE = "failure"
PING = "ping"
)
type Request struct {
Type string
Data string
User string
}
func (msg *Request) serialize() string {
data, _ := json.Marshal(msg)
return string(data)
}
type Response struct {
Status string
Data string
}
type Message struct {
User string
Data string
Timestamp uint32
}
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 parseRequest(data []byte) (Request, error) {
var m Request
err := json.Unmarshal(data, &m)
return m, err
}
|
