npm install @airtop/sdk
# or
yarn add @airtop/sdk

// Import the Airtop SDK
import { AirtopClient, AirtopError } from "@airtop/sdk";
import type { AirtopSessionConfigV1 } from "@airtop/sdk/wrapper/AirtopSessions";

const AIRTOP_API_KEY = ""; // Replace with your API key from https://portal.airtop.ai/api-keys

async function run() {
  let client: AirtopClient | null = null;
  let sessionId: string | null = null;
  // (optional) Set the profile to use for the session
  const profileName = undefined;
  try {
    if (!AIRTOP_API_KEY) {
      throw new Error("AIRTOP_API_KEY is not set");
    }
    client = new AirtopClient({
      apiKey: AIRTOP_API_KEY,
    });
    // Create a session configuration
    const configuration: AirtopSessionConfigV1 = {
      profileName,
      timeoutMinutes: 10,
    };
    // Create a session
    const session = await client.sessions.create({ configuration });
    if (!session || session.errors) {
      throw Error("Failed to create session");
    }
    sessionId = session.data.id;
    if (profileName) {
      console.log("Using profile:", profileName);
      await client.sessions.saveProfileOnTermination(sessionId, profileName);
    }

    // Create a browser window
    const window = await client.windows.create(session.data.id, { url: "https://www.descript.com/pricing" });
    if (!window.data) {
      throw Error("Failed to create window");
    }
    // Add a wait of 5 secs to allow the page to load
    await new Promise((resolve) => setTimeout(resolve, 5000));
    // Get the window ID
    const { windowId } = window.data;

    // Prompt the page
    const promptResponse = await client.windows.pageQuery(sessionId, windowId, {
      prompt: `[YOUR_PROMPT]`,
    });
    if (promptResponse.errors && promptResponse.errors.length > 0) {
      throw Error("Failed to prompt content");
    }
    console.log("Prompt results", promptResponse.data.modelResponse);

This is a pricing page. Please summarize it concisely by including every plan. 
For each plan, list the price and the top 3 features it includes. 
Compare the current plan to the previous plan described below:

Free Plan: $0 - Includes text-based editing, AI tools trial, and 1 hour of transcription per month.
Hobbyist Plan: $10 per person/month (annual) or $24 (monthly) - Offers 10 transcription hours/month, 1080p export, and 20 uses/month of Basic AI suite. 
Creator Plan: $22 per person/month (annual) or $39 (monthly) - Provides 30 transcription hours/month, 4k export, and unlimited use of Basic and Advanced AI suite. 
Business Plan: $55 per person/month (annual) or $70 (monthly) - Includes 40 transcription hours/month, free Basic seats for collaboration, and unlimited access to Professional AI suite. 
Enterprise Plan: Custom pricing - Tailored solutions with enterprise-grade security.

RETURN ONLY 3 FIELDS:

1. TEXT - A textual description of the pricing, including the plan's name, price, and top 3 features.

2. TEXT - If there are significant differences in the PRICES between the previous plan and the current one, 
  summarize the differences concisely in a textual description, focusing only on the changes in prices.

3. STATUS - In a status field, return [DIFF] if the new plan is substantially different from the previous one, 
  [SIMILAR] if they are similar, or [NEW] if the previous pricing is empty.

- important, do not guess or estimate, just report things that are clearly mentioned in pricing page

  } catch (err) {
    if (err instanceof AirtopError) {
      console.log(err.statusCode);
      console.log(err.message);
      console.log(err.body);
    } else {
      console.log(err);
    }
    throw err;
  } finally {
    // Terminate the session
    if (client != null && sessionId != null) {
      await client.sessions.terminate(sessionId);
    }
  }
}
run().catch((err) => {
  process.exit(1);
});

const competitorUrls = [
  "https://www.competitor1.com/pricing",
  "https://www.competitor2.com/pricing",
  "https://www.competitor3.com/pricing"
];
for (const url of competitorUrls) {
  // Create a new window for each URL
  const window = await client.windows.create(sessionId, { url });
  // ... rest of the code
}

import cron from 'node-cron';
// Schedule the task to run every day at 9 AM
cron.schedule('0 9 * * *', () => {
  console.log('Running price monitoring job');
  run().catch(console.error);
});

import { PrismaClient } from '@prisma/client';
const prisma = new PrismaClient();
async function storeResults(competitorName: string, pricingData: string, status: string) {
  await prisma.pricingHistory.create({
    data: {
      competitor: competitorName,
      pricingData,
      status,
      timestamp: new Date()
    }
  });
}

// schema.prisma
model PricingHistory {
  id          Int      @id @default(autoincrement())
  competitor  String
  pricingData String   @db.Text
  status      String
  timestamp   DateTime @default(now())
}

import nodemailer from 'nodemailer';
async function sendNotification(subject: string, message: string) {
  const transporter = nodemailer.createTransport({
    host: 'smtp.example.com',
    port: 587,
    secure: false,
    auth: {
      user: 'your-email@example.com',
      pass: 'your-password'
    }
  });
  await transporter.sendMail({
    from: 'your-email@example.com',
    to: 'recipient@example.com',
    subject,
    text: message
  });
}

import axios from 'axios';
async function sendSlackNotification(message: string) {
  const webhookUrl = 'YOUR_SLACK_WEBHOOK_URL';
  
  await axios.post(webhookUrl, {
    text: message
  });
}

async function monitorCompetitor(url: string, competitorName: string, previousData?: string) {
  const client = new AirtopClient({
    apiKey: AIRTOP_API_KEY,
  });
  
  let sessionId: string | null = null;
  
  try {
    // Create session
    const session = await client.sessions.create({ 
      configuration: { timeoutMinutes: 10 } 
    });
    sessionId = session.data.id;
    
    // Create window
    const window = await client.windows.create(sessionId, { url });
    const { windowId } = window.data;
    
    // Wait for page to load
    await new Promise((resolve) => setTimeout(resolve, 5000));
    
    // Query the page
    const promptResponse = await client.windows.pageQuery(sessionId, windowId, {
      prompt: `This is a pricing page. Please summarize it concisely by including every plan. For each plan, list the price and the top 3 features it includes. Compare the current plan to the previous plan described below:
"${previousData || ''}"
RETURN ONLY 3 FIELDS:
1. TEXT - A textual description of the pricing, including the plan's name, price, and top 3 features.
2. TEXT - If there are significant differences in the PRICES between the previous plan and the current one, summarize the differences concisely in a textual description, focusing only on the changes in prices.
3. STATUS - In a status field, return [DIFF] if the new plan is substantially different from the previous one, [SIMILAR] if they are similar, or [NEW] if the previous pricing is empty.
`
    });
    
    const result = promptResponse.data.modelResponse;
    
    // Parse the result
    const statusMatch = result.match(/STATUS: \[(.*?)\]/);
    const status = statusMatch ? statusMatch[1] : 'UNKNOWN';
    
    // Store the result
    await storeResults(competitorName, result, status);
    
    // If there's a change, send notification
    if (status === 'DIFF') {
      await sendNotification(
        `Price Change Detected: ${competitorName}`,
        `A price change has been detected for ${competitorName}.\n\nDetails:\n${result}`
      );
      
      await sendSlackNotification(
        `🚨 *Price Change Alert*: ${competitorName}\n\n${result}`
      );
    }
    
    return result;
  } finally {
    // Clean up
    if (sessionId) {
      await client.sessions.terminate(sessionId);
    }
  }
}