File size: 3,281 Bytes
6a7089a | 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 | // Package explicit implements the "explicit" strategy.
// All orchestrator endpoints are exposed directly — agents manage
// instances, profiles, and tabs explicitly. This reproduces the
// default dashboard behavior prior to the strategy framework.
package explicit
import (
"context"
"fmt"
"net/http"
"github.com/pinchtab/pinchtab/internal/orchestrator"
"github.com/pinchtab/pinchtab/internal/proxy"
"github.com/pinchtab/pinchtab/internal/strategy"
"github.com/pinchtab/pinchtab/internal/web"
)
func init() {
strategy.MustRegister("explicit", func() strategy.Strategy {
return &Strategy{}
})
}
// Strategy exposes all orchestrator endpoints directly.
type Strategy struct {
orch *orchestrator.Orchestrator
}
func (s *Strategy) Name() string { return "explicit" }
// SetOrchestrator injects the orchestrator after construction.
func (s *Strategy) SetOrchestrator(o *orchestrator.Orchestrator) {
s.orch = o
}
func (s *Strategy) Start(_ context.Context) error { return nil }
func (s *Strategy) Stop() error { return nil }
// RegisterRoutes adds all orchestrator routes plus shorthand proxy endpoints.
func (s *Strategy) RegisterRoutes(mux *http.ServeMux) {
s.orch.RegisterHandlers(mux)
// Shorthand endpoints proxy to first running instance.
shorthandRoutes := []string{
"GET /snapshot", "GET /screenshot", "GET /text", "GET /pdf", "POST /pdf",
"POST /navigate", "POST /back", "POST /forward", "POST /reload",
"POST /action", "POST /actions",
"POST /tab", "POST /tab/lock", "POST /tab/unlock",
"GET /cookies", "POST /cookies",
"GET /stealth/status", "POST /fingerprint/rotate",
"POST /find",
}
for _, route := range shorthandRoutes {
mux.HandleFunc(route, s.proxyToFirst)
}
strategy.RegisterCapabilityRoute(mux, "POST /evaluate", s.orch.AllowsEvaluate(), "evaluate", "security.allowEvaluate", "evaluate_disabled", s.proxyToFirst)
strategy.RegisterCapabilityRoute(mux, "GET /download", s.orch.AllowsDownload(), "download", "security.allowDownload", "download_disabled", s.proxyToFirst)
strategy.RegisterCapabilityRoute(mux, "POST /upload", s.orch.AllowsUpload(), "upload", "security.allowUpload", "upload_disabled", s.proxyToFirst)
strategy.RegisterCapabilityRoute(mux, "GET /screencast", s.orch.AllowsScreencast(), "screencast", "security.allowScreencast", "screencast_disabled", s.proxyToFirst)
strategy.RegisterCapabilityRoute(mux, "GET /screencast/tabs", s.orch.AllowsScreencast(), "screencast", "security.allowScreencast", "screencast_disabled", s.proxyToFirst)
strategy.RegisterCapabilityRoute(mux, "POST /macro", s.orch.AllowsMacro(), "macro", "security.allowMacro", "macro_disabled", s.proxyToFirst)
// /tabs returns empty list when no instances running.
mux.HandleFunc("GET /tabs", s.handleTabs)
}
func (s *Strategy) proxyToFirst(w http.ResponseWriter, r *http.Request) {
target := s.orch.FirstRunningURL()
if target == "" {
web.Error(w, 503, fmt.Errorf("no running instances — launch one from the Profiles tab"))
return
}
proxy.HTTP(w, r, target+r.URL.Path)
}
func (s *Strategy) handleTabs(w http.ResponseWriter, r *http.Request) {
target := s.orch.FirstRunningURL()
if target == "" {
web.JSON(w, 200, map[string]any{"tabs": []any{}})
return
}
proxy.HTTP(w, r, target+"/tabs")
}
|