/
main.py
65 lines (59 loc) · 2.18 KB
/
main.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
from flask import Flask, request, abort
from settings import Settings
from linebot import (
LineBotApi, WebhookHandler
)
from linebot.exceptions import (
InvalidSignatureError
)
from linebot.models import *
from CreatePriceTable import CreatePriceTable
import pandas as pd
import requests
import json
app = Flask(__name__)
app.config.from_object(Settings)
# LINE BOT info Settings
line_bot_api = LineBotApi(Settings['LINE_CHANNEL_ACCESS_TOKEN'])
handler = WebhookHandler(Settings['LINE_CHANNEL_SECRET'])
@app.route("/callback", methods=['POST'])
def callback():
signature = request.headers['X-Line-Signature']
body = request.get_data(as_text=True)
app.logger.info("Request body: " + body)
print(body)
try:
handler.handle(body, signature)
except InvalidSignatureError:
abort(400)
return 'OK'
# Message event
@handler.add(MessageEvent, message=TextMessage)
def handle_message(event):
message_type = event.message.type
user_id = event.source.user_id
reply_token = event.reply_token
message = event.message.text
sent = message.split(' ')
if sent[0] == '$':
""" Get Price Info: current price, 24hr %, 7day % """
if sent[1] == "Top":
""" Get Top Token Price Table """
flex_message = CreatePriceTable.get_top_token_price_table(message)
line_bot_api.reply_message(reply_token, FlexSendMessage('Top Token List', flex_message))
else:
""" Get Token Price Table """
flex_message = CreatePriceTable.get_token_price_table(message)
line_bot_api.reply_message(reply_token, FlexSendMessage('Price Table', flex_message))
elif sent[0] == '@':
""" Get the Price Graph """
pass
elif (sent[0].casefold() == "commands") or (sent[0] == "指令"):
""" Get the commands list """
flex_message = CreatePriceTable.get_commands_list()
line_bot_api.reply_message(reply_token, FlexSendMessage('Commands List', flex_message))
#line_bot_api.reply_message(reply_token, TextSendMessage(text = event.message.text))
if __name__ == "__main__":
#port = int(os.environ.get('PORT', 80))
#app.run(host='0.0.0.0', port=port)
app.run()