src/middleware-db.lisp

(in-package :murja.middleware.db)

(defvar *automatic-tests-on?* nil)

(defun db-config () 
  (list :db (or (sb-ext:posix-getenv "MURJA_DB")
		"blogdb")
	:username (or (sb-ext:posix-getenv "MURJA_DB_USER")
		      "blogadmin")
	:password (or (sb-ext:posix-getenv "MURJA_DB_PASSWD")
		      "blog")
	:host (or (sb-ext:posix-getenv "MURJA_DB_HOST")
		  "localhost")
	:port (let ((port-str
		      ;; return env-var if it exists (GHA, connecting straight to the automatic test db container)
		      (or (sb-ext:posix-getenv "MURJA_DB_PORT")
			  ;; return "2345", where autotest-db is on localhost (proxied to automatic-test-db:5432)
			  (and *automatic-tests-on?* "2345"))))
		 (if port-str
		     (parse-integer port-str)
		     ;; or else return the basic postgresql 5432 port
		     5432))))

(defun connect-murjadb-toplevel ()
  (destructuring-bind (&key db username password host port) (db-config)
    (postmodern:connect-toplevel db username password host :port port)))

;; (connect-murjadb-toplevel)

(defmacro with-db (&rest body)
  `(destructuring-bind (&key db username password host port) (db-config)
     (with-connection (list db username password host :port port)
       ,@body)))

(defun @transaction (next)
  (with-db
      (handler-bind ((cl-postgres:database-socket-error
		       (lambda (c)
			 (log:error "Socket error from db: ~a~%" c)
			 (setf (hunchentoot:return-code*) 500)
			 (return-from @transaction "Internal Server Error")))
		     (cl-postgres:database-error
		       (lambda (c)
			 (log:error "Error from db: ~a~%" c)
			 (setf (hunchentoot:return-code*) 500)
			 (return-from @transaction "Internal Server Error"))))
	(with-transaction (:repeatable-read-rw)
	  (funcall next)))))

(defun @db (next)
  (with-db
      (handler-bind ((cl-postgres:database-socket-error
		       (lambda (c)
			 (log:error "Socket error from db: ~a~%" c)
			 (setf (hunchentoot:return-code*) 500)
			 (return-from @db "Internal Server Error")))
		     (cl-postgres:database-error
		       (lambda (c)
			 (log:error "Error from db: ~a~%" c)
			 (setf (hunchentoot:return-code*) 500)
			 (return-from @db "Internal Server Error"))))
	(funcall next))))