Upload 3 files

crypto_tools.py

@@ -0,0 +1,57 @@
+from langchain.tools import tool
+import requests
+import pandas as pd
+import numpy as np
+
+class CryptoTools:
+    @tool("Get Cryptocurrency Price")
+    def get_crypto_price(crypto):
+        """Fetches the current price of a given cryptocurrency."""
+        url = f"https://api.coingecko.com/api/v3/simple/price?ids={crypto}&vs_currencies=usd"
+        response = requests.get(url)
+        if response.status_code == 200:
+            data = response.json()
+            return data[crypto]['usd']
+        else:
+            return "Error fetching price data"
+
+    @tool("Get Market Cap")
+    def get_market_cap(crypto):
+        """Fetches the current market cap of a given cryptocurrency."""
+        url = f"https://api.coingecko.com/api/v3/coins/{crypto}"
+        response = requests.get(url)
+        if response.status_code == 200:
+            data = response.json()
+            return data['market_data']['market_cap']['usd']
+        else:
+            return "Error fetching market cap data"
+
+    @tool("Calculate RSI")
+    def calculate_rsi(crypto, period=14):
+        """Calculates the Relative Strength Index (RSI) for a given cryptocurrency."""
+        url = f"https://api.coingecko.com/api/v3/coins/{crypto}/market_chart?vs_currency=usd&days={period}"
+        response = requests.get(url)
+        if response.status_code == 200:
+            data = response.json()
+            prices = [price[1] for price in data['prices']]
+            df = pd.DataFrame(prices, columns=['price'])
+            delta = df['price'].diff()
+            gain = (delta.where(delta > 0, 0)).rolling(window=period).mean()
+            loss = (-delta.where(delta < 0, 0)).rolling(window=period).mean()
+            rs = gain / loss
+            rsi = 100 - (100 / (1 + rs))
+            return rsi.iloc[-1]
+        else:
+            return "Error calculating RSI"
+
+    @tool("Calculate Moving Average")
+    def calculate_moving_average(crypto, days):
+        """Calculates the moving average for a given cryptocurrency over a specified number of days."""
+        url = f"https://api.coingecko.com/api/v3/coins/{crypto}/market_chart?vs_currency=usd&days={days}"
+        response = requests.get(url)
+        if response.status_code == 200:
+            data = response.json()
+            prices = [price[1] for price in data['prices']]
+            return np.mean(prices)
+        else:
+            return "Error calculating moving average"

news_tools.py

@@ -0,0 +1,14 @@
+from langchain.tools import tool
+import requests
+
+class NewsTools:
+    @tool("Search Crypto News")
+    def search_crypto_news(query):
+        """Searches for cryptocurrency news articles based on a given query."""
+        url = f"https://cryptonews-api.com/api/v1/category?section=general&items=10&token=YOUR_API_KEY&q={query}"
+        response = requests.get(url)
+        if response.status_code == 200:
+            articles = response.json()['data']
+            return [{'title': article['title'], 'source': article['source_name'], 'url': article['news_url']} for article in articles]
+        else:
+            return "Error fetching news data"

sentiment_tools.py

@@ -0,0 +1,15 @@
+from langchain.tools import tool
+from textblob import TextBlob
+
+class SentimentTools:
+    @tool("Analyze Sentiment")
+    def analyze_sentiment(text):
+        """Analyzes the sentiment of a given text."""
+        blob = TextBlob(text)
+        sentiment = blob.sentiment.polarity
+        if sentiment > 0:
+            return "Positive"
+        elif sentiment < 0:
+            return "Negative"
+        else:
+            return "Neutral"