mirror of
https://gitlab.com/simple-stock-bots/simple-stock-bot.git
synced 2026-06-03 21:00:26 +00:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 187714f8d0 |
@@ -13,7 +13,7 @@ COPY --from=builder /root/.local /root/.local
|
|||||||
|
|
||||||
RUN pip install --no-cache-dir black
|
RUN pip install --no-cache-dir black
|
||||||
ENV TELEGRAM=TOKEN
|
ENV TELEGRAM=TOKEN
|
||||||
ENV MARKETDATA=TOKEN
|
ENV IEX=TOKEN
|
||||||
|
|
||||||
COPY . .
|
COPY . .
|
||||||
|
|
||||||
|
|||||||
+6
-18
@@ -1,6 +1,10 @@
|
|||||||
|
"""Class with functions for running the bot with IEX Cloud.
|
||||||
|
"""
|
||||||
|
|
||||||
import logging
|
import logging
|
||||||
import os
|
import os
|
||||||
import datetime as dt
|
import datetime as dt
|
||||||
|
from logging import warning
|
||||||
from typing import Dict
|
from typing import Dict
|
||||||
|
|
||||||
import pandas as pd
|
import pandas as pd
|
||||||
@@ -9,8 +13,6 @@ import schedule
|
|||||||
|
|
||||||
from Symbol import Stock
|
from Symbol import Stock
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class MarketData:
|
class MarketData:
|
||||||
"""
|
"""
|
||||||
@@ -36,9 +38,7 @@ class MarketData:
|
|||||||
self.MARKETDATA_TOKEN = ""
|
self.MARKETDATA_TOKEN = ""
|
||||||
except KeyError:
|
except KeyError:
|
||||||
self.MARKETDATA_TOKEN = ""
|
self.MARKETDATA_TOKEN = ""
|
||||||
log.warning("Starting without an MarketData.app Token will not allow you to get market data!")
|
warning("Starting without an MarketData.app Token will not allow you to get market data!")
|
||||||
log.warning("Use this affiliate link so that the bot can stay free:")
|
|
||||||
log.warning("https://dashboard.marketdata.app/marketdata/aff/go/misterbiggs?keyword=repo")
|
|
||||||
|
|
||||||
if self.MARKETDATA_TOKEN != "":
|
if self.MARKETDATA_TOKEN != "":
|
||||||
schedule.every().day.do(self.clear_charts)
|
schedule.every().day.do(self.clear_charts)
|
||||||
@@ -47,11 +47,7 @@ class MarketData:
|
|||||||
url = "https://api.marketdata.app/v1/" + endpoint
|
url = "https://api.marketdata.app/v1/" + endpoint
|
||||||
|
|
||||||
# set token param if it wasn't passed.
|
# set token param if it wasn't passed.
|
||||||
params["token"] = self.MARKETDATA_TOKEN
|
params["token"] = params.get("token", self.MARKETDATA_TOKEN)
|
||||||
|
|
||||||
# Undocumented query variable that ensures bot usage can be
|
|
||||||
# monitored even if someone doesn't make it through an affiliate link.
|
|
||||||
params["application"] = "simplestockbot"
|
|
||||||
|
|
||||||
resp = r.get(url, params=params, timeout=timeout)
|
resp = r.get(url, params=params, timeout=timeout)
|
||||||
|
|
||||||
@@ -141,14 +137,6 @@ class MarketData:
|
|||||||
else:
|
else:
|
||||||
return f"Getting a quote for {symbol} encountered an error."
|
return f"Getting a quote for {symbol} encountered an error."
|
||||||
|
|
||||||
def spark_reply(self, symbol: Stock) -> str:
|
|
||||||
if quoteResp := self.get(f"stocks/quotes/{symbol}/"):
|
|
||||||
changePercent = round(quoteResp["changepct"][0], 2)
|
|
||||||
return f"`{symbol.tag}`: {changePercent}%"
|
|
||||||
else:
|
|
||||||
logging.warning(f"{symbol} did not have 'changepct' field.")
|
|
||||||
return f"`{symbol.tag}`"
|
|
||||||
|
|
||||||
def intra_reply(self, symbol: Stock) -> pd.DataFrame:
|
def intra_reply(self, symbol: Stock) -> pd.DataFrame:
|
||||||
"""Returns price data for a symbol of the past month up until the previous trading days close.
|
"""Returns price data for a symbol of the past month up until the previous trading days close.
|
||||||
Also caches multiple requests made in the same day.
|
Also caches multiple requests made in the same day.
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ https://docs.simplestockbot.com/commands/
|
|||||||
|
|
||||||
## Donate
|
## Donate
|
||||||
|
|
||||||
Simple Stock Bot is run entirely on donations, and costs about $420 a year to run. All donations go directly towards paying for servers, and premium market data provided by [marketdata.app](https://dashboard.marketdata.app/marketdata/aff/go/misterbiggs?keyword=repo).
|
Simple Stock Bot is run entirely on donations, and costs about $420 a year to run. All donations go directly towards paying for servers, and premium market data provided by [IEX Cloud](https://iexcloud.io/).
|
||||||
|
|
||||||
The best way to donate is through [Buy Me A Coffee](https://www.buymeacoffee.com/Anson) which accepts Paypal or Credit card.
|
The best way to donate is through [Buy Me A Coffee](https://www.buymeacoffee.com/Anson) which accepts Paypal or Credit card.
|
||||||
|
|
||||||
@@ -29,4 +29,4 @@ If you have any questions get in [touch.](contact.md)
|
|||||||
- Contribute to the project on [GitLab](https://gitlab.com/simple-stock-bots) or just leave a star
|
- Contribute to the project on [GitLab](https://gitlab.com/simple-stock-bots) or just leave a star
|
||||||
- Using my referral links to host your own Bot
|
- Using my referral links to host your own Bot
|
||||||
- [DigitalOcean](https://m.do.co/c/6b5df7ef55b6)
|
- [DigitalOcean](https://m.do.co/c/6b5df7ef55b6)
|
||||||
- [marketdata.app](https://dashboard.marketdata.app/marketdata/aff/go/misterbiggs?keyword=repo)
|
- [IEX Cloud](https://iexcloud.io/s/62c8503e)
|
||||||
|
|||||||
@@ -16,8 +16,6 @@ class T_info:
|
|||||||
help_text = """
|
help_text = """
|
||||||
Thanks for using this bot, consider supporting it by [buying me a beer.](https://www.buymeacoffee.com/Anson)
|
Thanks for using this bot, consider supporting it by [buying me a beer.](https://www.buymeacoffee.com/Anson)
|
||||||
|
|
||||||
If you are interested in stock market data, or want to host your own bot, be sure to use my affiliate link so that the bot can stay free: [marketdata.app](https://dashboard.marketdata.app/marketdata/aff/go/misterbiggs?keyword=telegram)
|
|
||||||
|
|
||||||
Keep up with the latest news for the bot in its Telegram Channel: https://t.me/simplestockbotnews
|
Keep up with the latest news for the bot in its Telegram Channel: https://t.me/simplestockbotnews
|
||||||
|
|
||||||
Full documentation on using and running your own stock bot can be found on the bots [docs.](https://docs.simplestockbot.com)
|
Full documentation on using and running your own stock bot can be found on the bots [docs.](https://docs.simplestockbot.com)
|
||||||
@@ -28,15 +26,20 @@ Simply calling a symbol in any message that the bot can see will also return the
|
|||||||
|
|
||||||
**Commands**
|
**Commands**
|
||||||
- `/donate [amount in USD]` to donate. 🎗️
|
- `/donate [amount in USD]` to donate. 🎗️
|
||||||
|
- `/dividend $[symbol]` Dividend information for the symbol. 📅
|
||||||
- `/intra $[symbol]` Plot of the stocks movement since the last market open. 📈
|
- `/intra $[symbol]` Plot of the stocks movement since the last market open. 📈
|
||||||
- `/chart $[symbol]` Plot of the stocks movement for the past 1 month. 📊
|
- `/chart $[symbol]` Plot of the stocks movement for the past 1 month. 📊
|
||||||
|
- `/news $[symbol]` News about the symbol. 📰
|
||||||
|
- `/info $[symbol]` General information about the symbol. ℹ️
|
||||||
|
- `/stat $[symbol]` Key statistics about the symbol. 🔢
|
||||||
|
- `/cap $[symbol]` Market Capitalization of symbol. 💰
|
||||||
- `/trending` Trending Stocks and Cryptos. 💬
|
- `/trending` Trending Stocks and Cryptos. 💬
|
||||||
- `/help` Get some help using the bot. 🆘
|
- `/help` Get some help using the bot. 🆘
|
||||||
|
|
||||||
**Inline Features**
|
**Inline Features**
|
||||||
You can type @SimpleStockBot `[search]` in any chat or direct message to search for the stock bots full list of stock and crypto symbols and return the price. Then once you select the ticker want the bot will send a message as you in that chat with the latest stock price. Prices may be delayed by up to an hour.
|
You can type @SimpleStockBot `[search]` in any chat or direct message to search for the stock bots full list of stock and crypto symbols and return the price. Then once you select the ticker want the bot will send a message as you in that chat with the latest stock price. Prices may be delayed by up to an hour.
|
||||||
|
|
||||||
Market data is provided by [marketdata.app](https://dashboard.marketdata.app/marketdata/aff/go/misterbiggs?keyword=telegram)
|
Market data is provided by [IEX Cloud](https://iexcloud.io)
|
||||||
|
|
||||||
If you believe the bot is not behaving properly run `/status` or [get in touch](https://docs.simplestockbot.com/contact).
|
If you believe the bot is not behaving properly run `/status` or [get in touch](https://docs.simplestockbot.com/contact).
|
||||||
"""
|
"""
|
||||||
@@ -44,22 +47,27 @@ Simply calling a symbol in any message that the bot can see will also return the
|
|||||||
donate_text = """
|
donate_text = """
|
||||||
Simple Stock Bot is run entirely on donations[.](https://www.buymeacoffee.com/Anson)
|
Simple Stock Bot is run entirely on donations[.](https://www.buymeacoffee.com/Anson)
|
||||||
All donations go directly towards paying for servers, and market data is provided by
|
All donations go directly towards paying for servers, and market data is provided by
|
||||||
[marketdata.app](https://dashboard.marketdata.app/marketdata/aff/go/misterbiggs?keyword=telegram).
|
[IEX Cloud](https://iexcloud.io/).
|
||||||
|
|
||||||
The easiest way to donate is to run the `/donate [amount in USD]` command with US dollars you would like to donate.
|
The easiest way to donate is to run the `/donate [amount in USD]` command with US dollars you would like to donate.
|
||||||
|
|
||||||
Example: `/donate 2` would donate 2 USD.
|
Example: `/donate 2` would donate 2 USD.
|
||||||
|
|
||||||
An alternative way to donate is through https://www.buymeacoffee.com/Anson which requires no account and accepts Paypal or Credit card.
|
An alternative way to donate is through https://www.buymeacoffee.com/Anson which requires no account and accepts Paypal or Credit card.
|
||||||
If you have any questions see the [website](https://docs.simplestockbot.com)
|
If you have any questions see the [website](https:docs.simplestockbot.com)
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
|
||||||
commands = """ # Not used by the bot but for updating commands with BotFather
|
commands = """
|
||||||
donate - Donate to the bot 🎗️
|
donate - Donate to the bot 🎗️
|
||||||
help - Get some help using the bot. 🆘
|
help - Get some help using the bot. 🆘
|
||||||
|
info - $[symbol] General information about the symbol. ℹ️
|
||||||
|
news - $[symbol] News about the symbol. 📰
|
||||||
|
stat - $[symbol] Key statistics about the symbol. 🔢
|
||||||
|
cap - $[symbol] Market Capitalization of symbol. 💰
|
||||||
|
dividend - $[symbol] Dividend info 📅
|
||||||
trending - Trending Stocks and Cryptos. 💬
|
trending - Trending Stocks and Cryptos. 💬
|
||||||
intra - $[symbol] Plot since the last market open. 📈
|
intra - $[symbol] Plot since the last market open. 📈
|
||||||
chart - $[chart] Plot of the past month. 📊
|
chart - $[chart] Plot of the past month. 📊
|
||||||
"""
|
""" # Not used by the bot but for updaing commands with BotFather
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import os
|
|||||||
import random
|
import random
|
||||||
import string
|
import string
|
||||||
import traceback
|
import traceback
|
||||||
|
import logging as log
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
|
|
||||||
import mplfinance as mpf
|
import mplfinance as mpf
|
||||||
@@ -31,10 +32,6 @@ from telegram.ext import (
|
|||||||
from symbol_router import Router
|
from symbol_router import Router
|
||||||
from T_info import T_info
|
from T_info import T_info
|
||||||
|
|
||||||
# Enable logging
|
|
||||||
logging.basicConfig(format="%(asctime)s - %(name)s - %(levelname)s - %(message)s", level=logging.INFO)
|
|
||||||
log = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
TELEGRAM_TOKEN = os.environ["TELEGRAM"]
|
TELEGRAM_TOKEN = os.environ["TELEGRAM"]
|
||||||
|
|
||||||
try:
|
try:
|
||||||
@@ -46,7 +43,10 @@ except KeyError:
|
|||||||
s = Router()
|
s = Router()
|
||||||
t = T_info()
|
t = T_info()
|
||||||
|
|
||||||
|
# Enable logging
|
||||||
|
logging.basicConfig(format="%(asctime)s - %(name)s - %(levelname)s - %(message)s", level=logging.INFO)
|
||||||
|
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
log.info("Bot script started.")
|
log.info("Bot script started.")
|
||||||
|
|
||||||
|
|
||||||
@@ -304,6 +304,7 @@ def trending(update: Update, context: CallbackContext):
|
|||||||
context.bot.send_chat_action(chat_id=chat_id, action=telegram.ChatAction.TYPING)
|
context.bot.send_chat_action(chat_id=chat_id, action=telegram.ChatAction.TYPING)
|
||||||
|
|
||||||
trending_list = s.trending()
|
trending_list = s.trending()
|
||||||
|
log.info(trending_list)
|
||||||
|
|
||||||
update.message.reply_text(
|
update.message.reply_text(
|
||||||
text=trending_list,
|
text=trending_list,
|
||||||
@@ -379,21 +380,22 @@ def error(update: Update, context: CallbackContext):
|
|||||||
log.warning(f"Logging error: {err_code}")
|
log.warning(f"Logging error: {err_code}")
|
||||||
|
|
||||||
if update:
|
if update:
|
||||||
log.warning(
|
message = (
|
||||||
f"An exception was raised while handling an update\n"
|
f"An exception was raised while handling an update\n"
|
||||||
f"\tupdate = {html.escape(json.dumps(update.to_dict(), indent=2, ensure_ascii=False))}\n"
|
f"<pre>update = {html.escape(json.dumps(update.to_dict(), indent=2, ensure_ascii=False))}"
|
||||||
f"\tcontext.chat_data = {str(context.chat_data)}\n"
|
"</pre>\n\n"
|
||||||
f"\tcontext.user_data = {str(context.user_data)}\n"
|
f"<pre>context.chat_data = {html.escape(str(context.chat_data))}</pre>\n\n"
|
||||||
f"\t{html.escape(tb_string)}"
|
f"<pre>context.user_data = {html.escape(str(context.user_data))}</pre>\n\n"
|
||||||
|
f"<pre>{html.escape(tb_string)}</pre>"
|
||||||
)
|
)
|
||||||
|
log.warning(message)
|
||||||
|
else:
|
||||||
|
log.warning(tb_string)
|
||||||
|
|
||||||
update.message.reply_text(
|
update.message.reply_text(
|
||||||
text=f"An error has occured. Please inform @MisterBiggs if the error persists. Error Code: `{err_code}`",
|
text=f"An error has occured. Please inform @MisterBiggs if the error persists. Error Code: `{err_code}`",
|
||||||
parse_mode=telegram.ParseMode.MARKDOWN,
|
parse_mode=telegram.ParseMode.MARKDOWN,
|
||||||
)
|
)
|
||||||
else:
|
|
||||||
log.warning("No message to send to user.")
|
|
||||||
log.warning(tb_string)
|
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
|
|||||||
+11
-3
@@ -1,4 +1,7 @@
|
|||||||
import logging
|
"""Class with functions for running the bot with IEX Cloud.
|
||||||
|
"""
|
||||||
|
|
||||||
|
import logging as log
|
||||||
from typing import List
|
from typing import List
|
||||||
|
|
||||||
import pandas as pd
|
import pandas as pd
|
||||||
@@ -8,8 +11,6 @@ from markdownify import markdownify
|
|||||||
|
|
||||||
from Symbol import Coin
|
from Symbol import Coin
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class cg_Crypto:
|
class cg_Crypto:
|
||||||
"""
|
"""
|
||||||
@@ -21,6 +22,13 @@ class cg_Crypto:
|
|||||||
trending_cache: List[str] = []
|
trending_cache: List[str] = []
|
||||||
|
|
||||||
def __init__(self) -> None:
|
def __init__(self) -> None:
|
||||||
|
"""Creates a Symbol Object
|
||||||
|
|
||||||
|
Parameters
|
||||||
|
----------
|
||||||
|
IEX_TOKEN : str
|
||||||
|
IEX Token
|
||||||
|
"""
|
||||||
self.get_symbol_list()
|
self.get_symbol_list()
|
||||||
schedule.every().day.do(self.get_symbol_list)
|
schedule.every().day.do(self.get_symbol_list)
|
||||||
|
|
||||||
|
|||||||
@@ -4,4 +4,3 @@ flake8==5.0.4
|
|||||||
Flake8-pyproject==1.2.3
|
Flake8-pyproject==1.2.3
|
||||||
pylama==8.4.1
|
pylama==8.4.1
|
||||||
mypy==1.2.0
|
mypy==1.2.0
|
||||||
types-cachetools==5.3.0.5
|
|
||||||
+13
-7
@@ -5,6 +5,7 @@ import datetime
|
|||||||
import logging
|
import logging
|
||||||
import random
|
import random
|
||||||
import re
|
import re
|
||||||
|
import logging as log
|
||||||
|
|
||||||
import pandas as pd
|
import pandas as pd
|
||||||
import schedule
|
import schedule
|
||||||
@@ -16,8 +17,6 @@ from Symbol import Coin, Stock, Symbol
|
|||||||
|
|
||||||
from typing import Dict
|
from typing import Dict
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class Router:
|
class Router:
|
||||||
STOCK_REGEX = "(?:^|[^\\$])\\$([a-zA-Z.]{1,6})"
|
STOCK_REGEX = "(?:^|[^\\$])\\$([a-zA-Z.]{1,6})"
|
||||||
@@ -78,9 +77,9 @@ class Router:
|
|||||||
else:
|
else:
|
||||||
symbols.append(Coin(sym))
|
symbols.append(Coin(sym))
|
||||||
if symbols:
|
if symbols:
|
||||||
|
log.info(symbols)
|
||||||
for symbol in symbols:
|
for symbol in symbols:
|
||||||
self.trending_count[symbol.tag] = self.trending_count.get(symbol.tag, 0) + trending_weight
|
self.trending_count[symbol.tag] = self.trending_count.get(symbol.tag, 0) + trending_weight
|
||||||
log.warning(self.trending_count)
|
|
||||||
|
|
||||||
return symbols
|
return symbols
|
||||||
|
|
||||||
@@ -304,7 +303,8 @@ class Router:
|
|||||||
|
|
||||||
for symbol in symbols:
|
for symbol in symbols:
|
||||||
if isinstance(symbol, Stock):
|
if isinstance(symbol, Stock):
|
||||||
replies.append(self.stock.spark_reply(symbol))
|
replies.append("Command not supported for stocks.")
|
||||||
|
# replies.append(self.stock.spark_reply(symbol))
|
||||||
elif isinstance(symbol, Coin):
|
elif isinstance(symbol, Coin):
|
||||||
replies.append(self.crypto.spark_reply(symbol))
|
replies.append(self.crypto.spark_reply(symbol))
|
||||||
else:
|
else:
|
||||||
@@ -322,21 +322,26 @@ class Router:
|
|||||||
List of preformatted strings to be sent to user.
|
List of preformatted strings to be sent to user.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
# stocks = self.stock.trending()
|
stocks = self.stock.trending()
|
||||||
coins = self.crypto.trending()
|
coins = self.crypto.trending()
|
||||||
|
|
||||||
reply = ""
|
reply = ""
|
||||||
|
|
||||||
log.warning(self.trending_count)
|
|
||||||
if self.trending_count:
|
if self.trending_count:
|
||||||
reply += "🔥Trending on the Stock Bot:\n`"
|
reply += "🔥Trending on the Stock Bot:\n`"
|
||||||
reply += "━" * len("Trending on the Stock Bot:") + "`\n"
|
reply += "━" * len("Trending on the Stock Bot:") + "`\n"
|
||||||
|
|
||||||
sorted_trending = [s[0] for s in sorted(self.trending_count.items(), key=lambda item: item[1])][::-1][0:5]
|
sorted_trending = [s[0] for s in sorted(self.trending_count.items(), key=lambda item: item[1])][::-1][0:5]
|
||||||
log.warning(sorted_trending)
|
|
||||||
for t in sorted_trending:
|
for t in sorted_trending:
|
||||||
reply += self.spark_reply(self.find_symbols(t))[0] + "\n"
|
reply += self.spark_reply(self.find_symbols(t))[0] + "\n"
|
||||||
|
|
||||||
|
if stocks:
|
||||||
|
reply += "\n\n💵Trending Stocks:\n`"
|
||||||
|
reply += "━" * len("Trending Stocks:") + "`\n"
|
||||||
|
for stock in stocks:
|
||||||
|
reply += stock + "\n"
|
||||||
|
|
||||||
if coins:
|
if coins:
|
||||||
reply += "\n\n🦎Trending Crypto:\n`"
|
reply += "\n\n🦎Trending Crypto:\n`"
|
||||||
reply += "━" * len("Trending Crypto:") + "`\n"
|
reply += "━" * len("Trending Crypto:") + "`\n"
|
||||||
@@ -385,6 +390,7 @@ class Router:
|
|||||||
log.debug(f"{symbol} is not a Stock or Coin")
|
log.debug(f"{symbol} is not a Stock or Coin")
|
||||||
|
|
||||||
if stocks:
|
if stocks:
|
||||||
|
# IEX batch endpoint doesnt seem to be working right now
|
||||||
for stock in stocks:
|
for stock in stocks:
|
||||||
replies.append(self.stock.price_reply(stock))
|
replies.append(self.stock.price_reply(stock))
|
||||||
if coins:
|
if coins:
|
||||||
|
|||||||
Reference in New Issue
Block a user