update action generation

test/test.ts

@@ -30,12 +30,20 @@ tap.test('should create a new StatePart', async () => {
 
 tap.test('should select something', async () => {
   testStatePart
-    .select(state => state.deep)
+    .select(state => state.deep.hi)
     .subscribe(substate => {
-      console.log(substate);
+      expect(substate).to.equal(2);
     });
 });
 
-tap.test('should dispatch a state action', async () => {});
+tap.test('should dispatch a state action', async () => {
+  const addFavourite = testStatePart.createAction<string>(async (statePart, payload) => {
+    const currentState = statePart.getState();
+    currentState.currentFavorites.push(payload)
+    return currentState;
+  });
+  await testStatePart.dispatchAction(addFavourite, 'my favourite things')
+  expect(testStatePart.getState().currentFavorites).to.include('my favourite things')
+});
 
 tap.start();

ts/smartstate.classes.stateaction.ts

@@ -1,8 +1,13 @@
 import * as plugins from './smartstate.plugins';
+import { StatePart } from './smartstate.classes.statepart';
+
+export interface IActionDef<TStateType, TActionPayloadType> {
+ (stateArg: StatePart<any, TStateType>, actionPayload: TActionPayloadType): Promise<TStateType>;
+}
 
 /**
  * an actionmodifier for the state
  */
-export class StateAction<StatePayload> {
-  constructor(public actionDef: (stateArg: StatePayload) => StatePayload) {}
+export class StateAction<TStateType, TActionPayloadType> {
+  constructor(public actionDef: IActionDef<TStateType, TActionPayloadType>) {}
 }

ts/smartstate.classes.statepart.ts

@@ -3,21 +3,21 @@ import * as plugins from './smartstate.plugins';
 import { Observable, Subject } from 'rxjs';
 import { startWith, takeUntil, map } from 'rxjs/operators';
 
-import { StateAction } from './smartstate.classes.stateaction';
+import { StateAction, IActionDef } from './smartstate.classes.stateaction';
 
-export class StatePart<StatePartNameType, PayloadType> {
-  name: StatePartNameType;
-  state = new Subject<PayloadType>();
-  stateStore: PayloadType;
+export class StatePart<TStatePartName, TStatePayload> {
+  name: TStatePartName;
+  state = new Subject<TStatePayload>();
+  stateStore: TStatePayload;
 
-  constructor(nameArg: StatePartNameType) {
+  constructor(nameArg: TStatePartName) {
     this.name = nameArg;
   }
 
   /**
    * gets the state from the state store
    */
-  getState(): PayloadType {
+  getState(): TStatePayload {
     return this.stateStore;
   }
 
@@ -25,7 +25,7 @@ export class StatePart<StatePartNameType, PayloadType> {
    * sets the stateStore to the new state
    * @param newStateArg
    */
-  setState(newStateArg: PayloadType) {
+  setState(newStateArg: TStatePayload) {
     this.stateStore = newStateArg;
     this.notifyChange();
   }
@@ -40,9 +40,9 @@ export class StatePart<StatePartNameType, PayloadType> {
   /**
    * selects a state or a substate
    */
-  select<T = PayloadType>(selectorFn?: (state: PayloadType) => T): Observable<T> {
+  select<T = TStatePayload>(selectorFn?: (state: TStatePayload) => T): Observable<T> {
     if (!selectorFn) {
-      selectorFn = (state: PayloadType) => <T>(<any>state);
+      selectorFn = (state: TStatePayload) => <T>(<any>state);
     }
 
     const mapped = this.state.pipe(
@@ -53,11 +53,18 @@ export class StatePart<StatePartNameType, PayloadType> {
     return mapped;
   }
 
+  /**
+   * creates an action capable of modifying the state
+   */
+  createAction <TActionPayload>(actionDef: IActionDef<TStatePayload, TActionPayload>): StateAction<TStatePayload, TActionPayload> {
+    return new StateAction(actionDef);
+  }
+
   /**
    * dispatches an action on the statepart level
    */
-  async dispatch(stateAction: StateAction<PayloadType>) {
-    const newState = stateAction.actionDef(this.getState());
+  async dispatchAction<T>(stateAction: StateAction<TStatePayload, T>, actionPayload: T) {
+    const newState = await stateAction.actionDef(this, actionPayload);
     this.setState(newState);
   }
 }