diff --git a/go.mod b/go.mod index 2a0d0774..527b0980 100644 --- a/go.mod +++ b/go.mod @@ -4,7 +4,6 @@ go 1.14 require ( github.com/Knetic/govaluate v3.0.0+incompatible - github.com/asaskevich/govalidator v0.0.0-20200428143746-21a406dcc535 github.com/blang/semver v3.5.1+incompatible github.com/d5/tengo/v2 v2.6.0 github.com/google/go-github/v32 v32.1.0 diff --git a/go.sum b/go.sum index 291954f3..acc2417d 100644 --- a/go.sum +++ b/go.sum @@ -1,23 +1,17 @@ -github.com/Knetic/govaluate v1.5.0 h1:L4MyqdJSld9xr2eZcZHCWLfeIX2SBjqrwIKG1pcm/+4= github.com/Knetic/govaluate v3.0.0+incompatible h1:7o6+MAPhYTCF0+fdvoz1xDedhRb4f6s9Tn1Tt7/WTEg= github.com/Knetic/govaluate v3.0.0+incompatible/go.mod h1:r7JcOSlj0wfOMncg0iLm8Leh48TZaKVeNIfJntJ2wa0= github.com/VividCortex/ewma v1.1.1 h1:MnEK4VOv6n0RSY4vtRe3h11qjxL3+t0B8yOL8iMXdcM= github.com/VividCortex/ewma v1.1.1/go.mod h1:2Tkkvm3sRDVXaiyucHiACn4cqf7DpdyLvmxzcbUokwA= github.com/acarl005/stripansi v0.0.0-20180116102854-5a71ef0e047d h1:licZJFw2RwpHMqeKTCYkitsPqHNxTmd4SNR5r94FGM8= github.com/acarl005/stripansi v0.0.0-20180116102854-5a71ef0e047d/go.mod h1:asat636LX7Bqt5lYEZ27JNDcqxfjdBQuJ/MM4CN/Lzo= -github.com/asaskevich/govalidator v0.0.0-20200428143746-21a406dcc535 h1:4daAzAu0S6Vi7/lbWECcX0j45yZReDZ56BQsrVBOEEY= -github.com/asaskevich/govalidator v0.0.0-20200428143746-21a406dcc535/go.mod h1:oGkLhpf+kjZl6xBf758TQhh5XrAeiJv/7FRz/2spLIg= -github.com/blang/semver v1.1.0 h1:ol1rO7QQB5uy7umSNV7VAmLugfLRD+17sYJujRNYPhg= github.com/blang/semver v3.5.1+incompatible h1:cQNTCjp13qL8KC3Nbxr/y2Bqb63oX6wdnnjpJbkM4JQ= github.com/blang/semver v3.5.1+incompatible/go.mod h1:kRBLl5iJ+tD4TcOOxsy/0fnwebNt5EWlYSAyrTnjyyk= -github.com/d5/tengo v1.24.8 h1:PRJ+NWt7ae/9sSbIfThOBTkPSvNV+dwYoBAvwfNgNJY= github.com/d5/tengo/v2 v2.6.0 h1:D0cJtpiBzaLJ/Smv6nnUc/LIfO46oKwDx85NZtIRNRI= github.com/d5/tengo/v2 v2.6.0/go.mod h1:XRGjEs5I9jYIKTxly6HCF8oiiilk5E/RYXOZ5b0DZC8= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= -github.com/google/go-github v17.0.0+incompatible h1:N0LgJ1j65A7kfXrZnUDaYCs/Sf4rEjNlfyDHW9dolSY= github.com/google/go-github/v32 v32.1.0 h1:GWkQOdXqviCPx7Q7Fj+KyPoGm4SwHRh8rheoPhd27II= github.com/google/go-github/v32 v32.1.0/go.mod h1:rIEpZD9CTDQwDK9GDrtMTycQNA4JU3qBsCizh3q2WCI= github.com/google/go-querystring v1.0.0 h1:Xkwi/a1rcvNg1PPYe5vI8GbeBY/jrVuDX5ASuANWTrk= @@ -33,7 +27,6 @@ github.com/logrusorgru/aurora v2.0.3+incompatible/go.mod h1:7rIyQOR62GCctdiQpZ/z github.com/mattn/go-runewidth v0.0.9 h1:Lm995f3rfxdpd6TSmuVCHVb/QhupuXlYr8sCI/QdE+0= github.com/mattn/go-runewidth v0.0.9/go.mod h1:H031xJmbD/WCDINGzjvQ9THkh0rPKHF+m2gUSrubnMI= github.com/miekg/dns v1.1.29/go.mod h1:KNUDUusw/aVsxyTYZM1oqvCicbwhgbNgztCETuNZ7xM= -github.com/miekg/dns v1.1.30/go.mod h1:KNUDUusw/aVsxyTYZM1oqvCicbwhgbNgztCETuNZ7xM= github.com/miekg/dns v1.1.31 h1:sJFOl9BgwbYAWOGEwr61FU28pqsBNdpRBnhGXtO06Oo= github.com/miekg/dns v1.1.31/go.mod h1:KNUDUusw/aVsxyTYZM1oqvCicbwhgbNgztCETuNZ7xM= github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 h1:ZqeYNhU3OHLH3mGKHDcjJRFFRrJa6eAM5H+CtDdOsPc= @@ -46,9 +39,6 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/projectdiscovery/gologger v1.0.1 h1:FzoYQZnxz9DCvSi/eg5A6+ET4CQ0CDUs27l6Exr8zMQ= github.com/projectdiscovery/gologger v1.0.1/go.mod h1:Ok+axMqK53bWNwDSU1nTNwITLYMXMdZtRc8/y1c7sWE= -github.com/projectdiscovery/nuclei v1.1.7 h1:5Z1fBHcjyAuuI89xcCzv8tYK7b6ucqLxs+mCC/nJjno= -github.com/projectdiscovery/nuclei/v2 v2.1.0 h1:TUr9lwJ8lulBmEfz6AQHoKPiBQocl4PrPXSu3ekXsXY= -github.com/projectdiscovery/nuclei/v2 v2.1.0/go.mod h1:iufrjj0m0PCZc8J8eVLZqZMyiCaMMv4R5d6QKBdqpZA= github.com/projectdiscovery/retryabledns v1.0.4 h1:0Va7qHlWQsIXjRLISTjzfN3tnJmHYDudY05Nu3IJd60= github.com/projectdiscovery/retryabledns v1.0.4/go.mod h1:/UzJn4I+cPdQl6pKiiQfvVAT636YZvJQYZhYhGB0dUQ= github.com/projectdiscovery/retryablehttp-go v1.0.1 h1:V7wUvsZNq1Rcz7+IlcyoyQlNwshuwptuBVYWw9lx8RE= @@ -57,8 +47,6 @@ github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= github.com/stretchr/testify v1.5.1 h1:nOGnQDM7FYENwehXlg/kFVnos3rEvtKTjRvOWSzb6H4= github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= -github.com/vbauerster/mpb v1.1.3 h1:IRgic8VFaURXkW0VxDLkNOiNaAgtw0okB2YIaVvJDI4= -github.com/vbauerster/mpb v3.4.0+incompatible h1:mfiiYw87ARaeRW6x5gWwYRUawxaW1tLAD8IceomUCNw= github.com/vbauerster/mpb/v5 v5.2.4 h1:PLP8vv75RcEgxGoJVtKaRD2FHSxEmIV/u4ZuOrfO8Qg= github.com/vbauerster/mpb/v5 v5.2.4/go.mod h1:K4iCHQp5sWnmAgEn+uW1sAxSilctb4JPAGXx49jV+Aw= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= @@ -73,6 +61,7 @@ golang.org/x/net v0.0.0-20190923162816-aa69164e4478/go.mod h1:z5CRVTTTmAJ677TzLL golang.org/x/net v0.0.0-20200707034311-ab3426394381 h1:VXak5I6aEWmAXeQjA+QSZzlgNrpq9mjcfDemuexIKsU= golang.org/x/net v0.0.0-20200707034311-ab3426394381/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= +golang.org/x/sync v0.0.0-20190423024810-112230192c58 h1:8gQV6CLnAEikrhgkHFbMAEhagSSnXWGV915qUMm9mrU= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= @@ -84,6 +73,7 @@ golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/tools v0.0.0-20191216052735-49a3e744a425/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU= diff --git a/internal/bufwriter/bufwriter.go b/internal/bufwriter/bufwriter.go new file mode 100644 index 00000000..32592d48 --- /dev/null +++ b/internal/bufwriter/bufwriter.go @@ -0,0 +1,74 @@ +package bufwriter + +import ( + "bufio" + "os" + "sync" +) + +// Writer is a mutex protected buffered writer +type Writer struct { + file *os.File + writer *bufio.Writer + mutex *sync.Mutex +} + +// New creates a new mutex protected buffered writer for a file +func New(file string) (*Writer, error) { + output, err := os.Create(file) + if err != nil { + return nil, err + } + return &Writer{file: output, writer: bufio.NewWriter(output), mutex: &sync.Mutex{}}, nil +} + +// Write writes a byte slice to the underlying file +// +// It also writes a newline if the last byte isn't a newline character. +func (w *Writer) Write(data []byte) error { + if len(data) == 0 { + return nil + } + w.mutex.Lock() + defer w.mutex.Unlock() + + _, err := w.writer.Write(data) + if err != nil { + return err + } + if data[len(data)-1] != '\n' { + _, err = w.writer.WriteRune('\n') + } + return err +} + +// WriteString writes a string to the underlying file +// +// It also writes a newline if the last byte isn't a newline character. +func (w *Writer) WriteString(data string) error { + if data == "" { + return nil + } + w.mutex.Lock() + defer w.mutex.Unlock() + + _, err := w.writer.WriteString(data) + if err != nil { + return err + } + if data[len(data)-1] != '\n' { + _, err = w.writer.WriteRune('\n') + } + return err +} + +// Close closes the underlying writer flushing everything to disk +func (w *Writer) Close() error { + w.mutex.Lock() + defer w.mutex.Unlock() + + w.writer.Flush() + //nolint:errcheck // we don't care whether sync failed or succeeded. + w.file.Sync() + return w.file.Close() +} diff --git a/internal/runner/processor.go b/internal/runner/processor.go index 097ef07d..03cc4839 100644 --- a/internal/runner/processor.go +++ b/internal/runner/processor.go @@ -31,16 +31,8 @@ type workflowTemplates struct { // processTemplateWithList processes a template and runs the enumeration on all the targets func (r *Runner) processTemplateWithList(ctx context.Context, p progress.IProgress, template *templates.Template, request interface{}) bool { - var writer *bufio.Writer - if r.output != nil { - writer = bufio.NewWriter(r.output) - defer writer.Flush() - } - var httpExecuter *executer.HTTPExecuter - var dnsExecuter *executer.DNSExecuter - var err error // Create an executer based on the request type. @@ -50,7 +42,7 @@ func (r *Runner) processTemplateWithList(ctx context.Context, p progress.IProgre Debug: r.options.Debug, Template: template, DNSRequest: value, - Writer: writer, + Writer: r.output, JSON: r.options.JSON, JSONRequests: r.options.JSONRequests, ColoredOutput: !r.options.NoColor, @@ -62,7 +54,7 @@ func (r *Runner) processTemplateWithList(ctx context.Context, p progress.IProgre Debug: r.options.Debug, Template: template, BulkHTTPRequest: value, - Writer: writer, + Writer: r.output, Timeout: r.options.Timeout, Retries: r.options.Retries, ProxyURL: r.options.ProxyURL, @@ -188,12 +180,6 @@ func (r *Runner) preloadWorkflowTemplates(p progress.IProgress, workflow *workfl var wflTemplatesList []workflowTemplates for name, value := range workflow.Variables { - var writer *bufio.Writer - if r.output != nil { - writer = bufio.NewWriter(r.output) - defer writer.Flush() - } - // Check if the template is an absolute path or relative path. // If the path is absolute, use it. Otherwise, if isRelative(value) { @@ -220,7 +206,7 @@ func (r *Runner) preloadWorkflowTemplates(p progress.IProgress, workflow *workfl if len(t.BulkRequestsHTTP) > 0 { template.HTTPOptions = &executer.HTTPOptions{ Debug: r.options.Debug, - Writer: writer, + Writer: r.output, Template: t, Timeout: r.options.Timeout, Retries: r.options.Retries, @@ -238,7 +224,7 @@ func (r *Runner) preloadWorkflowTemplates(p progress.IProgress, workflow *workfl template.DNSOptions = &executer.DNSOptions{ Debug: r.options.Debug, Template: t, - Writer: writer, + Writer: r.output, JSON: r.options.JSON, JSONRequests: r.options.JSONRequests, ColoredOutput: !r.options.NoColor, @@ -285,7 +271,7 @@ func (r *Runner) preloadWorkflowTemplates(p progress.IProgress, workflow *workfl if len(t.BulkRequestsHTTP) > 0 { template.HTTPOptions = &executer.HTTPOptions{ Debug: r.options.Debug, - Writer: writer, + Writer: r.output, Template: t, Timeout: r.options.Timeout, Retries: r.options.Retries, @@ -298,7 +284,7 @@ func (r *Runner) preloadWorkflowTemplates(p progress.IProgress, workflow *workfl template.DNSOptions = &executer.DNSOptions{ Debug: r.options.Debug, Template: t, - Writer: writer, + Writer: r.output, } } if template.DNSOptions != nil || template.HTTPOptions != nil { diff --git a/internal/runner/runner.go b/internal/runner/runner.go index 977145cc..2d20e608 100644 --- a/internal/runner/runner.go +++ b/internal/runner/runner.go @@ -13,6 +13,7 @@ import ( "github.com/logrusorgru/aurora" "github.com/projectdiscovery/gologger" + "github.com/projectdiscovery/nuclei/v2/internal/bufwriter" "github.com/projectdiscovery/nuclei/v2/internal/progress" "github.com/projectdiscovery/nuclei/v2/pkg/atomicboolean" "github.com/projectdiscovery/nuclei/v2/pkg/templates" @@ -25,8 +26,7 @@ type Runner struct { inputCount int64 // output is the output file to write if any - output *os.File - outputMutex *sync.Mutex + output *bufwriter.Writer tempFile string templatesConfig *nucleiConfig @@ -45,8 +45,7 @@ type Runner struct { // New creates a new client for running enumeration process. func New(options *Options) (*Runner, error) { runner := &Runner{ - outputMutex: &sync.Mutex{}, - options: options, + options: options, } if err := runner.updateTemplates(); err != nil { @@ -152,11 +151,10 @@ func New(options *Options) (*Runner, error) { // Create the output file if asked if options.Output != "" { - output, err := os.Create(options.Output) + output, err := bufwriter.New(options.Output) if err != nil { gologger.Fatalf("Could not create output file '%s': %s\n", options.Output, err) } - runner.output = output } @@ -170,7 +168,9 @@ func New(options *Options) (*Runner, error) { // Close releases all the resources and cleans up func (r *Runner) Close() { - r.output.Close() + if r.output != nil { + r.output.Close() + } os.Remove(r.tempFile) } @@ -266,9 +266,8 @@ func (r *Runner) RunEnumeration() { if !results.Get() { if r.output != nil { - outputFile := r.output.Name() r.output.Close() - os.Remove(outputFile) + os.Remove(r.options.Output) } gologger.Infof("No results found. Happy hacking!") diff --git a/pkg/executer/executer_dns.go b/pkg/executer/executer_dns.go index 458c3cb3..db2b1b8e 100644 --- a/pkg/executer/executer_dns.go +++ b/pkg/executer/executer_dns.go @@ -1,15 +1,14 @@ package executer import ( - "bufio" "fmt" "os" "regexp" - "sync" "github.com/logrusorgru/aurora" "github.com/pkg/errors" "github.com/projectdiscovery/gologger" + "github.com/projectdiscovery/nuclei/v2/internal/bufwriter" "github.com/projectdiscovery/nuclei/v2/internal/progress" "github.com/projectdiscovery/nuclei/v2/pkg/matchers" "github.com/projectdiscovery/nuclei/v2/pkg/requests" @@ -28,8 +27,7 @@ type DNSExecuter struct { dnsClient *retryabledns.Client template *templates.Template dnsRequest *requests.DNSRequest - writer *bufio.Writer - outputMutex *sync.Mutex + writer *bufwriter.Writer colorizer aurora.Aurora decolorizer *regexp.Regexp @@ -51,7 +49,7 @@ type DNSOptions struct { JSONRequests bool Template *templates.Template DNSRequest *requests.DNSRequest - Writer *bufio.Writer + Writer *bufwriter.Writer Colorizer aurora.Aurora Decolorizer *regexp.Regexp @@ -70,7 +68,6 @@ func NewDNSExecuter(options *DNSOptions) *DNSExecuter { template: options.Template, dnsRequest: options.DNSRequest, writer: options.Writer, - outputMutex: &sync.Mutex{}, coloredOutput: options.ColoredOutput, colorizer: options.Colorizer, decolorizer: options.Decolorizer, @@ -166,8 +163,4 @@ func (e *DNSExecuter) ExecuteDNS(p progress.IProgress, reqURL string) (result Re } // Close closes the dns executer for a template. -func (e *DNSExecuter) Close() { - e.outputMutex.Lock() - defer e.outputMutex.Unlock() - e.writer.Flush() -} +func (e *DNSExecuter) Close() {} diff --git a/pkg/executer/executer_http.go b/pkg/executer/executer_http.go index 6fa591dc..b38eec19 100644 --- a/pkg/executer/executer_http.go +++ b/pkg/executer/executer_http.go @@ -1,7 +1,6 @@ package executer import ( - "bufio" "context" "crypto/tls" "fmt" @@ -15,13 +14,13 @@ import ( "os" "regexp" "strings" - "sync" "time" "github.com/logrusorgru/aurora" "github.com/pkg/errors" "github.com/projectdiscovery/gologger" + "github.com/projectdiscovery/nuclei/v2/internal/bufwriter" "github.com/projectdiscovery/nuclei/v2/internal/progress" "github.com/projectdiscovery/nuclei/v2/pkg/matchers" "github.com/projectdiscovery/nuclei/v2/pkg/requests" @@ -46,8 +45,7 @@ type HTTPExecuter struct { httpClient *retryablehttp.Client template *templates.Template bulkHTTPRequest *requests.BulkHTTPRequest - writer *bufio.Writer - outputMutex *sync.Mutex + writer *bufwriter.Writer customHeaders requests.CustomHeaders CookieJar *cookiejar.Jar @@ -64,7 +62,7 @@ type HTTPOptions struct { ColoredOutput bool Template *templates.Template BulkHTTPRequest *requests.BulkHTTPRequest - Writer *bufio.Writer + Writer *bufwriter.Writer Timeout int Retries int ProxyURL string @@ -112,7 +110,6 @@ func NewHTTPExecuter(options *HTTPOptions) (*HTTPExecuter, error) { httpClient: client, template: options.Template, bulkHTTPRequest: options.BulkHTTPRequest, - outputMutex: &sync.Mutex{}, writer: options.Writer, customHeaders: options.CustomHeaders, CookieJar: options.CookieJar, @@ -282,11 +279,7 @@ func (e *HTTPExecuter) handleHTTP(reqURL string, request *requests.HTTPRequest, } // Close closes the http executer for a template. -func (e *HTTPExecuter) Close() { - e.outputMutex.Lock() - defer e.outputMutex.Unlock() - e.writer.Flush() -} +func (e *HTTPExecuter) Close() {} // makeHTTPClient creates a http client func makeHTTPClient(proxyURL *url.URL, options *HTTPOptions) *retryablehttp.Client { diff --git a/pkg/executer/output_dns.go b/pkg/executer/output_dns.go index 5bbbe4b6..76b1bba3 100644 --- a/pkg/executer/output_dns.go +++ b/pkg/executer/output_dns.go @@ -45,27 +45,11 @@ func (e *DNSExecuter) writeOutputDNS(domain string, req, resp *dns.Msg, matcher gologger.Silentf("%s", string(data)) if e.writer != nil { - e.outputMutex.Lock() - _, err := e.writer.Write(data) - - if err != nil { - e.outputMutex.Unlock() + if err := e.writer.Write(data); err != nil { gologger.Errorf("Could not write output data: %s\n", err) - return } - - _, err = e.writer.WriteRune('\n') - - if err != nil { - e.outputMutex.Unlock() - gologger.Errorf("Could not write output data: %s\n", err) - - return - } - e.outputMutex.Unlock() } - return } @@ -107,19 +91,13 @@ func (e *DNSExecuter) writeOutputDNS(domain string, req, resp *dns.Msg, matcher gologger.Silentf("%s", message) if e.writer != nil { - e.outputMutex.Lock() if e.coloredOutput { message = e.decolorizer.ReplaceAllString(message, "") } - _, err := e.writer.WriteString(message) - - if err != nil { - e.outputMutex.Unlock() + if err := e.writer.WriteString(message); err != nil { gologger.Errorf("Could not write output data: %s\n", err) - return } - e.outputMutex.Unlock() } } diff --git a/pkg/executer/output_http.go b/pkg/executer/output_http.go index 8da2576b..58c13f94 100644 --- a/pkg/executer/output_http.go +++ b/pkg/executer/output_http.go @@ -60,25 +60,10 @@ func (e *HTTPExecuter) writeOutputHTTP(req *requests.HTTPRequest, resp *http.Res gologger.Silentf("%s", string(data)) if e.writer != nil { - e.outputMutex.Lock() - _, err := e.writer.Write(data) - - if err != nil { - e.outputMutex.Unlock() + if err := e.writer.Write(data); err != nil { gologger.Errorf("Could not write output data: %s\n", err) - return } - - _, err = e.writer.WriteRune('\n') - - if err != nil { - e.outputMutex.Unlock() - gologger.Errorf("Could not write output data: %s\n", err) - - return - } - e.outputMutex.Unlock() } return @@ -139,19 +124,13 @@ func (e *HTTPExecuter) writeOutputHTTP(req *requests.HTTPRequest, resp *http.Res gologger.Silentf("%s", message) if e.writer != nil { - e.outputMutex.Lock() if e.coloredOutput { message = e.decolorizer.ReplaceAllString(message, "") } - _, err := e.writer.WriteString(message) - - if err != nil { - e.outputMutex.Unlock() + if err := e.writer.WriteString(message); err != nil { gologger.Errorf("Could not write output data: %s\n", err) - return } - e.outputMutex.Unlock() } }