yj  ddlmZddlmZmZddlmZddlmZm Z ddl m Z ddl m Z ddlmZddlmZeeZd ed ed e jd ee jfd Zd ed eeejfdZd ed eded dfdZdS)) getLogger)Selectselect) AsyncSession)modelsschemas)settings) get_workspace)ResourceNotFoundException)GetOrCreateResultdbworkspace_namewebhookreturncvKt||d{Vttjtjj|k}||d{V}|}|D]B}|j |j kr0ttj |dcSCt|tjjkr"t#dtjjdtj||j }|||d{Vt(d|j ttj |d S) a Get an existing webhook endpoint for a workspace or create it if missing. Args: db: Database session workspace_name: Name of the workspace webhook: Webhook endpoint creation schema Returns: GetOrCreateResult containing the webhook endpoint and whether it was created Raises: ResourceNotFoundException: If the workspace does not exist ValueError: If the workspace already has the maximum number of webhook endpoints rNF)createdz%Maximum number of webhook endpoints (z) reached for this workspace.)rurlzWebhook endpoint created: %sT)r rrWebhookEndpointwhererexecutescalarsallrr rmodel_validatelenr WEBHOOKMAX_WORKSPACE_LIMIT ValueErroraddcommitloggerdebug)r rrstmtresult endpointsendpointwebhook_endpoints 8/DATA/AppData/hermes/projects/honcho/src/crud/webhook.pyget_or_create_webhook_endpointr)s, > : : :::::::: &( ) ) / /-?  D::d## # # # # # #F  $$&&I <7; & &$'66x@@%    '  9~~)=== wH4D4X w w w   -% KFF  ))++ LL/=== ../?@@$   cKttjtjj|kS)z List all webhook endpoints, optionally filtered by workspace. Args: db: Database session workspace_name: Name of the workspace (optional) Returns: List of webhook endpoints )rrrrrrs r(list_webhook_endpointsr,Hs9 &( ) ) / /-?  r* endpoint_idNcKttjtjj|ktjj|k}||d{V}|}|std|d|| |d{V| d{Vt d|dS)z Delete a webhook endpoint. Args: db: Database session endpoint_id: ID of the webhook endpoint Raises: ResourceNotFoundException: If the webhook endpoint is not found NzWebhook endpoint z not found for workspace zWebhook endpoint %s deleted) rrrridrrscalar_one_or_noner deleter r!r")r rr-r#r$r&s r(delete_webhook_endpointr2Zs &( ) ) / /![0-?  D::d## # # # # # #F((**H  ' V V Vn V V    ))H   ))++ LL. <<<<r@sc%%%%%%%%//////,,,,,,444444------ 8  666 *6w./ 6666r E&( )*$==&)=8;= ======r*