guile-ssh/tests/popen.scm

;;; popen.scm -- Remote pipes testing.

;; Copyright (C) 2015, 2016 Artyom V. Poptsov <poptsov.artyom@gmail.com>
;;
;; This file is a part of Guile-SSH.
;;
;; Guile-SSH 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.
;;
;; Guile-SSH 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 Guile-SSH.  If not, see <http://www.gnu.org/licenses/>.

(add-to-load-path (getenv "abs_top_srcdir"))

(use-modules (srfi srfi-64)
             (ice-9 rdelim)
             (tests common)
             (ssh channel)
             (ssh session)
             (ssh auth)
             (ssh log)
             (ssh popen))

(set-log-verbosity! 'functions)

(test-begin-with-log "popen")

;;; Helper procedures.

(define (call-with-connected-session/popen proc)
  "Make a session for a channel test."
  (call-with-connected-session
   (lambda (session)
     (authenticate-server session)
     (userauth-none! session)
     (proc session))))

(define (response=? channel string)
  "Read a line from a CHANNEL, check if the line is equal to a STRING."
  (string=? (read-line channel) string))

(define (input-only? port)
  (and (input-port? port)
       (not (output-port? port))))

(define (output-only? port)
  (and (output-port? port)
       (not (input-port? port))))

;;;

(test-assert-with-log "open-remote-pipe, OPEN_READ"
  (run-client-test
   (lambda (server)
     (start-server/exec server (lambda () #t)))
   (lambda ()
     (sleep 1)
     (call-with-connected-session/shell
      (lambda (session)
        (let ((channel (open-remote-pipe session "ping" OPEN_READ)))
          (and (input-only? channel)
               (poll channel (lambda args (response=? channel "pong")))))))))) 

(test-assert-with-log "open-remote-pipe, OPEN_PTY_READ"
  (run-client-test
   (lambda (server)
     (start-server/exec server (const #t)))
   (lambda ()
     (call-with-connected-session/shell
      (lambda (session)
        (let* ((OPEN_PTY_READ (string-append OPEN_PTY OPEN_READ))
               (channel       (open-remote-pipe session "ping" OPEN_PTY_READ)))
          (format-log/scm 'nolog "open-remote-pipe, OPEN_PTY_READ" "channel: ~A" channel)
          (and (input-only? channel)
               (poll channel (lambda args (response=? channel "pong"))))))))))

(test-assert-with-log "open-remote-pipe, OPEN_BOTH"
  (run-client-test
   (lambda (server)
     (start-server/exec server (const #t)))
   (lambda ()
     (call-with-connected-session/shell
      (lambda (session)
        (let ((channel (open-remote-pipe session "ping" OPEN_BOTH)))
          (format-log/scm 'nolog "open-remote-pipe, OPEN_BOTH" "channel: ~A" channel)
          (and (input-port? channel)
               (output-port? channel)
               (poll channel (lambda args (response=? channel "pong"))))))))))

(test-assert-with-log "open-remote-pipe*"
  (run-client-test
   (lambda (server)
     (start-server/exec server (const #t)))
   (lambda ()
     (call-with-connected-session/shell
      (lambda (session)
        (let ((channel (open-remote-pipe* session OPEN_READ "ping")))
          (format-log/scm 'nolog "open-remote-pipe*" "channel: ~A" channel)
          (and (input-only? channel)
               (poll channel (lambda args (response=? channel "pong"))))))))))

(test-assert-with-log "open-remote-input-pipe"
  (run-client-test
   (lambda (server)
     (start-server/exec server (const #t)))
   (lambda ()
     (call-with-connected-session/shell
      (lambda (session)
        (let ((channel (open-remote-input-pipe session "ping")))
          (format-log/scm 'nolog "open-remote-input-pipe" "channel: ~A" channel)
          (and (input-only? channel)
               (poll channel (lambda args (response=? channel "pong"))))))))))

(test-assert-with-log "open-remote-output-pipe"
  (run-client-test
   (lambda (server)
     (start-server/exec server (const #t)))
   (lambda ()
     (call-with-connected-session/shell
      (lambda (session)
        (let ((channel (open-remote-output-pipe session "ping")))
          (format-log/scm 'nolog "open-remote-output-pipe"  "channel: ~A" channel)
          (output-only? channel)))))))

(test-end "popen")

(exit (= (test-runner-fail-count (test-runner-current)) 0))

;;; popen.scm ends here.