oceanprotocol/squid-js
1
0
Fork 0
mirror of https://github.com/oceanprotocol-archive/squid-js.git synced 2024-02-02 15:31:51 +01:00
Code Releases Activity

Fix Aquarius tests using new way to call to services.

Browse Source
This commit is contained in:
Pedro Gutiérrez 2019-05-08 16:55:58 +02:00 committed by Pedro Gutiérrez
parent d779adc0a3
commit 33a9939b47
1 changed files with 26 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
test/aquarius/Aquarius.test.ts
View File

@ -1,19 +1,34 @@
import { assert } from "chai" import { assert, spy, use } from "chai"
import * as spies from "chai-spies"
import { Ocean } from "../../src/ocean/Ocean"
import { Aquarius } from "../../src/aquarius/Aquarius" import { Aquarius } from "../../src/aquarius/Aquarius"
import { SearchQuery } from "../../src/aquarius/Aquarius" import { SearchQuery } from "../../src/aquarius/Aquarius"
import { DDO } from "../../src/ddo/DDO" import { DDO } from "../../src/ddo/DDO"
import DID from "../../src/ocean/DID" import DID from "../../src/ocean/DID"
import WebServiceConnectorProvider from "../../src/utils/WebServiceConnectorProvider"
import config from "../config" import config from "../config"
import WebServiceConnectorMock from "../mocks/WebServiceConnector.mock"
use(spies)
const reponsify = async data => ({ok: true, json: () => Promise.resolve(data)})
describe("Aquarius", () => { describe("Aquarius", () => {
const aquarius: Aquarius = new Aquarius({config} as any) let ocean: Ocean
let aquarius: Aquarius
// tslint:disable-next-line // tslint:disable-next-line
const getResults = (results: DDO[], page = 0, total_pages = 1, total_results = 1) => const getResults = (results: DDO[], page = 0, total_pages = 1, total_results = 1) =>
({results, page, total_pages, total_results}) ({results, page, total_pages, total_results})
beforeEach(async () => {
ocean = await Ocean.getInstance(config)
aquarius = ocean.aquarius
})
afterEach(() => {
spy.restore()
})
describe("#queryMetadata()", () => { describe("#queryMetadata()", () => {
const query = { const query = {
@ -29,8 +44,7 @@ describe("Aquarius", () => {
} as SearchQuery } as SearchQuery
it("should query metadata", async () => { it("should query metadata", async () => {
// @ts-ignore spy.on(ocean.utils.fetch, 'post', () => reponsify(getResults([new DDO()])))
WebServiceConnectorProvider.setConnector(new WebServiceConnectorMock(getResults([new DDO()])))
const result = await aquarius.queryMetadata(query) const result = await aquarius.queryMetadata(query)
assert.typeOf(result.results, "array") assert.typeOf(result.results, "array")
@ -42,8 +56,7 @@ describe("Aquarius", () => {
it("should query metadata and return real ddo", async () => { it("should query metadata and return real ddo", async () => {
// @ts-ignore spy.on(ocean.utils.fetch, 'post', () => reponsify(getResults([new DDO()])))
WebServiceConnectorProvider.setConnector(new WebServiceConnectorMock(getResults([new DDO()])))
const result = await aquarius.queryMetadata(query) const result = await aquarius.queryMetadata(query)
assert.typeOf(result.results, "array") assert.typeOf(result.results, "array")
@ -68,8 +81,7 @@ describe("Aquarius", () => {
it("should query metadata by text", async () => { it("should query metadata by text", async () => {
// @ts-ignore spy.on(ocean.utils.fetch, 'get', () => reponsify(getResults([new DDO()])))
WebServiceConnectorProvider.setConnector(new WebServiceConnectorMock(getResults([new DDO()])))
const result = await aquarius.queryMetadataByText(query) const result = await aquarius.queryMetadataByText(query)
assert.typeOf(result.results, "array") assert.typeOf(result.results, "array")
@ -81,8 +93,7 @@ describe("Aquarius", () => {
it("should query metadata and return real ddo", async () => { it("should query metadata and return real ddo", async () => {
// @ts-ignore spy.on(ocean.utils.fetch, 'get', () => reponsify(getResults([new DDO()])))
WebServiceConnectorProvider.setConnector(new WebServiceConnectorMock(getResults([new DDO()])))
const result = await aquarius.queryMetadataByText(query) const result = await aquarius.queryMetadataByText(query)
assert.typeOf(result.results, "array") assert.typeOf(result.results, "array")
@ -101,8 +112,7 @@ describe("Aquarius", () => {
id: did.getId(), id: did.getId(),
}) })
// @ts-ignore spy.on(ocean.utils.fetch, 'post', () => reponsify(ddo))
WebServiceConnectorProvider.setConnector(new WebServiceConnectorMock(ddo))
const result: DDO = await aquarius.storeDDO(ddo) const result: DDO = await aquarius.storeDDO(ddo)
assert(result) assert(result)
@ -119,8 +129,8 @@ describe("Aquarius", () => {
id: did.getId(), id: did.getId(),
}) })
// @ts-ignore spy.on(ocean.utils.fetch, 'post', () => reponsify(ddo))
WebServiceConnectorProvider.setConnector(new WebServiceConnectorMock(ddo)) spy.on(ocean.utils.fetch, 'get', () => reponsify(ddo))
const storageResult: DDO = await aquarius.storeDDO(ddo) const storageResult: DDO = await aquarius.storeDDO(ddo)
assert(storageResult) assert(storageResult)