Added class encapsulating bridge DB.

git-svn-id: https://vassalengine.svn.sourceforge.net/svnroot/vassalengine/site-src/trunk@6628 67b53d14-2c14-4ace-a08f-0dab2b34000c

3 files changed, 128 insertions, 0 deletions

diff --git a/src/Bridge.php b/src/Bridge.php
new file mode 100644
index 0000000..ab627d7
--- /dev/null
+++ b/src/Bridge.php
@@ -0,0 +1,63 @@
+<?php
+
+require_once(__DIR__ . '/BridgeConf.php');
+
+class Bridge {
+  protected $db;
+
+  public function __construct($db = FALSE) {
+    $this->db = $db ? $db :
+      new PDO('mysql:host=' . DB_HOST . ';dbname=' . DB, DB_USER, DB_PASS);
+  }
+
+  public function getPostId($messageId) {
+    $sql = 'SELECT post_id FROM posts' .
+           'WHERE message_id = "' . $this->db->quote($message_id) . '"';
+
+    $result = $this->db->query($sql);
+    if (!$result) {
+      trigger_error("Unknown message id: $message_id", E_USER_ERROR);
+    }
+
+    // FIXME: what to do if more than one row is returned?
+    $row = $result->fetch(PDO::FETCH_ASSOC);
+    $result->closeCursor();
+
+    return $row['post_id'];
+  }
+
+  public function registerMessage($msg, $parentId) {
+    $sql = 'INSERT INTO posts' .
+           '(post_id, message_id, parent_message_id, references)' .
+           'VALUES('   . $msg->getPostId()                       . ', '
+                   '"' . $this->db->quote($msg->getMessageId())  . '", '
+                   '"' . $this->db->quote()                      . '", ' 
+                   '"' . $this->db->quote($msg->getReferences()) . '")'; 
+
+    $count = $this->db->exec($sql);
+
+    if ($count != 1) {
+      trigger_error(
+        'Failed to register message: ' . $msg->getMessageId(), E_USER_ERROR
+      );
+    }
+  }
+
+  public function getDefaultForumId($list) {
+    $sql = 'SELECT forum_id FROM bridge' .
+           'WHERE list_name = "' . $this->db->quote($list) . '"';
+
+    $result = $this->db->query($sql);
+    if (!$result) {
+      trigger_error("Unknown list name: $list", E_USER_ERROR);
+    }
+
+    // FIXME: what to do if more than one row is returned?
+    $row = $result->fetch(PDO::FETCH_ASSOC);
+    $result->closeCursor();
+
+    return $row['forum_id'];
+  }
+}
+
+?>
diff --git a/src/BridgeConf.php b/src/BridgeConf.php
new file mode 100644
index 0000000..bd294e2
--- /dev/null
+++ b/src/BridgeConf.php
@@ -0,0 +1,8 @@
+<?php
+
+define('DB_HOST', 'localhost');
+define('DB',      'test');
+define('DB_USER', '');
+define('DB_PASS', '');
+
+?>
diff --git a/test/BridgeTest.php b/test/BridgeTest.php
new file mode 100644
index 0000000..3036f2b
--- /dev/null
+++ b/test/BridgeTest.php
@@ -0,0 +1,57 @@
+<?php
+
+require_once('PHPUnit/Framework.php');
+require_once('src/Bridge.php');
+
+class BridgeTest extends PHPUnit_Framework_TestCase {
+
+  /**
+   * @dataProvider providerGetPostId
+   */
+  public function testGetPostId($message_id, $expected, $ex) {
+    $bridge = new Bridge();
+    if ($ex) $this->setExpectedException($ex);
+    $this->assertEquals($expected, $bridge->getPostId($message_id));
+  }
+
+  public function providerGetPostId() {
+    return array(
+      array('bogus', null, 'PHPUnit_Framework_Error'), 
+    );
+  }
+
+  /**
+   * @dataProvider providerRegisterMessage
+   */
+  public function testRegisterMessage($msg, $expected, $ex) {
+    $this->markTestIncomplete();
+#    $bridge = new Bridge();
+#    if ($ex) $this->setExpectedException($ex);
+#    $this->assertEquals($expected, $bridge->registerMessage($msg));
+  }
+
+  public function providerRegisterMessage() {
+    return array(
+    );
+  }
+
+  /**
+   * @dataProvider providerGetDefaultForumId
+   */
+  public function testGetDefaultForumId($list, $expected, $ex) {
+    $bridge = new Bridge();
+    if ($ex) $this->setExpectedException($ex);
+    $this->assertEquals($expected, $bridge->getDefaultForumId($list));
+  }
+
+  public function providerGetDefaultForumId() {
+    return array(
+      array('bogus', null, 'PHPUnit_Framework_Error'), 
+#      array('messages@forums.vassalengine.org', 2, null),
+    );
+  }
+
+
+}
+
+?>