import * as assert from "assert"
import Aquarius from "../../src/aquarius/Aquarius"
import AquariusConnectorProvider from "../../src/aquarius/AquariusConnectorProvider"
import SearchQuery from "../../src/aquarius/query/SearchQuery"
import DDO from "../../src/ddo/DDO"
import IdGenerator from "../../src/ocean/IdGenerator"
import config from "../config"
import AquariusConnectorMock from "../mocks/AquariusConnector.mock"
// import * as jsonDDO from "../testdata/ddo.json"

describe("Aquarius", () => {

    const aquarius: Aquarius = new Aquarius(config)
    describe("#queryMetadata()", () => {

        it("should query metadata", async () => {

            const query = {
                offset: 100,
                page: 0,
                query: {
                    value: 1,
                },
                sort: {
                    value: 1,
                },
                text: "Office",
            } as SearchQuery

            // @ts-ignore
            AquariusConnectorProvider.setConnector(new AquariusConnectorMock())

            const result: any[] = await aquarius.queryMetadata(query)
            assert(result)
            assert(result.length !== null)
        })

    })

    describe("#queryMetadataByText()", () => {

        it("should query metadata by text", async () => {

            const query = {
                offset: 100,
                page: 0,
                query: {
                    value: 1,
                },
                sort: {
                    value: 1,
                },
                text: "Office",
            } as SearchQuery

            // @ts-ignore
            AquariusConnectorProvider.setConnector(new AquariusConnectorMock())

            const result: any[] = await aquarius.queryMetadataByText(query)
            assert(result)
            assert(result.length !== null)
        })

    })

    describe("#storeDDO()", () => {

        it("should store a ddo", async () => {

            const did: string = `did:op:${IdGenerator.generateId()}`
            const ddo: DDO = new DDO({
                id: did,
            })

            // @ts-ignore
            AquariusConnectorProvider.setConnector(new AquariusConnectorMock(ddo))

            const result: DDO = await aquarius.storeDDO(ddo)
            assert(result)
            assert(result.id === ddo.id)
        })
    })

    describe("#retrieveDDO()", () => {

        it("should store a ddo", async () => {

            const did: string = `did:op:${IdGenerator.generateId()}`
            const ddo: DDO = new DDO({
                id: did,
            })

            // @ts-ignore
            AquariusConnectorProvider.setConnector(new AquariusConnectorMock(ddo))

            const storageResult: DDO = await aquarius.storeDDO(ddo)
            assert(storageResult)

            assert(storageResult.id === did)

            const restrieveResult: DDO = await aquarius.retrieveDDO(did)
            assert(restrieveResult)

            assert(restrieveResult.id === did)
            assert(restrieveResult.id === storageResult.id)
        })
    })
})