services: Add RabbitMQ.rabbitmq

* gnu/services/message-broker.scm: New file.
* gnu/services/message-broker.scm: New file.
* gnu/local.mk: Add entries for new files.

3 files changed, 202 insertions, 0 deletions

diff --git a/gnu/local.mk b/gnu/local.mk
index 7d9e95917d..d032084292 100644
--- a/gnu/local.mk
+++ b/gnu/local.mk
@@ -544,6 +544,7 @@ GNU_SYSTEM_MODULES =				\
   %D%/services/virtualization.scm		\
   %D%/services/mail.scm				\
   %D%/services/mcron.scm			\
+  %D%/services/message-broker.scm			\
   %D%/services/messaging.scm			\
   %D%/services/monitoring.scm			\
   %D%/services/networking.scm			\
@@ -609,6 +610,7 @@ GNU_SYSTEM_MODULES =				\
   %D%/tests/install.scm				\
   %D%/tests/ldap.scm				\
   %D%/tests/mail.scm				\
+  %D%/tests/message-broker.scm			\
   %D%/tests/messaging.scm			\
   %D%/tests/networking.scm			\
   %D%/tests/reconfigure.scm			\
diff --git a/gnu/services/message-broker.scm b/gnu/services/message-broker.scm
new file mode 100644
index 0000000000..6b6831bf81
--- /dev/null
+++ b/gnu/services/message-broker.scm
@@ -0,0 +1,114 @@
+;;; GNU Guix --- Functional package management for GNU
+;;; Copyright © 2018 Christopher Baines <mail@cbaines.net>
+;;;
+;;; This file is part of GNU Guix.
+;;;
+;;; GNU Guix 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.
+;;;
+;;; GNU Guix 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 GNU Guix.  If not, see <http://www.gnu.org/licenses/>.
+
+(define-module (gnu services message-broker)
+  #:use-module (gnu services)
+  #:use-module (gnu services shepherd)
+  #:use-module (gnu system shadow)
+  #:use-module (gnu packages admin)
+  #:use-module ((gnu packages base) #:select (glibc-utf8-locales))
+  #:use-module (gnu packages rabbitmq)
+  #:use-module (guix modules)
+  #:use-module (guix records)
+  #:use-module (guix gexp)
+  #:use-module (ice-9 match)
+  #:export (<rabbitmq-configuration>
+            rabbitmq-configuration
+            rabbitmq-configuration?
+            rabbitmq-configuration-rabbitmq
+            rabbitmq-configuration-locale
+            rabbitmq-configuration-interfaces
+            rabbitmq-configuration-tcp-port
+            rabbitmq-configuration-udp-port
+            rabbitmq-configuration-additional-options
+
+            rabbitmq-service-type))
+
+
+;;;
+;;; RabbitMQ
+;;;
+
+(define-record-type* <rabbitmq-configuration>
+  rabbitmq-configuration make-rabbitmq-configuration
+  rabbitmq-configuration?
+  (rabbitmq           rabbitmq-configuration-rabbitmq ;<package>
+                      (default rabbitmq))
+  (locale             rabbitmq-configuration-rabbitmq
+                      (default "en_US.utf8"))
+  (interfaces         rabbitmq-configuration-interfaces
+                      (default '("0.0.0.0")))
+  (tcp-port           rabbitmq-configuration-tcp-port
+                      (default 11211))
+  (udp-port           rabbitmq-configuration-udp-port
+                      (default 11211))
+  (additional-options rabbitmq-configuration-additional-options
+                      (default '())))
+
+(define %rabbitmq-accounts
+  (list (user-group (name "rabbitmq") (system? #t))
+        (user-account
+         (name "rabbitmq")
+         (group "rabbitmq")
+         (system? #t)
+         (comment "Rabbitmq server user")
+         (home-directory "/var/empty")
+         (shell (file-append shadow "/sbin/nologin")))))
+
+(define rabbitmq-activation
+  #~(begin
+      (use-modules (guix build utils))
+      (let ((user (getpwnam "rabbitmq")))
+        (mkdir-p "/var/run/rabbitmq")
+        (chown "/var/run/rabbitmq"
+               (passwd:uid user) (passwd:gid user)))))
+
+(define rabbitmq-shepherd-service
+  (match-lambda
+    (($ <rabbitmq-configuration> rabbitmq locale interfaces tcp-port udp-port
+                                 additional-options)
+     (with-imported-modules (source-module-closure
+                             '((gnu build shepherd)))
+       (list (shepherd-service
+              (provision '(rabbitmq))
+              (documentation "Run the Rabbitmq daemon.")
+              (requirement '(user-processes loopback))
+              (modules '((gnu build shepherd)))
+              (start #~(make-forkexec-constructor
+                        `(#$(file-append rabbitmq "/sbin/rabbitmq-server"))
+                        #:pid-file "/var/run/rabbitmq/pid"
+                        #:environment-variables
+                        `("RABBITMQ_PID_FILE=/var/run/rabbitmq/pid"
+                          "HOME=/var/empty"
+                          ;; Elixir, the language used by RabbitMQ requires a
+                          ;; UTF8 locale to function properly
+                          ,(string-append "GUIX_LOCPATH="
+                                          #$glibc-utf8-locales "/lib/locale")
+                          ,#$(string-append "LC_ALL=" locale))))
+              (stop #~(make-kill-destructor))))))))
+
+(define rabbitmq-service-type
+  (service-type (name 'rabbitmq)
+                (extensions
+                 (list (service-extension shepherd-root-service-type
+                                          rabbitmq-shepherd-service)
+                       (service-extension activation-service-type
+                                          (const rabbitmq-activation))
+                       (service-extension account-service-type
+                                          (const %rabbitmq-accounts))))
+                (default-value (rabbitmq-configuration))))
diff --git a/gnu/tests/message-broker.scm b/gnu/tests/message-broker.scm
new file mode 100644
index 0000000000..f2f5590818
--- /dev/null
+++ b/gnu/tests/message-broker.scm
@@ -0,0 +1,86 @@
+;;; GNU Guix --- Functional package management for GNU
+;;; Copyright © 2017 Christopher Baines <mail@cbaines.net>
+;;;
+;;; This file is part of GNU Guix.
+;;;
+;;; GNU Guix 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.
+;;;
+;;; GNU Guix 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 GNU Guix.  If not, see <http://www.gnu.org/licenses/>.
+
+(define-module (gnu tests message-broker)
+  #:use-module (gnu tests)
+  #:use-module (gnu system)
+  #:use-module (gnu system file-systems)
+  #:use-module (gnu system shadow)
+  #:use-module (gnu system vm)
+  #:use-module (gnu services)
+  #:use-module (gnu services message-broker)
+  #:use-module (gnu services networking)
+  #:use-module (guix gexp)
+  #:use-module (guix store)
+  #:export (%test-rabbitmq))
+
+(define %rabbitmq-os
+  (simple-operating-system
+   (dhcp-client-service)
+   (service rabbitmq-service-type)))
+
+(define* (run-rabbitmq-test #:optional (port 11211))
+  "Run tests in %RABBITMQ-OS, forwarding PORT."
+  (define os
+    (marionette-operating-system
+     %rabbitmq-os
+     #:imported-modules '((gnu services herd)
+                          (guix combinators))))
+
+  (define vm
+    (virtual-machine
+     (operating-system os)
+     (port-forwardings `((11211 . ,port)))))
+
+  (define test
+    (with-imported-modules '((gnu build marionette))
+      #~(begin
+          (use-modules (srfi srfi-11) (srfi srfi-64)
+                       (gnu build marionette)
+                       (ice-9 rdelim))
+
+          (define marionette
+            (make-marionette (list #$vm)))
+
+          (mkdir #$output)
+          (chdir #$output)
+
+          (test-begin "rabbitmq")
+
+          ;; Wait for rabbitmq to be up and running.
+          (test-assert "service running"
+            (marionette-eval
+             '(begin
+                (use-modules (gnu services herd))
+                (match (start-service 'rabbitmq)
+                  (#f #f)
+                  (('service response-parts ...)
+                   (match (assq-ref response-parts 'running)
+                     ((pid) (number? pid))))))
+             marionette))
+
+          (test-end)
+          (exit (= (test-runner-fail-count (test-runner-current)) 0)))))
+
+  (gexp->derivation "rabbitmq-test" test))
+
+(define %test-rabbitmq
+  (system-test
+   (name "rabbitmq")
+   (description "Connect to a running RABBITMQ server.")
+   (value (run-rabbitmq-test))))