1ebd66d880
* wip post-demos cleanup * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * Reorganize: storage ├── common │ └── common.go `package storage` ├── boltdb │ └── ... └── redis └── ... storage ├── common.go `package storage` ├── boltdb │ └── ... └── redis └── ... storage ├── common │ ├── common.go `package storage` │ └── testing.go `package storage` <-- └── ... internal ├── app │ └── cli ├── pkg │ └── readcloser └── test └── util.go `package test` <-- * remove comment * add and use goimports * add test types & fix some lint errors * better typing * fixing linter issues/comments * goimports * goimports * more linter fixes; replace panic with NoError assertions in tests * fix typo/more linter errors * moar better linter fixes * even moar better linter fixes * linter * add localPort back * fixing exports, imports, and add comments
138 lines
3.6 KiB
Go
138 lines
3.6 KiB
Go
// Copyright (C) 2018 Storj Labs, Inc.
|
|
// See LICENSE for copying information.
|
|
|
|
package netstate
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/golang/protobuf/proto"
|
|
"go.uber.org/zap"
|
|
"google.golang.org/grpc"
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
|
|
"storj.io/storj/netstate/auth"
|
|
pb "storj.io/storj/protos/netstate"
|
|
"storj.io/storj/storage"
|
|
)
|
|
|
|
// PointerEntry - Path and Pointer are saved as a key/value pair to a `storage.KeyValueStore`.
|
|
type PointerEntry struct {
|
|
Path []byte
|
|
Pointer []byte
|
|
}
|
|
|
|
// Server implements the network state RPC service
|
|
type Server struct {
|
|
DB storage.KeyValueStore
|
|
logger *zap.Logger
|
|
}
|
|
|
|
// NewServer creates instance of Server
|
|
func NewServer(db storage.KeyValueStore, logger *zap.Logger) *Server {
|
|
return &Server{
|
|
DB: db,
|
|
logger: logger,
|
|
}
|
|
}
|
|
|
|
func (s *Server) validateAuth(APIKeyBytes []byte) error {
|
|
if !auth.ValidateAPIKey(string(APIKeyBytes)) {
|
|
s.logger.Error("unauthorized request: ", zap.Error(grpc.Errorf(codes.Unauthenticated, "Invalid API credential")))
|
|
return grpc.Errorf(codes.Unauthenticated, "Invalid API credential")
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Put formats and hands off a file path to be saved to boltdb
|
|
func (s *Server) Put(ctx context.Context, putReq *pb.PutRequest) (*pb.PutResponse, error) {
|
|
s.logger.Debug("entering netstate put")
|
|
|
|
APIKeyBytes := []byte(putReq.APIKey)
|
|
if err := s.validateAuth(APIKeyBytes); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
pointerBytes, err := proto.Marshal(putReq.Pointer)
|
|
if err != nil {
|
|
s.logger.Error("err marshaling pointer", zap.Error(err))
|
|
return nil, status.Errorf(codes.Internal, err.Error())
|
|
}
|
|
|
|
pe := PointerEntry{
|
|
Path: putReq.Path,
|
|
Pointer: pointerBytes,
|
|
}
|
|
|
|
if err := s.DB.Put(pe.Path, pe.Pointer); err != nil {
|
|
s.logger.Error("err putting pointer", zap.Error(err))
|
|
return nil, status.Errorf(codes.Internal, err.Error())
|
|
}
|
|
s.logger.Debug("put to the db: " + string(pe.Path))
|
|
|
|
return &pb.PutResponse{}, nil
|
|
}
|
|
|
|
// Get formats and hands off a file path to get from boltdb
|
|
func (s *Server) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetResponse, error) {
|
|
s.logger.Debug("entering netstate get")
|
|
|
|
APIKeyBytes := []byte(req.APIKey)
|
|
if err := s.validateAuth(APIKeyBytes); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
pointerBytes, err := s.DB.Get(req.Path)
|
|
|
|
if err != nil {
|
|
s.logger.Error("err getting file", zap.Error(err))
|
|
return nil, status.Errorf(codes.Internal, err.Error())
|
|
}
|
|
|
|
return &pb.GetResponse{
|
|
Pointer: pointerBytes,
|
|
}, nil
|
|
}
|
|
|
|
// List calls the bolt client's List function and returns all Path keys in the Pointers bucket
|
|
func (s *Server) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error) {
|
|
s.logger.Debug("entering netstate list")
|
|
|
|
APIKeyBytes := []byte(req.APIKey)
|
|
if err := s.validateAuth(APIKeyBytes); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
pathKeys, err := s.DB.List()
|
|
|
|
if err != nil {
|
|
s.logger.Error("err listing path keys", zap.Error(err))
|
|
return nil, status.Errorf(codes.Internal, err.Error())
|
|
}
|
|
|
|
s.logger.Debug("path keys retrieved")
|
|
return &pb.ListResponse{
|
|
// pathKeys is an array of byte arrays
|
|
Paths: pathKeys.ByteSlices(),
|
|
}, nil
|
|
}
|
|
|
|
// Delete formats and hands off a file path to delete from boltdb
|
|
func (s *Server) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteResponse, error) {
|
|
s.logger.Debug("entering netstate delete")
|
|
|
|
APIKeyBytes := []byte(req.APIKey)
|
|
if err := s.validateAuth(APIKeyBytes); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
err := s.DB.Delete(req.Path)
|
|
if err != nil {
|
|
s.logger.Error("err deleting pointer entry", zap.Error(err))
|
|
return nil, status.Errorf(codes.Internal, err.Error())
|
|
}
|
|
s.logger.Debug("deleted pointer at path: " + string(req.Path))
|
|
return &pb.DeleteResponse{}, nil
|
|
}
|