-
Notifications
You must be signed in to change notification settings - Fork 1
Add create graph endpoint #487
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
jreynard-code
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM ;)
As we discussed, changes will be done after merge...
...rc/integrationTest/kotlin/com/cosmotech/twingraph/service/TwingraphServiceIntegrationTest.kt
Show resolved
Hide resolved
...rc/integrationTest/kotlin/com/cosmotech/twingraph/service/TwingraphServiceIntegrationTest.kt
Show resolved
Hide resolved
| mutableMapOf( | ||
| "lastVersion" to "1", | ||
| "graphName" to graphId, | ||
| "graphRotation" to "3", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Could you please add graphRotation as optional parameter with default value to 2 ?
|
|
||
| queryBuffer.send() | ||
| } else { | ||
| getEntities(organizationId, graphId, "node", listOf("node_a")) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Add a comment please
twingraph/src/main/kotlin/com/cosmotech/twingraph/api/TwingraphServiceImpl.kt
Show resolved
Hide resolved
| } | ||
|
|
||
| (prop as String).also { | ||
| if (it == "") type = PropertyType.BI_NULL |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it.isNullOrBlank() instead
| fun addNodes(vararg nodesArg: Node) { | ||
| nodesArg.forEach { | ||
| if (it.properties.keys.any { s -> s !in header }) | ||
| // TODO create specific exception |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
To remove
| tasks.add(currentBulkQueryBuilder.build()) | ||
|
|
||
| tasks.forEach { query -> | ||
| println(query.toString()) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
To remove or replace by logger
| println(query.toString()) | ||
| val result = jedis.sendCommand({ "GRAPH.BULK".toByteArray() }, *query.generateQueryArgs()) | ||
|
|
||
| println((result as ByteArray).toString(Charset.defaultCharset())) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
To remove or replace by logger
| # - name: graph_model | ||
| # in: query | ||
| # description: the Graph Model | ||
| # required: false | ||
| # schema: | ||
| # type: object |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
To remove
No description provided.