mirror of
https://codeberg.org/streams/streams.git
synced 2024-09-20 06:35:15 +00:00
turn private_messages_list into backend functionality and separate it from the controller
This commit is contained in:
parent
cb5a20ba2c
commit
33b22338dc
2 changed files with 54 additions and 45 deletions
|
@ -109,4 +109,50 @@ function send_message($uid = 0, $recipient='', $body='', $subject='', $replyto='
|
|||
|
||||
}
|
||||
|
||||
function private_messages_list($uid, $mailbox = '', $order = 'desc', $start = 0, $numitems = 0) {
|
||||
|
||||
$where = '';
|
||||
$limit = '';
|
||||
|
||||
if($numitems)
|
||||
$limit = " LIMIT " . intval($start) . ", " . intval($numitems);
|
||||
|
||||
if($mailbox !== '') {
|
||||
$x = q("select channel_hash from channel where channel_id = %d limit 1",
|
||||
intval($uid)
|
||||
);
|
||||
if(! $x)
|
||||
return array();
|
||||
if($mailbox === 'inbox')
|
||||
$where = " and sender_xchan != '" . dbesc($x[0]['channel_hash']) . "' ";
|
||||
elseif($mailbox === 'outbox')
|
||||
$where = " and sender_xchan = '" . dbesc($x[0]['channel_hash']) . "' ";
|
||||
}
|
||||
|
||||
|
||||
$r = q("SELECT * from mail WHERE channel_id = %d $where order by created $order $limit",
|
||||
intval(local_user())
|
||||
);
|
||||
if(! $r) {
|
||||
return array();
|
||||
}
|
||||
|
||||
$chans = array();
|
||||
foreach($r as $rr) {
|
||||
$s = "'" . dbesc(trim($rr['from_xchan'])) . "'";
|
||||
if(! in_array($s,$chans))
|
||||
$chans[] = $s;
|
||||
$s = "'" . dbesc(trim($rr['to_xchan'])) . "'";
|
||||
if(! in_array($s,$chans))
|
||||
$chans[] = $s;
|
||||
}
|
||||
|
||||
$c = q("select * from xchan where xchan_hash in (" . implode(',',$chans) . ")");
|
||||
|
||||
foreach($r as $k => $rr) {
|
||||
$r[$k]['from'] = find_xchan_in_array($rr['from_xchan'],$c);
|
||||
$r[$k]['to'] = find_xchan_in_array($rr['to_xchan'],$c);
|
||||
$r[$k]['seen'] = (($rr['mail_flags'] & MAIL_SEEN) ? 1 : 0);
|
||||
}
|
||||
return $r;
|
||||
}
|
|
@ -326,71 +326,34 @@ function message_content(&$a) {
|
|||
|
||||
$o .= $header;
|
||||
|
||||
// private_messages_list() can do other more complicated stuff, for now keep it simple
|
||||
|
||||
$r = q("SELECT count(*) AS `total` FROM `mail`
|
||||
WHERE channel_id = %d",
|
||||
intval(local_user())
|
||||
);
|
||||
if($r)
|
||||
$a->set_pager_total($r[0]['total']);
|
||||
$r = private_messages_list($uid, '', 'desc', $a->pager['start'], $a->pager['itemspage']);
|
||||
|
||||
$r = q("SELECT * from mail WHERE channel_id = %d order by created desc limit %d, %d",
|
||||
intval(local_user()),
|
||||
intval($a->pager['start']),
|
||||
intval($a->pager['itemspage'])
|
||||
);
|
||||
if(! $r) {
|
||||
info( t('No messages.') . EOL);
|
||||
return $o;
|
||||
}
|
||||
|
||||
$chans = array();
|
||||
foreach($r as $rr) {
|
||||
$s = "'" . dbesc(trim($rr['from_xchan'])) . "'";
|
||||
if(! in_array($s,$chans))
|
||||
$chans[] = $s;
|
||||
$s = "'" . dbesc(trim($rr['to_xchan'])) . "'";
|
||||
if(! in_array($s,$chans))
|
||||
$chans[] = $s;
|
||||
}
|
||||
|
||||
$c = q("select * from xchan where xchan_hash in (" . implode(',',$chans) . ")");
|
||||
|
||||
$tpl = get_markup_template('mail_list.tpl');
|
||||
foreach($r as $rr) {
|
||||
$rr['from'] = find_xchan_in_array($rr['from_xchan'],$c);
|
||||
$rr['to'] = find_xchan_in_array($rr['to_xchan'],$c);
|
||||
$rr['seen'] = (($rr['mail_flags'] & MAIL_SEEN) ? 1 : "");
|
||||
|
||||
if($a->get_template_engine() === 'internal') {
|
||||
$from_name_e = template_escape($rr['from']['xchan_name']);
|
||||
$subject_e = template_escape((($rr['seen']) ? $rr['title'] : '<strong>' . $rr['title'] . '</strong>'));
|
||||
$body_e = template_escape($rr['body']);
|
||||
$to_name_e = template_escape($rr['to']['xchan_name']);
|
||||
}
|
||||
else {
|
||||
$from_name_e = $rr['from']['xchan_name'];
|
||||
$subject_e = (($rr['seen']) ? $rr['title'] : '<strong>' . $rr['title'] . '</strong>');
|
||||
$body_e = $rr['body'];
|
||||
$to_name_e = $rr['to']['xchan_name'];
|
||||
}
|
||||
|
||||
$o .= replace_macros($tpl, array(
|
||||
'$id' => $rr['id'],
|
||||
'$from_name' => template_escape($rr['from']['xchan_name']),
|
||||
'$from_name' => $rr['from']['xchan_name'],
|
||||
'$from_url' => z_root() . '/chanview/?f=&hash=' . $rr['from_xchan'],
|
||||
'$from_photo' => $rr['from']['xchan_photo_s'],
|
||||
'$to_name' => template_escape($rr['to']['xchan_name']),
|
||||
'$to_name' => $rr['to']['xchan_name'],
|
||||
'$to_url' => z_root() . '/chanview/?f=&hash=' . $rr['to_xchan'],
|
||||
'$to_photo' => $rr['to']['xchan_photo_s'],
|
||||
'$subject' => template_escape((($rr['seen']) ? $rr['title'] : '<strong>' . $rr['title'] . '</strong>')),
|
||||
'$subject' => (($rr['seen']) ? $rr['title'] : '<strong>' . $rr['title'] . '</strong>'),
|
||||
'$delete' => t('Delete message'),
|
||||
'$body' => template_escape($rr['body']),
|
||||
'$body' => $rr['body'],
|
||||
'$date' => datetime_convert('UTC',date_default_timezone_get(),$rr['created'], t('D, d M Y - g:i A')),
|
||||
'$seen' => $rr['seen']
|
||||
));
|
||||
}
|
||||
$o .= paginate($a);
|
||||
$o .= alt_pager($a,count($r));
|
||||
return $o;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue