Skip to content

Commit 7f12b2c

Browse files
committed
implementing FieldFilter for categories endpoint
1 parent a31443f commit 7f12b2c

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

functions/categories/libs/queries.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,14 @@
11
import os
2-
import json
32
from google.cloud import firestore
3+
from google.cloud.firestore_v1.base_query import FieldFilter
44
from .result import Result
55
from .utils import convert_to_array
66

77
DB = firestore.Client(project=os.environ.get('PROJECT'), database=os.environ.get('DATABASE'))
8+
TABLE = 'categories'
89

910
def list_data(params):
10-
ref = DB.collection(u'categories')
11+
ref = DB.collection(TABLE)
1112

1213
query = ref
1314

@@ -27,7 +28,7 @@ def list_data(params):
2728
category_array = convert_to_array(params['category'])
2829

2930
for category in category_array:
30-
results = query.where("category", "==", category).stream()
31+
results = query.where(filter=FieldFilter("category", "==", category)).stream()
3132
for doc in results:
3233
data.append(doc.to_dict())
3334

0 commit comments

Comments
 (0)