pkg/vector/alg/dbscan_test.go - develop - githubmirror/photoprism

pkg/vector/alg/dbscan_test.go
156 строк4 KB
Michael Mayer
Faces: Harden DBSCAN worker partitioning against zero step #5628
30 май 2026, 10:40
30 май 2026, 10:405511814
package alg

import (
	"reflect"
	"testing"
	"time"
)

func TestDBSCANCluster(t *testing.T) {
	tests := []struct {
		MinPts   int
		Eps      float64
		Points   [][]float64
		Expected []int
	}{
		{
			MinPts:   1,
			Eps:      1,
			Points:   [][]float64{{1}},
			Expected: []int{1},
		},
		{
			MinPts:   1,
			Eps:      1,
			Points:   [][]float64{{1}, {1.5}},
			Expected: []int{1, 1},
		},
		{
			MinPts:   1,
			Eps:      1,
			Points:   [][]float64{{1}, {1}},
			Expected: []int{1, 1},
		},
		{
			MinPts:   1,
			Eps:      1,
			Points:   [][]float64{{1}, {1}, {1}},
			Expected: []int{1, 1, 1},
		},
		{
			MinPts:   1,
			Eps:      1,
			Points:   [][]float64{{1}, {1.5}, {2}},
			Expected: []int{1, 1, 1},
		},
		{
			MinPts:   1,
			Eps:      1,
			Points:   [][]float64{{1}, {1.5}, {3}},
			Expected: []int{1, 1, 2},
		},
		{
			MinPts:   2,
			Eps:      1,
			Points:   [][]float64{{1}, {3}},
			Expected: []int{-1, -1},
		},
	}
	for _, test := range tests {
		c, e := DBSCAN(test.MinPts, test.Eps, 0, EuclideanDist)
		if e != nil {
			t.Errorf("Error initializing kmeans clusterer: %s\n", e.Error())
		}

		if e = c.Learn(test.Points); e != nil {
			t.Errorf("Error learning data: %s\n", e.Error())
		}

		if !reflect.DeepEqual(c.Guesses(), test.Expected) {
			t.Errorf("guesses does not match: %d vs %d\n", c.Guesses(), test.Expected)
		}
	}
}

func TestPartitionSize(t *testing.T) {
	tests := []struct {
		Points   int
		Workers  int
		Expected int
	}{
		{Points: 1000, Workers: 10, Expected: 100},
		{Points: 10, Workers: 2, Expected: 5},
		{Points: 5, Workers: 1, Expected: 5},
		{Points: 3, Workers: 64, Expected: 1},
		{Points: 1, Workers: 1, Expected: 1},
		{Points: 0, Workers: 1, Expected: 1},
		{Points: 4, Workers: 0, Expected: 4},
		{Points: 4, Workers: -3, Expected: 4},
	}
	for _, test := range tests {
		if got := partitionSize(test.Points, test.Workers); got != test.Expected {
			t.Errorf("partitionSize(%d, %d) = %d, want %d", test.Points, test.Workers, got, test.Expected)
		}
	}
}

func TestDBSCANMoreWorkersThanPoints(t *testing.T) {
	// Requesting far more workers than data points must still terminate and
	// cluster correctly; the partition size is floored at 1.
	c, err := DBSCAN(1, 1, 64, EuclideanDist)
	if err != nil {
		t.Fatalf("unexpected constructor error: %s", err)
	}

	points := [][]float64{{1}, {1.5}, {5}}

	if err = c.Learn(points); err != nil {
		t.Fatalf("unexpected learn error: %s", err)
	}

	if expected := []int{1, 1, 2}; !reflect.DeepEqual(c.Guesses(), expected) {
		t.Errorf("guesses do not match: %d vs %d", c.Guesses(), expected)
	}
}

func TestDBSCANWithProgress(t *testing.T) {
	progress := make([][2]int, 0)

	clusterer, err := DBSCANWithProgress(1, 1, 0, EuclideanDist, time.Second, func(done, total int) {
		progress = append(progress, [2]int{done, total})
	})
	if err != nil {
		t.Fatalf("unexpected constructor error: %s", err)
	}

	c, ok := clusterer.(*dbscanClusterer)
	if !ok {
		t.Fatalf("unexpected clusterer type %T", clusterer)
	}

	current := time.Unix(0, 0)
	c.now = func() time.Time {
		value := current
		current = current.Add(600 * time.Millisecond)
		return value
	}

	points := [][]float64{{1}, {1}, {1}, {1}, {1}}

	if err = c.Learn(points); err != nil {
		t.Fatalf("unexpected learn error: %s", err)
	}

	if len(progress) == 0 {
		t.Fatal("expected at least one progress update")
	}

	for _, entry := range progress {
		if entry[0] <= 0 {
			t.Fatalf("expected a positive processed count, got %d", entry[0])
		}
		if entry[1] != len(points) {
			t.Fatalf("expected total %d, got %d", len(points), entry[1])
		}
	}
}