package web

import (
	"context"

	"speedtest/internal/probe"
)

func DefaultRunner(ctx context.Context, request TestRequest, emit func(Event) error) (probe.Summary, error) {
	return probe.Run(ctx, probe.Config{
		Target:   request.Target,
		HTTPURL:  request.HTTPURL,
		Duration: request.Duration,
		Interval: request.Interval,
		Timeout:  request.Timeout,
	}, func(sample probe.Sample) error {
		return emit(Event{Type: "sample", Sample: &sample})
	})
}