Twitter / X

TWITTER_API_KEY=your_api_key
TWITTER_API_SECRET=your_api_secret
TWITTER_ACCESS_TOKEN=your_access_token
TWITTER_ACCESS_SECRET=your_access_secret
TWITTER_BEARER_TOKEN=your_bearer_token

integrations:
  twitter:
    enabled: true
    credentials:
      api_key: ${TWITTER_API_KEY}
      api_secret: ${TWITTER_API_SECRET}
      access_token: ${TWITTER_ACCESS_TOKEN}
      access_secret: ${TWITTER_ACCESS_SECRET}
      bearer_token: ${TWITTER_BEARER_TOKEN}
    settings:
      # Poll interval for timeline and mention checks (seconds)
      poll_interval: 30
      # Maximum tweet length (default 280)
      max_tweet_length: 280
      # Enable filtered stream for real-time events
      use_filtered_stream: true
      # Rate limit strategy: "queue" buffers requests, "drop" discards excess
      rate_limit_strategy: queue

twitter.on('mention', async (event) => {
  console.log(`@${event.username} mentioned you: ${event.text}`)

  // Auto-reply to mentions
  await twitter.reply(event.tweetId, `Thanks for the mention, @${event.username}!`)
})

twitter.on('dm:received', async (event) => {
  console.log(`DM from @${event.senderUsername}: ${event.text}`)
})

twitter.on('follower:new', async (event) => {
  console.log(`New follower: @${event.username}`)
})

import { Cognest } from '@cognest/sdk'

const cognest = new Cognest()
const twitter = cognest.integration('twitter')

// Monitor brand mentions and respond intelligently
twitter.on('mention', async (event) => {
  // Use the AI engine to analyze sentiment
  const analysis = await cognest.engine.run({
    prompt: `Analyze the sentiment of this tweet and decide if we should reply.
Tweet: "${event.text}"
If positive or neutral, draft a friendly reply under 280 characters.
If negative, draft a professional support-oriented reply.
Return JSON: { "sentiment": "positive"|"negative"|"neutral", "reply": "..." }`,
    responseFormat: 'json',
  })

  const { sentiment, reply } = JSON.parse(analysis.text)

  // Reply to the tweet
  await twitter.reply(event.tweetId, reply)

  // Log for analytics
  console.log(`[${sentiment}] @${event.username}: ${event.text}`)
  console.log(`  Replied: ${reply}`)
})

// Auto-retweet tweets from a curated list of accounts
const CURATED_ACCOUNTS = ['cognestai', 'techleaders', 'airesearchers']

cognest.skill('scheduled-retweet', {
  schedule: '0 */4 * * *', // Every 4 hours
  handler: async () => {
    for (const account of CURATED_ACCOUNTS) {
      const user = await twitter.getUser(account)
      const timeline = await twitter.getTimeline(user.id, { maxResults: 5 })

      for (const tweet of timeline.data) {
        // Only retweet if it matches our topic filter
        const isRelevant = await cognest.engine.run({
          prompt: `Is this tweet relevant to AI automation? Answer yes or no.\nTweet: "${tweet.text}"`,
        })

        if (isRelevant.text.toLowerCase().includes('yes')) {
          await twitter.retweet(tweet.id)
        }
      }
    }
  },
})

// Search for industry discussions and engage
cognest.skill('social-listening', {
  schedule: '*/15 * * * *', // Every 15 minutes
  handler: async () => {
    const results = await twitter.searchTweets(
      '"AI automation" OR "workflow automation" -is:retweet lang:en',
      { maxResults: 10 }
    )

    for (const tweet of results.data) {
      await twitter.like(tweet.id)
    }
  },
})

await cognest.start()
console.log('Twitter bot is running...')