tests: api

.eslintrc.json

@@ -11,5 +11,19 @@
     "rules": {
       "no-unused-expressions": "off"
     }
-  }]
+  }, {
+    "files": ["*.test.ts"],
+    "rules": {
+      "import/no-unresolved": "off"
+    }
+  }],
+  "settings": {
+    "import/resolver": {
+      "typescript": {
+        "project": [
+          "packages/*/tsconfig.json"
+        ]
+      }
+    }
+  }
 }

mocha-setup.js

@@ -3,6 +3,7 @@ require('@babel/register')({
   configFile: './babel.config.json',
   extensions: ['.js', '.jsx', '.ts', '.tsx'],
 })
+require('tsconfig-paths/register')
 
 require('chai-snapshot-matcher')
 

package.json

@@ -90,6 +90,7 @@
     ]
   },
   "devDependencies": {
-    "eslint-import-resolver-typescript": "^2.4.0"
+    "eslint-import-resolver-typescript": "^2.4.0",
+    "tsconfig-paths": "^3.9.0"
   }
 }

packages/knossos/lib/api.ts

@@ -1,22 +1,22 @@
-import { NamedNode, Term } from 'rdf-js'
+import { NamedNode, Stream, Term } from 'rdf-js'
 import type { Api } from 'hydra-box/Api'
 import StreamClient from 'sparql-http-client/StreamClient'
 import $rdf from 'rdf-ext'
 import { Debugger } from 'debug'
 import ApiBase from 'hydra-box/Api'
 import { ApiFactory } from '@hydrofoil/labyrinth'
-import { CONSTRUCT } from '@tpluscode/sparql-builder'
-import { hydra } from '@tpluscode/rdf-ns-builders'
 import { Handler } from '@hydrofoil/knossos-events'
 import clownface, { GraphPointer } from 'clownface'
 import DatasetExt from 'rdf-ext/lib/Dataset'
 import express from 'express'
 import httpStatus from 'http-status'
 import { ResourceStore } from './store'
+import * as query from './query'
 
 interface ApiFromStore {
   store: ResourceStore
   log?: Debugger
+  loadClasses?(): Promise<Stream>
 }
 
 function assertTerm(term: Term | undefined): asserts term is NamedNode {
@@ -39,7 +39,7 @@ export const DELETE: express.RequestHandler = (req, res) => {
   res.send(httpStatus.NO_CONTENT)
 }
 
-const createApi: (arg: ApiFromStore) => ApiFactory = ({ store, log }) => async ({ path = '/api', sparql, codePath }) => {
+const createApi: (arg: ApiFromStore) => ApiFactory = ({ store, log, loadClasses = query.loadClasses }) => async ({ path = '/api', sparql, codePath }) => {
   const client = new StreamClient(sparql)
 
   return new (class extends ApiBase implements Api {
@@ -65,14 +65,7 @@ const createApi: (arg: ApiFromStore) => ApiFactory = ({ store, log }) => async (
         api = await store.load(this.term)
       }
 
-      const resources = await CONSTRUCT`?s ?p ?o . ?c ?cp ?co. ${this.term} ${hydra.supportedClass} ?c`
-        .WHERE`
-          ?c a ${hydra.Class} ;
-             ${hydra.apiDocumentation} ${this.term} ; 
-             ?cp ?co .
-          ?c (<>|!<>)+ ?s .
-          ?s ?p ?o .
-        `.execute(client.query)
+      const resources = await loadClasses(this.term, client)
       await api.dataset.import(resources)
 
       this.dataset = api.dataset

packages/knossos/lib/query.ts

@@ -0,0 +1,15 @@
+import { NamedNode, Stream } from 'rdf-js'
+import { StreamClient } from 'sparql-http-client/StreamClient'
+import { CONSTRUCT } from '@tpluscode/sparql-builder'
+import { hydra } from '@tpluscode/rdf-ns-builders'
+
+export function loadClasses(api: NamedNode, client: StreamClient): Promise<Stream> {
+  return CONSTRUCT`?s ?p ?o . ?c ?cp ?co. ${api} ${hydra.supportedClass} ?c`
+    .WHERE`
+          ?c a ${hydra.Class} ;
+             ${hydra.apiDocumentation} ${api} ; 
+             ?cp ?co .
+          ?c (<>|!<>)+ ?s .
+          ?s ?p ?o .
+        `.execute(client.query)
+}

packages/knossos/test/lib/api.test.ts

@@ -0,0 +1,82 @@
+import factory from 'knossos/lib/api'
+import sinon from 'sinon'
+import { ResourceStore } from 'knossos/lib/store'
+import { expect } from 'chai'
+import $rdf from 'rdf-ext'
+import { Api } from 'hydra-box/Api'
+import { namedNode } from '@labyrinth/testing/nodeFactory'
+
+describe('@hydrofoil/knossos/lib/api', () => {
+  const term = $rdf.namedNode('/api/docs')
+  const codePath = './lib/hydra'
+  const path = '/api/path'
+  const sparql: any = {}
+  let store: sinon.SinonStubbedInstance<ResourceStore>
+  let loadClasses: sinon.SinonStub
+
+  describe('API', () => {
+    let api: Api
+
+    beforeEach(async () => {
+      loadClasses = sinon.stub().resolves($rdf.dataset().toStream())
+      store = {
+        exists: sinon.stub(),
+        load: sinon.stub(),
+        delete: sinon.stub(),
+        save: sinon.stub(),
+      }
+
+      api = await factory({
+        log: sinon.spy() as any,
+        store,
+        loadClasses,
+      })({
+        codePath,
+        path,
+        sparql,
+      })
+      api.term = term
+    })
+
+    afterEach(() => {
+      sinon.restore()
+    })
+
+    describe('.init', () => {
+      it('loads resource from store if it exists', async () => {
+        // given
+        store.exists.resolves(true)
+        store.load.resolves(namedNode(term))
+
+        // when
+        await api.init()
+
+        // then
+        expect(store.load).to.have.been.calledWith(sinon.match(term))
+      })
+
+      it('does not load if API resource does not exist', async () => {
+        // given
+        store.exists.resolves(false)
+
+        // when
+        await api.init()
+
+        // then
+        expect(store.load).not.to.have.been.called
+      })
+
+      it('sets initialized', async () => {
+        // given
+        store.exists.resolves(true)
+        store.load.resolves(namedNode(term))
+
+        // when
+        await api.init()
+
+        // then
+        expect(api.initialized).to.eq(true)
+      })
+    })
+  })
+})

tsconfig.json

@@ -20,7 +20,11 @@
     "typeRoots": [
       "node_modules/@types",
       "types"
-    ]
+    ],
+    "baseUrl": ".",
+    "paths": {
+      "knossos/*": ["packages/knossos/*"]
+    }
   },
   "include": [
     "apps",