From 4969c5eb0748442c214701ecc5b8f27c2f800ac4 Mon Sep 17 00:00:00 2001
From: Jonathan Camp <github@jonathan.camp>
Date: Fri, 4 Sep 2020 14:12:56 +0200
Subject: [PATCH] Revert "fix typo and make message types constant"

---
 uacp/conn.go | 23 +++++++++--------------
 1 file changed, 9 insertions(+), 14 deletions(-)

diff --git a/uacp/conn.go b/uacp/conn.go
index 9a17ee77..03b2798f 100644
--- a/uacp/conn.go
+++ b/uacp/conn.go
@@ -23,11 +23,6 @@ const (
 	DefaultSendBufSize    = 0xffff
 	DefaultMaxChunkCount  = 512
 	DefaultMaxMessageSize = 2 * MB
-
-	ERRF = "ERRF"
-	ACKF = "ACKF"
-	HELF = "HELF"
-	RHEF = "RHEF"
 )
 
 // connid stores the current connection id. updated with atomic.AddUint32
@@ -182,7 +177,7 @@ func (c *Conn) handshake(endpoint string) error {
 		EndpointURL:    endpoint,
 	}
 
-	if err := c.Send(HELF, hel); err != nil {
+	if err := c.Send("HELF", hel); err != nil {
 		return err
 	}
 
@@ -193,7 +188,7 @@ func (c *Conn) handshake(endpoint string) error {
 
 	msgtyp := string(b[:4])
 	switch msgtyp {
-	case ACKF:
+	case "ACKF":
 		ack := new(Acknowledge)
 		if _, err := ack.Decode(b[hdrlen:]); err != nil {
 			return errors.Errorf("uacp: decode ACK failed: %s", err)
@@ -213,7 +208,7 @@ func (c *Conn) handshake(endpoint string) error {
 		debug.Printf("conn %d: recv %#v", c.id, ack)
 		return nil
 
-	case ERRF:
+	case "ERRF":
 		errf := new(Error)
 		if _, err := errf.Decode(b[hdrlen:]); err != nil {
 			return errors.Errorf("uacp: decode ERR failed: %s", err)
@@ -238,7 +233,7 @@ func (c *Conn) srvhandshake(endpoint string) error {
 	msgtyp := string(b[:4])
 	msg := b[hdrlen:]
 	switch msgtyp {
-	case HELF:
+	case "HELF":
 		hel := new(Hello)
 		if _, err := hel.Decode(msg); err != nil {
 			c.SendError(ua.StatusBadTCPInternalError)
@@ -248,14 +243,14 @@ func (c *Conn) srvhandshake(endpoint string) error {
 			c.SendError(ua.StatusBadTCPEndpointURLInvalid)
 			return errors.Errorf("uacp: invalid endpoint url %s", hel.EndpointURL)
 		}
-		if err := c.Send(ACKF, c.ack); err != nil {
+		if err := c.Send("ACKF", c.ack); err != nil {
 			c.SendError(ua.StatusBadTCPInternalError)
 			return err
 		}
 		debug.Printf("conn %d: recv %#v", c.id, hel)
 		return nil
 
-	case RHEF:
+	case "RHEF":
 		rhe := new(ReverseHello)
 		if _, err := rhe.Decode(msg); err != nil {
 			c.SendError(ua.StatusBadTCPInternalError)
@@ -276,7 +271,7 @@ func (c *Conn) srvhandshake(endpoint string) error {
 		debug.Printf("conn %d: recv %#v", c.id, rhe)
 		return nil
 
-	case ERRF:
+	case "ERRF":
 		errf := new(Error)
 		if _, err := errf.Decode(b[hdrlen:]); err != nil {
 			return errors.Errorf("uacp: decode ERR failed: %s", err)
@@ -324,7 +319,7 @@ func (c *Conn) Receive() ([]byte, error) {
 
 	debug.Printf("conn %d: recv %s%c with %d bytes", c.id, h.MessageType, h.ChunkType, h.MessageSize)
 
-	if h.MessageType == ERRF {
+	if h.MessageType == "ERR" {
 		errf := new(Error)
 		if _, err := errf.Decode(b[hdrlen:h.MessageSize]); err != nil {
 			return nil, errors.Errorf("uacp: failed to decode ERRF message: %s", err)
@@ -372,5 +367,5 @@ func (c *Conn) SendError(code ua.StatusCode) {
 	// we swallow the error to silence complaints from the linter
 	// since sending an error will close the connection and we
 	// want to bubble a different error up.
-	_ = c.Send(ERRF, &Error{ErrorCode: uint32(code)})
+	_ = c.Send("ERRF", &Error{ErrorCode: uint32(code)})
 }