X Live Search

// Import the ATXP client SDK and Base account
import { atxpClient } from '@atxp/client';
import { BaseAccount } from '@atxp/base';

// Read the Base account details from the environment variables
const baseRpcUrl = process.env.BASE_RPC_URL;
const basePrivateKey = process.env.BASE_PRIVATE_KEY;

// Create a client using the `atxpClient` function
const client = await atxpClient({
  mcpServer: xLiveSearchService.mcpServer,
  account: new BaseAccount(baseRpcUrl, basePrivateKey),
});

// Import the ATXP client SDK and Solana account
import { atxpClient } from '@atxp/client';
import { SolanaAccount } from '@atxp/solana';

// Read the Solana account details from the environment variables
const solanaRpcUrl = process.env.SOLANA_RPC_URL;
const solanaPrivateKey = process.env.SOLANA_PRIVATE_KEY;

// Create a client using the `atxpClient` function
const client = await atxpClient({
  mcpServer: xLiveSearchService.mcpServer,
  account: new SolanaAccount(solanaRpcUrl, solanaPrivateKey),
});

// Import the ATXP client SDK and Worldchain account creator
import { atxpClient } from '@atxp/client';
import { createMiniKitWorldchainAccount } from '@atxp/worldchain';
import { MiniKit } from '@worldcoin/minikit-js';

// Create a Worldchain account using MiniKit
const account = await createMiniKitWorldchainAccount({
  walletAddress: '0x1234...', // User's wallet address
  miniKit: MiniKit
});

// Create a client using the `atxpClient` function
const client = await atxpClient({
  mcpServer: xLiveSearchService.mcpServer,
  account,
});

// Import the ATXP client SDK and Polygon browser account
import { atxpClient } from '@atxp/client';
import { PolygonBrowserAccount } from '@atxp/polygon';

// Initialize the Polygon browser account with wallet provider
const account = await PolygonBrowserAccount.initialize({
  provider: window.ethereum, // or any EIP-1193 provider
  walletAddress: '0x1234...', // User's wallet address
});

// Create a client using the `atxpClient` function
const client = await atxpClient({
  mcpServer: xLiveSearchService.mcpServer,
  account,
});

// Import the ATXP client SDK and Polygon server account
import { atxpClient } from '@atxp/client';
import { PolygonServerAccount } from '@atxp/polygon';

// Read the Polygon account details from the environment variables
const polygonRpcUrl = process.env.POLYGON_RPC_URL;
const polygonPrivateKey = process.env.POLYGON_PRIVATE_KEY;

// Create a Polygon server account
const account = new PolygonServerAccount(
  polygonRpcUrl,
  polygonPrivateKey,
  137 // Chain ID: 137 = Polygon mainnet, 80002 = Amoy testnet
);

// Create a client using the `atxpClient` function
const client = await atxpClient({
  mcpServer: xLiveSearchService.mcpServer,
  account,
});

const searchParams = {
  query: "What are the latest updates from Stripe?",
  allowed_x_handles: ["stripe"],
  from_date: "2024-01-01",
  min_likes: 100  // Only show posts with at least 100 likes
};

try {
  // Start async search
  const asyncResult = await client.callTool({
      name: xLiveSearchService.asyncSearchToolName,
      arguments: xLiveSearchService.getArguments(searchParams),
  });
  const { taskId } = xLiveSearchService.getAsyncCreateResult(asyncResult);
  console.log('Search started with task ID:', taskId);

  // Poll for completion
  let completed = false;
  while (!completed) {
    await new Promise(resolve => setTimeout(resolve, 5000)); // Wait 5 seconds

    const statusResult = await client.callTool({
        name: xLiveSearchService.getSearchAsyncToolName,
        arguments: { taskId },
    });
    const { status, result, error } = xLiveSearchService.getAsyncStatusResult(statusResult);

    console.log('Status:', status);

    if (status === 'completed') {
      console.log('Query:', result.query);
      console.log('Summary:', result.message);
      console.log('Citations:', result.citations);
      console.log('Tool Calls:', result.toolCalls); // See what the agent did
      completed = true;
    } else if (status === 'error') {
      console.error('Search failed:', error);
      completed = true;
    }
  }
} catch (error) {
  console.error(`Error with ${xLiveSearchService.description}:`, error);
  process.exit(1);
}