package tor

import (
	"fmt"
	"git.openprivacy.ca/openprivacy/log"
	path "path/filepath"
	"testing"
)

func getStatusCallback(progChan chan int) func(int, string) {
	return func(prog int, status string) {
		fmt.Printf("%v %v\n", prog, status)
		progChan <- prog
	}
}

func TestTorProvider(t *testing.T) {
	progChan := make(chan int)
	log.SetLevel(log.LevelDebug)
	torpath := path.Join("..", "tmp/tor")

	NewTorrc().WithControlPort(9051).WithHashedPassword("examplehashedpassword").Build(path.Join("..", "testing", "tor", "torrc"))

	log.Debugf("setting tor path %v", torpath)
	acn, err := NewTorACNWithAuth(path.Join("../testing/"), torpath, 9051, HashedPasswordAuthenticator{"examplehashedpassword"})
	if err != nil {
		t.Error(err)
		return
	}
	acn.SetStatusCallback(getStatusCallback(progChan))

	progress := 0
	for progress < 100 {
		progress = <-progChan
		t.Logf("progress: %v", progress)
	}

	acn.Restart()

	progress = 0
	for progress < 100 {
		progress = <-progChan
		t.Logf("progress: %v", progress)
	}

	// Test opening the OP Server
	_, _, err = acn.Open("isbr2t6bflul2zyi6hjtnuezb2xvfr42svzjg2q3gyqfgg3wmnrbkkqd")

	if err == nil {
		info, err := acn.GetInfo("isbr2t6bflul2zyi6hjtnuezb2xvfr42svzjg2q3gyqfgg3wmnrbkkqd")
		if err != nil {
			t.Fatalf("could not find info for OP server %v", err)
		}
		cinfo, exists := info["circuit"]
		if !exists {
			t.Fatalf("could not find circuit info for OP server %v", err)
		}
		t.Logf("Found Cicurit Info %v", cinfo)

		_, err = acn.GetInfo("not_a_real_onion")
		if err == nil {
			t.Fatalf("GetInfo for non existant onion should have errored")
		}

	} else {
		t.Fatalf("could not connect to OP server %v", err)
	}

	// Should skip without blocking...
	acn.Restart()
	acn.Restart()
	acn.Restart()

	acn.Close()
}