add timestamp to matrix msg
parent
09e87c66d8
commit
b6dbe25a48
|
|
@ -41,9 +41,9 @@ func (m Matrix) Receive() ([]Message, error) {
|
|||
log.Printf("matrix.Receive()")
|
||||
messages := make([]Message, 0)
|
||||
for k := range config.Get().Clients {
|
||||
messages = append(messages, Message{Sender: k, Content: "OH"})
|
||||
messages = append(messages, Message{Timestamp: time.Now(), Sender: k, Content: "OH"})
|
||||
if k == "broc" {
|
||||
messages = append(messages, Message{Sender: k, Content: "!available 2148-10-" + fmt.Sprint(time.Now().Unix()%28)})
|
||||
messages = append(messages, Message{Timestamp: time.Now(), Sender: k, Content: "!available 2148-10-" + fmt.Sprint(time.Now().Unix()%28)})
|
||||
}
|
||||
}
|
||||
return messages, nil
|
||||
|
|
@ -70,7 +70,7 @@ func (m Matrix) Receive() ([]Message, error) {
|
|||
case "m.room.message":
|
||||
b, ok := event.Body()
|
||||
if ok {
|
||||
messages = append(messages, Message{Sender: event.Sender, Content: strings.TrimSpace(b)})
|
||||
messages = append(messages, Message{Timestamp: time.Unix(0, event.Timestamp*int64(time.Millisecond)), Sender: event.Sender, Content: strings.TrimSpace(b)})
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,11 +1,14 @@
|
|||
package message
|
||||
|
||||
import "time"
|
||||
|
||||
type Sender interface {
|
||||
Send(string) error
|
||||
Receive() ([]Message, error)
|
||||
}
|
||||
|
||||
type Message struct {
|
||||
Sender string
|
||||
Content string
|
||||
Sender string
|
||||
Content string
|
||||
Timestamp time.Time
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue