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
t.Helper()
f := &ModelFake{
- reply: func(w http.ResponseWriter, call ModelFakeCall) {
+ reply: func(w http.ResponseWriter, _ ModelFakeCall) {
modelWriteEvents(w, modelCompletedEvent([]any{modelMessageItem("a line")}, 100, 0, 5))
},
}
// 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)
}