Add Firecrawl web search tool for tracker mapping
Firecrawl provides higher quality search results than SearXNG. When configured (firecrawl-endpoint + firecrawl-api-key), the tracker-mapping agent and search toolset prefer it over the SearXNG backend. Also improves the tracker identification prompt with multi-strategy search queries that leverage domain signals and adapt to tracker type. Signed-off-by: Émile Ré <emile@probo.com>
This commit is contained in:
139
pkg/agent/tools/search/firecrawl.go
Normal file
139
pkg/agent/tools/search/firecrawl.go
Normal file
@@ -0,0 +1,139 @@
|
|||||||
|
// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
|
||||||
|
//
|
||||||
|
// Permission to use, copy, modify, and/or distribute this software for any
|
||||||
|
// purpose with or without fee is hereby granted, provided that the above
|
||||||
|
// copyright notice and this permission notice appear in all copies.
|
||||||
|
//
|
||||||
|
// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
|
||||||
|
// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
|
||||||
|
// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
|
||||||
|
// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
|
||||||
|
// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
|
||||||
|
// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
|
||||||
|
// PERFORMANCE OF THIS SOFTWARE.
|
||||||
|
|
||||||
|
package search
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bytes"
|
||||||
|
"context"
|
||||||
|
"encoding/json"
|
||||||
|
"fmt"
|
||||||
|
"io"
|
||||||
|
"net/http"
|
||||||
|
"net/url"
|
||||||
|
|
||||||
|
"go.gearno.de/kit/httpclient"
|
||||||
|
|
||||||
|
"go.probo.inc/probo/pkg/agent"
|
||||||
|
)
|
||||||
|
|
||||||
|
type (
|
||||||
|
firecrawlParams struct {
|
||||||
|
Query string `json:"query" jsonschema:"The search query to execute"`
|
||||||
|
MaxResults int `json:"max_results" jsonschema:"Maximum number of results to return (default 5, max 10)"`
|
||||||
|
}
|
||||||
|
|
||||||
|
firecrawlRequest struct {
|
||||||
|
Query string `json:"query"`
|
||||||
|
Limit int `json:"limit"`
|
||||||
|
}
|
||||||
|
|
||||||
|
firecrawlResponse struct {
|
||||||
|
Success bool `json:"success"`
|
||||||
|
Data struct {
|
||||||
|
Web []firecrawlWebResult `json:"web"`
|
||||||
|
} `json:"data"`
|
||||||
|
}
|
||||||
|
|
||||||
|
firecrawlWebResult struct {
|
||||||
|
Title string `json:"title"`
|
||||||
|
Description string `json:"description"`
|
||||||
|
URL string `json:"url"`
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
// FirecrawlSearchTool creates a tool that searches the web using the Firecrawl
|
||||||
|
// API. The endpoint should be the base URL of the Firecrawl instance (e.g.
|
||||||
|
// "https://api.firecrawl.dev/v2"). The apiKey is used for Bearer authentication.
|
||||||
|
func FirecrawlSearchTool(endpoint, apiKey string) agent.Tool {
|
||||||
|
client := httpclient.DefaultPooledClient()
|
||||||
|
|
||||||
|
return agent.FunctionTool(
|
||||||
|
"web_search",
|
||||||
|
"Search the web for information about a topic. Returns a list of results with title, URL, and snippet. Use this to find news, reviews, breach reports, regulatory actions, and other external information about a vendor.",
|
||||||
|
func(ctx context.Context, p firecrawlParams) (agent.ToolResult, error) {
|
||||||
|
maxResults := p.MaxResults
|
||||||
|
if maxResults <= 0 {
|
||||||
|
maxResults = 5
|
||||||
|
}
|
||||||
|
if maxResults > 10 {
|
||||||
|
maxResults = 10
|
||||||
|
}
|
||||||
|
|
||||||
|
results, err := firecrawlSearch(ctx, client, endpoint, apiKey, p.Query, maxResults)
|
||||||
|
if err != nil {
|
||||||
|
return agent.ResultErrorf("search request failed: %s", err), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
return agent.ResultJSON(results), nil
|
||||||
|
},
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
func firecrawlSearch(ctx context.Context, client *http.Client, endpoint, apiKey, query string, maxResults int) ([]searchResult, error) {
|
||||||
|
u, err := url.JoinPath(endpoint, "search")
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("cannot build search URL: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
body, err := json.Marshal(firecrawlRequest{
|
||||||
|
Query: query,
|
||||||
|
Limit: maxResults,
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("cannot marshal request: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
req, err := http.NewRequestWithContext(ctx, http.MethodPost, u, bytes.NewReader(body))
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
req.Header.Set("Content-Type", "application/json")
|
||||||
|
req.Header.Set("Authorization", "Bearer "+apiKey)
|
||||||
|
|
||||||
|
resp, err := client.Do(req)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
defer func() { _ = resp.Body.Close() }()
|
||||||
|
|
||||||
|
respBody, err := io.ReadAll(resp.Body)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
if resp.StatusCode != http.StatusOK {
|
||||||
|
return nil, fmt.Errorf("search returned status %d", resp.StatusCode)
|
||||||
|
}
|
||||||
|
|
||||||
|
var fcResp firecrawlResponse
|
||||||
|
if err := json.Unmarshal(respBody, &fcResp); err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
if !fcResp.Success {
|
||||||
|
return nil, fmt.Errorf("search returned success=false")
|
||||||
|
}
|
||||||
|
|
||||||
|
results := make([]searchResult, 0, len(fcResp.Data.Web))
|
||||||
|
for _, r := range fcResp.Data.Web {
|
||||||
|
results = append(results, searchResult{
|
||||||
|
Title: r.Title,
|
||||||
|
URL: r.URL,
|
||||||
|
Snippet: r.Description,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
return results, nil
|
||||||
|
}
|
||||||
@@ -21,7 +21,8 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/url"
|
"net/url"
|
||||||
"time"
|
|
||||||
|
"go.gearno.de/kit/httpclient"
|
||||||
|
|
||||||
"go.probo.inc/probo/pkg/agent"
|
"go.probo.inc/probo/pkg/agent"
|
||||||
)
|
)
|
||||||
@@ -49,7 +50,8 @@ type (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func CheckGovernmentDBTool(searchEndpoint string) agent.Tool {
|
func CheckGovernmentDBTool(searchEndpoint string) agent.Tool {
|
||||||
client := &http.Client{Timeout: 15 * time.Second}
|
client := httpclient.DefaultPooledClient()
|
||||||
|
client.Transport = &userAgentTransport{next: client.Transport}
|
||||||
|
|
||||||
return agent.FunctionTool(
|
return agent.FunctionTool(
|
||||||
"check_government_databases",
|
"check_government_databases",
|
||||||
|
|||||||
@@ -20,19 +20,52 @@ import (
|
|||||||
|
|
||||||
// Toolset provides web search tools.
|
// Toolset provides web search tools.
|
||||||
type Toolset struct {
|
type Toolset struct {
|
||||||
endpoint string
|
endpoint string
|
||||||
|
firecrawlEndpoint string
|
||||||
|
firecrawlAPIKey string
|
||||||
|
}
|
||||||
|
|
||||||
|
// Option configures a Toolset.
|
||||||
|
type Option func(*Toolset)
|
||||||
|
|
||||||
|
// WithFirecrawl configures the Firecrawl search backend. The endpoint
|
||||||
|
// should be the base URL of the Firecrawl instance (e.g.
|
||||||
|
// "https://api.firecrawl.dev/v2").
|
||||||
|
func WithFirecrawl(endpoint, apiKey string) Option {
|
||||||
|
return func(t *Toolset) {
|
||||||
|
t.firecrawlEndpoint = endpoint
|
||||||
|
t.firecrawlAPIKey = apiKey
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewToolset creates a search toolset with the given SearXNG endpoint.
|
// NewToolset creates a search toolset with the given SearXNG endpoint.
|
||||||
func NewToolset(endpoint string) *Toolset {
|
func NewToolset(endpoint string, opts ...Option) *Toolset {
|
||||||
return &Toolset{endpoint: endpoint}
|
t := &Toolset{endpoint: endpoint}
|
||||||
|
for _, opt := range opts {
|
||||||
|
opt(t)
|
||||||
|
}
|
||||||
|
return t
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *Toolset) Tools() []agent.Tool {
|
func (t *Toolset) Tools() []agent.Tool {
|
||||||
return []agent.Tool{
|
tools := []agent.Tool{
|
||||||
WebSearchTool(t.endpoint),
|
|
||||||
CheckGovernmentDBTool(t.endpoint),
|
|
||||||
CheckWaybackTool(),
|
CheckWaybackTool(),
|
||||||
DiffDocumentsTool(),
|
DiffDocumentsTool(),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if t.firecrawlEndpoint != "" && t.firecrawlAPIKey != "" {
|
||||||
|
tools = append(
|
||||||
|
tools,
|
||||||
|
FirecrawlSearchTool(t.firecrawlEndpoint, t.firecrawlAPIKey),
|
||||||
|
CheckGovernmentDBTool(t.endpoint),
|
||||||
|
)
|
||||||
|
} else if t.endpoint != "" {
|
||||||
|
tools = append(
|
||||||
|
tools,
|
||||||
|
WebSearchTool(t.endpoint),
|
||||||
|
CheckGovernmentDBTool(t.endpoint),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
return tools
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -17,7 +17,8 @@ package search
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
|
||||||
|
"go.gearno.de/kit/httpclient"
|
||||||
|
|
||||||
"go.probo.inc/probo/pkg/agent"
|
"go.probo.inc/probo/pkg/agent"
|
||||||
)
|
)
|
||||||
@@ -43,13 +44,24 @@ type (
|
|||||||
URL string `json:"url"`
|
URL string `json:"url"`
|
||||||
Content string `json:"content"`
|
Content string `json:"content"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
userAgentTransport struct {
|
||||||
|
next http.RoundTripper
|
||||||
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func (t *userAgentTransport) RoundTrip(r *http.Request) (*http.Response, error) {
|
||||||
|
r2 := r.Clone(r.Context())
|
||||||
|
r2.Header.Set("User-Agent", "Probo-Agent/1.0")
|
||||||
|
return t.next.RoundTrip(r2)
|
||||||
|
}
|
||||||
|
|
||||||
// WebSearchTool creates a tool that searches the web using a SearXNG instance.
|
// WebSearchTool creates a tool that searches the web using a SearXNG instance.
|
||||||
// The endpoint should be the base URL of the SearXNG instance (e.g.
|
// The endpoint should be the base URL of the SearXNG instance (e.g.
|
||||||
// "http://localhost:8888").
|
// "http://localhost:8888").
|
||||||
func WebSearchTool(endpoint string) agent.Tool {
|
func WebSearchTool(endpoint string) agent.Tool {
|
||||||
client := &http.Client{Timeout: 15 * time.Second}
|
client := httpclient.DefaultPooledClient()
|
||||||
|
client.Transport = &userAgentTransport{next: client.Transport}
|
||||||
|
|
||||||
return agent.FunctionTool(
|
return agent.FunctionTool(
|
||||||
"web_search",
|
"web_search",
|
||||||
|
|||||||
@@ -17,7 +17,12 @@ Return a structured JSON response with:
|
|||||||
|
|
||||||
2. If search_tracker_patterns returns results with a third party name, use the search_third_parties tool to confirm the exact name in the database and get its category.
|
2. If search_tracker_patterns returns results with a third party name, use the search_third_parties tool to confirm the exact name in the database and get its category.
|
||||||
|
|
||||||
3. Only use web_search as a last resort if the internal tools return nothing useful. Search for "what is cookie [name]" or "[name] cookie tracker".
|
3. Only use web_search as a last resort if the internal tools return nothing useful. Try up to 3 different queries, adapting your strategy based on the available signals:
|
||||||
|
- If the tracker has a recognizable prefix or name, start with: "[prefix] cookie tracking" (e.g. "_ce.s cookie tracking").
|
||||||
|
- If observed domains are available and the name is opaque, search by domain instead: "[domain] cookies tracking privacy" (e.g. "clarity.ms cookies tracking privacy").
|
||||||
|
- For localStorage keys, include the type: "[name] localStorage tracking script".
|
||||||
|
- If the first query returns nothing useful, broaden: "[name] web tracker" or "site:[domain] cookie documentation".
|
||||||
|
- Stop searching once you get a confident match; do not exhaust all query slots if the first one succeeds.
|
||||||
|
|
||||||
4. Common cookie naming conventions to recognize:
|
4. Common cookie naming conventions to recognize:
|
||||||
- _ga*, _gid, _gat*: Google Analytics
|
- _ga*, _gid, _gat*: Google Analytics
|
||||||
|
|||||||
@@ -51,9 +51,11 @@ type trackerMappingHandler struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type TrackerMappingConfig struct {
|
type TrackerMappingConfig struct {
|
||||||
LLMClient *llm.Client
|
LLMClient *llm.Client
|
||||||
Model string
|
Model string
|
||||||
SearchEndpoint string
|
SearchEndpoint string
|
||||||
|
FirecrawlEndpoint string
|
||||||
|
FirecrawlAPIKey string
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewTrackerMappingWorker(
|
func NewTrackerMappingWorker(
|
||||||
@@ -68,13 +70,7 @@ func NewTrackerMappingWorker(
|
|||||||
}
|
}
|
||||||
|
|
||||||
if cfg.LLMClient != nil {
|
if cfg.LLMClient != nil {
|
||||||
h.agent = buildTrackerMappingAgent(
|
h.agent = buildTrackerMappingAgent(cfg, pgClient, logger)
|
||||||
cfg.LLMClient,
|
|
||||||
cfg.Model,
|
|
||||||
cfg.SearchEndpoint,
|
|
||||||
pgClient,
|
|
||||||
logger,
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return worker.New(
|
return worker.New(
|
||||||
@@ -86,9 +82,7 @@ func NewTrackerMappingWorker(
|
|||||||
}
|
}
|
||||||
|
|
||||||
func buildTrackerMappingAgent(
|
func buildTrackerMappingAgent(
|
||||||
llmClient *llm.Client,
|
cfg TrackerMappingConfig,
|
||||||
model string,
|
|
||||||
searchEndpoint string,
|
|
||||||
pgClient *pg.Client,
|
pgClient *pg.Client,
|
||||||
logger *log.Logger,
|
logger *log.Logger,
|
||||||
) *agent.Agent {
|
) *agent.Agent {
|
||||||
@@ -97,8 +91,10 @@ func buildTrackerMappingAgent(
|
|||||||
searchThirdPartiesTool(pgClient),
|
searchThirdPartiesTool(pgClient),
|
||||||
}
|
}
|
||||||
|
|
||||||
if searchEndpoint != "" {
|
if cfg.FirecrawlEndpoint != "" && cfg.FirecrawlAPIKey != "" {
|
||||||
tools = append(tools, search.WebSearchTool(searchEndpoint))
|
tools = append(tools, search.FirecrawlSearchTool(cfg.FirecrawlEndpoint, cfg.FirecrawlAPIKey))
|
||||||
|
} else if cfg.SearchEndpoint != "" {
|
||||||
|
tools = append(tools, search.WebSearchTool(cfg.SearchEndpoint))
|
||||||
}
|
}
|
||||||
|
|
||||||
outputType, err := agent.NewOutputType[TrackerIdentification]("tracker_identification")
|
outputType, err := agent.NewOutputType[TrackerIdentification]("tracker_identification")
|
||||||
@@ -108,9 +104,9 @@ func buildTrackerMappingAgent(
|
|||||||
|
|
||||||
return agent.New(
|
return agent.New(
|
||||||
"tracker-mapping",
|
"tracker-mapping",
|
||||||
llmClient,
|
cfg.LLMClient,
|
||||||
agent.WithInstructions(trackerIdentificationPrompt),
|
agent.WithInstructions(trackerIdentificationPrompt),
|
||||||
agent.WithModel(model),
|
agent.WithModel(cfg.Model),
|
||||||
agent.WithTools(tools...),
|
agent.WithTools(tools...),
|
||||||
agent.WithOutputType(outputType),
|
agent.WithOutputType(outputType),
|
||||||
agent.WithMaxTurns(agentMaxTurns),
|
agent.WithMaxTurns(agentMaxTurns),
|
||||||
|
|||||||
@@ -45,8 +45,10 @@ func (impl *Implm) buildTrackerMappingConfig(
|
|||||||
}
|
}
|
||||||
|
|
||||||
return cookiebanner.TrackerMappingConfig{
|
return cookiebanner.TrackerMappingConfig{
|
||||||
LLMClient: llmClient,
|
LLMClient: llmClient,
|
||||||
Model: agentCfg.ModelName,
|
Model: agentCfg.ModelName,
|
||||||
SearchEndpoint: impl.cfg.SearchEndpoint,
|
SearchEndpoint: impl.cfg.SearchEndpoint,
|
||||||
|
FirecrawlEndpoint: impl.cfg.FirecrawlEndpoint,
|
||||||
|
FirecrawlAPIKey: impl.cfg.FirecrawlAPIKey,
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -62,6 +62,8 @@ type (
|
|||||||
EvidenceDescriber EvidenceDescriberConfig `json:"evidence-describer"`
|
EvidenceDescriber EvidenceDescriberConfig `json:"evidence-describer"`
|
||||||
ChromeDPAddr string `json:"chrome-dp-addr"`
|
ChromeDPAddr string `json:"chrome-dp-addr"`
|
||||||
SearchEndpoint string `json:"search-endpoint"`
|
SearchEndpoint string `json:"search-endpoint"`
|
||||||
|
FirecrawlEndpoint string `json:"firecrawl-endpoint"`
|
||||||
|
FirecrawlAPIKey string `json:"firecrawl-api-key"`
|
||||||
CustomDomains CustomDomainsConfig `json:"custom-domains"`
|
CustomDomains CustomDomainsConfig `json:"custom-domains"`
|
||||||
SCIMBridge SCIMBridgeConfig `json:"scim-bridge"`
|
SCIMBridge SCIMBridgeConfig `json:"scim-bridge"`
|
||||||
ESign ESignConfig `json:"esign"`
|
ESign ESignConfig `json:"esign"`
|
||||||
|
|||||||
Reference in New Issue
Block a user