UPDATE: removed unused search routes
This commit is contained in:
@@ -56,83 +56,3 @@ def search_results():
|
|||||||
print(query, streams, users, categories, flush=True)
|
print(query, streams, users, categories, flush=True)
|
||||||
|
|
||||||
return jsonify({"streams": streams, "categories": categories, "users": users})
|
return jsonify({"streams": streams, "categories": categories, "users": users})
|
||||||
|
|
||||||
@search_bp.route("/search/categories", methods=["GET", "POST"])
|
|
||||||
def search_categories():
|
|
||||||
"""
|
|
||||||
Display all the results for categories from the specified user query
|
|
||||||
"""
|
|
||||||
# Receive the query data from the user
|
|
||||||
data = request.get_json()
|
|
||||||
query = sanitize(data["query"])
|
|
||||||
|
|
||||||
# Create the connection to the database
|
|
||||||
db = Database()
|
|
||||||
db.create_connection()
|
|
||||||
|
|
||||||
# Fetch the ranked data and send to JSON to be displayed
|
|
||||||
categories = db.fetchall("""
|
|
||||||
SELECT bm25(category_fts) AS score, c.category_id, c.category_name
|
|
||||||
FROM categories AS c
|
|
||||||
INNER JOIN category_fts AS f ON c.category_id = f.category_id
|
|
||||||
WHERE f.category_name LIKE '%' || ? || '%'
|
|
||||||
ORDER BY score ASC;
|
|
||||||
""", (query,))
|
|
||||||
|
|
||||||
db.close_connection()
|
|
||||||
|
|
||||||
return jsonify({"categories": categories})
|
|
||||||
|
|
||||||
@search_bp.route("/search/users", methods=["GET", "POST"])
|
|
||||||
def search_users():
|
|
||||||
"""
|
|
||||||
Display all the results for users from the specified user query
|
|
||||||
"""
|
|
||||||
# Receive the query data from the user
|
|
||||||
data = request.get_json()
|
|
||||||
query = sanitize(data["query"])
|
|
||||||
|
|
||||||
# Create the connection to the database
|
|
||||||
db = Database()
|
|
||||||
db.create_connection()
|
|
||||||
|
|
||||||
# Fetch the ranked data and send to JSON to be displayed
|
|
||||||
users = db.fetchall("""
|
|
||||||
SELECT bm25(user_fts) AS score, u.user_id, u.username, u.is_live
|
|
||||||
FROM users AS u
|
|
||||||
INNER JOIN user_fts AS f ON u.user_id = f.user_id
|
|
||||||
WHERE f.username LIKE '%' || ? || '%'
|
|
||||||
ORDER BY score ASC;
|
|
||||||
""", (query,))
|
|
||||||
|
|
||||||
db.close_connection()
|
|
||||||
|
|
||||||
return jsonify({"users": users})
|
|
||||||
|
|
||||||
|
|
||||||
@search_bp.route("/search/streams", methods=["GET", "POST"])
|
|
||||||
def search_streams():
|
|
||||||
"""
|
|
||||||
Display all the results for streams from the specified user query
|
|
||||||
"""
|
|
||||||
# Receive the query data from the user
|
|
||||||
data = request.get_json()
|
|
||||||
query = sanitize(data["query"])
|
|
||||||
|
|
||||||
# Create the connection to the database
|
|
||||||
db = Database()
|
|
||||||
db.create_connection()
|
|
||||||
|
|
||||||
# Fetch the ranked data and send to JSON to be displayed
|
|
||||||
streams = db.fetchall("""
|
|
||||||
SELECT bm25(stream_fts) AS score, s.user_id, s.title, s.num_viewers, s.category_id, u.username
|
|
||||||
FROM streams AS s
|
|
||||||
INNER JOIN stream_fts AS f ON s.user_id = f.user_id
|
|
||||||
INNER JOIN users AS u ON s.user_id = u.user_id
|
|
||||||
WHERE f.title LIKE '%' || ? || '%'
|
|
||||||
ORDER BY score ASC;
|
|
||||||
""", (query,))
|
|
||||||
|
|
||||||
db.close_connection()
|
|
||||||
|
|
||||||
return jsonify({"streams": streams})
|
|
||||||
Reference in New Issue
Block a user