mirror of
https://github.com/vale981/emacs-ipython-notebook
synced 2025-03-06 01:21:38 -05:00
c488bfb020
Somehow lost ability to handle iopub responses when debugger session is running. Also try to set prompt in comint buffer to match debugger being called (ipdb vs. pdb).
140 lines
5.5 KiB
EmacsLisp
140 lines
5.5 KiB
EmacsLisp
;;; ein-ipdb.el --- Support ipython debugger (ipdb)
|
|
|
|
;; Copyright (C) 2015 - John Miller
|
|
|
|
;; Author: John Miller <millejoh at mac.com>
|
|
|
|
;; This file is NOT part of GNU Emacs.
|
|
|
|
;; ein-ipdb.el is free software: you can redistribute it and/or modify
|
|
;; it under the terms of the GNU General Public License as published by
|
|
;; the Free Software Foundation, either version 3 of the License, or
|
|
;; (at your option) any later version.
|
|
|
|
;; ein-ipdb.el is distributed in the hope that it will be useful,
|
|
;; but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
;; MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
;; GNU General Public License for more details.
|
|
|
|
;; You should have received a copy of the GNU General Public License
|
|
;; along with ein-kernel.el. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
;;; Commentary:
|
|
|
|
;;
|
|
|
|
;;; Code:
|
|
|
|
(defvar *ein:ipdb-sessions* (make-hash-table))
|
|
(defconst *ein:ipdb-prompt* "(Pdb) ")
|
|
|
|
(make-variable-buffer-local 'ein:ipdb-buffer-active-kernel)
|
|
(make-variable-buffer-local 'ein:ipdb-buffer-prompt)
|
|
|
|
(defstruct ein:$ipdb-session
|
|
buffer
|
|
kernel
|
|
current-payload)
|
|
|
|
(defun ein:find-or-create-ipdb-session (kernel)
|
|
(ein:aif (gethash (ein:$kernel-kernel-id kernel) *ein:ipdb-sessions*)
|
|
it
|
|
(let ((db-session (make-ein:$ipdb-session
|
|
:kernel kernel
|
|
:current-payload "Debugger started.")))
|
|
(setf (gethash (ein:$kernel-kernel-id kernel) *ein:ipdb-sessions*) db-session)
|
|
db-session)))
|
|
|
|
(defun ein:pdb-session-id (session)
|
|
(ein:$kernel-kernel-id (ein:$ipdb-session-kernel session)))
|
|
|
|
(defun ein:run-ipdb-session (kernel prompt)
|
|
(unless (gethash (ein:$kernel-kernel-id kernel) *ein:ipdb-sessions*)
|
|
(let ((pdb-session (ein:find-or-create-ipdb-session kernel)))
|
|
(setf (ein:$kernel-stdin-activep kernel) t)
|
|
(ein:prepare-ipdb-session pdb-session prompt))))
|
|
|
|
(defun ein:prepare-ipdb-session (session prompt)
|
|
(with-current-buffer (setf (ein:$ipdb-session-buffer session)
|
|
(get-buffer-create (format "*ipdb: %s*" (ein:pdb-session-id session))))
|
|
(setq ein:ipdb-buffer-active-kernel (ein:pdb-session-id session))
|
|
(setq ein:ipdb-buffer-prompt prompt)
|
|
(add-hook 'kill-buffer-hook 'ein:ipdb-on-stop)
|
|
(ein:ipdb-mode)
|
|
(setq comint-prompt-regexp (concat "^" (regexp-quote ein:ipdb-buffer-prompt)))
|
|
(setq comint-input-sender 'ein:ipdb-input-sender)
|
|
|
|
(unless (comint-check-proc (current-buffer))
|
|
;; Was cat, but on non-Unix platforms that might not exist, so
|
|
;; use hexl instead, which is part of the Emacs distribution.
|
|
(let ((fake-proc
|
|
(condition-case nil
|
|
(start-process "ein:ipdb" (current-buffer) "hexl")
|
|
(file-error (start-process "ein:ipdb" (current-buffer) "cat")))))
|
|
(set-process-query-on-exit-flag fake-proc nil)
|
|
(insert "#ipdb#\n")
|
|
(set-marker
|
|
(process-mark fake-proc) (point))
|
|
(comint-output-filter fake-proc ein:ipdb-buffer-prompt)))
|
|
(switch-to-buffer (ein:$ipdb-session-buffer session))))
|
|
|
|
(defun ein:ipdb-on-stop ()
|
|
(when ein:ipdb-buffer-active-kernel
|
|
(let* ((kernel (ein:$ipdb-session-kernel
|
|
(gethash ein:ipdb-buffer-active-kernel *ein:ipdb-sessions*)))
|
|
(msg (ein:kernel--get-msg kernel "input_reply" (list :value "q"))))
|
|
(ein:websocket-send-stdin-channel kernel msg)
|
|
(setf (ein:$kernel-stdin-activep kernel) nil)
|
|
(remhash ein:ipdb-buffer-active-kernel *ein:ipdb-sessions*))))
|
|
|
|
(defun ein:stop-ipdb-session (db-session)
|
|
(let ((buffer (ein:$ipdb-session-buffer db-session)))
|
|
(kill-buffer buffer)))
|
|
|
|
(defun ein:ipdb--handle-iopub-reply (kernel packet)
|
|
(destructuring-bind
|
|
(&key content metadata parent_header header &allow-other-keys)
|
|
(ein:json-read-from-string packet)
|
|
(let ((msg-type (plist-get header :msg_type)))
|
|
(if (string-equal msg-type "stream")
|
|
(let* ((session (ein:find-or-create-ipdb-session kernel))
|
|
(buf (ein:$ipdb-session-buffer session))
|
|
(text (plist-get content :text)))
|
|
(with-current-buffer buf
|
|
(setf (ein:$ipdb-session-current-payload session) text)
|
|
(let ((buffer-read-only nil))
|
|
(save-excursion
|
|
(if (re-search-backward
|
|
(concat "#ipdb#")
|
|
nil t)
|
|
(progn
|
|
(delete-region (point) (line-end-position))
|
|
;(insert "\n")
|
|
(ein:cell-append-text text)))))))))))
|
|
|
|
;;; Now try with comint
|
|
|
|
|
|
(defun ein:ipdb-input-sender (proc input)
|
|
(with-current-buffer (process-buffer proc)
|
|
(assert (not (null ein:ipdb-buffer-active-kernel)) t "No active kernel associated with this buffer %s.")
|
|
(let* ((session (gethash ein:ipdb-buffer-active-kernel *ein:ipdb-sessions*))
|
|
(buffer-read-only nil)
|
|
(kernel (ein:$ipdb-session-kernel session))
|
|
(content (list :value input))
|
|
(msg (ein:kernel--get-msg kernel "input_reply" content)))
|
|
(if (or (string= input "q")
|
|
(string= input "quit"))
|
|
(ein:stop-ipdb-session session)
|
|
(progn
|
|
(comint-output-filter proc (format "#ipdb#\n"))
|
|
(ein:websocket-send-stdin-channel kernel msg)
|
|
(comint-output-filter proc ein:ipdb-buffer-prompt))))))
|
|
|
|
(define-derived-mode
|
|
ein:ipdb-mode comint-mode "EIN:IPDB"
|
|
"Run an EIN debug session."
|
|
;:syntax-table python-mode-syntax-table
|
|
)
|
|
|
|
(provide 'ein-ipdb)
|