import path from 'path';
import validate from './lib/validate.js';
import stdin from 'get-stdin';
import formatLambdaLogEvent from './utils/format-lambda-log-event.js';
import ServerlessError from '../../serverless-error.js';
import utils from '@serverlessinc/sf-core/src/utils.js';

const { writeText, style } = utils;

class AwsInvoke {
  constructor(serverless, options, pluginUtils) {
    this.serverless = serverless;
    this.options = options || {};
    this.provider = this.serverless.getProvider('aws');
    this.logger = pluginUtils.log
    this.progress = pluginUtils.progress

    Object.assign(this, validate);

    this.hooks = {
      'invoke:invoke': async () => {
        this.progress.notice('Invoking function')
        await this.extendedValidate();
        this.log(await this.invoke());
      },
    };
  }

  async validateFile(key) {
    const absolutePath = path.resolve(this.serverless.serviceDir, this.options[key]);
    try {
      return await this.serverless.utils.readFile(absolutePath);
    } catch (err) {
      if (err.code === 'ENOENT') {
        throw new ServerlessError('The file you provided does not exist.', 'FILE_NOT_FOUND');
      }
      throw err;
    }
  }

  async extendedValidate() {
    this.validate();
    // validate function exists in service
    this.options.functionObj = this.serverless.service.getFunction(this.options.function);
    this.options.data = this.options.data || '';

    if (!this.options.data) {
      if (this.options.path) {
        this.options.data = await this.validateFile('path');
      } else {
        try {
          this.options.data = await stdin();
        } catch {
          // continue if no stdin was provided
        }
      }
    }

    if (!this.options.context && this.options.contextPath) {
      this.options.context = await this.validateFile('contextPath');
    }

    try {
      if (!this.options.raw) {
        this.options.data = JSON.parse(this.options.data);
      }
    } catch (exception) {
      // do nothing if it's a simple string or object already
    }

    try {
      if (!this.options.raw && this.options.context) {
        this.options.context = JSON.parse(this.options.context);
      }
    } catch (exception) {
      // do nothing if it's a simple string or object already
    }
  }

  async invoke() {
    const invocationType = this.options.type || 'RequestResponse';
    if (invocationType !== 'RequestResponse') {
      this.options.log = 'None';
    } else {
      this.options.log = this.options.log ? 'Tail' : 'None';
    }

    const params = {
      FunctionName: this.options.functionObj.name,
      InvocationType: invocationType,
      LogType: this.options.log,
      Payload: Buffer.from(JSON.stringify(this.options.data || {})),
    };

    if (this.options.context) {
      params.ClientContext = Buffer.from(JSON.stringify(this.options.context)).toString('base64');
    }

    if (this.options.qualifier) {
      params.Qualifier = this.options.qualifier;
    }

    return this.provider.request('Lambda', 'invoke', params);
  }

  log(invocationReply) {
    this.progress.remove()

    if (invocationReply.Payload) {
      const response = JSON.parse(invocationReply.Payload);

      writeText(JSON.stringify(response, null, 4));
    }

    if (invocationReply.LogResult) {
      this.logger.blankLine()
      writeText(
        style.aside('----------------------')
      );
      this.logger.blankLine()
      const logResult = Buffer.from(invocationReply.LogResult, 'base64').toString();
      const logResultLines = logResult.split('\n')
      // Loop through and ensure the log that starts with "START" is always shown first
      // and the log that starts with "REPORT" is always shown last
      const startLog = logResultLines.find((line) => line.startsWith('START'))
      const reportLog = logResultLines.find((line) => line.startsWith('REPORT'))
      if (startLog) {
        this.logger.aside(formatLambdaLogEvent(startLog));
      }
      logResultLines.forEach((line) => {
        if (!line.startsWith('START')
          && !line.startsWith('END')
          && !line.startsWith('REPORT')) {
          this.logger.aside(formatLambdaLogEvent(line));
        }
      });
      if (reportLog) {
        this.logger.aside(formatLambdaLogEvent(reportLog));
      }
    }

    if (invocationReply.FunctionError) {
      throw new ServerlessError('Invoked function failed', 'AWS_LAMBDA_INVOCATION_FAILED');
    }
  }
}

export default AwsInvoke;