package openfluxv2sdk

import (
	"testing"

	"github.com/nats-io/go-nats"
)

const (
	subject     = "test.subject"
	message     = "this is test"
	successFlag = "ok"
	failFlag    = "fail"
)

func publish() {

}

func doRealWork() {
	c, _ := nats.Connect(defaultNatsServer)
	c.Publish(basicPrefix+subject, []byte(message))
	c.Close()
}

type openfluxTest struct {
	OpenfluxSdk
}

func TestSdk(t *testing.T) {
	doRealWork()

	testHandler := func(data []byte, c chan string) Feedback {
		feed := Feedback{}
		if string(data) == message {
			feed.State = 0
			feed.Message = "ok"
			return feed
		}
		t.Errorf("message, expected '%s', got '%s'\n", message, string(data))
		feed.State = 1
		feed.Reason = "message mismatch"
		return feed
	}

	m := openfluxTest{}
	m.SetSubject(subject)
	m.SetHandler(testHandler)
	go m.Run()
}