Update app.py

app.py

@@ -22,9 +22,8 @@ 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"
+# Zapier webhook settings
+ZAPIER_WEBHOOK_URL = os.getenv('ZAPIER_WEBHOOK_URL')  # Load webhook URL from environment variable
 
 def query_hugging_face(image_data):
     if not HF_API_TOKEN:
@@ -32,7 +31,6 @@ def query_hugging_face(image_data):
         return {"error": "Hugging Face API token not set. Please set the HF_API_TOKEN environment variable."}
     try:
         session = requests.Session()
-        # Configure retries: 3 attempts, backoff factor of 1s, retry on 502/503/504
         retries = Retry(total=3, backoff_factor=1, status_forcelist=[502, 503, 504])
         session.mount('https://', HTTPAdapter(max_retries=retries))
         headers = {"Authorization": f"Bearer {HF_API_TOKEN}"}
@@ -45,37 +43,35 @@ 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."}
+def send_to_zapier(image_path):
+    if not ZAPIER_WEBHOOK_URL:
+        logging.error("Zapier webhook URL not set.")
+        return {"error": "Zapier webhook URL not set. Please set the ZAPIER_WEBHOOK_URL environment variable."}
     try:
-        # Step 1: Create media object
+        # Read the image file
+        with open(image_path, "rb") as f:
+            image_data = f.read()
+            encoded_image = base64.b64encode(image_data).decode('utf-8')
+
+        # Prepare data for Zapier
+        payload = {
+            'image': encoded_image,
+            'filename': os.path.basename(image_path),
+            'content_type': 'image/jpeg'
+        }
+
+        # Send to Zapier webhook
         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)
+        logging.debug(f"Sending image to Zapier webhook: {ZAPIER_WEBHOOK_URL}")
+        response = session.post(ZAPIER_WEBHOOK_URL, json=payload, 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.")
+        logging.debug("Image sent to Zapier successfully.")
         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)}"}
+        logging.error(f"Failed to send to Zapier: {str(e)}")
+        return {"error": f"Failed to send to Zapier: {str(e)}"}
 
 @app.route('/')
 def index():
@@ -110,19 +106,19 @@ 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():
+@app.route('/upload_zapier', methods=['POST'])
+def upload_zapier():
     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('/'))
+        result = send_to_zapier(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)}")
+        logging.error(f"Error in upload_zapier: {str(e)}")
         return jsonify({'status': 'error', 'message': str(e)})
 
 @app.route('/test_connectivity')