diff --git a/integration/ocean/ConsumeAsset.test.ts b/integration/ocean/ConsumeAsset.test.ts index 48a933b..9e4c679 100644 --- a/integration/ocean/ConsumeAsset.test.ts +++ b/integration/ocean/ConsumeAsset.test.ts @@ -99,8 +99,8 @@ describe('Consume Asset', () => { it('should get the agreement conditions status not fulfilled', async () => { // Wait for the agreement event - await ocean.keeper.agreementStoreManager - .getAgreementCreatedEvent(serviceAgreementSignatureResult.agreementId).once() + // await ocean.keeper.agreementStoreManager + // .getAgreementCreatedEvent(serviceAgreementSignatureResult.agreementId).once() const status = await ocean.agreements.status( serviceAgreementSignatureResult.agreementId ) diff --git a/src/keeper/contracts/managers/AgreementStoreManager.ts b/src/keeper/contracts/managers/AgreementStoreManager.ts index d3b7971..cd57b01 100644 --- a/src/keeper/contracts/managers/AgreementStoreManager.ts +++ b/src/keeper/contracts/managers/AgreementStoreManager.ts @@ -68,7 +68,7 @@ export class AgreementStoreManager extends ContractBase { actors: string[], from?: string ): Promise { - this.sendFrom( + return this.sendFrom( 'createAgreement', [ zeroX(agreementId), diff --git a/src/ocean/OceanAgreements.ts b/src/ocean/OceanAgreements.ts index 0ba2dd3..8311499 100644 --- a/src/ocean/OceanAgreements.ts +++ b/src/ocean/OceanAgreements.ts @@ -123,7 +123,7 @@ export class OceanAgreements extends Instantiable { const ddo = await this.ocean.aquarius.retrieveDDO(d) const service = ddo.findServiceById(index) const templateName = service.attributes.serviceAgreementTemplate.contractName - await this.ocean.keeper + return await this.ocean.keeper .getTemplateByName(templateName) .createAgreementFromDDO( agreementId, @@ -133,8 +133,6 @@ export class OceanAgreements extends Instantiable { provider, from.getId() ) - - return true } /**