mirror of
https://github.com/oceanprotocol-archive/squid-js.git
synced 2024-02-02 15:31:51 +01:00
155 lines
4.8 KiB
TypeScript
155 lines
4.8 KiB
TypeScript
import {assert} from "chai"
|
|
import AquariusConnectorProvider from "../../src/aquarius/AquariusConnectorProvider"
|
|
import AquariusProvider from "../../src/aquarius/AquariusProvider"
|
|
import SearchQuery from "../../src/aquarius/query/SearchQuery"
|
|
import ConfigProvider from "../../src/ConfigProvider"
|
|
import DDO from "../../src/ddo/DDO"
|
|
import MetaData from "../../src/ddo/MetaData"
|
|
import Service from "../../src/ddo/Service"
|
|
import Account from "../../src/ocean/Account"
|
|
import Ocean from "../../src/ocean/Ocean"
|
|
import ServiceAgreement from "../../src/ocean/ServiceAgreements/ServiceAgreement"
|
|
import SecretStoreProvider from "../../src/secretstore/SecretStoreProvider"
|
|
import config from "../config"
|
|
import TestContractHandler from "../keeper/TestContractHandler"
|
|
import AquariusMock from "../mocks/Aquarius.mock"
|
|
import AquariusConnectorMock from "../mocks/AquariusConnector.mock"
|
|
import SecretStoreMock from "../mocks/SecretStore.mock"
|
|
|
|
let ocean: Ocean
|
|
let accounts: Account[]
|
|
let testPublisher: Account
|
|
|
|
describe("Ocean", () => {
|
|
|
|
before(async () => {
|
|
ConfigProvider.setConfig(config)
|
|
AquariusProvider.setAquarius(new AquariusMock(config))
|
|
SecretStoreProvider.setSecretStore(new SecretStoreMock(config))
|
|
await TestContractHandler.prepareContracts()
|
|
ocean = await Ocean.getInstance(config)
|
|
accounts = await ocean.getAccounts()
|
|
|
|
testPublisher = accounts[0]
|
|
})
|
|
|
|
describe("#getInstance()", () => {
|
|
|
|
it("should get an instance of cean", async () => {
|
|
|
|
const oceanInstance: Ocean = await Ocean.getInstance(config)
|
|
|
|
assert(oceanInstance)
|
|
})
|
|
})
|
|
|
|
describe("#getAccounts()", () => {
|
|
|
|
it("should list accounts", async () => {
|
|
|
|
const accs: Account[] = await ocean.getAccounts()
|
|
|
|
assert(10 === accs.length)
|
|
assert(0 === (await accs[5].getBalance()).ocn)
|
|
assert("string" === typeof accs[0].getId())
|
|
})
|
|
|
|
})
|
|
|
|
describe("#registerAsset()", () => {
|
|
|
|
it("should register an asset", async () => {
|
|
|
|
const metaData: MetaData = new MetaData()
|
|
const ddo: DDO = await ocean.registerAsset(metaData, testPublisher)
|
|
|
|
assert(ddo)
|
|
assert(ddo.id.startsWith("did:op:"))
|
|
})
|
|
})
|
|
|
|
describe("#searchAssets()", () => {
|
|
|
|
it("should search for assets", async () => {
|
|
|
|
const query = {
|
|
offset: 100,
|
|
page: 0,
|
|
query: {
|
|
value: 1,
|
|
},
|
|
sort: {
|
|
value: 1,
|
|
},
|
|
text: "Office",
|
|
} as SearchQuery
|
|
|
|
const assets: any[] = await ocean.searchAssets(query)
|
|
|
|
assert(assets)
|
|
})
|
|
|
|
})
|
|
|
|
describe("#searchAssetsByText()", () => {
|
|
|
|
it("should search for assets", async () => {
|
|
const text = "office"
|
|
const assets: any[] = await ocean.searchAssetsByText(text)
|
|
|
|
assert(assets)
|
|
})
|
|
|
|
})
|
|
|
|
describe("#signServiceAgreement()", () => {
|
|
|
|
it("should sign an service agreement", async () => {
|
|
|
|
const publisher = accounts[0]
|
|
const consumer = accounts[1]
|
|
|
|
const ddo: DDO = await ocean.registerAsset(new MetaData(), publisher)
|
|
|
|
const service: Service = ddo.findServiceByType("Access")
|
|
|
|
// @ts-ignore
|
|
AquariusConnectorProvider.setConnector(new AquariusConnectorMock(ddo))
|
|
|
|
const serviceAgreementSignature: any = await ocean.signServiceAgreement(ddo.id,
|
|
service.serviceDefinitionId, consumer)
|
|
|
|
assert(serviceAgreementSignature)
|
|
assert(serviceAgreementSignature.serviceAgreementId)
|
|
assert(serviceAgreementSignature.serviceAgreementSignature)
|
|
assert(serviceAgreementSignature.serviceAgreementSignature.startsWith("0x"))
|
|
})
|
|
|
|
})
|
|
|
|
describe("#executeServiceAgreement()", () => {
|
|
|
|
it("should execute an service agreement", async () => {
|
|
|
|
const publisher = accounts[0]
|
|
const consumer = accounts[1]
|
|
|
|
const ddo: DDO = await ocean.registerAsset(new MetaData(), publisher)
|
|
const service: Service = ddo.findServiceByType("Access")
|
|
|
|
// @ts-ignore
|
|
AquariusConnectorProvider.setConnector(new AquariusConnectorMock(ddo))
|
|
|
|
const signServiceAgreementResult: any = await ocean.signServiceAgreement(ddo.id,
|
|
service.serviceDefinitionId, consumer)
|
|
|
|
const serviceAgreement: ServiceAgreement = await ocean.executeServiceAgreement(ddo.id,
|
|
service.serviceDefinitionId, signServiceAgreementResult.serviceAgreementId,
|
|
signServiceAgreementResult.serviceAgreementSignature, consumer, publisher)
|
|
|
|
assert(serviceAgreement)
|
|
})
|
|
|
|
})
|
|
})
|