feat(interactive): add http service in Insight (#4464)

<!--
Thanks for your contribution! please review
https://github.com/alibaba/GraphScope/blob/main/CONTRIBUTING.md before
opening an issue.
-->

## What do these changes do?

<!-- Please give a short brief about these changes. -->

As titled.

## Related issue number

<!-- Are there any issues opened that will be resolved by merging this
change? -->

Fixes

---------

Co-authored-by: shirly121 <[email protected]>
Co-authored-by: 霄磊 <[email protected]>

Author: 3 people

.github/workflows/gss.yml

@@ -102,6 +102,11 @@ jobs:
         cp -r flex/interactive/examples/movies /tmp/gstest/
         cd interactive_engine/groot-client && ./gopt_groot_test.sh
 
+    - name: Groot Http Test
+      run: |
+        . ${HOME}/.graphscope_env
+        cd interactive_engine/groot-client && ./groot_http_test.sh
+
     - name: Upload tools for helm test to Artifact
       uses: actions/upload-artifact@v4
       with:

.github/workflows/interactive.yml

@@ -213,6 +213,7 @@ jobs:
         cd ${GITHUB_WORKSPACE}/flex/tests/hqps
         sed -i 's/interactive_workspace/temp_workspace/g' ./interactive_config_test.yaml
         bash hqps_sdk_test.sh ${TMP_INTERACTIVE_WORKSPACE} ./interactive_config_test.yaml java
+        export ENGINE_TYPE=interactive
         bash hqps_sdk_test.sh ${TMP_INTERACTIVE_WORKSPACE} ./interactive_config_test.yaml python
         sed -i 's/temp_workspace/interactive_workspace/g' ./interactive_config_test.yaml
   

.gitignore

@@ -58,6 +58,7 @@ docs/flex/interactive/development/java/*
 docs/flex/interactive/development/python/*
 !docs/flex/interactive/development/python/*Api.md
 !docs/flex/interactive/development/python/python_sdk.md
+!docs/flex/interactive/development/python/python_sdk_ref.md
 docs/flex/interactive/development/restful_api.html
 docs/flex/coordinator/development/python/*
 
@@ -167,6 +168,16 @@ flex/interactive/sdk/python/gs_interactive/rest.py
 !flex/interactive/sdk/python/gs_interactive/models/time_stamp_type.py
 !flex/interactive/sdk/python/gs_interactive/models/date_type.py
 
+interactive_engine/groot-http/src/main/java/com/alibaba/graphscope/groot/service/models/
+interactive_engine/groot-http/.openapi-generator/
+interactive_engine/groot-http/src/main/java/org/
+interactive_engine/groot-http/src/main/resources/
+interactive_engine/groot-http/src/main/java/com/alibaba/graphscope/groot/service/api/V1Api.java
+!interactive_engine/groot-http/src/main/java/com/alibaba/graphscope/groot/service/models/GSDataType.java
+!interactive_engine/groot-http/src/main/java/com/alibaba/graphscope/groot/service/models/StringTypeString.java
+!interactive_engine/groot-http/src/main/java/com/alibaba/graphscope/groot/service/models/TemporalTypeTemporal.java
+interactive_engine/groot-http/src/test/
+interactive_engine/groot-http/src/main/java/com/alibaba/graphscope/groot/RFC3339DateFormat.java
 
 **/.cache/
 

charts/graphscope-store/templates/configmap.yaml

@@ -36,6 +36,7 @@ data:
 
     ## Frontend Config
     frontend.service.port={{ .Values.frontend.service.servicePort }}
+    frontend.service.httpPort={{ .Values.frontend.service.httpPort }}
     frontend.server.id=INDEX
     frontend.server.num={{ .Values.frontend.replicaCount }}
 
@@ -171,6 +172,10 @@ data:
     # export MALLOC_CONF=prof:true,lg_prof_interval:29,lg_prof_sample:19,prof_prefix=/tmp
 
     export RUST_BACKTRACE=1
+    if [ "$ROLE" = "frontend" ]; then
+      echo "Starting groot-http Spring Boot service..."
+      ${GRAPHSCOPE_HOME}/groot/bin/store_ctl.sh start_http &
+    fi
     ${GRAPHSCOPE_HOME}/groot/bin/store_ctl.sh start ${ROLE}  # || sleep infinity
   portal_setup.sh: |-
     #!/bin/bash

charts/graphscope-store/values.yaml

@@ -139,6 +139,8 @@ frontend:
 
     cypherPort: 7687
 
+    httpPort: 8080
+
     ## Internal port for communication between components.
     ##
     port: 55555

docs/flex/interactive/dev_guide.md

@@ -11,6 +11,7 @@ maxdepth: 2
 development/dev_and_test
 development/java/java_sdk
 development/python/python_sdk
+development/python/python_sdk_ref
 development/restful_api
 development/stored_procedure/cypher_procedure
 development/stored_procedure/cpp_procedure

docs/flex/interactive/development/java/EdgeApi.md

@@ -38,16 +38,16 @@ public class Example {
                     .srcLabel("person")
                     .dstLabel("person")
                     .edgeLabel("knows")
-                    .srcPrimaryKeyValue(2)
-                    .dstPrimaryKeyValue(4)
+                    .srcPrimaryKeyValues(Arrays.asList(new Property().name("id").value(2)))
+                    .dstPrimaryKeyValues(Arrays.asList(new Property().name("id").value(4)))
                     .addPropertiesItem(new Property().name("weight").value(9.123));
     EdgeRequest edgeRequest4 =
             new EdgeRequest()
                     .srcLabel("person")
                     .dstLabel("person")
                     .edgeLabel("knows")
-                    .srcPrimaryKeyValue(2)
-                    .dstPrimaryKeyValue(6)
+                    .srcPrimaryKeyValues(Arrays.asList(new Property().name("id").value(2)))
+                    .dstPrimaryKeyValues(Arrays.asList(new Property().name("id").value(6)))
                     .addPropertiesItem(new Property().name("weight").value(3.233));
     List<EdgeRequest> edgeRequests = new ArrayList<>();
     edgeRequests.add(edgeRequest3);
@@ -187,8 +187,8 @@ public class Example {
                 .srcLabel("person")
                 .dstLabel("person")
                 .edgeLabel("knows")
-                .srcPrimaryKeyValue(2)
-                .dstPrimaryKeyValue(4)
+                .srcPrimaryKeyValues(Arrays.asList(new Property().name("id").value(2)))
+                .dstPrimaryKeyValues(Arrays.asList(new Property().name("id").value(4)))
                 .addPropertiesItem(new Property().name("weight").value(3.0));
     Result<String> updateEdgeResponse = session.updateEdge(graphId, updateEdgeRequest);
     if (!updateEdgeResponse.isOk()) {

docs/flex/interactive/development/java/VertexApi.md

@@ -37,7 +37,7 @@ public class Example {
     VertexRequest vertexRequest =
         new VertexRequest()
                 .label("person")
-                .primaryKeyValue(8)
+                .primaryKeyValues(Arrays.asList(new Property().name("id").value(8)))
                 .addPropertiesItem(new Property().name("name").value("mike"))
                 .addPropertiesItem(new Property().name("age").value(12));
     VertexEdgeRequest vertexEdgeRequest =
@@ -179,7 +179,7 @@ public class Example {
     VertexRequest updateVertexRequest =
         new VertexRequest()
                 .label("person")
-                .primaryKeyValue(8)
+                .primaryKeyValues(Arrays.asList(new Property().name("id").value(8)))
                 .addPropertiesItem(new Property().name("name").value("Cindy"))
                 .addPropertiesItem(new Property().name("age").value(24));
     Result<String> updateVertexResponse = session.updateVertex(graphId, updateVertexRequest);

docs/flex/interactive/development/python/EdgeApi.md

@@ -7,7 +7,7 @@ Method | HTTP request | Description
 [**add_edge**](EdgeApi.md#add_edge) | **POST** /v1/graph/{graph_id}/edge | Add edge to the graph
 [**get_edge**](EdgeApi.md#get_edge) | **GET** /v1/graph/{graph_id}/edge | Get the edge's properties with src and dst vertex primary keys.
 [**update_edge**](EdgeApi.md#update_edge) | **PUT** /v1/graph/{graph_id}/edge | Update edge's property
-
+[**delete_edge**](EdgeApi.md#deleteEdge) | **DELETE** /v1/graph/{graph_id}/edge | Remove edge from the graph
 
 # **add_edge**
 > [Result](./result.rst)[str] add_edge(graph_id, edge_request)
@@ -32,16 +32,16 @@ edge_request = [
         src_label="person",
         dst_label="person",
         edge_label="knows",
-        src_primary_key_value=2,
-        dst_primary_key_value=4,
+        src_primary_key_values=[ModelProperty(name="id", value=2)],
+        dst_primary_key_value=[ModelProperty(name="id", value=4)],
         properties=[ModelProperty(name="weight", value=9.123)],
     ),
     EdgeRequest(
         src_label="person",
         dst_label="person",
         edge_label="knows",
-        src_primary_key_value=2,
-        dst_primary_key_value=6,
+        src_primary_key_values=[ModelProperty(name="id", value=2)],
+        dst_primary_key_values=[ModelProperty(name="id", value=6)],
         properties=[ModelProperty(name="weight", value=3.233)],
     ),
 ]
@@ -178,8 +178,8 @@ resp = sess.update_edge(
         src_label="person",
         dst_label="person",
         edge_label="knows",
-        src_primary_key_value=2,
-        dst_primary_key_value=4,
+        src_primary_key_values=[ModelProperty(name="id", value=2)],
+        dst_primary_key_values=[ModelProperty(name="id", value=4)],
         properties=[ModelProperty(name="weight", value=3)],
     ),
 )
@@ -220,3 +220,75 @@ No authorization required
 
 [[Back to top]](#) [[Back to API list]](python_sdk.md#documentation-for-service-apis) [[Back to Model list]](python_sdk.md#documentation-for-data-structures) [[Back to python_sdk]](python_sdk.md)
 
+# **delete_edge**
+> [Result](./result.rst)[str] delete_edge(graph_id, delete_edge_request)
+
+Delete an edge from the graph.
+
+### Example
+
+
+```python
+from gs_interactive.client.driver import Driver
+from gs_interactive.client.session import Session
+from gs_interactive.models import *
+
+driver = Driver()
+sess = driver.session()
+
+graph_id = "1"
+
+delete_edge_request = [
+    EdgeRequest(
+        src_label="person",
+        dst_label="person",
+        edge_label="knows",
+        src_primary_key_value=[ModelProperty(name="id", value=2)]
+        dst_primary_key_value=[ModelProperty(name="id", value=4)]
+    ),
+    EdgeRequest(
+        src_label="person",
+        dst_label="person",
+        edge_label="knows",
+        src_primary_key_value=[ModelProperty(name="id", value=2)]
+        dst_primary_key_value=[ModelProperty(name="id", value=6)]
+    ),
+]
+resp = sess.delete_edge(graph_id, [delete_edge_request])
+print(resp)
+assert resp.is_ok()
+```
+
+
+
+### Parameters
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+ **graph_id** | **str**|  | 
+ **delete_edge_request** | [**List[DeleteEdgeRequest]**](DeleteEdgeRequest.md)|  | 
+
+### Return type
+
+[Result](./result.rst)[str]
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+ - **Content-Type**: application/json
+ - **Accept**: application/json
+
+### HTTP response details
+
+| Status code | Description | Response headers |
+|-------------|-------------|------------------|
+**200** | Successfully insert the edge |  -  |
+**400** | Invalid input edge |  -  |
+**404** | Graph or edge not exists |  -  |
+**500** | Server internal error |  -  |
+
+[[Back to top]](#) [[Back to API list]](python_sdk.md#documentation-for-service-apis) [[Back to Model list]](python_sdk.md#documentation-for-data-structures) [[Back to python_sdk]](python_sdk.md)