1 files changed, 63 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'];
+  }
+}
+
+?>