Function streamPermissionPrompt

internal/api/httpapi/httpapi_integration_test.go:3384–3432

(t *testing.T, body io.ReadCloser, requestIDCh chan<- string, resultCh chan<- []sseRecord)

}

func streamPermissionPrompt(t *testing.T, body io.ReadCloser, requestIDCh chan<- string, resultCh chan<- []sseRecord) {
	t.Helper()
	defer func() {
		_ = body.Close()
	}()

	scanner := bufio.NewScanner(body)
	records := make([]sseRecord, 0, 8)
	current := sseRecord{}
	requestIDSent := false

	for scanner.Scan() {
		line := scanner.Text()
		if line == "" {
			if current.Event != "" || current.ID != "" || len(current.Data) > 0 {
				records = append(records, current)
				if !requestIDSent {
					if payload, ok := extractPermissionPayloadFromRecord(
						current,
					); ok && payload.Decision == "" &&
						payload.RequestID != "" {
						requestIDCh <- payload.RequestID
						requestIDSent = true
					}
				}
			}
			current = sseRecord{}
			continue
		}
		switch {
		case strings.HasPrefix(line, "id: "):
			current.ID = strings.TrimPrefix(line, "id: ")
		case strings.HasPrefix(line, "event: "):
			current.Event = strings.TrimPrefix(line, "event: ")
		case strings.HasPrefix(line, "data: "):
			current.Data = append(current.Data, []byte(strings.TrimPrefix(line, "data: "))...)
		}
	}
	if current.Event != "" || current.ID != "" || len(current.Data) > 0 {
		records = append(records, current)
	}
	if !requestIDSent {
		requestIDCh <- ""
	}
	if err := scanner.Err(); err != nil {
		t.Fatalf("scan prompt SSE error = %v", err)
	}
	resultCh <- records
}

func extractPermissionPayloads(t *testing.T, records []sseRecord) []permissionStreamPayload {
	t.Helper()