aboutsummaryrefslogtreecommitdiff
path: root/wqflask/wqflask/collect.py
diff options
context:
space:
mode:
Diffstat (limited to 'wqflask/wqflask/collect.py')
-rw-r--r--wqflask/wqflask/collect.py38
1 files changed, 32 insertions, 6 deletions
diff --git a/wqflask/wqflask/collect.py b/wqflask/wqflask/collect.py
index 77be68b2..5a68c7c9 100644
--- a/wqflask/wqflask/collect.py
+++ b/wqflask/wqflask/collect.py
@@ -74,19 +74,38 @@ def collections_new():
collection_name = params['new_collection']
if "create_new" in params:
+ print("in create_new")
return create_new(collection_name)
elif "add_to_existing" in params:
+ print("in add to existing")
return add_traits(params, collection_name)
else:
+ print("ELSE")
CauseAnError
def add_anon_traits(params):
# Todo: assert user isn't logged in
anon_id = user_manager.AnonUser().anon_id
+ print("anon_id is:", anon_id)
+
+ key = "anon_collection:v1:" + anon_id
+
+ len_before = len(Redis.smembers(key))
traits = process_traits(params['traits'])
- print("anon traits:", traits)
+ print("redis key is:", key)
+ Redis.expire(key, 60*60*72)
+ for trait in traits:
+ Redis.sadd(key, trait)
+ #print("set members:", Redis.smembers(key))
+
+ len_now = len(Redis.smembers(key))
+ new_length = len_now - len_before
+ print("new_length:", new_length)
+ #print("anon traits:", traits)
+
+ return redirect(url_for('view_collection', key=key))
def add_traits(params, collection_name):
print("---> params are:", params.keys())
@@ -211,9 +230,16 @@ def delete_collection():
def view_collection():
params = request.args
print("params in view collection:", params)
- uc_id = params['uc_id']
- uc = model.UserCollection.query.get(uc_id)
- traits = json.loads(uc.members)
+
+ if "uc_id" in params:
+ uc_id = params['uc_id']
+ uc = model.UserCollection.query.get(uc_id)
+ traits = json.loads(uc.members)
+ else:
+ anon_id = params['key']
+ uc = model.AnonCollection
+ traits = Redis.smembers(anon_id)
+ print("the traits are:", traits)
print("in view_collection traits are:", traits)
@@ -236,9 +262,9 @@ def view_collection():
# lrs_location=trait_ob.LRS_location_repr))
# dis=trait_ob.description))
#json_version.append(trait_ob.__dict__th)
-
+
collection_info = dict(trait_obs=trait_obs,
- uc = uc)
+ uc = uc)
if "json" in params:
print("json_version:", json_version)
return json.dumps(json_version)