Upload app.py

app.py

@@ -63,6 +63,7 @@ from requests.auth import HTTPBasicAuth
 
 from google.cloud import storage, exceptions  # Import exceptions for error handling
 from google.cloud.exceptions import NotFound
+from google.oauth2 import service_account
 
 
 import logging
@@ -85,7 +86,7 @@ account_sid = os.environ["TWILLO_ACCOUNT_SID"]
 auth_token = os.environ["TWILLO_AUTH_TOKEN"]
 twilio_phone_number = os.environ["TWILLO_PHONE_NUMBER"]
 
-
+google_credentials_json = os.environ["GOOGLE_APPLICATION_CREDENTIALS"]
 twillo_client = Client(account_sid, auth_token)
 
 # Set the GOOGLE_APPLICATION_CREDENTIALS environment variable
@@ -336,6 +337,11 @@ def generate_task_hash(task_description):
         return 'output'
     
 def save_to_google_storage(bucket_name, file_path, destination_blob_name, expiration_minutes = 1440):
+    credentials_dict = json.loads(google_credentials_json)
+
+    # Step 3: Use `service_account.Credentials.from_service_account_info` to authenticate directly with the JSON
+    credentials = service_account.Credentials.from_service_account_info(credentials_dict)
+
     gcs_client = storage.Client()  # Initialize Google Cloud Storage client
     
     # Check if the bucket exists; if not, create it