Merge pull request #43 from goldenrecursion/sc-19726

Sc 19726

Author: aychang95

src/godel/api.py

@@ -25,6 +25,7 @@
 from godel.queries.CreateEntity import Operations as CreateEntityOperations
 from godel.queries.CreateValidation import Operations as CreateValidationOperations
 from godel.queries.CreateStatement import Operations as CreateStatementOperations
+from godel.queries.CreateTripleFlag import Operations as CreateTripleFlagOperations
 
 # from godel.queries.CurrentUserBlockchainData import Operations as CurrentUserBlockchainDataOperations
 from godel.queries.CurrentUserValidations import (
@@ -705,6 +706,15 @@ def create_statement(
     # Validation Submissions
 
     def create_validation(self, triple_id: str, validation_type: str, **kwargs) -> dict:
+        """Create verification vote
+
+        Args:
+            triple_id (str): Your triple id
+            validation_type (str): Verfication type "ACCEPTED", "REJECTED", "SKIPPED"
+
+        Returns:
+            dict: created verification task
+        """
         x_metrics = json.loads(self.headers.get("X-metrics"))
         x_metrics.update({"cv": time.time()})
         if x_metrics.get("uv"):
@@ -723,22 +733,29 @@ def create_validation(self, triple_id: str, validation_type: str, **kwargs) -> d
     # Create Triple Flag
 
     def create_triple_flag(
-        self, triple_id: str, flag: str, reason: str, **kwargs
+        self, create_triple_flag_input: schema.CreateTripleFlagInput, **kwargs
     ) -> dict:
-        query = f"""mutation MyMutation {{
-            createTripleFlag(
-              input: {{
-                tripleId: "{triple_id}"
-                flag: {flag}
-                reason: "{reason}"
-              }}
-              ) {{
-                clientMutationId
-              }}
-        }}"""
-        print(query)
-        variables = {}
-        data = self.endpoint(query, variables)
+        """Create triple flag given the triple flag inputs consisting of triple_id and your flag
+
+        Args:
+            create_triple_flag_input (schema.CreateTripleFlagInput): Triple flag input
+
+        Returns:
+            dict: created triple flag
+        """
+        # Special case for parsing input
+        variables = create_triple_flag_input.__to_json_value__()
+        for p, v in variables.items():
+            p = self.to_camel_case(p)
+            if p in variables:
+                variables[p] = v
+
+        params = locals()
+        params.pop("kwargs")
+        params.pop("self")
+        params.update(kwargs)
+        op = CreateTripleFlagOperations.mutation.create_triple_flag
+        data = self.endpoint(op, variables)
         return data
 
     def add_triple_to_entity(

src/godel/fragments/EntityDetail.py

@@ -21,7 +21,7 @@ def fragment_entity_detail():
     _frag_is_a_nodes = _frag_is_a.nodes()
     _frag_is_a_nodes.id()
     _frag_is_a_nodes.name()
-    _frag_statements_by_subject_id = _frag.statements_by_subject_id()
+    _frag_statements_by_subject_id = _frag.statements_by_subject_id(condition={'validationStatusIn': ('ACCEPTED', 'PENDING')})
     _frag_statements_by_subject_id_nodes = _frag_statements_by_subject_id.nodes()
     _frag_statements_by_subject_id_nodes.__fragment__(fragment_triple_widget())
     return _frag

src/godel/queries/CreateTripleFlag.py

@@ -0,0 +1,23 @@
+import sgqlc.types
+import sgqlc.operation
+import godel.schema
+
+_schema = godel.schema
+_schema_root = _schema.schema
+
+__all__ = ('Operations',)
+
+
+def mutation_create_triple_flag():
+    _op = sgqlc.operation.Operation(_schema_root.mutation_type, name='CreateTripleFlag', variables=dict(tripleId=sgqlc.types.Arg(sgqlc.types.non_null(_schema.UUID)), flag=sgqlc.types.Arg(sgqlc.types.non_null(_schema.TripleFlagType))))
+    _op_create_triple_flag = _op.create_triple_flag(input={'tripleId': sgqlc.types.Variable('tripleId'), 'flag': sgqlc.types.Variable('flag')})
+    _op_create_triple_flag.client_mutation_id()
+    return _op
+
+
+class Mutation:
+    create_triple_flag = mutation_create_triple_flag()
+
+
+class Operations:
+    mutation = Mutation

src/godel/queries/CurrentUserContributions.py

@@ -9,23 +9,23 @@
 
 
 def query_current_user_contributions():
-    _op = sgqlc.operation.Operation(_schema_root.query_type, name='CurrentUserContributions', variables=dict(first=sgqlc.types.Arg(_schema.Int, default=20), after=sgqlc.types.Arg(_schema.Cursor, default=None), condition=sgqlc.types.Arg(sgqlc.types.non_null(_schema.TripleCondition))))
+    _op = sgqlc.operation.Operation(_schema_root.query_type, name='CurrentUserContributions', variables=dict(first=sgqlc.types.Arg(_schema.Int, default=20), after=sgqlc.types.Arg(_schema.Cursor, default=None), condition=sgqlc.types.Arg(sgqlc.types.non_null(_schema.StatementCondition))))
     _op_current_user = _op.current_user()
     _op_current_user_contributions_stats = _op_current_user.contributions_stats()
     _op_current_user_contributions_stats.accuracy()
     _op_current_user_contributions_stats.agreed_with_consensus_count()
     _op_current_user_contributions_stats.disagreed_with_consensus_count()
     _op_current_user_contributions_stats.pending_count()
-    _op_triples = _op.triples(order_by='DATE_CREATED_DESC', after=sgqlc.types.Variable('after'), first=sgqlc.types.Variable('first'), condition=sgqlc.types.Variable('condition'))
-    _op_triples.total_count()
-    _op_triples_page_info = _op_triples.page_info()
-    _op_triples_page_info.end_cursor()
-    _op_triples_page_info.has_previous_page()
-    _op_triples_page_info.has_next_page()
-    _op_triples_edges = _op_triples.edges()
-    _op_triples_edges.cursor()
-    _op_triples_edges_node = _op_triples_edges.node()
-    _op_triples_edges_node.__fragment__(fragment_triple_widget())
+    _op_statements = _op.statements(order_by='DATE_CREATED_DESC', after=sgqlc.types.Variable('after'), first=sgqlc.types.Variable('first'), condition=sgqlc.types.Variable('condition'))
+    _op_statements.total_count()
+    _op_statements_page_info = _op_statements.page_info()
+    _op_statements_page_info.end_cursor()
+    _op_statements_page_info.has_previous_page()
+    _op_statements_page_info.has_next_page()
+    _op_statements_edges = _op_statements.edges()
+    _op_statements_edges.cursor()
+    _op_statements_edges_node = _op_statements_edges.node()
+    _op_statements_edges_node.__fragment__(fragment_triple_widget())
     return _op
 
 

src/godel/queries/EntityContributors.py

@@ -6,26 +6,3 @@
 _schema_root = _schema.schema
 
 __all__ = ('Operations',)
-
-
-def query_entity_contributors():
-    _op = sgqlc.operation.Operation(_schema_root.query_type, name='EntityContributors', variables=dict(id=sgqlc.types.Arg(sgqlc.types.non_null(_schema.UUID)), after=sgqlc.types.Arg(_schema.Cursor, default=None)))
-    _op_entity = _op.entity(id=sgqlc.types.Variable('id'))
-    _op_entity.id()
-    _op_entity_nft_requests = _op_entity.nft_requests(first=5, after=sgqlc.types.Variable('after'))
-    _op_entity_nft_requests_page_info = _op_entity_nft_requests.page_info()
-    _op_entity_nft_requests_page_info.has_next_page()
-    _op_entity_nft_requests_page_info.end_cursor()
-    _op_entity_nft_requests_nodes = _op_entity_nft_requests.nodes()
-    _op_entity_nft_requests_nodes.user_id()
-    _op_entity_nft_requests_nodes.ledger_record_amount_sum()
-    _op_entity_nft_requests_nodes.ownership_percent()
-    return _op
-
-
-class Query:
-    entity_contributors = query_entity_contributors()
-
-
-class Operations:
-    query = Query

src/godel/queries/EntityDetail.py

@@ -14,6 +14,7 @@ def query_entity_detail():
     _op = sgqlc.operation.Operation(_schema_root.query_type, name='EntityDetail', variables=dict(id=sgqlc.types.Arg(sgqlc.types.non_null(_schema.UUID))))
     _op_entity = _op.entity(id=sgqlc.types.Variable('id'))
     _op_entity.__fragment__(fragment_entity_detail())
+    _op_entity.is_entity_type()
     _op_templates = _op.templates(order_by='RANK_ASC')
     _op_templates_nodes = _op_templates.nodes()
     _op_templates_nodes.entity_id()

src/godel/queries/EntityType.py

@@ -0,0 +1,25 @@
+import sgqlc.types
+import sgqlc.operation
+import godel.schema
+
+_schema = godel.schema
+_schema_root = _schema.schema
+
+__all__ = ('Operations',)
+
+
+def query_entity_type():
+    _op = sgqlc.operation.Operation(_schema_root.query_type, name='EntityType', variables=dict(id=sgqlc.types.Arg(sgqlc.types.non_null(_schema.UUID))))
+    _op_entity = _op.entity(id=sgqlc.types.Variable('id'))
+    _op_entity.id()
+    _op_entity.name()
+    _op_entity.is_entity_type()
+    return _op
+
+
+class Query:
+    entity_type = query_entity_type()
+
+
+class Operations:
+    query = Query

src/godel/queries/LiveView.py

@@ -10,10 +10,15 @@
 
 
 def query_live_view():
-    _op = sgqlc.operation.Operation(_schema_root.query_type, name='LiveView')
-    _op_triples = _op.triples(first=20, condition={'validationStatus': 'ACCEPTED'}, order_by='DATE_ACCEPTED_DESC')
-    _op_triples_nodes = _op_triples.nodes()
-    _op_triples_nodes.__fragment__(fragment_triple_widget())
+    _op = sgqlc.operation.Operation(_schema_root.query_type, name='LiveView', variables=dict(first=sgqlc.types.Arg(_schema.Int, default=20), after=sgqlc.types.Arg(_schema.Cursor, default=None), condition=sgqlc.types.Arg(_schema.TripleCondition), orderBy=sgqlc.types.Arg(sgqlc.types.list_of(sgqlc.types.non_null(_schema.TriplesOrderBy)), default=('DATE_ACCEPTED_DESC',))))
+    _op_triples = _op.triples(first=sgqlc.types.Variable('first'), after=sgqlc.types.Variable('after'), condition=sgqlc.types.Variable('condition'), order_by=sgqlc.types.Variable('orderBy'))
+    _op_triples_page_info = _op_triples.page_info()
+    _op_triples_page_info.end_cursor()
+    _op_triples_page_info.has_previous_page()
+    _op_triples_page_info.has_next_page()
+    _op_triples_edges = _op_triples.edges()
+    _op_triples_edges_node = _op_triples_edges.node()
+    _op_triples_edges_node.__fragment__(fragment_triple_widget())
     return _op