feat(backend): removed not necessary message type

backend/pkg/messages/batch.go

@@ -1,11 +1,8 @@
 package messages
 
 import (
-	"fmt"
-	"io"
-	"strings"
-
 	"github.com/pkg/errors"
+	"io"
 )
 
 func ReadBatchReader(reader io.Reader, messageHandler func(Message)) error {
@@ -16,15 +13,7 @@ func ReadBatchReader(reader io.Reader, messageHandler func(Message)) error {
 		if err == io.EOF {
 			return nil
 		} else if err != nil {
-			if strings.HasPrefix(err.Error(), "Unknown message code:") {
-				code := strings.TrimPrefix(err.Error(), "Unknown message code: ")
-				msg, err = DecodeExtraMessage(code, reader)
-				if err != nil {
-					return fmt.Errorf("can't decode msg: %s", err)
-				}
-			} else {
-				return errors.Wrapf(err, "Batch Message decoding error on message with index %v", index)
-			}
+			return errors.Wrapf(err, "Batch Message decoding error on message with index %v", index)
 		}
 		msg = transformDeprecated(msg)
 

backend/pkg/messages/facade.go

@@ -1,41 +1,5 @@
 package messages
 
-import (
-	"bytes"
-	//"io"
-)
-
 func Encode(msg Message) []byte {
 	return msg.Encode()
 }
-
-//
-// func EncodeList(msgs []Message) []byte {
-
-// }
-//
-
-// func Decode(b []byte) (Message, error) {
-// 	return ReadMessage(bytes.NewReader(b))
-// }
-
-// func DecodeEach(b []byte, callback func(Message)) error {
-// 	var err error
-// 	reader :=	bytes.NewReader(b)
-// 	for {
-// 		msg, err := ReadMessage(reader)
-// 		if err != nil {
-// 			break
-// 		}
-// 		callback(msg)
-// 	}
-// 	if err == io.EOF {
-// 		return nil
-// 	}
-// 	return err
-// }
-
-func GetMessageTypeID(b []byte) (uint64, error) {
-	reader := bytes.NewReader(b)
-	return ReadUint(reader)
-}

backend/pkg/messages/trigger.go

@@ -1,35 +0,0 @@
-package messages
-
-import (
-	"fmt"
-	"io"
-)
-
-type SessionFinished struct {
-	message
-	Timestamp uint64
-}
-
-func (msg *SessionFinished) Encode() []byte {
-	buf := make([]byte, 11)
-	buf[0] = 127
-	p := 1
-	p = WriteUint(msg.Timestamp, buf, p)
-	return buf[:p]
-}
-
-func (msg *SessionFinished) TypeID() int {
-	return 127
-}
-
-func DecodeExtraMessage(code string, reader io.Reader) (Message, error) {
-	var err error
-	if code != "127" {
-		return nil, fmt.Errorf("unknown message code: %s", code)
-	}
-	trigger := &SessionFinished{}
-	if trigger.Timestamp, err = ReadUint(reader); err != nil {
-		return nil, fmt.Errorf("can't read message timestamp: %s", err)
-	}
-	return trigger, nil
-}