const { CodeSolverSDK } = require('solver-sdk');

// Создание экземпляра SDK
const sdk = new CodeSolverSDK({
  baseURL: 'https://localhost:3000',
  apiKey: 'your-api-key'
});

// Использование SDK
async function example() {
  // Проверка соединения с сервером
  const isHealthy = await sdk.checkHealth();
  console.log('Сервер доступен:', isHealthy);
  
  // Получение списка моделей
  const models = await sdk.reasoning.getModels();
  console.log('Доступные модели:', models);
}

example().catch(console.error);

import { CodeSolverSDK } from 'solver-sdk';

// Создание экземпляра SDK
const sdk = new CodeSolverSDK({
  baseURL: 'https://localhost:3000',
  apiKey: 'your-api-key'
});

// Пример использования
async function example() {
  const isHealthy = await sdk.checkHealth();
  console.log('Сервер доступен:', isHealthy);
}

example().catch(console.error);

// Получение списка проектов
const projects = await sdk.projects.getAllProjects();
console.log('Проекты:', projects);

// Создание нового проекта
const newProject = await sdk.projects.createProject('Мой проект', '/path/to/project');
console.log('Новый проект:', newProject);

// Запуск индексации
await sdk.projects.indexProject(newProject.id);

// Поиск кода
const searchResults = await sdk.search.searchCode(projectId, {
  query: 'function example',
  limit: 10
});
console.log('Результаты поиска:', searchResults);

// Семантический поиск кода
const semanticResults = await sdk.search.semanticSearch(projectId, {
  query: 'функция для обработки HTTP запросов',
  limit: 10
});
console.log('Семантические результаты:', semanticResults);

// Создание рассуждения
const reasoning = await sdk.reasoning.createReasoning({
  projectId: projectId,
  query: 'Объясни, как работает этот проект'
});

// Подключение через WebSocket
const wsClient = sdk.getWebSocketClient();
await wsClient.connectToReasoning(reasoning.id);

// Включение механизма ping/pong для мониторинга состояния соединения
wsClient.enablePingPong(30000, 3);

// Обработка событий мышления
wsClient.on('content_block_delta', (data) => {
  if (data.delta?.type === 'thinking_delta') {
    console.log('Фрагмент размышления:', data.delta.thinking);
  } else if (data.delta?.type === 'text_delta') {
    console.log('Фрагмент ответа:', data.delta.text);
  }
});

wsClient.on('message_stop', (data) => {
  console.log('Завершено:', data);
  
  // Отключаем механизм ping/pong и закрываем соединение
  wsClient.disablePingPong();
  wsClient.disconnectAll();
});

// Мониторинг качества соединения
const diagnostics = wsClient.diagnoseConnection(WebSocketNamespace.REASONING);
console.log(`Состояние соединения:`, diagnostics);

// Получение зависимостей конкретного файла
const fileDependencies = await sdk.dependencies.getFileDependencies(projectId, {
  filePath: 'src/app.js'
});

console.log('Импорты:', fileDependencies.imports);
console.log('Импортируется в:', fileDependencies.importedBy);

// Получение полного графа зависимостей проекта
const dependencyGraph = await sdk.dependencies.getDependencyGraph(projectId);

// Анализ графа зависимостей и поиск циклов
const analysis = await sdk.dependencies.analyzeDependencyGraph(projectId);
console.log('Циклические зависимости:', analysis.cycles);

// Подключение к WebSocket для зависимостей
await sdk.dependencies.connectWebSocket(projectId);
sdk.dependencies.on('dependency_update', (data) => {
  console.log('Обновление зависимостей:', data);
});

const { CodeSolverSDK } = require('solver-sdk');

async function streamThinking() {
  const sdk = new CodeSolverSDK({
    baseURL: 'https://api.example.com',
    apiKey: 'ваш-ключ-api'
  });
  
  // Сообщения для отправки
  const messages = [
    { role: 'user', content: 'Объясни, как работает blockchain' }
  ];
  
  // Опции запроса
  const options = {
    model: 'claude-3-7-sonnet-20240229',
    temperature: 0.7,
    thinking: true,
    authToken: 'your-auth-token' // Унифицированный параметр для аутентификации WebSocket
  };
  
  // Обработчик событий WebSocket
  const handleEvent = (eventType, data) => {
    switch(eventType) {
      case 'content_block_start':
        if (data.content_block && data.content_block.type === 'thinking') {
          console.log('Начало размышлений:');
        }
        break;
        
      case 'content_block_delta':
        if (data.delta && data.delta.type === 'thinking_delta') {
          process.stdout.write(data.delta.thinking); // Потоковый вывод размышлений
        } else if (data.delta && data.delta.type === 'text_delta') {
          process.stdout.write(data.delta.text); // Потоковый вывод итогового текста
        }
        break;
        
      case 'error':
        console.error('Ошибка:', data.message);
        
        // Обработка ошибки географических ограничений
        if (data.type === 'geo_restriction') {
          console.error('Необходимо включить VPN для доступа к API Anthropic из вашего региона');
        }
        break;
    }
  };
  
  try {
    // Отправляем запрос с потоковым мышлением
    const response = await sdk.chat.streamChatWithThinking(
      messages,
      options,
      handleEvent
    );
    
    console.log(`Запрос успешно отправлен. Socket ID: ${response.socketId}`);
  } catch (error) {
    console.error('Ошибка:', error);
    
    // Проверка наличия ошибки географических ограничений
    if (error.type === 'geo_restriction') {
      console.error('Необходимо включить VPN для доступа к API Anthropic из вашего региона');
    }
  }
}

streamThinking();

const sdk = new CodeSolverSDK({
  baseURL: 'https://localhost:3000',
  apiKey: 'test-api-key',
  httpsAgent: new https.Agent({
    rejectUnauthorized: false // Для самоподписанных сертификатов
  }),
  websocket: {
    reconnect: true,
    rejectUnauthorized: false
  }
});