log_data needs to be cleared inside async function

Author: GGontijo

fastapi_elasticsearch_middleware/elasticsearch_middleware.py

@@ -74,6 +74,7 @@ async def intercept_send(response):
                         log_data["response"]["body"] = str(response.get('body')) if 'body' in response.keys() else None
 
                     self.log_to_elasticsearch(log_data)
+                    log_data.clear()
 
                 if response['type'] == 'http.response.start': # Request part
 
@@ -134,7 +135,6 @@ async def intercept_receive():
     def log_to_elasticsearch(self, log_data) -> None:
         try:
             self.elasticsearch_client.index(index=self.index, body=log_data)
-            log_data["response"] = {}
         except Exception as e:
             logging.error(f"Failed to log to Elasticsearch: {str(e)}")