Update app.py

app.py

@@ -18,6 +18,42 @@ for webhook in client.webhooks:
     print(f"Deleting webhook: {webhook.url}")
     webhook.delete()
 
+@webhook_listener(events="response.created")
+async def update_validation_space_on_answer(event):
+    """
+    Webhook listener that triggers when a new response is added to an answering space.
+    It will automatically update the corresponding validation space with the new response.
+    
+    Args:
+        event: The webhook event containing the user response data
+    """
+    response = event.response
+    
+    record = response.record
+    
+    dataset_name = record.dataset.name
+    if not dataset_name.endswith("_responder_preguntas"):
+        return  # Not an answering space, ignore
+    
+    # Extract the country from the dataset name
+    country = dataset_name.replace("_responder_preguntas", "")
+    
+    validation_dataset_name = f"{country}_validar_respuestas"
+    try:
+        validation_dataset = client.datasets(validation_dataset_name)
+    except Exception as e:
+        print(f"Error connecting to validation dataset: {e}")
+        validation_dataset = create_validation_space(country)
+    
+    validation_record = {
+        "question": record.fields["question"],
+        "answer": response.value,
+    }
+    
+    validation_dataset.records.log(records=[validation_record])
+    
+    print(f"Added new response to validation space for {country}")
+
 
 # Create a webhook for record events
 @rg.webhook_listener(events=["record.deleted", "record.completed"])