etcdserver/api/v2http/client.go
func parseKeyRequest(r *http.Request, clock clockwork.Clock) (etcdserverpb.Request, bool, error) {
	var noValueOnSuccess bool
	emptyReq := etcdserverpb.Request{}

	err := r.ParseForm()
	if err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidForm,
			err.Error(),
		)
	}

	if !strings.HasPrefix(r.URL.Path, keysPrefix) {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidForm,
			"incorrect key prefix",
		)
	}
	p := path.Join(etcdserver.StoreKeysPrefix, r.URL.Path[len(keysPrefix):])

	var pIdx, wIdx uint64
	if pIdx, err = getUint64(r.Form, "prevIndex"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeIndexNaN,
			`invalid value for "prevIndex"`,
		)
	}
	if wIdx, err = getUint64(r.Form, "waitIndex"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeIndexNaN,
			`invalid value for "waitIndex"`,
		)
	}

	var rec, sort, wait, dir, quorum, stream bool
	if rec, err = getBool(r.Form, "recursive"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "recursive"`,
		)
	}
	if sort, err = getBool(r.Form, "sorted"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "sorted"`,
		)
	}
	if wait, err = getBool(r.Form, "wait"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "wait"`,
		)
	}
	// TODO(jonboulle): define what parameters dir is/isn't compatible with?
	if dir, err = getBool(r.Form, "dir"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "dir"`,
		)
	}
	if quorum, err = getBool(r.Form, "quorum"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "quorum"`,
		)
	}
	if stream, err = getBool(r.Form, "stream"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "stream"`,
		)
	}

	if wait && r.Method != "GET" {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`"wait" can only be used with GET requests`,
		)
	}

	pV := r.FormValue("prevValue")
	if _, ok := r.Form["prevValue"]; ok && pV == "" {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodePrevValueRequired,
			`"prevValue" cannot be empty`,
		)
	}

	if noValueOnSuccess, err = getBool(r.Form, "noValueOnSuccess"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "noValueOnSuccess"`,
		)
	}

	// TTL is nullable, so leave it null if not specified
	// or an empty string
	var ttl *uint64
	if len(r.FormValue("ttl")) > 0 {
		i, err := getUint64(r.Form, "ttl")
		if err != nil {
			return emptyReq, false, v2error.NewRequestError(
				v2error.EcodeTTLNaN,
				`invalid value for "ttl"`,
			)
		}
		ttl = &i
	}

	// prevExist is nullable, so leave it null if not specified
	var pe *bool
	if _, ok := r.Form["prevExist"]; ok {
		bv, err := getBool(r.Form, "prevExist")
		if err != nil {
			return emptyReq, false, v2error.NewRequestError(
				v2error.EcodeInvalidField,
				"invalid value for prevExist",
			)
		}
		pe = &bv
	}

	// refresh is nullable, so leave it null if not specified
	var refresh *bool
	if _, ok := r.Form["refresh"]; ok {
		bv, err := getBool(r.Form, "refresh")
		if err != nil {
			return emptyReq, false, v2error.NewRequestError(
				v2error.EcodeInvalidField,
				"invalid value for refresh",
			)
		}
		refresh = &bv
		if refresh != nil && *refresh {
			val := r.FormValue("value")
			if _, ok := r.Form["value"]; ok && val != "" {
				return emptyReq, false, v2error.NewRequestError(
					v2error.EcodeRefreshValue,
					`A value was provided on a refresh`,
				)
			}
			if ttl == nil {
				return emptyReq, false, v2error.NewRequestError(
					v2error.EcodeRefreshTTLRequired,
					`No TTL value set`,
				)
			}
		}
	}

	rr := etcdserverpb.Request{
		Method:    r.Method,
		Path:      p,
		Val:       r.FormValue("value"),
		Dir:       dir,
		PrevValue: pV,
		PrevIndex: pIdx,
		PrevExist: pe,
		Wait:      wait,
		Since:     wIdx,
		Recursive: rec,
		Sorted:    sort,
		Quorum:    quorum,
		Stream:    stream,
	}

	if pe != nil {
		rr.PrevExist = pe
	}

	if refresh != nil {
		rr.Refresh = refresh
	}

	// Null TTL is equivalent to unset Expiration
	if ttl != nil {
		expr := time.Duration(*ttl) * time.Second
		rr.Expiration = clock.Now().Add(expr).UnixNano()
	}

	return rr, noValueOnSuccess, nil
}
func parseKeyRequest(r *http.Request, clock clockwork.Clock) (etcdserverpb.Request, bool, error) {
	var noValueOnSuccess bool
	emptyReq := etcdserverpb.Request{}

	err := r.ParseForm()
	if err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidForm,
			err.Error(),
		)
	}

	if !strings.HasPrefix(r.URL.Path, keysPrefix) {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidForm,
			"incorrect key prefix",
		)
	}
	p := path.Join(etcdserver.StoreKeysPrefix, r.URL.Path[len(keysPrefix):])

	var pIdx, wIdx uint64
	if pIdx, err = getUint64(r.Form, "prevIndex"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeIndexNaN,
			`invalid value for "prevIndex"`,
		)
	}
	if wIdx, err = getUint64(r.Form, "waitIndex"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeIndexNaN,
			`invalid value for "waitIndex"`,
		)
	}

	var rec, sort, wait, dir, quorum, stream bool
	if rec, err = getBool(r.Form, "recursive"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "recursive"`,
		)
	}
	if sort, err = getBool(r.Form, "sorted"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "sorted"`,
		)
	}
	if wait, err = getBool(r.Form, "wait"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "wait"`,
		)
	}
	// TODO(jonboulle): define what parameters dir is/isn't compatible with?
	if dir, err = getBool(r.Form, "dir"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "dir"`,
		)
	}
	if quorum, err = getBool(r.Form, "quorum"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "quorum"`,
		)
	}
	if stream, err = getBool(r.Form, "stream"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "stream"`,
		)
	}

	if wait && r.Method != "GET" {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`"wait" can only be used with GET requests`,
		)
	}

	pV := r.FormValue("prevValue")
	if _, ok := r.Form["prevValue"]; ok && pV == "" {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodePrevValueRequired,
			`"prevValue" cannot be empty`,
		)
	}

	if noValueOnSuccess, err = getBool(r.Form, "noValueOnSuccess"); err != nil {
		return emptyReq, false, v2error.NewRequestError(
			v2error.EcodeInvalidField,
			`invalid value for "noValueOnSuccess"`,
		)
	}

	// TTL is nullable, so leave it null if not specified
	// or an empty string
	var ttl *uint64
	if len(r.FormValue("ttl")) > 0 {
		i, err := getUint64(r.Form, "ttl")
		if err != nil {
			return emptyReq, false, v2error.NewRequestError(
				v2error.EcodeTTLNaN,
				`invalid value for "ttl"`,
			)
		}
		ttl = &i
	}

	// prevExist is nullable, so leave it null if not specified
	var pe *bool
	if _, ok := r.Form["prevExist"]; ok {
		bv, err := getBool(r.Form, "prevExist")
		if err != nil {
			return emptyReq, false, v2error.NewRequestError(
				v2error.EcodeInvalidField,
				"invalid value for prevExist",
			)
		}
		pe = &bv
	}

	// refresh is nullable, so leave it null if not specified
	var refresh *bool
	if _, ok := r.Form["refresh"]; ok {
		bv, err := getBool(r.Form, "refresh")
		if err != nil {
			return emptyReq, false, v2error.NewRequestError(
				v2error.EcodeInvalidField,
				"invalid value for refresh",
			)
		}
		refresh = &bv
		if refresh != nil && *refresh {
			val := r.FormValue("value")
			if _, ok := r.Form["value"]; ok && val != "" {
				return emptyReq, false, v2error.NewRequestError(
					v2error.EcodeRefreshValue,
					`A value was provided on a refresh`,
				)
			}
			if ttl == nil {
				return emptyReq, false, v2error.NewRequestError(
					v2error.EcodeRefreshTTLRequired,
					`No TTL value set`,
				)
			}
		}
	}

	rr := etcdserverpb.Request{
		Method:    r.Method,
		Path:      p,
		Val:       r.FormValue("value"),
		Dir:       dir,
		PrevValue: pV,
		PrevIndex: pIdx,
		PrevExist: pe,
		Wait:      wait,
		Since:     wIdx,
		Recursive: rec,
		Sorted:    sort,
		Quorum:    quorum,
		Stream:    stream,
	}

	if pe != nil {
		rr.PrevExist = pe
	}

	if refresh != nil {
		rr.Refresh = refresh
	}

	// Null TTL is equivalent to unset Expiration
	if ttl != nil {
		expr := time.Duration(*ttl) * time.Second
		rr.Expiration = clock.Now().Add(expr).UnixNano()
	}

	return rr, noValueOnSuccess, nil
}
func parseKeyRequest ( r * http . Request , clock clockwork . Clock ) ( etcdserverpb . Request , bool , error ) { var noValueOnSuccess bool emptyReq := etcdserverpb . Request { } err := r . ParseForm ( ) if err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidForm , err . Error ( ) , ) } if ! strings . HasPrefix ( r . URL . Path , keysPrefix ) { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidForm , " " , ) } p := path . Join ( etcdserver . StoreKeysPrefix , r . URL . Path [ len ( keysPrefix ) : ] ) var pIdx , wIdx uint64 if pIdx , err = getUint64 ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeIndexNaN , `invalid value for "prevIndex"` , ) } if wIdx , err = getUint64 ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeIndexNaN , `invalid value for "waitIndex"` , ) } var rec , sort , wait , dir , quorum , stream bool if rec , err = getBool ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `invalid value for "recursive"` , ) } if sort , err = getBool ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `invalid value for "sorted"` , ) } if wait , err = getBool ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `invalid value for "wait"` , ) } // TODO(jonboulle): define what parameters dir is/isn't compatible with? if dir , err = getBool ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `invalid value for "dir"` , ) } if quorum , err = getBool ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `invalid value for "quorum"` , ) } if stream , err = getBool ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `invalid value for "stream"` , ) } if wait && r . Method != " " { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `"wait" can only be used with GET requests` , ) } pV := r . FormValue ( " " ) if _ , ok := r . Form [ " " ] ; ok && pV == " " { return emptyReq , false , v2error . NewRequestError ( v2error . EcodePrevValueRequired , `"prevValue" cannot be empty` , ) } if noValueOnSuccess , err = getBool ( r . Form , " " ) ; err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , `invalid value for "noValueOnSuccess"` , ) } // TTL is nullable, so leave it null if not specified // or an empty string var ttl * uint64 if len ( r . FormValue ( " " ) ) > 0 { i , err := getUint64 ( r . Form , " " ) if err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeTTLNaN , `invalid value for "ttl"` , ) } ttl = & i } // prevExist is nullable, so leave it null if not specified var pe * bool if _ , ok := r . Form [ " " ] ; ok { bv , err := getBool ( r . Form , " " ) if err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , " " , ) } pe = & bv } // refresh is nullable, so leave it null if not specified var refresh * bool if _ , ok := r . Form [ " " ] ; ok { bv , err := getBool ( r . Form , " " ) if err != nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeInvalidField , " " , ) } refresh = & bv if refresh != nil && * refresh { val := r . FormValue ( " " ) if _ , ok := r . Form [ " " ] ; ok && val != " " { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeRefreshValue , `A value was provided on a refresh` , ) } if ttl == nil { return emptyReq , false , v2error . NewRequestError ( v2error . EcodeRefreshTTLRequired , `No TTL value set` , ) } } } rr := etcdserverpb . Request { Method : r . Method , Path : p , Val : r . FormValue ( " " ) , Dir : dir , PrevValue : pV , PrevIndex : pIdx , PrevExist : pe , Wait : wait , Since : wIdx , Recursive : rec , Sorted : sort , Quorum : quorum , Stream : stream , } if pe != nil { rr . PrevExist = pe } if refresh != nil { rr . Refresh = refresh } // Null TTL is equivalent to unset Expiration if ttl != nil { expr := time . Duration ( * ttl ) * time . Second rr . Expiration = clock . Now ( ) . Add ( expr ) . UnixNano ( ) } return rr , noValueOnSuccess , nil }
// parseKeyRequest converts a received http.Request on keysPrefix to
// a server Request, performing validation of supplied fields as appropriate.
// If any validation fails, an empty Request and non-nil error is returned.
parseKeyRequest converts a received http . Request on keysPrefix to a server Request performing validation of supplied fields as appropriate . If any validation fails an empty Request and non - nil error is returned .