net/mosquitto/files/etc/init.d/mosquitto

   1 #!/bin/sh /etc/rc.common
   2 # Basic init script for mosquitto
   3 # April 2012, OpenWrt.org
   4 # Provides support for the luci-app-mosquitto package, if installed
   5
   6 START=80
   7 USE_PROCD=1
   8 TCONF=/tmp/mosquitto.generated.conf
   9
  10 # Usage: append_if cfg uci_name output_name
  11 # add a config line of the form "output_name <value>"
  12 # if the "uci_name" was found.
  13 # output_name defaults to uci_name if not specified.
  14 append_if() {
  15     local cfg="$1"
  16     local uci_name="$2"
  17     local out_name="$3"
  18     if [ -z "$out_name" ]; then
  19         out_name=$uci_name
  20     fi
  21     config_get val $cfg $uci_name
  22     if [ -n "$val" ]; then
  23         echo "$out_name $val" >> $TCONF
  24     fi
  25 }
  26
  27 # mosquitto uses true/false, uci uses 1/0
  28 # note that this is not shell truthy, but equality with 1!
  29 append_bool() {
  30     if [ $2 -eq 1 ]; then
  31         echo "$1 true" >> $TCONF
  32     else
  33         echo "$1 false" >> $TCONF
  34     fi
  35 }
  36
  37 # as per append_if, but gets the value as a uci bool, not raw
  38 append_optional_bool() {
  39     local cfg="$1"
  40     local uci_name="$2"
  41     local out_name="$3"
  42     config_get val $cfg $uci_name
  43     if [ -n "$val" ]; then
  44         config_get_bool real $cfg $uci_name
  45         append_bool $out_name $real
  46     fi
  47 }
  48
  49
  50 convert_mosq_general() {
  51         local cfg="$1"
  52         config_get destinations "$1" log_dest
  53         for dest in $destinations; do
  54                 echo "log_dest $dest" >> $TCONF
  55         done
  56
  57         config_get_bool no_remote "$1" no_remote_access 0
  58         if [ "$no_remote" -eq 1 ]; then
  59                 echo "bind_address 127.0.0.1" >> $TCONF
  60         fi
  61
  62         config_get port "$1" port 1883
  63         echo "port $port" >> $TCONF
  64         append_if "$1" protocol
  65         append_if "$1" max_inflight_messages
  66         append_if "$1" max_queued_messages
  67 }
  68
  69 convert_persistence() {
  70         local cfg="$1"
  71
  72         append_if "$cfg" client_expiration persistent_client_expiration
  73         append_if "$cfg" autosave_interval
  74         append_optional_bool "$cfg" autosave_on_changes autosave_on_changes
  75         append_optional_bool "$cfg" persistence persistence
  76         append_if "$cfg" file persistence_file
  77         config_get loc "$cfg" location
  78         if [ -n "$loc" ]; then
  79                 [ -d "$loc" ] || mkdir -p "$loc";
  80                 echo "persistence_location $loc" >> $TCONF
  81         fi
  82 }
  83
  84 add_listener() {
  85     echo "" >> $TCONF
  86     config_get port "$1" port
  87     if [ -z "$port" ]; then
  88         echo "Ignoring listener section without port"
  89         return
  90     fi
  91     config_get_bool no_remote "$1" no_remote_access 0
  92     if [ "$no_remote" -eq 1 ]; then
  93         echo "listener $port 127.0.0.1" >> $TCONF
  94     else
  95         echo "listener $port" >> $TCONF
  96     fi
  97
  98     append_if "$1" protocol
  99 }
 100
 101 add_topic() {
 102     echo "topic $1" >> $TCONF
 103 }
 104
 105 add_bridge() {
 106     config_get conn "$1" connection
 107     config_get addr "$1" address
 108     if [ -z "$conn" -o -z "$addr" ]; then
 109         echo "Ignoring bridge section, misisng connection/address"
 110         return
 111     fi
 112     echo "" >> $TCONF
 113     echo "# Bridge connection from UCI section" >> $TCONF
 114     append_if "$1" connection
 115     append_if "$1" address
 116
 117     config_list_foreach "$1" topic add_topic
 118     append_optional_bool "$1" cleansession cleansession
 119     append_optional_bool "$1" try_private try_private
 120
 121     append_if "$1" clientid
 122     append_if "$1" identity bridge_identity
 123     append_if "$1" psk bridge_psk
 124     append_if "$1" tls_version bridge_tls_version
 125 }
 126
 127
 128 convert_uci() {
 129         rm -rf $TCONF
 130         echo "Generating mosquitto config file in $TCONF"
 131         echo "# mosquitto.conf file generated from UCI config." >>$TCONF
 132         # Don't include a timestamp, it makes md5sum compares fail
 133
 134         config_load mosquitto
 135         config_foreach convert_mosq_general "mosquitto"
 136         config_foreach convert_persistence "persistence"
 137         config_foreach add_listener "listener"
 138         config_foreach add_bridge "bridge"
 139 }
 140
 141 start_service_real() {
 142         local cfg="$1"
 143         local use_uci write_pid
 144         config_get use_uci "$cfg" use_uci
 145         if [ "$use_uci" -eq 1 ]; then
 146                 CONF=$TCONF
 147                 convert_uci
 148         else
 149                 CONF=/etc/mosquitto/mosquitto.conf
 150         fi
 151         config_get write_pid "$cfg" write_pid 0
 152
 153         procd_open_instance
 154         procd_set_param command mosquitto
 155         procd_append_param command -c $CONF
 156         # Makes /etc/init.d/mosquitto reload work if you edit the final file.
 157         procd_set_param file $CONF
 158         [ "$write_pid" -eq 1 ] && procd_set_param pidfile /var/run/mosquitto.pid
 159         procd_close_instance
 160 }
 161
 162 start_service() {
 163         config_load mosquitto
 164         config_foreach start_service_real owrt
 165 }
 166
 167 service_triggers() {
 168         # Makes "reload_config" work
 169         procd_add_reload_trigger "mosquitto"
 170 }