߲jUdZddlmZddlZddlZddlZddlmZmZm Z ddl Z ddl m Z ddl mZejeZiZded<ej(Zd Zd Zd Zdd Zdd ZddZGddeZddlZddiZdZy)uEBrowser Use cloud browser provider — the only backend with dual auth: direct ``BROWSER_USE_API_KEY`` (https://browser-use.com) or the managed Nous tool gateway (bills to a Nous subscription). Direct first, managed second, unless ``tool_gateway.browser: gateway`` flips it. Config: ``browser.cloud_provider: "browser-use"``.) annotationsN)AnyDictOptional) get_secret)CloudBrowserProviderDict[str, str]_pending_create_keysz"https://api.browser-use.com/api/v3usct5tj|}|r |cdddSdtjj }|t|<|cdddS#1swYyxYw)Nzbrowser-use-session-create:)_pending_create_keys_lockr getuuiduuid4hex)task_idexistingcreateds I/home/ubuntu/.hermes/hermes-agent/plugins/browser/browser_use/provider.py!_get_or_create_pending_create_keyrsc "'++G4 0 0@0@/AB(/W% sA+AA(cft5tj|ddddy#1swYyxYw)N)rr pop)rs r_clear_pending_create_keyr(s* "0  $/000s'0cH|jdk\ry|jdk7ry |j}t|tr|j dnd}t|txr.dt |j dxsd jvS#t$rYywxYw) zKeep the key when retryable: any 5xx, or a 409 saying the original request is still in flight. Other 4xx (auth, bad request) won't succeed on retry, so the key is dropped.iTiFerrorNzalready in progressmessage) status_codejson Exception isinstancedictrstrlower)responsepayloadrs r#_should_preserve_pending_create_keyr(-ss"s"--/%/w$=GKK 4E eT " g'<EIIiDXD^\^@_@e@e@g'gg sB B! B!cZeZdZdZdZdZdZdZdZddZ dd dd Z dd Z dd Z dd Z ddZy)BrowserUseBrowserProviderz._managed_configOsJ2MDG]_G"22#2299#> $ r3BROWSER_USE_API_KEYbrowserFr<)returnOptional[Dict[str, Any]])tools.managed_tool_gatewayr5r6tools.tool_backend_helpersr7r8r _BASE_URL) r1r/r7r8rDr=selecteddirectr5r6s ` @@rr0z-BrowserUseBrowserProvider._get_config_or_noneJshcT 23!),$)US , ,"$ $  $6 .$ . v7o&77r3cddlm}m}m}m}|j }||S|d}||k(rt |d|d|t |d|d|r t dt d)Nr)r7managed_nous_tools_enabledr8selection_errorrFzDthe Nous Tool Gateway is not available (not entitled or unreachable)zBROWSER_USE_API_KEY is not setzsBrowser Use requires either a direct BROWSER_USE_API_KEY credential or a managed Browser Use gateway configuration.z=Browser Use requires a direct BROWSER_USE_API_KEY credential.)rJr7rOr8rPr0 ValueError)r1r7rOr8rPconfigrLs r _get_configz%BrowserUseBrowserProvider._get_configgs ` `))+  M!), , ,_0VXY Y  _YBbcd d % 'MN NXYYr3cd|ddS)Nzapplication/jsonr=)z Content-TypezX-Browser-Use-API-Keyr1rRs r_headersz"BrowserUseBrowserProvider._headers{s 2VT]M^__r3c ddiS)NactionstoprUrVs r _release_bodyz'BrowserUseBrowserProvider._release_body~s &!!r3c|j}t|jd}|j|}|rt ||d<|r t t dni}|j|dd||| }|js|rt|s t||j||j}|r t||j|}tjd|||d|jd xs|jd xsd |jd d di|r|j jddSddS)Nr?zX-Idempotency-Key)timeoutproxyCountryCoder>z /browsers) wrap_errorszCreated Browser Use session %sidcdpUrl connectUrlr timeoutAt browser_useTzx-external-call-id) session_name bb_session_idcdp_url expires_atfeaturesexternal_call_id)rSboolrrWr _DEFAULT_MANAGED_TIMEOUT_MINUTES#_DEFAULT_MANAGED_PROXY_COUNTRY_CODE _post_createokr(r_check_createdr _session_nameloggerinfoheaders) r1rrRr?rtr'r& session_datares rcreate_sessionz(BrowserUseBrowserProvider.create_sessionsb!!#FJJ~67 --' +LW+UG' (9Nq r!# $$j!") ,gwP\L\%^{{|4WX`4a %g . H%}}  %g .))'2  4lC()$/#''1Y\5E5El5SYWY&**;7&-NZ 0 0 4 45I J  ae  r3)rGrk)r/rkrGrH)rGDict[str, Any])rRrwrGr )rRrwrGDict[str, object])rr$rGrx)__name__ __module__ __qualname____doc__ provider_idlabelrelease_method release_path setup_tagr2r0rSrWr[rvrUr3rr*r*<sGFK EN+LII<@8:Z(`" r3r*BrowserProvider)zagent.browser_providerrctj|}|tdtd|ddl}ddlm}|t|g|t|j|d|dS)Nzmodule z has no attribute r) warn_once) _PLUGIN_COMPAT_LAZYrAttributeErrorry importlibhermes_cli.plugin_compatrgetattr import_module)nametargetrrs r __getattr__rse $ $T *F ~wxl2DTHMNN2 h&v& 9**6!95vay AAr3)rr$rGr$)rr$rGNone)r&zrequests.ResponserGrk) r| __future__rlogging threadingrtypingrrrrequestsagent.secret_scoperplugins.browser._commonr getLoggerryrrr __annotations__LockrrKrlrmrrr(r*osrrrUr3rrs: # &&)8   8 $(*n)*INN, 0 #$ &*#0 hd 4d V D Br3