Spaces:
Sleeping
Sleeping
Update app.py
#1
by
Yaswanth56
- opened
app.py
CHANGED
@@ -5,6 +5,82 @@ from salesforce import get_salesforce_connection
|
|
5 |
from flask_cors import CORS
|
6 |
import os
|
7 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
8 |
# Initialize Flask app and Salesforce connection
|
9 |
print("Starting app...")
|
10 |
app = Flask(__name__)
|
|
|
5 |
from flask_cors import CORS
|
6 |
import os
|
7 |
|
8 |
+
from flask import Flask, redirect, request, jsonify, session
|
9 |
+
import requests
|
10 |
+
import os
|
11 |
+
|
12 |
+
app = Flask(__name__)
|
13 |
+
app.secret_key = os.urandom(24) # Random secret key for session management
|
14 |
+
|
15 |
+
# Salesforce OAuth URLs and credentials
|
16 |
+
SALESFORCE_OAUTH_URL = "https://login.salesforce.com/services/oauth2/authorize"
|
17 |
+
SALESFORCE_TOKEN_URL = "https://login.salesforce.com/services/oauth2/token"
|
18 |
+
CLIENT_ID = '3MVG9WVXk15qiz1JbtW1tT9a7WojFUbAfMVyVXfvI4PISHAKAxmZ8RLS1lBHqpnaDPQPZOOInuVdcQpi7smWc' # Your Consumer Key
|
19 |
+
CLIENT_SECRET = '36C463CD713C420BA2ED78F853359EACCE1ECCE2954C9810FFD7F946564CB0E8' # Your Consumer Secret
|
20 |
+
REDIRECT_URI = 'https://huggingface.co/spaces/nagasurendra/BiryaniHubflask21' # Your Hugging Face redirect URI
|
21 |
+
INSTANCE_URL = 'https://biryanihub-dev-ed.develop.my.site.com/s/welcomePage' # Your Salesforce instance URL
|
22 |
+
|
23 |
+
# OAuth flow to redirect to Salesforce login
|
24 |
+
@app.route('/login')
|
25 |
+
def login():
|
26 |
+
oauth_url = f"{SALESFORCE_OAUTH_URL}?response_type=code&client_id={CLIENT_ID}&redirect_uri={REDIRECT_URI}"
|
27 |
+
return redirect(oauth_url)
|
28 |
+
|
29 |
+
# Handle the OAuth callback from Salesforce and exchange the authorization code for an access token
|
30 |
+
@app.route('/oauth/callback')
|
31 |
+
def oauth_callback():
|
32 |
+
auth_code = request.args.get('code') # The code returned from Salesforce
|
33 |
+
|
34 |
+
if not auth_code:
|
35 |
+
return jsonify({"error": "No authorization code provided"}), 400
|
36 |
+
|
37 |
+
# Exchange the authorization code for an access token
|
38 |
+
token_data = {
|
39 |
+
'grant_type': 'authorization_code',
|
40 |
+
'code': auth_code,
|
41 |
+
'client_id': CLIENT_ID,
|
42 |
+
'client_secret': CLIENT_SECRET,
|
43 |
+
'redirect_uri': REDIRECT_URI
|
44 |
+
}
|
45 |
+
|
46 |
+
token_response = requests.post(SALESFORCE_TOKEN_URL, data=token_data)
|
47 |
+
|
48 |
+
if token_response.status_code == 200:
|
49 |
+
token_info = token_response.json()
|
50 |
+
access_token = token_info['sSSjyhInIsUohKpG8sHzty2q']
|
51 |
+
instance_url = token_info['https://biryanihub-dev-ed.develop.my.site.com/s/welcomePage'] # The Salesforce instance URL
|
52 |
+
|
53 |
+
# Store access token in session for future API requests
|
54 |
+
session['access_token'] = access_token
|
55 |
+
session['instance_url'] = instance_url
|
56 |
+
|
57 |
+
return redirect('/dashboard') # Redirect user to the Hugging Face dashboard or home page
|
58 |
+
else:
|
59 |
+
return jsonify({"error": "Failed to authenticate with Salesforce"}), 400
|
60 |
+
|
61 |
+
# Example protected route that uses the Salesforce access token
|
62 |
+
@app.route('/dashboard')
|
63 |
+
def dashboard():
|
64 |
+
if 'access_token' not in session:
|
65 |
+
return redirect('/login') # If the user is not logged in, redirect to login
|
66 |
+
|
67 |
+
access_token = session['access_token']
|
68 |
+
instance_url = session['instance_url']
|
69 |
+
|
70 |
+
# Use the access token to make API calls to Salesforce (example: fetch user info)
|
71 |
+
headers = {'Authorization': f'Bearer {access_token}'}
|
72 |
+
user_info_url = f"{instance_url}/services/oauth2/userinfo"
|
73 |
+
user_info_response = requests.get(user_info_url, headers=headers)
|
74 |
+
|
75 |
+
if user_info_response.status_code == 200:
|
76 |
+
user_info = user_info_response.json()
|
77 |
+
return jsonify(user_info) # Display user info from Salesforce
|
78 |
+
else:
|
79 |
+
return jsonify({"error": "Failed to fetch user info from Salesforce"}), 400
|
80 |
+
|
81 |
+
if __name__ == '__main__':
|
82 |
+
app.run(debug=True)
|
83 |
+
|
84 |
# Initialize Flask app and Salesforce connection
|
85 |
print("Starting app...")
|
86 |
app = Flask(__name__)
|