mirror of
https://github.com/wavetermdev/backup.git
synced 2026-08-05 13:57:07 -07:00
remote bugfix and filter remotes on client side
This commit is contained in:
@@ -931,32 +931,12 @@ func HistoryCommand(ctx context.Context, pk *scpacket.FeCommandPacketType) (ssto
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var filteredItems []*sstore.HistoryItemType
|
||||
for _, hitem := range hitems {
|
||||
if hitem.Remote == ids.Remote.RemotePtr || hitem.IsMetaCmd {
|
||||
filteredItems = append(filteredItems, hitem)
|
||||
}
|
||||
}
|
||||
var buf bytes.Buffer
|
||||
if len(filteredItems) == 0 {
|
||||
buf.WriteString("(no history)")
|
||||
} else {
|
||||
for idx := len(filteredItems) - 1; idx >= 0; idx-- {
|
||||
hitem := filteredItems[idx]
|
||||
hnumStr := hitem.HistoryNum
|
||||
if hitem.IsMetaCmd {
|
||||
hnumStr = "*" + hnumStr
|
||||
}
|
||||
hstr := fmt.Sprintf("%6s %s\n", hnumStr, hitem.CmdStr)
|
||||
buf.WriteString(hstr)
|
||||
}
|
||||
}
|
||||
show := !resolveBool(pk.Kwargs["noshow"], false)
|
||||
update := &sstore.ModelUpdate{}
|
||||
update.History = &sstore.HistoryInfoType{
|
||||
SessionId: ids.SessionId,
|
||||
WindowId: ids.WindowId,
|
||||
Items: filteredItems,
|
||||
Items: hitems,
|
||||
Show: show,
|
||||
}
|
||||
return update, nil
|
||||
|
||||
@@ -511,6 +511,9 @@ func RunCommand(ctx context.Context, cmdId string, remotePtr sstore.RemotePtrTyp
|
||||
return nil, fmt.Errorf("sending run packet to remote: %w", err)
|
||||
}
|
||||
rtnPk := msh.ServerProc.Output.WaitForResponse(ctx, runPacket.ReqId)
|
||||
if rtnPk == nil {
|
||||
return nil, ctx.Err()
|
||||
}
|
||||
startPk, ok := rtnPk.(*packet.CmdStartPacketType)
|
||||
if !ok {
|
||||
respPk, ok := rtnPk.(*packet.ResponsePacketType)
|
||||
|
||||
Reference in New Issue
Block a user