Function newSessionWaitCommand

internal/cli/session.go:438–480

(deps commandDeps)

}

func newSessionWaitCommand(deps commandDeps) *cobra.Command {
	return &cobra.Command{
		Use:   "wait <id>",
		Short: "Block until a session stops",
		Example: `  # Block until a session emits its stopped event
  agh session wait sess_1234`,
		Args: exactOneNonBlankArg(),
		RunE: func(cmd *cobra.Command, args []string) error {
			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}

			info, err := client.GetSession(cmd.Context(), args[0])
			if err != nil {
				return err
			}
			if info.State != session.StateStopped {
				err = client.StreamSessionEvents(
					cmd.Context(),
					args[0],
					SessionEventQuery{},
					"",
					func(event SSEEvent) error {
						if event.Event == session.EventTypeSessionStopped {
							return errStopSSE
						}
						return nil
					},
				)
				if err != nil && !errors.Is(err, errStopSSE) {
					return err
				}
				info, err = client.GetSession(cmd.Context(), args[0])
				if err != nil {
					return err
				}
			}

			return writeCommandOutput(cmd, sessionBundle(info, deps.now))
		},
	}
}

func newSessionPromptCommand(deps commandDeps) *cobra.Command {
	var (