1 files changed, 0 insertions, 111 deletions
diff --git a/internal/protocol.go b/internal/protocol.go
deleted file mode 100755
index cefd685d..00000000
--- a/internal/protocol.go
+++ /dev/null
@@ -1,111 +0,0 @@
-package internal
-
-import (
-	"os"
-	"sync"
-
-	json "github.com/json-iterator/go"
-	"github.com/spiral/errors"
-	"github.com/spiral/goridge/v3/pkg/frame"
-	"github.com/spiral/goridge/v3/pkg/relay"
-)
-
-type StopCommand struct {
-	Stop bool `json:"stop"`
-}
-
-type pidCommand struct {
-	Pid int `json:"pid"`
-}
-
-var fPool = sync.Pool{New: func() interface{} {
-	return frame.NewFrame()
-}}
-
-func getFrame() *frame.Frame {
-	return fPool.Get().(*frame.Frame)
-}
-
-func putFrame(f *frame.Frame) {
-	f.Reset()
-	fPool.Put(f)
-}
-
-func SendControl(rl relay.Relay, payload interface{}) error {
-	fr := getFrame()
-	defer putFrame(fr)
-
-	fr.WriteVersion(fr.Header(), frame.VERSION_1)
-	fr.WriteFlags(fr.Header(), frame.CONTROL, frame.CODEC_JSON)
-
-	if data, ok := payload.([]byte); ok {
-		// check if payload no more that 4Gb
-		if uint32(len(data)) > ^uint32(0) {
-			return errors.Str("payload is more that 4gb")
-		}
-
-		fr.WritePayloadLen(fr.Header(), uint32(len(data)))
-		fr.WritePayload(data)
-		fr.WriteCRC(fr.Header())
-
-		err := rl.Send(fr)
-		if err != nil {
-			return err
-		}
-		return nil
-	}
-
-	data, err := json.Marshal(payload)
-	if err != nil {
-		return errors.Errorf("invalid payload: %s", err)
-	}
-
-	fr.WritePayloadLen(fr.Header(), uint32(len(data)))
-	fr.WritePayload(data)
-	fr.WriteCRC(fr.Header())
-
-	// we don't need a copy here, because frame copy the data before send
-	err = rl.Send(fr)
-	if err != nil {
-		return errors.E(errors.FileNotFound, err)
-	}
-
-	return nil
-}
-
-func Pid(rl relay.Relay) (int64, error) {
-	err := SendControl(rl, pidCommand{Pid: os.Getpid()})
-	if err != nil {
-		return 0, err
-	}
-
-	fr := getFrame()
-	defer putFrame(fr)
-
-	err = rl.Receive(fr)
-	if err != nil {
-		return 0, err
-	}
-
-	if fr == nil {
-		return 0, errors.Str("nil frame received")
-	}
-
-	flags := fr.ReadFlags()
-
-	if flags&frame.CONTROL == 0 {
-		return 0, errors.Str("unexpected response, header is missing, no CONTROL flag")
-	}
-
-	link := &pidCommand{}
-	err = json.Unmarshal(fr.Payload(), link)
-	if err != nil {
-		return 0, err
-	}
-
-	if link.Pid <= 0 {
-		return 0, errors.Str("pid should be greater than 0")
-	}
-
-	return int64(link.Pid), nil
-}