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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
package main
import (
"errors"
"fmt"
"os"
"path/filepath"
"sync"
"github.com/pektezol/bitreader"
"github.com/pektezol/sdp.go/pkg/packets"
"github.com/pektezol/sdp.go/pkg/types"
"github.com/pektezol/sdp.go/pkg/writer"
)
type Parser struct {
DemoPath string
}
func NewParser(demoPath string) *Parser {
return &Parser{
DemoPath: demoPath,
}
}
const littleEndian bool = true
func main() {
if len(os.Args) != 2 {
fmt.Println("specify file in command line arguments")
os.Exit(1)
}
parser := NewParser(os.Args[1])
demos, err := parser.ParseDemos()
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
for _, d := range demos {
fmt.Println(d.Writer.GetOutputString())
// You can also marshal structs into JSON and print them:
// out, _ := json.Marshal(d)
// fmt.Println(string(out))
}
}
func (p *Parser) ParseDemos() ([]*types.Demo, error) {
files, err := os.ReadDir(p.DemoPath)
if err != nil {
// not a directory
file, err := os.Open(p.DemoPath)
if err != nil {
return []*types.Demo{}, err
}
defer file.Close()
demo := &types.Demo{}
demo.Writer = writer.NewWriter()
demo.Writer.AppendLine("Generated By: github.com/pektezol/sdp.go")
reader := bitreader.NewReader(file, littleEndian)
p.demoParserHandler(reader, file.Name(), demo, nil)
return []*types.Demo{demo}, nil
} else {
// directory
demoCount := 0
for _, fileinfo := range files {
if len(fileinfo.Name()) > 4 && fileinfo.Name()[len(fileinfo.Name())-4:] == ".dem" {
demoCount++
}
}
wg := new(sync.WaitGroup)
wg.Add(demoCount)
demos := make([]*types.Demo, demoCount)
for i := 0; i < len(demos); i++ {
demos[i] = &types.Demo{}
demos[i].Writer = writer.NewWriter()
demos[i].Writer.AppendLine("Generated By: github.com/pektezol/sdp.go")
}
for i, fileinfo := range files {
if len(fileinfo.Name()) > 4 && fileinfo.Name()[len(fileinfo.Name())-4:] == ".dem" {
file, err := os.Open(filepath.Join(p.DemoPath, fileinfo.Name()))
if err != nil {
return []*types.Demo{}, err
}
defer file.Close()
go p.demoParserHandler(bitreader.NewReader(file, littleEndian), file.Name(), demos[i], wg)
}
}
wg.Wait()
if len(demos) == 0 {
return demos, errors.New("no demo found in given directory")
}
return demos, nil
}
}
func (p *Parser) demoParserHandler(reader *bitreader.Reader, filename string, demo *types.Demo, wg *sync.WaitGroup) {
demo.Writer.AppendLine("\nFile Name: %s", filename)
// this is for recovering after a panic inside parse headers and packet.
// this approach was taken since error handling bitreader functions would take a long time.
defer func() {
if err := recover(); err != nil {
if wg != nil {
wg.Done()
}
demo.Writer.AppendLine("failed to parse demo: %v", err)
}
}()
demo.Headers = packets.ParseHeaders(reader, demo)
for {
message := packets.ParseMessage(reader, demo)
demo.Messages = append(demo.Messages, message)
if message.PacketType == 7 {
if wg != nil {
wg.Done()
}
break
}
}
}
|