Compare commits
No commits in common. "v0.0.1-flask" and "master" have entirely different histories.
v0.0.1-fla
...
master
2
.gitignore
vendored
2
.gitignore
vendored
@ -1,5 +1,3 @@
|
|||||||
refs/
|
|
||||||
|
|
||||||
# ---> Python
|
# ---> Python
|
||||||
# Byte-compiled / optimized / DLL files
|
# Byte-compiled / optimized / DLL files
|
||||||
__pycache__/
|
__pycache__/
|
||||||
|
8
.idea/.gitignore
generated
vendored
8
.idea/.gitignore
generated
vendored
@ -1,8 +0,0 @@
|
|||||||
# Default ignored files
|
|
||||||
/shelf/
|
|
||||||
/workspace.xml
|
|
||||||
# Editor-based HTTP Client requests
|
|
||||||
/httpRequests/
|
|
||||||
# Datasource local storage ignored files
|
|
||||||
/dataSources/
|
|
||||||
/dataSources.local.xml
|
|
6
.idea/inspectionProfiles/profiles_settings.xml
generated
6
.idea/inspectionProfiles/profiles_settings.xml
generated
@ -1,6 +0,0 @@
|
|||||||
<component name="InspectionProjectProfileManager">
|
|
||||||
<settings>
|
|
||||||
<option name="USE_PROJECT_PROFILE" value="false" />
|
|
||||||
<version value="1.0" />
|
|
||||||
</settings>
|
|
||||||
</component>
|
|
4
.idea/misc.xml
generated
4
.idea/misc.xml
generated
@ -1,4 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project version="4">
|
|
||||||
<component name="ProjectRootManager" version="2" project-jdk-name="Python 3.10 (sinkhole)" project-jdk-type="Python SDK" />
|
|
||||||
</project>
|
|
8
.idea/modules.xml
generated
8
.idea/modules.xml
generated
@ -1,8 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project version="4">
|
|
||||||
<component name="ProjectModuleManager">
|
|
||||||
<modules>
|
|
||||||
<module fileurl="file://$PROJECT_DIR$/.idea/sinkhole.iml" filepath="$PROJECT_DIR$/.idea/sinkhole.iml" />
|
|
||||||
</modules>
|
|
||||||
</component>
|
|
||||||
</project>
|
|
10
.idea/sinkhole.iml
generated
10
.idea/sinkhole.iml
generated
@ -1,10 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<module type="PYTHON_MODULE" version="4">
|
|
||||||
<component name="NewModuleRootManager">
|
|
||||||
<content url="file://$MODULE_DIR$">
|
|
||||||
<excludeFolder url="file://$MODULE_DIR$/venv" />
|
|
||||||
</content>
|
|
||||||
<orderEntry type="jdk" jdkName="Python 3.10 (sinkhole)" jdkType="Python SDK" />
|
|
||||||
<orderEntry type="sourceFolder" forTests="false" />
|
|
||||||
</component>
|
|
||||||
</module>
|
|
6
.idea/vcs.xml
generated
6
.idea/vcs.xml
generated
@ -1,6 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project version="4">
|
|
||||||
<component name="VcsDirectoryMappings">
|
|
||||||
<mapping directory="$PROJECT_DIR$" vcs="Git" />
|
|
||||||
</component>
|
|
||||||
</project>
|
|
111
src/app.py
111
src/app.py
@ -1,111 +0,0 @@
|
|||||||
from flask import Flask, request, redirect, abort, url_for
|
|
||||||
from urllib.parse import quote_plus
|
|
||||||
from base64 import b64encode
|
|
||||||
import datetime
|
|
||||||
import requests
|
|
||||||
import uuid
|
|
||||||
import os
|
|
||||||
|
|
||||||
|
|
||||||
app = Flask(__name__)
|
|
||||||
|
|
||||||
STATE = quote_plus(str(uuid.uuid4()))
|
|
||||||
TOKEN = None
|
|
||||||
AGENT = f"sinkhole v0.0.1"
|
|
||||||
CLIENT_ID = os.getenv('REDDIT_APP_ID', '')
|
|
||||||
CLIENT_SECRET = os.getenv('CLIENT_SECRET', '')
|
|
||||||
REDIRECT_URI = quote_plus(os.getenv('REDIRECT_URI', ''))
|
|
||||||
DURATION = quote_plus(os.getenv('DURATION', 'temporary'))
|
|
||||||
SCOPE = ','.join([
|
|
||||||
'identity',
|
|
||||||
'edit',
|
|
||||||
'flair',
|
|
||||||
'history',
|
|
||||||
'modconfig',
|
|
||||||
'modflair',
|
|
||||||
'modlog',
|
|
||||||
'modposts',
|
|
||||||
'modwiki',
|
|
||||||
'mysubreddits',
|
|
||||||
'privatemessages',
|
|
||||||
'read',
|
|
||||||
'report',
|
|
||||||
'save',
|
|
||||||
'submit',
|
|
||||||
'subscribe',
|
|
||||||
'vote',
|
|
||||||
'wikiedit',
|
|
||||||
'wikiread'
|
|
||||||
])
|
|
||||||
|
|
||||||
|
|
||||||
def get_bearer_token(
|
|
||||||
code: str
|
|
||||||
) -> dict:
|
|
||||||
token_resp = requests.post(
|
|
||||||
"https://www.reddit.com/api/v1/access_token",
|
|
||||||
headers={
|
|
||||||
'Accept': 'application/json',
|
|
||||||
'Content-Type': 'application/x-www-form-urlencoded',
|
|
||||||
'User-Agent': AGENT,
|
|
||||||
'Authorization': f"Basic {b64encode(f'{CLIENT_ID}:{CLIENT_SECRET}'.encode()).decode('utf-8')}"
|
|
||||||
},
|
|
||||||
data=f"grant_type=authorization_code&code={code}&redirect_uri={REDIRECT_URI}"
|
|
||||||
)
|
|
||||||
|
|
||||||
token_data = token_resp.json()
|
|
||||||
expiration_ts = (datetime.datetime.now() + datetime.timedelta(seconds=token_data['expires_in'])).isoformat()
|
|
||||||
return {
|
|
||||||
'access_token': token_data['access_token'],
|
|
||||||
'token_type': token_data['token_type'],
|
|
||||||
'expiration_ts': expiration_ts,
|
|
||||||
'scope': token_data['scope']
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
@app.route("/")
|
|
||||||
def index():
|
|
||||||
if TOKEN:
|
|
||||||
return "You are authorized, way to go!"
|
|
||||||
auth_url = f"https://www.reddit.com/api/v1/authorize.compact?client_id={quote_plus(CLIENT_ID)}" \
|
|
||||||
f"&response_type=code" \
|
|
||||||
f"&state={STATE}" \
|
|
||||||
f"&redirect_uri={REDIRECT_URI}" \
|
|
||||||
f"&duration={DURATION}" \
|
|
||||||
f"&scope={SCOPE}"
|
|
||||||
return f"Please navigate <a href=\"{auth_url}\">here</a> to authorize."
|
|
||||||
|
|
||||||
|
|
||||||
@app.route('/home', methods=['POST'])
|
|
||||||
def home():
|
|
||||||
token = request.form.get('token')
|
|
||||||
return {
|
|
||||||
'TOKEN': request.form.get('token'),
|
|
||||||
'TOKEN_TYPE': request.form.get('token_type'),
|
|
||||||
'TOKEN_EXPIRATION': request.form.get('token_expire_dt'),
|
|
||||||
'TOKEN_SCOPE': request.form.get('token_scope')
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
@app.route("/callback", methods=['GET', 'POST'])
|
|
||||||
def auth_callback(**kwargs):
|
|
||||||
error = request.args.get('error')
|
|
||||||
state = request.args.get('state')
|
|
||||||
code = request.args.get('code')
|
|
||||||
|
|
||||||
if not error:
|
|
||||||
if state == STATE:
|
|
||||||
# get the bearer token and redirect
|
|
||||||
token_info = get_bearer_token(code)
|
|
||||||
return redirect(url_for('home',
|
|
||||||
token=token_info.get('access_token'),
|
|
||||||
token_type=token_info.get('token_type'),
|
|
||||||
token_expire_dt=token_info.get('expiration_ts'),
|
|
||||||
token_scope=token_info.get('scope')
|
|
||||||
),
|
|
||||||
code=307)
|
|
||||||
else:
|
|
||||||
return f"Not authorized! State {state} didn't match {STATE} that was sent!"
|
|
||||||
else:
|
|
||||||
abort(403)
|
|
||||||
|
|
Loading…
x
Reference in New Issue
Block a user