Method queryURL

sources/agent/driftnet/driftnet.go:217–232

(ctx context.Context, session *sources.Session, URL string, driftnetRequest *DriftnetRequest)

}

func (agent *Agent) queryURL(ctx context.Context, session *sources.Session, URL string, driftnetRequest *DriftnetRequest) (*http.Response, error) {
	apiURL := fmt.Sprintf(URL, url.QueryEscape(driftnetRequest.From), processQuery(driftnetRequest.Query))

	if driftnetRequest.Page > 0 {
		pageStr := strconv.Itoa(driftnetRequest.Page)
		apiURL = apiURL + "&page=" + pageStr
	}

	request, err := sources.NewHTTPRequest(ctx, http.MethodGet, apiURL, nil)
	if err != nil {
		return nil, err
	}
	request.Header.Set("Accept", "application/json")
	request.Header.Set("Authorization", `Bearer `+session.Keys.DriftnetToken)
	return session.Do(request, agent.Name())
}

func processQuery(input string) string {
	if iputil.IsIP(input) || iputil.IsCIDR(input) {