reply func(http.ResponseWriter, ModelFakeCall)
}
+func newModelFake(t *testing.T) *ModelFake {
+ t.Helper()
+
+ f := &ModelFake{
+ reply: func(w http.ResponseWriter, _ ModelFakeCall) {
+ modelWriteEvents(w, modelCompletedEvent([]any{modelMessageItem("a line")}, 100, 0, 5))
+ },
+ }
+
+ f.Server = httptest.NewServer(http.HandlerFunc(f.serve))
+ t.Cleanup(f.Close)
+
+ return f
+}
+
// Call returns call number n.
func (f *ModelFake) Call(n int) ModelFakeCall {
f.mutex.Lock()
raw, err := io.ReadAll(r.Body)
if err != nil {
http.Error(w, err.Error(), http.StatusBadRequest)
+
return
}
err = json.Unmarshal(raw, &call.body)
if err != nil {
http.Error(w, err.Error(), http.StatusBadRequest)
+
return
}
f.mutex.Lock()
+
call.number = len(f.calls)
f.calls = append(f.calls, call)
reply := f.reply
reply(w, call)
}
-func newModelFake(t *testing.T) *ModelFake {
- t.Helper()
-
- f := &ModelFake{
- reply: func(w http.ResponseWriter, _ ModelFakeCall) {
- modelWriteEvents(w, modelCompletedEvent([]any{modelMessageItem("a line")}, 100, 0, 5))
- },
- }
-
- f.Server = httptest.NewServer(http.HandlerFunc(f.serve))
- t.Cleanup(f.Close)
-
- return f
-}
-
func modelTestRequest() ModelRequest {
return ModelRequest{
Model: "gpt-test",
// modelWriteEvents writes events as a server-sent event stream.
func modelWriteEvents(w http.ResponseWriter, events ...any) {
w.Header().Set("Content-Type", "text/event-stream")
+
for _, event := range events {
data, err := json.Marshal(event)
if err != nil {
}()
var records []ModelUsageRecord
+
scanner := bufio.NewScanner(file)
for scanner.Scan() {
var record ModelUsageRecord
+
require.NoError(t, json.Unmarshal(scanner.Bytes(), &record))
+
records = append(records, record)
}
return records
}
-func modelReasoningItem(id, encrypted string) map[string]any {
- return map[string]any{
- "type": "reasoning",
- "id": id,
- "encrypted_content": encrypted,
- "summary": []any{},
- }
-}
-
func modelFunctionCallItem(id, callID, name, arguments string) map[string]any {
return map[string]any{
"type": "function_call",