(data io.Reader)
| 156 | } |
| 157 | |
| 158 | func (r *runner) ProcessResponse(data io.Reader) { |
| 159 | sources, err := extractor.ExtractSources(data) |
| 160 | if err != nil { |
| 161 | log.Println(fmt.Errorf("[error] extracting sources from response file: %w", err)) |
| 162 | } |
| 163 | |
| 164 | filtered, err := extractor.Filter(sources, r.filters(nil)...) |
| 165 | if err != nil { |
| 166 | log.Println(fmt.Errorf("[error] filtering sources from response file: %w", err)) |
| 167 | return |
| 168 | } |
| 169 | |
| 170 | for source := range filtered { |
| 171 | r.Results <- source |
| 172 | } |
| 173 | } |
| 174 | |
| 175 | func (r *runner) filters(base *url.URL) (options []func([]url.URL) []url.URL) { |
| 176 | if r.Options.Complete && base != nil { |
no test coverage detected