Spaces:

techprotrade
/

annator-full-system

Paused

annator-full-system / scripts /deploy_enhanced_workflow_simple.sh

github-actions

Sync from ATOM master 2026-08-17T19:34:18Z

81e8bb6 2 months ago

7.95 kB

#!/bin/bash

# 🚀 Simplified Enhanced Workflow Automation Deployment
# Quick deployment with essential enhanced features

set -e  # Exit on any error

echo "🚀 Deploying Enhanced Workflow Automation System"
echo "================================================"

# Colors for output
RED='\033[0;31m'
GREEN='\033[0;32m'
YELLOW='\033[1;33m'
BLUE='\033[0;34m'
NC='\033[0m' # No Color

print_status() {
    echo -e "${BLUE}[INFO]${NC} $1"
}

print_success() {
    echo -e "${GREEN}[SUCCESS]${NC} $1"
}

print_warning() {
    echo -e "${YELLOW}[WARNING]${NC} $1"
}

print_error() {
    echo -e "${RED}[ERROR]${NC} $1"
}

# Check if we're in the correct directory
if [ ! -f "README.md" ] && [ ! -d "backend" ]; then
    print_error "Please run this script from the atom project root directory"
    exit 1
fi

# Set default environment variables
export DATABASE_URL=${DATABASE_URL:-"postgresql://atom_user:local_password@localhost:5432/atom_production"}
export FLASK_ENV=${FLASK_ENV:-"production"}
export PYTHON_API_PORT=${PYTHON_API_PORT:-5058}
export CELERY_BROKER_URL=${CELERY_BROKER_URL:-"redis://localhost:6379/0"}

print_status "Environment configuration:"
echo "  DATABASE_URL: $(echo $DATABASE_URL | sed 's/:[^:]*@/:***@/')"
echo "  FLASK_ENV: $FLASK_ENV"
echo "  PYTHON_API_PORT: $PYTHON_API_PORT"
echo "  CELERY_BROKER_URL: $(echo $CELERY_BROKER_URL | sed 's/:[^:]*@/:***@/')"

# Check required services
print_status "Checking required services..."

# Check if API server is running
if lsof -i :5058 > /dev/null 2>&1; then
    print_success "API server is running on port 5058"
else
    print_warning "API server not detected on port 5058"
    print_status "Starting API server..."
    cd backend/python-api-service
    python3 main_api_app.py &
    API_PID=$!
    echo $API_PID > /tmp/atom_api.pid
    sleep 5
    print_success "API server started (PID: $API_PID)"
    cd ../..
fi

# Test API connectivity
print_status "Testing API connectivity..."
if curl -s http://localhost:5058/healthz > /dev/null; then
    print_success "API server is responsive"
else
    print_error "API server is not responding"
    exit 1
fi

# Initialize enhanced workflow components
print_status "Initializing enhanced workflow components..."

# Test enhanced workflow generation
print_status "Testing enhanced workflow intelligence..."
curl -X POST http://localhost:5058/api/workflows/automation/generate \
  -H "Content-Type: application/json" \
  -d '{
    "user_input": "When I receive important emails from gmail, create tasks in asana and notify team on slack",
    "user_id": "deployment_test",
    "enhanced_intelligence": true
  }' > /tmp/workflow_test.json 2>/dev/null

if [ $? -eq 0 ]; then
    print_success "Enhanced workflow intelligence is working"
    SERVICES=$(cat /tmp/workflow_test.json | grep -o '"services":\[[^]]*\]' | head -1)
    echo "  Detected services: $SERVICES"
else
    print_warning "Enhanced workflow intelligence test failed"
fi

# Test optimization endpoint
print_status "Testing workflow optimization..."
curl -X POST http://localhost:5058/api/workflows/optimization/analyze \
  -H "Content-Type: application/json" \
  -d '{
    "workflow": {
      "name": "Test Workflow",
      "steps": [
        {"action": "search_emails", "service": "gmail", "estimated_duration": 5.0},
        {"action": "create_task", "service": "asana", "estimated_duration": 3.0}
      ]
    },
    "strategy": "performance",
    "user_id": "deployment_test"
  }' > /tmp/optimization_test.json 2>/dev/null

if [ $? -eq 0 ]; then
    print_success "Workflow optimization is working"
    SUGGESTIONS=$(cat /tmp/optimization_test.json | grep -o '"optimization_suggestions":\[[^]]*\]' | head -1)
    if [ -n "$SUGGESTIONS" ]; then
        echo "  Optimization suggestions available"
    fi
else
    print_warning "Workflow optimization test failed"
fi

# Test monitoring endpoints
print_status "Testing monitoring system..."
MONITORING_ENDPOINTS=(
    "/api/workflows/monitoring/health"
    "/api/workflows/monitoring/metrics"
)

for endpoint in "${MONITORING_ENDPOINTS[@]}"; do
    if curl -s http://localhost:5058$endpoint > /dev/null; then
        print_success "Monitoring endpoint $endpoint is responsive"
    else
        print_warning "Monitoring endpoint $endpoint not available"
    fi
done

# Start enhanced services
print_status "Starting enhanced services..."

# Start enhanced workflow intelligence service
print_status "Starting enhanced intelligence service..."
cd backend/python-api-service
python3 -c "
import sys
sys.path.append('.')
try:
    from enhanced_workflow_intelligence import EnhancedWorkflowIntelligence
    intelligence = EnhancedWorkflowIntelligence()
    print('Enhanced workflow intelligence service initialized')
except Exception as e:
    print(f'Enhanced intelligence service failed: {e}')
" &
INTELLIGENCE_PID=$!
echo $INTELLIGENCE_PID > /tmp/enhanced_intelligence.pid
print_success "Enhanced intelligence service started (PID: $INTELLIGENCE_PID)"

# Start monitoring service
print_status "Starting monitoring service..."
python3 -c "
import sys
sys.path.append('.')
try:
    from enhanced_workflow_monitoring import EnhancedWorkflowMonitor
    monitor = EnhancedWorkflowMonitor()
    monitor.start_monitoring()
    print('Enhanced monitoring service started')
except Exception as e:
    print(f'Enhanced monitoring service failed: {e}')
" &
MONITOR_PID=$!
echo $MONITOR_PID > /tmp/enhanced_monitor.pid
print_success "Enhanced monitoring service started (PID: $MONITOR_PID)"

cd ../..

# Final validation
print_status "Performing final validation..."

# Test comprehensive workflow execution
print_status "Testing enhanced workflow execution..."
curl -X POST http://localhost:5058/api/workflows/execute \
  -H "Content-Type: application/json" \
  -d '{
    "workflow": {
      "name": "Enhanced Deployment Test",
      "description": "Test workflow for enhanced deployment",
      "steps": [
        {
          "step_id": "test_step_1",
          "action": "send_test_notification",
          "service": "generic",
          "parameters": {"message": "Enhanced workflow system deployed successfully"}
        }
      ]
    },
    "user_id": "deployment_test",
    "enhanced_execution": true
  }' > /tmp/execution_test.json 2>/dev/null

if [ $? -eq 0 ]; then
    print_success "Enhanced workflow execution is working"
    EXECUTION_ID=$(cat /tmp/execution_test.json | grep -o '"execution_id":"[^"]*"' | cut -d'"' -f4)
    if [ -n "$EXECUTION_ID" ]; then
        echo "  Execution ID: $EXECUTION_ID"
    fi
else
    print_warning "Enhanced workflow execution test failed"
fi

# Cleanup test files
rm -f /tmp/workflow_test.json /tmp/optimization_test.json /tmp/execution_test.json

print_success "Enhanced workflow automation system deployed successfully!"
echo ""
echo "📋 Deployment Summary:"
echo "  ✅ API server running on port 5058"
echo "  ✅ Enhanced workflow intelligence active"
echo "  ✅ Workflow optimization available"
echo "  ✅ Monitoring system running"
echo "  ✅ Enhanced execution capabilities enabled"
echo ""
echo "🌐 Available Endpoints:"
echo "  - API Server: http://localhost:5058"
echo "  - Workflow Generation: http://localhost:5058/api/workflows/automation/generate"
echo "  - Workflow Optimization: http://localhost:5058/api/workflows/optimization/analyze"
echo "  - Monitoring: http://localhost:5058/api/workflows/monitoring/health"
echo ""
echo "🚀 Next Steps:"
echo "  1. Access the Atom Agent UI at http://localhost:3000"
echo "  2. Navigate to 'Workflow Automation' tab"
echo "  3. Test enhanced features with intelligent workflow generation"
echo "  4. Monitor workflow executions in real-time"
echo ""
echo "📝 Service PIDs:"
echo "  - API Server: $(cat /tmp/atom_api.pid 2>/dev/null || echo 'unknown')"
echo "  - Enhanced Intelligence: $INTELLIGENCE_PID"
echo "  - Enhanced Monitor: $MONITOR_PID"
echo ""
echo "🎉 Enhanced workflow automation system is ready for use!"

	#!/bin/bash

	# 🚀 Simplified Enhanced Workflow Automation Deployment
	# Quick deployment with essential enhanced features

	set -e # Exit on any error

	echo "🚀 Deploying Enhanced Workflow Automation System"
	echo "================================================"

	# Colors for output
	RED='\033[0;31m'
	GREEN='\033[0;32m'
	YELLOW='\033[1;33m'
	BLUE='\033[0;34m'
	NC='\033[0m' # No Color

	print_status() {
	echo -e "${BLUE}[INFO]${NC} $1"
	}

	print_success() {
	echo -e "${GREEN}[SUCCESS]${NC} $1"
	}

	print_warning() {
	echo -e "${YELLOW}[WARNING]${NC} $1"
	}

	print_error() {
	echo -e "${RED}[ERROR]${NC} $1"
	}

	# Check if we're in the correct directory
	if [ ! -f "README.md" ] && [ ! -d "backend" ]; then
	print_error "Please run this script from the atom project root directory"
	exit 1
	fi

	# Set default environment variables
	export DATABASE_URL=${DATABASE_URL:-"postgresql://atom_user:local_password@localhost:5432/atom_production"}
	export FLASK_ENV=${FLASK_ENV:-"production"}
	export PYTHON_API_PORT=${PYTHON_API_PORT:-5058}
	export CELERY_BROKER_URL=${CELERY_BROKER_URL:-"redis://localhost:6379/0"}

	print_status "Environment configuration:"
	echo " DATABASE_URL: $(echo $DATABASE_URL \| sed 's/:[^:]@/:**@/')"
	echo " FLASK_ENV: $FLASK_ENV"
	echo " PYTHON_API_PORT: $PYTHON_API_PORT"
	echo " CELERY_BROKER_URL: $(echo $CELERY_BROKER_URL \| sed 's/:[^:]@/:**@/')"

	# Check required services
	print_status "Checking required services..."

	# Check if API server is running
	if lsof -i :5058 > /dev/null 2>&1; then
	print_success "API server is running on port 5058"
	else
	print_warning "API server not detected on port 5058"
	print_status "Starting API server..."
	cd backend/python-api-service
	python3 main_api_app.py &
	API_PID=$!
	echo $API_PID > /tmp/atom_api.pid
	sleep 5
	print_success "API server started (PID: $API_PID)"
	cd ../..
	fi

	# Test API connectivity
	print_status "Testing API connectivity..."
	if curl -s http://localhost:5058/healthz > /dev/null; then
	print_success "API server is responsive"
	else
	print_error "API server is not responding"
	exit 1
	fi

	# Initialize enhanced workflow components
	print_status "Initializing enhanced workflow components..."

	# Test enhanced workflow generation
	print_status "Testing enhanced workflow intelligence..."
	curl -X POST http://localhost:5058/api/workflows/automation/generate \
	-H "Content-Type: application/json" \
	-d '{
	"user_input": "When I receive important emails from gmail, create tasks in asana and notify team on slack",
	"user_id": "deployment_test",
	"enhanced_intelligence": true
	}' > /tmp/workflow_test.json 2>/dev/null

	if [ $? -eq 0 ]; then
	print_success "Enhanced workflow intelligence is working"
	SERVICES=$(cat /tmp/workflow_test.json \| grep -o '"services":\[[^]]*\]' \| head -1)
	echo " Detected services: $SERVICES"
	else
	print_warning "Enhanced workflow intelligence test failed"
	fi

	# Test optimization endpoint
	print_status "Testing workflow optimization..."
	curl -X POST http://localhost:5058/api/workflows/optimization/analyze \
	-H "Content-Type: application/json" \
	-d '{
	"workflow": {
	"name": "Test Workflow",
	"steps": [
	{"action": "search_emails", "service": "gmail", "estimated_duration": 5.0},
	{"action": "create_task", "service": "asana", "estimated_duration": 3.0}
	]
	},
	"strategy": "performance",
	"user_id": "deployment_test"
	}' > /tmp/optimization_test.json 2>/dev/null

	if [ $? -eq 0 ]; then
	print_success "Workflow optimization is working"
	SUGGESTIONS=$(cat /tmp/optimization_test.json \| grep -o '"optimization_suggestions":\[[^]]*\]' \| head -1)
	if [ -n "$SUGGESTIONS" ]; then
	echo " Optimization suggestions available"
	fi
	else
	print_warning "Workflow optimization test failed"
	fi

	# Test monitoring endpoints
	print_status "Testing monitoring system..."
	MONITORING_ENDPOINTS=(
	"/api/workflows/monitoring/health"
	"/api/workflows/monitoring/metrics"
	)

	for endpoint in "${MONITORING_ENDPOINTS[@]}"; do
	if curl -s http://localhost:5058$endpoint > /dev/null; then
	print_success "Monitoring endpoint $endpoint is responsive"
	else
	print_warning "Monitoring endpoint $endpoint not available"
	fi
	done

	# Start enhanced services
	print_status "Starting enhanced services..."

	# Start enhanced workflow intelligence service
	print_status "Starting enhanced intelligence service..."
	cd backend/python-api-service
	python3 -c "
	import sys
	sys.path.append('.')
	try:
	from enhanced_workflow_intelligence import EnhancedWorkflowIntelligence
	intelligence = EnhancedWorkflowIntelligence()
	print('Enhanced workflow intelligence service initialized')
	except Exception as e:
	print(f'Enhanced intelligence service failed: {e}')
	" &
	INTELLIGENCE_PID=$!
	echo $INTELLIGENCE_PID > /tmp/enhanced_intelligence.pid
	print_success "Enhanced intelligence service started (PID: $INTELLIGENCE_PID)"

	# Start monitoring service
	print_status "Starting monitoring service..."
	python3 -c "
	import sys
	sys.path.append('.')
	try:
	from enhanced_workflow_monitoring import EnhancedWorkflowMonitor
	monitor = EnhancedWorkflowMonitor()
	monitor.start_monitoring()
	print('Enhanced monitoring service started')
	except Exception as e:
	print(f'Enhanced monitoring service failed: {e}')
	" &
	MONITOR_PID=$!
	echo $MONITOR_PID > /tmp/enhanced_monitor.pid
	print_success "Enhanced monitoring service started (PID: $MONITOR_PID)"

	cd ../..

	# Final validation
	print_status "Performing final validation..."

	# Test comprehensive workflow execution
	print_status "Testing enhanced workflow execution..."
	curl -X POST http://localhost:5058/api/workflows/execute \
	-H "Content-Type: application/json" \
	-d '{
	"workflow": {
	"name": "Enhanced Deployment Test",
	"description": "Test workflow for enhanced deployment",
	"steps": [
	{
	"step_id": "test_step_1",
	"action": "send_test_notification",
	"service": "generic",
	"parameters": {"message": "Enhanced workflow system deployed successfully"}
	}
	]
	},
	"user_id": "deployment_test",
	"enhanced_execution": true
	}' > /tmp/execution_test.json 2>/dev/null

	if [ $? -eq 0 ]; then
	print_success "Enhanced workflow execution is working"
	EXECUTION_ID=$(cat /tmp/execution_test.json \| grep -o '"execution_id":"[^"]*"' \| cut -d'"' -f4)
	if [ -n "$EXECUTION_ID" ]; then
	echo " Execution ID: $EXECUTION_ID"
	fi
	else
	print_warning "Enhanced workflow execution test failed"
	fi

	# Cleanup test files
	rm -f /tmp/workflow_test.json /tmp/optimization_test.json /tmp/execution_test.json

	print_success "Enhanced workflow automation system deployed successfully!"
	echo ""
	echo "📋 Deployment Summary:"
	echo " ✅ API server running on port 5058"
	echo " ✅ Enhanced workflow intelligence active"
	echo " ✅ Workflow optimization available"
	echo " ✅ Monitoring system running"
	echo " ✅ Enhanced execution capabilities enabled"
	echo ""
	echo "🌐 Available Endpoints:"
	echo " - API Server: http://localhost:5058"
	echo " - Workflow Generation: http://localhost:5058/api/workflows/automation/generate"
	echo " - Workflow Optimization: http://localhost:5058/api/workflows/optimization/analyze"
	echo " - Monitoring: http://localhost:5058/api/workflows/monitoring/health"
	echo ""
	echo "🚀 Next Steps:"
	echo " 1. Access the Atom Agent UI at http://localhost:3000"
	echo " 2. Navigate to 'Workflow Automation' tab"
	echo " 3. Test enhanced features with intelligent workflow generation"
	echo " 4. Monitor workflow executions in real-time"
	echo ""
	echo "📝 Service PIDs:"
	echo " - API Server: $(cat /tmp/atom_api.pid 2>/dev/null \|\| echo 'unknown')"
	echo " - Enhanced Intelligence: $INTELLIGENCE_PID"
	echo " - Enhanced Monitor: $MONITOR_PID"
	echo ""
	echo "🎉 Enhanced workflow automation system is ready for use!"