Function NewHelloKite

kontrol/helper_test.go:99–135

(name string, conf *Config)

}

func NewHelloKite(name string, conf *Config) (*HelloKite, error) {
	k := kite.New(name, "1.0.0")
	k.Config = conf.Config.Copy()
	k.Config.Port = 0
	k.Config.KiteKey = testutil.NewToken(name, conf.Private, conf.Public).Raw
	// k.SetLogLevel(kite.DEBUG)

	k.HandleFunc("hello", func(r *kite.Request) (interface{}, error) {
		return fmt.Sprintf("%s says hello", name), nil
	})

	go k.Run()
	<-k.ServerReadyNotify()

	u := &url.URL{
		Scheme: "http",
		Host:   fmt.Sprintf("127.0.0.1:%d", k.Port()),
		Path:   "/kite",
	}

	hk := &HelloKite{
		Kite:    k,
		URL:     u,
		clients: make(map[string]*kite.Client),
		regs:    make(chan *protocol.RegisterResult, 16),
		toks:    make(chan struct{}, 16),
		renew:   make(chan struct{}, 16),
	}

	hk.Kite.OnRegister(hk.onRegister)

	if err := conf.Register(hk); err != nil {
		return nil, err
	}

	return hk, nil
}

func (hk *HelloKite) onRegister(reg *protocol.RegisterResult) {
	hk.regs <- reg