diff options
Diffstat (limited to 'src/PhpBB3Impl.php')
| -rw-r--r-- | src/PhpBB3Impl.php | 364 |
1 files changed, 364 insertions, 0 deletions
diff --git a/src/PhpBB3Impl.php b/src/PhpBB3Impl.php new file mode 100644 index 0000000..9986a6a --- /dev/null +++ b/src/PhpBB3Impl.php @@ -0,0 +1,364 @@ +<?php + +# +# $Id$ +# +# forum-list bridge +# Copyright (C) 2010 Joel Uckelman +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# This program 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 General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program. If not, see <http://www.gnu.org/licenses/>. +# + +require_once(__DIR__ . '/PhpBB3.php'); +require_once(__DIR__ . '/Util.php'); + +# phpBB setup +define('IN_PHPBB', true); +$phpEx = substr(strrchr(__FILE__, '.'), 1); +require_once($phpbb_root_path . 'common.' . $phpEx); +require_once($phpbb_root_path . 'includes/functions.' . $phpEx); +require_once($phpbb_root_path . 'includes/functions_posting.' . $phpEx); +require_once($phpbb_root_path . 'includes/functions_user.' . $phpEx); + +class PhpBB3Impl implements PhpBB3 { + public function __construct() { + } + + public function getUserId($from) { + throw_if_null($from); + + global $db; + + # NB: There might be multiple user accounts associated with one email + # address. We can only return one user id, so we decide in favor of + # the account which was most recently used to visit the forum. + $sql = 'SELECT u1.user_id FROM ' . USERS_TABLE . ' AS u1 ' . + 'LEFT OUTER JOIN ' . USERS_TABLE . ' AS u2 ON (' . + 'u1.user_email = u2.user_email AND ' . + 'u1.user_lastvisit < u2.user_lastvisit' . + ') WHERE u1.user_email = "' . $db->sql_escape($from) . '" AND ' . + 'u2.user_email IS NULL'; + + $row = $this->get_exactly_one_row($sql); + return $row ? $row['user_id'] : false; + } + + public function getUserName($id) { + throw_if_null($id); + + # NB: user_get_id_name is pass-by-reference; we copy $id to prevent + # it from being modified, as we might need it for error messages + $ids = array($id); + $err = user_get_id_name($ids, $names); + if ($err) { + throw new Exception("Could not resolve user id $id: $err"); + } + + if (!isset($names[$id])) { + throw new Exception("Unknown user id: $id"); + } + + return $names[$id]; + } + + public function getTopicAndForumIds($post_id) { + throw_if_null($post_id); + + global $db; + + $sql = 'SELECT topic_id, forum_id FROM ' . POSTS_TABLE . ' ' . + 'WHERE post_id = ' . $post_id; + + $row = $this->get_exactly_one_row($sql); + return $row; + } + + public function forumExists($forumId) { + throw_if_null($forumId); + + global $db; + + $sql = 'SELECT 1 FROM ' . FORUMS_TABLE . ' ' . + 'WHERE forum_id = ' . $forumId . ' LIMIT 1'; + + $result = $db->sql_query($sql); + + $rows = $db->sql_fetchrowset($result); + $db->sql_freeresult($result); + + switch (count($rows)) { + case 0: + return false; + + case 1: + return true; + + default: + # Should be impossible due to LIMIT 1. + throw new Exception("Too many rows returned: $sql"); + } + } + + public function topicStatus($topicId) { + throw_if_null($topicId); + + global $db; + + $sql = 'SELECT topic_status FROM ' . TOPICS_TABLE . ' ' . + 'WHERE topic_id = ' . $topicId; + + $row = $this->get_exactly_one_row($sql); + return $row ? $row['topic_status'] : false; + } + + public function getPostTime($postId) { + throw_if_null($postId); + + global $db; + + $sql = 'SELECT post_time FROM ' . POSTS_TABLE . ' ' . + 'WHERE post_id = ' . $postId; + + $row = $this->get_exactly_one_row($sql); + return $row ? $row['post_time'] : false; + } + + public function getAttachmentData($attachId) { + throw_if_null($attachId); + + global $db; + + $sql = 'SELECT physical_filename, real_filename, ' . + 'attach_comment, mimetype ' . + 'FROM ' . ATTACHMENTS_TABLE . ' ' . + 'WHERE attach_id = ' . $attachId; + + $row = $this->get_exactly_one_row($sql); + return $row; + } + + public function postMessage($postType, $forumId, $topicId, $msg) { + throw_if_null($msg); + + if ($postType == 'post') { + # do nothing + } + else if ($postType == 'reply') { + # Check that we're not replying to a locked topic. + $status = $this->topicStatus($topicId); + if ($status === false) { + throw new Exception('topic does not exist: ' . $topicId); + } + + switch ($this->topicStatus($topicId)) { + case ITEM_UNLOCKED: + # normal, ok + break; + case ITEM_LOCKED: + throw new Exception('post to locked topic: ' . $topicId); + break; + case ITEM_MOVED: + # Should not happen, since the only topics with this status + # are new shadow topics created after moves. + throw new Exception('post to moved topic: ' . $topicId); + break; + default: + # Should not happen. + throw new Exception('bad topic status: ' . $topicId); + break; + } + } + else { + # Should not happen. + throw new Exception('bad post type: ' . $postType); + } + + if (!$this->forumExists($forumId)) { + throw new Exception('forum does not exist: ' . $forumId); + } + + $userId = $this->getUserId($msg->getFrom()); + if ($userId === false) { + throw new Exception('unrecognized email address: ' . $msg->getFrom()); + } + + $userName = $this->getUserName($userId); + if ($userName === false) { + throw new Exception('unrecognized user id: ' . $userId); + } + + $subject = $msg->getSubject(); + list($message, $attachments) = $msg->getFlattenedParts(); + +# FIXME: extract the footer pattern into a config file? + # strip the list footer + $message = preg_replace("/^_______________________________________________\nmessages mailing list\nmessages@vassalengine.org\nhttp:\/\/www.vassalengine.org\/mailman\/listinfo\/messages.*/ms", '', $message); + +# TODO: convert > quoting into BBCode + + # handle attachments + $attachment_data = array(); + + foreach ($attachments as $a) { + $attachment_data[] = $this->addAttachment( + $userId, $a['filename'], $a['comment'], $a['mimetype'], $a['data'] + ); + } + + # bring in the PhpBB globals + global $phpEx, $phpbb_root_path, $user, $auth, + $template, $cache, $db, $config; + + # authenticate ourselves + $user->session_create($userId); + $auth->acl($user->data); + +# FIXME: strip list and forum tag from subject + $subject = utf8_normalize_nfc($subject); + $message = utf8_normalize_nfc($message); + + $uid = $bitfield = $options = ''; + + generate_text_for_storage( + $subject, $uid, $bitfield, $options, false, false, false + ); + + generate_text_for_storage( + $message, $uid, $bitfield, $options, true, true, true + ); + + # build the data array for submit_post + $postId = null; + + $data = array( + 'forum_id' => $forumId, + 'topic_id' => &$topicId, + 'post_id' => &$postId, + 'icon_id' => false, + + 'enable_bbcode' => true, + 'enable_smilies' => true, + 'enable_urls' => true, + 'enable_sig' => true, + + 'message' => $message, + 'message_md5' => md5($message), + + 'bbcode_bitfield' => $bitfield, + 'bbcode_uid' => $uid, + + 'post_edit_locked' => 0, + 'topic_title' => $subject, + 'notify_set' => false, + 'notify' => false, + 'post_time' => 0, + 'forum_name' => '', + 'enable_indexing' => true + ); + + if (!empty($attachment_data)) { + $data['attachment_data'] = $attachment_data; + } + + $poll = ''; + + submit_post($postType, $subject, $userName, POST_NORMAL, $poll, $data); + + return $postId; + } + + public function addAttachment($userId, $filename, $comment, + $mimetype, $data) { + throw_if_null($userId); + throw_if_null($filename); + throw_if_null($mimetype); + throw_if_null($data); + + global $db; + +# TODO: check that attachment is a permissible type, size + + # lifted from include/functions_upload.php: filespec::clean_filename() + $physicalFilename = $userId . '_' . md5(unique_id()); + + # get extension + $dot = strrpos($filename, '.'); + $extension = $dot === false ? '' : substr($filename, $dot + 1); + + # put the attachment data into the db + $sql = 'INSERT INTO ' . ATTACHMENTS_TABLE . ' (' . + 'poster_id, is_orphan, physical_filename, real_filename, ' . + 'attach_comment, extension, mimetype, filesize, filetime' . + ') VALUES (' . + $userId . ', ' . + '1, ' . + '"' . $physicalFilename . '", ' . + '"' . $db->sql_escape($filename) . '", ' . + '"' . $db->sql_escape($comment) . '", ' . + '"' . $db->sql_escape($extension) . '", ' . + '"' . $db->sql_escape($mimetype) . '", ' . + strlen($data) . ', ' . + time() . + ')'; + + $db->sql_query($sql); + + if ($db->sql_affectedrows() != 1) { + throw new Exception("Adding attachment failed: $sql"); + } + + # post the attachment data to our attachment writer shim + require_once(__DIR__ . '/HTTP_POST_multipart.php'); + + $url = 'http://www.test.nomic.net/forum/attachment_writer.php'; + $poster = new HTTP_POST_multipart(); + $poster->addData('password', '5rnudbp7dLkijcwrT@sz'); + $poster->addFile(1, $physicalFilename, $mimetype, null, 'binary', $data); + $result = $poster->post($url); + + if ($result != 1) { + throw new Exception('Attachment writer failed: ' . $result); + } + + # return the attachment info needed by submit_post + return array( + 'attach_id' => $db->sql_nextid(), + 'is_orphan' => 1, + 'real_filename' => $realFilename, + 'attach_comment' => $comment, + ); + } + + protected function get_exactly_one_row($sql) { + global $db; + + $result = $db->sql_query($sql); + + $rows = $db->sql_fetchrowset($result); + $db->sql_freeresult($result); + + switch (count($rows)) { + case 0: + return false; + + case 1: + return $rows[0]; + + default: + throw new Exception("Too many rows returned: $sql"); + } + } +} + +?> |