- Create Jukebox
+ Create Jukebox
/", methods=["GET"])
+@jukebox_ext.route("/api/v1/jukebox/spotify/cb/", methods=["GET"])
async def api_check_credentials_callbac(sp_user):
+ sp_code = ""
+ sp_access_token = ""
+ sp_refresh_token = ""
+ print(request.args)
jukebox = await get_jukebox_by_user(sp_user)
- jukebox = await update_jukebox(
- sp_user=sp_user, sp_secret=jukebox.sp_secret, sp_token=request.args.get('code')
- )
+ if request.args.get('code'):
+ sp_code = request.args.get('code')
+ jukebox = await update_jukebox(
+ sp_user=sp_user, sp_secret=jukebox.sp_secret, sp_access_token=sp_code
+ )
+ if request.args.get('access_token'):
+ sp_access_token = request.args.get('access_token')
+ sp_refresh_token = request.args.get('refresh_token')
+ jukebox = await update_jukebox(
+ sp_user=sp_user, sp_secret=jukebox.sp_secret, sp_access_token=sp_access_token, sp_refresh_token=sp_refresh_token
+ )
return "Success!
You can close this window
"
-@jukebox_ext.route("/api/v1/jukebox/spotify/", methods=["GET"])
+@jukebox_ext.route("/api/v1/jukebox/spotify/", methods=["GET"])
@api_check_wallet_key("invoice")
-async def api_check_credentials_check(sp_user):
- jukebox = await get_jukebox_by_user(sp_user)
+async def api_check_credentials_check(sp_id):
+ jukebox = await get_jukebox(sp_id)
return jsonify(jukebox._asdict()), HTTPStatus.CREATED
@@ -49,14 +61,16 @@ async def api_check_credentials_check(sp_user):
"wallet": {"type": "string", "empty": False, "required": True},
"sp_user": {"type": "string", "empty": False, "required": True},
"sp_secret": {"type": "string", "required": True},
- "sp_token": {"type": "string", "required": False},
+ "sp_access_token": {"type": "string", "required": False},
+ "sp_refresh_token": {"type": "string", "required": False},
"sp_device": {"type": "string", "required": False},
"sp_playlists": {"type": "string", "required": False},
"price": {"type": "string", "required": True},
}
)
async def api_create_update_jukebox(item_id=None):
- print(g.data)
+ if item_id:
+ jukebox = await update_jukebox(**g.data)
jukebox = await create_jukebox(**g.data)
return jsonify(jukebox._asdict()), HTTPStatus.CREATED