refactor(global): the host's tables, content and the sweep stand behind ports

capabilities/coordination/src/testing/test-host.ts

@@ -1,8 +1,8 @@
 import { shippedFilesOnDisk } from '@on.auto/operations/shipped-files-on-disk';
 import { freshInstances, machineSandboxOf, sandboxModuleIn, sandboxShippedRoots } from '@on.auto/workflow-engine/dsl';
-import { openWorkflowHost, type WorkflowHost } from '@on.auto/workflow-host';
-import { recordedReactions, recordedWaiting } from '@on.auto/workflow-host/testing';
-import { Effect, Function } from 'effect';
+import type { WorkflowHost } from '@on.auto/workflow-host';
+import { recordedReactions, recordedWaiting, workflowHostOnALedger } from '@on.auto/workflow-host/testing';
+import { Effect } from 'effect';
 
 import { callResultOfEnding, definitionCalls } from '../calls/function-calls.ts';
 import { workflowMachineOptionsOf } from '../runs/workflow-machine-options.ts';
@@ -14,20 +14,21 @@ const sandboxFiles = shippedFilesOnDisk(sandboxShippedRoots);
 const sandboxModule = await sandboxModuleIn(sandboxFiles);
 
 export function testHost(nested: Playbook): Promise<WorkflowHost> {
-  return openWorkflowHost({
-    database: { store: 'sqlite', file: ':memory:' },
-    machine: workflowMachineOptionsOf(machineSandboxOf(freshInstances(sandboxModule)), testPlaybookNames),
-    perform: definitionCalls(nested.executeNested),
-    settle: nested.settle,
-    reports: {
-      unsettled: Effect.logWarning,
-      trouble: Effect.logWarning,
-      lostConnection: Function.constVoid,
-      note: Effect.logWarning,
+  return workflowHostOnALedger(
+    { store: 'sqlite', file: ':memory:' },
+    {
+      machine: workflowMachineOptionsOf(machineSandboxOf(freshInstances(sandboxModule)), testPlaybookNames),
+      perform: definitionCalls(nested.executeNested),
+      settle: nested.settle,
+      reports: {
+        unsettled: Effect.logWarning,
+        trouble: Effect.logWarning,
+        note: Effect.logWarning,
+      },
+      sweepEveryMs: 20,
+      mostCallsAtOnce: 4,
+      reactions: recordedReactions().options,
+      waiting: { ...recordedWaiting().options, resultOf: callResultOfEnding },
     },
-    sweepEveryMs: 20,
-    mostCallsAtOnce: 4,
-    reactions: recordedReactions().options,
-    waiting: { ...recordedWaiting().options, resultOf: callResultOfEnding },
-  });
+  );
 }

capabilities/prediction/measure/dataset-rebuild.ts

@@ -1,8 +1,8 @@
 import { setTimeout } from 'node:timers/promises';
 
 import type { FilterSandbox } from '@on.auto/workflow-engine';
-import { someFolder, type DatabaseSettings, type HostDatabase } from '@on.auto/workflow-host';
-import { projectedFolders, type ProjectedFolders } from '@on.auto/workflow-host/testing';
+import { someFolder, type HostDatabase } from '@on.auto/workflow-host';
+import { projectedFolders, type DatabaseSettings, type ProjectedFolders } from '@on.auto/workflow-host/testing';
 import { Effect } from 'effect';
 
 import { datasetFolder, datasetsOf } from '../src/dataset/dataset-folder.ts';

capabilities/prediction/measure/stores.ts

@@ -6,7 +6,7 @@ import { join } from 'node:path';
 import { plainPoolsOn, postgresqlLedgerLayer } from '@on.auto/ledger/postgresql';
 import { ledgerLayer } from '@on.auto/ledger/sqlite3';
 import type { Ledger } from '@on.auto/operations';
-import type { DatabaseSettings } from '@on.auto/workflow-host';
+import type { DatabaseSettings } from '@on.auto/workflow-host/testing';
 import type { Layer } from 'effect';
 import { Client } from 'pg';
 

capabilities/prediction/src/dataset-testing/dataset-stores.ts

@@ -2,7 +2,7 @@ import { mkdtempSync, rmSync } from 'node:fs';
 import { tmpdir } from 'node:os';
 import { join } from 'node:path';
 
-import type { DatabaseSettings } from '@on.auto/workflow-host';
+import type { DatabaseSettings } from '@on.auto/workflow-host/testing';
 import { onTestFinished } from 'vitest';
 
 export type SettingsOf = () => Promise<DatabaseSettings>;

capabilities/prediction/src/dataset-testing/projected-datasets.ts

@@ -1,7 +1,7 @@
 import { shippedFilesOnDisk } from '@on.auto/operations/shipped-files-on-disk';
 import { filterSandboxOf, freshInstances, sandboxModuleIn, sandboxShippedRoots } from '@on.auto/workflow-engine/dsl';
-import { someFolder, type DatabaseSettings } from '@on.auto/workflow-host';
-import { projectedFolders, type ProjectedFolders } from '@on.auto/workflow-host/testing';
+import { someFolder } from '@on.auto/workflow-host';
+import { projectedFolders, type DatabaseSettings, type ProjectedFolders } from '@on.auto/workflow-host/testing';
 import { Effect, Option, Result, type Schema } from 'effect';
 import { expect, onTestFinished, vi } from 'vitest';
 

docs/self-host/workflows.md

@@ -144,7 +144,7 @@ The [engine's README](https://github.com/BeOnAuto/runtime/blob/main/packages/wor
 | `An answer of a call could not be recorded; it is written again until it is`                                                                                     | warning | The server keeps writing the call's result                                         |
 | `A call could not record its answer`                                                                                                                             | warning | A call's result was not recorded                                                   |
 | `An answer of a call could not be given to its run`                                                                                                              | warning | A recorded result did not reach its run                                            |
-| `A connection of the workflows to their PostgreSQL database was lost; they open another when they need one`                                                      | warning | PostgreSQL only; the server reconnects                                             |
+| `A connection to the PostgreSQL database of the ledger was lost; the ledger opens another when it needs one`                                                     | warning | PostgreSQL only; the workflows share the ledger's connections, and it reconnects   |
 | `A run could not be settled in <n> attempts; it is tried again once a minute until it is`                                                                        | warning | The end of the run is retried once a minute; see [Settling a run](#settling-a-run) |
 | `A run that could not be settled was settled at attempt <n>`                                                                                                     | warning | The end of the run was recorded                                                    |
 | `A run stays started because settling it failed`                                                                                                                 | error   | `reason` is `The ledger has no such run` or `The run was settled otherwise before` |