mirror of
https://github.com/woodpecker-ci/woodpecker.git
synced 2025-09-17 17:23:54 +00:00
Remove capability package
It's no longer used. This commit can always be reverted later if it's needed again.
This commit is contained in:
@@ -1,23 +0,0 @@
|
|||||||
package capability
|
|
||||||
|
|
||||||
import (
|
|
||||||
"code.google.com/p/go.net/context"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Capability map[string]bool
|
|
||||||
|
|
||||||
// Get the capability value from the map.
|
|
||||||
func (c Capability) Get(key string) bool {
|
|
||||||
return c[key]
|
|
||||||
}
|
|
||||||
|
|
||||||
// Sets the capability value in the map.
|
|
||||||
func (c Capability) Set(key string, value bool) {
|
|
||||||
c[key] = value
|
|
||||||
}
|
|
||||||
|
|
||||||
// Enabled returns true if the capability is
|
|
||||||
// enabled in the system.
|
|
||||||
func Enabled(c context.Context, key string) bool {
|
|
||||||
return FromContext(c).Get(key)
|
|
||||||
}
|
|
@@ -1,22 +0,0 @@
|
|||||||
package capability
|
|
||||||
|
|
||||||
import (
|
|
||||||
"testing"
|
|
||||||
|
|
||||||
"code.google.com/p/go.net/context"
|
|
||||||
"github.com/franela/goblin"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestBlobstore(t *testing.T) {
|
|
||||||
caps := map[string]bool{}
|
|
||||||
|
|
||||||
ctx := NewContext(context.Background(), caps)
|
|
||||||
|
|
||||||
g := goblin.Goblin(t)
|
|
||||||
g.Describe("Capabilities", func() {
|
|
||||||
|
|
||||||
g.It("Should get capabilities from context", func() {
|
|
||||||
g.Assert(Enabled(ctx, "Fake Key")).Equal(false)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
}
|
|
@@ -1,5 +0,0 @@
|
|||||||
package capability
|
|
||||||
|
|
||||||
const (
|
|
||||||
Registration = "REGISTRATION"
|
|
||||||
)
|
|
@@ -1,32 +0,0 @@
|
|||||||
package capability
|
|
||||||
|
|
||||||
import (
|
|
||||||
"code.google.com/p/go.net/context"
|
|
||||||
)
|
|
||||||
|
|
||||||
const reqkey = "capability"
|
|
||||||
|
|
||||||
// NewContext returns a Context whose Value method returns the
|
|
||||||
// application's Blobstore data.
|
|
||||||
func NewContext(parent context.Context, caps Capability) context.Context {
|
|
||||||
return &wrapper{parent, caps}
|
|
||||||
}
|
|
||||||
|
|
||||||
type wrapper struct {
|
|
||||||
context.Context
|
|
||||||
caps Capability
|
|
||||||
}
|
|
||||||
|
|
||||||
// Value returns the named key from the context.
|
|
||||||
func (c *wrapper) Value(key interface{}) interface{} {
|
|
||||||
if key == reqkey {
|
|
||||||
return c.caps
|
|
||||||
}
|
|
||||||
return c.Context.Value(key)
|
|
||||||
}
|
|
||||||
|
|
||||||
// FromContext returns the capability map for the
|
|
||||||
// current context.
|
|
||||||
func FromContext(c context.Context) Capability {
|
|
||||||
return c.Value(reqkey).(Capability)
|
|
||||||
}
|
|
@@ -26,7 +26,6 @@ import (
|
|||||||
"github.com/drone/drone/plugin/remote/gitlab"
|
"github.com/drone/drone/plugin/remote/gitlab"
|
||||||
"github.com/drone/drone/plugin/remote/gogs"
|
"github.com/drone/drone/plugin/remote/gogs"
|
||||||
"github.com/drone/drone/server/blobstore"
|
"github.com/drone/drone/server/blobstore"
|
||||||
"github.com/drone/drone/server/capability"
|
|
||||||
"github.com/drone/drone/server/datastore"
|
"github.com/drone/drone/server/datastore"
|
||||||
"github.com/drone/drone/server/datastore/database"
|
"github.com/drone/drone/server/datastore/database"
|
||||||
"github.com/drone/drone/server/worker/director"
|
"github.com/drone/drone/server/worker/director"
|
||||||
@@ -66,8 +65,6 @@ var (
|
|||||||
nodes StringArr
|
nodes StringArr
|
||||||
|
|
||||||
db *sql.DB
|
db *sql.DB
|
||||||
|
|
||||||
caps map[string]bool
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
@@ -100,8 +97,6 @@ func main() {
|
|||||||
gitlab.Register()
|
gitlab.Register()
|
||||||
gogs.Register()
|
gogs.Register()
|
||||||
|
|
||||||
caps = map[string]bool{}
|
|
||||||
|
|
||||||
// setup the database and cancel all pending
|
// setup the database and cancel all pending
|
||||||
// commits in the system.
|
// commits in the system.
|
||||||
db = database.MustConnect(*driver, *datasource)
|
db = database.MustConnect(*driver, *datasource)
|
||||||
@@ -165,7 +160,6 @@ func ContextMiddleware(c *web.C, h http.Handler) http.Handler {
|
|||||||
ctx = pool.NewContext(ctx, workers)
|
ctx = pool.NewContext(ctx, workers)
|
||||||
ctx = director.NewContext(ctx, worker)
|
ctx = director.NewContext(ctx, worker)
|
||||||
ctx = pubsub.NewContext(ctx, pub)
|
ctx = pubsub.NewContext(ctx, pub)
|
||||||
ctx = capability.NewContext(ctx, caps)
|
|
||||||
|
|
||||||
// add the context to the goji web context
|
// add the context to the goji web context
|
||||||
webcontext.Set(c, ctx)
|
webcontext.Set(c, ctx)
|
||||||
|
Reference in New Issue
Block a user