blob: 4596cdba55ff78e4c984d472fb959900c47a05a5 (
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
|
package api
import (
"context"
"strings"
"github.com/kyren223/eko/internal/data"
"github.com/kyren223/eko/internal/packet"
"github.com/kyren223/eko/internal/server/session"
"github.com/kyren223/eko/pkg/assert"
)
func SendMessage(ctx context.Context, request *packet.SendMessage) packet.Payload {
sess, ok := session.FromContext(ctx)
assert.Assert(ok, "context in process packet should always have a session")
content := strings.TrimSpace(request.Content)
if content == "" {
return &packet.ErrorMessage{Error: "message content must not be blank"}
}
node := sess.Manager().Node()
message := data.Message{
Id: node.Generate(),
SenderId: sess.ID(),
FrequencyId: node.Generate(), // TODO: replace with actual ID
NetworkId: node.Generate(), // TODO: replace with actual ID
Contents: content,
}
messages = append(messages, message)
payload := &packet.Messages{Messages: messages}
pkt := packet.NewPacket(packet.NewMsgPackEncoder(payload))
sess.WriteQueue <- pkt
return packet.NewOkMessage()
}
var messages []data.Message
|
