diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/server/db_op.py | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/src/server/db_op.py b/src/server/db_op.py index b81bc288..638d327a 100644 --- a/src/server/db_op.py +++ b/src/server/db_op.py @@ -192,6 +192,14 @@ class DB_composed_op(DB_op): ret.append(s_result_set) return ret +def obj_from_blob(blob): + """ + @return json.loads(gzip_decompress(base64_decode(blob))) + """ + blob_gzip = base64.decodestring(blob) + blob = gzip.zlib.decompress(blob_gzip) + return json.loads(blob) + def obj_to_blob(obj): """ @return: blob = base64(gzip(json.dumps(obj))) @@ -217,7 +225,7 @@ class DBO_block_chain__commit(DB_op): ret = sha1.hexdigest() return ret - def __init__(self, commit_obj=None, ctx=None): + def __init__(self, commit_obj=None, ctx=None, meta=None): """ @param commit_obj: serializable blob @@ -257,6 +265,18 @@ class DBO_block_chain__commit(DB_op): if None != ctx and None != ctx.user_name: self.add_statement(self._authored_by_statement(ctx.user_name)) + if None != meta and 'sentence' in meta and meta['sentence'] != '': + self.add_statement(self._result_of_sentence(ctx.user_name, meta['sentence'])) + + def _result_of_sentence(self, user_name, sentence): + return ['match (head:%s:%s)' % (neo4j_schema.META_LABEL__VC_HEAD, + neo4j_schema.META_LABEL__VC_COMMIT), + 'create (head)-[r:%s]->(result_of:%s {sentence: \'%s\'} )' % ( + neo4j_schema.META_LABEL__VC_COMMIT_RESULT_OF, + neo4j_schema.META_LABEL__VC_OPERATION, + sentence, + )] + def _authored_by_statement(self, user_name): return ['merge (n:%s {user_name: \'%s\'})' % (neo4j_schema.META_LABEL__USER, user_name), 'with n', |