From eccd915b23e2ea7a1485ecceae9e89ecc2e5c3f7 Mon Sep 17 00:00:00 2001
From: Silvio Rhatto <rhatto@riseup.net>
Date: Fri, 7 Oct 2011 17:01:22 -0300
Subject: Adding active, created and changed db fields

---
 muamba.db.inc | 25 +++++++++++++++++++++++--
 1 file changed, 23 insertions(+), 2 deletions(-)

(limited to 'muamba.db.inc')

diff --git a/muamba.db.inc b/muamba.db.inc
index 3650e08..0500dd9 100644
--- a/muamba.db.inc
+++ b/muamba.db.inc
@@ -128,7 +128,7 @@ function muamba_current_transaction($data) {
 
   $query
     ->condition('m.nid', $nid, '=')
-    ->condition('m.status', array(muamba_ongoing()), 'IN');
+    ->condition('m.active', '1', '=');
 
   $results = $query->execute()->fetchAll();
 
@@ -180,7 +180,28 @@ function muamba_check_availability($data) {
 function muamba_update_status($mid, $status) {
   $update = db_update('muamba')
     ->fields(array(
-      'status' => $status,
+      'status'  => $status,
+      'changed' => REQUEST_TIME,
+    ))
+    ->condition('mid', $mid, '=')
+    ->execute();
+
+  // Close transaction depending on the status.
+  if (!in_array($status, muamba_ongoing())) {
+    muamba_finish($mid);
+  }
+}
+
+/**
+ * Finish a transaction.
+ *
+ * @param $mid
+ *   Transaction id.
+ */
+function muamba_finish($mid) {
+  $update = db_update('muamba')
+    ->fields(array(
+      'active' => 0,
     ))
     ->condition('mid', $mid, '=')
     ->execute();
-- 
cgit v1.2.3