Automate workflows with Webhooks

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
from flask import Flask, request, jsonify
import logging

app = Flask(__name__)
logging.basicConfig(level=logging.INFO)

@app.route('/webhook', methods=['POST'])
def survey123_webhook():
    data = request.json
    logging.info(f"Received webhook: {data}")

    # Add your processing logic here

    return jsonify({"status": "success"}), 200

if __name__ == '__main__':
    app.run(port=5000)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
from flask import Flask, request, jsonify
import psycopg2
import json
from datetime import datetime

app = Flask(__name__)

@app.route('/webhook', methods=['POST'])
def store_survey():
    data = request.json

    # Validate required fields
    if not data or 'surveyInfo' not in data or 'feature' not in data:
        return jsonify({"error": "Invalid payload"}), 400

    # Extract survey data
    survey_id = data['surveyInfo']['id']
    attributes = data['feature']['attributes']

    # Connect to database
    conn = psycopg2.connect(
        dbname="your_database",
        user="your_user",
        password="your_password",
        host="your_host"
    )
    cur = conn.cursor()

    try:
        # Insert survey response (serialize attributes as JSON)
        cur.execute("""
            INSERT INTO survey_responses
            (survey_id, response_data, created_at)
            VALUES (%s, %s, %s)
        """, (survey_id, json.dumps(attributes), datetime.now()))

        conn.commit()
        return jsonify({"status": "success"}), 200

    except Exception as e:
        conn.rollback()
        return jsonify({"error": str(e)}), 500

    finally:
        cur.close()
        conn.close()

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
from flask import Flask, request, jsonify
import smtplib
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
from datetime import datetime

app = Flask(__name__)

@app.route('/webhook', methods=['POST'])
def notify_submission():
    data = request.json

    # Validate required fields
    if not data or 'surveyInfo' not in data or 'userInfo' not in data:
        return jsonify({"error": "Invalid payload"}), 400

    # Extract survey info
    survey_name = data['surveyInfo']['name']
    username = data['userInfo']['username']

    # Email server settings
    smtp_server = "smtp.your-server.com"
    smtp_port = 587
    sender_email = "your-email@domain.com"
    password = "your-password"
    recipient = "recipient@domain.com"

    # Create email content
    subject = f"New Survey Submission: {survey_name}"
    body = f"""
    New survey response received:
    Survey: {survey_name}
    Submitted by: {username}
    Time: {datetime.now()}
    """

    try:
        # Create and send email
        message = MIMEMultipart()
        message["From"] = sender_email
        message["To"] = recipient
        message["Subject"] = subject
        message.attach(MIMEText(body, "plain"))

        with smtplib.SMTP(smtp_server, smtp_port) as server:
            server.starttls()
            server.login(sender_email, password)
            server.send_message(message)

        return jsonify({"status": "success"}), 200
    except Exception as e:
        return jsonify({"error": str(e)}), 500

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
from flask import Flask, request, jsonify
import requests
from datetime import datetime

app = Flask(__name__)

@app.route('/webhook', methods=['POST'])
def notify_slack():
    data = request.json

    # Slack webhook URL
    slack_webhook = "https://hooks.slack.com/services/YOUR/WEBHOOK/URL"

    # Format message
    message = f"""
    :clipboard: *New Survey Response*
    *Survey:* {data['surveyInfo']['name']}
    *Submitted by:* {data['userInfo']['username']}
    *Time:* {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}
    """

    try:
        response = requests.post(slack_webhook, json={"text": message})
        if response.status_code == 200:
            return jsonify({"status": "success"}), 200
        else:
            return jsonify({"error": "Failed to send to Slack"}), 500
    except Exception as e:
        return jsonify({"error": str(e)}), 500