busunit management scripts

* wip

busunit/scripts/get_net_ids.sh

@@ -0,0 +1,127 @@
+#!/bin/bash
+#
+# Copyright (c) 2019 Clementine Computing LLC.
+# 
+# This file is part of PopuFare.
+# 
+# PopuFare is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+# 
+# PopuFare 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 Affero General Public License for more details.
+# 
+# You should have received a copy of the GNU Affero General Public License
+# along with PopuFare.  If not, see <https://www.gnu.org/licenses/>.
+#
+
+export BASEDIR="/home/bus"
+
+. $BASEDIR/bin/common_values.sh
+
+SERIAL_PORT="/dev/ttyGPRS"
+PORT_CONFIG="115200 -raw"
+REPLY_TIMEOUT="3"
+RAW_DROPFILE="/tmp/raw_net_ids"
+COOKED_DROPFILE="$NETWORK_ID_DROPFILE"
+
+function collect_modem_results
+{
+	regex="$1"
+	dest="$2"
+	
+	while read line; do
+		match="`echo "$line" | egrep "$regex"`"
+		echo RX: $line >> $RAW_DROPFILE
+		echo MATCH: $match >> $RAW_DROPFILE
+		if [ -n "$match" ]; then
+			echo DONE. >> $RAW_DROPFILE
+			echo "$match" >> $dest
+			exit 0;
+		fi
+	done
+}
+
+function query_modem
+{
+	query_command="$1"
+	reply_regex="$2"
+	
+
+	if [ -z "$query_command" ]; then
+		query_command="AT"
+	fi
+	
+	if [ -z "$reply_regex" ]; then
+		reply_regex='.*'
+	fi
+
+	dest_name="/tmp/$$.`date +%s`.tmp"
+	echo -n > $dest_name
+
+	(collect_modem_results "$reply_regex" $dest_name < $SERIAL_PORT) 2>&1 > /dev/null &
+	serial_coprocess="$!"
+
+	sleep 2
+	
+	echo TX: $query_command >> $RAW_DROPFILE
+	echo -e "$query_command\r" > $SERIAL_PORT
+
+	(sleep $REPLY_TIMEOUT; echo TIMEOUT >> $RAW_DROPFILE; kill $serial_coprocess) 2>&1 > /dev/null &
+	watchdog_coprocess="$!"
+
+	wait $serial_coprocess 2>&1 > /dev/null
+	echo "`cat $dest_name`"
+	rm $dest_name
+	kill $watchdog_coprocess 2> /dev/null
+	
+}
+
+function query_mac_address
+{
+	iface=$1
+	
+	if [ -z "$iface" ]; then
+		iface="eth0"
+	fi
+	
+	#/sbin/ifconfig $iface | head -n 1 | egrep '([0-9a-fA-F][0-9a-fA-F]:?)+' | tr -s ' ' | cut -d' ' -f5
+  /sbin/ifconfig $iface | grep -P '^ *ether ' | head -n 1 | egrep -o '([0-9a-fA-F][0-9a-fA-F]:?)+'  | head -n1
+}
+
+
+function setup_modem
+{
+	stty -F $SERIAL_PORT $PORT_CONFIG
+	query_modem 'AT' 2>&1 > /dev/null
+	sleep 2
+	echo -n "+++" > $SERIAL_PORT
+	sleep 2
+	query_modem 'ATZ' 'OK' 2>&1 > /dev/null
+}
+
+setup_modem
+query_modem 'AT+CMEE=1'	'OK' 2>&1 > /dev/null
+
+maxtries=5
+tries=0
+
+while !(echo $imei | egrep '[0-9]+') && [ $tries -lt $maxtries ]; do
+	imei="`query_modem 'AT+CGSN' '[0-9]+|.*ERROR.*' 2> /dev/null`"
+	tries=$((tries + 1))
+done
+
+tries=0
+
+while !(echo $imsi | egrep '[0-9]+') && [ $tries -lt $maxtries ]; do
+	imsi="`query_modem 'AT+CIMI' '[0-9]+|.*ERROR.*' 2> /dev/null`"
+	tries=$((tries + 1))
+done
+
+echo "IMEI = $imei" > $COOKED_DROPFILE
+echo "IMSI = $imsi" >> $COOKED_DROPFILE
+echo "ETH0 = `query_mac_address eth0 2> /dev/null`"  >> $COOKED_DROPFILE
+

busunit/scripts/init_bus.sh

@@ -0,0 +1,41 @@
+#!/bin/sh
+#
+# Copyright (c) 2019 Clementine Computing LLC.
+# 
+# This file is part of PopuFare.
+# 
+# PopuFare is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+# 
+# PopuFare 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 Affero General Public License for more details.
+# 
+# You should have received a copy of the GNU Affero General Public License
+# along with PopuFare.  If not, see <https://www.gnu.org/licenses/>.
+#
+
+export BASEDIR="/home/bus/bin"
+export USEGPRS=0
+
+# Ask for our identifying network numbers
+#
+echo -n "Obtaining network hardware IDs..."
+$BASEDIR/bin/get_net_ids.sh 2>&1 > /dev/null
+echo " Done."
+
+# Start the network monitor / GPRS dialer
+#
+if [[ "$USEGPRS" == 1 ]] ; then
+	/etc/ppp/ppp-dialer.sh &
+else
+  $BASEDIR/bin/setup_test_tunnel.sh &
+fi
+
+# Start the client monitor (which then goes and starts everything else...)
+#
+$BASEDIR/bin/update_loop.sh &
+

busunit/scripts/update_loop.sh

@@ -0,0 +1,192 @@
+#!/bin/sh
+#
+# Copyright (c) 2019 Clementine Computing LLC.
+# 
+# This file is part of PopuFare.
+# 
+# PopuFare is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+# 
+# PopuFare 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 Affero General Public License for more details.
+# 
+# You should have received a copy of the GNU Affero General Public License
+# along with PopuFare.  If not, see <https://www.gnu.org/licenses/>.
+#
+
+export BASEDIR="/home/bus"
+
+. $BASEDIR/bin/common_values.sh
+
+# Do this at startup, and again if we've gotten a dropfile flag telling us to do so...
+#
+generate_ssh_targets
+
+supervisor_pidfile="/tmp/client_supervisor.pid"
+supervisor_args="$BASEDIR/bin/ipc_server $BASEDIR/bin/billdb $BASEDIR/bin/piu_minder $BASEDIR/bin/diu_minder $BASEDIR/bin/passdb $BASEDIR/bin/avls $BASEDIR/bin/paddlemgr"
+
+eqnum_file="$EQUIP_NUM_FILE"
+checksum_path="$CHECKSUM_AND_VERSION_PATH"
+
+function spawn_supervisor
+{
+  # If we have a client supervisor binary to run
+  #
+  if [ -f $BASEDIR/bin/client_supervisor ]; then
+    
+    # If we also have a config file for the UI
+    #
+    if [ -f $BASEDIR/config/menu.xml ]; then
+      rm $supervisor_pidfile
+
+      # then run the whole shebang...
+      #
+      $BASEDIR/bin/client_supervisor $supervisor_args &
+      echo $! > $supervisor_pidfile
+      echo Spawned client_supervisor. PID = `cat $supervisor_pidfile`
+
+    # if we DON'T have one, we still need to download a config before we're viable...
+    #
+    else
+      rm -f config.tgz.*
+      $BASEDIR/bin/showmessage -b "Downloading Config..."
+    fi
+  
+  # If we DON'T have one, we are either a new system or just badly broken so...
+  #
+  else
+
+    # Go and remove all package records so we can start fresh...
+    #
+    rm -f  $BASEDIR/config/*.tgz.*
+    $BASEDIR/bin/showmessage -b "Wait (~ 15 min)"
+
+  fi
+}
+
+function check_update
+{
+  if [ ! -f $TUNNEL_DROPFILE ]; then return 1; fi;
+  (  
+
+    if [ -f "$eqnum_file" ]; then
+      echo -en "`cat $eqnum_file`"; 
+    else
+      echo -en "0"
+    fi
+    
+    for file in `ls $checksum_path/*.checksum`; do 
+      echo -en "\t`echo $file | sed -r 's/^.*\/(.*)\.checksum$/\1/'`=`cat $file`"; 
+    done; 
+    echo;
+  ) | nc localhost $UPDATE_DAEMON_PORT  
+}
+
+
+while true; do
+  
+  #See if we need to spawn our client supervisor
+  if [ ! -f $supervisor_pidfile ]; then
+    spawn_supervisor;
+    sleep $SLEEP_AFTER_SPAWN;
+  else
+    if [ ! -d /proc/`cat $supervisor_pidfile` ]; then
+      spawn_supervisor;    
+      sleep $SLEEP_AFTER_SPAWN;
+    fi
+  fi
+
+  if [ -f $TUNNEL_DROPFILE ]; then echo "Checking for updates..."; fi
+
+  check_update | 
+    (
+      while read client_file checksum file_size server_path file_version; do
+        
+        # If we've been asked to abort this update, do so before we start downloading if possible
+        #
+        if [ -f $UPDATE_ABORT_DROPFILE ]; then
+          echo "Aborting update on request!";
+          # generate new SSH target from dropfiles
+          #
+          generate_ssh_targets
+          # clear the flag
+          #
+          rm -f $UPDATE_ABORT_DROPFILE
+          # break out of the loop
+          #
+          break;
+        fi
+
+        # Generate dropfiles to tell the rest of the system what we're up to
+        #
+        echo "$file_size" > /tmp/$client_file.expected_size
+        echo "$checksum" > /tmp/$client_file.expected_md5
+        echo "$file_version" > /tmp/$client_file.expected_version
+
+        echo "Downloading $client_file version $file_version to /tmp ($file_size bytes)"
+
+        # Initiate a secure download to fetch this package down from the server
+        #
+        scp -i $SSH_IDENTITY $SCP_OPTIONS -P $SSH_PORT $SSH_TARGET:$server_path /tmp/$client_file
+      
+        # If we've already downloaded when we get the abort message
+        #
+        if [ -f $UPDATE_ABORT_DROPFILE ]; then
+          echo "Aborting update on request!";
+          
+          # Clean up after ourselves
+          #
+          rm -f /tmp/$client_file.expected_size /tmp/$client_file.expected_md5
+          rm -f  /tmp/$client_file.expected_version /install.sh /tmp/install.sh /tmp/$client_file
+
+          # generate new SSH target from dropfiles
+          #
+          generate_ssh_targets
+
+          # clear the flag
+          #
+          rm -f $UPDATE_ABORT_DROPFILE
+
+          # break out of the loop
+          #
+          break;
+        fi
+
+        # If we indeed _got_ a file to begin with...  
+        #
+        if [ -f /tmp/$client_file ]; then
+          
+          # Start a subshell in which we...
+          #
+          (
+            # set our pwd to /tmp/ where we downloaded our package
+            #
+            cd /tmp/;
+
+            #    Execute our package installer script which will check the package checksum
+            # and assuming that matches, it will extract the installer script embedded in the
+            # package and execute it.
+            #
+            $BASEDIR/bin/apply_update.sh $client_file $checksum $file_size $server_path $file_version
+          );
+        fi
+      
+        # Clean up after ourselves (removing our during-update dropfiles)  
+        #
+        rm -f /tmp/$client_file.expected_size /tmp/$client_file.expected_md5
+
+        # as well as the update file itself
+        #
+        rm -f  /tmp/$client_file.expected_version /install.sh /tmp/install.sh /tmp/$client_file
+
+      done
+    )
+
+  echo "Sleeping..."  
+  sleep $SLEEP_BETWEEN_UPDATES;
+done
+