Skip to content

Commit afade42

Browse files
Michael Crosbytiborvass
authored andcommitted
Don't hard code true for auth job
Signed-off-by: Michael Crosby <[email protected]> Conflicts: registry/service.go
1 parent 48f7384 commit afade42

3 files changed

Lines changed: 20 additions & 13 deletions

File tree

builtins/builtins.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@ import (
1010
"github.com/docker/docker/engine"
1111
"github.com/docker/docker/events"
1212
"github.com/docker/docker/pkg/parsers/kernel"
13-
"github.com/docker/docker/registry"
1413
)
1514

1615
func Register(eng *engine.Engine) error {
@@ -26,7 +25,8 @@ func Register(eng *engine.Engine) error {
2625
if err := eng.Register("version", dockerVersion); err != nil {
2726
return err
2827
}
29-
return registry.NewService().Install(eng)
28+
29+
return nil
3030
}
3131

3232
// remote: a RESTful api for cross-docker communication

docker/daemon.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ import (
1313
"github.com/docker/docker/engine"
1414
flag "github.com/docker/docker/pkg/mflag"
1515
"github.com/docker/docker/pkg/signal"
16+
"github.com/docker/docker/registry"
1617
)
1718

1819
const CanDaemon = true
@@ -32,11 +33,17 @@ func mainDaemon() {
3233
}
3334
eng := engine.New()
3435
signal.Trap(eng.Shutdown)
36+
3537
// Load builtins
3638
if err := builtins.Register(eng); err != nil {
3739
log.Fatal(err)
3840
}
3941

42+
// load registry service
43+
if err := registry.NewService(daemonCfg.InsecureRegistries).Install(eng); err != nil {
44+
log.Fatal(err)
45+
}
46+
4047
// load the daemon in the background so we can immediately start
4148
// the http api so that connections don't fail while the daemon
4249
// is booting

registry/service.go

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,15 @@ import (
1313
// 'pull': Download images from any registry (TODO)
1414
// 'push': Upload images to any registry (TODO)
1515
type Service struct {
16+
insecureRegistries []string
1617
}
1718

1819
// NewService returns a new instance of Service ready to be
1920
// installed no an engine.
20-
func NewService() *Service {
21-
return &Service{}
21+
func NewService(insecureRegistries []string) *Service {
22+
return &Service{
23+
insecureRegistries: insecureRegistries,
24+
}
2225
}
2326

2427
// Install installs registry capabilities to eng.
@@ -32,15 +35,12 @@ func (s *Service) Install(eng *engine.Engine) error {
3235
// and returns OK if authentication was sucessful.
3336
// It can be used to verify the validity of a client's credentials.
3437
func (s *Service) Auth(job *engine.Job) engine.Status {
35-
var (
36-
err error
37-
authConfig = &AuthConfig{}
38-
)
38+
var authConfig = new(AuthConfig)
3939

4040
job.GetenvJson("authConfig", authConfig)
41-
// TODO: this is only done here because auth and registry need to be merged into one pkg
41+
4242
if addr := authConfig.ServerAddress; addr != "" && addr != IndexServerAddress() {
43-
endpoint, err := NewEndpoint(addr, true)
43+
endpoint, err := NewEndpoint(addr, IsSecure(addr, s.insecureRegistries))
4444
if err != nil {
4545
return job.Error(err)
4646
}
@@ -49,11 +49,11 @@ func (s *Service) Auth(job *engine.Job) engine.Status {
4949
}
5050
authConfig.ServerAddress = endpoint.String()
5151
}
52-
status, err := Login(authConfig, HTTPRequestFactory(nil))
53-
if err != nil {
52+
53+
if _, err := Login(authConfig, HTTPRequestFactory(nil)); err != nil {
5454
return job.Error(err)
5555
}
56-
job.Printf("%s\n", status)
56+
5757
return engine.StatusOK
5858
}
5959

0 commit comments

Comments
 (0)