test mv
This commit is contained in:
182
system_test.py
182
system_test.py
@@ -1,182 +0,0 @@
|
|||||||
#!/usr/bin/env python3
|
|
||||||
"""
|
|
||||||
Simple test script to verify the women's safety app is working correctly.
|
|
||||||
"""
|
|
||||||
|
|
||||||
import asyncio
|
|
||||||
import asyncpg
|
|
||||||
import sys
|
|
||||||
from pathlib import Path
|
|
||||||
|
|
||||||
# Add project root to path
|
|
||||||
sys.path.insert(0, str(Path(__file__).parent))
|
|
||||||
|
|
||||||
from shared.config import settings
|
|
||||||
from shared.database import engine, AsyncSessionLocal
|
|
||||||
from services.user_service.models import User
|
|
||||||
from services.user_service.schemas import UserCreate
|
|
||||||
from shared.auth import get_password_hash
|
|
||||||
from sqlalchemy import text
|
|
||||||
|
|
||||||
|
|
||||||
async def test_database_connection():
|
|
||||||
"""Test basic database connectivity."""
|
|
||||||
print("🔍 Testing database connection...")
|
|
||||||
try:
|
|
||||||
# Test direct asyncpg connection
|
|
||||||
conn = await asyncpg.connect(settings.DATABASE_URL.replace('+asyncpg', ''))
|
|
||||||
await conn.execute('SELECT 1')
|
|
||||||
await conn.close()
|
|
||||||
print("✅ Direct asyncpg connection successful")
|
|
||||||
|
|
||||||
# Test SQLAlchemy engine connection
|
|
||||||
async with engine.begin() as conn:
|
|
||||||
result = await conn.execute(text('SELECT version()'))
|
|
||||||
version = result.scalar()
|
|
||||||
print(f"✅ SQLAlchemy connection successful (PostgreSQL {version[:20]}...)")
|
|
||||||
|
|
||||||
return True
|
|
||||||
except Exception as e:
|
|
||||||
print(f"❌ Database connection failed: {e}")
|
|
||||||
return False
|
|
||||||
|
|
||||||
|
|
||||||
async def test_database_tables():
|
|
||||||
"""Test database table structure."""
|
|
||||||
print("🔍 Testing database tables...")
|
|
||||||
try:
|
|
||||||
async with AsyncSessionLocal() as session:
|
|
||||||
# Test that we can query the users table
|
|
||||||
result = await session.execute(text("SELECT COUNT(*) FROM users"))
|
|
||||||
count = result.scalar()
|
|
||||||
print(f"✅ Users table exists with {count} users")
|
|
||||||
|
|
||||||
# Test table structure
|
|
||||||
result = await session.execute(text("""
|
|
||||||
SELECT column_name, data_type
|
|
||||||
FROM information_schema.columns
|
|
||||||
WHERE table_name = 'users'
|
|
||||||
ORDER BY ordinal_position
|
|
||||||
LIMIT 5
|
|
||||||
"""))
|
|
||||||
columns = result.fetchall()
|
|
||||||
print(f"✅ Users table has columns: {[col[0] for col in columns]}")
|
|
||||||
|
|
||||||
return True
|
|
||||||
except Exception as e:
|
|
||||||
print(f"❌ Database table test failed: {e}")
|
|
||||||
return False
|
|
||||||
|
|
||||||
|
|
||||||
async def test_user_creation():
|
|
||||||
"""Test creating a user in the database."""
|
|
||||||
print("🔍 Testing user creation...")
|
|
||||||
try:
|
|
||||||
async with AsyncSessionLocal() as session:
|
|
||||||
# Create test user
|
|
||||||
test_email = "test_debug@example.com"
|
|
||||||
|
|
||||||
# Delete if exists
|
|
||||||
await session.execute(text("DELETE FROM users WHERE email = :email"),
|
|
||||||
{"email": test_email})
|
|
||||||
await session.commit()
|
|
||||||
|
|
||||||
# Create new user
|
|
||||||
user = User(
|
|
||||||
email=test_email,
|
|
||||||
phone="+1234567890",
|
|
||||||
password_hash=get_password_hash("testpass"),
|
|
||||||
first_name="Test",
|
|
||||||
last_name="User"
|
|
||||||
)
|
|
||||||
session.add(user)
|
|
||||||
await session.commit()
|
|
||||||
|
|
||||||
# Verify creation
|
|
||||||
result = await session.execute(text("SELECT id, email FROM users WHERE email = :email"),
|
|
||||||
{"email": test_email})
|
|
||||||
user_row = result.fetchone()
|
|
||||||
|
|
||||||
if user_row:
|
|
||||||
print(f"✅ User created successfully: ID={user_row[0]}, Email={user_row[1]}")
|
|
||||||
return True
|
|
||||||
else:
|
|
||||||
print("❌ User creation failed - user not found after creation")
|
|
||||||
return False
|
|
||||||
|
|
||||||
except Exception as e:
|
|
||||||
print(f"❌ User creation test failed: {e}")
|
|
||||||
return False
|
|
||||||
|
|
||||||
|
|
||||||
async def test_auth_functions():
|
|
||||||
"""Test authentication functions."""
|
|
||||||
print("🔍 Testing authentication functions...")
|
|
||||||
try:
|
|
||||||
from shared.auth import get_password_hash, verify_password, create_access_token, verify_token
|
|
||||||
|
|
||||||
# Test password hashing
|
|
||||||
password = "testpassword123"
|
|
||||||
hashed = get_password_hash(password)
|
|
||||||
print(f"✅ Password hashing works")
|
|
||||||
|
|
||||||
# Test password verification
|
|
||||||
if verify_password(password, hashed):
|
|
||||||
print("✅ Password verification works")
|
|
||||||
else:
|
|
||||||
print("❌ Password verification failed")
|
|
||||||
return False
|
|
||||||
|
|
||||||
# Test token creation and verification
|
|
||||||
token_data = {"sub": "123", "email": "test@example.com"}
|
|
||||||
token = create_access_token(token_data)
|
|
||||||
verified_data = verify_token(token)
|
|
||||||
|
|
||||||
if verified_data and verified_data["user_id"] == 123:
|
|
||||||
print("✅ Token creation and verification works")
|
|
||||||
else:
|
|
||||||
print("❌ Token verification failed")
|
|
||||||
return False
|
|
||||||
|
|
||||||
return True
|
|
||||||
|
|
||||||
except Exception as e:
|
|
||||||
print(f"❌ Authentication test failed: {e}")
|
|
||||||
return False
|
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
|
||||||
"""Run all tests."""
|
|
||||||
print("🚀 Starting Women's Safety App System Tests")
|
|
||||||
print(f"Database URL: {settings.DATABASE_URL}")
|
|
||||||
print("=" * 60)
|
|
||||||
|
|
||||||
tests = [
|
|
||||||
test_database_connection,
|
|
||||||
test_database_tables,
|
|
||||||
test_user_creation,
|
|
||||||
test_auth_functions,
|
|
||||||
]
|
|
||||||
|
|
||||||
results = []
|
|
||||||
for test in tests:
|
|
||||||
try:
|
|
||||||
result = await test()
|
|
||||||
results.append(result)
|
|
||||||
except Exception as e:
|
|
||||||
print(f"❌ Test {test.__name__} failed with exception: {e}")
|
|
||||||
results.append(False)
|
|
||||||
print()
|
|
||||||
|
|
||||||
print("=" * 60)
|
|
||||||
if all(results):
|
|
||||||
print("🎉 All tests passed! The system is ready for use.")
|
|
||||||
return 0
|
|
||||||
else:
|
|
||||||
failed = len([r for r in results if not r])
|
|
||||||
print(f"❌ {failed}/{len(results)} tests failed. Please check the errors above.")
|
|
||||||
return 1
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
sys.exit(asyncio.run(main()))
|
|
||||||
326
test_api.py
326
test_api.py
@@ -1,326 +0,0 @@
|
|||||||
#!/usr/bin/env python3
|
|
||||||
"""
|
|
||||||
API Test Script for Women's Safety App
|
|
||||||
Run this script to test all major API endpoints
|
|
||||||
"""
|
|
||||||
|
|
||||||
import asyncio
|
|
||||||
import httpx
|
|
||||||
import json
|
|
||||||
from typing import Dict, Any
|
|
||||||
|
|
||||||
BASE_URL = "http://localhost:8000"
|
|
||||||
|
|
||||||
|
|
||||||
class APITester:
|
|
||||||
def __init__(self, base_url: str = BASE_URL):
|
|
||||||
self.base_url = base_url
|
|
||||||
self.token = None
|
|
||||||
self.user_id = None
|
|
||||||
|
|
||||||
async def test_registration(self) -> Dict[str, Any]:
|
|
||||||
"""Test user registration"""
|
|
||||||
print("🔐 Testing user registration...")
|
|
||||||
|
|
||||||
user_data = {
|
|
||||||
"email": "test@example.com",
|
|
||||||
"password": "testpassword123",
|
|
||||||
"first_name": "Test",
|
|
||||||
"last_name": "User",
|
|
||||||
"phone": "+1234567890"
|
|
||||||
}
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
response = await client.post(f"{self.base_url}/api/v1/register", json=user_data)
|
|
||||||
|
|
||||||
if response.status_code == 200:
|
|
||||||
data = response.json()
|
|
||||||
self.user_id = data["id"]
|
|
||||||
print(f"✅ Registration successful! User ID: {self.user_id}")
|
|
||||||
return data
|
|
||||||
else:
|
|
||||||
print(f"❌ Registration failed: {response.status_code} - {response.text}")
|
|
||||||
return {}
|
|
||||||
|
|
||||||
async def test_login(self) -> str:
|
|
||||||
"""Test user login and get token"""
|
|
||||||
print("🔑 Testing user login...")
|
|
||||||
|
|
||||||
login_data = {
|
|
||||||
"email": "test@example.com",
|
|
||||||
"password": "testpassword123"
|
|
||||||
}
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
response = await client.post(f"{self.base_url}/api/v1/login", json=login_data)
|
|
||||||
|
|
||||||
if response.status_code == 200:
|
|
||||||
data = response.json()
|
|
||||||
self.token = data["access_token"]
|
|
||||||
print("✅ Login successful! Token received")
|
|
||||||
return self.token
|
|
||||||
else:
|
|
||||||
print(f"❌ Login failed: {response.status_code} - {response.text}")
|
|
||||||
return ""
|
|
||||||
|
|
||||||
async def test_profile(self):
|
|
||||||
"""Test getting and updating profile"""
|
|
||||||
if not self.token:
|
|
||||||
print("❌ No token available for profile test")
|
|
||||||
return
|
|
||||||
|
|
||||||
print("👤 Testing profile operations...")
|
|
||||||
headers = {"Authorization": f"Bearer {self.token}"}
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
# Get profile
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/profile", headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
print("✅ Profile retrieval successful")
|
|
||||||
else:
|
|
||||||
print(f"❌ Profile retrieval failed: {response.status_code}")
|
|
||||||
|
|
||||||
# Update profile
|
|
||||||
update_data = {"bio": "Updated bio for testing"}
|
|
||||||
response = await client.put(f"{self.base_url}/api/v1/profile", json=update_data, headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
print("✅ Profile update successful")
|
|
||||||
else:
|
|
||||||
print(f"❌ Profile update failed: {response.status_code}")
|
|
||||||
|
|
||||||
async def test_location_update(self):
|
|
||||||
"""Test location services"""
|
|
||||||
if not self.token:
|
|
||||||
print("❌ No token available for location test")
|
|
||||||
return
|
|
||||||
|
|
||||||
print("📍 Testing location services...")
|
|
||||||
headers = {"Authorization": f"Bearer {self.token}"}
|
|
||||||
|
|
||||||
location_data = {
|
|
||||||
"latitude": 37.7749,
|
|
||||||
"longitude": -122.4194,
|
|
||||||
"accuracy": 10.5
|
|
||||||
}
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
# Update location
|
|
||||||
response = await client.post(f"{self.base_url}/api/v1/update-location", json=location_data, headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
print("✅ Location update successful")
|
|
||||||
else:
|
|
||||||
print(f"❌ Location update failed: {response.status_code} - {response.text}")
|
|
||||||
|
|
||||||
# Get nearby users
|
|
||||||
params = {
|
|
||||||
"latitude": 37.7749,
|
|
||||||
"longitude": -122.4194,
|
|
||||||
"radius_km": 1.0
|
|
||||||
}
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/nearby-users", params=params, headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
nearby = response.json()
|
|
||||||
print(f"✅ Nearby users query successful - found {len(nearby)} users")
|
|
||||||
else:
|
|
||||||
print(f"❌ Nearby users query failed: {response.status_code}")
|
|
||||||
|
|
||||||
async def test_emergency_alert(self):
|
|
||||||
"""Test emergency alert system"""
|
|
||||||
if not self.token:
|
|
||||||
print("❌ No token available for emergency test")
|
|
||||||
return
|
|
||||||
|
|
||||||
print("🚨 Testing emergency alert system...")
|
|
||||||
headers = {"Authorization": f"Bearer {self.token}"}
|
|
||||||
|
|
||||||
alert_data = {
|
|
||||||
"latitude": 37.7749,
|
|
||||||
"longitude": -122.4194,
|
|
||||||
"alert_type": "general",
|
|
||||||
"message": "Test emergency alert",
|
|
||||||
"address": "123 Test Street, San Francisco, CA"
|
|
||||||
}
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
# Create emergency alert
|
|
||||||
response = await client.post(f"{self.base_url}/api/v1/alert", json=alert_data, headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
alert = response.json()
|
|
||||||
alert_id = alert["id"]
|
|
||||||
print(f"✅ Emergency alert created successfully! Alert ID: {alert_id}")
|
|
||||||
|
|
||||||
# Get my alerts
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/alerts/my", headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
alerts = response.json()
|
|
||||||
print(f"✅ Retrieved {len(alerts)} alerts")
|
|
||||||
else:
|
|
||||||
print(f"❌ Failed to retrieve alerts: {response.status_code}")
|
|
||||||
|
|
||||||
# Resolve alert
|
|
||||||
response = await client.put(f"{self.base_url}/api/v1/alert/{alert_id}/resolve", headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
print("✅ Alert resolved successfully")
|
|
||||||
else:
|
|
||||||
print(f"❌ Failed to resolve alert: {response.status_code}")
|
|
||||||
|
|
||||||
else:
|
|
||||||
print(f"❌ Emergency alert creation failed: {response.status_code} - {response.text}")
|
|
||||||
|
|
||||||
async def test_calendar_entry(self):
|
|
||||||
"""Test calendar services"""
|
|
||||||
if not self.token:
|
|
||||||
print("❌ No token available for calendar test")
|
|
||||||
return
|
|
||||||
|
|
||||||
print("📅 Testing calendar services...")
|
|
||||||
headers = {"Authorization": f"Bearer {self.token}"}
|
|
||||||
|
|
||||||
calendar_data = {
|
|
||||||
"entry_date": "2024-01-15",
|
|
||||||
"entry_type": "period",
|
|
||||||
"flow_intensity": "medium",
|
|
||||||
"mood": "happy",
|
|
||||||
"energy_level": 4
|
|
||||||
}
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
# Create calendar entry
|
|
||||||
response = await client.post(f"{self.base_url}/api/v1/entries", json=calendar_data, headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
print("✅ Calendar entry created successfully")
|
|
||||||
|
|
||||||
# Get calendar entries
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/entries", headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
entries = response.json()
|
|
||||||
print(f"✅ Retrieved {len(entries)} calendar entries")
|
|
||||||
else:
|
|
||||||
print(f"❌ Failed to retrieve calendar entries: {response.status_code}")
|
|
||||||
|
|
||||||
# Get cycle overview
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/cycle-overview", headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
overview = response.json()
|
|
||||||
print(f"✅ Cycle overview retrieved - Phase: {overview.get('current_phase', 'unknown')}")
|
|
||||||
else:
|
|
||||||
print(f"❌ Failed to get cycle overview: {response.status_code}")
|
|
||||||
|
|
||||||
else:
|
|
||||||
print(f"❌ Calendar entry creation failed: {response.status_code} - {response.text}")
|
|
||||||
|
|
||||||
async def test_notifications(self):
|
|
||||||
"""Test notification services"""
|
|
||||||
if not self.token:
|
|
||||||
print("❌ No token available for notification test")
|
|
||||||
return
|
|
||||||
|
|
||||||
print("🔔 Testing notification services...")
|
|
||||||
headers = {"Authorization": f"Bearer {self.token}"}
|
|
||||||
|
|
||||||
device_data = {
|
|
||||||
"token": "test_fcm_token_12345",
|
|
||||||
"platform": "android"
|
|
||||||
}
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
# Register device token
|
|
||||||
response = await client.post(f"{self.base_url}/api/v1/register-device", json=device_data, headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
print("✅ Device token registered successfully")
|
|
||||||
|
|
||||||
# Get my devices
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/my-devices", headers=headers)
|
|
||||||
if response.status_code == 200:
|
|
||||||
devices = response.json()
|
|
||||||
print(f"✅ Retrieved device info - {devices['device_count']} devices")
|
|
||||||
else:
|
|
||||||
print(f"❌ Failed to retrieve devices: {response.status_code}")
|
|
||||||
|
|
||||||
else:
|
|
||||||
print(f"❌ Device token registration failed: {response.status_code} - {response.text}")
|
|
||||||
|
|
||||||
async def test_health_checks(self):
|
|
||||||
"""Test system health endpoints"""
|
|
||||||
print("🏥 Testing health checks...")
|
|
||||||
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
# Gateway health
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/health")
|
|
||||||
if response.status_code == 200:
|
|
||||||
print("✅ API Gateway health check passed")
|
|
||||||
else:
|
|
||||||
print(f"❌ API Gateway health check failed: {response.status_code}")
|
|
||||||
|
|
||||||
# Services status
|
|
||||||
response = await client.get(f"{self.base_url}/api/v1/services-status")
|
|
||||||
if response.status_code == 200:
|
|
||||||
status = response.json()
|
|
||||||
healthy_services = sum(1 for service in status["services"].values() if service["status"] == "healthy")
|
|
||||||
total_services = len(status["services"])
|
|
||||||
print(f"✅ Services status check - {healthy_services}/{total_services} services healthy")
|
|
||||||
|
|
||||||
# Print individual service status
|
|
||||||
for name, service in status["services"].items():
|
|
||||||
status_icon = "✅" if service["status"] == "healthy" else "❌"
|
|
||||||
print(f" {status_icon} {name}: {service['status']}")
|
|
||||||
else:
|
|
||||||
print(f"❌ Services status check failed: {response.status_code}")
|
|
||||||
|
|
||||||
async def run_all_tests(self):
|
|
||||||
"""Run all API tests"""
|
|
||||||
print("🚀 Starting API Tests for Women's Safety App\n")
|
|
||||||
|
|
||||||
# Test basic functionality
|
|
||||||
await self.test_health_checks()
|
|
||||||
print()
|
|
||||||
|
|
||||||
await self.test_registration()
|
|
||||||
print()
|
|
||||||
|
|
||||||
await self.test_login()
|
|
||||||
print()
|
|
||||||
|
|
||||||
if self.token:
|
|
||||||
await self.test_profile()
|
|
||||||
print()
|
|
||||||
|
|
||||||
await self.test_location_update()
|
|
||||||
print()
|
|
||||||
|
|
||||||
await self.test_emergency_alert()
|
|
||||||
print()
|
|
||||||
|
|
||||||
await self.test_calendar_entry()
|
|
||||||
print()
|
|
||||||
|
|
||||||
await self.test_notifications()
|
|
||||||
print()
|
|
||||||
|
|
||||||
print("🎉 API testing completed!")
|
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
|
||||||
"""Main function to run tests"""
|
|
||||||
print("Women's Safety App - API Test Suite")
|
|
||||||
print("=" * 50)
|
|
||||||
|
|
||||||
# Check if services are running
|
|
||||||
try:
|
|
||||||
async with httpx.AsyncClient() as client:
|
|
||||||
response = await client.get(f"{BASE_URL}/api/v1/health", timeout=5.0)
|
|
||||||
if response.status_code != 200:
|
|
||||||
print(f"❌ Services not responding. Make sure to run './start_services.sh' first")
|
|
||||||
return
|
|
||||||
except Exception as e:
|
|
||||||
print(f"❌ Cannot connect to services: {e}")
|
|
||||||
print("Make sure to run './start_services.sh' first")
|
|
||||||
return
|
|
||||||
|
|
||||||
# Run tests
|
|
||||||
tester = APITester()
|
|
||||||
await tester.run_all_tests()
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
asyncio.run(main())
|
|
||||||
@@ -1,103 +0,0 @@
|
|||||||
#!/usr/bin/env python3
|
|
||||||
|
|
||||||
import asyncio
|
|
||||||
import aiohttp
|
|
||||||
import json
|
|
||||||
import subprocess
|
|
||||||
import time
|
|
||||||
import signal
|
|
||||||
import os
|
|
||||||
import sys
|
|
||||||
|
|
||||||
async def test_user_service():
|
|
||||||
"""Test the User Service API"""
|
|
||||||
|
|
||||||
# Start the service
|
|
||||||
print("🚀 Starting User Service...")
|
|
||||||
|
|
||||||
# Set up environment
|
|
||||||
env = os.environ.copy()
|
|
||||||
env['PYTHONPATH'] = f"{os.getcwd()}:{env.get('PYTHONPATH', '')}"
|
|
||||||
|
|
||||||
# Start uvicorn process
|
|
||||||
process = subprocess.Popen([
|
|
||||||
sys.executable, "-m", "uvicorn", "main:app",
|
|
||||||
"--host", "0.0.0.0", "--port", "8001"
|
|
||||||
], cwd="services/user_service", env=env)
|
|
||||||
|
|
||||||
print("⏳ Waiting for service to start...")
|
|
||||||
await asyncio.sleep(5)
|
|
||||||
|
|
||||||
try:
|
|
||||||
# Test registration
|
|
||||||
async with aiohttp.ClientSession() as session:
|
|
||||||
print("🧪 Testing user registration...")
|
|
||||||
|
|
||||||
registration_data = {
|
|
||||||
"email": "test3@example.com",
|
|
||||||
"password": "testpassword123",
|
|
||||||
"first_name": "Test",
|
|
||||||
"last_name": "User3",
|
|
||||||
"phone": "+1234567892"
|
|
||||||
}
|
|
||||||
|
|
||||||
async with session.post(
|
|
||||||
"http://localhost:8001/api/v1/register",
|
|
||||||
json=registration_data,
|
|
||||||
headers={"Content-Type": "application/json"}
|
|
||||||
) as response:
|
|
||||||
if response.status == 201:
|
|
||||||
data = await response.json()
|
|
||||||
print("✅ Registration successful!")
|
|
||||||
print(f"📝 Response: {json.dumps(data, indent=2)}")
|
|
||||||
else:
|
|
||||||
text = await response.text()
|
|
||||||
print(f"❌ Registration failed with status {response.status}")
|
|
||||||
print(f"📝 Error: {text}")
|
|
||||||
|
|
||||||
# Test login
|
|
||||||
print("\n🧪 Testing user login...")
|
|
||||||
|
|
||||||
login_data = {
|
|
||||||
"email": "test3@example.com",
|
|
||||||
"password": "testpassword123"
|
|
||||||
}
|
|
||||||
|
|
||||||
async with session.post(
|
|
||||||
"http://localhost:8001/api/v1/login",
|
|
||||||
json=login_data,
|
|
||||||
headers={"Content-Type": "application/json"}
|
|
||||||
) as response:
|
|
||||||
if response.status == 200:
|
|
||||||
data = await response.json()
|
|
||||||
print("✅ Login successful!")
|
|
||||||
print(f"📝 Token: {data['access_token'][:50]}...")
|
|
||||||
else:
|
|
||||||
text = await response.text()
|
|
||||||
print(f"❌ Login failed with status {response.status}")
|
|
||||||
print(f"📝 Error: {text}")
|
|
||||||
|
|
||||||
# Test health check
|
|
||||||
print("\n🧪 Testing health check...")
|
|
||||||
async with session.get("http://localhost:8001/api/v1/health") as response:
|
|
||||||
if response.status == 200:
|
|
||||||
data = await response.json()
|
|
||||||
print("✅ Health check successful!")
|
|
||||||
print(f"📝 Response: {json.dumps(data, indent=2)}")
|
|
||||||
else:
|
|
||||||
text = await response.text()
|
|
||||||
print(f"❌ Health check failed with status {response.status}")
|
|
||||||
print(f"📝 Error: {text}")
|
|
||||||
|
|
||||||
except Exception as e:
|
|
||||||
print(f"❌ Test failed with exception: {e}")
|
|
||||||
|
|
||||||
finally:
|
|
||||||
# Stop the service
|
|
||||||
print("\n🛑 Stopping service...")
|
|
||||||
process.terminate()
|
|
||||||
process.wait()
|
|
||||||
print("✅ Test completed!")
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
asyncio.run(test_user_service())
|
|
||||||
@@ -1,142 +0,0 @@
|
|||||||
#!/bin/bash
|
|
||||||
|
|
||||||
# Скрипт для тестирования полного цикла аутентификации
|
|
||||||
# Регистрация -> Авторизация -> Получение Bearer токена
|
|
||||||
|
|
||||||
echo "🔐 Тестирование полного цикла аутентификации"
|
|
||||||
echo "============================================="
|
|
||||||
|
|
||||||
# Проверяем, что сервис запущен
|
|
||||||
echo "🔍 Проверяем доступность User Service..."
|
|
||||||
if ! curl -s http://localhost:8001/api/v1/health > /dev/null; then
|
|
||||||
echo "❌ User Service недоступен. Запустите сервис командой:"
|
|
||||||
echo " cd services/user_service && python -m uvicorn main:app --host 0.0.0.0 --port 8001"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
echo "✅ User Service доступен"
|
|
||||||
|
|
||||||
# Генерируем уникальный email для тестирования
|
|
||||||
TIMESTAMP=$(date +%s)
|
|
||||||
EMAIL="test_user_${TIMESTAMP}@example.com"
|
|
||||||
|
|
||||||
echo -e "\n📝 Тестовые данные:"
|
|
||||||
echo "Email: $EMAIL"
|
|
||||||
echo "Password: TestPassword123"
|
|
||||||
echo "First Name: Тест"
|
|
||||||
echo "Last Name: Пользователь"
|
|
||||||
echo "Phone: +7-900-123-45-67"
|
|
||||||
|
|
||||||
# 1. РЕГИСТРАЦИЯ ПОЛЬЗОВАТЕЛЯ
|
|
||||||
echo -e "\n🔵 Шаг 1: Регистрация нового пользователя"
|
|
||||||
echo "============================================"
|
|
||||||
|
|
||||||
REGISTRATION_RESPONSE=$(curl -s -w "HTTPSTATUS:%{http_code}" -X POST "http://localhost:8001/api/v1/register" \
|
|
||||||
-H "Content-Type: application/json" \
|
|
||||||
-d "{
|
|
||||||
\"email\": \"$EMAIL\",
|
|
||||||
\"password\": \"TestPassword123\",
|
|
||||||
\"first_name\": \"Тест\",
|
|
||||||
\"last_name\": \"Пользователь\",
|
|
||||||
\"phone\": \"+7-900-123-45-67\"
|
|
||||||
}")
|
|
||||||
|
|
||||||
# Извлекаем HTTP статус и тело ответа
|
|
||||||
HTTP_STATUS=$(echo $REGISTRATION_RESPONSE | tr -d '\n' | sed -e 's/.*HTTPSTATUS://')
|
|
||||||
REGISTRATION_BODY=$(echo $REGISTRATION_RESPONSE | sed -e 's/HTTPSTATUS:.*//g')
|
|
||||||
|
|
||||||
if [ "$HTTP_STATUS" -eq 201 ] || [ "$HTTP_STATUS" -eq 200 ]; then
|
|
||||||
echo "✅ Регистрация успешна!"
|
|
||||||
echo "📋 Данные пользователя:"
|
|
||||||
echo "$REGISTRATION_BODY" | jq . 2>/dev/null || echo "$REGISTRATION_BODY"
|
|
||||||
|
|
||||||
# Извлекаем UUID пользователя
|
|
||||||
USER_UUID=$(echo "$REGISTRATION_BODY" | jq -r '.uuid' 2>/dev/null)
|
|
||||||
echo "🆔 UUID пользователя: $USER_UUID"
|
|
||||||
else
|
|
||||||
echo "❌ Ошибка регистрации. HTTP Status: $HTTP_STATUS"
|
|
||||||
echo "📋 Ответ сервера:"
|
|
||||||
echo "$REGISTRATION_BODY" | jq . 2>/dev/null || echo "$REGISTRATION_BODY"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
# 2. АВТОРИЗАЦИЯ ПОЛЬЗОВАТЕЛЯ
|
|
||||||
echo -e "\n🔵 Шаг 2: Авторизация пользователя"
|
|
||||||
echo "=================================="
|
|
||||||
|
|
||||||
LOGIN_RESPONSE=$(curl -s -w "HTTPSTATUS:%{http_code}" -X POST "http://localhost:8001/api/v1/login" \
|
|
||||||
-H "Content-Type: application/json" \
|
|
||||||
-d "{
|
|
||||||
\"email\": \"$EMAIL\",
|
|
||||||
\"password\": \"TestPassword123\"
|
|
||||||
}")
|
|
||||||
|
|
||||||
# Извлекаем HTTP статус и тело ответа
|
|
||||||
HTTP_STATUS=$(echo $LOGIN_RESPONSE | tr -d '\n' | sed -e 's/.*HTTPSTATUS://')
|
|
||||||
LOGIN_BODY=$(echo $LOGIN_RESPONSE | sed -e 's/HTTPSTATUS:.*//g')
|
|
||||||
|
|
||||||
if [ "$HTTP_STATUS" -eq 200 ]; then
|
|
||||||
echo "✅ Авторизация успешна!"
|
|
||||||
echo "📋 Данные авторизации:"
|
|
||||||
echo "$LOGIN_BODY" | jq . 2>/dev/null || echo "$LOGIN_BODY"
|
|
||||||
|
|
||||||
# Извлекаем Bearer токен
|
|
||||||
BEARER_TOKEN=$(echo "$LOGIN_BODY" | jq -r '.access_token' 2>/dev/null)
|
|
||||||
TOKEN_TYPE=$(echo "$LOGIN_BODY" | jq -r '.token_type' 2>/dev/null)
|
|
||||||
|
|
||||||
if [ "$BEARER_TOKEN" != "null" ] && [ "$BEARER_TOKEN" != "" ]; then
|
|
||||||
echo -e "\n🎯 Bearer Token получен успешно!"
|
|
||||||
echo "=================================="
|
|
||||||
echo "🔑 Token Type: $TOKEN_TYPE"
|
|
||||||
echo "🔐 Access Token: $BEARER_TOKEN"
|
|
||||||
echo ""
|
|
||||||
echo "📋 Полный Authorization Header:"
|
|
||||||
echo "Authorization: $TOKEN_TYPE $BEARER_TOKEN"
|
|
||||||
echo ""
|
|
||||||
echo "📋 Для использования в curl:"
|
|
||||||
echo "curl -H \"Authorization: $TOKEN_TYPE $BEARER_TOKEN\" http://localhost:8001/api/v1/protected-endpoint"
|
|
||||||
else
|
|
||||||
echo "❌ Не удалось извлечь Bearer токен из ответа"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
echo "❌ Ошибка авторизации. HTTP Status: $HTTP_STATUS"
|
|
||||||
echo "📋 Ответ сервера:"
|
|
||||||
echo "$LOGIN_BODY" | jq . 2>/dev/null || echo "$LOGIN_BODY"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
# 3. ТЕСТИРОВАНИЕ ТОКЕНА (если есть защищенный эндпоинт)
|
|
||||||
echo -e "\n🔵 Шаг 3: Проверка профиля пользователя с токеном"
|
|
||||||
echo "==============================================="
|
|
||||||
|
|
||||||
PROFILE_RESPONSE=$(curl -s -w "HTTPSTATUS:%{http_code}" -X GET "http://localhost:8001/api/v1/profile" \
|
|
||||||
-H "Authorization: $TOKEN_TYPE $BEARER_TOKEN")
|
|
||||||
|
|
||||||
# Извлекаем HTTP статус и тело ответа
|
|
||||||
HTTP_STATUS=$(echo $PROFILE_RESPONSE | tr -d '\n' | sed -e 's/.*HTTPSTATUS://')
|
|
||||||
PROFILE_BODY=$(echo $PROFILE_RESPONSE | sed -e 's/HTTPSTATUS:.*//g')
|
|
||||||
|
|
||||||
if [ "$HTTP_STATUS" -eq 200 ]; then
|
|
||||||
echo "✅ Токен работает! Профиль получен:"
|
|
||||||
echo "$PROFILE_BODY" | jq . 2>/dev/null || echo "$PROFILE_BODY"
|
|
||||||
else
|
|
||||||
echo "⚠️ Не удалось получить профиль. HTTP Status: $HTTP_STATUS"
|
|
||||||
echo "📋 Ответ сервера:"
|
|
||||||
echo "$PROFILE_BODY" | jq . 2>/dev/null || echo "$PROFILE_BODY"
|
|
||||||
echo "💡 Возможно, эндпоинт /profile не реализован или требует другой путь"
|
|
||||||
fi
|
|
||||||
|
|
||||||
echo -e "\n🎉 Тестирование завершено!"
|
|
||||||
echo "=========================="
|
|
||||||
echo "✅ Регистрация: Успешно"
|
|
||||||
echo "✅ Авторизация: Успешно"
|
|
||||||
echo "✅ Bearer Token: Получен"
|
|
||||||
echo ""
|
|
||||||
echo "🔐 Ваш Bearer Token:"
|
|
||||||
echo "$TOKEN_TYPE $BEARER_TOKEN"
|
|
||||||
echo ""
|
|
||||||
echo "💾 Токен сохранен в переменную окружения для использования:"
|
|
||||||
echo "export AUTH_TOKEN=\"$TOKEN_TYPE $BEARER_TOKEN\""
|
|
||||||
echo ""
|
|
||||||
echo "📖 Для тестирования других эндпоинтов используйте:"
|
|
||||||
echo "curl -H \"Authorization: \$AUTH_TOKEN\" http://localhost:8001/api/v1/your-endpoint"
|
|
||||||
@@ -1,72 +0,0 @@
|
|||||||
#!/bin/bash
|
|
||||||
|
|
||||||
echo "🚀 Starting Women Safety App Services - Simple Mode"
|
|
||||||
|
|
||||||
# Clean up any existing processes
|
|
||||||
echo "🧹 Cleaning up existing processes..."
|
|
||||||
pkill -f uvicorn 2>/dev/null || true
|
|
||||||
sleep 2
|
|
||||||
|
|
||||||
# Set environment
|
|
||||||
export PYTHONPATH=$PWD:$PYTHONPATH
|
|
||||||
source .venv/bin/activate
|
|
||||||
|
|
||||||
# Test database connection
|
|
||||||
echo "🔍 Testing database connection..."
|
|
||||||
python -c "
|
|
||||||
import asyncio
|
|
||||||
import asyncpg
|
|
||||||
from shared.config import settings
|
|
||||||
|
|
||||||
async def test_db():
|
|
||||||
try:
|
|
||||||
conn = await asyncpg.connect(settings.DATABASE_URL.replace('+asyncpg', ''))
|
|
||||||
print('✅ Database connection successful!')
|
|
||||||
await conn.close()
|
|
||||||
except Exception as e:
|
|
||||||
print(f'❌ Database connection failed: {e}')
|
|
||||||
exit(1)
|
|
||||||
|
|
||||||
asyncio.run(test_db())
|
|
||||||
"
|
|
||||||
|
|
||||||
echo "🎯 Starting services one by one..."
|
|
||||||
|
|
||||||
# Start User Service
|
|
||||||
echo "Starting User Service on port 8001..."
|
|
||||||
cd services/user_service
|
|
||||||
python -m uvicorn main:app --host 127.0.0.1 --port 8001 &
|
|
||||||
USER_PID=$!
|
|
||||||
cd ../..
|
|
||||||
sleep 3
|
|
||||||
|
|
||||||
# Test User Service
|
|
||||||
echo "Testing User Service..."
|
|
||||||
if python -c "import httpx; import sys; sys.exit(0 if httpx.get('http://localhost:8001/health').status_code == 200 else 1)" 2>/dev/null; then
|
|
||||||
echo "✅ User Service is running"
|
|
||||||
else
|
|
||||||
echo "❌ User Service failed to start"
|
|
||||||
kill $USER_PID 2>/dev/null
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
echo ""
|
|
||||||
echo "🎉 Services started successfully!"
|
|
||||||
echo "📋 Active Services:"
|
|
||||||
echo " 👤 User Service: http://localhost:8001"
|
|
||||||
echo " 📖 User Service Docs: http://localhost:8001/docs"
|
|
||||||
echo ""
|
|
||||||
echo "Press Ctrl+C to stop the service"
|
|
||||||
|
|
||||||
# Wait for interrupt
|
|
||||||
trap "echo 'Stopping services...'; kill $USER_PID 2>/dev/null; echo 'Done'; exit 0" INT
|
|
||||||
|
|
||||||
# Keep script running
|
|
||||||
while true; do
|
|
||||||
sleep 10
|
|
||||||
# Check if user service is still running
|
|
||||||
if ! kill -0 $USER_PID 2>/dev/null; then
|
|
||||||
echo "User service stopped unexpectedly"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
done
|
|
||||||
@@ -1,53 +0,0 @@
|
|||||||
#!/bin/bash
|
|
||||||
|
|
||||||
echo "🚀 Starting User Service and Testing API"
|
|
||||||
|
|
||||||
# Activate virtual environment
|
|
||||||
source .venv/bin/activate
|
|
||||||
|
|
||||||
# Set PYTHONPATH
|
|
||||||
export PYTHONPATH="${PWD}:${PYTHONPATH}"
|
|
||||||
|
|
||||||
# Start user service in background
|
|
||||||
cd services/user_service
|
|
||||||
python -m uvicorn main:app --host 0.0.0.0 --port 8001 &
|
|
||||||
USER_SERVICE_PID=$!
|
|
||||||
|
|
||||||
echo "⏳ Waiting for service to start..."
|
|
||||||
sleep 5
|
|
||||||
|
|
||||||
# Go back to project root
|
|
||||||
cd ../..
|
|
||||||
|
|
||||||
# Test registration
|
|
||||||
echo "🧪 Testing user registration..."
|
|
||||||
RESPONSE=$(curl -s -X POST "http://localhost:8001/api/v1/register" \
|
|
||||||
-H "Content-Type: application/json" \
|
|
||||||
-d '{
|
|
||||||
"email": "test@example.com",
|
|
||||||
"password": "testpassword123",
|
|
||||||
"first_name": "Test",
|
|
||||||
"last_name": "User",
|
|
||||||
"phone": "+1234567890"
|
|
||||||
}')
|
|
||||||
|
|
||||||
echo "📝 Registration response:"
|
|
||||||
echo "$RESPONSE" | jq . 2>/dev/null || echo "$RESPONSE"
|
|
||||||
|
|
||||||
# Test login
|
|
||||||
echo -e "\n🧪 Testing user login..."
|
|
||||||
LOGIN_RESPONSE=$(curl -s -X POST "http://localhost:8001/api/v1/login" \
|
|
||||||
-H "Content-Type: application/json" \
|
|
||||||
-d '{
|
|
||||||
"email": "test@example.com",
|
|
||||||
"password": "testpassword123"
|
|
||||||
}')
|
|
||||||
|
|
||||||
echo "📝 Login response:"
|
|
||||||
echo "$LOGIN_RESPONSE" | jq . 2>/dev/null || echo "$LOGIN_RESPONSE"
|
|
||||||
|
|
||||||
# Stop the service
|
|
||||||
echo -e "\n🛑 Stopping service..."
|
|
||||||
kill $USER_SERVICE_PID
|
|
||||||
|
|
||||||
echo "✅ Test completed!"
|
|
||||||
@@ -1,38 +0,0 @@
|
|||||||
#!/bin/bash
|
|
||||||
|
|
||||||
echo "🧪 Testing User Service"
|
|
||||||
echo "Working directory: $(pwd)"
|
|
||||||
|
|
||||||
# Activate virtual environment
|
|
||||||
source .venv/bin/activate
|
|
||||||
|
|
||||||
# Set PYTHONPATH to include the project root
|
|
||||||
export PYTHONPATH="${PWD}:${PYTHONPATH}"
|
|
||||||
|
|
||||||
# Print configuration
|
|
||||||
echo "🔍 Testing configuration loading..."
|
|
||||||
python -c "from shared.config import settings; print(f'DATABASE_URL: {settings.DATABASE_URL}')"
|
|
||||||
|
|
||||||
# Test database connection
|
|
||||||
echo "🔍 Testing database connection..."
|
|
||||||
python -c "
|
|
||||||
import asyncio
|
|
||||||
import asyncpg
|
|
||||||
from shared.config import settings
|
|
||||||
|
|
||||||
async def test_db():
|
|
||||||
try:
|
|
||||||
conn = await asyncpg.connect(settings.DATABASE_URL.replace('postgresql+asyncpg://', 'postgresql://'))
|
|
||||||
version = await conn.fetchval('SELECT version()')
|
|
||||||
print(f'✅ Database connection successful: {version[:50]}...')
|
|
||||||
await conn.close()
|
|
||||||
except Exception as e:
|
|
||||||
print(f'❌ Database connection failed: {e}')
|
|
||||||
|
|
||||||
asyncio.run(test_db())
|
|
||||||
"
|
|
||||||
|
|
||||||
# Start user service
|
|
||||||
echo "🚀 Starting User Service..."
|
|
||||||
cd services/user_service
|
|
||||||
exec python -m uvicorn main:app --host 0.0.0.0 --port 8001
|
|
||||||
Reference in New Issue
Block a user