aboutsummaryrefslogtreecommitdiff
path: root/cmd/parser.go
blob: f21d91faec4a2e54392e82a3055811a9417583c3 (plain) (blame)
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
package main

import (
	"errors"
	"fmt"
	"os"
	"strings"

	"github.com/pektezol/bitreader"
	"github.com/pektezol/sdp.go/pkg/packets"
	"github.com/pektezol/sdp.go/pkg/writer"
)

type Demo struct {
	Headers  packets.Headers   `json:"headers"`
	Messages []packets.Message `json:"messages"`
}

type Parser struct {
	DemoPath string
	writer   strings.Builder
}

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])
	_, err := parser.ParseDemos()
	if err != nil {
		fmt.Println(err.Error())
		os.Exit(1)
	}
	fmt.Println(parser.GetOutput())
}

func (p *Parser) GetOutput() string {
	return p.writer.String()
}

func (p *Parser) ParseDemos() ([]Demo, error) {
	writer.AppendLine("Generated By: github.com/pektezol/sdp.go")
	files, err := os.ReadDir(p.DemoPath)
	if err != nil {
		// not a directory
		file, err := os.Open(p.DemoPath)
		if err != nil {
			return []Demo{}, err
		}
		defer file.Close()
		reader := bitreader.NewReader(file, littleEndian)
		demo := demoParserHandler(reader, file.Name())
		p.writer = writer.GetWriter()
		return []Demo{demo}, nil
	} else {
		demos := []Demo{}
		// directory
		for _, fileinfo := range files {
			if len(fileinfo.Name()) > 4 && fileinfo.Name()[len(fileinfo.Name())-4:] == ".dem" {
				file, err := os.Open(p.DemoPath + fileinfo.Name())
				if err != nil {
					return []Demo{}, err
				}
				defer file.Close()
				reader := bitreader.NewReader(file, littleEndian)
				demo := demoParserHandler(reader, file.Name())
				demos = append(demos, demo)
			}
		}
		p.writer = writer.GetWriter()
		if len(demos) == 0 {
			return demos, errors.New("no demo found in given directory")
		}
		return demos, nil
	}
}

func demoParserHandler(reader *bitreader.Reader, filename string) Demo {
	demo := 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 {
			writer.AppendLine("failed to parse demo: %v", err)
		}
	}()
	demo.Headers = packets.ParseHeaders(reader)
	for {
		message := packets.ParseMessage(reader)
		demo.Messages = append(demo.Messages, message)
		if message.PacketType == 7 {
			break
		}
	}
	return demo
}