(defpackage :slacker.postmodern-store
  (:use :cl :alexandria :serapeum :fw.lu)
  (:export #:postmodern-store))
(in-package :slacker.postmodern-store)

(defclass postmodern-store ()
  ((%connection :reader connection)
   (%connection-spec :reader connection-spec :initarg :postgres-connection-spec)))

(defmethod shared-initialize :after ((instance postmodern-store) slot-names &key postgres-connection-spec)
  (setf (slot-value instance '%connection)
	(apply 'postmodern:connect postgres-connection-spec)))

(defun save-slack-message (value)
  (pomo:query "INSERT INTO slack_messages_raw (message) VALUES ($1) RETURNING id,slack_ts,message_text;"
              value :rows))

(defmethod slacker:handle-message :before
    (type (event-pump postmodern-store) ts channel message)
  (declare (ignore type ts channel))
  (let ((pomo:*database* (connection event-pump)))
    (save-slack-message
     (with-output-to-string (s)
       (yason:encode message s))))
  (values))