service_test.go

package git

import (
	"fmt"
	"testing"
	"time"

	"github.com/abiosoft/caddy-git/gittest"
)

func init() {
	SetOS(gittest.FakeOS)
}

func TestServices(t *testing.T) {
	repo := &Repo{URL: "git@github.com", Interval: time.Second}

	Start(repo)
	if len(Services.services) != 1 {
		t.Errorf("Expected 1 service, found %v", len(Services.services))
	}

	Services.Stop(string(repo.URL), 1)
	if len(Services.services) != 0 {
		t.Errorf("Expected 1 service, found %v", len(Services.services))
	}

	repos := make([]*Repo, 5)
	for i := 0; i < 5; i++ {
		repos[i] = &Repo{URL: RepoURL(fmt.Sprintf("test%v", i)), Interval: time.Second * 2}
		Start(repos[i])
		if len(Services.services) != i+1 {
			t.Errorf("Expected %v service(s), found %v", i+1, len(Services.services))
		}
	}

	gos.Sleep(time.Second * 5)
	Services.Stop(string(repos[0].URL), 1)
	if len(Services.services) != 4 {
		t.Errorf("Expected %v service(s), found %v", 4, len(Services.services))
	}

	repo = &Repo{URL: "git@github.com", Interval: time.Second}
	Start(repo)
	if len(Services.services) != 5 {
		t.Errorf("Expected %v service(s), found %v", 5, len(Services.services))
	}

	repo = &Repo{URL: "git@github.com", Interval: time.Second * 2}
	Start(repo)
	if len(Services.services) != 6 {
		t.Errorf("Expected %v service(s), found %v", 6, len(Services.services))
	}

	gos.Sleep(time.Second * 5)
	Services.Stop(string(repo.URL), -1)
	if len(Services.services) != 4 {
		t.Errorf("Expected %v service(s), found %v", 4, len(Services.services))
	}

	for _, repo := range repos {
		Services.Stop(string(repo.URL), -1)
	}
	if len(Services.services) != 0 {
		t.Errorf("Expected %v service(s), found %v", 0, len(Services.services))
	}

	repo.Interval = 0
	Start(repo)
	if len(Services.services) != 0 {
		t.Errorf("Expected %v service(s), found %v", 0, len(Services.services))
	}
}