(in-package 3harder)

(defvar *posts* (list))

(when (probe-file #p"posts.txt")
 (let ((*read-eval* nil))
   (with-open-file (in #p"posts.txt")
     (loop for post = (read in nil nil)
           while post
           do (push post *posts*)))))

(defun serve ()
 (let ((socket (usocket:socket-listen "127.0.0.1" 12345)) (connection nil))
   (loop
     (ignore-errors
         (unwind-protect
              (setf connection (usocket:socket-accept socket :element-type 'character))
           (usocket:wait-for-input connection)
           (let* ((*read-eval* nil) (stream (usocket:socket-stream connection)))
             (loop initially (format *terminal-io* "Connected at ~d~%" (get-universal-time))
                   for item-type = (ignore-errors (read-char stream))
                   for alist = (ignore-errors (read stream))
                   for message = (ignore-errors (read stream))
                   do (princ (list item-type alist message))
                   do (terpri)
                   do (assert (or (null alist) (consp alist)))
                   do (unless (or (null message))
                        (with-open-file (s #p"posts.txt" :direction :output :if-exists :append :if-does-not-exist :create)
                          (prin1 (cons alist message) s) (terpri s)))
                   do (if (null message)
                          (format stream "~{~s~%~}"
                                  (mapcan
                                   (lambda (post) (if (subsetp alist (car post) :test 'equalp) (list post) nil)) *posts*))
                          (format stream "~{~s~%~}~%"
                                  (mapcan
                                   (lambda (post) (if (subsetp alist (car post) :test 'equalp) (list post) nil))
                                   (push (cons alist message) *posts*))))
                   do (return))

             (format *terminal-io* "finished message")
             (terpri stream)
             (force-output stream) (sleep 1))
           (progn (format *terminal-io* "Connection closing at ~D~%" (get-universal-time))
                  (usocket:socket-close connection)))))))

(serve)

You are viewing proxied material from sdf.org. The copyright of proxied material belongs to its original authors. Any comments or complaints in relation to proxied material should be directed to the original authors of the content concerned. Please see the disclaimer for more details.