delete_handler.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. // +build ignore
  2. package v2
  3. import (
  4. "net/http"
  5. "strconv"
  6. etcdErr "github.com/coreos/etcd/error"
  7. "github.com/coreos/etcd/third_party/github.com/gorilla/mux"
  8. )
  9. func DeleteHandler(w http.ResponseWriter, req *http.Request, s Server) error {
  10. vars := mux.Vars(req)
  11. key := "/" + vars["key"]
  12. recursive := (req.FormValue("recursive") == "true")
  13. dir := (req.FormValue("dir") == "true")
  14. req.ParseForm()
  15. _, valueOk := req.Form["prevValue"]
  16. _, indexOk := req.Form["prevIndex"]
  17. if !valueOk && !indexOk {
  18. c := s.Store().CommandFactory().CreateDeleteCommand(key, dir, recursive)
  19. return s.Dispatch(c, w, req)
  20. }
  21. var err error
  22. prevIndex := uint64(0)
  23. prevValue := req.Form.Get("prevValue")
  24. if indexOk {
  25. prevIndexStr := req.Form.Get("prevIndex")
  26. prevIndex, err = strconv.ParseUint(prevIndexStr, 10, 64)
  27. // bad previous index
  28. if err != nil {
  29. return etcdErr.NewError(etcdErr.EcodeIndexNaN, "CompareAndDelete", s.Store().Index())
  30. }
  31. }
  32. if valueOk {
  33. if prevValue == "" {
  34. return etcdErr.NewError(etcdErr.EcodePrevValueRequired, "CompareAndDelete", s.Store().Index())
  35. }
  36. }
  37. c := s.Store().CommandFactory().CreateCompareAndDeleteCommand(key, prevValue, prevIndex)
  38. return s.Dispatch(c, w, req)
  39. }