// Copyright (c) Huawei Technologies Co., Ltd. 2020. All rights reserved.
// isula-build licensed under the Mulan PSL v2.
// You can use this software according to the terms and conditions of the Mulan PSL v2.
// You may obtain a copy of Mulan PSL v2 at:
//     http://license.coscl.org.cn/MulanPSL2
// THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
// PURPOSE.
// See the Mulan PSL v2 for more details.
// Author: iSula Team
// Create: 2020-01-20
// Description: This file is used for "build" command

package main

import (
	"context"
	"crypto/sha256"
	"fmt"
	"io"
	"io/ioutil"
	"os"
	"path"
	"path/filepath"
	"strings"
	"time"

	"github.com/containers/storage/pkg/stringid"
	"github.com/gogo/protobuf/types"
	"github.com/pkg/errors"
	"github.com/sirupsen/logrus"
	"github.com/spf13/cobra"
	"golang.org/x/sync/errgroup"

	constant "isula.org/isula-build"
	pb "isula.org/isula-build/api/services"
	"isula.org/isula-build/exporter"
	_ "isula.org/isula-build/exporter/register"
	"isula.org/isula-build/pkg/opts"
	"isula.org/isula-build/util"
)

type buildOptions struct {
	file        string
	output      string
	buildArgs   []string
	encryptKey  string
	contextDir  string
	buildID     string
	proxyFlag   bool
	buildStatic opts.ListOpts
	imageIDFile string
}

type staticBuildMode string

const (
	buildExample = `isula-build ctr-img build -f Dockerfile .
isula-build ctr-img build -f Dockerfile -o docker-archive:name.tar:image:tag .
isula-build ctr-img build -f Dockerfile -o docker-daemon:image:tag .
isula-build ctr-img build -f Dockerfile -o docker://registry.example.com/repository:tag .
isula-build ctr-img build -f Dockerfile -o isulad:image:tag .
isula-build ctr-img build -f Dockerfile --build-static='build-time=2020-06-30 15:05:05' .`
	// tarPathFormat is the path used to temporarily store tar for isulad load later,
	// as client could not get daemon's dataroot and runroot, so we use /var/tmp here.
	tarPathFormat = "/var/tmp/isula-build-tmp-%v.tar"

	// buildTimeType is an option for static-build
	buildTimeType staticBuildMode = "build-time"
)

var buildOpts buildOptions = buildOptions{
	buildStatic: opts.NewListOpts(opts.OptValidator),
}

// NewContainerImageBuildCmd returns container image operations commands
func NewContainerImageBuildCmd() *cobra.Command {
	ctrImgBuildCmd := &cobra.Command{
		Use:   "ctr-img",
		Short: "Container Image Operations",
	}
	ctrImgBuildCmd.AddCommand(
		NewBuildCmd(),
		NewImagesCmd(),
		NewRemoveCmd(),
		NewLoadCmd(),
		NewImportCmd(),
	)

	return ctrImgBuildCmd
}

// NewBuildCmd cmd for container image building
func NewBuildCmd() *cobra.Command {
	// buildCmd represents the "build" command
	buildCmd := &cobra.Command{
		Use:     "build",
		Short:   "Build container images",
		Example: buildExample,
		RunE:    buildCommand,
	}

	buildCmd.PersistentFlags().StringVarP(&buildOpts.file, "filename", "f", "", "Path for Dockerfile")
	buildCmd.PersistentFlags().StringVarP(&buildOpts.output, "output", "o", "", "Destination of output images")
	buildCmd.PersistentFlags().BoolVarP(&buildOpts.proxyFlag, "proxy", "", true, "Inherit proxy environment variables from host")
	buildCmd.PersistentFlags().VarP(&buildOpts.buildStatic, "build-static", "", "Static build with the given option")
	buildCmd.PersistentFlags().StringArrayVar(&buildOpts.buildArgs, "build-arg", []string{}, "Arguments used during build time")
	buildCmd.PersistentFlags().StringVar(&buildOpts.imageIDFile, "iidfile", "", "Write image ID to the file")

	return buildCmd
}

func buildCommand(c *cobra.Command, args []string) error {
	if err := newBuildOptions(args); err != nil {
		return err
	}

	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	cli, err := NewClient(ctx)
	if err != nil {
		return err
	}

	eg, _ := errgroup.WithContext(ctx)
	eg.Go(func() error {
		imageID, err2 := runBuild(ctx, cli)
		if err2 != nil {
			logrus.Debugf("Build failed: %v", err2)
			cancel()
		} else {
			logrus.Debugf("Build success with image id: %s", imageID)
		}
		return errors.Wrap(err2, "error runBuild")
	})

	eg.Go(func() error {
		err2 := runStatus(ctx, cli)
		if err2 != nil {
			logrus.Debugf("Status get failed: %v", err2)
			cancel()
		}
		return errors.Wrap(err2, "error runStatus")
	})

	return eg.Wait()
}

func newBuildOptions(args []string) error {
	// unique buildID for each build progress
	buildOpts.buildID = stringid.GenerateNonCryptoID()[:constant.DefaultIDLen]

	if len(args) < 1 {
		// use current working directory as default context directory
		contextDir, err := os.Getwd()
		if err != nil {
			return errors.Wrapf(err, "unable to choose current working directory as build context")
		}
		realPath, err := filepath.EvalSymlinks(contextDir)
		if err != nil {
			return errors.Wrapf(err, "error getting the real path from %q", contextDir)
		}
		buildOpts.contextDir = realPath
		return nil
	}

	// the path may be a symbol link
	contextDir, err := filepath.Abs(args[0])
	if err != nil {
		return errors.Wrapf(err, "error deriving an absolute path from %q", args[0])
	}
	realPath, err := filepath.EvalSymlinks(contextDir)
	if err != nil {
		return errors.Wrapf(err, "error getting the real path from %q", contextDir)
	}
	f, err := os.Stat(realPath)
	if err != nil {
		return errors.Wrapf(err, "stat context directory path %q err", realPath)
	}
	if !f.IsDir() {
		return errors.Errorf("context directory path %q should be a directory", realPath)
	}
	buildOpts.contextDir = realPath
	return nil
}

func checkAndProcessOutput() (string, bool, error) {
	const outputFieldLen = 2
	segments := strings.Split(buildOpts.output, ":")
	transport := segments[0]

	// if transport is empty, but the rest parts are not empty
	if transport == "" && len(segments) >= outputFieldLen {
		return "", false, errors.New("transport should not be empty")
	}

	if transport != "" {
		// 1. check the destination is not empty
		if len(segments) < outputFieldLen || strings.TrimSpace(segments[1]) == "" {
			return "", false, errors.New("destination should not be empty")
		}

		// 2. check the transport is support
		if !exporter.IsSupport(transport) {
			return "", false, errors.Errorf("transport %q not support", transport)
		}

		const longestOutputLen = 512
		if len(buildOpts.output) > longestOutputLen {
			return "", false, errors.Errorf("output should not longer than %v", longestOutputLen)
		}

		if transport == "isulad" {
			const validIsuladFiledsLen = 3
			if len(segments) != validIsuladFiledsLen {
				return "", true, errors.Errorf("invalid isulad output format: %v", buildOpts.output)
			}
			return fmt.Sprintf(tarPathFormat, buildOpts.buildID), true, nil
		}

		// for export to local, output may contain docker-reference, e.g docker-archive:path:image:tag,
		// the part of reference is not a path, so only return segments[1]
		if util.IsClientExporter(transport) {
			return segments[1], false, nil
		}
	}

	// just build, not need to export to any destination
	return "", false, nil
}

func parseStaticBuildOpts() (*pb.BuildStatic, error) {
	var (
		t           time.Time
		err         error
		buildStatic *pb.BuildStatic = &pb.BuildStatic{}
	)
	for k, v := range buildOpts.buildStatic.Values {
		mode := staticBuildMode(k)
		switch mode {
		case buildTimeType:
			if t, err = time.Parse(constant.LayoutTime, v); err != nil {
				return nil, errors.Wrap(err, "build time format need like '2020-05-23 10:55:33'")
			}
			if buildStatic.BuildTime, err = types.TimestampProto(t); err != nil {
				return nil, err
			}
		default:
			return nil, errors.Errorf("option %q not support by build-static", mode)
		}
	}

	return buildStatic, nil
}

func runBuild(ctx context.Context, cli Cli) (string, error) {
	var (
		err      error
		content  string
		dest     string
		isIsulad bool
	)

	if dest, isIsulad, err = checkAndProcessOutput(); err != nil {
		return "", err
	}
	if content, err = readDockerfile(); err != nil {
		return "", err
	}
	if err = encryptBuildArgs(); err != nil {
		return "", errors.Wrap(err, "encrypt --build-arg failed")
	}
	buildStatic, err := parseStaticBuildOpts()
	if err != nil {
		return "", err
	}

	budStream, err := cli.Client().Build(ctx, &pb.BuildRequest{
		BuildType:   constant.BuildContainerImageType,
		BuildID:     buildOpts.buildID,
		BuildArgs:   buildOpts.buildArgs,
		EncryptKey:  buildOpts.encryptKey,
		ContextDir:  buildOpts.contextDir,
		FileContent: content,
		Output:      buildOpts.output,
		Proxy:       buildOpts.proxyFlag,
		BuildStatic: buildStatic,
		Iidfile:     buildOpts.imageIDFile,
	})
	if err != nil {
		return "", err
	}
	if dest == "" {
		msg, serr := budStream.Recv()
		if serr != nil {
			return "", serr
		}
		return msg.ImageID, nil
	}

	imageID, err := exporter.ArchiveRecv(ctx, dest, isIsulad, budStream.Recv)
	if err != nil {
		return "", err
	}

	return imageID, nil
}

// encryptes those sensitive args before transmissing via GRPC
func encryptBuildArgs() error {
	var hasSensiArg bool
	for _, v := range buildOpts.buildArgs {
		const kvNums = 2
		var ss = strings.SplitN(v, "=", kvNums)
		// check whether there is sensitive build-arg, if has, goto encrypt all build-args
		if constant.ReservedArgs[ss[0]] {
			hasSensiArg = true
			break
		}
	}
	if !hasSensiArg {
		return nil
	}

	oriKey, err := util.GenerateCryptoKey(util.CryptoKeyLen)
	if err != nil {
		return err
	}
	key, err := util.PBKDF2(oriKey, util.CryptoKeyLen, sha256.New)
	if err != nil {
		return err
	}

	const possibleArgCaps = 10
	var args = make([]string, 0, possibleArgCaps)
	for _, v := range buildOpts.buildArgs {
		encryptedArg, encErr := util.EncryptAES(v, key)
		if encErr != nil {
			return encErr
		}
		args = append(args, encryptedArg)
	}

	buildOpts.buildArgs = args
	buildOpts.encryptKey = key
	return nil
}

func runStatus(ctx context.Context, cli Cli) error {
	status, err := cli.Client().Status(ctx, &pb.StatusRequest{
		BuildID: buildOpts.buildID,
	})
	if err != nil {
		return err
	}

	for {
		msg, err := status.Recv()
		if msg != nil {
			fmt.Print(msg.Content)
		}

		if err != nil {
			if err == io.EOF {
				return nil
			}
			return err
		}
	}
}

// readDockerfile validates the --file, opens it and returns its content
// The possible Dockerfile path should be: filepath or contextDir+filepath
// or contextDir+Dockerfile if filepath is empty
func readDockerfile() (string, error) {
	resolvedPath, err := resolveDockerfilePath()
	if err != nil {
		return "", err
	}

	f, err := os.Open(filepath.Clean(resolvedPath))
	if err != nil {
		return "", errors.Wrapf(err, "open dockerfile failed")
	}
	defer func() {
		if err2 := f.Close(); err2 != nil {
			logrus.Warnf("Close dockerfile %s failed", resolvedPath)
		}
	}()

	buf, err := ioutil.ReadAll(f)
	if err != nil {
		return "", errors.Wrapf(err, "read dockerfile failed")
	}
	logrus.Debugf("Read Dockerfile at %s", resolvedPath)
	return string(buf), nil
}

func resolveDockerfilePath() (string, error) {
	var resolvedPath = buildOpts.file

	if buildOpts.file == "" {
		// filepath is empty, try to resolve with contextDir+Dockerfile
		resolvedPath = path.Join(buildOpts.contextDir, "Dockerfile")
	}
	// stat path with origin filepath or contextDir+Dockerfile
	fileInfo, err := os.Stat(resolvedPath)
	if err != nil {
		logrus.Debugf("Stat dockerfile failed with path %s", resolvedPath)
		// not found with filepath, try to resolve with contextDir+filepath
		resolvedPath = path.Join(buildOpts.contextDir, buildOpts.file)
		fileInfo, err = os.Stat(resolvedPath)
		if err != nil {
			logrus.Debugf("Stat dockerfile failed again with path %s", resolvedPath)
			return "", errors.Wrapf(err, "stat dockerfile failed with filename %s", buildOpts.file)
		}
	}
	if !fileInfo.Mode().IsRegular() {
		return "", errors.Errorf("file %s should be a regular file", resolvedPath)
	}
	if fileInfo.Size() == 0 {
		return "", errors.New("file is empty, is it a normal dockerfile?")
	}
	if fileInfo.Size() > constant.MaxFileSize {
		return "", errors.Errorf("file is too big with size %v, is it a normal dockerfile?", fileInfo.Size())
	}
	return resolvedPath, nil
}