fix proto codec

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

.github/workflows/dependabot-automerge.yml

@@ -25,7 +25,7 @@ jobs:
           || (github.event.workflow_run.event == 'push' && github.event.workflow_run.pull_requests[0].base.ref == github.event.repository.default_branch ))
     steps:
       - name: Approve Changes and Merge changes if label 'dependencies' is set
-        uses: actions/github-script@v4
+        uses: actions/github-script@v5
         with:
           github-token: ${{ secrets.GITHUB_TOKEN }}
           script: |

proto/proto.go

@@ -38,14 +38,14 @@ func (c *protoCodec) Marshal(v interface{}, opts ...codec.Option) ([]byte, error
 		return m.Data, nil
 	}
 
-	switch v.(type) {
-	case proto.Message, newproto.Message:
-		break
-	default:
-		return nil, codec.ErrInvalidMessage
+	switch m := v.(type) {
+	case proto.Message:
+		return proto.Marshal(m)
+	case newproto.Message:
+		return proto.Marshal(m)
 	}
 
-	return proto.Marshal(v.(proto.Message))
+	return nil, codec.ErrInvalidMessage
 }
 
 func (c *protoCodec) Unmarshal(d []byte, v interface{}, opts ...codec.Option) error {
@@ -67,14 +67,15 @@ func (c *protoCodec) Unmarshal(d []byte, v interface{}, opts ...codec.Option) er
 		return nil
 	}
 
-	switch v.(type) {
-	case proto.Message, newproto.Message:
-		break
-	default:
-		return codec.ErrInvalidMessage
+	switch m := v.(type) {
+	case proto.Message:
+		return proto.Unmarshal(d, m)
+	case newproto.Message:
+		return proto.Unmarshal(d, m)
+
 	}
 
-	return proto.Unmarshal(d, v.(proto.Message))
+	return codec.ErrInvalidMessage
 }
 
 func (c *protoCodec) ReadHeader(conn io.Reader, m *codec.Message, t codec.MessageType) error {