From b9c4156e5bf59686d61e2e9fed2b8f6a5bbc314f Mon Sep 17 00:00:00 2001 From: Evgeniy Kulikov Date: Mon, 13 Jul 2020 14:23:23 +0300 Subject: [PATCH] Fix S3 NeoFS integration --- cmd/gate/app.go | 9 ++++++-- legacy/neofs-router.go | 43 ++++++++++++++++++++++++++++-------- neofs/layer/gateway-neofs.go | 5 ++++- neofs/layer/neofs-object.go | 19 ++++++++++++++++ neofs/layer/util.go | 18 +++++++++++++-- 5 files changed, 80 insertions(+), 14 deletions(-) diff --git a/cmd/gate/app.go b/cmd/gate/app.go index 3de2245..1129e31 100644 --- a/cmd/gate/app.go +++ b/cmd/gate/app.go @@ -122,7 +122,7 @@ func newApp(l *zap.Logger, v *viper.Viper) *App { zap.String("SecretKey", wif)) } - if obj, err = layer.NewLayer(cli, auth.Credentials{AccessKey: uid.String(), SecretKey: wif}); err != nil { + if obj, err = layer.NewLayer(cli, l, auth.Credentials{AccessKey: uid.String(), SecretKey: wif}); err != nil { l.Fatal("could not prepare ObjectLayer", zap.Error(err)) } @@ -188,8 +188,13 @@ func (a *App) Server(ctx context.Context) { a.log.Info("starting server", zap.String("bind", addr)) + // var ( + // keyPath string + // certPath string + // ) + if err = srv.Serve(lis); err != nil && err != http.ErrServerClosed { - a.log.Warn("listen and serve", + a.log.Fatal("listen and serve", zap.Error(err)) } }() diff --git a/legacy/neofs-router.go b/legacy/neofs-router.go index 28b759b..89d2895 100644 --- a/legacy/neofs-router.go +++ b/legacy/neofs-router.go @@ -6,6 +6,40 @@ import ( ) func AttachS3API(r *mux.Router, obj ObjectLayer, l *zap.Logger) { + { // should be removed in feature + // Initialize all help + initHelp() + + globalGatewayName = "NeoFS GW" + + // Set when gateway is enabled + globalIsGateway = true + + // Handle gateway specific env + gatewayHandleEnvVars() + + // Set system resources to maximum. + if err := setMaxResources(); err != nil { + l.Warn("could not set max resources", + zap.Error(err)) + } + + // TODO: We need to move this code with globalConfigSys.Init() + // for now keep it here such that "s3" gateway layer initializes + // itself properly when KMS is set. + + // Initialize server config. + srvCfg := newServerConfig() + + // Override any values from ENVs. + lookupConfigs(srvCfg) + + // hold the mutex lock before a new config is assigned. + globalServerConfigMu.Lock() + globalServerConfig = srvCfg + globalServerConfigMu.Unlock() + } + // Add healthcheck router registerHealthCheckRouter(r) @@ -35,13 +69,4 @@ func AttachS3API(r *mux.Router, obj ObjectLayer, l *zap.Logger) { globalObjLayerMutex.Lock() globalSafeMode = false globalObjLayerMutex.Unlock() - - // Handle gateway specific env - gatewayHandleEnvVars() - - // Set system resources to maximum. - if err := setMaxResources(); err != nil { - l.Warn("could not set max resources", - zap.Error(err)) - } } diff --git a/neofs/layer/gateway-neofs.go b/neofs/layer/gateway-neofs.go index aaebe80..2f4c161 100644 --- a/neofs/layer/gateway-neofs.go +++ b/neofs/layer/gateway-neofs.go @@ -14,6 +14,7 @@ import ( "github.com/nspcc-dev/neofs-api-go/service" crypto "github.com/nspcc-dev/neofs-crypto" "github.com/pkg/errors" + "go.uber.org/zap" ) type ( @@ -23,6 +24,7 @@ type ( minio.GatewayUnsupported // placeholder for unimplemented functions cli pool.Client + log *zap.Logger key *ecdsa.PrivateKey owner refs.OwnerID token *service.Token @@ -40,7 +42,7 @@ type ( // NewGatewayLayer creates instance of neofsObject. It checks credentials // and establishes gRPC connection with node. -func NewLayer(cli pool.Client, cred auth.Credentials) (minio.ObjectLayer, error) { +func NewLayer(cli pool.Client, log *zap.Logger, cred auth.Credentials) (minio.ObjectLayer, error) { // check if wif is correct key, err := crypto.WIFDecode(cred.SecretKey) if err != nil { @@ -73,6 +75,7 @@ func NewLayer(cli pool.Client, cred auth.Credentials) (minio.ObjectLayer, error) return &neofsObject{ cli: cli, key: key, + log: log, owner: owner, token: token, }, nil diff --git a/neofs/layer/neofs-object.go b/neofs/layer/neofs-object.go index 66b801a..f585616 100644 --- a/neofs/layer/neofs-object.go +++ b/neofs/layer/neofs-object.go @@ -12,6 +12,7 @@ import ( "github.com/nspcc-dev/neofs-api-go/refs" "github.com/nspcc-dev/neofs-api-go/service" "github.com/nspcc-dev/neofs-api-go/storagegroup" + "go.uber.org/zap" ) const ( @@ -350,11 +351,15 @@ func (n *neofsObject) objectPut(ctx context.Context, p putParams) (*object.Objec verb: service.Token_Info_Put, }) if err != nil { + n.log.Error("could not prepare token", + zap.Error(err)) return nil, err } conn, err := n.cli.GetConnection(ctx) if err != nil { + n.log.Error("could not prepare connection", + zap.Error(err)) return nil, err } @@ -362,6 +367,8 @@ func (n *neofsObject) objectPut(ctx context.Context, p putParams) (*object.Objec // todo: think about timeout putClient, err := client.Put(ctx) if err != nil { + n.log.Error("could not prepare PutClient", + zap.Error(err)) return nil, err } @@ -390,17 +397,23 @@ func (n *neofsObject) objectPut(ctx context.Context, p putParams) (*object.Objec err = service.SignRequestData(n.key, req) if err != nil { + n.log.Error("could not prepare request", + zap.Error(err)) return nil, err } err = putClient.Send(req) if err != nil { + n.log.Error("could not send request", + zap.Error(err)) return nil, err } read, err := p.r.Read(readBuffer) for read > 0 { if err != nil && err != io.EOF { + n.log.Error("something went wrong", + zap.Error(err)) return nil, err } @@ -411,11 +424,15 @@ func (n *neofsObject) objectPut(ctx context.Context, p putParams) (*object.Objec err = service.SignRequestData(n.key, req) if err != nil { + n.log.Error("could not sign chunk request", + zap.Error(err)) return nil, err } err = putClient.Send(req) if err != nil && err != io.EOF { + n.log.Error("could not send chunk", + zap.Error(err)) return nil, err } } @@ -425,6 +442,8 @@ func (n *neofsObject) objectPut(ctx context.Context, p putParams) (*object.Objec _, err = putClient.CloseAndRecv() if err != nil { + n.log.Error("could not finish request", + zap.Error(err)) return nil, err } diff --git a/neofs/layer/util.go b/neofs/layer/util.go index 880fd81..d63d6f9 100644 --- a/neofs/layer/util.go +++ b/neofs/layer/util.go @@ -6,7 +6,6 @@ import ( "strings" "time" - "github.com/gogo/protobuf/proto" minio "github.com/minio/minio/legacy" "github.com/minio/minio/neofs/pool" "github.com/nspcc-dev/neofs-api-go/object" @@ -104,7 +103,22 @@ func generateToken(ctx context.Context, p tokenParams) (*service.Token, error) { } func prepareToken(t *service.Token, p queryParams) (*service.Token, error) { - token := proto.Clone(t).(*service.Token) + sig := make([]byte, len(t.Signature)) + copy(sig, t.Signature) + + token := &service.Token{ + Token_Info: service.Token_Info{ + ID: t.ID, + OwnerID: t.OwnerID, + Verb: t.Verb, + Address: t.Address, + TokenLifetime: t.TokenLifetime, + SessionKey: t.SessionKey, + OwnerKey: t.OwnerKey, + }, + Signature: sig, + } + token.SetAddress(p.addr) token.SetVerb(p.verb)