From b13241564b994762e5c1a4747f74acc6cd27adf5 Mon Sep 17 00:00:00 2001 From: redmatrix Date: Mon, 14 Dec 2015 22:44:05 -0800 Subject: more work on queue api --- include/notifier.php | 21 +++++++-------------- 1 file changed, 7 insertions(+), 14 deletions(-) (limited to 'include/notifier.php') diff --git a/include/notifier.php b/include/notifier.php index 6ff2666bb..c5c1ec75b 100644 --- a/include/notifier.php +++ b/include/notifier.php @@ -159,23 +159,16 @@ function notifier_run($argv, $argc){ )); if($data) { $hash = random_string(); - q("insert into outq ( outq_hash, outq_account, outq_channel, outq_driver, outq_posturl, outq_async, outq_created, outq_updated, outq_notify, outq_msg ) - values ( '%s', %d, %d, '%s', '%s', %d, '%s', '%s', '%s', '%s' )", - dbesc($hash), - intval($s[0]['channel_account_id']), - intval($s[0]['channel_id']), - dbesc('zot'), - dbesc($hh['hubloc_callback']), - intval(1), - dbesc(datetime_convert()), - dbesc(datetime_convert()), - dbesc($data), - dbesc('') - ); + queue_insert(array( + 'hash' => $hash, + 'account_id' => $s[0]['channel_account_id'], + 'channel_id' => $s[0]['channel_id'], + 'posturl' => $hh['hubloc_callback'], + 'notify' => $data, + )); $deliveries[] = $hash; } } - } } -- cgit v1.2.3