diff --git a/Makefile b/Makefile index a56e9ee2d4..d82f4703e2 100644 --- a/Makefile +++ b/Makefile @@ -90,7 +90,7 @@ protobuild: @protoc-go-inject-tag -input=./internal/kms/store/token_key.pb.go @protoc-go-inject-tag -input=./internal/kms/store/session_key.pb.go @protoc-go-inject-tag -input=./internal/target/store/target.pb.go - @protoc-go-inject-tag -input=./internal/sessions/store/session.pb.go + @protoc-go-inject-tag -input=./internal/session/store/session.pb.go @rm -R ${TMP_DIR} diff --git a/internal/proto/local/controller/storage/sessions/store/v1/session.proto b/internal/proto/local/controller/storage/session/store/v1/session.proto similarity index 97% rename from internal/proto/local/controller/storage/sessions/store/v1/session.proto rename to internal/proto/local/controller/storage/session/store/v1/session.proto index 308e125b7a..25dee18718 100644 --- a/internal/proto/local/controller/storage/sessions/store/v1/session.proto +++ b/internal/proto/local/controller/storage/session/store/v1/session.proto @@ -1,7 +1,7 @@ syntax = "proto3"; -package controller.storage.sessions.store.v1; -option go_package = "github.com/hashicorp/boundary/internal/sessions/store;store"; +package controller.storage.session.store.v1; +option go_package = "github.com/hashicorp/boundary/internal/session/store;store"; import "controller/storage/timestamp/v1/timestamp.proto"; import "controller/custom_options/v1/options.proto"; diff --git a/internal/servers/controller/handler.go b/internal/servers/controller/handler.go index 0ab0d3843d..f3f5190628 100644 --- a/internal/servers/controller/handler.go +++ b/internal/servers/controller/handler.go @@ -26,7 +26,7 @@ import ( "github.com/hashicorp/boundary/internal/servers/controller/handlers/authmethods" "github.com/hashicorp/boundary/internal/servers/controller/handlers/host_sets" "github.com/hashicorp/boundary/internal/servers/controller/handlers/targets" - "github.com/hashicorp/boundary/internal/sessions" + "github.com/hashicorp/boundary/internal/session" "github.com/hashicorp/boundary/internal/types/scope" "github.com/hashicorp/shared-secure-libs/configutil" "github.com/hashicorp/vault/sdk/helper/base62" @@ -376,7 +376,7 @@ func jobTestingHandler(c *Controller) http.Handler { return } jobId = "s_" + jobId - pubKey, privKey, err := sessions.DeriveED25519Key(wrapper, "u_1234567890", jobId) + pubKey, privKey, err := session.DeriveED25519Key(wrapper, "u_1234567890", jobId) template := &x509.Certificate{ ExtKeyUsage: []x509.ExtKeyUsage{ diff --git a/internal/servers/controller/handlers/workers/worker_service.go b/internal/servers/controller/handlers/workers/worker_service.go index cac841ad58..c098bb7bb0 100644 --- a/internal/servers/controller/handlers/workers/worker_service.go +++ b/internal/servers/controller/handlers/workers/worker_service.go @@ -8,7 +8,7 @@ import ( pbs "github.com/hashicorp/boundary/internal/gen/controller/api/services" "github.com/hashicorp/boundary/internal/kms" "github.com/hashicorp/boundary/internal/servers/controller/common" - "github.com/hashicorp/boundary/internal/sessions" + "github.com/hashicorp/boundary/internal/session" "github.com/hashicorp/boundary/internal/types/resource" "github.com/hashicorp/go-hclog" "google.golang.org/grpc/codes" @@ -79,7 +79,7 @@ func (ws *workerServiceServer) ValidateSession(ctx context.Context, req *pbs.Val // Derive the private key, which should match. Deriving on both ends allows // us to not store it in the DB. - _, privKey, err := sessions.DeriveED25519Key(wrapper, sessionInfo.GetUserId(), req.GetId()) + _, privKey, err := session.DeriveED25519Key(wrapper, sessionInfo.GetUserId(), req.GetId()) if err != nil { return &pbs.ValidateSessionResponse{}, status.Errorf(codes.Internal, "Error deriving session key: %v", err) } diff --git a/internal/sessions/ids.go b/internal/session/ids.go similarity index 96% rename from internal/sessions/ids.go rename to internal/session/ids.go index d34138a45d..38b9b40db8 100644 --- a/internal/sessions/ids.go +++ b/internal/session/ids.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "fmt" diff --git a/internal/sessions/ids_test.go b/internal/session/ids_test.go similarity index 96% rename from internal/sessions/ids_test.go rename to internal/session/ids_test.go index cf91e17489..959abb4797 100644 --- a/internal/sessions/ids_test.go +++ b/internal/session/ids_test.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "strings" diff --git a/internal/sessions/options.go b/internal/session/options.go similarity index 97% rename from internal/sessions/options.go rename to internal/session/options.go index ef5004a16b..0413bca504 100644 --- a/internal/sessions/options.go +++ b/internal/session/options.go @@ -1,4 +1,4 @@ -package sessions +package session // getOpts - iterate the inbound Options and return a struct func getOpts(opt ...Option) options { diff --git a/internal/sessions/options_test.go b/internal/session/options_test.go similarity index 97% rename from internal/sessions/options_test.go rename to internal/session/options_test.go index 9418a9399c..8696c247c0 100644 --- a/internal/sessions/options_test.go +++ b/internal/session/options_test.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "testing" diff --git a/internal/sessions/repository.go b/internal/session/repository.go similarity index 98% rename from internal/sessions/repository.go rename to internal/session/repository.go index f988beaebf..762d830294 100644 --- a/internal/sessions/repository.go +++ b/internal/session/repository.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "errors" diff --git a/internal/sessions/repository_test.go b/internal/session/repository_test.go similarity index 98% rename from internal/sessions/repository_test.go rename to internal/session/repository_test.go index b6f70a15f4..ed1f68ae13 100644 --- a/internal/sessions/repository_test.go +++ b/internal/session/repository_test.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "testing" diff --git a/internal/sessions/session.go b/internal/session/session.go similarity index 97% rename from internal/sessions/session.go rename to internal/session/session.go index d566085041..eaba3f936f 100644 --- a/internal/sessions/session.go +++ b/internal/session/session.go @@ -1,11 +1,11 @@ -package sessions +package session import ( "context" "fmt" "github.com/hashicorp/boundary/internal/db" - "github.com/hashicorp/boundary/internal/sessions/store" + "github.com/hashicorp/boundary/internal/session/store" "google.golang.org/protobuf/proto" ) diff --git a/internal/sessions/session_test.go b/internal/session/session_test.go similarity index 99% rename from internal/sessions/session_test.go rename to internal/session/session_test.go index b36b9fca89..5439d8f229 100644 --- a/internal/sessions/session_test.go +++ b/internal/session/session_test.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "context" @@ -7,7 +7,7 @@ import ( "github.com/hashicorp/boundary/internal/db" "github.com/hashicorp/boundary/internal/iam" - "github.com/hashicorp/boundary/internal/sessions/store" + "github.com/hashicorp/boundary/internal/session/store" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" "google.golang.org/protobuf/proto" diff --git a/internal/session/state.go b/internal/session/state.go new file mode 100644 index 0000000000..4ae47d8e07 --- /dev/null +++ b/internal/session/state.go @@ -0,0 +1,110 @@ +package session + +import ( + "context" + "fmt" + + "github.com/hashicorp/boundary/internal/db" + "github.com/hashicorp/boundary/internal/session/store" + "google.golang.org/protobuf/proto" +) + +const ( + DefaultSessionStateTableName = "session" +) + +type Status string + +const ( + Pending Status = "pending" + Connected Status = "connected" + Canceling Status = "canceling" + Closed Status = "closed" +) + +func (s Status) String() string { + return string(s) +} + +type State struct { + *store.State + tableName string `gorm:"-"` +} + +var _ Cloneable = (*State)(nil) +var _ db.VetForWriter = (*State)(nil) + +// NewState creates a new in memory session state. No options +// are currently supported. +func NewState(session_id, state string, opt ...Option) (*State, error) { + s := State{ + State: &store.State{ + SessionId: session_id, + State: state, + }, + } + + if err := s.validate("new session:"); err != nil { + return nil, err + } + return &s, nil +} + +// allocSessionState will allocate a SessionState +func allocState() State { + return State{ + State: &store.State{}, + } +} + +// Clone creates a clone of the SessionState +func (s *State) Clone() interface{} { + cp := proto.Clone(s.State) + return &State{ + State: cp.(*store.State), + } +} + +// VetForWrite implements db.VetForWrite() interface and validates the session +// before it's written. +func (s *State) VetForWrite(ctx context.Context, r db.Reader, opType db.OpType, opt ...db.Option) error { + if err := s.validate("session state vet for write:"); err != nil { + return err + } + return nil +} + +// TableName returns the tablename to override the default gorm table name +func (s *State) TableName() string { + if s.tableName != "" { + return s.tableName + } + return DefaultSessionStateTableName +} + +// SetTableName sets the tablename and satisfies the ReplayableMessage +// interface. If the caller attempts to set the name to "" the name will be +// reset to the default name. +func (s *State) SetTableName(n string) { + s.tableName = n +} + +// validateSessionState checks the session state +func (s *State) validate(errorPrefix string) error { + if s.SessionId == "" { + return fmt.Errorf("%s missing session id: %w", errorPrefix, db.ErrInvalidParameter) + } + if s.State == nil { + return fmt.Errorf("%s missing state: %w", errorPrefix, db.ErrInvalidParameter) + } + if s.StartTime != nil { + return fmt.Errorf("%s start time is not settable: %w", errorPrefix, db.ErrInvalidParameter) + } + if s.EndTime != nil { + return fmt.Errorf("%s end time is not settable: %w", errorPrefix, db.ErrInvalidParameter) + } + if s.PreviousEndTime != nil { + return fmt.Errorf("%s previous end time is not settable: %w", errorPrefix, db.ErrInvalidParameter) + } + return nil +} diff --git a/internal/sessions/store/session.pb.go b/internal/session/store/session.pb.go similarity index 53% rename from internal/sessions/store/session.pb.go rename to internal/session/store/session.pb.go index bf75225f69..7d3944f4b3 100644 --- a/internal/sessions/store/session.pb.go +++ b/internal/session/store/session.pb.go @@ -2,7 +2,7 @@ // versions: // protoc-gen-go v1.25.0 // protoc v3.12.4 -// source: controller/storage/sessions/store/v1/session.proto +// source: controller/storage/session/store/v1/session.proto package store @@ -87,7 +87,7 @@ type Session struct { func (x *Session) Reset() { *x = Session{} if protoimpl.UnsafeEnabled { - mi := &file_controller_storage_sessions_store_v1_session_proto_msgTypes[0] + mi := &file_controller_storage_session_store_v1_session_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -100,7 +100,7 @@ func (x *Session) String() string { func (*Session) ProtoMessage() {} func (x *Session) ProtoReflect() protoreflect.Message { - mi := &file_controller_storage_sessions_store_v1_session_proto_msgTypes[0] + mi := &file_controller_storage_session_store_v1_session_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -113,7 +113,7 @@ func (x *Session) ProtoReflect() protoreflect.Message { // Deprecated: Use Session.ProtoReflect.Descriptor instead. func (*Session) Descriptor() ([]byte, []int) { - return file_controller_storage_sessions_store_v1_session_proto_rawDescGZIP(), []int{0} + return file_controller_storage_session_store_v1_session_proto_rawDescGZIP(), []int{0} } func (x *Session) GetPublicId() string { @@ -260,7 +260,7 @@ type State struct { func (x *State) Reset() { *x = State{} if protoimpl.UnsafeEnabled { - mi := &file_controller_storage_sessions_store_v1_session_proto_msgTypes[1] + mi := &file_controller_storage_session_store_v1_session_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -273,7 +273,7 @@ func (x *State) String() string { func (*State) ProtoMessage() {} func (x *State) ProtoReflect() protoreflect.Message { - mi := &file_controller_storage_sessions_store_v1_session_proto_msgTypes[1] + mi := &file_controller_storage_session_store_v1_session_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -286,7 +286,7 @@ func (x *State) ProtoReflect() protoreflect.Message { // Deprecated: Use State.ProtoReflect.Descriptor instead. func (*State) Descriptor() ([]byte, []int) { - return file_controller_storage_sessions_store_v1_session_proto_rawDescGZIP(), []int{1} + return file_controller_storage_session_store_v1_session_proto_rawDescGZIP(), []int{1} } func (x *State) GetSessionId() string { @@ -324,108 +324,107 @@ func (x *State) GetEndTime() *timestamp.Timestamp { return nil } -var File_controller_storage_sessions_store_v1_session_proto protoreflect.FileDescriptor - -var file_controller_storage_sessions_store_v1_session_proto_rawDesc = []byte{ - 0x0a, 0x32, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x73, 0x74, 0x6f, - 0x72, 0x61, 0x67, 0x65, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, - 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x70, - 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x24, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, - 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, - 0x73, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x1a, 0x2f, 0x63, 0x6f, 0x6e, 0x74, - 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x74, - 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2f, 0x76, 0x31, 0x2f, 0x74, 0x69, 0x6d, 0x65, - 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2a, 0x63, 0x6f, 0x6e, - 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x5f, 0x6f, - 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x31, 0x2f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, - 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xd9, 0x04, 0x0a, 0x07, 0x53, 0x65, 0x73, 0x73, - 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x5f, 0x69, 0x64, - 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x49, 0x64, - 0x12, 0x17, 0x0a, 0x07, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x14, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x17, 0x0a, 0x07, 0x68, 0x6f, 0x73, - 0x74, 0x5f, 0x69, 0x64, 0x18, 0x1e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, - 0x49, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, - 0x28, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x49, 0x64, 0x12, - 0x1f, 0x0a, 0x0b, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x32, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, - 0x12, 0x1b, 0x0a, 0x09, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x3c, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x08, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x49, 0x64, 0x12, 0x15, 0x0a, - 0x06, 0x73, 0x65, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x46, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x73, - 0x65, 0x74, 0x49, 0x64, 0x12, 0x22, 0x0a, 0x0d, 0x61, 0x75, 0x74, 0x68, 0x5f, 0x74, 0x6f, 0x6b, - 0x65, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x50, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x75, 0x74, - 0x68, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x49, 0x64, 0x12, 0x19, 0x0a, 0x08, 0x73, 0x63, 0x6f, 0x70, - 0x65, 0x5f, 0x69, 0x64, 0x18, 0x5a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x63, 0x6f, 0x70, - 0x65, 0x49, 0x64, 0x12, 0x2d, 0x0a, 0x12, 0x74, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x69, - 0x6f, 0x6e, 0x5f, 0x72, 0x65, 0x61, 0x73, 0x6f, 0x6e, 0x18, 0x64, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x11, 0x74, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x61, 0x73, - 0x6f, 0x6e, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x6e, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x12, 0x0a, 0x04, - 0x70, 0x6f, 0x72, 0x74, 0x18, 0x78, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, - 0x12, 0x1a, 0x0a, 0x08, 0x62, 0x79, 0x74, 0x65, 0x73, 0x5f, 0x75, 0x70, 0x18, 0x82, 0x01, 0x20, - 0x01, 0x28, 0x04, 0x52, 0x07, 0x62, 0x79, 0x74, 0x65, 0x73, 0x55, 0x70, 0x12, 0x1e, 0x0a, 0x0a, - 0x62, 0x79, 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f, 0x77, 0x6e, 0x18, 0x8c, 0x01, 0x20, 0x01, 0x28, - 0x04, 0x52, 0x09, 0x62, 0x79, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x77, 0x6e, 0x12, 0x4c, 0x0a, 0x0b, - 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x96, 0x01, 0x20, 0x01, - 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, - 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, - 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, - 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x4c, 0x0a, 0x0b, 0x75, 0x70, - 0x64, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0xa0, 0x01, 0x20, 0x01, 0x28, 0x0b, +var File_controller_storage_session_store_v1_session_proto protoreflect.FileDescriptor + +var file_controller_storage_session_store_v1_session_proto_rawDesc = []byte{ + 0x0a, 0x31, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x73, 0x74, 0x6f, + 0x72, 0x61, 0x67, 0x65, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2f, 0x73, 0x74, 0x6f, + 0x72, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, + 0x6f, 0x74, 0x6f, 0x12, 0x23, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, + 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, + 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x31, 0x1a, 0x2f, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, + 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x74, 0x69, 0x6d, + 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2f, 0x76, 0x31, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, + 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2a, 0x63, 0x6f, 0x6e, 0x74, 0x72, + 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x5f, 0x6f, 0x70, 0x74, + 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x31, 0x2f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, + 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xd9, 0x04, 0x0a, 0x07, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, + 0x6e, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x5f, 0x69, 0x64, 0x18, 0x0a, + 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x49, 0x64, 0x12, 0x17, + 0x0a, 0x07, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x14, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x17, 0x0a, 0x07, 0x68, 0x6f, 0x73, 0x74, 0x5f, + 0x69, 0x64, 0x18, 0x1e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x64, + 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x28, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1f, 0x0a, + 0x0b, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x32, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x0a, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1b, + 0x0a, 0x09, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x3c, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x08, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x49, 0x64, 0x12, 0x15, 0x0a, 0x06, 0x73, + 0x65, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x46, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x73, 0x65, 0x74, + 0x49, 0x64, 0x12, 0x22, 0x0a, 0x0d, 0x61, 0x75, 0x74, 0x68, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, + 0x5f, 0x69, 0x64, 0x18, 0x50, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x75, 0x74, 0x68, 0x54, + 0x6f, 0x6b, 0x65, 0x6e, 0x49, 0x64, 0x12, 0x19, 0x0a, 0x08, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x5f, + 0x69, 0x64, 0x18, 0x5a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x49, + 0x64, 0x12, 0x2d, 0x0a, 0x12, 0x74, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, + 0x5f, 0x72, 0x65, 0x61, 0x73, 0x6f, 0x6e, 0x18, 0x64, 0x20, 0x01, 0x28, 0x09, 0x52, 0x11, 0x74, + 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x61, 0x73, 0x6f, 0x6e, + 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x6e, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, + 0x72, 0x74, 0x18, 0x78, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x1a, + 0x0a, 0x08, 0x62, 0x79, 0x74, 0x65, 0x73, 0x5f, 0x75, 0x70, 0x18, 0x82, 0x01, 0x20, 0x01, 0x28, + 0x04, 0x52, 0x07, 0x62, 0x79, 0x74, 0x65, 0x73, 0x55, 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x62, 0x79, + 0x74, 0x65, 0x73, 0x5f, 0x64, 0x6f, 0x77, 0x6e, 0x18, 0x8c, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, + 0x09, 0x62, 0x79, 0x74, 0x65, 0x73, 0x44, 0x6f, 0x77, 0x6e, 0x12, 0x4c, 0x0a, 0x0b, 0x63, 0x72, + 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x96, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, - 0x76, 0x31, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x75, 0x70, - 0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x19, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, - 0x69, 0x6f, 0x6e, 0x18, 0xaa, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, - 0x69, 0x6f, 0x6e, 0x22, 0xa6, 0x02, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x1d, 0x0a, - 0x0a, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x0a, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, - 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x14, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x73, 0x74, 0x61, - 0x74, 0x65, 0x12, 0x56, 0x0a, 0x11, 0x70, 0x72, 0x65, 0x76, 0x69, 0x6f, 0x75, 0x73, 0x5f, 0x65, - 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x1e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, - 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, - 0x67, 0x65, 0x2e, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x76, 0x31, 0x2e, - 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0f, 0x70, 0x72, 0x65, 0x76, 0x69, - 0x6f, 0x75, 0x73, 0x45, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x49, 0x0a, 0x0a, 0x73, 0x74, - 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x28, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, + 0x76, 0x31, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x63, 0x72, + 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x4c, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, + 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0xa0, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x76, 0x31, - 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, - 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x45, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, - 0x65, 0x18, 0x32, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, - 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x74, 0x69, 0x6d, - 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, - 0x61, 0x6d, 0x70, 0x52, 0x07, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x42, 0x3d, 0x5a, 0x3b, - 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x68, 0x61, 0x73, 0x68, 0x69, - 0x63, 0x6f, 0x72, 0x70, 0x2f, 0x62, 0x6f, 0x75, 0x6e, 0x64, 0x61, 0x72, 0x79, 0x2f, 0x69, 0x6e, - 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, - 0x73, 0x74, 0x6f, 0x72, 0x65, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, - 0x74, 0x6f, 0x33, + 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, + 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x19, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x18, 0xaa, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x22, 0xa6, 0x02, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x73, + 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, + 0x61, 0x74, 0x65, 0x18, 0x14, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, + 0x12, 0x56, 0x0a, 0x11, 0x70, 0x72, 0x65, 0x76, 0x69, 0x6f, 0x75, 0x73, 0x5f, 0x65, 0x6e, 0x64, + 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x1e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x63, 0x6f, + 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, + 0x2e, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x69, + 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0f, 0x70, 0x72, 0x65, 0x76, 0x69, 0x6f, 0x75, + 0x73, 0x45, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x49, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x72, + 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x28, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x63, + 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, + 0x65, 0x2e, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x54, + 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, + 0x69, 0x6d, 0x65, 0x12, 0x45, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, + 0x32, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, + 0x65, 0x72, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x74, 0x69, 0x6d, 0x65, 0x73, + 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, + 0x70, 0x52, 0x07, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, + 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x68, 0x61, 0x73, 0x68, 0x69, 0x63, 0x6f, + 0x72, 0x70, 0x2f, 0x62, 0x6f, 0x75, 0x6e, 0x64, 0x61, 0x72, 0x79, 0x2f, 0x69, 0x6e, 0x74, 0x65, + 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2f, 0x73, 0x74, 0x6f, + 0x72, 0x65, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( - file_controller_storage_sessions_store_v1_session_proto_rawDescOnce sync.Once - file_controller_storage_sessions_store_v1_session_proto_rawDescData = file_controller_storage_sessions_store_v1_session_proto_rawDesc + file_controller_storage_session_store_v1_session_proto_rawDescOnce sync.Once + file_controller_storage_session_store_v1_session_proto_rawDescData = file_controller_storage_session_store_v1_session_proto_rawDesc ) -func file_controller_storage_sessions_store_v1_session_proto_rawDescGZIP() []byte { - file_controller_storage_sessions_store_v1_session_proto_rawDescOnce.Do(func() { - file_controller_storage_sessions_store_v1_session_proto_rawDescData = protoimpl.X.CompressGZIP(file_controller_storage_sessions_store_v1_session_proto_rawDescData) +func file_controller_storage_session_store_v1_session_proto_rawDescGZIP() []byte { + file_controller_storage_session_store_v1_session_proto_rawDescOnce.Do(func() { + file_controller_storage_session_store_v1_session_proto_rawDescData = protoimpl.X.CompressGZIP(file_controller_storage_session_store_v1_session_proto_rawDescData) }) - return file_controller_storage_sessions_store_v1_session_proto_rawDescData + return file_controller_storage_session_store_v1_session_proto_rawDescData } -var file_controller_storage_sessions_store_v1_session_proto_msgTypes = make([]protoimpl.MessageInfo, 2) -var file_controller_storage_sessions_store_v1_session_proto_goTypes = []interface{}{ - (*Session)(nil), // 0: controller.storage.sessions.store.v1.Session - (*State)(nil), // 1: controller.storage.sessions.store.v1.State +var file_controller_storage_session_store_v1_session_proto_msgTypes = make([]protoimpl.MessageInfo, 2) +var file_controller_storage_session_store_v1_session_proto_goTypes = []interface{}{ + (*Session)(nil), // 0: controller.storage.session.store.v1.Session + (*State)(nil), // 1: controller.storage.session.store.v1.State (*timestamp.Timestamp)(nil), // 2: controller.storage.timestamp.v1.Timestamp } -var file_controller_storage_sessions_store_v1_session_proto_depIdxs = []int32{ - 2, // 0: controller.storage.sessions.store.v1.Session.create_time:type_name -> controller.storage.timestamp.v1.Timestamp - 2, // 1: controller.storage.sessions.store.v1.Session.update_time:type_name -> controller.storage.timestamp.v1.Timestamp - 2, // 2: controller.storage.sessions.store.v1.State.previous_end_time:type_name -> controller.storage.timestamp.v1.Timestamp - 2, // 3: controller.storage.sessions.store.v1.State.start_time:type_name -> controller.storage.timestamp.v1.Timestamp - 2, // 4: controller.storage.sessions.store.v1.State.end_time:type_name -> controller.storage.timestamp.v1.Timestamp +var file_controller_storage_session_store_v1_session_proto_depIdxs = []int32{ + 2, // 0: controller.storage.session.store.v1.Session.create_time:type_name -> controller.storage.timestamp.v1.Timestamp + 2, // 1: controller.storage.session.store.v1.Session.update_time:type_name -> controller.storage.timestamp.v1.Timestamp + 2, // 2: controller.storage.session.store.v1.State.previous_end_time:type_name -> controller.storage.timestamp.v1.Timestamp + 2, // 3: controller.storage.session.store.v1.State.start_time:type_name -> controller.storage.timestamp.v1.Timestamp + 2, // 4: controller.storage.session.store.v1.State.end_time:type_name -> controller.storage.timestamp.v1.Timestamp 5, // [5:5] is the sub-list for method output_type 5, // [5:5] is the sub-list for method input_type 5, // [5:5] is the sub-list for extension type_name @@ -433,13 +432,13 @@ var file_controller_storage_sessions_store_v1_session_proto_depIdxs = []int32{ 0, // [0:5] is the sub-list for field type_name } -func init() { file_controller_storage_sessions_store_v1_session_proto_init() } -func file_controller_storage_sessions_store_v1_session_proto_init() { - if File_controller_storage_sessions_store_v1_session_proto != nil { +func init() { file_controller_storage_session_store_v1_session_proto_init() } +func file_controller_storage_session_store_v1_session_proto_init() { + if File_controller_storage_session_store_v1_session_proto != nil { return } if !protoimpl.UnsafeEnabled { - file_controller_storage_sessions_store_v1_session_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_controller_storage_session_store_v1_session_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*Session); i { case 0: return &v.state @@ -451,7 +450,7 @@ func file_controller_storage_sessions_store_v1_session_proto_init() { return nil } } - file_controller_storage_sessions_store_v1_session_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_controller_storage_session_store_v1_session_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*State); i { case 0: return &v.state @@ -468,18 +467,18 @@ func file_controller_storage_sessions_store_v1_session_proto_init() { out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_controller_storage_sessions_store_v1_session_proto_rawDesc, + RawDescriptor: file_controller_storage_session_store_v1_session_proto_rawDesc, NumEnums: 0, NumMessages: 2, NumExtensions: 0, NumServices: 0, }, - GoTypes: file_controller_storage_sessions_store_v1_session_proto_goTypes, - DependencyIndexes: file_controller_storage_sessions_store_v1_session_proto_depIdxs, - MessageInfos: file_controller_storage_sessions_store_v1_session_proto_msgTypes, + GoTypes: file_controller_storage_session_store_v1_session_proto_goTypes, + DependencyIndexes: file_controller_storage_session_store_v1_session_proto_depIdxs, + MessageInfos: file_controller_storage_session_store_v1_session_proto_msgTypes, }.Build() - File_controller_storage_sessions_store_v1_session_proto = out.File - file_controller_storage_sessions_store_v1_session_proto_rawDesc = nil - file_controller_storage_sessions_store_v1_session_proto_goTypes = nil - file_controller_storage_sessions_store_v1_session_proto_depIdxs = nil + File_controller_storage_session_store_v1_session_proto = out.File + file_controller_storage_session_store_v1_session_proto_rawDesc = nil + file_controller_storage_session_store_v1_session_proto_goTypes = nil + file_controller_storage_session_store_v1_session_proto_depIdxs = nil } diff --git a/internal/sessions/testing.go b/internal/session/testing.go similarity index 99% rename from internal/sessions/testing.go rename to internal/session/testing.go index d10c2f0003..be1cf6ec2e 100644 --- a/internal/sessions/testing.go +++ b/internal/session/testing.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "context" diff --git a/internal/sessions/testing_test.go b/internal/session/testing_test.go similarity index 96% rename from internal/sessions/testing_test.go rename to internal/session/testing_test.go index ba99da75f3..85dcf8e3d6 100644 --- a/internal/sessions/testing_test.go +++ b/internal/session/testing_test.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "testing" diff --git a/internal/sessions/util.go b/internal/session/util.go similarity index 97% rename from internal/sessions/util.go rename to internal/session/util.go index 6c7d426d38..90503d5906 100644 --- a/internal/sessions/util.go +++ b/internal/session/util.go @@ -1,4 +1,4 @@ -package sessions +package session import ( "crypto/ed25519" @@ -12,7 +12,7 @@ import ( "golang.org/x/crypto/hkdf" ) -// DeriveED25519Key generates a key based on the scope's sessions DEK, the +// DeriveED25519Key generates a key based on the scope's session DEK, the // requesting user, and the generated job ID. func DeriveED25519Key(wrapper wrapping.Wrapper, userId, jobId string) (ed25519.PublicKey, ed25519.PrivateKey, error) { var aeadWrapper *aead.Wrapper