#!/usr/bin/env node
import Progress from 'progress';
import copy from '../lib/copy';
import { resolve } from 'path';
import login from '../lib/login';
import { stat } from 'fs-promise';
import * as cfg from '../lib/cfg';
import { version } from '../../package';
import Logger from '../lib/build-logger';
import bytes from 'bytes';
import chalk from 'chalk';
import minimist from 'minimist';
import Now from '../lib';
import toHumanPath from '../lib/utils/to-human-path';
import promptOptions from '../lib/utils/prompt-options';
import ms from 'ms';
import { handleError, error } from '../lib/error';

const argv = minimist(process.argv.slice(2), {
  boolean: ['help', 'version', 'debug', 'force', 'login', 'no-clipboard', 'forward-npm', 'docker', 'npm'],
  alias: {
    help: 'h',
    debug: 'd',
    version: 'v',
    force: 'f',
    forceSync: 'F',
    login: 'L',
    public: 'p',
    'no-clipboard': 'C',
    'forward-npm': 'N'
  }
});

const help = () => {
  console.log(`
  ${chalk.bold('𝚫 now')} [options] <command | path>

  ${chalk.dim('Commands:')}

    deploy       [path]       performs a deployment ${chalk.bold('(default)')}
    ls | list    [app]        list deployments
    rm | remove  [id]         remove a deployment
    ln | alias   [id] [url]   configures aliases for deployments
    domains      [name]       manages your domain names
    secrets      [name]       manages your env secrets
    help         [cmd]        displays complete help for [cmd]

  ${chalk.dim('Options:')}

    -h, --help          output usage information
    -v, --version       output the version number
    -d, --debug         debug mode [off]
    -f, --force         force a new deployment even if nothing has changed
    -L, --login         configure login
    -p, --public        deployment is public (\`/_src\` is exposed) [on for oss, off for premium]
    -C, --no-clipboard  do not attempt to copy URL to clipboard
    -N, --forward-npm   Forward login information to install private NPM modules

  ${chalk.dim('Examples:')}

  ${chalk.gray('–')} Deploys the current directory

    ${chalk.cyan('$ now')}

  ${chalk.gray('–')} Deploys a custom path ${chalk.dim('`/usr/src/project`')}

    ${chalk.cyan('$ now /usr/src/project')}

  ${chalk.gray('–')} Lists all deployments with their IDs

    ${chalk.cyan('$ now ls')}

  ${chalk.gray('–')} Associates deployment ${chalk.dim('`deploymentId`')} with ${chalk.dim('`custom-domain.com`')}

    ${chalk.cyan('$ now alias deploymentId custom-domain.com')}

  ${chalk.gray('–')} Displays comprehensive help for the subcommand ${chalk.dim('`list`')}

    ${chalk.cyan('$ now help list')}
`);
};

let path = argv._[0];

if (null != path) {
  // if path is relative: resolve
  // if path is absolute: clear up strange `/` etc
  path = resolve(process.cwd(), path);
} else {
  path = process.cwd();
}

const exit = (code) => {
  // we give stdout some time to flush out
  // because there's a node bug where
  // stdout writes are asynchronous
  // https://github.com/nodejs/node/issues/6456
  setTimeout(() => process.exit(code || 0), 100);
};

// options
const debug = argv.debug;
const clipboard = !argv['no-clipboard'];
const forwardNpm = argv['forward-npm'];
const forceNew = argv.force;
const forceSync = argv.forceSync;
const shouldLogin = argv.login;
const wantsPublic = argv.public;
const apiUrl = argv.url || 'https://api.zeit.co';
const isTTY = process.stdout.isTTY;
const quiet = !isTTY;
const config = cfg.read();
const alwaysForwardNpm = config.forwardNpm;

if (argv.h || argv.help) {
  help();
  exit(0);
} else if (argv.v || argv.version) {
  console.log(chalk.bold('𝚫 now'), version);
  process.exit(0);
} else if (!config.token || shouldLogin) {
  login(apiUrl)
  .then((token) => {
    if (shouldLogin) {
      console.log('> Logged in successfully. Token saved in ~/.now.json');
      process.exit(0);
    } else {
      sync(token).catch((err) => {
        error(`Unknown error: ${err.stack}`);
        process.exit(1);
      });
    }
  })
  .catch((e) => {
    error(`Authentication error – ${e.message}`);
    process.exit(1);
  });
} else {
  sync(config.token).catch((err) => {
    error(`Unknown error: ${err.stack}`);
    process.exit(1);
  });
}

async function sync (token) {
  const start = Date.now();

  if (!quiet) {
    console.log(`> Deploying ${chalk.bold(toHumanPath(path))}`);
  }

  try {
    await stat(path);
  } catch (err) {
    error(`Could not read directory ${chalk.bold(path)}`);
    process.exit(1);
  }

  let deploymentType, hasPackage, hasDockerfile;

  if (argv.docker) {
    if (debug) {
      console.log(`> [debug] Forcing \`deploymentType\` = \`docker\``);
    }
    deploymentType = 'docker';
  } else {
    if (argv.npm) {
      deploymentType = 'npm';
    } else {
      try {
        await stat(resolve(path, 'package.json'));
      } catch (err) {
        hasPackage = true;
      }

      [hasPackage, hasDockerfile] = await Promise.all([
        await (async () => {
          try {
            await stat(resolve(path, 'package.json'));
          } catch (err) {
            return false;
          }
          return true;
        })(),
        await (async () => {
          try {
            await stat(resolve(path, 'Dockerfile'));
          } catch (err) {
            return false;
          }
          return true;
        })()
      ]);

      if (hasPackage && hasDockerfile) {
        if (debug) console.log('[debug] multiple manifests found, disambiguating');
        if (isTTY) {
          try {
            console.log(`> Two manifests found. Press [${chalk.bold('n')}] to deploy or re-run with --flag`);
            deploymentType = await promptOptions([
              ['npm', `${chalk.bold('package.json')}\t${chalk.gray('   --npm')} `],
              ['docker', `${chalk.bold('Dockerfile')}\t${chalk.gray('--docker')} `]
            ]);
          } catch (err) {
            error(err.message);
            process.exit(1);
          }
        } else {
          error('Ambiguous deployment (`package.json` and `Dockerfile` found). ' +
            'Please supply `--npm` or `--docker` to disambiguate.');
        }
      } else if (hasPackage) {
        if (debug) console.log('[debug] `package.json` found, assuming `deploymentType` = `npm`');
        deploymentType = 'npm';
      } else if (hasDockerfile) {
        if (debug) console.log('[debug] `Dockerfile` found, assuming `deploymentType` = `docker`');
        deploymentType = 'docker';
      } else {
        error(`Could not read directory ${chalk.bold(path)}`);
        process.exit(1);
      }
    }
  }


  const now = new Now(apiUrl, token, { debug });

  try {
    await now.create(path, {
      deploymentType,
      forceNew,
      forceSync,
      forwardNpm: alwaysForwardNpm || forwardNpm,
      quiet,
      wantsPublic
    });
  } catch (err) {
    if (debug) console.log(`> [debug] error: ${err.stack}`);
    handleError(err);
    process.exit(1);
  }

  const { url } = now;
  const elapsed = ms(new Date() - start);

  if (isTTY) {
    if (clipboard) {
      try {
        await copy(url);
        console.log(`${chalk.cyan('> Ready!')} ${chalk.bold(url)} (copied to clipboard) [${elapsed}]`);
      } catch (err) {
        console.log(`${chalk.cyan('> Ready!')} ${chalk.bold(url)} [${elapsed}]`);
      }
    } else {
      console.log(`> ${url} [${elapsed}]`);
    }
  } else {
    process.stdout.write(url);
  }

  const start_u = new Date();
  const complete = () => {
    if (!quiet) {
      const elapsed_u = ms(new Date() - start_u);
      console.log(`> Sync complete (${bytes(now.syncAmount)}) [${elapsed_u}] `);
      console.log('> Initializing…');
    }

    // close http2 agent
    now.close();

    // show build logs
    printLogs(now.host);
  };

  if (now.syncAmount) {
    const bar = new Progress('> Upload [:bar] :percent :etas', {
      width: 20,
      complete: '=',
      incomplete: '',
      total: now.syncAmount
    });

    now.upload();

    now.on('upload', ({ names, data }) => {
      const amount = data.length;
      if (debug) {
        console.log(`> [debug] Uploaded: ${names.join(' ')} (${bytes(data.length)})`);
      }
      bar.tick(amount);
    });

    now.on('complete', complete);

    now.on('error', (err) => {
      error('Upload failed');
      handleError(err);
      process.exit(1);
    });
  } else {
    if (!quiet) {
      console.log(`> Initializing…`);
    }

    // close http2 agent
    now.close();

    // show build logs
    printLogs(now.host);
  }
}

function printLogs (host) {
  // log build
  const logger = new Logger(host, { debug, quiet });
  logger.on('close', () => {
    if (!quiet) {
      console.log(`${chalk.cyan('> Deployment complete!')}`);
    }
    process.exit(0);
  });
}