feat(command-flow): introduce Flow API to replace Effects

Author: Char2sGu

docs/src/content/packages/command-flow/index.md

@@ -42,6 +42,17 @@ Facade:
 - `useCommand`
   {{ JSDoc.description("packages/command-flow/src/index.ts#useCommand") }}
 
+Flow:
+
+- `Flow`
+  {{ JSDoc.description("packages/command-flow/src/flow.ts#Flow") }}
+- `FlowEffect`
+  {{ JSDoc.description("packages/command-flow/src/flow.ts#FlowEffect") }}
+- `createFlow`
+  {{ JSDoc.description("packages/command-flow/src/flow.ts#createFlow") }}
+- `provideFlows`
+  {{ JSDoc.description("packages/command-flow/src/flow.ts#provideFlows") }}
+
 ### Exported from `@angularity/command-flow/process-flow`
 
 Foundation:

packages/command-flow/effects/src/effects.ts

@@ -5,13 +5,15 @@ import {
 
 /**
  * A function that registers side-effects (of commands/events).
+ * @deprecated Use `createFlow` instead.
  */
 export interface Effects {
   (): void;
 }
 
 /**
  * Registers the provided effects in an environment initializer.
+ * @deprecated Use `provideFlows` instead.
  */
 export function provideEffects(
   ...effectsInput: (Effects | Effects[])[]

packages/command-flow/src/flow.ts

@@ -0,0 +1,64 @@
+import {
+  EnvironmentProviders,
+  inject,
+  Injector,
+  makeEnvironmentProviders,
+  provideEnvironmentInitializer,
+  runInInjectionContext,
+} from '@angular/core';
+
+/**
+ * A collection of effects that are run in an injection context.
+ */
+export interface Flow {
+  effects: FlowEffect[];
+}
+
+/**
+ * A function that is run in an injection context and registers some side effects.
+ */
+export interface FlowEffect {
+  (): void;
+}
+
+/**
+ * Creates a `Flow` with the given `FlowEffect`s.
+ * @example
+ * ```ts
+ * export const authFlow = createFlow(
+ *   () =>
+ *     onCommand(
+ *       [Alert],
+ *       map((payload) => {
+ *         window.alert(payload.message);
+ *         return AlertCompleted();
+ *       }),
+ *     ),
+ *   (confirm = inject(ConfirmService)) =>
+ *     onCommand(
+ *       [Confirm],
+ *       map((payload) => {
+ *         const result = confirm.launch(payload.message);
+ *         return ConfirmCompleted(result);
+ *       }),
+ *     ),
+ * );
+ * ```
+ */
+export function createFlow(...effects: FlowEffect[]): Flow {
+  return { effects };
+}
+
+/**
+ * Provides the given flows to an environment.
+ */
+export function provideFlows(...flows: Flow[]): EnvironmentProviders {
+  return makeEnvironmentProviders([
+    provideEnvironmentInitializer(() => {
+      const injector = inject(Injector);
+      for (const flow of flows)
+        for (const effect of flow.effects)
+          runInInjectionContext(injector, effect);
+    }),
+  ]);
+}