Function serverRunRouter

cmd/wsh/cmd/wshcmd-connserver.go:202–286

()

}

func serverRunRouter() error {
	log.Printf("starting connserver router")
	router := wshutil.NewWshRouter()
	ConnServerWshRouter = router
	termProxy := wshutil.MakeRpcProxy("connserver-term")
	rawCh := make(chan []byte, wshutil.DefaultOutputChSize)
	go func() {
		defer func() {
			panichandler.PanicHandler("serverRunRouter:Parse", recover())
		}()
		packetparser.Parse(os.Stdin, termProxy.FromRemoteCh, rawCh)
	}()
	go func() {
		defer func() {
			panichandler.PanicHandler("serverRunRouter:WritePackets", recover())
		}()
		for msg := range termProxy.ToRemoteCh {
			packetparser.WritePacket(os.Stdout, msg)
		}
	}()
	go func() {
		defer func() {
			panichandler.PanicHandler("serverRunRouter:drainRawCh", recover())
		}()
		defer func() {
			log.Printf("stdin closed, shutting down")
			wshutil.DoShutdown("", 0, true)
		}()
		for range rawCh {
			// ignore
		}
	}()
	router.RegisterUpstream(termProxy)

	sockName := getRemoteDomainSocketName()

	// setup the connserver rpc client first
	client, bareRouteId, err := setupConnServerRpcClientWithRouter(router, sockName)
	if err != nil {
		return fmt.Errorf("error setting up connserver rpc client: %v", err)
	}
	wshfs.RpcClient = client
	wshfs.RpcClientRouteId = bareRouteId

	log.Printf("trying to get JWT public key")

	// fetch and set JWT public key
	jwtPublicKeyB64, err := wshclient.GetJwtPublicKeyCommand(client, nil)
	if err != nil {
		return fmt.Errorf("error getting jwt public key: %v", err)
	}
	jwtPublicKeyBytes, err := base64.StdEncoding.DecodeString(jwtPublicKeyB64)
	if err != nil {
		return fmt.Errorf("error decoding jwt public key: %v", err)
	}
	err = wavejwt.SetPublicKey(jwtPublicKeyBytes)
	if err != nil {
		return fmt.Errorf("error setting jwt public key: %v", err)