sms_handlers.php

<?php

function sms_handler($usr_id, $rx_msg, $rx_id, $usr_context) {

	// Based on the user context, invoke a handler function.

	if ($usr_context == 'handler') {
		die("Bailing out before we hit infinite recursion.");
	}

	$handler_func = "sms_{$usr_context}";

	if (DEBUG) {
		echo "Handler: $handler_func\n";
	}

	if (function_exists($handler_func)) {
		$rsp = call_user_func($handler_func, $usr_id, $rx_msg, $rx_id);
	} else {
		return array(
			'ok' => 0,
			'error' => "No handler function found for '$usr_context' context.\n"
		);
	}

	$rsp['rx_id'] = $rx_id;
	return $rsp;
}

function sms_intro($usr_id, $rx_msg, $rx_id) {

	// 'intro' is the default context for new users, assigned after they've
	// sent their first message.

	$rsp = usr_get_by_id($usr_id);
	if (! $rsp['ok']) {
		if (DEBUG) {
			print_r($rsp);
		}
		exit;
	}

	$usr = $rsp['usr'];

	// Send the first incoming message out to admins for
	// moderation.
	$admin_options = "[/hold {$rx_id} /ban id$usr->id]";
	$admin_msg = "$rx_msg\n$admin_options";
	$signed_msg = msg_signed_format($usr, $admin_msg);
	msg_mod_tx($usr_id, $signed_msg, $rx_id);

	// Transition to name context.
	usr_set_context($usr_id, 'name');
	$tx_msg = xo('ctx_intro');

	return array(
		'ok' => 1,
		'tx_msg' => $tx_msg
	);
}

function sms_send_invite($usr_id, $rx_msg, $rx_id) {
	
	// 'send_invite' is the context for when the user just initiated an
	// /invite [phone] command. The response should be Y, N, or the message
	// they want to send out as the invitation.

	$rsp = usr_get_last_invite($usr_id);
	if (! $rsp['ok']) {
		return array(
			'ok' => 0,
			'tx_msg' => xo($rsp['xo'])
		);
	}
	$invite = $rsp['invite'];

	$yes_no = strtolower($rx_msg);
	$yes_no = trim($yes_no);
	$yes_no = mb_substr($yes_no, 0, 1);
	
	if ($yes_no == 'y') {

		// Send the invitation as-is!
		$rsp = usr_get_by_phone($invite->phone);
		$invited = $rsp['usr'];
		usr_set_context($usr_id, 'chat');

		$rsp = db_update('usr', array(
			'context' => 'invited',
			'invited_by' => $usr_id,
			'joined' => null
		), "id = $invited->id");
		if (! $rsp['ok']) {
			return array(
				'ok' => 0,
				'tx_msg' => xo('err_db')
			);
		}

		$rsp = db_update('usr_invite', array(
			'sent' => date('Y-m-d H:i:s')
		), "id = $invite->id");
		if (! $rsp['ok']) {
			return array(
				'ok' => 0,
				'tx_msg' => xo('err_db')
			);
		}

		// (This is the part where we actually send out the invite.)
		msg_tx($invited->id, xo('cmd_invite_hello', $invite->invitation), $rx_id);

		return array(
			'ok' => 1,
			'tx_msg' => xo('cmd_invite_sent')
		);

	} else if ($yes_no == 'n') {
		// Cancel the invitation
		usr_set_context($usr_id, 'chat');
		$tx_msg = xo('cmd_invite_cancel');
	} else {
		// Update the invitation text
		db_update('usr_invite', array(
			'invitation' => $rx_msg
		), "id = $invite->id");

		// And ask one more time before we send it out.
		return array(
			'ok' => 1,
			'tx_msg' => xo('cmd_invite_preview', $rx_msg)
		);
	}

}

function sms_invited($usr_id, $rx_msg, $rx_id) {

	// 'invited' is the status a user gets assigned when their friend sends
	// an "/invite [phone]" command.

	$msg = strtolower($rx_msg);
	$msg = trim($msg);

	if (mb_substr($msg, 0, 2) == 'ok') {

		// Great, a new user accepted an invite!
		$usr = usr_get("id$usr_id");

		// Transition to name context.
		usr_set_context($usr_id, 'name');
		
		$phone = addslashes($usr->phone);

		// Update the usr_invite record
		db_update('usr_invite', array(
			'accepted' => date('Y-m-d H:i:s')
		), "phone = '$phone'");

		// Update the usr record
		db_update('usr', array(
			'joined' => date('Y-m-d H:i:s')
		), "id = $usr_id");

		$rsp = db_single("
			SELECT *
			FROM usr_invite
			WHERE phone = ?
			ORDER BY sent DESC
		", array($usr->phone));
		if ($rsp['row']) {
			$invite = $rsp['row'];
			msg_tx($invite->usr_id, xo('cmd_invite_accepted', $usr->phone), $rx_id);
		}

		// Send intro text out
		$tx_msg = xo('ctx_intro');
	} else {
		$tx_msg = xo('ctx_invite_sorry');
	}

	return array(
		'ok' => 1,
		'tx_msg' => $tx_msg
	);
}

function sms_name($usr_id, $rx_msg, $rx_id) {

	// 'name' context is when we're prompting the user for theif first
	// username.

	include(__DIR__ . '/config.php');

	$rsp = usr_set_name($usr_id, $rx_msg, $rx_id);
	if ($rsp['ok']) {

		$name = $rsp['new_name'];

		$rsp = usr_get_by_id($usr_id);
		util_ensure_rsp($rsp);
		$usr = $rsp['usr'];

		// Transition to coc
		usr_set_context($usr_id, 'coc');

		$coc_url = "$website_url/conduct";
		$tx_msg = xo('ctx_name', $name, $coc_url);

	} else {
		// Invalid name
		$tx_msg = xo($rsp['xo']);
		$tx_msg .= "\nPlease try again.";
	}

	return array(
		'ok' => 1,
		'tx_msg' => $tx_msg
	);
}

function sms_coc($usr_id, $rx_msg, $rx_id) {
	
	// 'coc' is the Code of Conduct context. The user has to reply 'ok' in
	// order to proceed.

	include(__DIR__ . '/config.php');

	$usr = usr_get("id$usr_id");

	$msg = strtolower($rx_msg);
	$msg = trim($msg);

	if (mb_substr($msg, 0, 2) == 'ok') {

		// What happens next depends on whether the user was invited.

		if (! empty($usr->invited_by)) {
			// If the user was *invited*, just jump into the chat.
			usr_set_context($usr_id, 'chat');
			$count = xo_chat_count($usr_id);
			$mod = xo('ctx_coc_mod');
			$tx_msg = xo('ctx_first_msg', "$mod $count", $website_url);

			// Announce that the user has joined the chat
			$announcement = xo('cmd_start_announce', $usr->name);
			msg_mod_tx($usr_id, "[$announcement]", $rx_id);
		} else {

			$rsp = usr_get_first_msg($usr_id, 'formatted');
			util_ensure_rsp($rsp);
			$first_msg = $rsp['first_msg'];
			$first_msg_held = $rsp['first_msg_held'];

			if ($first_msg_held) {
				// First message is held: just jump into to chat
				usr_set_context($usr_id, 'chat');
				$mod = xo('ctx_coc_mod');
				$count = xo_chat_count($usr_id, $usr->channel);
				$tx_msg = xo('ctx_first_msg', "$mod $count", $website_url);

				// Announce that the user has joined the chat
				$announcement = xo('cmd_start_announce', $usr->name);
				msg_mod_tx($usr_id, "[$announcement]", $rx_id);
			} else {
				// Ask to send out the first message.
				usr_set_context($usr_id, 'first_msg');
				$mod = xo('ctx_coc_mod');
				$tx_msg = xo('ctx_coc_first_msg', $mod, $first_msg);
			}
		}
	} else {
		$coc_url = "$website_url/conduct";
		$tx_msg = xo('ctx_coc_nope', $coc_url);
	}

	return array(
		'ok' => 1,
		'tx_msg' => $tx_msg
	);
}

function sms_first_msg($usr_id, $rx_msg, $rx_id) {

	// 'first_msg' context is when the user is deciding whether they want
	// to send out their first message.

	// This is also where we transition into the chat, so we try to offer as
	// much context as possible.

	// For example:
	// Message sent! You are now chatting with 17 others.
	// Reply /stop to leave, or /help for more commands...

	include(__DIR__ . '/config.php');

	$usr = usr_get("id$usr_id");
	if (! $usr) {
		return array(
			'ok' => 0,
			'error' => "Couldn't find user $usr_id!\n"
		);
	}

	// Transition into chat
	usr_set_context($usr_id, 'chat');

	// Announce that the user has joined the chat
	$announcement = xo('cmd_start_announce', $usr->name);
	msg_mod_tx($usr_id, "[$announcement]", $rx_id);

	// First, figure out $count: how many people are in the chat?

	$count = xo_chat_count($usr_id);

	// Next: send or not send the message? Result is stored in $sent.

	$yes_no = strtolower($rx_msg);
	$yes_no = trim($yes_no);
	$yes_no = mb_substr($yes_no, 0, 1);

	if ($yes_no == 'y') {

		// Ok, send it!!
		$rsp = usr_get_first_msg($usr_id);
		util_ensure_rsp($rsp);
		$first_msg = $rsp['first_msg'];
		$first_msg_id = $rsp['first_msg_id'];
		$first_msg_held = $rsp['first_msg_held'];

		if ($first_msg_held) {

			// On second thought, the message was held, so I guess
			// we will just bail out now.

			// Instead, join the chat!
			usr_set_context($usr_id, 'chat');

			// Announce that the user has joined the chat
			$announcement = xo('cmd_start_announce', $usr->name);
			msg_mod_tx($usr_id, "[$announcement]", $rx_id);

			$tx_msg = xo_first_msg_held($usr_id);
			return array(
				'ok' => 1,
				'tx_msg' => $tx_msg
			);
		}

		// This is the part where we actually send the message: *whoosh*
		msg_chat($usr_id, $first_msg, $first_msg_id);

		// Yep, "we sent it."
		if ($count == xo('ctx_chat_first')) {
			$sent = xo('ctx_first_msg_saved'); // "saved." (archived)
		} else {
			$sent = xo('ctx_first_msg_sent');  // vs. "sent!"
		}

	} else if ($yes_no == 'n') {
		// Nope, "didn't send."
		$sent = xo('ctx_first_msg_drop');
	} else {
		// Huh? "Didn't send."
		$sent = xo('ctx_first_msg_huh');
	}
	
	
	// Send the response message
	$tx_msg = xo('ctx_first_msg', "$sent $count", $website_url);

	// Is this the first user? If so, make 'em the admin.
	if (usr_is_first()) {
		// TODO: figure out if this could work better via web service
		$rsp = usr_set_status("id$usr_id", 'admin');
		if ($rsp['ok']) {
			msg_tx($usr_id, xo('ctx_intro_admin'), $rx_id);
		} else if (DEBUG) {
			echo "Could not set user status:\n";
			print_r($rsp);
		}
	}

	return array(
		'ok' => 1,
		'tx_msg' => $tx_msg
	);
}

function sms_stopped($usr_id, $rx_msg, $rx_id) {

	// 'stopped' is when the user has left the chat with the "/stop"
	// command. We will send their message and transition to 'chat' context.

	$rsp = msg_chat($usr_id, $rx_msg, $rx_id);
	$rsp['tx_msg'] = xo('ctx_stopped');
	return $rsp;
}

function sms_chat($usr_id, $rx_msg, $rx_id) {

	// 'chat' is when the user is sending messages to other users.

	return msg_chat($usr_id, $rx_msg, $rx_id);
}

function sms_mod_request($usr_id, $rx_msg, $rx_id) {

	// 'mod_request' is when a user has sent "/mod" to request help, but
	// still needs to confirm that they want help.

	$usr = usr_get("id$usr_id");

	$msg = strtolower($rx_msg);
	$msg = trim($msg);

	if (mb_substr($msg, 0, 2) == 'ok') {
		usr_set_context($usr_id, 'stopped');
		$announcement = xo('cmd_mod_request', $usr->name, $usr->name);
		msg_mod_tx($usr_id, "[$announcement]", $rx_id);
		$tx_msg = xo('cmd_mod_sent');
	} else {
		usr_set_context($usr_id, 'chat');
		$tx_msg = xo('cmd_mod_cancel');
	}

	return array(
		'ok' => 1,
		'tx_msg' => $tx_msg
	);
}