from flask import Flask, request, jsonify

from google.cloud import bigquery

app = Flask(__name__)

@app.route("/", methods=["POST"])

def record_feedback():

    request_json = request.get_json(silent=True)

    if not request_json or "feedback" not in request_json:

        return jsonify({"message": "Missing feedback"}), 400

    feedback = request_json["feedback"]

    store_number = request_json.get("store_number", 8)

    bq_client = bigquery.Client()

    table_id = "qwiklabs-gcp-00-c3c9af2583eb.feedback.employee_feedback"

    rows_to_insert = [

        {

            "feedback": feedback,

            "store_number": store_number

        }

    ]

    errors = bq_client.insert_rows_json(table_id, rows_to_insert)

    if not errors:

        return jsonify({"message": "New row has been added."})

    else:

        return jsonify({

            "message": "Encountered errors while inserting rows",

            "errors": errors

        }), 500