Skip to content

Commit

Permalink
add test for a large plan
Browse files Browse the repository at this point in the history
  • Loading branch information
@LeosPrograms
LeosPrograms committed May 15, 2024
1 parent 7002c87 commit 88c29d1
Showing 1 changed file with 386 additions and 0 deletions.
386 changes: 386 additions & 0 deletions test/plan/test_plan_large.js
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,386 @@
import test from 'tape'
import { pause } from '@holochain/tryorama'
import {
buildPlayer,
mockIdentifier,
mockAddress,
} from '../init.js'

const testCommitmentProps = {
action: 'raise',
resourceClassifiedAs: ['some-resource-type'],
resourceQuantity: { hasNumericalValue: 1, hasUnit: mockIdentifier() },
provider: mockAddress(),
receiver: mockAddress(),
}

test('Plan links & queries', async (t) => {
// display the filename for context in the terminal and use .warn
// to override the tap testing log filters
console.warn(`\n\n${import.meta.url}`)
const alice = await buildPlayer(['combined'])

// ===CREATE PLAN===
let start = new Date()
try {
let resp = await alice.graphQL(`
mutation($rs: PlanCreateParams!) {
res: createPlan(plan: $rs) {
plan {
id
}
}
}
`, {
rs: {
name: 'test plan',
created: new Date(),
due: new Date(),
note: 'just testing, nothing was rly planned',
},
})
let end = new Date()
console.log('⏱︎ time to create plan:', (end - start) * 0.001, 'seconds ⏱︎')
t.ok(resp.data.res.plan.id, 'plan created')
const planId = resp.data.res.plan.id

// ===CREATE 4 COMMITMENTS AND 4 PROCESSES===
// define async function to create a process and commitment
const createProcessAndCommitment = async (processName, commitmentNote) => {
const resp = await alice.graphQL(`
mutation($p: ProcessCreateParams!, $c: CommitmentCreateParams!) {
process: createProcess(process: $p) {
process {
id
}
}
commitment: createCommitment(commitment: $c) {
commitment {
id
}
}
}
`, {
p: {
plannedWithin: planId,
name: processName,
note: 'linked process note 1',
},
c: {
independentDemandOf: planId,
plannedWithin: planId,
note: commitmentNote,
due: new Date(Date.now() + 86400000),
...testCommitmentProps,
},
})
return resp.data.process.process.id
}

start = new Date()
let processId1 = await createProcessAndCommitment('linked process name 1', 'linked commitment 1')
t.ok(processId1, 'process 1 created')
let processId2 = await createProcessAndCommitment('linked process name 2', 'linked commitment 2')
t.ok(processId2, 'process 2 created')
let processId3 = await createProcessAndCommitment('linked process name 3', 'linked commitment 3')
t.ok(processId3, 'process 3 created')
let processId4 = await createProcessAndCommitment('linked process name 4', 'linked commitment 4')
t.ok(processId4, 'process 4 created')
end = new Date()

console.log('⏱︎ time to create 4 commitments and 4 processes:', (end - start) * 0.001 , 'seconds ⏱︎')

// ===ADD ORGANIZATION===
const exampleOrganization = {
name: 'test organization',
image: 'https://org.png',
classifiedAs: ['org'],
note: 'test organization note',
}
start = new Date()
let createOrgResp = await alice.graphQL(
`
mutation($rs: OrganizationCreateParams!) {
res: createOrganization(organization: $rs) {
agent {
id
revisionId
}
}
}
`,
{
rs: exampleOrganization,
},
)
end = new Date()
console.log('⏱︎ time to create organization:', (end - start) * 0.001, 'seconds ⏱︎')
let organizationId = createOrgResp.data.res.agent.id

// ===ADD UNIT DOLLAR===
start = new Date()
resp = await alice.graphQL(`
mutation($u: UnitCreateParams!) {
res: createUnit(unit: $u) {
unit {
id
}
}
}
`, {
u: {
label: 'US Dollar',
symbol: 'USD',
},
})
end = new Date()
console.log('⏱︎ time to create unit:', (end - start) * 0.001, 'seconds ⏱︎')
t.ok(resp.data.res.unit.id, 'unit created')
const unitId = resp.data.res.unit.id

// ===ADD RESOURCE SPECIFICATION===
start = new Date()
resp = await alice.graphQL(`
mutation($rs: ResourceSpecificationCreateParams!) {
res: createResourceSpecification(resourceSpecification: $rs) {
resourceSpecification {
id
}
}
}
`, {
rs: {
name: 'test resource specification',
defaultUnitOfResource: unitId,
note: 'test resource specification note',
},
})
end = new Date()
console.log("RS ID", resp.data.res.resourceSpecification.id)
console.log('⏱︎ time to create resource specification:', (end - start) * 0.001, 'seconds ⏱︎')
t.ok(resp.data.res.resourceSpecification.id, 'resource specification created')
const resourceSpecificationId = resp.data.res.resourceSpecification.id

// ===ADD INPUT AND OUTPUT COMMITMENTS TO PROCESS===
const addInputAndOutputCommitments = async (processId) => {
let com3 = {
'action': 'pickup',
'inputOf': processId,
'provider': organizationId,
'receiver': organizationId,
'due': '2019-11-19T04:29:55.056Z',
'resourceQuantity': { hasNumericalValue: 1, hasUnit: unitId },
'resourceClassifiedAs': ['some-resource-type'],
'note': 'some input will be provided',
}

let com4 = {
'action': 'dropoff',
'outputOf': processId,
'provider': organizationId,
'receiver': organizationId,
'due': '2019-11-19T04:29:55.056Z',
'resourceQuantity': { hasNumericalValue: 1, hasUnit: unitId },
'resourceClassifiedAs': ['some-resource-type'],
'note': 'some input will be provided',
}

resp = await alice.graphQL(`
mutation($c1: CommitmentCreateParams!, $c2: CommitmentCreateParams!) {
commitment1: createCommitment(commitment: $c1) {
commitment {
id
}
}
commitment2: createCommitment(commitment: $c1) {
commitment {
id
}
}
commitment3: createCommitment(commitment: $c1) {
commitment {
id
}
}
commitment4: createCommitment(commitment: $c1) {
commitment {
id
}
}
commitment5: createCommitment(commitment: $c2) {
commitment {
id
}
}
commitment6: createCommitment(commitment: $c2) {
commitment {
id
}
}
commitment7: createCommitment(commitment: $c2) {
commitment {
id
}
}
commitment8: createCommitment(commitment: $c2) {
commitment {
id
}
}
}
`, {
c1: com3,
c2: com4,
})
}


start = new Date()
console.log("creating commitments", start)
await addInputAndOutputCommitments(processId1)
await addInputAndOutputCommitments(processId2)
await addInputAndOutputCommitments(processId3)
await addInputAndOutputCommitments(processId4)
end = new Date()
console.log("commitments created", end)
console.log('⏱︎ time to add 4 input and 4 output commitments to 4 process:', (end - start) * 0.001, 'seconds ⏱︎')

// ===RETRIEVE FULL PLAN===
start = new Date()
resp = await alice.graphQL(`
query {
plan(id: "${planId}") {
independentDemands {
id
}
processes {
id
revisionId
name
meta {
retrievedRevision {
id
time
}
}
committedInputs {
id
revisionId
hasBeginning
action {
id
label
}
meta {
retrievedRevision {
id
time
}
}
providerId
provider {
id
name
}
}
committedOutputs {
id
revisionId
hasBeginning
action {
id
label
}
meta {
retrievedRevision {
id
time
}
}
providerId
provider {
id
name
}
receiverId
resourceQuantity {
hasNumericalValue
hasUnitId
}
}
}
}
}
`,
)
end = new Date()
console.log('⏱︎ time to query full plan:', (end - start) * 0.001, 'seconds ⏱︎')
// t.equal(resp.data.process.plannedWithin.id, planId, 'process -> plan ref OK')
// t.equal(resp.data.commitment.independentDemandOf.id, planId, 'commitment -> plan ref OK')
// t.equal(resp.data.commitment.plannedWithin.id, planId, 'commitment -> plan ref OK')
// t.equal(resp.data.plan.independentDemands.length, 1, 'commitment ref added')
// t.equal(resp.data.plan.independentDemands[0].id, cId, 'commitment ref OK')
// t.equal(resp.data.plan.processes.length, 1, 'process ref added')
// t.equal(resp.data.plan.processes[0].id, pId, 'process ref OK')

// resp = await alice.graphQL(`
// mutation($p: ProcessCreateParams!, $c: CommitmentCreateParams!) {
// process: createProcess(process: $p) {
// process {
// id
// }
// }
// commitment: createCommitment(commitment: $c) {
// commitment {
// id
// }
// }
// }
// `, {
// p: {
// plannedWithin: planId,
// name: 'linked process name 2',
// note: 'linked process note 2',
// },
// c: {
// independentDemandOf: planId,
// // plannedWithin: planId, // not able to add this yet as this field is not currently defined in the CreateCommitmentParams object
// note: 'linked commitment 2',
// due: new Date(Date.now() + 86400000),
// ...testCommitmentProps,
// },
// })
// await pause(100)
// t.ok(resp.data.process.process.id, 'event 2 created')
// t.ok(resp.data.commitment.commitment.id, 'commitment 2 created')
// const p2Id = resp.data.process.process.id
// const c2Id = resp.data.commitment.commitment.id

// resp = await alice.graphQL(`
// query {
// plan(id: "${planId}") {
// independentDemands {
// id
// }
// processes {
// id
// }
// }
// }
// `)

// const sortedCIds = [{ id: c2Id }, { id: cId }]
// const sortedPIds = [{ id: p2Id }, { id: pId }]

// t.equal(resp.data.plan.independentDemands.length, 2, '2nd commitment ref added')
// t.equal(resp.data.plan.independentDemands[0].id, sortedCIds[0].id, 'commitment ref 1 OK')
// t.equal(resp.data.plan.independentDemands[1].id, sortedCIds[1].id, 'commitment ref 2 OK')
// t.equal(resp.data.plan.processes.length, 2, '2nd event ref added')
// t.equal(resp.data.plan.processes[0].id, sortedPIds[0].id, 'process ref 1 OK')
// t.equal(resp.data.plan.processes[1].id, sortedPIds[1].id, 'process ref 2 OK')
} catch (e) {
await alice.scenario.cleanUp()
throw e
}
await alice.scenario.cleanUp()
})

0 comments on commit 88c29d1

Please sign in to comment.