List sessions CLI reports correct target id and status (#511)
* Including some missing session fields and improving reporting of sessions of CLI.
This commit is contained in:
1 parent
9bd6045c46
commit
d1d94c19c8
4 files changed
+14
-2
No files matched your search
@@ -33,7 +33,9 @@ func generateSessionTableOutput(in *sessions.Session) string {
|
||||
m := map[string]interface{}{
|
||||
"Status": state.Status,
|
||||
"Start Time": state.StartTime.Local().Format(time.RFC1123),
|
||||
"End Time": state.EndTime.Local().Format(time.RFC1123),
|
||||
}
|
||||
if !state.EndTime.IsZero() {
|
||||
m["End Time"] = state.EndTime.Local().Format(time.RFC1123)
|
||||
}
|
||||
statesMaps = append(statesMaps, m)
|
||||
}
|
||||
|
||||
@@ -170,11 +170,12 @@ func (c *Command) Run(args []string) int {
|
||||
}
|
||||
output = append(output,
|
||||
fmt.Sprintf(" ID: %s", t.Id),
|
||||
fmt.Sprintf(" Status: %s", t.Status),
|
||||
fmt.Sprintf(" Created Time: %s", t.CreatedTime.Local().Format(time.RFC3339)),
|
||||
fmt.Sprintf(" Expiration Time: %s", t.ExpirationTime.Local().Format(time.RFC3339)),
|
||||
fmt.Sprintf(" Updated Time: %s", t.UpdatedTime.Local().Format(time.RFC3339)),
|
||||
fmt.Sprintf(" User ID: %s", t.UserId),
|
||||
fmt.Sprintf(" Target ID: %s", t.UserId),
|
||||
fmt.Sprintf(" Target ID: %s", t.TargetId),
|
||||
)
|
||||
}
|
||||
c.UI.Output(base.WrapForHelpText(output))
|
||||
|
||||
@@ -12,6 +12,7 @@ import (
|
||||
"github.com/hashicorp/boundary/internal/servers/controller/common"
|
||||
"github.com/hashicorp/boundary/internal/servers/controller/handlers"
|
||||
"github.com/hashicorp/boundary/internal/session"
|
||||
"github.com/hashicorp/boundary/internal/target"
|
||||
"github.com/hashicorp/boundary/internal/types/action"
|
||||
"github.com/hashicorp/boundary/internal/types/resource"
|
||||
"github.com/hashicorp/boundary/internal/types/scope"
|
||||
@@ -192,6 +193,8 @@ func toProto(in *session.Session) *pb.Session {
|
||||
HostId: in.HostId,
|
||||
HostSetId: in.HostSetId,
|
||||
AuthTokenId: in.AuthTokenId,
|
||||
Endpoint: in.Endpoint,
|
||||
Type: target.SubtypeFromId(in.TargetId).String(),
|
||||
// TODO: Provide the ServerType and the ServerId when that information becomes relevant in the API.
|
||||
|
||||
CreatedTime: in.CreateTime.GetTimestamp(),
|
||||
|
||||
@@ -67,6 +67,7 @@ func TestGetSession(t *testing.T) {
|
||||
Id: sess.GetPublicId(),
|
||||
ScopeId: p.GetPublicId(),
|
||||
AuthTokenId: at.GetPublicId(),
|
||||
Endpoint: sess.Endpoint,
|
||||
UserId: at.GetIamUserId(),
|
||||
TargetId: sess.TargetId,
|
||||
HostSetId: sess.HostSetId,
|
||||
@@ -79,6 +80,7 @@ func TestGetSession(t *testing.T) {
|
||||
Scope: &scopes.ScopeInfo{Id: p.GetPublicId(), Type: scope.Project.String()},
|
||||
States: []*pb.SessionState{{Status: session.StatusPending.String(), StartTime: sess.CreateTime.GetTimestamp()}},
|
||||
Certificate: sess.Certificate,
|
||||
Type: target.TcpSubType.String(),
|
||||
}
|
||||
|
||||
cases := []struct {
|
||||
@@ -183,6 +185,7 @@ func TestList(t *testing.T) {
|
||||
AuthTokenId: at.GetPublicId(),
|
||||
UserId: at.GetIamUserId(),
|
||||
TargetId: sess.TargetId,
|
||||
Endpoint: sess.Endpoint,
|
||||
HostSetId: sess.HostSetId,
|
||||
HostId: sess.HostId,
|
||||
Version: sess.Version,
|
||||
@@ -193,6 +196,7 @@ func TestList(t *testing.T) {
|
||||
Status: status,
|
||||
States: states,
|
||||
Certificate: sess.Certificate,
|
||||
Type: target.TcpSubType.String(),
|
||||
})
|
||||
}
|
||||
|
||||
@@ -297,11 +301,13 @@ func TestCancel(t *testing.T) {
|
||||
HostSetId: sess.HostSetId,
|
||||
HostId: sess.HostId,
|
||||
Version: sess.Version,
|
||||
Endpoint: sess.Endpoint,
|
||||
CreatedTime: sess.CreateTime.GetTimestamp(),
|
||||
ExpirationTime: sess.ExpirationTime.GetTimestamp(),
|
||||
Scope: &scopes.ScopeInfo{Id: p.GetPublicId(), Type: scope.Project.String()},
|
||||
Status: session.StatusCanceling.String(),
|
||||
Certificate: sess.Certificate,
|
||||
Type: target.TcpSubType.String(),
|
||||
}
|
||||
|
||||
version := wireSess.GetVersion()
|
||||
|
||||
Reference in new issue
Block a user