Skip to content

Commit

Permalink
chg: remove user kick and user ban commands
Browse files Browse the repository at this point in the history
This reverts commit 51d8669

This feature doesn't work
  • Loading branch information
libvoid committed Sep 20, 2023
1 parent 9d44c0f commit b1ba647
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 68 deletions.
53 changes: 0 additions & 53 deletions pkg/bastion/shell.go
Original file line number Diff line number Diff line change
Expand Up @@ -1621,59 +1621,6 @@ GLOBAL OPTIONS:
enc.SetIndent("", " ")
return enc.Encode(users)
},
}, {
Name: "kick",
Usage: "Kills all active sessions for user(s)",
ArgsUsage: "USER...",
Action: func(c *cli.Context) error {
if c.NArg() < 1 {
return cli.ShowSubcommandHelp(c)
}

if err := myself.CheckRoles([]string{"admin"}); err != nil {
return err
}

var users []*dbmodels.User
if err := dbmodels.UsersByIdentifiers(db, c.Args()).Find(&users).Error; err != nil {
return err
}

for _, user := range users {
if err := db.Model(&dbmodels.Session{}).Where(&dbmodels.Session{User: user, Status: string(dbmodels.SessionStatusActive)}).Update("status", "closed").Error; err != nil {
return err
}
}
return nil
},
}, {
Name: "ban",
Usage: "Kills all active sessions for user(s), and wipes all his ssh keys",
ArgsUsage: "USER...",
Action: func(c *cli.Context) error {
if c.NArg() < 1 {
return cli.ShowSubcommandHelp(c)
}

if err := myself.CheckRoles([]string{"admin"}); err != nil {
return err
}

var users []*dbmodels.User
if err := dbmodels.UsersByIdentifiers(db, c.Args()).Find(&users).Error; err != nil {
return err
}

for _, user := range users {
if err := db.Where("user_id = ?", user.ID).Delete(&dbmodels.UserKey{}).Error; err != nil {
return err
}
if err := db.Model(&dbmodels.Session{}).Where(&dbmodels.Session{User: user, Status: string(dbmodels.SessionStatusActive)}).Update("status", "closed").Error; err != nil {
return err
}
}
return nil
},
}, {
Name: "invite",
ArgsUsage: "<email>",
Expand Down
15 changes: 0 additions & 15 deletions pkg/bastion/ssh.go
Original file line number Diff line number Diff line change
Expand Up @@ -169,21 +169,6 @@ func ChannelHandler(srv *ssh.Server, conn *gossh.ServerConn, newChan gossh.NewCh
_ = ch.Close()
return
}
go func(_ *gossh.ServerConn, sessionID uint) {
for {
sess := dbmodels.Session{
Model: gorm.Model{ID: sessionID},
Status: string(dbmodels.SessionStatusActive),
}

if sess.Status != string(dbmodels.SessionStatusActive) {
log.Println("Session", sessionID, "should be closed : closing connection")
conn.Close()
break
}
time.Sleep(60 * time.Second)
}
}(conn, sess.ID)
go func() {
err = multiChannelHandler(conn, newChan, ctx, sessionConfigs, sess.ID)
if err != nil {
Expand Down

0 comments on commit b1ba647

Please sign in to comment.