smartlog-receiver/ts/sl.classes.smartlogreceiver.ts

import * as plugins from './sl.receiver.plugins.js';

import {
  ILogPackage,
  ILogPackageAuthenticated,
  ILogDestination,
} from '@pushrocks/smartlog-interfaces';

export type TValidatorFunction = (logPackage: ILogPackage) => Promise<boolean>;

export interface ISmartlogReceiverOptions {
  smartlogInstance: plugins.smartlog.Smartlog;
  passphrase: string;
  validatorFunction: TValidatorFunction;
}

/**
 * a class that receives smartlog packages
 */
export class SmartlogReceiver {
  public passphrase: string;
  public validatorFunction: TValidatorFunction;
  public smartlogInstance: plugins.smartlog.Smartlog;

  constructor(smartlogReceiverOptions: ISmartlogReceiverOptions) {
    this.passphrase = smartlogReceiverOptions.passphrase;
    this.validatorFunction =
      smartlogReceiverOptions.validatorFunction ||
      (async (logpackageArg) => {
        return true;
      });
    this.smartlogInstance = smartlogReceiverOptions.smartlogInstance;
  }

  /**
   * handles a authenticated log
   */
  public async handleAuthenticatedLog(authenticatedLogPackageArg: ILogPackageAuthenticated) {
    const authString = authenticatedLogPackageArg.auth;
    const logPackage = authenticatedLogPackageArg.logPackage;

    if (
      authString === plugins.smarthash.sha256FromStringSync(this.passphrase) &&
      (await this.validatorFunction(logPackage))
    ) {
      // Message authenticated lets clean up.
      logPackage.correlation ? null : (logPackage.correlation = { id: '123', type: 'none' });
      logPackage.correlation.id ? null : (logPackage.correlation.id = '123');
      logPackage.correlation.type ? null : (logPackage.correlation.type = 'none');

      this.smartlogInstance.handleLog(logPackage);
      return { status: 'ok' };
    } else {
      this.smartlogInstance.log('error', 'Message rejected because of bad passphrase');
      return { status: 'error' };
      // console.log(plugins.smarthash.sha256FromStringSync(this.passphrase));
    }
  }

  /**
   * handles an array of authenticated logs
   * @param authenticatedLogsPackageArrayArg
   */
  public async handleManyAuthenticatedLogs(
    authenticatedLogsPackageArrayArg: ILogPackageAuthenticated[]
  ) {
    const promiseArray: Array<Promise<any>> = [];
    for (const logPackage of authenticatedLogsPackageArrayArg) {
      promiseArray.push(this.handleAuthenticatedLog(logPackage));
    }
    await Promise.all(promiseArray);
  }
}