Browse Source

remove item from queue

pull/1/head
Friendika 9 years ago
parent
commit
b61d535f81
2 changed files with 23 additions and 11 deletions
  1. +13
    -0
      include/delivery.php
  2. +10
    -11
      include/queue.php

+ 13
- 0
include/delivery.php View File

@ -37,6 +37,19 @@ function delivery_run($argv, $argc){
$item_id = intval($argv[2]);
$contact_id = intval($argv[3]);
// Some other process may have delivered this item already.
$r = q("select * from deliverq where cmd = '%s' and item = %d and contact = %d limit 1",
dbesc($cmd),
dbesc($item_id),
dbesc($contact_id)
);
if(! count($r)) {
return;
}
// It's ours to deliver. Remove it from the queue.
q("delete from deliverq where cmd = '%s' and item = %d and contact = %d limit 1",
dbesc($cmd),
dbesc($item_id),


+ 10
- 11
include/queue.php View File

@ -3,18 +3,18 @@ require_once("boot.php");
require_once('include/queue_fn.php');
function queue_run($argv, $argc){
global $a, $db;
global $a, $db;
if(is_null($a)){
$a = new App;
}
if(is_null($a)){
$a = new App;
}
if(is_null($db)){
@include(".htconfig.php");
require_once("dba.php");
$db = new dba($db_host, $db_user, $db_pass, $db_data);
unset($db_host, $db_user, $db_pass, $db_data);
};
if(is_null($db)){
@include(".htconfig.php");
require_once("dba.php");
$db = new dba($db_host, $db_user, $db_pass, $db_data);
unset($db_host, $db_user, $db_pass, $db_data);
};
require_once("session.php");
@ -42,7 +42,6 @@ function queue_run($argv, $argc){
if(! $interval)
$interval = 2;
$r = q("select * from deliverq where 1");
if(count($r)) {
foreach($r as $rr) {


Loading…
Cancel
Save