// Copyright 2016 HenryLee. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package thinkgo

import (
	"bytes"
	"crypto/hmac"
	"crypto/sha1"
	"encoding/base64"
	"encoding/json"
	"encoding/xml"
	"errors"
	"fmt"
	"io"
	"io/ioutil"
	"mime/multipart"
	"net/http"
	"net/url"
	"os"
	"path/filepath"
	"reflect"
	"regexp"
	"strconv"
	"strings"

	"github.com/henrylee2cn/thinkgo/apiware"
	"github.com/henrylee2cn/thinkgo/utils"
)

// Regexes for checking the accept headers
// TODO make sure these are correct
var (
	acceptsHTMLRegex = regexp.MustCompile(`(text/html|application/xhtml\+xml)(?:,|$)`)
	acceptsXMLRegex  = regexp.MustCompile(`(application/xml|text/xml)(?:,|$)`)
	acceptsJSONRegex = regexp.MustCompile(`(application/json)(?:,|$)`)
)

// Protocol returns request protocol name, such as HTTP/1.1 .
func (ctx *Context) Protocol() string {
	return ctx.R.Proto
}

// URI returns full request url with query string, fragment.
func (ctx *Context) URI() string {
	return ctx.R.RequestURI
}

// URL returns full request url with query string, fragment.
func (ctx *Context) URL() *url.URL {
	return ctx.R.URL
}

// Path returns request url path (without query string, fragment).
func (ctx *Context) Path() string {
	return ctx.R.URL.Path
}

// ModifyPath modifies the access path for the request.
func (ctx *Context) ModifyPath(p string) {
	ctx.R.URL.Path = p
}

// Scheme returns request scheme as "http" or "https".
func (ctx *Context) Scheme() string {
	if scheme := ctx.HeaderParam(HeaderXForwardedProto); scheme != "" {
		return scheme
	}
	if ctx.R.URL.Scheme != "" {
		return ctx.R.URL.Scheme
	}
	if ctx.R.TLS == nil {
		return "http"
	}
	return "https"
}

// Site returns base site url as scheme://host type.
func (ctx *Context) Site() string {
	return ctx.Scheme() + "://" + ctx.Host()
}

// SiteWithPort returns base site url as scheme://host:8080 type.
func (ctx *Context) SiteWithPort() string {
	return ctx.Scheme() + "://" + ctx.HostWithPort()
}

// Host returns host name.
// `host` is `subDomain.domain`.
// if no host info in request, return localhost.
func (ctx *Context) Host() string {
	if ctx.R.Host != "" {
		hostParts := strings.Split(ctx.R.Host, ":")
		if len(hostParts) > 0 {
			return hostParts[0]
		}
		return ctx.R.Host
	}
	return "localhost"
}

// HostWithPort returns a host:port string for this request,
// such as "example.com" or "example.com:8080".
func (ctx *Context) HostWithPort() string {
	if ctx.R.Host != "" {
		if strings.Contains(ctx.R.Host, ":") {
			return ctx.R.Host
		}
		return ctx.R.Host
	}
	return "localhost"
}

// Domain returns domain name.
// `host` is `subDomain.domain`.
// if aa.bb.domain.com, returns aa.bb .
// if no host info in request, return localhost.
func (ctx *Context) Domain() string {
	parts := strings.Split(ctx.Host(), ".")
	if len(parts) >= 3 {
		return strings.Join(parts[len(parts)-2:], ".")
	}
	return "localhost"
}

// SubDomain returns sub domain string.
// `host` is `subDomain.domain`.
// if aa.bb.domain.com, returns aa.bb .
func (ctx *Context) SubDomain() string {
	parts := strings.Split(ctx.Host(), ".")
	if len(parts) >= 3 {
		return strings.Join(parts[:len(parts)-2], ".")
	}
	return ""
}

// Port returns host port for this request.
// when error or empty, return 80.
func (ctx *Context) Port() int {
	parts := strings.Split(ctx.R.Host, ":")
	if len(parts) == 2 {
		port, _ := strconv.Atoi(parts[1])
		return port
	}
	return 80
}

// IP gets just the ip from the most direct one client.
func (ctx *Context) IP() string {
	var ip = strings.Split(ctx.R.RemoteAddr, ":")
	if len(ip) > 0 {
		if ip[0] != "[" {
			return ip[0]
		}
	}
	return "127.0.0.1"
}

// RealIP returns request client ip.
// if in proxy, return first proxy id.
// if error, return 127.0.0.1.
func (ctx *Context) RealIP() string {
	var ip = ctx.R.Header.Get(HeaderXRealIP)
	if len(ip) > 0 {
		return ip
	}
	ips := ctx.Proxy()
	if len(ips) > 0 && ips[0] != "" {
		rip := strings.Split(ips[0], ":")
		return rip[0]
	}
	return ctx.IP()
}

// Proxy returns proxy client ips slice.
func (ctx *Context) Proxy() []string {
	if ips := ctx.HeaderParam(HeaderXForwardedFor); ips != "" {
		return strings.Split(ips, ",")
	}
	return []string{}
}

// Referer returns http referer header.
func (ctx *Context) Referer() string {
	return ctx.HeaderParam(HeaderReferer)
}

// Method returns http request method.
func (ctx *Context) Method() string {
	return ctx.R.Method
}

// Is returns boolean of this request is on given method, such as Is("POST").
func (ctx *Context) Is(method string) bool {
	return ctx.Method() == method
}

// IsGet Is this a GET method request?
func (ctx *Context) IsGet() bool {
	return ctx.Is("GET")
}

// IsPost Is this a POST method request?
func (ctx *Context) IsPost() bool {
	return ctx.Is("POST")
}

// IsHead Is this a Head method request?
func (ctx *Context) IsHead() bool {
	return ctx.Is("HEAD")
}

// IsOptions Is this a OPTIONS method request?
func (ctx *Context) IsOptions() bool {
	return ctx.Is("OPTIONS")
}

// IsPut Is this a PUT method request?
func (ctx *Context) IsPut() bool {
	return ctx.Is("PUT")
}

// IsDelete Is this a DELETE method request?
func (ctx *Context) IsDelete() bool {
	return ctx.Is("DELETE")
}

// IsPatch Is this a PATCH method request?
func (ctx *Context) IsPatch() bool {
	return ctx.Is("PATCH")
}

// IsAjax returns boolean of this request is generated by ajax.
func (ctx *Context) IsAjax() bool {
	return ctx.HeaderParam(HeaderXRequestedWith) == "XMLHttpRequest"
}

// IsSecure returns boolean of this request is in https.
func (ctx *Context) IsSecure() bool {
	return ctx.Scheme() == "https"
}

// IsWebsocket returns boolean of this request is in webSocket.
func (ctx *Context) IsWebsocket() bool {
	return ctx.HeaderParam(HeaderUpgrade) == "websocket"
}

// IsUpload returns boolean of whether file uploads in this request or not..
func (ctx *Context) IsUpload() bool {
	return strings.Contains(ctx.HeaderParam(HeaderContentType), MIMEMultipartForm)
}

// AcceptHTML Checks if request accepts html response
func (ctx *Context) AcceptHTML() bool {
	return acceptsHTMLRegex.MatchString(ctx.HeaderParam(HeaderAccept))
}

// AcceptXML Checks if request accepts xml response
func (ctx *Context) AcceptXML() bool {
	return acceptsXMLRegex.MatchString(ctx.HeaderParam(HeaderAccept))
}

// AcceptJSON Checks if request accepts json response
func (ctx *Context) AcceptJSON() bool {
	return acceptsJSONRegex.MatchString(ctx.HeaderParam(HeaderAccept))
}

// UserAgent returns request client user agent string.
func (ctx *Context) UserAgent() string {
	return ctx.HeaderParam(HeaderUserAgent)
}

// Data returns the stored data in this context.
func (ctx *Context) Data(key interface{}) interface{} {
	if v, ok := ctx.data[key]; ok {
		return v
	}
	return nil
}

// HasData checks if the key exists in the context.
func (ctx *Context) HasData(key interface{}) bool {
	_, ok := ctx.data[key]
	return ok
}

// DataAll return the implicit data in the context
func (ctx *Context) DataAll() map[interface{}]interface{} {
	if ctx.data == nil {
		ctx.data = make(map[interface{}]interface{})
	}
	return ctx.data
}

// SetData stores data with given key in this context.
// This data are only available in this context.
func (ctx *Context) SetData(key, val interface{}) {
	if ctx.data == nil {
		ctx.data = make(map[interface{}]interface{})
	}
	ctx.data[key] = val
}

// Param returns the first value for the kinds of parameters.
// priority:
// path parameters > POST and PUT body parameters > URL query string values > header > cookie.Value.
//
// Param calls ParseMultipartForm and ParseForm if necessary and ignores
// any errors returned by these functions.
// If key is not present, Param returns the empty string.
// To access multiple values of the same key, call ParseForm and
// then inspect Request.Form directly.
func (ctx *Context) Param(key string) string {
	var value string
	value = ctx.BizParam(key)
	if len(value) > 0 {
		return value
	}
	value = ctx.R.Header.Get(key)
	if len(value) > 0 {
		return value
	}
	if cookie, _ := ctx.R.Cookie(key); cookie != nil {
		return cookie.Value
	}
	return value
}

// BizParam returns the first value for the kinds of business parameters.
// priority:
// path parameters > POST and PUT body parameters > URL query string values.
//
// BizParam calls ParseMultipartForm and ParseForm if necessary and ignores
// any errors returned by these functions.
// If key is not present, BizParam returns the empty string.
// To access multiple values of the same key, call ParseForm and
// then inspect Request.Form directly.
func (ctx *Context) BizParam(key string) string {
	var value string
	value = ctx.pathParams.ByName(key)
	if len(value) > 0 {
		return value
	}
	if ctx.R.Form == nil {
		ctx.R.ParseMultipartForm(ctx.frame.config.multipartMaxMemory)
	}
	return ctx.R.FormValue(key)
}

// BindBizParam data from ctx.BizParam(key) to dest
// like /?id=123&isok=true&ft=1.2&ol[0]=1&ol[1]=2&ul[]=str&ul[]=array&user.Name=abc
// var id int  ctx.BindBizParam(&id, "id")  id ==123
// var isok bool  ctx.BindBizParam(&isok, "isok")  isok ==true
// var ft float64  ctx.BindBizParam(&ft, "ft")  ft ==1.2
// ol := make([]int, 0, 2)  ctx.BindBizParam(&ol, "ol")  ol ==[1 2]
// ul := make([]string, 0, 2)  ctx.BindBizParam(&ul, "ul")  ul ==[str array]
// user struct{Name}  ctx.BindBizParam(&user, "user")  user == {Name:"abc"}
func (ctx *Context) BindBizParam(dest interface{}, key string) error {
	return apiware.ConvertAssign(reflect.ValueOf(dest), ctx.BizParam(key))
}

// PathParam returns path param by key.
func (ctx *Context) PathParam(key string) string {
	return ctx.pathParams.ByName(key)
}

// PathParamAll returns whole path parameters.
func (ctx *Context) PathParamAll() PathParams {
	return ctx.pathParams
}

// ParseFormOrMulitForm parseForm or parseMultiForm based on Content-type
func (ctx *Context) ParseFormOrMulitForm(maxMemory int64) error {
	// Parse the body depending on the content type.
	if strings.Contains(ctx.HeaderParam(HeaderContentType), MIMEMultipartForm) {
		if err := ctx.R.ParseMultipartForm(maxMemory); err != nil {
			return errors.New("Error parsing request body:" + err.Error())
		}
	} else if err := ctx.R.ParseForm(); err != nil {
		return errors.New("Error parsing request body:" + err.Error())
	}
	return nil
}

// FormParam returns the first value for the named component of the POST or PUT ruest body.
// URL query parameters and path parameters are ignored.
// FormParam calls ParseMultipartForm and ParseForm if necessary and ignores
// any errors returned by these functions.
// If key is not present, FormParam returns the empty string.
func (ctx *Context) FormParam(key string) string {
	if ctx.R.PostForm == nil {
		ctx.R.ParseMultipartForm(ctx.frame.config.multipartMaxMemory)
	}
	return ctx.R.PostFormValue(key)
}

// FormParams returns the form field value with "[]string" for the provided key.
func (ctx *Context) FormParams(key string) []string {
	if ctx.R.PostForm == nil {
		ctx.R.ParseMultipartForm(ctx.frame.config.multipartMaxMemory)
	}
	return ctx.R.PostForm[key]
}

// FormParamAll returns the parsed form data from POST, PATCH,
// or PUT body parameters.
func (ctx *Context) FormParamAll() url.Values {
	if ctx.R.PostForm == nil {
		ctx.R.ParseMultipartForm(ctx.frame.config.multipartMaxMemory)
	}
	return ctx.R.PostForm
}

const (
	// TAG_PARAM param tag
	TAG_PARAM = apiware.TAG_PARAM
)

// BindForm reads form data from request's body
func (ctx *Context) BindForm(structObject interface{}) error {
	value := reflect.ValueOf(structObject)
	if value.Kind() != reflect.Ptr {
		return errors.New("`*Context.BindForm` accepts only parameter of struct pointer type")
	}
	value = reflect.Indirect(value)
	if value.Kind() != reflect.Struct {
		return errors.New("`*Context.BindForm` accepts only parameter of struct pointer type")
	}
	t := value.Type()
	for i, count := 0, t.NumField(); i < count; i++ {
		fieldT := t.Field(i)
		if fieldT.Anonymous {
			continue
		}
		var key = fieldT.Tag.Get(TAG_PARAM)
		if key == "" {
			key = MapParamName(fieldT.Name)
		}
		err := apiware.ConvertAssign(value.Field(i), ctx.FormParams(key)...)
		if err != nil {
			return err
		}
	}
	return nil
}

// QueryParam gets the first query value associated with the given key.
// If there are no values associated with the key, QueryParam returns
// the empty string.
func (ctx *Context) QueryParam(key string) string {
	if ctx.queryParams == nil {
		ctx.queryParams = ctx.R.URL.Query()
	}
	return ctx.queryParams.Get(key)
}

// QueryParams returns the query param with "[]string".
func (ctx *Context) QueryParams(key string) []string {
	if ctx.queryParams == nil {
		ctx.queryParams = ctx.R.URL.Query()
	}
	return ctx.queryParams[key]
}

// QueryParamAll returns all query params.
func (ctx *Context) QueryParamAll() url.Values {
	if ctx.queryParams == nil {
		ctx.queryParams = ctx.R.URL.Query()
	}
	return ctx.queryParams
}

// HeaderParam gets the first header value associated with the given key.
// If there are no values associated with the key, HeaderParam returns
// the empty string.
func (ctx *Context) HeaderParam(key string) string {
	return ctx.R.Header.Get(key)
}

// HeaderParamAll returns the whole ruest header.
func (ctx *Context) HeaderParamAll() http.Header {
	return ctx.R.Header
}

// CookieParam returns request cookie item string by a given key.
// if non-existed, return empty string.
func (ctx *Context) CookieParam(key string) string {
	cookie, err := ctx.R.Cookie(key)
	if err != nil {
		return ""
	}
	return cookie.Value
}

// SecureCookieParam Get secure cookie from request by a given key.
func (ctx *Context) SecureCookieParam(secret, key string) (string, bool) {
	val := ctx.CookieParam(key)
	if val == "" {
		return "", false
	}

	parts := strings.SplitN(val, "|", 3)

	if len(parts) != 3 {
		return "", false
	}

	vs := parts[0]
	timestamp := parts[1]
	sig := parts[2]

	h := hmac.New(sha1.New, []byte(secret))
	fmt.Fprintf(h, "%s%s", vs, timestamp)

	if fmt.Sprintf("%02x", h.Sum(nil)) != sig {
		return "", false
	}
	res, _ := base64.URLEncoding.DecodeString(vs)
	return string(res), true
}

// FormFile returns the first file for the provided form key.
// FormFile calls ParseMultipartForm and ParseForm if necessary.
func (ctx *Context) FormFile(key string) (multipart.File, *multipart.FileHeader, error) {
	return ctx.R.FormFile(key)
}

// HasFormFile returns if the file header for the provided form key is exist.
func (ctx *Context) HasFormFile(key string) bool {
	if ctx.R.MultipartForm == nil {
		ctx.R.ParseMultipartForm(ctx.frame.config.multipartMaxMemory)
	}
	if ctx.R.MultipartForm != nil && ctx.R.MultipartForm.File != nil {
		if fhs := ctx.R.MultipartForm.File[key]; len(fhs) > 0 {
			return true
		}
	}
	return false
}

// SavedFileInfo for SaveFiles()
type SavedFileInfo struct {
	Url  string
	Size int64
}

// SaveFile saves the uploaded file to global.UploadDir(),
// character "?" indicates that the original file name.
// for example newfname="a/?" -> global.UploadDir()/a/fname.
func (ctx *Context) SaveFile(key string, cover bool, newfname ...string) (savedFileInfo SavedFileInfo, err error) {
	f, fh, err := ctx.R.FormFile(key)
	if err != nil {
		return
	}
	defer func() {
		err2 := f.Close()
		if err2 != nil && err == nil {
			err = err2
		}
	}()

	// Sets the full file name
	var fullname string
	if len(newfname) == 0 {
		fullname = filepath.Join(UploadDir(), fh.Filename)
	} else {
		if strings.Contains(newfname[0], "?") {
			fullname = filepath.Join(UploadDir(), strings.Replace(newfname[0], "?", fh.Filename, -1))
		} else {
			fname := strings.TrimRight(newfname[0], ".")
			if filepath.Ext(fname) == "" {
				fullname = filepath.Join(UploadDir(), fname+filepath.Ext(fh.Filename))
			} else {
				fullname = filepath.Join(UploadDir(), fname)
			}
		}
	}

	// Create the completion file path
	p, _ := filepath.Split(fullname)
	err = os.MkdirAll(p, 0777)
	if err != nil {
		return
	}

	// If the file with the same name exists, add the suffix of the serial number
	idx := strings.LastIndex(fullname, filepath.Ext(fullname))
	_fullname := fullname
	for i := 2; utils.FileExists(_fullname) && !cover; i++ {
		_fullname = fmt.Sprintf("%s(%d)%s", fullname[:idx], i, fullname[idx:])
	}
	fullname = _fullname

	// Create the URL of the file
	savedFileInfo.Url = "/" + strings.Replace(fullname, `\`, `/`, -1)

	// Save the file to local
	f2, err := os.OpenFile(fullname, os.O_CREATE|os.O_WRONLY, 0644)
	if err != nil {
		return
	}
	savedFileInfo.Size, err = io.Copy(f2, f)
	err3 := f2.Close()
	if err3 != nil && err == nil {
		err = err3
	}
	return
}

// SaveFiles saves the uploaded files to global.UploadDir(),
// it's similar to SaveFile, but for saving multiple files.
func (ctx *Context) SaveFiles(key string, cover bool, newfname ...string) (savedFileInfos []SavedFileInfo, err error) {
	if !ctx.HasFormFile(key) {
		err = errors.New("there are no file param: " + key)
		return
	}
	files := ctx.R.MultipartForm.File[key]
	hasFilename := len(newfname) > 0
	filemap := map[string]int{}
	for _, fh := range files {
		var f multipart.File
		f, err = fh.Open()
		if err != nil {
			return
		}
		defer func() {
			err2 := f.Close()
			if err2 != nil && err == nil {
				err = err2
			}
		}()

		// Sets the full file name
		var fullname string
		if !hasFilename {
			fullname = filepath.Join(UploadDir(), fh.Filename)
		} else {
			if strings.Contains(newfname[0], "?") {
				fullname = filepath.Join(UploadDir(), strings.Replace(newfname[0], "?", fh.Filename, -1))
			} else {
				fname := strings.TrimRight(newfname[0], ".")
				if filepath.Ext(fname) == "" {
					fullname = filepath.Join(UploadDir(), fname+filepath.Ext(fh.Filename))
				} else {
					fullname = filepath.Join(UploadDir(), fname)
				}
			}
		}

		// If the file with the same name exists, add the suffix of the serial number
		idx := strings.LastIndex(fullname, filepath.Ext(fullname))
		num := filemap[fullname]
		_fullname := fullname
		num++
		if num >= 2 {
			_fullname = fmt.Sprintf("%s(%d)%s", fullname[:idx], num, fullname[idx:])
		}
		for utils.FileExists(_fullname) && !cover {
			num++
			_fullname = fmt.Sprintf("%s(%d)%s", fullname[:idx], num, fullname[idx:])
		}
		filemap[fullname] = num
		fullname = _fullname

		var info SavedFileInfo

		// Create the URL of the file
		info.Url = "/" + strings.Replace(fullname, `\`, `/`, -1)

		// Save the file to local
		var f2 *os.File
		f2, err = os.OpenFile(fullname, os.O_CREATE|os.O_WRONLY, 0644)
		if err != nil {
			// Create the completion file path
			p, _ := filepath.Split(fullname)
			err = os.MkdirAll(p, 0777)
			if err != nil {
				return
			}
			f2, err = os.OpenFile(fullname, os.O_CREATE|os.O_WRONLY, 0644)
			if err != nil {
				return
			}
		}
		info.Size, err = io.Copy(f2, f)
		err3 := f2.Close()
		if err3 != nil && err == nil {
			err = err3
			return
		}
		savedFileInfos = append(savedFileInfos, info)
	}
	return
}

// BindJSON reads JSON from request's body
func (ctx *Context) BindJSON(jsonObject interface{}) error {
	rawData, _ := ioutil.ReadAll(ctx.R.Body)
	// check if jsonObject is already a pointer, if yes then pass as it's
	if reflect.TypeOf(jsonObject).Kind() == reflect.Ptr {
		err := json.Unmarshal(rawData, jsonObject)
		if err != nil {
			return err
		}
	}
	// finally, if the jsonObject is not a pointer
	return json.Unmarshal(rawData, &jsonObject)
}

// BindXML reads XML from request's body
func (ctx *Context) BindXML(xmlObject interface{}) error {
	rawData, _ := ioutil.ReadAll(ctx.R.Body)
	// check if xmlObject is already a pointer, if yes then pass as it's
	if reflect.TypeOf(xmlObject).Kind() == reflect.Ptr {
		err := xml.Unmarshal(rawData, xmlObject)
		if err != nil {
			return err
		}
	}
	// finally, if the xmlObject is not a pointer
	return xml.Unmarshal(rawData, &xmlObject)
}

// BodyBytes returns the raw request body data as bytes.
func (ctx *Context) BodyBytes() []byte {
	if ctx.limitedRequestBody != nil {
		return ctx.limitedRequestBody
	}
	if ctx.R.Body == nil {
		ctx.limitedRequestBody = []byte{}
		return ctx.limitedRequestBody
	}
	safe := &io.LimitedReader{R: ctx.R.Body, N: ctx.frame.config.multipartMaxMemory}
	limitedRequestBody, _ := ioutil.ReadAll(safe)
	ctx.R.Body.Close()
	bf := bytes.NewBuffer(limitedRequestBody)
	ctx.R.Body = ioutil.NopCloser(bf)
	ctx.limitedRequestBody = limitedRequestBody
	return limitedRequestBody
}

// Session returns current session item value by a given key.
// if non-existed, return nil.
func (ctx *Context) Session(key interface{}) interface{} {
	return ctx.CruSession.Get(key)
}