1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
package hotline
import (
"bytes"
"encoding/binary"
)
// FileResumeData is sent when a client or server would like to resume a transfer from an offset
type FileResumeData struct {
Format [4]byte // "RFLT"
Version [2]byte // Always 1
RSVD [34]byte // Unused
ForkCount [2]byte // Length of ForkInfoList. Either 2 or 3 depending on whether file has a resource fork
ForkInfoList []ForkInfoList
readOffset int
}
type ForkInfoList struct {
Fork [4]byte // "DATA" or "MACR"
DataSize [4]byte // offset from which to resume the transfer of data
RSVDA [4]byte // Unused
RSVDB [4]byte // Unused
}
func NewForkInfoList(b []byte) *ForkInfoList {
return &ForkInfoList{
Fork: [4]byte{0x44, 0x41, 0x54, 0x41},
DataSize: [4]byte{b[0], b[1], b[2], b[3]},
RSVDA: [4]byte{},
RSVDB: [4]byte{},
}
}
func NewFileResumeData(list []ForkInfoList) *FileResumeData {
return &FileResumeData{
Format: [4]byte{0x52, 0x46, 0x4C, 0x54}, // RFLT
Version: [2]byte{0, 1},
RSVD: [34]byte{},
ForkCount: [2]byte{0, uint8(len(list))},
ForkInfoList: list,
}
}
//
//func (frd *FileResumeData) Read(p []byte) (int, error) {
// buf := slices.Concat(
// frd.Format[:],
// frd.Version[:],
// frd.RSVD[:],
// frd.ForkCount[:],
// )
// for _, fil := range frd.ForkInfoList {
// buf = append(buf, fil...)
// _ = binary.Write(&buf, binary.LittleEndian, fil)
// }
//
// var buf bytes.Buffer
// _ = binary.Write(&buf, binary.LittleEndian, frd.Format)
// _ = binary.Write(&buf, binary.LittleEndian, frd.Version)
// _ = binary.Write(&buf, binary.LittleEndian, frd.RSVD)
// _ = binary.Write(&buf, binary.LittleEndian, frd.ForkCount)
// for _, fil := range frd.ForkInfoList {
// _ = binary.Write(&buf, binary.LittleEndian, fil)
// }
//
// return buf.Bytes(), nil
//}
func (frd *FileResumeData) BinaryMarshal() ([]byte, error) {
var buf bytes.Buffer
_ = binary.Write(&buf, binary.LittleEndian, frd.Format)
_ = binary.Write(&buf, binary.LittleEndian, frd.Version)
_ = binary.Write(&buf, binary.LittleEndian, frd.RSVD)
_ = binary.Write(&buf, binary.LittleEndian, frd.ForkCount)
for _, fil := range frd.ForkInfoList {
_ = binary.Write(&buf, binary.LittleEndian, fil)
}
return buf.Bytes(), nil
}
func (frd *FileResumeData) UnmarshalBinary(b []byte) error {
frd.Format = [4]byte{b[0], b[1], b[2], b[3]}
frd.Version = [2]byte{b[4], b[5]}
frd.ForkCount = [2]byte{b[40], b[41]}
for i := 0; i < int(frd.ForkCount[1]); i++ {
var fil ForkInfoList
start := 42 + i*16
end := start + 16
r := bytes.NewReader(b[start:end])
if err := binary.Read(r, binary.BigEndian, &fil); err != nil {
return err
}
frd.ForkInfoList = append(frd.ForkInfoList, fil)
}
return nil
}
|
