ownerer · November 18, 2025 15:10 · akkharawat1150 · Mar 3, 2025 · ownerer · Mar 4, 2025
diff --git a/readme.md b/readme.md
diff --git a/add.sh b/add.sh
 #!/bin/sh

 # anything added here gets executed as the final step of the /etc/rc.local file
 # before it gets called rc.local will make sure this script is executable, yay!

 chmod +x /persistent/script/loop.sh
 chmod +x /persistent/script/process_texts.sh
 /persistent/script/loop.sh /persistent/script/process_texts.sh 10 &
diff --git a/loop.sh b/loop.sh
 #!/bin/sh

 script_to_run=$1
 wait_seconds=$2

 if [ -z "$script_to_run" ] || [ -z "$wait_seconds" ]; then
  echo "Usage: $0 <script_to_execute> <seconds_to_wait>"
  exit 1
 fi

 while true; do
  $script_to_run
  sleep "$wait_seconds"
 done
diff --git a/process_texts.sh b/process_texts.sh
 #!/bin/sh

 HTTP_ENDPOINT="<ADD YOUR WEBHOOK URL HERE>"

 # Paths
 SQLITE3="sqlite3"
 DB_PATH="/persistent/var/lib/asterisk/db/MyPBX.sqlite"
 TEMP_DB="/persistent/tmp/temp_sms_db.sqlite"
 COMPRESSED_DB="/persistent/tmp/compressed_sms_db.gz"
 PROCESSED_IDS="/persistent/tmp/processed_ids.txt"

 # Create a new temporary SQLite database and copy relevant data into it
 $SQLITE3 "$TEMP_DB" <<EOF
 -- Create the table schema
 CREATE TABLE smsrecv (
  id VARCHAR(64) PRIMARY KEY,
  sender TEXT,
  smsc TEXT,
  portid TEXT,
  content TEXT,
  recvtime TEXT,
  hasread TEXT
 );

 -- Attach the original database with a different alias
 ATTACH DATABASE '$DB_PATH' AS original_db;

 -- Insert the rows with hasread = 'No' from the original database into the temp DB
 INSERT INTO smsrecv (id, sender, smsc, portid, content, recvtime, hasread)
 SELECT id, sender, smsc, portid, content, recvtime, hasread
 FROM original_db.smsrecv
 WHERE hasread = 'No';
 EOF

 # Check if there are unread messages in the temporary database
 UNREAD_MESSAGES=$($SQLITE3 "$TEMP_DB" "SELECT COUNT(*) FROM smsrecv")
 if [ "$UNREAD_MESSAGES" -eq 0 ]; then
  echo "No unread messages found. Sending empty payload."
  QUERY_STRING="payload="
 else
  # Get the ids of the rows that were inserted into the temp DB
  $SQLITE3 "$TEMP_DB" "SELECT id FROM smsrecv" > "$PROCESSED_IDS"
  
  # Compress the temporary SQLite database
  gzip -c "$TEMP_DB" > "$COMPRESSED_DB"
  
  # Base64 encode the compressed database
  BASE64_PAYLOAD=$(base64 "$COMPRESSED_DB")

  # Remove newlines and spaces from the Base64-encoded string
  CLEAN_BASE64_PAYLOAD=$(echo "$BASE64_PAYLOAD" | tr -d '\n' | tr -d ' ')

  # URL-encode the Base64-encoded payload to make it safe for HTTP transmission
  URL_ENCODED_PAYLOAD=$(echo "$CLEAN_BASE64_PAYLOAD" | sed 's/ /%20/g' | sed 's/+/%2B/g' | sed 's/\//%2F/g' | sed 's/=/%3D/g')
  
  # Construct the GET request query string with the URL-encoded Base64-encoded gzipped data
  QUERY_STRING="payload=$URL_ENCODED_PAYLOAD"
 fi

 # Send the data as a GET request
 wget "${HTTP_ENDPOINT}?${QUERY_STRING}" -O /dev/null

 # Check if the GET request was successful
 if [ $? -eq 0 ]; then
  echo "GET request successful."

  if [ "$UNREAD_MESSAGES" -gt 0 ]; then
    echo "Updating rows..."
    # Update only rows that were processed (those in the temporary database)
    while read -r ID; do
      $SQLITE3 "$DB_PATH" <<EOF
 UPDATE smsrecv
 SET hasread = 'Yes'
 WHERE id = '$ID';
 EOF
    done < "$PROCESSED_IDS"

    echo "Rows updated."
  else
    echo "No rows to update."
  fi
 else
  echo "GET request failed."
 fi

 # Clean up temporary files
 rm -f "$TEMP_DB" "$COMPRESSED_DB" "$PROCESSED_IDS"

 exit 0
	#!/bin/sh

	# anything added here gets executed as the final step of the /etc/rc.local file
	# before it gets called rc.local will make sure this script is executable, yay!

	chmod +x /persistent/script/loop.sh
	chmod +x /persistent/script/process_texts.sh
	/persistent/script/loop.sh /persistent/script/process_texts.sh 10 &
	#!/bin/sh

	script_to_run=$1
	wait_seconds=$2

	if [ -z "$script_to_run" ] \|\| [ -z "$wait_seconds" ]; then
	echo "Usage: $0 <script_to_execute> <seconds_to_wait>"
	exit 1
	fi

	while true; do
	$script_to_run
	sleep "$wait_seconds"
	done
	#!/bin/sh

	HTTP_ENDPOINT="<ADD YOUR WEBHOOK URL HERE>"

	# Paths
	SQLITE3="sqlite3"
	DB_PATH="/persistent/var/lib/asterisk/db/MyPBX.sqlite"
	TEMP_DB="/persistent/tmp/temp_sms_db.sqlite"
	COMPRESSED_DB="/persistent/tmp/compressed_sms_db.gz"
	PROCESSED_IDS="/persistent/tmp/processed_ids.txt"

	# Create a new temporary SQLite database and copy relevant data into it
	$SQLITE3 "$TEMP_DB" <<EOF
	-- Create the table schema
	CREATE TABLE smsrecv (
	id VARCHAR(64) PRIMARY KEY,
	sender TEXT,
	smsc TEXT,
	portid TEXT,
	content TEXT,
	recvtime TEXT,
	hasread TEXT
	);

	-- Attach the original database with a different alias
	ATTACH DATABASE '$DB_PATH' AS original_db;

	-- Insert the rows with hasread = 'No' from the original database into the temp DB
	INSERT INTO smsrecv (id, sender, smsc, portid, content, recvtime, hasread)
	SELECT id, sender, smsc, portid, content, recvtime, hasread
	FROM original_db.smsrecv
	WHERE hasread = 'No';
	EOF

	# Check if there are unread messages in the temporary database
	UNREAD_MESSAGES=$($SQLITE3 "$TEMP_DB" "SELECT COUNT(*) FROM smsrecv")
	if [ "$UNREAD_MESSAGES" -eq 0 ]; then
	echo "No unread messages found. Sending empty payload."
	QUERY_STRING="payload="
	else
	# Get the ids of the rows that were inserted into the temp DB
	$SQLITE3 "$TEMP_DB" "SELECT id FROM smsrecv" > "$PROCESSED_IDS"

	# Compress the temporary SQLite database
	gzip -c "$TEMP_DB" > "$COMPRESSED_DB"

	# Base64 encode the compressed database
	BASE64_PAYLOAD=$(base64 "$COMPRESSED_DB")

	# Remove newlines and spaces from the Base64-encoded string
	CLEAN_BASE64_PAYLOAD=$(echo "$BASE64_PAYLOAD" \| tr -d '\n' \| tr -d ' ')

	# URL-encode the Base64-encoded payload to make it safe for HTTP transmission
	URL_ENCODED_PAYLOAD=$(echo "$CLEAN_BASE64_PAYLOAD" \| sed 's/ /%20/g' \| sed 's/+/%2B/g' \| sed 's/\//%2F/g' \| sed 's/=/%3D/g')

	# Construct the GET request query string with the URL-encoded Base64-encoded gzipped data
	QUERY_STRING="payload=$URL_ENCODED_PAYLOAD"
	fi

	# Send the data as a GET request
	wget "${HTTP_ENDPOINT}?${QUERY_STRING}" -O /dev/null

	# Check if the GET request was successful
	if [ $? -eq 0 ]; then
	echo "GET request successful."

	if [ "$UNREAD_MESSAGES" -gt 0 ]; then
	echo "Updating rows..."
	# Update only rows that were processed (those in the temporary database)
	while read -r ID; do
	$SQLITE3 "$DB_PATH" <<EOF
	UPDATE smsrecv
	SET hasread = 'Yes'
	WHERE id = '$ID';
	EOF
	done < "$PROCESSED_IDS"

	echo "Rows updated."
	else
	echo "No rows to update."
	fi
	else
	echo "GET request failed."
	fi

	# Clean up temporary files
	rm -f "$TEMP_DB" "$COMPRESSED_DB" "$PROCESSED_IDS"

	exit 0