feat: onReady plugin hook

.changeset/modern-walls-hammer.md

@@ -0,0 +1,6 @@
+---
+"@kopflos-cms/core": patch
+"kopflos": patch
+---
+
+New plugin hook: `onReady`

packages/cli/lib/command/serve.ts

@@ -49,6 +49,7 @@ async function run({
 
   const server = app.listen(port, host, () => {
     log.info(`Server running on ${port}. API URL: ${config.baseIri}`)
+    instance.ready()
   })
 
   if (config.watch) {

packages/core/lib/Kopflos.ts

@@ -65,6 +65,7 @@ export interface PluginConfig {
 export interface KopflosPlugin {
   readonly name?: string
   onStart?(): Promise<void> | void
+  onReady?(): Promise<void> | void
   onStop?(): Promise<void> | void
   apiTriples?(): Promise<DatasetCore | Stream> | DatasetCore | Stream
 }
@@ -121,6 +122,7 @@ export default class Impl implements Kopflos {
   readonly env: KopflosEnvironment
   readonly plugins: Array<KopflosPlugin>
   readonly start: () => Promise<void>
+  readonly ready: () => Promise<void>
 
   constructor({ variables = {}, ...config }: KopflosConfig, private readonly options: Options = {}) {
     this.env = createEnv({ variables, ...config })
@@ -148,6 +150,10 @@ export default class Impl implements Kopflos {
     this.start = onetime(async function (this: Impl) {
       await Promise.all(this.plugins.map(plugin => plugin.onStart?.()))
     }).bind(this)
+
+    this.ready = onetime(async function (this: Impl) {
+      await Promise.all(this.plugins.map(plugin => plugin.onReady?.()))
+    }).bind(this)
   }
 
   get graph() {

packages/core/test/lib/Kopflos.test.ts

@@ -752,6 +752,46 @@ describe('lib/Kopflos', () => {
       await instance.stop()
     })
   })
+
+  describe('ready', () => {
+    it('calls onReady on plugins', async function () {
+      // given
+      const onReady = sinon.spy()
+      const plugin = class {
+        onReady = onReady
+      }
+      const instance = new Kopflos({
+        ...config,
+        sparql: {
+          default: inMemoryClients(this.rdf),
+        },
+      }, {
+        plugins: [plugin],
+      })
+
+      // when
+      await instance.ready()
+
+      // then
+      expect(onReady).to.have.been.called
+    })
+
+    it('ignores plugins without onReady', async function () {
+      // given
+      const plugin = class {}
+      const instance = new Kopflos({
+        ...config,
+        sparql: {
+          default: inMemoryClients(this.rdf),
+        },
+      }, {
+        plugins: [plugin],
+      })
+
+      // when
+      await instance.ready()
+    })
+  })
 })
 
 const testHandler: Handler = ({ subject, property, object }) => ({