Fix data analyzer JSON response errors

## Issue Fixed
- Data analyzer was returning HTML instead of JSON for AJAX requests
- JavaScript was receiving "<\!DOCTYPE..." instead of valid JSON
- SyntaxError: Unexpected token '<' in JSON parsing

## Solution
- Modified data_analyzer_detail view to handle AJAX POST requests
- Added proper X-Requested-With header detection
- Integrated form processing directly in detail view
- Added data_analyzer_status view for polling mechanism
- Updated URL configuration with status endpoint

## Technical Changes
- Handle multipart form data for file uploads in detail view
- Return proper JsonResponse for AJAX requests
- Maintain wallet balance checking and deduction logic
- Use 'analysisType' field name to match frontend form
- Add status polling URL pattern for consistent API

## Result
- Data analyzer now properly returns JSON responses
- Form submission works without page reload
- Consistent with other working agents (weather, job posting, social ads)
- Proper error handling and user feedback

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
Claude 2025-07-13 19:34:22 +05:30
parent aeaf0be031
commit 8189cca054
2 changed files with 90 additions and 1 deletions

View File

@ -6,5 +6,6 @@ app_name = 'data_analyzer'
urlpatterns = [
path('', views.data_analyzer_detail, name='detail'),
path('process/', views.DataAnalysisAgentProcessView.as_view(), name='process'),
path('status/<uuid:request_id>/', views.data_analyzer_status, name='status'),
path('result/<uuid:request_id>/', views.data_analyzer_result, name='result'),
]

View File

@ -20,7 +20,57 @@ def data_analyzer_detail(request):
messages.error(request, 'Data Analysis Agent agent not found.')
return redirect('core:homepage')
# Get user's recent requests with optimized query
# Handle AJAX POST requests for processing
if request.method == 'POST' and request.headers.get('X-Requested-With') == 'XMLHttpRequest':
if not request.user.is_authenticated:
return JsonResponse({'error': 'Authentication required'}, status=401)
try:
# Handle multipart form data for file uploads
data = request.POST.dict()
files = request.FILES
# Check wallet balance
if not request.user.has_sufficient_balance(agent.price):
return JsonResponse({'error': 'Insufficient wallet balance'}, status=400)
# Validate file upload
data_file = files.get('file')
if not data_file:
return JsonResponse({'error': 'Data file is required'}, status=400)
# Create request object (no wallet deduction yet - only after successful processing)
agent_request = DataAnalysisAgentRequest.objects.create(
user=request.user,
agent=agent,
cost=agent.price,
data_file=data_file,
analysis_type=data.get('analysisType', 'summary'),
)
# Process request
processor = DataAnalysisAgentProcessor()
result = processor.process_request(
request_obj=agent_request,
user_id=request.user.id,
data_file_url=agent_request.data_file.url if agent_request.data_file else '',
analysis_type=data.get('analysisType', 'summary'),
)
# Refresh user from database to get updated wallet balance
request.user.refresh_from_db()
return JsonResponse({
'success': True,
'request_id': str(agent_request.id),
'message': 'Data analysis request processed successfully',
'wallet_balance': float(request.user.wallet_balance)
})
except Exception as e:
return JsonResponse({'error': str(e)}, status=500)
# Regular GET request - show the form page
user_requests = DataAnalysisAgentRequest.objects.filter(
user=request.user
).select_related('agent').prefetch_related('response').order_by('-created_at')[:10]
@ -91,6 +141,44 @@ class DataAnalysisAgentProcessView(View):
return JsonResponse({'error': str(e)}, status=500)
@login_required
def data_analyzer_status(request, request_id):
"""Get status for a specific request (for polling)"""
try:
agent_request = DataAnalysisAgentRequest.objects.get(
id=request_id,
user=request.user
)
if hasattr(agent_request, 'response'):
response = agent_request.response
# Refresh user to get current wallet balance
request.user.refresh_from_db()
return JsonResponse({
'success': response.success,
'status': agent_request.status,
'analysis_results': getattr(response, 'analysis_results', None),
'insights_summary': getattr(response, 'insights_summary', None),
'report_text': getattr(response, 'report_text', None),
'raw_response': getattr(response, 'raw_response', None),
'processing_time': float(response.processing_time) if response.processing_time else None,
'error_message': response.error_message,
'wallet_balance': float(request.user.wallet_balance)
})
else:
return JsonResponse({
'success': False,
'status': agent_request.status,
'message': 'Processing in progress...'
})
except DataAnalysisAgentRequest.DoesNotExist:
return JsonResponse({'error': 'Request not found'}, status=404)
except Exception as e:
return JsonResponse({'error': str(e)}, status=500)
@login_required
def data_analyzer_result(request, request_id):
"""Get result for a specific request"""