SaveMessages 保存消息列表
(ctx context.Context, agentID string, messages []types.Message)
| 108 | |
| 109 | // SaveMessages 保存消息列表 |
| 110 | func (js *JSONStore) SaveMessages(ctx context.Context, agentID string, messages []types.Message) error { |
| 111 | js.mu.Lock() |
| 112 | defer js.mu.Unlock() |
| 113 | |
| 114 | if err := js.ensureAgentDir(agentID); err != nil { |
| 115 | return err |
| 116 | } |
| 117 | |
| 118 | path := filepath.Join(js.agentDir(agentID), "messages.json") |
| 119 | return js.saveJSON(path, messages) |
| 120 | } |
| 121 | |
| 122 | // LoadMessages 加载消息列表 |
| 123 | func (js *JSONStore) LoadMessages(ctx context.Context, agentID string) ([]types.Message, error) { |
no test coverage detected