aboutsummaryrefslogtreecommitdiff
path: root/muamba.db.inc
diff options
context:
space:
mode:
authorSilvio Rhatto <rhatto@riseup.net>2011-10-07 17:01:22 -0300
committerSilvio Rhatto <rhatto@riseup.net>2011-10-07 17:01:22 -0300
commiteccd915b23e2ea7a1485ecceae9e89ecc2e5c3f7 (patch)
treeede7023eb76bcbb8b3ba45e3ef840a1e3dd19b43 /muamba.db.inc
parentf8da1aa6b4c77e839fde883e2aef244b4fe18bf8 (diff)
downloadmuamba-eccd915b23e2ea7a1485ecceae9e89ecc2e5c3f7.tar.gz
muamba-eccd915b23e2ea7a1485ecceae9e89ecc2e5c3f7.tar.bz2
Adding active, created and changed db fields
Diffstat (limited to 'muamba.db.inc')
-rw-r--r--muamba.db.inc25
1 files changed, 23 insertions, 2 deletions
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();