[rbdr/mobius] / hotline / transfer.go

package hotline

import (
	"bytes"
	"encoding/binary"
	"errors"
)

type transfer struct {
	Protocol        [4]byte // "HTXF" 0x48545846
	ReferenceNumber [4]byte // Unique ID generated for the transfer
	DataSize        [4]byte // File size
	RSVD            [4]byte // Not implemented in Hotline Protocol
}

var HTXF = [4]byte{0x48, 0x54, 0x58, 0x46} // (HTXF) is the only supported transfer protocol

func (tf *transfer) Write(b []byte) (int, error) {
	if err := binary.Read(bytes.NewReader(b), binary.BigEndian, tf); err != nil {
		return 0, err
	}

	if tf.Protocol != HTXF {
		return 0, errors.New("invalid protocol")
	}

	return len(b), nil
}
Commit	Line	Data
6988a057 JH	1	package hotline
	2
	3	import (
	4	"bytes"
	5	"encoding/binary"
	6	"errors"
	7	)
	8
df2735b2	9	type transfer struct {
6988a057 JH	10	Protocol [4]byte // "HTXF" 0x48545846
	11	ReferenceNumber [4]byte // Unique ID generated for the transfer
	12	DataSize [4]byte // File size
	13	RSVD [4]byte // Not implemented in Hotline Protocol
	14	}
	15
df2735b2	16	var HTXF = [4]byte{0x48, 0x54, 0x58, 0x46} // (HTXF) is the only supported transfer protocol
6988a057	17
df2735b2 JH	18	func (tf *transfer) Write(b []byte) (int, error) {
	19	if err := binary.Read(bytes.NewReader(b), binary.BigEndian, tf); err != nil {
	20	return 0, err
6988a057 JH	21	}
6988a057 JH	22
df2735b2 JH	23	if tf.Protocol != HTXF {
df2735b2 JH	24	return 0, errors.New("invalid protocol")
6988a057 JH	25	}
6988a057 JH	26
df2735b2	27	return len(b), nil
6988a057	28	}