summaryrefslogtreecommitdiffstats
path: root/model/message.go
diff options
context:
space:
mode:
Diffstat (limited to 'model/message.go')
-rw-r--r--model/message.go54
1 files changed, 54 insertions, 0 deletions
diff --git a/model/message.go b/model/message.go
new file mode 100644
index 000000000..47f598af8
--- /dev/null
+++ b/model/message.go
@@ -0,0 +1,54 @@
+// Copyright (c) 2015 Spinpunch, Inc. All Rights Reserved.
+// See License.txt for license information.
+
+package model
+
+import (
+ "encoding/json"
+ "io"
+)
+
+const (
+ ACTION_TYPING = "typing"
+ ACTION_POSTED = "posted"
+ ACTION_POST_EDITED = "post_edited"
+ ACTION_POST_DELETED = "post_deleted"
+ ACTION_VIEWED = "viewed"
+ ACTION_NEW_USER = "new_user"
+)
+
+type Message struct {
+ TeamId string `json:"team_id"`
+ ChannelId string `json:"channel_id"`
+ UserId string `json:"user_id"`
+ Action string `json:"action"`
+ Props map[string]string `json:"props"`
+}
+
+func (m *Message) Add(key string, value string) {
+ m.Props[key] = value
+}
+
+func NewMessage(teamId string, channekId string, userId string, action string) *Message {
+ return &Message{TeamId: teamId, ChannelId: channekId, UserId: userId, Action: action, Props: make(map[string]string)}
+}
+
+func (o *Message) ToJson() string {
+ b, err := json.Marshal(o)
+ if err != nil {
+ return ""
+ } else {
+ return string(b)
+ }
+}
+
+func MessageFromJson(data io.Reader) *Message {
+ decoder := json.NewDecoder(data)
+ var o Message
+ err := decoder.Decode(&o)
+ if err == nil {
+ return &o
+ } else {
+ return nil
+ }
+}