2024-06-25 05:50:52 -07:00
import logging
import random
import time
2024-07-04 20:46:22 -07:00
from meshtastic import BROADCAST_NUM
2024-06-25 05:50:52 -07:00
from db_operations import (
add_bulletin , add_mail , delete_mail ,
get_bulletin_content , get_bulletins ,
get_mail , get_mail_content ,
add_channel , get_channels
)
from utils import (
get_node_id_from_num , get_node_info ,
get_node_short_name , send_message ,
update_user_state
)
2024-07-09 08:57:38 -07:00
def handle_help_command ( sender_id , interface , menu_name = None ) :
if menu_name :
update_user_state ( sender_id , { ' command ' : ' MENU ' , ' menu ' : menu_name , ' step ' : 1 } )
if menu_name == ' bbs ' :
response = " 📰BBS Menu📰 \n [M]ail \n [B]ulletins \n [C]hannel Dir \n E[X]IT "
elif menu_name == ' utilities ' :
response = " 🛠️ Utilities Menu🛠️ \n [S]tats \n [F]ortune \n [W]all of Shame \n E[X]IT "
else :
update_user_state ( sender_id , { ' command ' : ' MAIN_MENU ' , ' step ' : 1 } ) # Reset to main menu state
response = " 💾TC² BBS💾 \n [Q]uick Commands \n [B]BS \n [U]tilities \n E[X]IT "
send_message ( response , sender_id , interface )
2024-06-25 05:50:52 -07:00
def get_node_name ( node_id , interface ) :
node_info = interface . nodes . get ( node_id )
if node_info :
return node_info [ ' user ' ] [ ' longName ' ]
return f " Node { node_id } "
def handle_mail_command ( sender_id , interface ) :
2024-07-09 08:57:38 -07:00
response = " ✉️ Mail Menu✉️ \n What would you like to do with mail? \n [R]ead [S]end E[X]IT "
2024-06-25 05:50:52 -07:00
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 1 } )
2024-07-09 08:57:38 -07:00
2024-06-25 05:50:52 -07:00
def handle_bulletin_command ( sender_id , interface ) :
2024-07-09 08:57:38 -07:00
response = " 📰Bulletin Menu📰 \n Which board would you like to enter? \n [G]eneral [I]nfo [N]ews [U]rgent "
2024-06-25 05:50:52 -07:00
send_message ( response , sender_id , interface )
2024-07-09 08:57:38 -07:00
update_user_state ( sender_id , { ' command ' : ' BULLETIN_MENU ' , ' step ' : 1 } )
2024-06-25 05:50:52 -07:00
def handle_exit_command ( sender_id , interface ) :
send_message ( " Type ' HELP ' for a list of commands. " , sender_id , interface )
update_user_state ( sender_id , None )
def handle_stats_command ( sender_id , interface ) :
2024-07-09 08:57:38 -07:00
response = " 📊Stats Menu📊 \n What stats would you like to view? \n [N]odes [H]ardware [R]oles E[X]IT "
2024-06-25 05:50:52 -07:00
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' STATS ' , ' step ' : 1 } )
def handle_fortune_command ( sender_id , interface ) :
try :
with open ( ' fortunes.txt ' , ' r ' ) as file :
fortunes = file . readlines ( )
if not fortunes :
send_message ( " No fortunes available. " , sender_id , interface )
return
fortune = random . choice ( fortunes ) . strip ( )
decorated_fortune = f " 🔮 { fortune } 🔮 "
send_message ( decorated_fortune , sender_id , interface )
except Exception as e :
send_message ( f " Error generating fortune: { e } " , sender_id , interface )
2024-07-09 08:57:38 -07:00
def handle_stats_steps ( sender_id , message , step , interface ) :
2024-06-25 05:50:52 -07:00
if step == 1 :
2024-07-09 08:57:38 -07:00
choice = message . lower ( )
if choice == ' x ' :
2024-06-25 05:50:52 -07:00
handle_help_command ( sender_id , interface )
return
2024-07-09 08:57:38 -07:00
elif choice == ' n ' :
current_time = int ( time . time ( ) )
timeframes = {
" All time " : None ,
" Last 24 hours " : 86400 ,
" Last 8 hours " : 28800 ,
" Last hour " : 3600
}
total_nodes_summary = [ ]
for period , seconds in timeframes . items ( ) :
if seconds is None :
total_nodes = len ( interface . nodes )
else :
time_limit = current_time - seconds
total_nodes = sum ( 1 for node in interface . nodes . values ( ) if node . get ( ' lastHeard ' , 0 ) > = time_limit )
total_nodes_summary . append ( f " - { period } : { total_nodes } " )
response = " Total nodes seen: \n " + " \n " . join ( total_nodes_summary )
2024-06-25 05:50:52 -07:00
send_message ( response , sender_id , interface )
2024-07-09 08:57:38 -07:00
handle_stats_command ( sender_id , interface )
elif choice == ' h ' :
2024-06-25 05:50:52 -07:00
hw_models = { }
for node in interface . nodes . values ( ) :
hw_model = node [ ' user ' ] . get ( ' hwModel ' , ' Unknown ' )
hw_models [ hw_model ] = hw_models . get ( hw_model , 0 ) + 1
response = " Hardware Models: \n " + " \n " . join ( [ f " { model } : { count } " for model , count in hw_models . items ( ) ] )
send_message ( response , sender_id , interface )
handle_stats_command ( sender_id , interface )
2024-07-09 08:57:38 -07:00
elif choice == ' r ' :
2024-06-25 05:50:52 -07:00
roles = { }
for node in interface . nodes . values ( ) :
role = node [ ' user ' ] . get ( ' role ' , ' Unknown ' )
roles [ role ] = roles . get ( role , 0 ) + 1
response = " Roles: \n " + " \n " . join ( [ f " { role } : { count } " for role , count in roles . items ( ) ] )
send_message ( response , sender_id , interface )
handle_stats_command ( sender_id , interface )
def handle_bb_steps ( sender_id , message , step , state , interface , bbs_nodes ) :
2024-06-29 16:33:51 -07:00
boards = { 0 : " General " , 1 : " Info " , 2 : " News " , 3 : " Urgent " }
2024-06-25 05:50:52 -07:00
if step == 1 :
2024-07-09 08:57:38 -07:00
if message . lower ( ) == ' e ' :
handle_help_command ( sender_id , interface , ' bbs ' )
2024-06-25 05:50:52 -07:00
return
2024-07-09 11:05:33 -07:00
board_name = boards [ int ( message ) ]
2024-07-09 08:57:38 -07:00
response = f " What would you like to do in the { board_name } board? \n [R]ead [P]ost "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' BULLETIN_ACTION ' , ' step ' : 2 , ' board ' : board_name } )
2024-06-25 05:50:52 -07:00
elif step == 2 :
2024-07-09 08:57:38 -07:00
board_name = state [ ' board ' ]
if message . lower ( ) == ' r ' :
2024-06-25 05:50:52 -07:00
bulletins = get_bulletins ( board_name )
2024-07-09 08:57:38 -07:00
if bulletins :
2024-06-25 05:50:52 -07:00
send_message ( f " Select a bulletin number to view from { board_name } : " , sender_id , interface )
for bulletin in bulletins :
send_message ( f " [ { bulletin [ 0 ] } ] { bulletin [ 1 ] } " , sender_id , interface )
2024-07-09 08:57:38 -07:00
update_user_state ( sender_id , { ' command ' : ' BULLETIN_READ ' , ' step ' : 3 , ' board ' : board_name } )
2024-06-25 05:50:52 -07:00
else :
send_message ( f " No bulletins in { board_name } . " , sender_id , interface )
2024-07-09 08:57:38 -07:00
handle_bb_steps ( sender_id , ' e ' , 1 , state , interface , bbs_nodes )
elif message . lower ( ) == ' p ' :
2024-07-09 11:05:33 -07:00
if board_name . lower ( ) == ' urgent ' :
node_id = get_node_id_from_num ( sender_id , interface )
allowed_nodes = interface . allowed_nodes
if allowed_nodes and node_id not in allowed_nodes :
send_message ( " You don ' t have permission to post to this board. " , sender_id , interface )
return
2024-06-25 05:50:52 -07:00
send_message ( " What is the subject of your bulletin? Keep it short. " , sender_id , interface )
2024-07-09 08:57:38 -07:00
update_user_state ( sender_id , { ' command ' : ' BULLETIN_POST ' , ' step ' : 4 , ' board ' : board_name } )
2024-06-25 05:50:52 -07:00
elif step == 3 :
bulletin_id = int ( message )
sender_short_name , date , subject , content , unique_id = get_bulletin_content ( bulletin_id )
send_message ( f " From: { sender_short_name } \n Date: { date } \n Subject: { subject } \n - - - - - - - \n { content } " , sender_id , interface )
board_name = state [ ' board ' ]
2024-07-09 08:57:38 -07:00
handle_bb_steps ( sender_id , ' e ' , 1 , state , interface , bbs_nodes )
2024-06-25 05:50:52 -07:00
elif step == 4 :
subject = message
send_message ( " Send the contents of your bulletin. Send a message with END when finished. " , sender_id , interface )
2024-07-09 08:57:38 -07:00
update_user_state ( sender_id , { ' command ' : ' BULLETIN_POST_CONTENT ' , ' step ' : 5 , ' board ' : state [ ' board ' ] , ' subject ' : subject , ' content ' : ' ' } )
2024-06-25 05:50:52 -07:00
elif step == 5 :
if message . lower ( ) == " end " :
board = state [ ' board ' ]
subject = state [ ' subject ' ]
content = state [ ' content ' ]
node_id = get_node_id_from_num ( sender_id , interface )
node_info = interface . nodes . get ( node_id )
if node_info is None :
send_message ( " Error: Unable to retrieve your node information. " , sender_id , interface )
update_user_state ( sender_id , None )
return
sender_short_name = node_info [ ' user ' ] . get ( ' shortName ' , f " Node { sender_id } " )
unique_id = add_bulletin ( board , sender_short_name , subject , content , bbs_nodes , interface )
send_message ( f " Your bulletin ' { subject } ' has been posted to { board } . \n (╯°□°)╯📄📌[ { board } ] " , sender_id , interface )
2024-07-09 08:57:38 -07:00
handle_bb_steps ( sender_id , ' e ' , 1 , state , interface , bbs_nodes )
2024-06-25 05:50:52 -07:00
else :
state [ ' content ' ] + = message + " \n "
update_user_state ( sender_id , state )
def handle_mail_steps ( sender_id , message , step , state , interface , bbs_nodes ) :
if step == 1 :
2024-07-09 08:57:38 -07:00
choice = message . lower ( )
if choice == ' r ' :
2024-06-25 05:50:52 -07:00
sender_node_id = get_node_id_from_num ( sender_id , interface )
mail = get_mail ( sender_node_id )
if mail :
send_message ( f " You have { len ( mail ) } mail messages. Select a message number to read: " , sender_id , interface )
for msg in mail :
2024-07-09 08:57:38 -07:00
send_message ( f " - { msg [ 0 ] } - \n Date: { msg [ 3 ] } \n From: { msg [ 1 ] } \n Subject: { msg [ 2 ] } " , sender_id , interface )
2024-06-25 05:50:52 -07:00
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 2 } )
else :
2024-07-09 08:57:38 -07:00
send_message ( " There are no messages in your mailbox.📭 " , sender_id , interface )
2024-06-25 05:50:52 -07:00
update_user_state ( sender_id , None )
2024-07-09 08:57:38 -07:00
elif choice == ' s ' :
2024-06-25 05:50:52 -07:00
send_message ( " What is the Short Name of the node you want to leave a message for? " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 3 } )
2024-07-09 08:57:38 -07:00
elif choice == ' x ' :
2024-06-25 05:50:52 -07:00
handle_help_command ( sender_id , interface )
elif step == 2 :
mail_id = int ( message )
2024-06-28 15:41:08 -07:00
try :
sender_node_id = get_node_id_from_num ( sender_id , interface )
sender , date , subject , content , unique_id = get_mail_content ( mail_id , sender_node_id )
send_message ( f " Date: { date } \n From: { sender } \n Subject: { subject } \n { content } " , sender_id , interface )
send_message ( " Would you like to delete this message now that you ' ve viewed it? Y/N " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 4 , ' mail_id ' : mail_id , ' unique_id ' : unique_id } )
except TypeError :
logging . info ( f " Node { sender_id } tried to access non-existent message " )
2024-07-09 08:57:38 -07:00
send_message ( " Mail not found " , sender_id , interface )
2024-06-28 15:41:08 -07:00
update_user_state ( sender_id , None )
2024-06-25 05:50:52 -07:00
elif step == 3 :
2024-07-04 08:42:29 -07:00
short_name = message . lower ( )
2024-06-25 05:50:52 -07:00
nodes = get_node_info ( interface , short_name )
if not nodes :
send_message ( " I ' m unable to find that node in my database. " , sender_id , interface )
handle_mail_command ( sender_id , interface )
elif len ( nodes ) == 1 :
recipient_id = nodes [ 0 ] [ ' num ' ]
recipient_name = get_node_name ( recipient_id , interface )
send_message ( f " What is the subject of your message to { recipient_name } ? \n Keep it short. " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 5 , ' recipient_id ' : recipient_id } )
else :
send_message ( " There are multiple nodes with that short name. Which one would you like to leave a message for? " , sender_id , interface )
for i , node in enumerate ( nodes ) :
send_message ( f " [ { i } ] { node [ ' longName ' ] } " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 6 , ' nodes ' : nodes } )
elif step == 4 :
if message . lower ( ) == " y " :
unique_id = state [ ' unique_id ' ]
2024-06-28 15:41:08 -07:00
sender_node_id = get_node_id_from_num ( sender_id , interface )
delete_mail ( unique_id , sender_node_id , bbs_nodes , interface )
2024-06-25 05:50:52 -07:00
send_message ( " The message has been deleted 🗑️ " , sender_id , interface )
else :
2024-07-09 08:57:38 -07:00
send_message ( " The message has been kept in your inbox.✉️ " , sender_id , interface )
2024-06-25 05:50:52 -07:00
update_user_state ( sender_id , None )
elif step == 5 :
subject = message
send_message ( " Send your message. You can send it in multiple messages if it ' s too long for one. \n Send a single message with END when you ' re done " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 7 , ' recipient_id ' : state [ ' recipient_id ' ] , ' subject ' : subject , ' content ' : ' ' } )
elif step == 6 :
selected_node_index = int ( message )
selected_node = state [ ' nodes ' ] [ selected_node_index ]
recipient_id = selected_node [ ' num ' ]
recipient_name = get_node_name ( recipient_id , interface )
send_message ( f " What is the subject of your message to { recipient_name } ? \n Keep it short. " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 5 , ' recipient_id ' : recipient_id } )
elif step == 7 :
if message . lower ( ) == " end " :
recipient_id = state [ ' recipient_id ' ]
subject = state [ ' subject ' ]
content = state [ ' content ' ]
recipient_name = get_node_name ( recipient_id , interface )
sender_short_name = get_node_short_name ( get_node_id_from_num ( sender_id , interface ) , interface )
unique_id = add_mail ( get_node_id_from_num ( sender_id , interface ) , sender_short_name , recipient_id , subject , content , bbs_nodes , interface )
send_message ( f " Mail has been posted to the mailbox of { recipient_name } . \n (╯°□°)╯📨📬 " , sender_id , interface )
2024-07-04 20:46:22 -07:00
notification_message = f " You have a new mail message from { sender_short_name } . Check your mailbox by responding to this message with CM. "
2024-06-25 05:50:52 -07:00
send_message ( notification_message , recipient_id , interface )
update_user_state ( sender_id , None )
update_user_state ( sender_id , { ' command ' : ' MAIL ' , ' step ' : 8 } )
else :
state [ ' content ' ] + = message + " \n "
update_user_state ( sender_id , state )
elif step == 8 :
if message . lower ( ) == " y " :
handle_mail_command ( sender_id , interface )
else :
send_message ( " Okay, feel free to send another command. " , sender_id , interface )
update_user_state ( sender_id , None )
2024-07-09 08:57:38 -07:00
2024-06-25 05:50:52 -07:00
def handle_wall_of_shame_command ( sender_id , interface ) :
response = " Devices with battery levels below 20 % : \n "
for node_id , node in interface . nodes . items ( ) :
metrics = node . get ( ' deviceMetrics ' , { } )
battery_level = metrics . get ( ' batteryLevel ' , 101 )
if battery_level < 20 :
long_name = node [ ' user ' ] [ ' longName ' ]
response + = f " { long_name } - Battery { battery_level } % \n "
if response == " Devices with battery levels below 20 % : \n " :
response = " No devices with battery levels below 20 % f ound. "
send_message ( response , sender_id , interface )
def handle_channel_directory_command ( sender_id , interface ) :
2024-07-09 08:57:38 -07:00
response = " 📚CHANNEL DIRECTORY📚 \n What would you like to do? \n [V]iew [P]ost E[X]IT "
2024-06-25 05:50:52 -07:00
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHANNEL_DIRECTORY ' , ' step ' : 1 } )
def handle_channel_directory_steps ( sender_id , message , step , state , interface ) :
if step == 1 :
2024-07-09 08:57:38 -07:00
choice = message . lower ( )
if choice == ' x ' :
2024-06-25 05:50:52 -07:00
handle_help_command ( sender_id , interface )
return
2024-07-09 08:57:38 -07:00
elif choice == ' v ' :
2024-06-25 05:50:52 -07:00
channels = get_channels ( )
if channels :
response = " Select a channel number to view: \n " + " \n " . join (
[ f " [ { i } ] { channel [ 0 ] } " for i , channel in enumerate ( channels ) ] )
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHANNEL_DIRECTORY ' , ' step ' : 2 } )
else :
send_message ( " No channels available in the directory. " , sender_id , interface )
handle_channel_directory_command ( sender_id , interface )
2024-07-09 08:57:38 -07:00
elif choice == ' p ' :
2024-06-25 05:50:52 -07:00
send_message ( " Name your channel for the directory: " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHANNEL_DIRECTORY ' , ' step ' : 3 } )
elif step == 2 :
channel_index = int ( message )
channels = get_channels ( )
if 0 < = channel_index < len ( channels ) :
channel_name , channel_url = channels [ channel_index ]
send_message ( f " Channel Name: { channel_name } \n Channel URL: \n { channel_url } " , sender_id , interface )
handle_channel_directory_command ( sender_id , interface )
elif step == 3 :
channel_name = message
send_message ( " Send a message with your channel URL: " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHANNEL_DIRECTORY ' , ' step ' : 4 , ' channel_name ' : channel_name } )
elif step == 4 :
channel_url = message
channel_name = state [ ' channel_name ' ]
add_channel ( channel_name , channel_url )
send_message ( f " Your channel ' { channel_name } ' has been added to the directory. " , sender_id , interface )
2024-06-29 16:33:51 -07:00
handle_channel_directory_command ( sender_id , interface )
2024-07-04 20:46:22 -07:00
def handle_send_mail_command ( sender_id , message , interface , bbs_nodes ) :
try :
2024-07-09 08:57:38 -07:00
parts = message . split ( " ,, " , 3 )
2024-07-04 20:46:22 -07:00
if len ( parts ) != 4 :
2024-07-09 08:57:38 -07:00
send_message ( " Send Mail Quick Command format: \n SM,, {short_name} ,, {subject} ,, {message} " , sender_id , interface )
2024-07-04 20:46:22 -07:00
return
_ , short_name , subject , content = parts
nodes = get_node_info ( interface , short_name . lower ( ) )
if not nodes :
send_message ( f " Node with short name ' { short_name } ' not found. " , sender_id , interface )
return
if len ( nodes ) > 1 :
send_message ( f " Multiple nodes with short name ' { short_name } ' found. Please be more specific. " , sender_id ,
interface )
return
recipient_id = nodes [ 0 ] [ ' num ' ]
recipient_name = get_node_name ( recipient_id , interface )
sender_short_name = get_node_short_name ( get_node_id_from_num ( sender_id , interface ) , interface )
unique_id = add_mail ( get_node_id_from_num ( sender_id , interface ) , sender_short_name , recipient_id , subject ,
content , bbs_nodes , interface )
send_message ( f " Mail has been sent to { recipient_name } . " , sender_id , interface )
2024-07-09 08:57:38 -07:00
notification_message = f " You have a new mail message from { sender_short_name } . Check your mailbox by responding to this message with CM. "
2024-07-04 20:46:22 -07:00
send_message ( notification_message , recipient_id , interface )
except Exception as e :
logging . error ( f " Error processing send mail command: { e } " )
send_message ( " Error processing send mail command. " , sender_id , interface )
def handle_check_mail_command ( sender_id , interface ) :
try :
sender_node_id = get_node_id_from_num ( sender_id , interface )
mail = get_mail ( sender_node_id )
if not mail :
send_message ( " You have no new messages. " , sender_id , interface )
return
response = " 📬 You have the following messages: \n "
for i , msg in enumerate ( mail ) :
2024-07-09 08:57:38 -07:00
response + = f " { i + 1 : 02d } . From: { msg [ 1 ] } , Subject: { msg [ 2 ] } \n "
2024-07-04 20:46:22 -07:00
response + = " \n Please reply with the number of the message you want to read. "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHECK_MAIL ' , ' step ' : 1 , ' mail ' : mail } )
except Exception as e :
logging . error ( f " Error processing check mail command: { e } " )
send_message ( " Error processing check mail command. " , sender_id , interface )
def handle_read_mail_command ( sender_id , message , state , interface ) :
try :
mail = state . get ( ' mail ' , [ ] )
message_number = int ( message ) - 1
if message_number < 0 or message_number > = len ( mail ) :
send_message ( " Invalid message number. Please try again. " , sender_id , interface )
return
mail_id = mail [ message_number ] [ 0 ]
sender_node_id = get_node_id_from_num ( sender_id , interface )
sender , date , subject , content , unique_id = get_mail_content ( mail_id , sender_node_id )
response = f " Date: { date } \n From: { sender } \n Subject: { subject } \n \n { content } "
send_message ( response , sender_id , interface )
send_message ( " Would you like to delete this message now that you ' ve read it? Y/N " , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHECK_MAIL ' , ' step ' : 2 , ' mail_id ' : mail_id , ' unique_id ' : unique_id } )
except ValueError :
send_message ( " Invalid input. Please enter a valid message number. " , sender_id , interface )
except Exception as e :
logging . error ( f " Error processing read mail command: { e } " )
send_message ( " Error processing read mail command. " , sender_id , interface )
def handle_delete_mail_confirmation ( sender_id , message , state , interface , bbs_nodes ) :
try :
choice = message . lower ( )
if choice == ' y ' :
unique_id = state [ ' unique_id ' ]
sender_node_id = get_node_id_from_num ( sender_id , interface )
delete_mail ( unique_id , sender_node_id , bbs_nodes , interface )
send_message ( " The message has been deleted 🗑️ " , sender_id , interface )
else :
send_message ( " The message has been kept in your inbox.✉️ " , sender_id , interface )
update_user_state ( sender_id , None )
except Exception as e :
logging . error ( f " Error processing delete mail confirmation: { e } " )
send_message ( " Error processing delete mail confirmation. " , sender_id , interface )
def handle_post_bulletin_command ( sender_id , message , interface , bbs_nodes ) :
try :
2024-07-09 08:57:38 -07:00
parts = message . split ( " ,, " , 3 )
2024-07-04 20:46:22 -07:00
if len ( parts ) != 4 :
2024-07-09 08:57:38 -07:00
send_message ( " Post Bulletin Quick Command format: \n PB,, {board_name} ,, {subject} ,, {content} " , sender_id , interface )
2024-07-04 20:46:22 -07:00
return
_ , board_name , subject , content = parts
sender_short_name = get_node_short_name ( get_node_id_from_num ( sender_id , interface ) , interface )
unique_id = add_bulletin ( board_name , sender_short_name , subject , content , bbs_nodes , interface )
send_message ( f " Your bulletin ' { subject } ' has been posted to { board_name } . " , sender_id , interface )
if board_name . lower ( ) == " urgent " :
notification_message = f " 💥NEW URGENT BULLETIN💥 \n From: { sender_short_name } \n Title: { subject } "
send_message ( notification_message , BROADCAST_NUM , interface )
except Exception as e :
logging . error ( f " Error processing post bulletin command: { e } " )
send_message ( " Error processing post bulletin command. " , sender_id , interface )
def handle_check_bulletin_command ( sender_id , message , interface ) :
try :
2024-07-09 08:57:38 -07:00
parts = message . split ( " ,, " , 2 )
2024-07-04 20:46:22 -07:00
if len ( parts ) != 2 :
2024-07-09 08:57:38 -07:00
send_message ( " Check Bulletins Quick Command format: \n CB,, {board_name} " , sender_id , interface )
2024-07-04 20:46:22 -07:00
return
_ , board_name = parts
bulletins = get_bulletins ( board_name )
if not bulletins :
send_message ( f " No bulletins available on { board_name } board. " , sender_id , interface )
return
response = f " 📰 Bulletins on { board_name } board: \n "
for i , bulletin in enumerate ( bulletins ) :
response + = f " [ { i + 1 : 02d } ] Subject: { bulletin [ 1 ] } , From: { bulletin [ 2 ] } , Date: { bulletin [ 3 ] } \n "
response + = " \n Please reply with the number of the bulletin you want to read. "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHECK_BULLETIN ' , ' step ' : 1 , ' board_name ' : board_name , ' bulletins ' : bulletins } )
except Exception as e :
logging . error ( f " Error processing check bulletin command: { e } " )
send_message ( " Error processing check bulletin command. " , sender_id , interface )
def handle_read_bulletin_command ( sender_id , message , state , interface ) :
try :
bulletins = state . get ( ' bulletins ' , [ ] )
message_number = int ( message ) - 1
if message_number < 0 or message_number > = len ( bulletins ) :
send_message ( " Invalid bulletin number. Please try again. " , sender_id , interface )
return
bulletin_id = bulletins [ message_number ] [ 0 ]
sender , date , subject , content , unique_id = get_bulletin_content ( bulletin_id )
response = f " Date: { date } \n From: { sender } \n Subject: { subject } \n \n { content } "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , None )
except ValueError :
send_message ( " Invalid input. Please enter a valid bulletin number. " , sender_id , interface )
except Exception as e :
logging . error ( f " Error processing read bulletin command: { e } " )
send_message ( " Error processing read bulletin command. " , sender_id , interface )
def handle_post_channel_command ( sender_id , message , interface ) :
try :
parts = message . split ( " | " , 3 )
if len ( parts ) != 3 :
2024-07-09 08:57:38 -07:00
send_message ( " Post Channel Quick Command format: \n CHP,, {channel_name} ,, {channel_url} " , sender_id , interface )
2024-07-04 20:46:22 -07:00
return
_ , channel_name , channel_url = parts
bbs_nodes = interface . bbs_nodes
add_channel ( channel_name , channel_url , bbs_nodes , interface )
send_message ( f " Channel ' { channel_name } ' has been added to the directory. " , sender_id , interface )
except Exception as e :
logging . error ( f " Error processing post channel command: { e } " )
send_message ( " Error processing post channel command. " , sender_id , interface )
def handle_check_channel_command ( sender_id , interface ) :
try :
channels = get_channels ( )
if not channels :
send_message ( " No channels available in the directory. " , sender_id , interface )
return
2024-07-09 08:57:38 -07:00
response = " Available Channels: \n "
2024-07-04 20:46:22 -07:00
for i , channel in enumerate ( channels ) :
response + = f " { i + 1 : 02d } . Name: { channel [ 0 ] } \n "
response + = " \n Please reply with the number of the channel you want to view. "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' CHECK_CHANNEL ' , ' step ' : 1 , ' channels ' : channels } )
except Exception as e :
logging . error ( f " Error processing check channel command: { e } " )
send_message ( " Error processing check channel command. " , sender_id , interface )
def handle_read_channel_command ( sender_id , message , state , interface ) :
try :
channels = state . get ( ' channels ' , [ ] )
message_number = int ( message ) - 1
if message_number < 0 or message_number > = len ( channels ) :
send_message ( " Invalid channel number. Please try again. " , sender_id , interface )
return
channel_name , channel_url = channels [ message_number ]
response = f " Channel Name: { channel_name } \n Channel URL: { channel_url } "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , None )
except ValueError :
send_message ( " Invalid input. Please enter a valid channel number. " , sender_id , interface )
except Exception as e :
logging . error ( f " Error processing read channel command: { e } " )
send_message ( " Error processing read channel command. " , sender_id , interface )
def handle_list_channels_command ( sender_id , interface ) :
try :
channels = get_channels ( )
if not channels :
send_message ( " No channels available in the directory. " , sender_id , interface )
return
2024-07-09 08:57:38 -07:00
response = " Available Channels: \n "
2024-07-04 20:46:22 -07:00
for i , channel in enumerate ( channels ) :
response + = f " { i + 1 : 02d } . Name: { channel [ 0 ] } \n "
response + = " \n Please reply with the number of the channel you want to view. "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , { ' command ' : ' LIST_CHANNELS ' , ' step ' : 1 , ' channels ' : channels } )
except Exception as e :
logging . error ( f " Error processing list channels command: { e } " )
send_message ( " Error processing list channels command. " , sender_id , interface )
def handle_read_channel_command ( sender_id , message , state , interface ) :
try :
channels = state . get ( ' channels ' , [ ] )
message_number = int ( message ) - 1
if message_number < 0 or message_number > = len ( channels ) :
send_message ( " Invalid channel number. Please try again. " , sender_id , interface )
return
channel_name , channel_url = channels [ message_number ]
response = f " Channel Name: { channel_name } \n Channel URL: { channel_url } "
send_message ( response , sender_id , interface )
update_user_state ( sender_id , None )
except ValueError :
send_message ( " Invalid input. Please enter a valid channel number. " , sender_id , interface )
except Exception as e :
logging . error ( f " Error processing read channel command: { e } " )
send_message ( " Error processing read channel command. " , sender_id , interface )
def handle_quick_help_command ( sender_id , interface ) :
2024-07-09 08:57:38 -07:00
response = ( " ✈️ QUICK COMMANDS✈️ \n Send command below for usage info: \n SM,, - Send "
" Mail \n CM - Check Mail \n PB,, - Post Bulletin \n CB,, - Check Bulletins \n " )
2024-07-04 20:46:22 -07:00
send_message ( response , sender_id , interface )