Architecting

app.ts

import {MarkdownService, RendererService, FileSystemService, PuppeteerService, IngestService} from './services/_index';
import {IWorkflowConfig} from './entities/_index';
import {CommanderService} from './services/commander-service';
import {empty, Observable, Observer, Subject} from "rxjs";
import {IAppState} from "./entities/IAppStream";
import {Command} from "commander";
import {flatMap, mergeMap} from "rxjs/operators";

const appState: IAppState = {};
const cs = new CommanderService();

const app$: Observable<IAppState> = Observable.create((obs: Observer<IAppState>) => {
    obs.next(appState)
});

const appRun = app$.pipe(
    mergeMap(
        (source) => cs.convertAction(),
        (sourceValue, commandValue) => {
            // console.log(sourceValue, commandValue);
            sourceValue.command = commandValue.args[0];
            return sourceValue;
        })
);

appRun
    .subscribe((data) => {
        console.log('End result: ', data);
        
        // Produces: End result:  { command: './files' }
    
    });


// I want to substitute this for the second param in mergeMap() but not sure how...
const mergeCommanderToAppState = (appState: IAppState, commanderValues: Command) => {
    appState.command = commanderValues.usage();
    return appState;
}

IAppState.ts

import {IWorkflowConfig} from "./iWorkflowConfig";
import {IMarkdown} from "./iMarkdown";
import {Browser} from "puppeteer";
import {Command} from "commander";

export interface IAppState {
    workflowConfig?: IWorkflowConfig;
    template?: string;
    styles?: string;
    markdownFiles?: IMarkdown[];
    browser?: Browser;
    command?: string;
}