import fs from 'fs'
import chalk from 'chalk'
import path from 'path'
import tar from 'tar-fs'
import fse from 'fs-extra'
import inquirer from 'inquirer'
import { CloudBaseError } from '../../error'
import { successLog } from '../../logger'
import { listEnvs } from '../../env'
import {
    fetch,
    fetchStream,
    loadingFactory,
    genClickableLink,
    checkFullAccess,
    searchConfig
} from '../../utils'
import { ICommandContext } from '../command'

// 云函数
const listUrl = 'https://cli.service.tcloudbase.com/list'

async function extractTemplate(projectPath: string, templatePath: string) {
    // 文件下载链接
    const url = `https://636c-cli-1252710547.tcb.qcloud.la/cloudbase-templates/${templatePath}.tar.gz`

    return fetchStream(url).then(async res => {
        if (!res) {
            throw new CloudBaseError('请求异常')
        }
        if (res.status !== 200) {
            throw new CloudBaseError('未找到文件')
        }

        // 解压缩文件
        await new Promise((resolve, reject) => {
            const extractor = tar.extract(projectPath)
            res.body.on('error', reject)
            extractor.on('error', reject)
            extractor.on('finish', resolve)
            res.body.pipe(extractor)
        })
    })
}

async function copyServerTemplate(projectPath: string) {
    // 模板目录
    const templatePath = path.resolve(__dirname, '../../templates', 'server/node')
    fse.copySync(templatePath, projectPath)
}

// 项目初始化成功后打印提示语
function initSuccessOutput(projectName) {
    successLog(`创建项目 ${projectName} 成功！\n`)
    const command = chalk.bold.cyan(`cd ${projectName}`)
    console.log(`👉 执行命令 ${command} 进入项目文件夹！\n`)
    console.log(`👉 执行命令 ${chalk.bold.cyan('cloudbase functions:deploy app')} 部署云函数\n`)

    const link = genClickableLink('https://github.com/TencentCloudBase/cloudbase-templates')
    console.log(`🎉 欢迎贡献你的模板 👉 ${link}`)
}

export async function init(ctx: ICommandContext) {
    const { options } = ctx
    const loading = loadingFactory()
    loading.start('拉取环境列表中')
    let envData = []
    try {
        envData = (await listEnvs()) || []
    } catch (e) {
        loading.stop()
        throw e
    }
    loading.stop()

    const envs: { name: string; value: string }[] = envData
        .filter(item => item.Status === 'NORMAL')
        .map(item => ({
            name: `${item.Alias} - [${item.EnvId}:${item.PackageName || '空'}]`,
            value: item.EnvId
        }))
        .sort()

    if (!envs.length) {
        throw new CloudBaseError(
            '没有可以使用的环境，请使用 cloudbase env:create $name 命令创建免费环境！'
        )
    }

    const { env } = await inquirer.prompt({
        type: 'list',
        name: 'env',
        message: '选择关联环境',
        choices: envs
    })

    const { projectName } = await inquirer.prompt({
        type: 'input',
        name: 'projectName',
        message: '请输入项目名称',
        default: 'cloudbase-demo'
    })

    const { lang } = await inquirer.prompt({
        type: 'list',
        name: 'lang',
        message: '选择开发语言',
        choices: ['PHP', 'Java', 'Node']
    })

    loading.start('拉取云开发模板列表中')

    const templateList = await fetch(listUrl)

    loading.stop()

    const templates = templateList.filter(item => item.lang === lang)

    const { selectTemplateName } = await inquirer.prompt({
        type: 'list',
        name: 'selectTemplateName',
        message: '选择云开发模板',
        choices: templates.map(item => item.name)
    })

    const selectedTemplate = templates.find(item => item.name === selectTemplateName)

    // 项目目录
    const projectPath = path.join(process.cwd(), projectName)

    if (checkFullAccess(projectPath)) {
        const { cover } = await inquirer.prompt({
            type: 'confirm',
            name: 'cover',
            message: `已存在同名文件夹：${projectName}，是否覆盖？`,
            default: false
        })
        // 不覆盖，操作终止
        if (!cover) {
            throw new CloudBaseError('操作终止！')
        } else {
            // 覆盖操作不会删除不冲突的文件夹或文件
            // 删除原有文件夹，防止生成的项目包含用户原有文件
            fse.removeSync(projectPath)
        }
    }

    loading.start('下载文件中')

    if (options.server) {
        await copyServerTemplate(projectPath)
        // 重命名 _gitignore 文件
        fs.renameSync(path.join(projectPath, '_gitignore'), path.join(projectPath, '.gitignore'))
    } else {
        await extractTemplate(projectPath, selectedTemplate.path)
    }

    loading.stop()

    // 写入 envId
    const { filepath } = await searchConfig(projectPath)

    // 配置文件未找到
    if (!filepath) {
        initSuccessOutput(projectName)
        return
    }

    const configContent = fs.readFileSync(filepath).toString()

    fs.writeFileSync(filepath, configContent.replace('{{envId}}', env))
    initSuccessOutput(projectName)
}