Update app.py

app.py

@@ -22,6 +22,10 @@ app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
 HF_API_TOKEN = os.getenv('HF_API_TOKEN')  # Load token from environment variable
 HF_API_URL = "https://api-inference.huggingface.co/models/facebook/detr-resnet-50"  # Example model for object detection
 
+# Instagram API settings
+INSTAGRAM_ACCESS_TOKEN = os.getenv('INSTAGRAM_ACCESS_TOKEN')  # Load token from environment variable
+INSTAGRAM_API_URL = "https://graph.instagram.com/v21.0/me/media"
+
 def query_hugging_face(image_data):
     if not HF_API_TOKEN:
         logging.error("Hugging Face API token not set.")
@@ -41,6 +45,38 @@ def query_hugging_face(image_data):
         logging.error(f"Failed to connect to Hugging Face API: {str(e)}")
         return {"error": f"Failed to connect to Hugging Face API: {str(e)}"}
 
+def upload_to_instagram(image_path):
+    if not INSTAGRAM_ACCESS_TOKEN:
+        logging.error("Instagram access token not set.")
+        return {"error": "Instagram access token not set. Please set the INSTAGRAM_ACCESS_TOKEN environment variable."}
+    try:
+        # Step 1: Create media object
+        session = requests.Session()
+        retries = Retry(total=3, backoff_factor=1, status_forcelist=[502, 503, 504])
+        session.mount('https://', HTTPAdapter(max_retries=retries))
+        
+        media_url = f"{INSTAGRAM_API_URL}?image_url={request.url_root}{image_path}&caption=Uploaded%20via%20Flask%20Camera%20App&access_token={INSTAGRAM_ACCESS_TOKEN}"
+        logging.debug(f"Sending media creation request to Instagram: {media_url}")
+        response = session.post(media_url, timeout=10)
+        response.raise_for_status()
+        media_data = response.json()
+        
+        if 'id' not in media_data:
+            logging.error(f"Failed to create media: {media_data}")
+            return {"error": f"Failed to create media: {media_data}"}
+        
+        # Step 2: Publish media
+        media_id = media_data['id']
+        publish_url = f"https://graph.instagram.com/v21.0/me/media_publish?creation_id={media_id}&access_token={INSTAGRAM_ACCESS_TOKEN}"
+        logging.debug(f"Sending publish request to Instagram: {publish_url}")
+        publish_response = session.post(publish_url, timeout=10)
+        publish_response.raise_for_status()
+        logging.debug("Instagram upload successful.")
+        return {"status": "success"}
+    except requests.exceptions.RequestException as e:
+        logging.error(f"Failed to upload to Instagram: {str(e)}")
+        return {"error": f"Failed to upload to Instagram: {str(e)}"}
+
 @app.route('/')
 def index():
     return render_template('index.html')
@@ -74,6 +110,21 @@ def capture():
         logging.error(f"Error in capture: {str(e)}")
         return jsonify({'status': 'error', 'message': str(e)})
 
+@app.route('/upload_instagram', methods=['POST'])
+def upload_instagram():
+    try:
+        image_url = request.form['image_url']
+        if not image_url.startswith('/static/captures/'):
+            return jsonify({'status': 'error', 'message': 'Invalid image path.'})
+        
+        result = upload_to_instagram(image_url.lstrip('/'))
+        if 'error' in result:
+            return jsonify({'status': 'error', 'message': result['error']})
+        return jsonify({'status': 'success'})
+    except Exception as e:
+        logging.error(f"Error in upload_instagram: {str(e)}")
+        return jsonify({'status': 'error', 'message': str(e)})
+
 @app.route('/test_connectivity')
 def test_connectivity():
     try: