+
-{% endblock %}
\ No newline at end of file
+{% endblock %}
diff --git a/eveai_chat_client/views/chat_views.py b/eveai_chat_client/views/chat_views.py
index dd4fb90..96cf118 100644
--- a/eveai_chat_client/views/chat_views.py
+++ b/eveai_chat_client/views/chat_views.py
@@ -1,3 +1,4 @@
+import json
import uuid
from flask import Blueprint, render_template, request, session, current_app, jsonify, Response, stream_with_context
from sqlalchemy.exc import SQLAlchemyError
@@ -6,9 +7,12 @@ from common.extensions import db
from common.models.user import Tenant, SpecialistMagicLinkTenant, TenantMake
from common.models.interaction import SpecialistMagicLink, Specialist, ChatSession, Interaction
from common.services.interaction.specialist_services import SpecialistServices
+from common.utils.business_event import BusinessEvent
+from common.utils.business_event_context import current_event
from common.utils.database import Database
from common.utils.chat_utils import get_default_chat_customisation
from common.utils.execution_progress import ExecutionProgressTracker
+from common.extensions import cache_manager
chat_bp = Blueprint('chat_bp', __name__, url_prefix='/chat')
@@ -103,13 +107,20 @@ def chat(magic_link_code):
"auto_scroll": True
}
+ specialist_config = specialist.configuration
+ if isinstance(specialist_config, str):
+ specialist_config = json.loads(specialist_config)
+
+ welcome_message = specialist_config.get('welcome_message', 'Hello! How can I help you today?')
+
return render_template('chat.html',
tenant=tenant,
tenant_make=tenant_make,
specialist=specialist,
customisation=customisation,
- messages=[customisation['welcome_message']],
- settings=settings
+ messages=[welcome_message],
+ settings=settings,
+ config=current_app.config
)
except Exception as e:
@@ -149,6 +160,11 @@ def send_message():
if form_values:
specialist_args['form_values'] = form_values
+ # Add language to specialist arguments if present
+ user_language = data.get('language')
+ if user_language:
+ specialist_args['language'] = user_language
+
current_app.logger.debug(f"Sending message to specialist: {specialist_id} for tenant {tenant_id}\n"
f" with args: {specialist_args}\n"
f"with session ID: {chat_session_id}")
@@ -255,3 +271,78 @@ def task_progress_stream(task_id):
current_app.logger.error(f"Failed to start progress stream: {str(e)}")
return jsonify({'error': str(e)}), 500
+@chat_bp.route('/api/translate', methods=['POST'])
+def translate():
+ """
+ API endpoint om tekst te vertalen naar een doeltaal
+
+ Parameters (JSON):
+ - text: de tekst die moet worden vertaald
+ - target_lang: de ISO 639-1 taalcode waarnaar moet worden vertaald
+ - source_lang: (optioneel) de ISO 639-1 taalcode van de brontaal
+ - context: (optioneel) context voor de vertaling
+
+ Returns:
+ JSON met vertaalde tekst
+ """
+ try:
+ tenant_id = session.get('tenant', {}).get('id')
+ with BusinessEvent('Client Translation Service', tenant_id):
+ with current_event.create_span('Front-End Translation'):
+ data = request.json
+
+ # Valideer vereiste parameters
+ if not data or 'text' not in data or 'target_lang' not in data:
+ return jsonify({
+ 'success': False,
+ 'error': 'Required parameters missing: text and/or target_lang'
+ }), 400
+
+ text = data.get('text')
+ target_lang = data.get('target_lang')
+ source_lang = data.get('source_lang')
+ context = data.get('context')
+
+ # Controleer of tekst niet leeg is
+ if not text.strip():
+ return jsonify({
+ 'success': False,
+ 'error': 'Text to translate cannot be empty'
+ }), 400
+
+ # Haal tenant_id uit sessie
+ tenant_id = session.get('tenant', {}).get('id')
+ if not tenant_id:
+ current_app.logger.error("No tenant ID found in session")
+ # Fallback naar huidige app tenant_id
+ tenant_id = getattr(current_app, 'tenant_id', None)
+
+ # Haal vertaling op (uit cache of genereer nieuw)
+ translation = cache_manager.translation_cache.get_translation(
+ text=text,
+ target_lang=target_lang,
+ source_lang=source_lang,
+ context=context
+ )
+
+ if not translation:
+ return jsonify({
+ 'success': False,
+ 'error': 'No translation found in cache. Please try again later.'
+ }), 500
+
+ # Retourneer het resultaat
+ return jsonify({
+ 'success': True,
+ 'translated_text': translation.translated_text,
+ 'source_language': translation.source_language,
+ 'target_language': translation.target_language
+ })
+
+ except Exception as e:
+ current_app.logger.error(f"Error translating: {str(e)}", exc_info=True)
+ return jsonify({
+ 'success': False,
+ 'error': f"Error translating: {str(e)}"
+ }), 500
+
diff --git a/eveai_chat_workers/__init__.py b/eveai_chat_workers/__init__.py
index 5cfb2b4..21f563a 100644
--- a/eveai_chat_workers/__init__.py
+++ b/eveai_chat_workers/__init__.py
@@ -52,6 +52,8 @@ def register_cache_handlers(app):
register_specialist_cache_handlers(cache_manager)
from eveai_chat_workers.chat_session_cache import register_chat_session_cache_handlers
register_chat_session_cache_handlers(cache_manager)
+ from common.utils.cache.translation_cache import register_translation_cache_handlers
+ register_translation_cache_handlers(cache_manager)
app, celery = create_app()
diff --git a/eveai_chat_workers/specialists/traicie/TRAICIE_SELECTION_SPECIALIST/1_3.py b/eveai_chat_workers/specialists/traicie/TRAICIE_SELECTION_SPECIALIST/1_3.py
index f3a5486..d231145 100644
--- a/eveai_chat_workers/specialists/traicie/TRAICIE_SELECTION_SPECIALIST/1_3.py
+++ b/eveai_chat_workers/specialists/traicie/TRAICIE_SELECTION_SPECIALIST/1_3.py
@@ -12,6 +12,7 @@ from sqlalchemy.exc import SQLAlchemyError
from common.extensions import db
from common.models.user import Tenant
from common.models.interaction import Specialist
+from common.services.utils.translation_services import TranslationServices
from eveai_chat_workers.outputs.globals.basic_types.list_item import ListItem
from eveai_chat_workers.outputs.traicie.knockout_questions.knockout_questions_v1_0 import KOQuestions, KOQuestion
from eveai_chat_workers.specialists.crewai_base_specialist import CrewAIBaseSpecialistExecutor
@@ -177,8 +178,15 @@ class SpecialistExecutor(CrewAIBaseSpecialistExecutor):
"fields": fields,
}
+ answer = f"Let's start our selection process by asking you a few important questions."
+
+ if arguments.language != 'en':
+ TranslationServices.translate_config(ko_form, "fields", arguments.language)
+ TranslationServices.translate(answer, arguments.language)
+
+
results = SpecialistResult.create_for_type(self.type, self.type_version,
- answer=f"We starten met een aantal KO Criteria vragen",
+ answer=answer,
form_request=ko_form,
phase="ko_question_evaluation")
@@ -208,15 +216,27 @@ class SpecialistExecutor(CrewAIBaseSpecialistExecutor):
break
if evaluation == "negative":
+ answer = (f"We hebben de antwoorden op onze eerste vragen verwerkt. Je voldoet jammer genoeg niet aan de "
+ f"minimale vereisten voor deze job.")
+ if arguments.language != 'nl':
+ answer = TranslationServices.translate(answer, arguments.language)
+
results = SpecialistResult.create_for_type(self.type, self.type_version,
- answer=f"We hebben de antwoorden op de KO criteria verwerkt. Je voldoet jammer genoeg niet aan de minimale vereisten voor deze job.",
+ answer=answer,
form_request=None,
phase="no_valid_candidate")
else:
+ answer = (f"We hebben de antwoorden op de KO criteria verwerkt. Je bent een geschikte kandidaat. "
+ f"Ben je bereid je contactgegevens door te geven, zodat we je kunnen contacteren voor een verder "
+ f"gesprek?")
# Check if answers to questions are positive
contact_form = cache_manager.specialist_forms_config_cache.get_config("PERSONAL_CONTACT_FORM", "1.0")
+ if arguments.language != 'nl':
+ answer = TranslationServices.translate(answer, arguments.language)
+ if arguments.language != 'en':
+ contact_form = TranslationServices.translate_config(contact_form, "fields", arguments.language)
results = SpecialistResult.create_for_type(self.type, self.type_version,
- answer=f"We hebben de antwoorden op de KO criteria verwerkt. Je bent een geschikte kandidaat. Kan je je contactegevens doorgeven?",
+ answer=answer,
form_request=contact_form,
phase="personal_contact_data")
diff --git a/migrations/public/versions/057fb975f0e3_remove_not_null_constraint_from_source_.py b/migrations/public/versions/057fb975f0e3_remove_not_null_constraint_from_source_.py
new file mode 100644
index 0000000..b78ed79
--- /dev/null
+++ b/migrations/public/versions/057fb975f0e3_remove_not_null_constraint_from_source_.py
@@ -0,0 +1,36 @@
+"""Remove not null constraint from source language in TranslationCache
+
+Revision ID: 057fb975f0e3
+Revises: bb67d16f428a
+Create Date: 2025-06-27 13:09:28.171399
+
+"""
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision = '057fb975f0e3'
+down_revision = 'bb67d16f428a'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+ # ### commands auto generated by Alembic - please adjust! ###
+ with op.batch_alter_table('translation_cache', schema=None) as batch_op:
+ batch_op.alter_column('source_language',
+ existing_type=sa.VARCHAR(length=2),
+ nullable=True)
+
+ # ### end Alembic commands ###
+
+
+def downgrade():
+ # ### commands auto generated by Alembic - please adjust! ###
+ with op.batch_alter_table('translation_cache', schema=None) as batch_op:
+ batch_op.alter_column('source_language',
+ existing_type=sa.VARCHAR(length=2),
+ nullable=False)
+
+ # ### end Alembic commands ###
diff --git a/migrations/public/versions/bb67d16f428a_move_default_language_to_tenant_make.py b/migrations/public/versions/bb67d16f428a_move_default_language_to_tenant_make.py
new file mode 100644
index 0000000..e57d32b
--- /dev/null
+++ b/migrations/public/versions/bb67d16f428a_move_default_language_to_tenant_make.py
@@ -0,0 +1,40 @@
+"""Move default language to Tenant Make
+
+Revision ID: bb67d16f428a
+Revises: e47dc002b678
+Create Date: 2025-06-27 06:38:35.092499
+
+"""
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision = 'bb67d16f428a'
+down_revision = 'e47dc002b678'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+ # ### commands auto generated by Alembic - please adjust! ###
+ with op.batch_alter_table('tenant', schema=None) as batch_op:
+ batch_op.drop_column('allowed_languages')
+ batch_op.drop_column('default_language')
+
+ with op.batch_alter_table('tenant_make', schema=None) as batch_op:
+ batch_op.add_column(sa.Column('default_language', sa.String(length=2), nullable=True))
+
+ # ### end Alembic commands ###
+
+
+def downgrade():
+ # ### commands auto generated by Alembic - please adjust! ###
+ with op.batch_alter_table('tenant_make', schema=None) as batch_op:
+ batch_op.drop_column('default_language')
+
+ with op.batch_alter_table('tenant', schema=None) as batch_op:
+ batch_op.add_column(sa.Column('default_language', sa.VARCHAR(length=2), autoincrement=False, nullable=True))
+ batch_op.add_column(sa.Column('allowed_languages', postgresql.ARRAY(sa.VARCHAR(length=2)), autoincrement=False, nullable=True))
+
+ # ### end Alembic commands ###