delete_handler.go 1.2 KB

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