package common

import (
	"errors"
	"fmt"
	"gitee.com/tym_hmm/mysql-mydumper/config"
	"strings"
)

type DumpNode struct {
	Host      string
	Port      int
	User      string
	Password  string
	DataBase  string
	Table     string
	OutDir    string
	ChunkSize int

	DatabaseRegexp       string
	DatabaseInvertRegexp bool

	ChunksizeInMB int
	SessionVars   string

	listener MyDumperListener
}

/**
读取结构体配置
*/
func ParseDumperConfigStruct(dumpNode *DumpNode) (*config.Config, error) {

	if dumpNode == nil {
		return nil, errors.New("empty node data")
	}

	if len(strings.TrimSpace(dumpNode.Host)) == 0 {
		return nil, errors.New("empty host")
	}

	if dumpNode.Port == 0 {
		return nil, errors.New("invalid port")
	}

	if len(strings.TrimSpace(dumpNode.User)) == 0 {
		return nil, errors.New("empty user")
	}

	if len(strings.TrimSpace(dumpNode.OutDir)) == 0 {
		return nil, errors.New("empty outdir")
	}

	args := &config.Config{
		Wheres: make(map[string]string),
	}

	args.Address = fmt.Sprintf("%s:%d", dumpNode.Host, dumpNode.Port)
	args.User = dumpNode.User
	args.Password = dumpNode.Password
	args.Database = dumpNode.DataBase
	args.DatabaseRegexp = dumpNode.DatabaseRegexp
	args.DatabaseInvertRegexp = dumpNode.DatabaseInvertRegexp
	args.Table = dumpNode.Table
	args.Outdir = dumpNode.OutDir
	if dumpNode.ChunksizeInMB < 10 {
		args.ChunksizeInMB = 128
	} else {
		args.ChunksizeInMB = dumpNode.ChunksizeInMB
	}
	args.SessionVars = dumpNode.SessionVars
	args.Threads = 16
	args.StmtSize = 1000000
	args.IntervalMs = 1 * 1000
	return args, nil
}