feat: add composedb correctness test that perfroms parallelization #115
Conversation
|
|
||
| export const MultiQuerySchema = ` | ||
| type MultiQuerySchema @createModel(accountRelation: LIST, description: "A set of unique numbers") | ||
| @createIndex(fields: [{ path: "myData" }]){ | ||
| myData: String! @string(maxLength: 500) | ||
| }` |
There was a problem hiding this comment.
Seems to be the same schema as the BasicSchema above, any reason to duplicate please?
There was a problem hiding this comment.
Yes, we want to plug in the schema that gitcoin uses or something similar. This is a TODO
|
|
||
| const queryResponses = await Promise.all(queryPromises) | ||
| queryResponses.forEach((queryResponse) => { | ||
| const queryResponseObj = JSON.parse(JSON.stringify(queryResponse)) |
There was a problem hiding this comment.
What is the purpose of the stringify+parse here please?
There was a problem hiding this comment.
create a deep copy of the queryResponse
There was a problem hiding this comment.
Why does it need a deep copy of the data here please?
| for (let i = 0; i < parallelIterations; i++) { | ||
| queryPromises.push( | ||
| composeClient3.executeQuery(getDocumentsByStreamIdQuery, getDocumentsByStreamIdVariables), | ||
| ) | ||
| } |
There was a problem hiding this comment.
What is the expected behavior here please?
Seems like this is going to execute 20 queries using the 20 IDs of the created documents? It's likely the batching logic of the ComposeDB runtime will dedupe the calls though, so in effect it should only perform a single multiquery of 20 documents.
If the goal is to create load on the node, better use the Ceramic APIs directly I think.
There was a problem hiding this comment.
We want to perform 20 multi-query operations simultaneously. So the query of getDocumentsByStreamId will have to change.
|
|
||
| test('Create 20 model instance documents in a second and query them from the same node using mult query in the same node, query 20 times ina second', async () => { | ||
| for (let i = 0; i < transactionIterations; i++) { | ||
| // TODO : Add whatever mutation gitcoin was doing |
There was a problem hiding this comment.
@PaulLeCam We want to plug in the mutation which will enable us to perform a multi-query here
| const documentIds = await Promise.all(createDocumentPromises) | ||
| documentIds.forEach((id) => expect(id).toBeDefined()) | ||
|
|
||
| // TODO: Create a multi query instead of simple query |
There was a problem hiding this comment.
@PaulLeCam We want to create a graphql query which perfoems multi-query
Composedb test for investigating gotcoin failures