Function serverRunRouterDomainSocket

cmd/wsh/cmd/wshcmd-connserver.go:288–395

(jwtToken string)

}

func serverRunRouterDomainSocket(jwtToken string) error {
	log.Printf("starting connserver router (domain socket upstream)")

	// extract socket name from JWT token (unverified - we're on the client side)
	sockName, err := wshutil.ExtractUnverifiedSocketName(jwtToken)
	if err != nil {
		return fmt.Errorf("error extracting socket name from JWT: %v", err)
	}

	// connect to the forwarded domain socket
	sockName = wavebase.ExpandHomeDirSafe(sockName)
	conn, err := net.Dial("unix", sockName)
	if err != nil {
		return fmt.Errorf("error connecting to domain socket %s: %v", sockName, err)
	}

	// create router
	router := wshutil.NewWshRouter()
	ConnServerWshRouter = router

	// create proxy for the domain socket connection
	upstreamProxy := wshutil.MakeRpcProxy("connserver-upstream")

	// goroutine to write to the domain socket
	go func() {
		defer func() {
			panichandler.PanicHandler("serverRunRouterDomainSocket:WriteLoop", recover())
		}()
		writeErr := wshutil.AdaptOutputChToStream(upstreamProxy.ToRemoteCh, conn)
		if writeErr != nil {
			log.Printf("error writing to upstream domain socket: %v\n", writeErr)
		}
	}()

	// goroutine to read from the domain socket
	go func() {
		defer func() {
			panichandler.PanicHandler("serverRunRouterDomainSocket:ReadLoop", recover())
		}()
		defer func() {
			log.Printf("upstream domain socket closed, shutting down")
			wshutil.DoShutdown("", 0, true)
		}()
		wshutil.AdaptStreamToMsgCh(conn, upstreamProxy.FromRemoteCh, nil)
	}()

	// register the domain socket connection as upstream
	router.RegisterUpstream(upstreamProxy)

	// use the router's control RPC to authenticate with upstream
	controlRpc := router.GetControlRpc()

	// authenticate with the upstream router using the JWT
	_, err = wshclient.AuthenticateCommand(controlRpc, jwtToken, &wshrpc.RpcOpts{Route: wshutil.ControlRootRoute})
	if err != nil {
		return fmt.Errorf("error authenticating with upstream: %v", err)
	}
	log.Printf("authenticated with upstream router")