[crashtracking] Add errorsintake proxy endpoint (#252)

* Add errorsintake proxy endpoint

* release note

* Add to exclusion? list

* Update releasenotes/notes/add-errors-intake-proxy-endpoint-7e0f31d72a130f1a.yaml

Co-authored-by: Brett Langdon <[email protected]>

---------

Co-authored-by: Brett Langdon <[email protected]>

Author: 2 people

ddapm_test_agent/agent.py

@@ -330,6 +330,7 @@ def __init__(self) -> None:
             "/evp_proxy/v2/api/v2/llmobs",
             "/evp_proxy/v2/api/intake/llm-obs/v1/eval-metric",
             "/evp_proxy/v2/api/intake/llm-obs/v2/eval-metric",
+            "/evp_proxy/v4/api/v2/errorsintake",
         ]
 
         # Note that sessions are not cleared at any point since we don't know
@@ -802,6 +803,9 @@ async def handle_evp_proxy_v2_api_v2_llmobs(self, request: Request) -> web.Respo
     async def handle_evp_proxy_v2_llmobs_eval_metric(self, request: Request) -> web.Response:
         return web.HTTPOk()
 
+    async def handle_evp_proxy_v4_api_v2_errorsintake(self, request: Request) -> web.Response:
+        return web.HTTPOk()
+
     async def handle_put_tested_integrations(self, request: Request) -> web.Response:
         # we need to store the request manually since this is not a real DD agent endpoint
         await self._store_request(request)
@@ -879,6 +883,7 @@ async def handle_info(self, request: Request) -> web.Response:
                     "/v0.7/config",
                     "/tracer_flare/v1",
                     "/evp_proxy/v2/",
+                    "/evp_proxy/v4/",
                 ],
                 "feature_flags": [],
                 "config": {},
@@ -1125,6 +1130,7 @@ async def handle_session_requests(self, request: Request) -> web.Response:
                 self.handle_v1_tracer_flare,
                 self.handle_evp_proxy_v2_api_v2_llmobs,
                 self.handle_evp_proxy_v2_llmobs_eval_metric,
+                self.handle_evp_proxy_v4_api_v2_errorsintake,
                 self.handle_v1_logs,
                 self.handle_v1_metrics,
             ):
@@ -1418,6 +1424,7 @@ def _process_named_pipe_request(self, data: bytes, app: web.Application) -> byte
                 "/evp_proxy/v2/api/v2/llmobs": self.handle_evp_proxy_v2_api_v2_llmobs,
                 "/evp_proxy/v2/api/intake/llm-obs/v1/eval-metric": self.handle_evp_proxy_v2_llmobs_eval_metric,
                 "/evp_proxy/v2/api/intake/llm-obs/v2/eval-metric": self.handle_evp_proxy_v2_llmobs_eval_metric,
+                "/evp_proxy/v4/api/v2/errorsintake": self.handle_evp_proxy_v4_api_v2_errorsintake,
                 "/info": self.handle_info,
                 # Test endpoints
                 "/test/session/start": self.handle_session_start,
@@ -1628,6 +1635,7 @@ def make_app(
             web.post("/evp_proxy/v2/api/v2/llmobs", agent.handle_evp_proxy_v2_api_v2_llmobs),
             web.post("/evp_proxy/v2/api/intake/llm-obs/v1/eval-metric", agent.handle_evp_proxy_v2_llmobs_eval_metric),
             web.post("/evp_proxy/v2/api/intake/llm-obs/v2/eval-metric", agent.handle_evp_proxy_v2_llmobs_eval_metric),
+            web.post("/evp_proxy/v4/api/v2/errorsintake", agent.handle_evp_proxy_v4_api_v2_errorsintake),
             web.get("/info", agent.handle_info),
             web.get("/test/session/start", agent.handle_session_start),
             web.get("/test/session/clear", agent.handle_session_clear),

releasenotes/notes/add-errors-intake-proxy-endpoint-7e0f31d72a130f1a.yaml

@@ -0,0 +1,4 @@
+---
+features:
+  - |
+    Add support for ``/evp_proxy/v4/api/v2/errorsintake`` endpoint to collect errors intake payload requests.

tests/test_agent.py

@@ -105,6 +105,7 @@ async def test_info(agent):
             "/v0.7/config",
             "/tracer_flare/v1",
             "/evp_proxy/v2/",
+            "/evp_proxy/v4/",
         ],
         "peer_tags": [
             "db.name",
@@ -514,6 +515,16 @@ async def test_post_unknown_settings(
     assert "dummy_setting" not in agent.app
 
 
+async def test_evp_proxy_v4_api_v2_errorsintake(agent):
+    resp = await agent.post("/evp_proxy/v4/api/v2/errorsintake", data='{"key": "value"}')
+    assert resp.status == 200, await resp.text()
+
+    resp = await agent.get("/test/session/requests")
+    assert resp.status == 200
+    reqs = await resp.json()
+    assert len(reqs) == 1
+
+
 async def test_evp_proxy_v2_api_v2_llmobs(agent):
     resp = await agent.post("/evp_proxy/v2/api/v2/llmobs", data='{"key": "value"}')
     assert resp.status == 200, await resp.text()