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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
package main
import (
"elefant/models"
"encoding/json"
"fmt"
"time"
)
var (
chatMap = make(map[string]*models.Chat)
)
func historyToSJSON(msgs []models.MessagesStory) (string, error) {
data, err := json.Marshal(msgs)
if err != nil {
return "", err
}
if data == nil {
return "", fmt.Errorf("nil data")
}
return string(data), nil
}
func updateStorageChat(name string, msgs []models.MessagesStory) error {
var err error
chat, ok := chatMap[name]
if !ok {
err = fmt.Errorf("failed to find active chat; map:%v; key:%s", chatMap, name)
logger.Error("failed to find active chat", "map", chatMap, "key", name)
return err
}
chat.Msgs, err = historyToSJSON(msgs)
if err != nil {
return err
}
chat.UpdatedAt = time.Now()
_, err = store.UpsertChat(chat)
return err
}
func loadHistoryChats() ([]string, error) {
chats, err := store.ListChats()
if err != nil {
return nil, err
}
resp := []string{}
for _, chat := range chats {
if chat.Name == "" {
chat.Name = fmt.Sprintf("%d_%v", chat.ID, chat.CreatedAt.Unix())
}
resp = append(resp, chat.Name)
chatMap[chat.Name] = &chat
}
return resp, nil
}
func loadHistoryChat(chatName string) ([]models.MessagesStory, error) {
chat, ok := chatMap[chatName]
if !ok {
err := fmt.Errorf("failed to read chat")
logger.Error("failed to read chat", "name", chatName)
return nil, err
}
activeChatName = chatName
return chat.ToHistory()
}
func loadOldChatOrGetNew() []models.MessagesStory {
// find last chat
chat, err := store.GetLastChat()
newChat := &models.Chat{
ID: 0,
CreatedAt: time.Now(),
UpdatedAt: time.Now(),
}
newChat.Name = fmt.Sprintf("%d_%v", chat.ID, chat.CreatedAt.Unix())
if err != nil {
logger.Warn("failed to load history chat", "error", err)
activeChatName = newChat.Name
chatMap[newChat.Name] = newChat
return defaultStarter
}
history, err := chat.ToHistory()
if err != nil {
logger.Warn("failed to load history chat", "error", err)
activeChatName = newChat.Name
chatMap[newChat.Name] = newChat
return defaultStarter
}
return history
}
|
