From d929eb75ed5847b9f4529a3085305e2687f5cd2f Mon Sep 17 00:00:00 2001
From: Tomasz Pluskiewicz <tpluscode@users.noreply.github.com>
Date: Wed, 12 Feb 2025 09:47:16 +0100
Subject: [PATCH] feat: onReady plugin hook

---
 .changeset/modern-walls-hammer.md | 6 ++++++
 packages/cli/lib/command/serve.ts | 1 +
 packages/core/lib/Kopflos.ts      | 6 ++++++
 3 files changed, 13 insertions(+)
 create mode 100644 .changeset/modern-walls-hammer.md

diff --git a/.changeset/modern-walls-hammer.md b/.changeset/modern-walls-hammer.md
new file mode 100644
index 00000000..7d496e31
--- /dev/null
+++ b/.changeset/modern-walls-hammer.md
@@ -0,0 +1,6 @@
+---
+"@kopflos-cms/core": patch
+"kopflos": patch
+---
+
+New plugin hook: `onReady`
diff --git a/packages/cli/lib/command/serve.ts b/packages/cli/lib/command/serve.ts
index 4908f7ad..94e0a375 100644
--- a/packages/cli/lib/command/serve.ts
+++ b/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) {
diff --git a/packages/core/lib/Kopflos.ts b/packages/core/lib/Kopflos.ts
index b8f7055f..b3d34836 100644
--- a/packages/core/lib/Kopflos.ts
+++ b/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() {