Merge pull request #1 from erigontech/upd

upd

README.md

@@ -1,3 +1,3 @@
 # speedtest
-Fork of https://github.com/showwin/speedtest-go adjusted to use erigon infra to do download speed test
+Fork of https://github.com/erigontech/speedtest adjusted to use erigon infra to do download speed test
 

example/main.go

@@ -0,0 +1,48 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+
+	"github.com/erigontech/speedtest/speedtest"
+)
+
+var cloudflareHeaders = http.Header{
+	"lsjdjwcush6jbnjj3jnjscoscisoc5s": []string{"I%OSJDNFKE783DDHHJD873EFSIVNI7384R78SSJBJBCCJBC32JABBJCBJK45"},
+}
+
+func main() {
+	servurl := []string{
+		"v1:https://caplin-snapshots-sepolia.erigon.network",
+		"v1:https://erigon2-v1-snapshots-sepolia.erigon.network/",
+		"v1:https://erigon2-v2-snapshots-sepolia.erigon.network/",
+		"v1:https://erigon2-v3-snapshots-sepolia.erigon.network/",
+		"v1:https://erigon3-v1-snapshots-sepolia.erigon.network/",
+		"v1:https://erigon3-v3-snapshots-sepolia.erigon.network/",
+		"v1:https://erigon3-v3-snapshots-sepolia.erigon.network/v2/",
+	}
+
+	urlstr, err := speedtest.SelectSegmentFromWebseeds(servurl, cloudflareHeaders)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	s, err := speedtest.CustomServer(urlstr)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	checkError(s.PingTest(nil))
+	checkError(s.DownloadTest())
+
+	// Note: The unit of s.DLSpeed, s.ULSpeed is bytes per second, this is a float64.
+	fmt.Printf("Latency: %s, Download: %s\n", s.Latency, s.DLSpeed)
+	s.Context.Reset()
+}
+
+func checkError(err error) {
+	if err != nil {
+		log.Fatal(err)
+	}
+}

go.mod

@@ -1,4 +1,4 @@
-module github.com/showwin/speedtest-go
+module github.com/erigontech/speedtest
 
 go 1.19
 

speedtest.go

@@ -13,10 +13,10 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/showwin/speedtest-go/speedtest/transport"
+	"github.com/erigontech/speedtest/speedtest/transport"
 	"gopkg.in/alecthomas/kingpin.v2"
 
-	"github.com/showwin/speedtest-go/speedtest"
+	"github.com/erigontech/speedtest/speedtest"
 )
 
 var (

speedtest/data_manager.go

@@ -4,13 +4,14 @@ import (
 	"bytes"
 	"context"
 	"errors"
-	"github.com/showwin/speedtest-go/speedtest/internal"
 	"io"
 	"math"
 	"runtime"
 	"sync"
 	"sync/atomic"
 	"time"
+
+	"github.com/erigontech/speedtest/speedtest/internal"
 )
 
 type Manager interface {

speedtest/internal/README.md

@@ -1,6 +1,6 @@
 # Issue #192
 
-<img width="1172" alt="SpeedTest-Go (1)" src="https://github.com/showwin/speedtest-go/assets/30739857/ecced0e9-830c-42d6-aa8b-e3dcf8d124d6">
+<img width="1172" alt="SpeedTest-Go (1)" src="https://github.com/erigontech/speedtest/assets/30739857/ecced0e9-830c-42d6-aa8b-e3dcf8d124d6">
 
 1. Use welford alg to quickly calculate standard deviation and mean.
 2. The welford alg integrated moving window feature, This allows us to ignore early data with excessive volatility.

speedtest/loss.go

@@ -2,10 +2,11 @@ package speedtest
 
 import (
 	"context"
-	"github.com/showwin/speedtest-go/speedtest/transport"
 	"net"
 	"sync"
 	"time"
+
+	"github.com/erigontech/speedtest/speedtest/transport"
 )
 
 type PacketLossAnalyzerOptions struct {

speedtest/request.go

@@ -13,7 +13,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/showwin/speedtest-go/speedtest/transport"
+	"github.com/erigontech/speedtest/speedtest/transport"
 )
 
 type (

speedtest/server.go

@@ -16,7 +16,7 @@ import (
 	"sync"
 	"time"
 
-	"github.com/showwin/speedtest-go/speedtest/transport"
+	"github.com/erigontech/speedtest/speedtest/transport"
 )
 
 const (