import _ from "lodash";

import { CloseBracketState, GetBlockEndState, GetPathState } from "./";

import * as chars from "../Characters";
import * as errors from "../Errors";
import * as notifies from "../Notify";

import { StubbleError } from "../StubbleError";
import {
  ProcessMessage,
  NotifyMessage,
  StubbleMessage,
} from "../StubbleMessages";

import { StubbleResult } from "../StubbleResult";
import { StubbleState } from "../StubbleState";
import { StubbleContext } from "../StubbleContext";

export class GetEachBlockState implements StubbleState {
  private _path: string = "";
  private _body: string = "";
  private _symbol: number;
  private _line: number;

  constructor(symbol: number, line: number) {
    this._symbol = symbol;
    this._line = line;
  }

  getName() {
    return "GetEachBlockState";
  }

  canAcceptMessage(msg: StubbleMessage): boolean {
    if (msg instanceof ProcessMessage || msg instanceof NotifyMessage) {
      return true;
    }

    return false;
  }

  handleMessage(
    msg: StubbleMessage,
    context: StubbleContext
  ): StubbleResult | null {
    if (msg instanceof ProcessMessage) {
      return this.process(msg, context);
    }

    if (msg instanceof NotifyMessage) {
      return this.notify(msg, context);
    }

    return null;
  }

  process(msg: ProcessMessage, context: StubbleContext): StubbleResult | null {
    let charCode = msg.charCode;

    if (charCode == chars.EOS) {
      return {
        err: new StubbleError(
          errors.ERROR_UNTERMINATED_BLOCK,
          `Unterminated "EACH" block at ${this._line}:${this._symbol}`
        ),
      };
    } else if (charCode == chars.CLOSE_BRACKET) {
      return {
        state: new CloseBracketState(),
      };
    } else if (charCode == chars.SPACE) {
      return null;
    }

    return {
      state: new GetPathState(""),
      message: new ProcessMessage(charCode),
    };
  }

  notify(msg: NotifyMessage, context: StubbleContext): StubbleResult | null {
    switch (msg.type) {
      case notifies.NOTIFY_PATH_RESULT:
        this._path = msg.value;

        return {
          message: new ProcessMessage(msg.charCode!),
        };

      case notifies.NOTIFY_SECOND_CLOSE_BRACKET_FOUND:
        return {
          state: new GetBlockEndState("each"),
        };

      case notifies.NOTIFY_BLOCK_END_RESULT:
        this._body = msg.value;
        return this.result(context);
    }

    return null;
  }

  result(context: StubbleContext): StubbleResult {
    const result: StubbleResult = {};

    if (!this._path) {
      result.err = new StubbleError(
        errors.ERROR_PATH_NOT_SPECIFIED,
        '"EACH" block requires path as parameter'
      );
    } else {
      try {
        let data = context.get(this._path) ?? [];

        if (_.isArray(data) || _.isObject(data)) {
          let fn = context.compile(this._body);
          let res = "";

          _.forEach(data, (item) => {
            res += fn ? fn(item) : "";
          });

          return {
            result: res,
            pop: true,
          };
        } else {
          result.err = new StubbleError(
            errors.ERROR_WITH_DATA_MALFORMED,
            '"EACH" block data should have "Array" or "Object" type'
          );
        }
      } catch (e: any) {
        result.err = new StubbleError(
          errors.ERROR_CALLING_HELPER,
          e.toString()
        );
      }
    }

    return result;
  }
}