io.arc

(use arc values)

(ail-code (racket-require (racket-prefix-in racket- scheme/tcp)))
(ail-code (racket-require (racket-prefix-in racket- scheme/port)))

(defrule type (racket-true (racket-tcp-listener? x))
  'socket)

(def open-socket (port)
  (racket-tcp-listen port 50 (ail-code #t)))

(mac w/socket (var port . body)
  `(open-close ,var open-socket ,port ,@body))

(defrule close-port (isa port 'socket)
  (racket-tcp-close port))

(def limited-input-port (in maxbytes)
  (racket-make-limited-input-port in maxbytes (ail-code #t)))

(def client-ip (port)
  (values (us them) (racket-tcp-addresses port) them))

(def socket-accept (s)
  (values (in out) (racket-tcp-accept s)
    (list (limited-input-port in 100000)
          out
          (client-ip out))))

(mac rmodule (language . body)
  (w/uniq module
    (eval `(ail-code (racket-module ,module ,language ,@body))) 
    (racket-module-ref `',module)))

(def setuid (uid)
  ((inline
    ((rmodule scheme
       (require (lib "foreign.ss"))
       (unsafe!)
       (provide setuid)
       (define setuid (get-ffi-obj 'setuid #f (_fun _int -> _int))))
     'setuid))
   uid))

(def dir (name)
  (ar-toarc (racket-map racket-path->string (racket-directory-list name))))

(def rmfile (name)
  (racket-delete-file name)
  nil)

(def dead (thd)
  (aracket-true (racket-thread-dead? thd)))