httparg/processor.go at main · Bofry/httparg · GitHub

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
package httparg

import "github.com/Bofry/httparg/internal"

type Processor struct {
	arg *internal.HttpArg

	hasError     bool
	errorHandler ErrorHandler
}

func NewProcessor(target interface{}, option Option) *Processor {
	var (
		arg          = internal.NewHttpArg(target)
		errorHandler = option.ErrorHandler
	)

	instance := Processor{
		arg:          arg,
		errorHandler: errorHandler,
	}

	return &instance
}

func (p *Processor) ProcessQueryString(query string) *Processor {
	if p.hasError {
		return p
	}

	var err error
	defer func() {
		if err != nil {
			p.throwError(err)
		}
	}()

	err = p.arg.ProcessQueryString(query)
	return p
}

func (p *Processor) ProcessContent(content []byte, contentType string) *Processor {
	if p.hasError {
		return p
	}

	var err error
	defer func() {
		if err != nil {
			p.throwError(err)
		}
	}()

	err = p.arg.ProcessContent(content, contentType)
	return p
}

func (p *Processor) Process(content []byte, processor ContentProcessor) *Processor {
	if p.hasError {
		return p
	}

	var err error
	defer func() {
		if err != nil {
			p.throwError(err)
		}
	}()

	err = p.arg.Process(content, processor)
	return p
}

func (p *Processor) Validate() {
	if p.hasError {
		return
	}

	var err error
	defer func() {
		if err != nil {
			p.throwError(err)
		}
	}()

	err = p.arg.Validate()
}

func (p *Processor) throwError(err error) {
	// set the hasError flag
	p.hasError = true

	errHandler := p.errorHandler
	if errHandler == nil {
		errHandler = RegistryService.CurrentErrorHandler()
	}
	if errHandler != nil {
		errHandler(err)
	}
}