From 1af82df8b1b13da4eca9ea77ee873646815de4de Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Fri, 3 Jan 2020 19:46:14 +0000
Subject: [PATCH] Check link is grpc

---
 proxy/mucp/mucp.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/proxy/mucp/mucp.go b/proxy/mucp/mucp.go
index 388aba91..f8baaf91 100644
--- a/proxy/mucp/mucp.go
+++ b/proxy/mucp/mucp.go
@@ -490,7 +490,8 @@ func (p *Proxy) serveRequest(ctx context.Context, link client.Client, service, e
 	defer stream.Close()
 
 	// if we receive a grpc stream we have to refire the initial request
-	if c, ok := req.Codec().(codec.Codec); ok && c.String() == "grpc" {
+	c, ok := req.Codec().(codec.Codec)
+	if ok && c.String() == "grpc" && link.String() == "grpc" {
 		// get the header from client
 		hdr := req.Header()
 		msg := &codec.Message{