tswatch/ts/tswatch.classes.tswatch.ts

import * as plugins from './tswatch.plugins.js';
import * as paths from './tswatch.paths.js';
import * as interfaces from './interfaces/index.js';

import { Watcher } from './tswatch.classes.watcher.js';
import { logger } from './tswatch.logging.js';

export class TsWatch {
  public watchmode: interfaces.TWatchModes;
  public watcherMap = new plugins.lik.ObjectMap<Watcher>();
  public typedserver: plugins.typedserver.TypedServer;

  constructor(watchmodeArg: interfaces.TWatchModes) {
    this.watchmode = watchmodeArg;
  }

  /**
   * starts the TsWatch instance
   */
  public async start() {
    const tsbundle = new plugins.tsbundle.TsBundle();
    const htmlHandler = new plugins.tsbundle.HtmlHandler();
    switch (this.watchmode) {
      case 'test':
        /**
         * this strategy runs test whenever there is a change in the ts directory
         */
        this.watcherMap.add(
          new Watcher({
            filePathToWatch: paths.cwd,
            commandToExecute: 'npm run test2',
            timeout: null,
          })
        );
        break;
      case 'node':
        this.watcherMap.add(
          new Watcher({
            filePathToWatch: paths.cwd,
            commandToExecute: 'npm run test',
            timeout: null,
          })
        );
        break;
      case 'element':
        await (async () => {
          /**
           * this strategy runs a standard server and bundles the ts files to a dist_watch directory
           */
          // lets create a standard server
          logger.log(
            'info',
            'bundling TypeScript files to "dist_watch" Note: This is for development only!'
          );
          this.typedserver = new plugins.typedserver.TypedServer({
            cors: true,
            injectReload: true,
            serveDir: plugins.path.join(paths.cwd, './dist_watch/'),
            port: 3002,
            enableCompression: true,
            preferredCompressionMethod: 'gzip',
          });

          const bundleAndReloadElement = async () => {
            await tsbundle.build(paths.cwd, './html/index.ts', './dist_watch/bundle.js', {
              bundler: 'esbuild',
            });
            await this.typedserver.reload();
          };
          this.watcherMap.add(
            new Watcher({
              filePathToWatch: plugins.path.join(paths.cwd, './ts_web/'),
              functionToCall: async () => {
                await bundleAndReloadElement();
              },
              timeout: null,
            })
          );

          // lets get the other ts folders
          let tsfolders = await plugins.smartfile.fs.listFolders(paths.cwd);
          tsfolders = tsfolders.filter(
            (itemArg) => itemArg.startsWith('ts') && itemArg !== 'ts_web'
          );
          const smartshellInstance = new plugins.smartshell.Smartshell({
            executor: 'bash',
          });
          for (const tsfolder of tsfolders) {
            logger.log('info', `creating watcher for folder ${tsfolder}`);
            this.watcherMap.add(
              new Watcher({
                filePathToWatch: plugins.path.join(paths.cwd, `./${tsfolder}/`),
                functionToCall: async () => {
                  logger.log('info', `building ${tsfolder}`);
                  await smartshellInstance.exec(`(cd ${paths.cwd} && npm run build)`);
                  await bundleAndReloadElement();
                },
                timeout: null,
              })
            );
          }

          this.watcherMap.add(
            new Watcher({
              filePathToWatch: plugins.path.join(paths.cwd, './html/'),
              functionToCall: async () => {
                await htmlHandler.processHtml({
                  from: plugins.path.join(paths.cwd, './html/index.html'),
                  to: plugins.path.join(paths.cwd, './dist_watch/index.html'),
                  minify: false,
                });
                await bundleAndReloadElement();
              },
              timeout: null,
            })
          );
        })();
        break;
      case 'website':
        await (async () => {
          const websiteExecution = new plugins.smartshell.SmartExecution('npm run startTs');
          const bundleAndReloadWebsite = async () => {
            await tsbundle.build(paths.cwd, './ts_web/index.ts', './dist_serve/bundle.js', {
              bundler: 'esbuild',
            });
          };
          let tsfolders = await plugins.smartfile.fs.listFolders(paths.cwd);
          tsfolders = tsfolders.filter(
            (itemArg) => itemArg.startsWith('ts') && itemArg !== 'ts_web'
          );
          const smartshellInstance = new plugins.smartshell.Smartshell({
            executor: 'bash',
          });
          for (const tsfolder of tsfolders) {
            this.watcherMap.add(
              new Watcher({
                filePathToWatch: plugins.path.join(paths.cwd, `./${tsfolder}/`),
                functionToCall: async () => {
                  await websiteExecution.restart();
                },
                timeout: null,
              })
            );
          }
          this.watcherMap.add(
            new Watcher({
              filePathToWatch: plugins.path.join(paths.cwd, './ts_web/'),
              functionToCall: async () => {
                await bundleAndReloadWebsite();
              },
              timeout: null,
            })
          );
          this.watcherMap.add(
            new Watcher({
              filePathToWatch: plugins.path.join(paths.cwd, './html/'),
              functionToCall: async () => {
                await htmlHandler.processHtml({
                  from: plugins.path.join(paths.cwd, './html/index.html'),
                  to: plugins.path.join(paths.cwd, './dist_serve/index.html'),
                  minify: false,
                });
                await bundleAndReloadWebsite();
              },
              timeout: null,
            })
          );
        })();
        break;
      case 'service':
        this.watcherMap.add(
          new Watcher({
            filePathToWatch: plugins.path.join(paths.cwd, './ts/'),
            commandToExecute: 'npm run startTs',
            timeout: null,
          })
        );
        break;
      case 'echo':
        const tsWatchInstanceEchoSomething = new Watcher({
          filePathToWatch: plugins.path.join(paths.cwd, './ts'),
          commandToExecute: 'npm -v',
          timeout: null,
        });
        this.watcherMap.add(tsWatchInstanceEchoSomething);
        break;
      default:
        break;
    }
    this.watcherMap.forEach(async (watcher) => {
      await watcher.start();
    });
    if (this.typedserver) {
      await this.typedserver.start();
    }
  }

  /**
   * stops the execution of any active Watchers
   */
  public async stop() {
    if (this.typedserver) {
      await this.typedserver.stop();
    }
    this.watcherMap.forEach(async (watcher) => {
      await watcher.stop();
    });
  }
}