delete_handler.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  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. req.ParseForm()
  12. _, valueOk := req.Form["prevValue"]
  13. _, indexOk := req.Form["prevIndex"]
  14. recursive := (req.Form.Get("recursive") == "true")
  15. if !valueOk && !indexOk {
  16. c := s.Store().CommandFactory().CreateDeleteCommand(key, recursive)
  17. return s.Dispatch(c, w, req)
  18. }
  19. var err error
  20. prevIndex := uint64(0)
  21. prevValue := req.Form.Get("prevValue")
  22. if indexOk {
  23. prevIndexStr := req.Form.Get("prevIndex")
  24. prevIndex, err = strconv.ParseUint(prevIndexStr, 10, 64)
  25. // bad previous index
  26. if err != nil {
  27. return etcdErr.NewError(etcdErr.EcodeIndexNaN, "CompareAndDelete", s.Store().Index())
  28. }
  29. }
  30. if valueOk {
  31. if prevValue == "" {
  32. return etcdErr.NewError(etcdErr.EcodePrevValueRequired, "CompareAndDelete", s.Store().Index())
  33. }
  34. }
  35. c := s.Store().CommandFactory().CreateCompareAndDeleteCommand(key, recursive, prevValue, prevIndex)
  36. return s.Dispatch(c, w, req)
  37. }