parent
b051ffccac
commit
91078c0d21
coordinator
integration
|
@ -15,7 +15,7 @@ func (self *Permissions) AuthorizeDeleteQuery(user common.User, db string) (ok b
|
||||||
}
|
}
|
||||||
|
|
||||||
func (self *Permissions) AuthorizeDropSeries(user common.User, db string, seriesName string) (ok bool, err common.AuthorizationError) {
|
func (self *Permissions) AuthorizeDropSeries(user common.User, db string, seriesName string) (ok bool, err common.AuthorizationError) {
|
||||||
if !user.IsDbAdmin(db) && !user.HasWriteAccess(seriesName) {
|
if !user.IsDbAdmin(db) {
|
||||||
return false, common.NewAuthorizationError("Insufficient permissions to drop series")
|
return false, common.NewAuthorizationError("Insufficient permissions to drop series")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -86,6 +86,28 @@ func (self *SingleServerSuite) TestAdministrationOperation(c *C) {
|
||||||
c.Assert(client.AuthenticateDatabaseUser("test_admin_operations", "user", "pass2"), IsNil)
|
c.Assert(client.AuthenticateDatabaseUser("test_admin_operations", "user", "pass2"), IsNil)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// issue #736
|
||||||
|
func (self *SingleServerSuite) TestDroppingSeries(c *C) {
|
||||||
|
client := self.server.GetClient("", c)
|
||||||
|
c.Assert(client.CreateDatabase("test_dropping_series"), IsNil)
|
||||||
|
c.Assert(client.CreateDatabaseUser("test_dropping_series", "user", "pass"), IsNil)
|
||||||
|
user := self.server.GetClientWithUser("test_dropping_series", "user", "pass", c)
|
||||||
|
err := user.WriteSeries([]*influxdb.Series{{
|
||||||
|
Name: "foo",
|
||||||
|
Columns: []string{"column1"},
|
||||||
|
Points: [][]interface{}{{1}},
|
||||||
|
}})
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
_, err = user.Query("drop series foo")
|
||||||
|
c.Assert(err, NotNil)
|
||||||
|
s, err := user.Query("select * from foo")
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
c.Assert(s, HasLen, 1)
|
||||||
|
maps := ToMap(s[0])
|
||||||
|
c.Assert(maps, HasLen, 1)
|
||||||
|
c.Assert(maps[0]["column1"], Equals, 1.0)
|
||||||
|
}
|
||||||
|
|
||||||
// pr #483
|
// pr #483
|
||||||
func (self *SingleServerSuite) TestConflictStatusCode(c *C) {
|
func (self *SingleServerSuite) TestConflictStatusCode(c *C) {
|
||||||
client := self.server.GetClient("", c)
|
client := self.server.GetClient("", c)
|
||||||
|
|
Loading…
Reference in New Issue