Realtime Trend Data

// register a trend data provider for Elon Musk's X/Twitter account
$this->_elonMuskX = $this->addTrendDataProvider("elonMuskX", new XTrendDataProvider("elonmusk"));
// register a trend data provider for Telegram channel CatfishcallsbyPoe
$this->_catfishcallsByPoeTelegram = $this->addTrendDataProvider("catfishcallsByPoeTelegram", new TelegramTrendDataProvider("CatfishcallsbyPoe"));

function getSignalInfo(TradeContext $tradeContext):?TradeSignalInfo
{
	if ($this->_elonMuskX->hasNewData())
	{
		$xPost = $this->_elonMuskX->getLatestContent();

		if (str_contains($xPost, "DOGE"))
		{
			// do something
		}
	}

	if ($this->_catfishcallsByPoeTelegram->hasNewData())
	{
		$telegramMessage = $this->_catfishcallsByPoeTelegram->getLatestContent();

		if (str_contains($telegramMessage, "BAI"))
		{
			// do something
		}
	}

	...
}

class MultiTrendDataExample extends UserTradeSignalBase
{
	private ?XTrendDataProvider $_elonMuskX = null;
	private ?TelegramTrendDataProvider $_catfishcallsByPoeTelegram = null;

	protected function init(?ParamValues $params = null)
	{
		// register a trend data provider for Elon Musk's X/Twitter account
		$this->_elonMuskX = $this->addTrendDataProvider("elonMuskX", new XTrendDataProvider("elonmusk"));
		// register a trend data provider for Telegram channel CatfishcallsbyPoe
		$this->_catfishcallsByPoeTelegram = $this->addTrendDataProvider("catfishcallsByPoeTelegram", new TelegramTrendDataProvider("CatfishcallsbyPoe"));
	}

	function getSignalInfo(TradeContext $tradeContext):?TradeSignalInfo
	{
		if ($this->_elonMuskX->hasNewData())
		{
			$xPost = $this->_elonMuskX->getLatestContent();

			if (str_contains($xPost, "DOGE"))
			{
				// do something
			}
		}

		if ($this->_catfishcallsByPoeTelegram->hasNewData())
		{
			$telegramMessage = $this->_catfishcallsByPoeTelegram->getLatestContent();

			if (str_contains($telegramMessage, "BAI"))
			{
				// do something
			}
		}

		...
	}
}

new XTrendDataProvider(twitterUsername); // hasNewData() triggers on new tweets
new YouTubeTrendDataProvider(channelName); // hasNewData() triggers on new video uploads
new TelegramTrendDataProvider(channelName); // hasNewData() triggers on new messages
new RedditTrendDataProvider(subredditName); // hasNewData() triggers on new posts
new WebsiteTrendDataProvider(websiteUrl); // hasNewData() is not supported. Call getLatestContent() to crawl the website's content
new RSSTrendDataProvider(feedUrl); // hasNewData() triggers on new feed items
new TradingViewTrendDataProvider(alertName); // hasNewData() triggers on new alerts
new WebhookTrendDataProvider(webhookUrl); // hasNewData() triggers on new webhook calls

interface ITrendDataProvider
{
	// returns true if new data is available
	function hasNewData():bool;

	// returns the latest content
	// NOTE: there could be multiple new contents available since the last call to hasNewData().
	// Use getPreviousContentId() to get the content id of the last fetched content and getContent(x) to iterate over all new contents if needed.
	function getLatestContent():string;

	// returns the content id of the getLatestContent() content
	function getLatestContentId():int

	// returns the content id of the last call to hasNewData()
	function getPreviousContentId():string;

	// returns the content of the specified id
	function getContent(int $id):int;
}