2024-06-05 13:05:17 +02:00
< ? php
/*
* NNTP <-> HTTP Gateway
* Download : https :// news . novabbs . com / get
*
* Based on Newsportal by Florian Amrhein
*
* E - Mail : retroguy @ novabbs . com
* Web : https :// news . novabbs . com
*
* This program is free software ; you can redistribute it and / or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation ; either version 2 of the License , or
* ( at your option ) any later version .
*
* This program is distributed in the hope that it will be useful ,
* but WITHOUT ANY WARRANTY ; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE . See the
* GNU General Public License for more details .
*
* You should have received a copy of the GNU General Public License
* along with this program ; if not , write to the Free Software
* Foundation , Inc . , 59 Temple Place , Suite 330 , Boston , MA 02111 - 1307 USA
*/
if ( file_exists ( " lib/types.inc.php " ))
include " lib/types.inc.php " ;
if ( file_exists ( " lib/thread.inc.php " ))
include " lib/thread.inc.php " ;
if ( file_exists ( " lib/message.inc.php " ))
include " lib/message.inc.php " ;
if ( file_exists ( " lib/post.inc.php " ))
include " lib/post.inc.php " ;
2024-09-28 18:15:51 +02:00
$CONFIG = include ( $config_file );
2024-06-05 13:05:17 +02:00
/*
* opens the connection to the NNTP - Server
*
* $server : adress of the NNTP - Server
* $port : port of the server
*/
function nntp_open ( $nserver = 0 , $nport = 0 )
{
global $text_error , $CONFIG ;
global $server , $port ;
// echo "<br>NNTP OPEN<br>";
if ( ! isset ( $CONFIG [ 'enable_nntp' ]) || $CONFIG [ 'enable_nntp' ] != true ) {
$CONFIG [ 'server_auth_user' ] = $CONFIG [ 'remote_auth_user' ];
$CONFIG [ 'server_auth_pass' ] = $CONFIG [ 'remote_auth_pass' ];
}
$authorize = (( isset ( $CONFIG [ 'server_auth_user' ])) && ( isset ( $CONFIG [ 'server_auth_pass' ])) && ( $CONFIG [ 'server_auth_user' ] != " " ));
if ( $nserver == 0 )
$nserver = $server ;
if ( $nport == 0 )
$nport = $port ;
$ns = @ fsockopen ( $nserver , $nport );
// if the connection to the news server fails, inform the user and stop processing.
if ( $ns == false ) {
echo '<center><p>' . $text_error [ " error: " ] . " " . $text_error [ " connection_failed " ] . '.</p>' ;
echo '<br>' ;
echo '<p>Please wait a few moments and try again. If you see the same error, notify the owner that their Message Server is offline.</p>' ;
echo '</center>' ;
return false ;
// exit(0);
}
$weg = line_read ( $ns ); // kill the first line
if ( substr ( $weg , 0 , 2 ) != " 20 " ) {
echo " <p> " . $text_error [ " error: " ] . $weg . " </p> " ;
fclose ( $ns );
$ns = false ;
} else {
if ( $ns != false ) {
fputs ( $ns , " MODE reader \r \n " );
$weg = line_read ( $ns ); // and once more
if (( substr ( $weg , 0 , 2 ) != " 20 " ) && (( ! $authorize ) || (( substr ( $weg , 0 , 3 ) != " 480 " ) && ( $authorize )))) {
echo " <p> " . $text_error [ " error: " ] . $weg . " </p> " ;
fclose ( $ns );
$ns = false ;
}
}
if (( isset ( $CONFIG [ 'server_auth_user' ])) && ( isset ( $CONFIG [ 'server_auth_pass' ])) && ( $CONFIG [ 'server_auth_user' ] != " " )) {
fputs ( $ns , " AUTHINFO USER " . $CONFIG [ 'server_auth_user' ] . " \r \n " );
$weg = line_read ( $ns );
fputs ( $ns , " AUTHINFO PASS " . $CONFIG [ 'server_auth_pass' ] . " \r \n " );
$weg = line_read ( $ns );
/* Only check auth if reading and posting same server */
// NNTP Response NOT 281 (Authorization failed)
if ( substr ( $weg , 0 , 3 ) != " 281 " && ! ( isset ( $post_server )) && ( $post_server != " " )) {
echo " <p> " . $text_error [ " error: " ] . " </p> " ;
echo " <p> " . $text_error [ " auth_error " ] . " </p> " ;
}
}
}
if ( $ns == false )
echo " <p> " . $text_error [ " connection_failed " ] . " </p> " ;
return $ns ;
}
function nntp2_open ( $nserver = 0 , $nport = 0 )
{
global $text_error , $CONFIG ;
$authorize = (( isset ( $CONFIG [ 'remote_auth_user' ])) && ( isset ( $CONFIG [ 'remote_auth_pass' ])) && ( $CONFIG [ 'remote_auth_user' ] != " " ));
if ( $nserver == 0 )
$nserver = $CONFIG [ 'remote_server' ];
if ( $nport == 0 )
$nport = $CONFIG [ 'remote_port' ];
if ( $CONFIG [ 'remote_ssl' ]) {
if ( $nport == $CONFIG [ 'remote_port' ]) {
$nport = $CONFIG [ 'remote_ssl' ];
}
$ns = fsockopen ( " ssl:// " . $nserver , $nport , $error , $errorString , 30 );
if ( ! $ns ) {
return false ;
}
} else {
if ( isset ( $CONFIG [ 'socks_host' ]) && $CONFIG [ 'socks_host' ] !== '' ) {
$ns = fsocks4asockopen ( $CONFIG [ 'socks_host' ], $CONFIG [ 'socks_port' ], $nserver , $nport );
} else {
$ns = @ fsockopen ( 'tcp://' . $nserver . " : " . $nport );
}
}
// $ns=@fsockopen($nserver,$nport);
// echo "PORT: ".$nport." ns: ".$ns;
$weg = line_read ( $ns ); // kill the first line
if ( substr ( $weg , 0 , 2 ) != " 20 " ) {
echo " <p> " . $text_error [ " error: " ] . $weg . " </p> " ;
if ( $ns ) {
fclose ( $ns );
}
$ns = false ;
} else {
if ( $ns != false ) {
fputs ( $ns , " MODE reader \r \n " );
$weg = line_read ( $ns ); // and once more
if (( substr ( $weg , 0 , 2 ) != " 20 " ) && (( ! $authorize ) || (( substr ( $weg , 0 , 3 ) != " 480 " ) && ( $authorize )))) {
echo " <p> " . $text_error [ " error: " ] . $weg . " </p> " ;
fclose ( $ns );
$ns = false ;
}
}
if (( isset ( $CONFIG [ 'remote_auth_user' ])) && ( isset ( $CONFIG [ 'remote_auth_pass' ])) && ( $CONFIG [ 'remote_auth_user' ] != " " )) {
fputs ( $ns , " AUTHINFO USER " . $CONFIG [ 'remote_auth_user' ] . " \r \n " );
$weg = line_read ( $ns );
fputs ( $ns , " AUTHINFO PASS " . $CONFIG [ 'remote_auth_pass' ] . " \r \n " );
$weg = line_read ( $ns );
/* Only check auth if reading and posting same server */
if ( substr ( $weg , 0 , 3 ) != " 281 " && ! ( isset ( $post_server )) && ( $post_server != " " )) {
echo " <p> " . $text_error [ " error: " ] . " </p> " ;
echo " <p> " . $text_error [ " auth_error " ] . " </p> " ;
}
}
}
if ( $ns == false )
echo " <p> " . $text_error [ " connection_failed " ] . " </p> " ;
return $ns ;
}
function fsocks4asockopen ( $proxyHostname , $proxyPort , $targetHostname , $targetPort )
{
$sock = fsockopen ( $proxyHostname , $proxyPort );
if ( $sock === false )
return false ;
fwrite ( $sock , pack ( " CCnCCCCC " , 0x04 , 0x01 , $targetPort , 0x00 , 0x00 , 0x00 , 0x01 , 0x00 ) . $targetHostname . pack ( " C " , 0x00 ));
$response = fread ( $sock , 16 );
$values = unpack ( " xnull/Cret/nport/Nip " , $response );
if ( $values [ " ret " ] == 0x5a )
return $sock ;
else {
fclose ( $sock );
return false ;
}
}
/*
* Close a NNTP connection
*
* $ns : the handle of the connection
*/
function nntp_close ( & $ns )
{
if ( $ns != false ) {
fputs ( $ns , " QUIT \r \n " );
fclose ( $ns );
}
}
/*
* Validates an email adress
*
* $address : a string containing the email - address to be validated
*
* returns true if the address passes the tests , false otherwise .
*/
function validate_email ( $address )
{
global $validate_email ;
$return = true ;
2024-07-17 15:33:48 +02:00
if (( $validate_email >= 1 ) && ( $return == true ))
2024-09-28 18:15:51 +02:00
/* Need to clean up this regex to work properly with preg_match
2024-07-17 15:33:48 +02:00
$return = ( preg_match ( '^[-!#$%&\'*+\\./0-9=?A-Z^_A-z{|}~]+' . '@' .
'[-!#$%&\'*+\\/0-9=?A-Z^_A-z{|}~]+\.' .
'[-!#$%&\'*+\\./0-9=?A-Z^_A-z{|}~]+$' , $address ));
*/
2024-09-28 18:15:51 +02:00
$return = 1 ;
2024-06-05 13:05:17 +02:00
if (( $validate_email >= 2 ) && ( $return == true )) {
$addressarray = address_decode ( $address , " garantiertungueltig " );
$return = checkdnsrr ( $addressarray [ 0 ][ " host " ], " MX " );
if ( ! $return )
$return = checkdnsrr ( $addressarray [ 0 ][ " host " ], " A " );
}
return ( $return );
}
/*
* decodes a block of 7 bit - data in uuencoded format to it ' s original
* 8 bit format .
* The headerline containing filename and permissions doesn ' t have to
* be included .
*
* $data : The uuencoded data as a string
*
* returns the 8 bit data as a string
*
* Note : this function is very slow and doesn ' t recognize incorrect code .
*/
function uudecode_line ( $line )
{
$data = substr ( $line , 1 );
$length = ord ( $line [ 0 ]) - 32 ;
$decoded = " " ;
2024-09-28 18:15:51 +02:00
for ( $i = 0 ; $i < ( strlen ( $data ) >> 2 ); $i ++ ) {
2024-06-05 13:05:17 +02:00
$pack = substr ( $data , $i << 2 , 4 );
$upack = " " ;
$bitmaske = 0 ;
2024-09-28 18:15:51 +02:00
for ( $o = 0 ; $o < 4 ; $o ++ ) {
2024-06-05 13:05:17 +02:00
$g = (( ord ( $pack [ 3 - $o ]) - 32 ));
if ( $g == 64 )
$g = 0 ;
$bitmaske = $bitmaske | ( $g << ( 6 * $o ));
}
$schablone = 255 ;
2024-09-28 18:15:51 +02:00
for ( $o = 0 ; $o < 3 ; $o ++ ) {
2024-06-05 13:05:17 +02:00
$c = ( $bitmaske & $schablone ) >> ( $o << 3 );
$schablone = ( $schablone << 8 );
$upack = chr ( $c ) . $upack ;
}
$decoded .= $upack ;
}
$decoded = substr ( $decoded , 0 , $length );
return $decoded ;
}
/*
* decodes uuencoded Attachments .
*
* $data : the encoded data
*
* returns the decoded data
*/
function uudecode ( $data )
{
$d = explode ( " \n " , $data );
$u = " " ;
2024-09-28 18:15:51 +02:00
for ( $i = 0 ; $i < count ( $d ) - 1 ; $i ++ )
2024-06-05 13:05:17 +02:00
$u .= uudecode_line ( $d [ $i ]);
return $u ;
}
/*
* returns the mimetype of an filename
*
* $name : the complete filename of a file
*
* returns a string containing the mimetype
*/
function get_mimetype_by_filename ( $name )
{
$ending = strtolower ( strrchr ( $name , " . " ));
switch ( $ending ) {
case " .jpg " :
case " .jpeg " :
$type = " image/jpeg " ;
break ;
case " .gif " :
$type = " image/gif " ;
break ;
case " .png " :
$type = " image/png " ;
break ;
case " .bmp " :
$type = " image/bmp " ;
break ;
default :
$type = " text/plain " ;
}
return $type ;
}
function get_mimetype_by_string ( $filedata )
{
if ( function_exists ( 'finfo_open' )) {
$f = finfo_open ();
return finfo_buffer ( $f , $filedata , FILEINFO_MIME_TYPE );
} else {
return false ;
}
}
/*
* Test , if the access to a group is allowed . This is true , if $testgroup is
* false or the groupname is in groups . txt
*
* $groupname : name of the group to be checked
*
* returns true , if access is allowed
*/
function testGroup ( $groupname )
{
global $CONFIG , $testgroup , $file_groups , $config_dir ;
$groupname = strtolower ( $groupname );
if ( $testgroup ) {
$gf = fopen ( $file_groups , " r " );
while ( ! feof ( $gf )) {
$read = trim ( line_read ( $gf ));
$read = preg_replace ( '/\t/' , ' ' , $read );
$read = strtolower ( $read );
$pos = strpos ( $read , " " );
if ( $pos != false ) {
if ( substr ( $read , 0 , $pos ) == trim ( $groupname ))
return true ;
} else {
if ( $read == trim ( $groupname ))
return true ;
}
}
fclose ( $gf );
if ( $groupname == $CONFIG [ 'spamgroup' ]) {
return true ;
} else {
/* Find section */
2024-09-28 18:15:51 +02:00
if ( get_section_by_group ( $groupname , false )) {
return true ;
} else {
return false ;
2024-06-05 13:05:17 +02:00
}
}
} else {
return true ;
}
}
function get_section_by_group ( $groupname , $all_sections = false )
{
global $CONFIG , $config_dir ;
$menulist = file ( $config_dir . " menu.conf " , FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES );
// Get first group in Newsgroups
$groupname = preg_split ( " /( | \ ,)/ " , $groupname , 2 );
$groupname = $groupname [ 0 ];
foreach ( $menulist as $menu ) {
if ( $menu [ 0 ] == '#' ) {
continue ;
}
$menuitem = explode ( ':' , $menu );
if ( $menuitem [ 1 ] == '0' ) {
if ( ! $all_sections ) {
continue ;
}
}
$section = " " ;
$gldata = file ( $config_dir . $menuitem [ 0 ] . " /groups.txt " );
foreach ( $gldata as $gl ) {
$group_name = preg_split ( " /( | \t )/ " , $gl , 2 );
if ( strtolower ( trim ( $groupname )) == strtolower ( trim ( $group_name [ 0 ]))) {
$section = $menuitem [ 0 ];
return $section ;
}
}
}
return false ;
}
function testGroups ( $newsgroups )
{
$groups = explode ( " , " , $newsgroups );
$count = count ( $groups );
$return = " " ;
$o = 0 ;
2024-09-28 18:15:51 +02:00
for ( $i = 0 ; $i < $count ; $i ++ ) {
2024-06-05 13:05:17 +02:00
if ( testgroup ( $groups [ $i ]) && ( ! function_exists ( " npreg_group_has_write_access " ) || npreg_group_has_write_access ( $groups [ $i ]))) {
if ( $o > 0 )
$return .= " , " ;
2024-09-28 18:15:51 +02:00
$o ++ ;
2024-06-05 13:05:17 +02:00
$return .= $groups [ $i ];
}
}
return ( $return );
}
/*
* read one line from the NNTP - server
*/
function line_read ( & $ns )
{
if ( $ns != false ) {
$t = str_replace ( " \n " , " " , str_replace ( " \r " , " " , fgets ( $ns , 1200 )));
return $t ;
}
}
/*
* Split an internet - address string into its parts . An address string could
* be for example :
* - user @ host . domain ( Realname )
* - " Realname " < user @ host . domain >
* - user @ host . domain
*
* The address will be split into user , host ( incl . domain ) and realname
*
* $adrstring : The string containing the address in internet format
* $defaulthost : The name of the host which should be returned if the
* address - string doesn ' t contain a hostname .
*
* returns an hash containing the fields " mailbox " , " host " and " personal "
*/
function address_decode ( $adrstring , $defaulthost )
{
$parsestring = trim ( $adrstring );
$len = strlen ( $parsestring );
$at_pos = strpos ( $parsestring , '@' ); // find @
$ka_pos = strpos ( $parsestring , " ( " ); // find (
$kz_pos = strpos ( $parsestring , ')' ); // find )
$ha_pos = strpos ( $parsestring , '<' ); // find <
$hz_pos = strpos ( $parsestring , '>' ); // find >
$space_pos = strpos ( $parsestring , ')' ); // find ' '
$email = " " ;
$mailbox = " " ;
$host = " " ;
$personal = " " ;
if ( $space_pos != false ) {
if (( $ka_pos != false ) && ( $kz_pos != false )) {
$personal = substr ( $parsestring , $ka_pos + 1 , $kz_pos - $ka_pos - 1 );
$email = trim ( substr ( $parsestring , 0 , $ka_pos - 1 ));
}
} else {
$email = $adrstring ;
}
if (( $ha_pos != false ) && ( $hz_pos != false )) {
$email = trim ( substr ( $parsestring , $ha_pos + 1 , $hz_pos - $ha_pos - 1 ));
$personal = substr ( $parsestring , 0 , $ha_pos - 1 );
}
if ( $at_pos != false ) {
$mailbox = substr ( $email , 0 , strpos ( $email , '@' ));
$host = substr ( $email , strpos ( $email , '@' ) + 1 );
} else {
$mailbox = $email ;
$host = $defaulthost ;
}
$personal = trim ( $personal );
if ( substr ( $personal , 0 , 1 ) == '"' )
$personal = substr ( $personal , 1 );
if ( substr ( $personal , strlen ( $personal ) - 1 , 1 ) == '"' )
$personal = substr ( $personal , 0 , strlen ( $personal ) - 1 );
$result [ " mailbox " ] = trim ( $mailbox );
$result [ " host " ] = trim ( $host );
if ( $personal != " " )
$result [ " personal " ] = $personal ;
$complete [] = $result ;
return ( $complete );
}
/*
* Read the groupnames from groups . txt , and get additional informations
* of the groups from the newsserver
*
* when load = 0 , returns cached group list
* when load = 1 , checks if the cache should be used , and returns nothing
* when force_reload = true , rebuilds group list cache
*/
function groups_read ( $server , $port , $load = 0 , $force_reload = false )
{
global $gl_age , $file_groups , $spooldir , $config_name , $cache_index ;
// is there a cached version, and is it actual enough?
$cachefile = $spooldir . '/' . $config_name . '-groups.dat' ;
// if cache is new enough, don't recreate it
clearstatcache ( TRUE , $cachefile );
if ( ! $force_reload && $load == 1 && file_exists ( $cachefile ) && ( filemtime ( $cachefile ) + $cache_index > time ())) {
return ;
}
if ( ! $force_reload && file_exists ( $cachefile ) && $load == 0 ) {
// cached file exists and is new enough, so lets read it out.
$file = fopen ( $cachefile , " r " );
$data = " " ;
while ( ! feof ( $file )) {
$data .= fgets ( $file , 1000 );
}
fclose ( $file );
$newsgroups = unserialize ( $data );
} else {
// force a refresh of the group list
$ns = nntp_open ( $server , $port );
if ( $ns == false )
return false ;
// $gf=fopen($file_groups,"r");
$gfdata = file ( $file_groups );
// if we want to mark groups with new articles with colors, we will later
// need the format of the overview
$overviewformat = thread_overview_read ( $ns );
foreach ( $gfdata as $gf ) {
$gruppe = new newsgroupType ();
$tmp = preg_replace ( '/\t/' , ' ' , trim ( $gf ));
if ( substr ( $tmp , 0 , 1 ) == " : " ) {
$gruppe -> text = substr ( $tmp , 1 );
$newsgroups [] = $gruppe ;
} elseif ( strlen ( $tmp ) > 0 ) {
// is there a description in groups.txt?
$gr = explode ( " " , $tmp , 2 );
if ( isset ( $gr [ 1 ])) { // Yes
$gruppe -> name = $gr [ 0 ];
$desc = $gr [ 1 ];
} else { // No
2024-09-28 18:15:51 +02:00
// no, get it from the newsserver.
2024-06-05 13:05:17 +02:00
$gruppe -> name = $tmp ;
if ( is_file ( $spooldir . '/' . $tmp . '-title' )) {
$response = file_get_contents ( $spooldir . '/' . $tmp . '-title' );
$desc = strrchr ( $response , " \t " );
} else {
$desc = " - " ;
}
}
if ( strcmp ( $desc , " " ) == 0 )
$desc = " - " ;
$gruppe -> description = $desc ;
fputs ( $ns , " GROUP " . $gruppe -> name . " \r \n " );
$t = explode ( " " , line_read ( $ns ));
if ( $t [ 0 ] == " 211 " )
$gruppe -> count = $t [ 1 ];
else {
nntp_close ( $ns );
$ns = nntp_open ( $server , $port );
if ( $ns == false )
return false ;
fputs ( $ns , " GROUP " . $gruppe -> name . " \r \n " );
$t = explode ( " " , line_read ( $ns ));
if ( $t [ 0 ] == " 211 " )
$gruppe -> count = $t [ 1 ];
else
continue ;
}
// mark group with new articles with colors
if ( $gl_age ) {
fputs ( $ns , 'XOVER ' . $t [ 3 ] . " \r \n " );
$tmp = explode ( " " , line_read ( $ns ));
if ( $tmp [ 0 ] == " 224 " ) {
$tmp = line_read ( $ns );
if ( $tmp != " . " ) {
$head = thread_overview_interpret ( $tmp , $overviewformat , $gruppe -> name );
$tmp = line_read ( $ns );
$gruppe -> age = $head -> date ;
}
}
}
if (( strcmp ( trim ( $gruppe -> name ), " " ) != 0 ) && ( substr ( $gruppe -> name , 0 , 1 ) != " # " ))
$newsgroups [] = $gruppe ;
}
}
nntp_close ( $ns );
// write the data to the cachefile
file_put_contents ( $cachefile , serialize ( $newsgroups ));
}
if ( $load == 0 ) {
return $newsgroups ;
} else {
return ;
}
}
function groups_show ( $gruppen )
{
global $gl_age , $frame , $spooldir , $config_dir , $logdir , $CONFIG , $OVERRIDES , $spoolnews ;
if ( $gruppen == false )
return ;
global $file_thread , $text_groups ;
$logfile = $logdir . '/debug.log' ;
2024-06-07 13:13:23 +02:00
if ( file_exists ( $config_dir . '/cache.inc.php' )) {
include $config_dir . '/cache.inc.php' ;
2024-06-05 13:05:17 +02:00
}
$c = count ( $gruppen );
$acttype = " keins " ;
echo '<table class="np_groups_table" cellspacing="0"><tr class="np_thread_head"><td width="45px" class="np_thread_head">' ;
echo 'Latest</td><td style="text-align: center;">Newsgroup</td><td width="8%" class="np_thread_head">Messages</td><td width="20%" class="np_thread_head" >Last Message</td></tr>' ;
$subs = array ();
$nonsubs = array ();
$user = null ;
// Get registered user settings
2024-07-29 14:20:50 +02:00
$cookie_mail_name = $_COOKIE [ 'mail_name' ];
2024-09-28 18:15:51 +02:00
if ( isset ( $_COOKIE [ 'mail_name' ]) && $_COOKIE [ 'mail_name' ] == $CONFIG [ 'anonusername' ]) {
2024-07-29 14:20:50 +02:00
unset ( $cookie_mail_name );
}
if ( isset ( $cookie_mail_name )) {
if ( $userdata = get_user_mail_auth_data ( $cookie_mail_name )) {
$userfile = $spooldir . '/' . strtolower ( $cookie_mail_name ) . '-articleviews.dat' ;
$user_config = unserialize ( file_get_contents ( $config_dir . '/userconfig/' . strtolower ( $cookie_mail_name ) . '.config' ));
2024-06-05 13:05:17 +02:00
}
}
2024-09-28 18:15:51 +02:00
for ( $i = 0 ; $i < $c ; $i ++ ) {
2024-06-05 13:05:17 +02:00
unset ( $groupdisplay );
$g = $gruppen [ $i ];
if ( isset ( $g -> text )) {
if ( $acttype != " text " ) {
$acttype = " text " ;
}
} else {
if ( $acttype != " group " ) {
$acttype = " group " ;
}
if ( ! isset ( $userdata [ $g -> name ])) {
if ( isset ( $user_config [ 'hide_unsub' ]) && $user_config [ 'hide_unsub' ] == 'hide' ) {
continue ;
}
}
unset ( $lastarticleinfo );
$found = 0 ;
// Get last article info from article database
// First check memcache
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
$memcache_key = $cache_key_prefix . '_' . 'lastarticleinfo-' . $g -> name ;
2024-06-05 13:05:17 +02:00
$groupfile = $spooldir . '/' . $g -> name . '-lastarticleinfo.dat' ;
2024-06-07 14:43:52 +02:00
$lar = cache_get ( $memcache_key , $memcacheD );
2024-06-05 13:05:17 +02:00
if ( $lar ) {
if ( $lastarticleinfo = unserialize ( $lar )) {
if ( $lastarticleinfo && file_exists ( $groupfile ) && filemtime ( $groupfile ) <= $lastarticleinfo [ 'date' ]) {
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . ' (cache hit) ' . $memcache_key , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
$found = 1 ;
} else {
unset ( $lastarticleinfo );
}
}
}
}
if ( ! isset ( $lastarticleinfo [ 'date' ])) {
if ( $CONFIG [ 'article_database' ] == '1' ) {
$database = $spooldir . '/' . $g -> name . '-articles.db3' ;
$article_dbh = article_db_open ( $database );
$article_query = $article_dbh -> prepare ( 'SELECT * FROM articles ORDER BY CAST(date AS int) DESC LIMIT 5' );
$article_query -> execute ();
while ( $row = $article_query -> fetch ()) {
if ( $row [ 'date' ] > time ()) {
continue ;
}
$found = 1 ;
break ;
}
$article_dbh = null ;
} else {
$database = $spooldir . '/articles-overview.db3' ;
$overview_dbh = overview_db_open ( $database );
$overview_query = $overview_dbh -> prepare ( 'SELECT * FROM overview WHERE newsgroup=:newsgroup ORDER BY CAST(date AS int) DESC LIMIT 5' );
$overview_query -> execute ([
'newsgroup' => $g -> name
]);
while ( $row = $overview_query -> fetch ()) {
if ( $row [ 'date' ] > time ()) {
continue ;
}
$found = 1 ;
break ;
}
$overview_dbh = null ;
}
if ( $found == 1 ) {
$lastarticleinfo = $row ;
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
2024-06-05 13:05:17 +02:00
touch ( $groupfile , $lastarticleinfo [ 'date' ]);
2024-06-07 14:43:52 +02:00
$nicole = cache_delete ( $memcache_key , $memcacheD );
cache_add ( $memcache_key , serialize ( $row ), $cache_ttl , $memcacheD );
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging ) {
2024-06-05 13:05:17 +02:00
if ( $nicole ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache update) $memcache_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
} else {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache write) $memcache_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
}
}
}
$new = false ;
$new_style_on = '' ;
$new_style_off = '' ;
if ( isset ( $userdata [ $g -> name ]) && ( $userdata [ $g -> name ] < $lastarticleinfo [ 'date' ])) {
$new_style_on = '<b><i>*' ;
$new_style_off = '</i></b>' ;
$new = true ;
}
/* Display group name and description */
if ( isset ( $userdata [ $g -> name ])) {
$lineclass = " np_thread_line2 " ;
} else {
$lineclass = " np_thread_line1 " ;
}
if ( $new ) {
$latest_link = '&time=' . $userdata [ $g -> name ];
} else {
$latest_link = '' ;
}
$groupdisplay = '<tr class="' . $lineclass . '"><td style="text-align: center;" class="' . $lineclass . '">' ;
$groupdisplay .= '<a href="overboard.php?thisgroup=' . _rawurlencode ( $g -> name ) . $latest_link . '">' ;
if (( isset ( $_SESSION [ 'theme' ])) && file_exists ( '../common/themes/' . $_SESSION [ 'theme' ] . '/images/latest.png' )) {
$latest_image = '../common/themes/' . $_SESSION [ 'theme' ] . '/images/latest.png' ;
} else {
$latest_image = '../common/images/latest.png' ;
}
if ( $new ) {
if (( isset ( $_SESSION [ 'theme' ])) && file_exists ( '../common/themes/' . $_SESSION [ 'theme' ] . '/images/new-articles.png' )) {
$latest_image = '../common/themes/' . $_SESSION [ 'theme' ] . '/images/new-articles.png' ;
} else {
$latest_image = '../common/images/new-articles.png' ;
}
$groupdisplay .= '<img src="' . $latest_image . '" title="New articles">' ;
} else {
$groupdisplay .= '<img src="' . $latest_image . '" title="Recent articles">' ;
}
$groupdisplay .= '</a>' ;
$groupdisplay .= '</td>' ;
$groupdisplay .= '<td class="' . $lineclass . '">' ;
$groupdisplay .= '<span class="np_group_line_text">' ;
$groupdisplay .= '<a ' ;
$groupdisplay .= 'target="' . $frame [ 'content' ] . '" ' ;
$groupdisplay .= 'href="' . $file_thread . '?group=' . urlencode ( $g -> name ) . '"><span class="np_group_line_text">' . $new_style_on . group_display_name ( $g -> name ) . $new_style_off . " </span></a> \n " ;
if ( $new ) {
echo '</i></b>' ;
}
if ( $g -> description != " - " ) {
$groupdisplay .= '</span><br><p class="np_group_desc">' . $g -> description . '</p>' ;
}
if ( isset ( $userdata [ $g -> name ])) {
$groupdisplay .= '</span><p class="np_group_user_tools">' ;
$groupdisplay .= '<a class="np_group_user_tools" href="index.php?unsub=' . urlencode ( $g -> name ) . '">(unsubscribe)</a>' ;
if ( $new ) {
$groupdisplay .= '<a class="np_group_user_tools" href="index.php?mark_read=' . urlencode ( $g -> name ) . '">(mark read)</a>' ;
}
$groupdisplay .= '</p' ;
} else {
if ( isset ( $user_config [ 'hide_unsub' ]) && $user_config [ 'hide_unsub' ] == 'hide' ) {
continue ;
}
}
/* Display article count */
$groupdisplay .= '</td><td class="' . $lineclass . '">' ;
2024-10-09 14:29:04 +02:00
if ( $gl_age && isset ( $g -> age ))
2024-06-05 13:05:17 +02:00
$datecolor = thread_format_date_color ( $g -> age );
$groupdisplay .= '<small>' ;
if ( $datecolor != " " )
$groupdisplay .= '<font color="' . $datecolor . '">' . $g -> count . '</font>' ;
else
$groupdisplay .= $g -> count ;
$groupdisplay .= '</small>' ;
/* Display latest article info */
$groupdisplay .= '</td><td class="' . $lineclass . '"><div class="np_last_posted_date">' ;
if ( $found == 1 ) {
2024-08-10 18:49:51 +02:00
$fromline = address_decode ( headerDecode ( $lastarticleinfo [ 'name' ]), " nowhere " );
if ( ! isset ( $fromline [ 0 ][ " host " ]))
$fromline [ 0 ][ " host " ] = " " ;
$name_from = $fromline [ 0 ][ " mailbox " ] . " @ " . $fromline [ 0 ][ " host " ];
if ( ! isset ( $fromline [ 0 ][ " personal " ])) {
$poster_name = $fromline [ 0 ][ " mailbox " ];
2024-06-05 13:05:17 +02:00
} else {
2024-08-10 18:49:51 +02:00
$poster_name = $fromline [ 0 ][ " personal " ];
2024-06-05 13:05:17 +02:00
}
2024-08-10 18:49:51 +02:00
if ( trim ( $poster_name ) == '' ) {
$fromoutput = explode ( " < " , html_entity_decode ( $c -> name ));
if ( strlen ( $fromoutput [ 0 ]) < 1 ) {
$poster_name = $fromoutput [ 1 ];
} else {
$poster_name = $fromoutput [ 0 ];
}
}
$lastarticleinfo [ 'name' ] = $poster_name ;
2024-06-05 13:05:17 +02:00
$groupdisplay .= get_date_interval ( date ( " D, j M Y H:i T " , $lastarticleinfo [ 'date' ]));
$groupdisplay .= '<table><tr><td>' ;
$groupdisplay .= '<font class="np_last_posted_date">by: ' ;
2024-08-10 18:49:51 +02:00
$groupdisplay .= create_name_link ( $lastarticleinfo [ 'name' ], $name_from );
2024-06-05 13:05:17 +02:00
$groupdisplay .= '</td></tr></table>' ;
} else {
unset ( $lastarticleinfo );
}
}
if ( isset ( $groupdisplay )) {
$groupdisplay .= " \n " ;
flush ();
if ( isset ( $userdata [ $g -> name ])) {
$subs [] = $groupdisplay ;
} else {
$nonsubs [] = $groupdisplay ;
}
}
}
foreach ( $subs as $sub ) {
echo $sub ;
}
foreach ( $nonsubs as $nonsub ) {
echo $nonsub ;
}
echo " </table><table> " ;
echo '<tr><td class="np_show_hide_toggle">' ;
if ( isset ( $user_config [ 'hide_unsub' ]) && $user_config [ 'hide_unsub' ] == 'hide' ) {
echo ' Unsubscribed groups are HIDDEN.' ;
echo ' Select groups from <a href="/common/grouplist.php">Grouplist</a> to add groups' ;
}
if ( isset ( $userdata )) {
show_groups_hide_toggle ();
}
echo '</td></tr>' ;
echo '</table>' ;
}
function show_groups_hide_toggle ()
{
global $user_config ;
echo '<form method="post" action="' . $_SERVER [ 'REQUEST_URI' ] . '">' ;
echo ' Unsubscribed Groups: ' ;
if ( $user_config [ 'hide_unsub' ] == 'hide' ) {
echo '<input type="radio" name="hide_unsub" value="show">Show' ;
echo ' ' ;
echo '<input type="radio" name="hide_unsub" value="hide" checked>Hide' ;
echo ' ' ;
} else {
echo '<input type="radio" name="hide_unsub" value="show" checked>Show' ;
echo ' ' ;
echo '<input type="radio" name="hide_unsub" value="hide">Hide' ;
echo ' ' ;
}
echo '<input class="np_button_link" type="submit" value="Reload" name="reload">' ;
echo '</form >' ;
}
/*
* print the group names from an array to the webpage
*/
function groups_show_frames ( $gruppen )
{
global $gl_age , $frame , $spooldir ;
if ( $gruppen == false )
return ;
global $file_thread , $text_groups ;
$c = count ( $gruppen );
echo '<div class="np_index_groupblock">' ;
$acttype = " keins " ;
2024-09-28 18:15:51 +02:00
for ( $i = 0 ; $i < $c ; $i ++ ) {
2024-06-05 13:05:17 +02:00
$g = $gruppen [ $i ];
if ( isset ( $g -> text )) {
if ( $acttype != " text " ) {
$acttype = " text " ;
if ( $i > 0 )
echo '</div>' ;
echo '<div class="np_index_grouphead">' ;
}
echo $g -> text ;
} else {
if ( $acttype != " group " ) {
$acttype = " group " ;
if ( $i > 0 )
echo '</div>' ;
echo '<div class="np_index_groupblock">' ;
}
echo '<div class="np_index_group">' ;
echo '<b><a ' ;
echo 'target="' . $frame [ 'content' ] . '" ' ;
echo 'href="' . $file_thread . '?group=' . _rawurlencode ( $g -> name ) . '">' . group_display_name ( $g -> name ) . " </a></b> \n " ;
if ( $gl_age )
$datecolor = thread_format_date_color ( $g -> age );
echo '<small>(' ;
if ( $datecolor != " " )
echo '<font color="' . $datecolor . '">' . $g -> count . '</font>' ;
else
echo $g -> count ;
echo ')</small>' ;
if ( $g -> description != " - " )
echo '<br><small>' . $g -> description . '</small>' ;
echo '</div>' ;
}
echo " \n " ;
flush ();
}
echo " </div></div> \n " ;
}
/*
* gets a list of available articles in the group $groupname
*/
/*
* function getArticleList ( & $ns , $groupname ) {
* fputs ( $ns , " LISTGROUP $groupname \r \n " );
* $line = line_read ( $ns );
* $line = line_read ( $ns );
* while ( strcmp ( $line , " . " ) != 0 ) {
* $articleList [] = trim ( $line );
* $line = line_read ( $ns );
* }
* if ( ! isset ( $articleList )) $articleList = " - " ;
* return $articleList ;
* }
*/
/*
* Decode quoted - printable or base64 encoded headerlines
*
* $value : The to be decoded line
*
* returns the decoded line
*/
function headerDecode ( $value )
{
$value = preg_replace_callback ( '/(=\?[^\?]+\?Q\?)([^\?]+)(\?=)/i' , function ( $matches ) {
return $matches [ 1 ] . str_replace ( '_' , '=20' , $matches [ 2 ]) . $matches [ 3 ];
}, $value );
return mb_decode_mimeheader ( $value );
}
/*
* calculates an Unix timestamp out of a Date - Header in an article
*
* $value : Value of the Date : header
*
* returns an Unix timestamp
*/
function getTimestamp ( $value )
{
global $CONFIG ;
return strtotime ( $value );
}
function parse_header ( $hdr , $number = " " )
{
2024-09-28 18:15:51 +02:00
for ( $i = count ( $hdr ) - 1 ; $i > 0 ; $i -- )
2024-06-05 13:05:17 +02:00
if ( preg_match ( " /^( \x09 | \x20 )/ " , $hdr [ $i ]))
$hdr [ $i - 1 ] = $hdr [ $i - 1 ] . " " . ltrim ( $hdr [ $i ]);
$header = new headerType ();
$header -> isAnswer = false ;
2024-09-28 18:15:51 +02:00
for ( $count = 0 ; $count < count ( $hdr ); $count ++ ) {
2024-06-05 13:05:17 +02:00
$variable = substr ( $hdr [ $count ], 0 , strpos ( $hdr [ $count ], " " ));
$value = trim ( substr ( $hdr [ $count ], strpos ( $hdr [ $count ], " " ) + 1 ));
switch ( strtolower ( $variable )) {
case " from: " :
$fromline = address_decode ( headerDecode ( $value ), " nowhere " );
if ( ! isset ( $fromline [ 0 ][ " host " ]))
$fromline [ 0 ][ " host " ] = " " ;
$header -> from = $fromline [ 0 ][ " mailbox " ] . " @ " . $fromline [ 0 ][ " host " ];
$header -> username = $fromline [ 0 ][ " mailbox " ];
if ( ! isset ( $fromline [ 0 ][ " personal " ])) {
$header -> name = " " ;
} else {
$header -> name = $fromline [ 0 ][ " personal " ];
}
break ;
case " message-id: " :
$header -> id = $value ;
break ;
case " subject: " :
$header -> subject = headerDecode ( $value );
break ;
case " newsgroups: " :
$header -> newsgroups = $value ;
break ;
case " organization: " :
$header -> organization = headerDecode ( $value );
break ;
case " content-transfer-encoding: " :
$header -> content_transfer_encoding = trim ( strtolower ( $value ));
break ;
case " content-disposition: " :
$getname = preg_split ( " /name \ =/ " , $value , 2 );
if ( isset ( $getname [ 1 ])) {
$header -> content_type_name = array (
$getname [ 1 ]
);
}
break ;
case " content-type: " :
$header -> content_type = array ();
$subheader = explode ( " ; " , $value );
$header -> content_type [ 0 ] = strtolower ( trim ( $subheader [ 0 ]));
2024-09-28 18:15:51 +02:00
for ( $i = 1 ; $i < count ( $subheader ); $i ++ ) {
2024-06-05 13:05:17 +02:00
$gleichpos = strpos ( $subheader [ $i ], " = " );
if ( $gleichpos ) {
$subvariable = trim ( substr ( $subheader [ $i ], 0 , $gleichpos ));
$subvalue = trim ( substr ( $subheader [ $i ], $gleichpos + 1 ));
if (( $subvalue [ 0 ] == '"' ) && ( $subvalue [ strlen ( $subvalue ) - 1 ] == '"' ))
$subvalue = substr ( $subvalue , 1 , strlen ( $subvalue ) - 2 );
switch ( $subvariable ) {
case " charset " :
$header -> content_type_charset = array (
strtolower ( $subvalue )
);
break ;
case " name " :
$header -> content_type_name = array (
$subvalue
);
break ;
case " boundary " :
$header -> content_type_boundary = $subvalue ;
break ;
case " format " :
$header -> content_type_format = array (
$subvalue
);
}
}
}
break ;
case " references: " :
$ref = trim ( $value );
while ( strpos ( $ref , " > < " ) != false ) {
$header -> references [] = substr ( $ref , 0 , strpos ( $ref , " " ));
$ref = substr ( $ref , strpos ( $ref , " > < " ) + 2 );
}
$header -> references [] = trim ( $ref );
break ;
case " date: " :
$header -> date = getTimestamp ( trim ( $value ));
break ;
case " followup-to: " :
$header -> followup = trim ( $value );
break ;
case " x-newsreader: " :
case " x-mailer: " :
case " x-rslight-to: " :
$header -> rslight_to = trim ( $value );
break ;
case " x-rslight-site: " :
$header -> rslight_site = trim ( $value );
break ;
case " user-agent: " :
$header -> user_agent = trim ( $value );
break ;
case " x-face: " : // not ready
2024-09-28 18:15:51 +02:00
// echo "<p>-".base64_decode($value)."-</p>";
2024-06-05 13:05:17 +02:00
break ;
case " x-no-archive: " :
$header -> xnoarchive = strtolower ( trim ( $value ));
}
}
if ( ! isset ( $header -> content_type [ 0 ]))
$header -> content_type [ 0 ] = " text/plain " ;
if ( ! isset ( $header -> content_transfer_encoding ))
$header -> content_transfer_encoding = " 8bit " ;
if ( $number != " " )
$header -> number = $number ;
return $header ;
}
/*
* convert the charset of a text
*/
function recode_charset ( $text , $source = false , $dest = false )
{
global $iconv_enable , $www_charset ;
if ( $dest == false )
$dest = $www_charset ;
if (( $iconv_enable ) && ( $source != false )) {
$return = iconv ( $source , $dest . " //TRANSLIT " , $text );
if ( $return != " " )
return $return ;
else
return $text ;
} else {
return $text ;
}
}
function decode_body ( $body , $encoding )
{
$bodyzeile = " " ;
switch ( $encoding ) {
case " base64 " :
$body = base64_decode ( $body );
break ;
case " quoted-printable " :
$body = Quoted_printable_decode ( $body );
$body = str_replace ( " = \n " , " " , $body );
2024-09-28 18:15:51 +02:00
// default:
// $body=str_replace("\n..\n","\n.\n",$body);
2024-06-05 13:05:17 +02:00
}
return $body ;
}
/*
* makes URLs clickable
*
* $text : A text - line probably containing links .
*
* the function returns the text - line with HTML - Links to the links or
* email - adresses .
*/
function html_parse ( $text )
{
global $frame_externallink ;
if (( isset ( $frame_externallink )) && ( $frame_externallink != " " )) {
$target = ' TARGET="' . $frame_externallink . '" ' ;
} else {
$target = ' ' ;
}
$ntext = " " ;
// split every line into it's words
$words = explode ( " " , $text );
$n = count ( $words );
$is_link = 0 ;
2024-09-28 18:15:51 +02:00
for ( $i = 0 ; $i < $n ; $i ++ ) {
2024-06-05 13:05:17 +02:00
$word = $words [ $i ];
// add the spaces between the words
if ( $i > 0 )
$ntext .= " " ;
$ntext .= $word ;
}
return ( $ntext );
}
2024-10-10 14:04:24 +02:00
function rewrite_body ( $text ) {
global $config_dir ;
if ( file_exists ( $config_dir . '/rewrite_body.inc.php' )) {
include ( $config_dir . '/rewrite_body.inc.php' );
}
return $text ;
}
2024-06-05 13:05:17 +02:00
function display_links_in_body ( $text )
{
global $config_dir ;
preg_match_all ( '/(https?|ftp|scp|news|gopher|gemini|telnet):\/\/[a-zA-Z0-9.?%=\-\+\;\:\,\~\@\!\(\)\$\#&_\/]+/' , $text , $matches );
$isquote = false ;
if ( strpos ( $text , " > " ) == 0 ) {
$isquote = true ;
echo '<blockquote class="np_article_quote">' ;
}
foreach ( $matches [ 0 ] as $match ) {
if ( ! $match ) {
continue ;
}
// Get rid of unwanted trailing characters
$match = rtrim ( htmlspecialchars_decode ( $match ), '/>,"' );
$match = htmlspecialchars ( $match );
$linkurl = preg_replace ( " /(<|>)/ " , '' , htmlspecialchars_decode ( $match ));
$url = preg_replace ( " /(<|>)/ " , ' ' , $match );
$pattern = preg_quote ( $url );
$pattern = " ! $pattern ! " ;
$text = preg_replace ( $pattern , '<a href="' . $linkurl . '" rel="nofollow" target="_blank">' . $url . '</a>' , $text , 1 );
}
2024-10-10 14:04:24 +02:00
$text = rewrite_body ( $text );
2024-06-05 13:05:17 +02:00
echo $text ;
if ( $isquote ) {
echo '</blockquote>' ;
}
}
/*
* read the header of an article in plaintext into an array
* $articleNumber can be the number of an article or its message - id .
*/
function readPlainHeader ( & $ns , $group , $articleNumber )
{
fputs ( $ns , " GROUP $group\r\n " );
$line = line_read ( $ns );
fputs ( $ns , " HEAD $articleNumber\r\n " );
$line = line_read ( $ns );
if ( substr ( $line , 0 , 3 ) != " 221 " ) {
echo $text_error [ " article_not_found " ];
$header = false ;
} else {
$line = line_read ( $ns );
$body = " " ;
while ( strcmp ( trim ( $line ), " . " ) != 0 ) {
$body .= $line . " \n " ;
$line = line_read ( $ns );
}
return explode ( " \n " , str_replace ( " \r \n " , " \n " , $body ));
}
}
/*
* cancel an article on the newsserver
*
* DO NOT USE THIS FUNCTION , IF YOU DON ' T KNOW WHAT YOU ARE DOING !
*
* $ns : The handler of the NNTP - Connection
* $group : The group of the article
* $id : the Number of the article inside the group or the message - id
*/
function message_cancel ( $subject , $from , $newsgroups , $ref , $body , $id )
{
global $server , $port , $send_poster_host , $CONFIG , $text_error ;
global $www_charset ;
flush ();
$ns = nntp_open ( $server , $port );
if ( $ns != false ) {
fputs ( $ns , " POST \r \n " );
$weg = line_read ( $ns );
fputs ( $ns , 'Subject: ' . quoted_printable_encode ( $subject ) . " \r \n " );
fputs ( $ns , 'From: ' . $from . " \r \n " );
fputs ( $ns , 'Newsgroups: ' . $newsgroups . " \r \n " );
fputs ( $ns , " Mime-Version: 1.0 \r \n " );
fputs ( $ns , " Content-Type: text/plain; charset= " . $www_charset . " \r \n " );
fputs ( $ns , " Content-Transfer-Encoding: 8bit \r \n " );
if ( $send_poster_host )
fputs ( $ns , 'X-HTTP-Posting-Host: ' . gethostbyaddr ( getenv ( " REMOTE_ADDR " )) . " \r \n " );
if ( $ref != false )
fputs ( $ns , 'References: ' . $ref . " \r \n " );
if ( isset ( $CONFIG [ 'organization' ]))
fputs ( $ns , 'Organization: ' . quoted_printable_encode ( $CONFIG [ 'organization' ]) . " \r \n " );
fputs ( $ns , " Control: cancel " . $id . " \r \n " );
$body = str_replace ( " \n . \r " , " \n .. \r " , $body );
$body = str_replace ( " \r " , '' , $body );
$b = explode ( " \n " , $body );
$body = " " ;
2024-09-28 18:15:51 +02:00
for ( $i = 0 ; $i < count ( $b ); $i ++ ) {
2024-06-05 13:05:17 +02:00
if (( strpos ( substr ( $b [ $i ], 0 , strpos ( $b [ $i ], " " )), " > " ) != false ) | ( strcmp ( substr ( $b [ $i ], 0 , 1 ), " > " ) == 0 )) {
$body .= textwrap ( stripSlashes ( $b [ $i ]), 78 , " \r \n " ) . " \r \n " ;
} else {
$body .= textwrap ( stripSlashes ( $b [ $i ]), 74 , " \r \n " ) . " \r \n " ;
}
}
fputs ( $ns , " \r \n " . $body . " \r \n . \r \n " );
$message = line_read ( $ns );
nntp_close ( $ns );
} else {
$message = $text_error [ " post_failed " ];
}
return $message ;
}
function rslight_encrypt ( $data , $key )
{
$encryption_key = base64_decode ( $key );
$iv = openssl_random_pseudo_bytes ( openssl_cipher_iv_length ( 'aes-256-cbc' ));
$encrypted = openssl_encrypt ( $data , 'aes-256-cbc' , $encryption_key , 0 , $iv );
return base64_encode ( $encrypted . '::' . $iv );
}
function _rawurlencode ( $string )
{
$string = rawurlencode ( str_replace ( '+' , '%2B' , $string ));
return $string ;
}
function _rawurldecode ( $string )
{
$string = rawurldecode ( str_replace ( '%2B' , '+' , $string ));
return $string ;
}
function rslight_decrypt ( $data , $key )
{
$encryption_key = base64_decode ( $key );
2024-09-28 18:15:51 +02:00
list ( $encrypted_data , $iv ) = explode ( '::' , base64_decode ( $data ), 2 );
2024-06-05 13:05:17 +02:00
return openssl_decrypt ( $encrypted_data , 'aes-256-cbc' , $encryption_key , 0 , $iv );
}
function group_display_name ( $gname )
{
global $config_dir ;
$namelist = file ( $config_dir . " rename.conf " , FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES );
foreach ( $namelist as $name ) {
if ( $name [ 0 ] == '#' ) {
continue ;
}
$nameitem = explode ( ':' , $name );
if ( ! strcmp ( trim ( $nameitem [ 0 ]), trim ( $gname ))) {
return $nameitem [ 1 ];
}
}
return $gname ;
}
2024-09-28 18:15:51 +02:00
function verify_logged_in ( $name )
{
2024-07-25 15:09:36 +02:00
global $CONFIG , $auth_log , $debug_log ;
2024-07-21 15:19:35 +02:00
$logged_in = false ;
$ip_pass = false ;
2024-07-25 15:09:36 +02:00
2024-09-28 18:15:51 +02:00
// /* This may cause issues if cookies or javascript disabled
// if(!isset($_COOKIE['mail_name']) || trim($_COOKIE['mail_name'] == '')) {
// return false;
// }
2024-09-05 14:42:28 +02:00
2024-07-25 15:09:36 +02:00
// For checking session expire stuff
2024-09-28 18:15:51 +02:00
if ( ! isset ( $_SESSION [ 'start_stamp' ])) {
2024-07-25 15:09:36 +02:00
$_SESSION [ 'start_stamp' ] = time ();
}
2024-07-25 22:41:57 +02:00
2024-10-08 17:08:04 +02:00
if ( ! isset ( $_SESSION [ 'start_address' ])) {
2024-07-23 13:37:31 +02:00
$_SESSION [ 'start_address' ] = $_SERVER [ 'REMOTE_ADDR' ];
2024-07-21 15:19:35 +02:00
$ip_pass = true ;
2024-07-25 15:09:36 +02:00
file_put_contents ( $auth_log , " \n " . logging_prefix () . " IP address SET for: " . $name , FILE_APPEND );
2024-07-21 15:19:35 +02:00
} else {
if ( $_SERVER [ 'REMOTE_ADDR' ] != $_SESSION [ 'start_address' ]) {
$ip_pass = false ;
2024-07-21 15:30:13 +02:00
file_put_contents ( $auth_log , " \n " . logging_prefix () . " IP address changed for: " . $name , FILE_APPEND );
2024-07-21 15:19:35 +02:00
} else {
$ip_pass = true ;
2024-07-21 15:30:13 +02:00
file_put_contents ( $auth_log , " \n " . logging_prefix () . " IP address OK for: " . $name , FILE_APPEND );
2024-07-21 15:19:35 +02:00
}
}
if ( $ip_pass && ( isset ( $_SESSION [ 'pass' ]) && $_SESSION [ 'pass' ] === true )) {
$logged_in = true ;
file_put_contents ( $auth_log , " \n " . logging_prefix () . " SESSION PASS OK for: " . $name , FILE_APPEND );
} else {
$logged_in = false ;
2024-07-25 15:09:36 +02:00
file_put_contents ( $auth_log , " \n " . logging_prefix () . " SESSION PASS false or expired for: " . $name , FILE_APPEND );
2024-07-21 15:19:35 +02:00
}
if ( $CONFIG [ 'anonuser' ] == '1' ) {
$logged_in = false ;
}
2024-09-28 18:15:51 +02:00
return $logged_in ;
2024-07-21 15:19:35 +02:00
}
2024-09-28 18:15:51 +02:00
function set_user_logged_in_cookies ( $name , $keys )
{
2024-07-19 15:53:09 +02:00
2024-07-30 15:31:32 +02:00
global $debug_log , $CONFIG ;
2024-07-21 15:19:35 +02:00
$name = trim ( $name );
$name_lc = strtolower ( $name );
2024-09-28 18:15:51 +02:00
if ( $name == $CONFIG [ 'anonusername' ]) {
2024-07-30 15:31:32 +02:00
return false ;
}
2024-09-28 18:15:51 +02:00
if ( ! get_user_config ( $name_lc , 'encryptionkey' )) {
2024-07-19 15:53:09 +02:00
$key = openssl_random_pseudo_bytes ( 44 );
2024-07-21 15:19:35 +02:00
set_user_config ( $name_lc , 'encryptionkey' , base64_encode ( $key ));
2024-07-19 15:53:09 +02:00
file_put_contents ( $debug_log , " \n " . logging_prefix () . " Created encryptionkey for: " . $name , FILE_APPEND );
}
2024-07-21 15:19:35 +02:00
$auth_expire = 14400 ;
$authkey = password_hash ( $name_lc . $keys [ 0 ] . get_user_config ( $name , 'encryptionkey' ), PASSWORD_DEFAULT );
$pkey = hash ( 'crc32' , get_user_config ( $name , 'encryptionkey' ));
set_user_config ( strtolower ( $name ), " pkey " , $pkey );
$_SESSION [ 'pass' ] = true ;
2024-07-17 15:33:48 +02:00
?>
2024-09-28 18:15:51 +02:00
< script type = " text/javascript " >
if ( navigator . cookieEnabled )
var authcookie = " <?php echo $authkey ; ?> " ;
var savename = " <?php echo stripslashes( $name ); ?> " ;
var auth_expire = " <?php echo $auth_expire ; ?> " ;
var name_expire = " 7776000 " ;
var pkey = " <?php echo $pkey ; ?> " ;
document . cookie = " mail_auth= " + authcookie + " ; max-age= " + auth_expire + " ; path=/ " ;
document . cookie = " mail_name= " + savename + " ; max-age= " + name_expire + " ; path=/ " ;
document . cookie = " pkey= " + pkey + " ; max-age= " + name_expire + " ; path=/ " ;
</ script >
2024-07-17 15:33:48 +02:00
< ? php
2024-07-30 15:31:32 +02:00
return true ;
2024-07-17 15:33:48 +02:00
}
2024-07-21 17:11:32 +02:00
function check_bbs_auth ( $username , $password , $sockip = null )
2024-06-05 13:05:17 +02:00
{
2024-07-17 17:27:49 +02:00
global $config_dir , $spooldir , $CONFIG , $auth_log ;
2024-06-05 13:05:17 +02:00
2024-07-17 17:27:49 +02:00
$logfile = $auth_log ;
2024-06-05 13:05:17 +02:00
if ( $username == '' && $password == '' ) {
return false ;
}
$workpath = $config_dir . " users/ " ;
$username = trim ( strtolower ( $username ));
$userFilename = $workpath . $username ;
$banned_list = file ( $config_dir . '/banned_users.conf' );
$keyFilename = $config_dir . " /userconfig/ " . $username ;
foreach ( $banned_list as $banned ) {
if ( $banned [ 0 ] == '#' )
continue ;
if ( strtolower ( trim ( $username )) == strtolower ( trim ( $banned ))) {
2024-07-21 17:11:32 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " AUTH Failed for: " . $username . ' (user is banned)' , FILE_APPEND );
2024-06-05 13:05:17 +02:00
return false ;
}
}
// Create accounts for $anonymous and $CONFIG['server_auth_user'] if not exist
if ( $username == strtolower ( $CONFIG [ 'anonusername' ])) {
if ( filemtime ( $config_dir . " rslight.inc.php " ) > filemtime ( $userFilename )) {
if ( $userFileHandle = fopen ( $userFilename , 'w+' )) {
fwrite ( $userFileHandle , password_hash ( $CONFIG [ 'anonuserpass' ], PASSWORD_DEFAULT ));
fclose ( $userFileHandle );
}
}
}
if ( $username == strtolower ( $CONFIG [ 'server_auth_user' ])) {
if ( filemtime ( $config_dir . " rslight.inc.php " ) > filemtime ( $userFilename )) {
if ( $userFileHandle = fopen ( $userFilename , 'w+' )) {
fwrite ( $userFileHandle , password_hash ( $CONFIG [ 'server_auth_pass' ], PASSWORD_DEFAULT ));
fclose ( $userFileHandle );
}
}
}
if ( trim ( $username ) == strtolower ( $CONFIG [ 'anonusername' ]) && $CONFIG [ 'anonuser' ] != true ) {
2024-07-21 17:11:32 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " AUTH Failed for: " . $username . ' (' . $CONFIG [ " anonusername " ] . ' is disabled)' , FILE_APPEND );
2024-06-05 13:05:17 +02:00
return FALSE ;
}
if ( $userFileHandle = fopen ( $userFilename , 'r' )) {
$userFileInfo = fread ( $userFileHandle , filesize ( $userFilename ));
fclose ( $userFileHandle );
if ( password_verify ( $password , $userFileInfo )) {
touch ( $userFilename );
$ok = TRUE ;
} else {
2024-09-28 18:15:51 +02:00
if ( trim ( $password ) == '' ) {
2024-07-21 17:11:32 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " AUTH Failed for: " . $username . ' (no password)' , FILE_APPEND );
2024-07-20 17:01:24 +02:00
} else {
2024-07-21 17:11:32 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " AUTH Failed for: " . $username . ' (password incorrect)' , FILE_APPEND );
2024-07-20 17:01:24 +02:00
}
2024-06-05 13:05:17 +02:00
return FALSE ;
}
} else {
$ok = FALSE ;
}
if ( $ok ) {
2024-07-26 17:31:40 +02:00
if ( $username != $CONFIG [ 'server_auth_user' ]) {
2024-07-21 17:11:32 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " AUTH OK for: " . $username , FILE_APPEND );
2024-07-26 17:31:40 +02:00
if ( isset ( $_SESSION )) {
$_SESSION [ 'start_address' ] = $_SERVER [ 'REMOTE_ADDR' ];
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " SET IP address for: " . $username , FILE_APPEND );
}
2024-07-22 11:41:02 +02:00
}
2024-06-05 13:05:17 +02:00
return TRUE ;
} else {
if ( isset ( $CONFIG [ 'auto_create' ]) && $CONFIG [ 'auto_create' ] == true ) {
if ( $userFileHandle = @ fopen ( $userFilename , 'w+' )) {
fwrite ( $userFileHandle , password_hash ( $password , PASSWORD_DEFAULT ));
fclose ( $userFileHandle );
chmod ( $userFilename , 0666 );
}
$newkey = base64_encode ( openssl_random_pseudo_bytes ( 44 ));
if ( $userFileHandle = @ fopen ( $keyFilename , 'w+' )) {
fwrite ( $userFileHandle , 'encryptionkey:' . $newkey );
fclose ( $userFileHandle );
chmod ( $userFilename , 0666 );
}
2024-07-21 17:11:32 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " AUTH OK for: " . $username . ' (auto created user)' , FILE_APPEND );
2024-07-23 13:37:31 +02:00
$_SESSION [ 'start_address' ] = $_SERVER [ 'REMOTE_ADDR' ];
2024-06-05 13:05:17 +02:00
return TRUE ;
} else {
2024-07-21 17:11:32 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix ( $sockip ) . " AUTH Failed for: " . $username , FILE_APPEND );
2024-06-05 13:05:17 +02:00
return FALSE ;
}
}
}
function check_encryption_groups ( $request )
{
global $config_dir ;
$groupsFilename = $config_dir . " encryption_ok.txt " ;
if ( $groupsFileHandle = @ fopen ( $groupsFilename , 'r' )) {
while ( ! feof ( $groupsFileHandle )) {
$buffer = fgets ( $groupsFileHandle );
$buffer = str_replace ( array (
" \r " ,
" \n "
), '' , $buffer );
if ( ! strcmp ( $buffer , $request )) {
fclose ( $groupsFileHandle );
return TRUE ;
}
}
fclose ( $groupsFileHandle );
} else {
return FALSE ;
}
}
function set_user_config ( $username , $request , $newval )
{
global $config_dir ;
$userconfigpath = $config_dir . " userconfig/ " ;
$username = strtolower ( $username );
$userFilename = $userconfigpath . $username ;
$userData = file ( $userFilename , FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES );
$userFileHandle = fopen ( $userFilename , 'w' );
$found = 0 ;
foreach ( $userData as $data ) {
if ( strpos ( $data , $request . ':' ) !== FALSE ) {
fputs ( $userFileHandle , $request . ':' . $newval . " \r \n " );
$found = 1 ;
} else {
fputs ( $userFileHandle , $data . " \r \n " );
}
}
if ( $found == 0 ) {
fputs ( $userFileHandle , $request . ':' . $newval . " \r \n " );
}
fclose ( $userFileHandle );
return ;
}
function get_user_config ( $username , $request )
{
global $config_dir ;
$userconfigpath = $config_dir . " userconfig/ " ;
$username = strtolower ( $username );
$userFilename = $userconfigpath . $username ;
if ( $userFileHandle = @ fopen ( $userFilename , 'r' )) {
while ( ! feof ( $userFileHandle )) {
$buffer = fgets ( $userFileHandle );
if ( strpos ( $buffer , $request . ':' ) !== FALSE ) {
$userdataline = $buffer ;
fclose ( $userFileHandle );
$userdatafound = explode ( ':' , $userdataline );
return trim ( $userdatafound [ 1 ]);
}
}
fclose ( $userFileHandle );
return FALSE ;
} else {
return FALSE ;
}
}
function is_multibyte ( $s )
{
return mb_strlen ( $s , 'utf-8' ) < strlen ( $s );
}
function check_spam ( $subject , $from , $newsgroups , $ref , $body , $msgid , $useheaders = false )
{
global $msgid_generate , $msgid_fqdn , $spooldir , $logdir ;
global $CONFIG ;
$spamdir = $spooldir . '/spam' ;
if ( ! is_dir ( $spamdir )) {
mkdir ( $spamdir );
}
$logfile = $logdir . '/spam.log' ;
$spamfile = tempnam ( $spooldir , 'spam-' );
if ( $useheaders ) {
// Add headers
$head = '' ;
if ( trim ( $subject ) != '' ) {
$head .= 'Subject: ' . $subject . " \r \n " ;
}
if ( trim ( $from ) != '' ) {
$head .= 'From: ' . $from . " \r \n " ;
}
if ( trim ( $newsgroups ) != '' ) {
$head .= 'Newsgroups: ' . $newsgroups . " \r \n " ;
}
if ( trim ( $ref ) != '' ) {
$head .= 'References: ' . $ref . " \r \n " ;
}
if ( trim ( $msgid ) != '' ) {
$head .= 'Message-ID: ' . $msgid . " \r \n " ;
}
$message = $head . " \r \n " . $body ;
} else {
$message = $body ;
}
file_put_contents ( $spamfile , $message );
$spamcommand = $CONFIG [ 'spamc' ] . ' -E < ' . $spamfile ;
ob_start ();
passthru ( $spamcommand , $res );
$spamresult = ob_get_contents ();
ob_end_clean ();
$spam_fail = 1 ;
foreach ( explode ( PHP_EOL , $spamresult ) as $line ) {
$line = str_replace ( array (
" \n \r " ,
" \n " ,
" \r "
), '' , $line );
if ( strpos ( $line , 'X-Spam-Checker-Version:' ) !== FALSE ) {
$spamcheckerversion = $line ;
$spam_fail = 0 ;
}
if ( strpos ( $line , 'X-Spam-Level:' ) !== FALSE ) {
$spamlevel = $line ;
}
if (( strpos ( $line , " X-Spam-Flag: YES " ) === 0 ) && ( $res !== 1 )) {
$res = 1 ;
}
}
unlink ( $spamfile );
if ( $res === 1 ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " spamc: \t SPAM \t " . $msgid . " \t " . $newsgroups . " \t " . preg_replace ( '/\t/' , ' ' , $from ), FILE_APPEND );
2024-06-05 13:05:17 +02:00
file_put_contents ( $spamdir . '/' . $msgid , $spamresult );
} else {
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " spamc: \t HAM \t " . $msgid . " \t " . $newsgroups . " \t " . preg_replace ( '/\t/' , ' ' , $from ), FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
return array (
'res' => $res ,
'spamresult' => $spamresult ,
'spamcheckerversion' => $spamcheckerversion ,
'spamlevel' => $spamlevel ,
'spam_fail' => $spam_fail
);
}
2024-09-28 18:15:51 +02:00
function logging_prefix ( $sockip = null )
{
2024-07-18 14:20:38 +02:00
global $client_ip_address ;
2024-09-28 18:15:51 +02:00
if ( $sockip ) {
if ( preg_match ( " / \ ./ " , $sockip )) {
2024-07-22 11:17:00 +02:00
$ipv4_addr = preg_split ( " / \ :/ " , $sockip );
$client_ip = $ipv4_addr [ 0 ];
} else {
2024-07-21 17:11:32 +02:00
$ipv6_addr = explode ( " ] " , $sockip );
$client_ip = substr ( $ipv6_addr [ 0 ], 1 );
}
} else {
$client_ip = $client_ip_address ;
}
2024-09-28 18:15:51 +02:00
if ( trim ( $client_ip == '' )) {
2024-07-18 14:20:38 +02:00
return format_log_date ();
} else {
2024-07-21 17:11:32 +02:00
return format_log_date () . " [ " . $client_ip . " ] " ;
2024-07-18 14:20:38 +02:00
}
}
2024-09-28 23:56:42 +02:00
function repair_broken_group ( $group )
{
global $debug_log , $spooldir ;
$rslight_file = $spooldir . '/' . $group . '-rslight_info.txt' ;
$newsportal_file = $spooldir . '/' . $group . '-info.txt' ;
if ( file_exists ( $rslight_file ) && file_exists ( $newsportal_file )) {
$rslight_info = file_get_contents ( $rslight_file );
$newsportal_info = file ( $newsportal_file );
$newsportal_info = trim ( $newsportal_info [ 1 ]);
$newsportal_start = explode ( " " , $newsportal_info );
$rslight_start = explode ( " " , $rslight_info );
2024-10-04 13:14:34 +02:00
if ( $newsportal_start [ 0 ] != $rslight_start [ 0 ] || (( $rslight_start [ 2 ] - $newsportal_start [ 2 ]) > 10 )) {
2024-10-02 18:59:47 +02:00
file_put_contents ( $debug_log , " \n " . format_log_date () . " GROUP MISMATCH: " . $group . " rslight: " . $rslight_info . " newsportal: " . $newsportal_info . " Repairing... " , FILE_APPEND );
2024-09-28 23:56:42 +02:00
wipe_newsportal_spool_info ( $group );
}
}
}
function wipe_newsportal_spool_info ( $group )
{
2024-09-28 18:15:51 +02:00
global $spooldir ;
$gpath = $spooldir . '/' . $group ;
@ unlink ( $gpath . '-cache.txt' );
@ unlink ( $gpath . '-data.dat' );
@ unlink ( $gpath . '-firstarticleinfo.dat' );
@ unlink ( $gpath . '-lastarticleinfo.dat' );
@ unlink ( $gpath . '-info.txt' );
@ unlink ( $gpath . '-overboard.dat' );
}
2024-06-05 13:05:17 +02:00
function format_log_date ()
{
return date ( 'M d H:i:s' );
}
function create_name_link ( $name , $data = null )
{
global $CONFIG ;
$name = preg_replace ( '/\"/' , '' , $name );
if ( $data ) {
$data = urlencode ( base64_encode ( $data ));
}
if (( strpos ( $name , '...@' ) !== false && ( isset ( $CONFIG [ 'hide_email' ]) && $CONFIG [ 'hide_email' ] == true )) && ! $data ) {
$return = '<span class="visited">' . substr ( htmlspecialchars ( $name ), 0 , 20 ) . '</span>' ;
} else {
if ( isset ( $_COOKIE [ 'mail_name' ])) {
$return = '<a href="search.php?command=search&searchpoint=Poster&terms=' . $name . '&data=' . $data . '" title="Search or Block by user"><span class="visited">' . substr ( htmlspecialchars ( $name ), 0 , 20 ) . '</span></a>' ;
} else {
$return = '<a href="search.php?command=search&searchpoint=Poster&terms=' . $name . '&data=' . $data . '" title="Search by user"><span class="visited">' . substr ( htmlspecialchars ( $name ), 0 , 20 ) . '</span></a>' ;
}
}
return ( $return );
}
function truncate_email ( $address )
{
$before_at = explode ( '@' , $address );
$namelen = strlen ( $before_at [ 0 ]);
if ( $namelen > 3 ) {
$endname = $namelen - 3 ;
if ( $endname > 8 )
$endname = 8 ;
if ( $endname < 3 )
2024-09-28 18:15:51 +02:00
$endname ++ ;
2024-06-05 13:05:17 +02:00
if ( $endname < 3 )
2024-09-28 18:15:51 +02:00
$endname ++ ;
2024-06-05 13:05:17 +02:00
} else {
$endname = $namelen ;
}
return substr ( $before_at [ 0 ], 0 , $endname ) . '...' . substr ( $address , $namelen , strlen ( $address ));
}
function get_date_interval ( $value )
{
$current = time ();
$datetime1 = date_create ( $value );
$datetime2 = date_create ( " @ $current " );
$interval = date_diff ( $datetime1 , $datetime2 );
if ( ! $interval ) {
return '(date error)' ;
}
$years = $interval -> format ( '%y' ) . " Years " ;
$months = $interval -> format ( '%m' ) . " Months " ;
$days = $interval -> format ( '%d' ) . " Days " ;
$hours = $interval -> format ( '%h' ) . " Hours " ;
$minutes = $interval -> format ( '%i' ) . " Minutes " ;
if ( $interval -> format ( '%y' ) == 1 ) {
$years = $interval -> format ( '%y' ) . " Year " ;
}
if ( $interval -> format ( '%m' ) == 1 ) {
$months = $interval -> format ( '%m' ) . " Month " ;
}
if ( $interval -> format ( '%d' ) == 1 ) {
$days = $interval -> format ( '%d' ) . " Day " ;
}
if ( $interval -> format ( '%h' ) == 1 ) {
$hours = $interval -> format ( '%h' ) . " Hour " ;
}
if ( $interval -> format ( '%i' ) == 1 ) {
$minutes = $interval -> format ( '%i' ) . " Minute " ;
}
if ( $interval -> format ( '%y' ) == 0 ) {
$years = '' ;
}
if ( $interval -> format ( '%m' ) == 0 ) {
$months = '' ;
}
if ( $interval -> format ( '%d' ) == 0 ) {
$days = '' ;
}
if ( $interval -> format ( '%h' ) == 0 ) {
$hours = '' ;
}
if ( $interval -> format ( '%i' ) == 0 ) {
$minutes = '' ;
}
if ( $years > 0 ) {
$days = '' ;
$hours = '' ;
$minutes = '' ;
}
if ( $months > 0 ) {
$hours = '' ;
$minutes = '' ;
}
if ( $days > 0 ) {
$minutes = '' ;
}
$variance = $interval -> format ( $years . $months . $days . $hours . $minutes . ' ago' );
if ( strlen ( $variance ) < 5 ) {
$variance = " now " ;
}
return $variance ;
}
function get_newsgroups_by_msgid ( $msgid , $noarray = false )
{
global $spooldir , $config_dir , $logdir , $CONFIG ;
2024-06-07 13:13:23 +02:00
if ( file_exists ( $config_dir . '/cache.inc.php' )) {
include $config_dir . '/cache.inc.php' ;
2024-06-05 13:05:17 +02:00
}
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
$memcache_key = $cache_key_prefix . '_' . 'get_newsgroups_by_msgid-' . $msgid ;
2024-06-07 14:43:52 +02:00
if ( $getgroups = cache_get ( $memcache_key , $memcacheD )) {
2024-06-05 13:05:17 +02:00
if ( $groups = unserialize ( $getgroups )) {
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache hit) $memcache_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
}
}
2024-06-11 12:22:21 +02:00
if ( ! isset ( $groups )) {
2024-06-05 13:05:17 +02:00
$database = $spooldir . '/articles-overview.db3' ;
$table = 'overview' ;
$overview_dbh = overview_db_open ( $database , $table );
$overview_stmt = $overview_dbh -> prepare ( " SELECT newsgroup FROM overview WHERE msgid=:msgid " );
$overview_stmt -> bindParam ( ':msgid' , $msgid );
$overview_stmt -> execute ();
$found = false ;
$groups = array ();
while ( $row = $overview_stmt -> fetch ()) {
$groups [] = $row [ 'newsgroup' ];
$found = true ;
}
if ( ! $found ) {
$groups = null ;
}
$overview_dbh = null ;
2024-06-07 15:33:00 +02:00
if ( $groups && $enable_cache ) {
2024-06-07 14:43:52 +02:00
$nicole = cache_add ( $memcache_key , serialize ( $groups ), $cache_ttl , $memcacheD );
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging && $nicole ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache write) $memcache_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
}
if ( $noarray ) {
return ( implode ( " , " , $groups ));
} else {
return ( $groups );
}
}
function create_xref_from_msgid ( $msgid , $thisgroup = null , $thisnumber = null )
{
global $spooldir , $CONFIG ;
$database = $spooldir . '/articles-overview.db3' ;
$table = 'overview' ;
$overview_dbh = overview_db_open ( $database , $table );
$overview_stmt = $overview_dbh -> prepare ( " SELECT * FROM overview WHERE msgid=:msgid " );
$overview_stmt -> bindParam ( ':msgid' , $msgid );
$overview_stmt -> execute ();
$found = false ;
$xref = " Xref: " . $CONFIG [ 'pathhost' ];
while ( $row = $overview_stmt -> fetch ()) {
if ( $row [ 'newsgroup' ] == $thisgroup && $thisgroup != null ) {
$found = true ;
}
$xref .= ' ' . $row [ 'newsgroup' ] . ':' . $row [ 'number' ];
}
if ( ! $found ) {
$xref .= ' ' . $thisgroup . ':' . $thisnumber ;
}
$overview_dbh = null ;
return ( $xref );
}
function get_search_snippet ( $body , $content_type = '' , $content_transfer_encoding = null )
{
if ( $content_transfer_encoding == 'base64' ) {
$body = base64_decode ( $body );
}
if ( $content_transfer_encoding == 'quoted-printable' ) {
$body = quoted_printable_decode ( $body );
}
if ( $content_type !== '' ) {
2024-08-25 22:33:05 +02:00
$content_type = explode ( ';' , $content_type );
$mysnippet = recode_charset ( $body , $content_type [ 0 ]);
2024-06-05 13:05:17 +02:00
} else {
$mysnippet = $body ;
}
if ( $bodyend = strrpos ( $mysnippet , " \n --- \n " )) {
$mysnippet = substr ( $mysnippet , 0 , $bodyend );
} else {
if ( $bodyend = strrpos ( $mysnippet , " \n -- " )) {
$mysnippet = substr ( $mysnippet , 0 , $bodyend );
} else {
if ( $bodyend = strrpos ( $mysnippet , " \n . " )) {
$mysnippet = substr ( $mysnippet , 0 , $bodyend );
}
}
}
$mysnippet = preg_replace ( '/\n.{0,5}>(.*)/' , '' , $mysnippet );
$snipstart = strpos ( $mysnippet , " : \n " );
if ( substr_count ( trim ( substr ( $mysnippet , 0 , $snipstart )), " \n " ) < 2 ) {
$mysnippet = substr ( $mysnippet , $snipstart + 1 );
} else {
$mysnippet = substr ( $mysnippet , 0 );
}
return $mysnippet ;
}
function mail_db_open ( $database , $table = 'messages' )
{
try {
$dbh = new PDO ( 'sqlite:' . $database );
} catch ( PDOException $e ) {
echo 'Connection failed: ' . $e -> getMessage ();
exit ();
}
2024-07-17 15:33:48 +02:00
$dbh -> exec ( " CREATE TABLE IF NOT EXISTS messages(
id INTEGER PRIMARY KEY ,
msgid TEXT UNIQUE ,
mail_from TEXT ,
mail_viewed TEXT ,
rcpt_to TEXT ,
rcpt_viewed TEXT ,
rcpt_target TEXT ,
date TEXT ,
subject TEXT ,
message TEXT ,
from_hide TEXT ,
2024-06-05 13:05:17 +02:00
to_hide TEXT ) " );
return ( $dbh );
}
function history_db_open ( $database , $table = 'history' )
{
try {
$dbh = new PDO ( 'sqlite:' . $database );
} catch ( PDOException $e ) {
echo 'Connection failed: ' . $e -> getMessage ();
exit ();
}
2024-07-17 15:33:48 +02:00
$dbh -> exec ( " CREATE TABLE IF NOT EXISTS history(
id INTEGER PRIMARY KEY ,
newsgroup TEXT ,
number TEXT ,
msgid TEXT ,
status TEXT ,
statusdate TEXT ,
statusreason TEXT ,
statusnotes TEXT ,
unique ( newsgroup , msgid ),
2024-06-05 13:05:17 +02:00
unique ( newsgroup , number )) " );
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_status on ' . $table . '(status)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_newsgroup on ' . $table . '(newsgroup)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_msgid on ' . $table . '(msgid)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_newsgroup_number on ' . $table . '(newsgroup,number)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_statusdate on ' . $table . '(statusdate)' );
$stmt -> execute ();
return ( $dbh );
}
function overview_db_open ( $database , $table = 'overview' )
{
try {
$dbh = new PDO ( 'sqlite:' . $database );
} catch ( PDOException $e ) {
echo 'Connection failed: ' . $e -> getMessage ();
exit ();
}
2024-07-17 15:33:48 +02:00
$dbh -> exec ( " CREATE TABLE IF NOT EXISTS overview(
id INTEGER PRIMARY KEY ,
newsgroup TEXT ,
number TEXT ,
msgid TEXT ,
date TEXT ,
datestring TEXT ,
name TEXT ,
subject TEXT ,
refs TEXT ,
bytes TEXT ,
lines TEXT ,
xref TEXT ,
unique ( newsgroup , msgid ),
2024-06-05 13:05:17 +02:00
unique ( newsgroup , number )) " );
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_date on ' . $table . '(date)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_newsgroup on ' . $table . '(newsgroup)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_msgid on ' . $table . '(msgid)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_newsgroup_number on ' . $table . '(newsgroup,number)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS id_name on ' . $table . '(name)' );
$stmt -> execute ();
return ( $dbh );
}
function article_db_open ( $database , $table = 'articles' )
{
global $spooldir , $logdir , $config_name ;
$logfile = $logdir . '/debug.log' ;
$spoolpath = " / " . preg_replace ( " / \ // " , " \ / " , $spooldir ) . " / " ;
$group = preg_replace ( " / \ -articles \ .db3/ " , " " , $database );
$group = preg_replace ( $spoolpath , " " , $group );
$group = preg_replace ( " / \ // " , " " , $group );
if ( ! preg_match ( '/\-articles\.db3\-new/' , $database )) {
if ( ! get_section_by_group ( $group , true )) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " " . $config_name . " Attempt to create: " . $database . " for: " . $group , FILE_APPEND );
2024-06-05 13:05:17 +02:00
return false ;
}
}
try {
$dbh = new PDO ( 'sqlite:' . $database );
} catch ( PDOException $e ) {
echo 'Connection failed: ' . $e -> getMessage ();
exit ();
}
2024-07-17 15:33:48 +02:00
$dbh -> exec ( " CREATE TABLE IF NOT EXISTS articles(
id INTEGER PRIMARY KEY ,
newsgroup TEXT ,
number TEXT UNIQUE ,
msgid TEXT UNIQUE ,
date TEXT ,
name TEXT ,
subject TEXT ,
search_snippet TEXT ,
2024-06-05 13:05:17 +02:00
article TEXT ) " );
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS db_number on ' . $table . '(number)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS db_date on ' . $table . '(date)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS db_msgid on ' . $table . '(msgid)' );
$stmt -> execute ();
$stmt = $dbh -> query ( 'CREATE INDEX IF NOT EXISTS db_name on ' . $table . '(name)' );
$stmt -> execute ();
2024-07-17 15:33:48 +02:00
$dbh -> exec ( " CREATE VIRTUAL TABLE IF NOT EXISTS search_fts USING fts5(
newsgroup ,
number ,
msgid ,
date ,
name ,
subject ,
2024-06-05 13:05:17 +02:00
search_snippet ) " );
2024-07-17 15:33:48 +02:00
$dbh -> exec ( " CREATE TRIGGER IF NOT EXISTS after_articles_insert AFTER INSERT ON $table BEGIN
INSERT INTO search_fts ( newsgroup , number , msgid , date , name , subject , search_snippet ) VALUES ( new . newsgroup , new . number , new . msgid , new . date , new . name , new . subject , new . search_snippet );
2024-06-05 13:05:17 +02:00
END ; " );
2024-07-17 15:33:48 +02:00
$dbh -> exec ( " CREATE TRIGGER IF NOT EXISTS after_articles_delete AFTER DELETE ON $table BEGIN
DELETE FROM search_fts WHERE msgid = old . msgid ;
2024-06-05 13:05:17 +02:00
END ; " );
return ( $dbh );
}
function np_get_db_article ( $article , $group , $makearray = 1 , $dbh = null )
{
global $config_dir , $path , $groupconfig , $config_name , $logdir , $spooldir ;
$logfile = $logdir . '/newsportal.log' ;
2024-06-07 13:13:23 +02:00
if ( file_exists ( $config_dir . '/cache.inc.php' )) {
include $config_dir . '/cache.inc.php' ;
2024-06-05 13:05:17 +02:00
}
$msg2 = " " ;
$closeme = 0 ;
$ok_article = 0 ;
// Check memcache
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
$article_key = $cache_key_prefix . '_' . 'article.db3-' . $group . ':' . $article ;
2024-06-07 16:39:33 +02:00
if ( $msg2 = gzuncompress ( cache_get ( $article_key , $memcacheD ))) {
2024-06-05 13:05:17 +02:00
$ok_article = 1 ;
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache hit) $article_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
}
if ( ! $ok_article ) {
$database = $spooldir . '/' . $group . '-articles.db3' ;
if ( ! $dbh ) {
if ( ! is_file ( $database )) {
return FALSE ;
}
$dbh = article_db_open ( $database );
$closeme = 1 ;
}
// By Message-ID
if ( ! is_numeric ( $article )) {
$stmt = $dbh -> prepare ( " SELECT * FROM articles WHERE msgid like :terms " );
$stmt -> bindParam ( ':terms' , $article );
$stmt -> execute ();
while ( $found = $stmt -> fetch ()) {
$msg2 = $found [ 'article' ];
$ok_article = 1 ;
break ;
}
} else {
$stmt = $dbh -> prepare ( " SELECT * FROM articles WHERE number = :terms " );
$stmt -> bindParam ( ':terms' , $article );
$stmt -> execute ();
while ( $found = $stmt -> fetch ()) {
$msg2 = $found [ 'article' ];
$ok_article = 1 ;
break ;
}
}
2024-06-07 15:13:00 +02:00
if ( $ok_article == 1 && $enable_cache ) {
2024-06-07 16:39:33 +02:00
$nicole = cache_add ( $article_key , gzcompress ( $msg2 ), $cache_ttl , $memcacheD );
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging && $nicole ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache write) $article_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
}
if ( $closeme == 1 ) {
$dbh = null ;
}
if ( $ok_article !== 1 ) {
// file_put_contents($logfile, "\n".format_log_date()." ".$config_name." DEBUG: ".$article." from ".$group." not found in database", FILE_APPEND);
return FALSE ;
}
// file_put_contents($logfile, "\n".format_log_date()." ".$config_name." DEBUG: fetched: ".$article." from ".$group, FILE_APPEND);
if ( $makearray == 1 ) {
$thisarticle = preg_split ( " / \r \n | \n | \r / " , trim ( $msg2 ));
array_pop ( $thisarticle );
return $thisarticle ;
} else {
return trim ( $msg2 );
}
}
function get_poster_name ( $name )
{
$fromline = address_decode ( $name , " nowhere " );
if ( ! isset ( $fromline [ 0 ][ " host " ]))
$fromline [ 0 ][ " host " ] = " " ;
$name_from = $fromline [ 0 ][ " mailbox " ] . " @ " . $fromline [ 0 ][ " host " ];
$name_username = $fromline [ 0 ][ " mailbox " ];
if ( ! isset ( $fromline [ 0 ][ " personal " ])) {
$poster_name = $fromline [ 0 ][ " mailbox " ];
} else {
$poster_name = $fromline [ 0 ][ " personal " ];
}
if ( trim ( $poster_name ) == '' ) {
$fromoutput = explode ( " < " , html_entity_decode ( $name ));
if ( strlen ( $fromoutput [ 0 ]) < 1 ) {
$poster_name = $fromoutput [ 1 ];
} else {
$poster_name = $fromoutput [ 0 ];
}
}
$thisposter [ 'name' ] = $poster_name ;
$thisposter [ 'from' ] = $name_from ;
return ( $thisposter );
}
/*
* This function returns false on success
* or return value contains error info
* 'added' etc .
*/
function save_config_value ( $configfile , $name , $value , $value_unique = false )
{
2024-10-07 00:38:41 +02:00
global $spooldir , $logdir ;
2024-06-05 13:05:17 +02:00
$return_val = false ;
$tempfile = tempnam ( $spooldir , 'rslight-' );
if ( file_exists ( $tempfile )) {
unlink ( $tempfile );
}
$lines = file ( $configfile , FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES );
$found = false ;
foreach ( $lines as $line ) {
$current = explode ( ':' , $line );
if ( $value_unique && ( strcmp ( $current [ 1 ], $value ) == 0 )) {
// Found value. Write once
if ( ! $found ) {
file_put_contents ( $tempfile , $name . " : " . $value . " \n " , FILE_APPEND );
}
$found = true ;
continue ;
}
if ( strcmp ( $current [ 0 ], $name ) == 0 ) {
// $name matches option. Overwrite
file_put_contents ( $tempfile , $name . " : " . $value . " \n " , FILE_APPEND );
$found = true ;
} else {
// $name does not match option. Keep current line
file_put_contents ( $tempfile , $line . " \n " , FILE_APPEND );
}
}
if ( ! $found ) {
// $name not found in options. Add to file.
file_put_contents ( $tempfile , $name . " : " . $value . " \n " , FILE_APPEND );
}
copy ( $tempfile , $configfile );
unlink ( $tempfile );
return $return_val ;
}
function get_config_file_value ( $configfile , $request )
{
if ( $configFileHandle = @ fopen ( $configfile , 'r' )) {
while ( ! feof ( $configFileHandle )) {
$buffer = fgets ( $configFileHandle );
if ( strpos ( $buffer , $request . ':' ) !== FALSE ) {
$dataline = $buffer ;
fclose ( $configFileHandle );
$datafound = explode ( ':' , $dataline );
return trim ( $datafound [ 1 ]);
}
}
fclose ( $configFileHandle );
return FALSE ;
} else {
return FALSE ;
}
}
// This function is specific to $config_dir configuration values
function get_config_value ( $configfile , $request )
{
global $config_dir ;
if ( $configFileHandle = @ fopen ( $config_dir . '/' . $configfile , 'r' )) {
while ( ! feof ( $configFileHandle )) {
$buffer = fgets ( $configFileHandle );
if ( strpos ( $buffer , $request . ':' ) !== FALSE ) {
$dataline = $buffer ;
fclose ( $configFileHandle );
$datafound = explode ( ':' , $dataline );
return trim ( $datafound [ 1 ]);
}
}
fclose ( $configFileHandle );
return FALSE ;
} else {
return FALSE ;
}
}
function disable_page_by_user_agent ( $client_device , $useragent , $script = " Page " )
{
global $logdir , $config_name ;
2024-07-05 20:35:17 +02:00
if ( ! $client_device ) {
$client_device = get_client_user_agent_info ();
}
$client_device = strtolower ( $client_device );
2024-06-05 13:05:17 +02:00
if ( $client_device == $useragent ) {
$logfile = $logdir . '/device.log' ;
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " " . $config_name . " " . $script . " disabled for ' " . $useragent . " ' Exiting... " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
if ( $client_device == " bot " ) {
$_SESSION [ 'bot' ] = true ;
}
return true ;
} else {
return false ;
}
}
function throttle_hits ( $client_device = null )
{
2024-07-03 09:16:36 +02:00
global $CONFIG , $OVERRIDES , $logdir , $abuse_log , $config_name , $spooldir ;
2024-06-25 13:44:51 +02:00
$rdns_file = $spooldir . '/rdns.dat' ;
$rdns = array ();
if ( file_exists ( $rdns_file )) {
$rdns = unserialize ( file_get_contents ( $rdns_file ));
}
2024-06-05 13:05:17 +02:00
if ( ! $client_device ) {
$client_device = get_client_user_agent_info ();
}
$client_device = strtolower ( $client_device );
$_SESSION [ 'rsactive' ] = true ;
2024-06-25 13:44:51 +02:00
// Block by user-agent
2024-06-05 13:05:17 +02:00
if ( isset ( $OVERRIDES [ 'block_by_user_agent' ])) {
2024-07-05 15:30:53 +02:00
$this_ua = strtolower ( $_SERVER [ " HTTP_USER_AGENT " ]);
foreach ( $OVERRIDES [ 'block_by_user_agent' ] as $block_user_agent ) {
if ( stripos ( $this_ua , $block_user_agent ) !== false ) {
2024-07-19 14:56:46 +02:00
file_put_contents ( $abuse_log , " \n " . logging_prefix () . " (blocking) ' " . $block_user_agent . " ' found in User-Agent block list " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
$_SESSION [ 'throttled' ] = true ;
header ( " HTTP/1.0 403 Forbidden " );
exit ();
}
}
}
2024-06-25 13:44:51 +02:00
// Block by rdns
if ( isset ( $OVERRIDES [ 'block_by_rdns' ])) {
$ip = $_SERVER [ 'REMOTE_ADDR' ];
if ( isset ( $rdns [ $ip ])) {
2024-07-05 15:30:53 +02:00
$this_rdns = $rdns [ $ip ];
2024-06-25 13:44:51 +02:00
} else {
2024-07-05 15:30:53 +02:00
$this_rdns = gethostbyaddr ( $ip );
$rdns [ $ip ] = $this_rdns ;
2024-06-25 13:44:51 +02:00
file_put_contents ( $rdns_file , serialize ( $rdns ));
}
2024-07-05 15:30:53 +02:00
foreach ( $OVERRIDES [ 'block_by_rdns' ] as $block_rdns ) {
if ( stripos ( $this_rdns , $block_rdns ) !== false ) {
2024-07-19 14:56:46 +02:00
file_put_contents ( $abuse_log , " \n " . logging_prefix () . " (blocking) ' " . $block_rdns . " ' found in RDNS block list " , FILE_APPEND );
2024-06-25 13:44:51 +02:00
$_SESSION [ 'throttled' ] = true ;
header ( " HTTP/1.0 403 Forbidden " );
exit ();
}
}
}
2024-06-05 13:05:17 +02:00
// $loadrate = allowed article request per second
$loadrate = . 15 ;
if ( $client_device == " bot " ) {
$_SESSION [ 'bot' ] = 'true' ;
if ( isset ( $OVERRIDES [ 'throttle_hits_bot_loadrate' ]) && trim ( $OVERRIDES [ 'throttle_hits_bot_loadrate' ]) != '' ) {
$loadrate = $OVERRIDES [ 'throttle_hits_bot_loadrate' ];
}
}
if ( ! isset ( $_SESSION [ 'starttime' ])) {
$_SESSION [ 'starttime' ] = time ();
$_SESSION [ 'views' ] = 0 ;
}
2024-09-28 18:15:51 +02:00
$_SESSION [ 'views' ] ++ ;
2024-06-05 13:05:17 +02:00
// $rate = current hits / seconds since start of session
$rate = fdiv ( $_SESSION [ 'views' ], ( time () - $_SESSION [ 'starttime' ]));
// if $rate > greater than $loadrate, throttle hits
// but allow 50 hits at start of session to allow loading everything
if (( $rate > $loadrate ) && ( $_SESSION [ 'views' ] > 50 )) {
header ( " HTTP/1.0 429 Too Many Requests " );
if ( ! isset ( $_SESSION [ 'throttled' ])) {
2024-07-19 14:56:46 +02:00
file_put_contents ( $abuse_log , " \n " . logging_prefix () . " (throttling) too many requests " . " ( " . $rate . " > " . $loadrate . " ) " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
$_SESSION [ 'throttled' ] = true ;
}
exit ( 0 );
}
if ( isset ( $_SESSION [ 'throttled' ])) {
unset ( $_SESSION [ 'throttled' ]);
}
}
function get_client_user_agent_info ()
{
2024-07-05 20:35:17 +02:00
global $config_dir , $logdir ;
2024-06-05 13:05:17 +02:00
// Try to get browser info to use for extra formatting of page
$ua = strtolower ( $_SERVER [ " HTTP_USER_AGENT " ]);
$devices = array (
" bot " ,
" spider " ,
" mobile " ,
" lynx " ,
" w3m " ,
" links " ,
" ipad " ,
" tablet "
);
$client_device = " desktop " ;
foreach ( $devices as $device ) {
if ( strpos ( $ua , $device ) !== false ) {
$client_device = $device ;
break ;
}
}
2024-07-05 20:35:17 +02:00
if ( $client_device == " spider " || $client_device == " crawler " ) {
2024-06-05 13:05:17 +02:00
$client_device = " bot " ;
}
// Log client device if enabled by semaphore
if ( file_exists ( $config_dir . '/devicelog.enable' )) {
$client_ip = getenv ( " REMOTE_ADDR " );
$logfile = $logdir . '/device.log' ;
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " browser: " . $client_device , FILE_APPEND );
2024-07-05 20:35:17 +02:00
file_put_contents ( $logfile , " \n Full UA: " . $ua , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
return $client_device ;
}
2024-10-06 15:06:01 +02:00
/* This function sends internet email
* $subject and $body are strings
* $mail_to is an email address to send to
* $mail_from is an email address to use as from
* $mail_name is the name to use with $mail_from when sending
* required if setting $mail_from
* DEFAULT is Admin address for to ( phpmailer . inc . php )
* DEFAULT is standard From address for from ( phpmailer . inc . php )
*/
function send_internet_email ( $subject , $body , $mail_to = false , $mail_from = false , $mail_name = false )
{
global $CONFIG , $config_dir , $spooldir , $keys ;
global $debug_log , $mail_log ;
include ( $config_dir . '/phpmailer.inc.php' );
if ( class_exists ( 'PHPMailer' )) {
$mail = new PHPMailer ();
} else {
$mail = new PHPMailer\PHPMailer\PHPMailer ();
}
2024-10-09 14:59:10 +02:00
if ( ! $mail ) {
return false ;
}
2024-10-06 15:06:01 +02:00
$mail -> SMTPOptions = array (
'ssl' => array (
'verify_peer' => false ,
'verify_peer_name' => false ,
'allow_self_signed' => true
)
);
$mail -> IsSMTP ();
# uncomment below to enable debugging
# $mail->SMTPDebug = 3;
$mail -> CharSet = 'UTF-8' ;
$mail -> Host = $mailer [ 'host' ];
$mail -> SMTPAuth = true ;
$mail -> Port = $mailer [ 'port' ];
$mail -> Username = $mailer [ 'username' ];
$mail -> Password = $mailer [ 'password' ];;
$mail -> SMTPSecure = 'tls' ;
if ( $mail_from != false ) {
$mail -> setFrom ( $mail_from , $mail_name );
} else {
$mail -> setFrom ( $mail_user . '@' . $mail_domain , $mail_name ); // Default Admin
$mail_from = $mail_user . '@' . $mail_domain ;
}
if ( $mail_to != false ) {
$mail -> addAddress ( $mail_to );
} else {
$mail -> addAddress ( $mail_admin_user . '@' . $mail_admin_domain , $mail_admin_name ); // Default Admin
$mail_to = $mail_admin_user . '@' . $mail_admin_domain ;
}
$mail -> Subject = $subject ;
foreach ( $mail_custom_header as $key => $value ) {
$mail -> addCustomHeader ( $key , $value );
}
$mail -> Body = $body ;
if ( ! $mail -> send ()) {
file_put_contents ( $mail_log , " \n " . format_log_date () . ' FAILED to send mail from: ' . $mail_from . ' to: ' . $mail_to . 'Error: ' . $mail -> ErrorInfo , FILE_APPEND );
2024-10-09 14:59:10 +02:00
return true ;
2024-10-06 15:06:01 +02:00
} else {
file_put_contents ( $mail_log , " \n " . format_log_date () . ' SENT mail from: ' . $mail_from . ' to: ' . $mail_to , FILE_APPEND );
2024-10-09 14:59:10 +02:00
return false ;
2024-10-06 15:06:01 +02:00
}
}
2024-06-05 13:05:17 +02:00
function get_user_mail_auth_data ( $user )
{
global $spooldir ;
$userdata = array ();
$user = strtolower ( $user );
$pkey_config = get_user_config ( $user , " pkey " );
if ( ! isset ( $_COOKIE [ 'pkey' ])) {
$_COOKIE [ 'pkey' ] = null ;
}
$pkey_cookie = $_COOKIE [ 'pkey' ];
if (( ! isset ( $_COOKIE [ 'pkey' ])) || $pkey_config == false || $pkey_cookie == false ) {
return false ;
}
if ( $pkey_config == $pkey_cookie ) {
$userfile = $spooldir . '/' . $user . '-articleviews.dat' ;
if ( is_file ( $userfile )) {
$userdata = unserialize ( file_get_contents ( $userfile ));
if ( isset ( $userdata [ 'DO.NOT.DELETE' ])) {
$userdata [ 'DO.NOT.DELETE' ] = time ();
}
} else {
$userdata [ 'DO.NOT.DELETE' ] = time ();
}
return $userdata ;
}
return false ;
}
function write_access_log ()
{
global $logdir ;
$accessfile = $logdir . '/access.log' ;
$currentPageUrl = $_SERVER [ " HTTP_HOST " ] . $_SERVER [ " REQUEST_URI " ];
2024-07-18 14:20:38 +02:00
file_put_contents ( $accessfile , " \n " . logging_prefix () . " " . $currentPageUrl , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
function verify_gpg_signature ( $res , $signed_text )
{
$result = gnupg_verify ( $res , $signed_text , false );
if ( $result == false ) {
return false ;
}
if ((( $result [ 0 ][ 'summary' ] > 3 )) || $result [ 0 ][ 'validity' ] == 2 ) {
return false ; // Bad signature
} else {
return true ; // Good signature
}
}
function mb_wordwrap ( $string , $width = 75 , $break = " \n " , $cut = false )
{
$string = ( string ) $string ;
if ( $string === '' ) {
return '' ;
}
$break = ( string ) $break ;
if ( $break === '' ) {
trigger_error ( 'Break string cannot be empty' , E_USER_ERROR );
}
$width = ( int ) $width ;
if ( $width === 0 && $cut ) {
trigger_error ( 'Cannot force cut when width is zero' , E_USER_ERROR );
}
if ( strlen ( $string ) === mb_strlen ( $string )) {
return wordwrap ( $string , $width , $break , $cut );
}
$stringWidth = mb_strlen ( $string );
$breakWidth = mb_strlen ( $break );
$result = '' ;
$lastStart = $lastSpace = 0 ;
2024-09-28 18:15:51 +02:00
for ( $current = 0 ; $current < $stringWidth ; $current ++ ) {
2024-06-05 13:05:17 +02:00
$char = mb_substr ( $string , $current , 1 );
$possibleBreak = $char ;
if ( $breakWidth !== 1 ) {
$possibleBreak = mb_substr ( $string , $current , $breakWidth );
}
if ( $possibleBreak === $break ) {
$result .= mb_substr ( $string , $lastStart , $current - $lastStart + $breakWidth );
$current += $breakWidth - 1 ;
$lastStart = $lastSpace = $current + 1 ;
continue ;
}
if ( $char === ' ' ) {
if ( $current - $lastStart >= $width ) {
$result .= mb_substr ( $string , $lastStart , $current - $lastStart ) . $break ;
$lastStart = $current + 1 ;
}
$lastSpace = $current ;
continue ;
}
if ( $current - $lastStart >= $width && $cut && $lastStart >= $lastSpace ) {
$result .= mb_substr ( $string , $lastStart , $current - $lastStart ) . $break ;
$lastStart = $lastSpace = $current ;
continue ;
}
if ( $current - $lastStart >= $width && $lastStart < $lastSpace ) {
$result .= mb_substr ( $string , $lastStart , $lastSpace - $lastStart ) . $break ;
$lastStart = $lastSpace = $lastSpace + 1 ;
continue ;
}
}
if ( $lastStart !== $current ) {
$result .= mb_substr ( $string , $lastStart , $current - $lastStart );
}
return $result ;
}
function is_moderated ( $newsgroups )
{
global $CONFIG , $OVERRIDES , $spooldir ;
$moderated_groups_file = $spooldir . '/moderated_groups.dat' ;
$unmoderated_groups_file = $spooldir . '/unmoderated_groups.dat' ;
$moderated_groups = array ();
$unmoderated_groups = array ();
$ngroups = preg_split ( " /[ \ s,]+/ " , $newsgroups );
foreach ( $ngroups as $group ) {
if ( file_exists ( $moderated_groups_file )) {
$moderated_groups = file ( $moderated_groups_file , FILE_IGNORE_NEW_LINES );
if ( in_array ( $group , $moderated_groups )) {
return true ;
}
}
if ( file_exists ( $unmoderated_groups_file )) {
$unmoderated_groups = file ( $unmoderated_groups_file , FILE_IGNORE_NEW_LINES );
if ( in_array ( $group , $unmoderated_groups )) {
return false ;
}
}
}
if ( $CONFIG [ 'remote_server' ] == '' ) {
return false ;
}
$ns = nntp2_open ();
if ( ! $ns ) {
return false ;
}
foreach ( $ngroups as $group ) {
fputs ( $ns , " list active $group\r\n " );
while ( $weg = line_read ( $ns )) {
if ( strcmp ( $weg , " . " ) == 0 ) {
nntp_close ( $ns );
return false ;
}
if ( strpos ( $weg , $group . ' ' ) !== false ) {
if ( str_ends_with ( $weg , 'm' )) {
nntp_close ( $ns );
if ( ! in_array ( $newsgroups , $moderated_groups )) {
file_put_contents ( $moderated_groups_file , $group . " \n " , FILE_APPEND );
}
return true ;
} else {
nntp_close ( $ns );
if ( ! in_array ( $newsgroups , $unmoderated_groups )) {
file_put_contents ( $unmoderated_groups_file , $group . " \n " , FILE_APPEND );
}
return false ;
}
}
}
}
nntp_close ( $ns );
return false ;
}
function get_next_article_number ( $group )
{
$ok_article = get_article_list ( $group );
sort ( $ok_article );
2024-09-28 18:15:51 +02:00
$local = $ok_article [ key ( array_slice ( $ok_article , - 1 , 1 , true ))];
2024-06-05 13:05:17 +02:00
if ( ! is_numeric ( $local )) {
$local = 0 ;
}
$local = $local + 1 ;
if ( $local < 1 ) {
$local = 1 ;
}
while ( is_deleted_post ( $group , $local )) {
2024-09-28 18:15:51 +02:00
$local ++ ;
2024-06-05 13:05:17 +02:00
}
return $local ;
}
2024-10-09 14:29:04 +02:00
function get_article_list ( $thisgroup )
{
global $spooldir ;
$database = $spooldir . " /articles-overview.db3 " ;
$table = 'overview' ;
$dbh = overview_db_open ( $database , $table );
$stmt = $dbh -> prepare ( " SELECT * FROM $table WHERE newsgroup=:thisgroup ORDER BY number " );
$stmt -> execute ([
'thisgroup' => $thisgroup
]);
$ok_article = array ();
while ( $found = $stmt -> fetch ()) {
$ok_article [] = $found [ 'number' ];
}
$dbh = null ;
return ( array_unique ( $ok_article ));
}
2024-06-05 13:05:17 +02:00
function check_duplicate_msgid ( $msgid , $group )
{
global $spooldir , $logdir ;
$found = false ;
$database = $spooldir . '/articles-overview.db3' ;
$table = 'overview' ;
$dbh = overview_db_open ( $database , $table );
$stmt = $dbh -> prepare ( " SELECT * FROM $table WHERE msgid=:msgid AND newsgroup=:newsgroup " );
$stmt -> bindParam ( ':msgid' , $msgid );
$stmt -> bindParam ( ':newsgroup' , $group );
$stmt -> execute ();
while ( $row = $stmt -> fetch ()) {
if ( $row [ 'msgid' ] == $msgid ) {
$found = true ;
}
}
$dbh = null ;
$database = $spooldir . '/history.db3' ;
$table = 'history' ;
$dbh = history_db_open ( $database , $table );
$stmt = $dbh -> prepare ( " SELECT * FROM $table WHERE msgid=:msgid AND newsgroup=:newsgroup " );
$stmt -> bindParam ( ':msgid' , $msgid );
$stmt -> bindParam ( ':newsgroup' , $group );
$stmt -> execute ();
while ( $row = $stmt -> fetch ()) {
if ( $row [ 'msgid' ] == $msgid ) {
$found = true ;
}
}
$dbh = null ;
2024-10-08 17:08:04 +02:00
if ( $found ) {
2024-10-07 00:38:41 +02:00
file_put_contents ( $logdir . '/debug.log' , " \n " . format_log_date () . " FOUND Duplicate " . $msgid , FILE_APPEND );
}
2024-06-05 13:05:17 +02:00
return $found ;
}
function insert_article_from_array ( $this_article , $check_duplicates = true )
{
global $CONFIG , $config_name , $config_dir , $spooldir , $logdir ;
$logfile = $logdir . '/spoolnews.log' ;
$group = $this_article [ 'group' ];
$grouppath = $path . preg_replace ( '/\./' , '/' , $group );
if ( $check_duplicates ) {
if ( check_duplicate_msgid ( $this_article [ 'mid' ], $group )) {
echo " \n (newsportal)Duplicate Message-ID for: " . $group . " : " . $this_article [ 'mid' ];
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " " . $config_name . " Duplicate Message-ID for: " . $group . " : " . $this_article [ 'mid' ], FILE_APPEND );
2024-06-05 13:05:17 +02:00
return " 441 Insert failed (duplicate) \r \n " ;
}
}
// Open articles Database
if ( $CONFIG [ 'article_database' ] == '1' ) {
$article_dbh = article_db_open ( $spooldir . '/' . $group . '-articles.db3' );
if ( ! $article_dbh ) {
return " 441 Cannot open " . $spooldir . '/' . $group . " -articles.db3 \r \n " ;
}
$article_sql = 'INSERT OR IGNORE INTO articles(newsgroup, number, msgid, date, name, subject, article, search_snippet) VALUES(?,?,?,?,?,?,?,?)' ;
$article_stmt = $article_dbh -> prepare ( $article_sql );
}
// Open overview database
$database = $spooldir . '/articles-overview.db3' ;
$table = 'overview' ;
$overview_dbh = overview_db_open ( $database , $table );
if ( ! $overview_dbh ) {
$article_dbh = null ;
return " 441 Cannot open " . $database . " \r \n " ;
}
$overview_sql = 'INSERT OR IGNORE INTO overview(newsgroup, number, msgid, date, datestring, name, subject, refs, bytes, lines, xref) VALUES(?,?,?,?,?,?,?,?,?,?,?)' ;
$overview_stmt = $overview_dbh -> prepare ( $overview_sql );
// Overview
$overview_stmt -> execute ([
$group ,
$this_article [ 'local' ],
$this_article [ 'mid' ],
$this_article [ 'epochdate' ],
$this_article [ 'stringdate' ],
$this_article [ 'from' ],
$this_article [ 'subject' ],
$this_article [ 'references' ],
$this_article [ 'bytes' ],
$this_article [ 'lines' ],
$this_article [ 'xref' ]
]);
$overview_dbh = null ;
$references = " " ;
// Articles
if ( $CONFIG [ 'article_database' ] == '1' ) {
$article_stmt -> execute ([
$group ,
$this_article [ 'local' ],
$this_article [ 'mid' ],
$this_article [ 'epochdate' ],
$this_article [ 'from' ],
$this_article [ 'subject' ],
$this_article [ 'article' ],
$this_article [ 'snippet' ]
]);
unlink ( $grouppath . " / " . $this_article [ 'local' ]);
$article_dbh = null ;
} else {
2024-10-07 00:38:41 +02:00
$article_date = $this_article [ 'epochdate' ];
2024-06-05 13:05:17 +02:00
if ( $article_date > time ())
$article_date = time ();
touch ( $grouppath . " / " . $this_article [ 'local' ], $article_date );
}
echo " \n Spooling: " . $group . " " . $this_article [ 'local' ];
2024-10-07 00:38:41 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " " . $config_name . " Spooling: " . $group . " : " . $this_article [ 'local' ] . " " . $this_article [ 'mid' ], FILE_APPEND );
2024-06-05 13:05:17 +02:00
$status = " spooled " ;
$statusdate = time ();
$statusreason = " imported " ;
2024-10-07 00:38:41 +02:00
$statusnotes = '' ;
2024-06-05 13:05:17 +02:00
add_to_history ( $group , $this_article [ 'local' ], $this_article [ 'mid' ], $status , $statusdate , $statusreason , $statusnotes );
}
function is_deleted_post ( $group , $number )
{
global $spooldir ;
$database = $spooldir . '/history.db3' ;
$table = 'history' ;
$dbh = history_db_open ( $database , $table );
$stmt = $dbh -> prepare ( " SELECT * FROM $table WHERE newsgroup=:newsgroup AND number=:newsnum " );
$stmt -> bindParam ( ':newsgroup' , $group );
$stmt -> bindParam ( ':newsnum' , $number );
$stmt -> execute ();
$status = false ;
while ( $row = $stmt -> fetch ()) {
if ( $row [ 'status' ] == " deleted " ) {
$status = " 430 Article Deleted " ;
break ;
}
}
$dbh = null ;
return $status ;
}
function add_to_history ( $group , $number , $msgid , $status , $statusdate , $statusreason = null , $statusnotes = null )
{
global $spooldir ;
$history = $spooldir . '/history.db3' ;
$history_dbh = history_db_open ( $history );
$history_sql = 'INSERT OR REPLACE INTO history(newsgroup, number, msgid, status, statusdate, statusreason, statusnotes) VALUES(?,?,?,?,?,?,?)' ;
$history_stmt = $history_dbh -> prepare ( $history_sql );
$history_stmt -> execute ([
$group ,
$number ,
$msgid ,
$status ,
$statusdate ,
$statusreason ,
$statusnotes
]);
$history_dbh = null ;
}
function clear_history_by_group ( $group )
{
global $spooldir ;
$history = $spooldir . '/history.db3' ;
$history_dbh = history_db_open ( $history );
$clear_stmt = $history_dbh -> prepare ( " DELETE FROM history WHERE newsgroup=:group " );
$clear_stmt -> bindParam ( ':group' , $group );
$clear_stmt -> execute ();
$history_dbh = null ;
}
/* get_data_from_msgid uses overview database */
/* get_db_data_from_msgid uses overview database */
function get_db_data_from_msgid ( $msgid , $group )
{
global $spooldir , $config_dir , $logdir ;
2024-06-07 13:13:23 +02:00
if ( file_exists ( $config_dir . '/cache.inc.php' )) {
include $config_dir . '/cache.inc.php' ;
2024-06-05 13:05:17 +02:00
}
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
$row_cache = $cache_key_prefix . '_' . 'get_db_data_from_msgid-' . $msgid ;
2024-06-07 16:39:33 +02:00
if ( $row = unserialize ( gzuncompress ( cache_get ( $row_cache , $memcacheD )))) {
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache hit) $row_cache " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
return $row ;
}
}
$database = $spooldir . '/' . $group . '-articles.db3' ;
if ( ! is_file ( $database )) {
return false ;
}
$articles_dbh = article_db_open ( $database );
$articles_query = $articles_dbh -> prepare ( 'SELECT * FROM articles WHERE msgid=:messageid' );
$articles_query -> execute ([
'messageid' => $msgid
]);
$found = 0 ;
while ( $row = $articles_query -> fetch ()) {
$found = 1 ;
break ;
}
$dbh = null ;
if ( $found ) {
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
2024-06-07 16:39:33 +02:00
$nicole = cache_add ( $row_cache , gzcompress ( serialize ( $row )), $cache_ttl , $memcacheD );
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging && $nicole ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache write) $row_cache " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
return $row ;
} else {
return false ;
}
}
function get_group_array_from_msgid ( $msgid )
{
global $spooldir ;
$database = $spooldir . '/articles-overview.db3' ;
$overview_dbh = overview_db_open ( $database );
$overview_query = $overview_dbh -> prepare ( 'SELECT * FROM overview WHERE msgid=:messageid' );
$overview_query -> execute ([
'messageid' => $msgid
]);
$newsgroups = array ();
$found = false ;
while ( $row = $overview_query -> fetch ()) {
$newsgroups [] = $row [ 'newsgroup' ];
$found = true ;
}
$dbh = null ;
if ( $found ) {
return $newsgroups ;
} else {
return false ;
}
}
/* get_data_from_msgid uses overview database */
/* get_db_data_from_msgid uses overview database */
function get_data_from_msgid ( $msgid , $thisgroup = null )
{
global $spooldir , $config_dir , $logdir , $CONFIG ;
2024-06-07 13:13:23 +02:00
if ( file_exists ( $config_dir . '/cache.inc.php' )) {
include $config_dir . '/cache.inc.php' ;
2024-06-05 13:05:17 +02:00
}
if ( $CONFIG [ 'article_database' ] == '1' && isset ( $thisgroup )) {
return get_db_data_from_msgid ( $msgid , $thisgroup );
}
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
$row_cache = $cache_key_prefix . '_' . 'get_data_from_msgid-' . $msgid ;
2024-06-18 12:44:07 +02:00
if ( $row = unserialize ( gzuncompress ( cache_get ( $row_cache , $memcacheD )))) {
2024-06-25 13:44:51 +02:00
if ( isset ( $row [ 'msgid' ])) {
if ( $enable_cache_logging ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache hit) $row_cache " , FILE_APPEND );
2024-06-25 13:44:51 +02:00
}
return $row ;
2024-06-05 13:05:17 +02:00
}
2024-06-18 12:44:07 +02:00
} else {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache update) $row_cache " , FILE_APPEND );
2024-06-18 12:44:07 +02:00
cache_delete ( $row_cache , $memcacheD );
}
2024-06-05 13:05:17 +02:00
}
$database = $spooldir . '/articles-overview.db3' ;
$articles_dbh = overview_db_open ( $database );
if ( $thisgroup != null ) {
$articles_query = $articles_dbh -> prepare ( 'SELECT * FROM overview WHERE msgid=:messageid AND newsgroup=:newsgroup' );
$articles_query -> execute ([
'messageid' => $msgid ,
'newsgroup' => $thisgroup
]);
} else {
$articles_query = $articles_dbh -> prepare ( 'SELECT * FROM overview WHERE msgid=:messageid' );
$articles_query -> execute ([
'messageid' => $msgid
]);
}
$found = 0 ;
while ( $row = $articles_query -> fetch ()) {
$found = 1 ;
break ;
}
$dbh = null ;
if ( $found ) {
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
2024-06-18 12:44:07 +02:00
$nicole = cache_add ( $row_cache , gzcompress ( serialize ( $row )), $cache_ttl , $memcacheD );
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging && $nicole ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " (cache write) $row_cache " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
return $row ;
} else {
return false ;
}
}
function prune_dir_by_days ( $path , $days )
{
if ( $filenames = array_diff ( scandir ( $path ), array (
'..' ,
'.'
))) {
foreach ( $filenames as $file ) {
$filelastmodified = filemtime ( $path . $file );
if (( time () - $filelastmodified ) > $days * 86400 ) {
if ( is_file ( $path . $file )) {
unlink ( $path . $file );
}
}
}
} else {
return false ;
}
return true ;
}
function check_registered_email_addresses ( $email )
{
global $config_dir ;
$users = scandir ( $config_dir . " /userconfig " );
foreach ( $users as $user ) {
if ( strcmp ( get_user_config ( $user , 'email' ), $email ) == 0 ) {
return $user ;
}
}
return false ;
}
function send_admin_message ( $admin , $from , $subject , $message )
{
global $config_dir , $spooldir ;
if (( $to = get_config_value ( 'aliases.conf' , strtolower ( $admin ))) == false ) {
$to = strtolower ( $admin );
}
$to = trim ( $to );
$from = $to ;
$database = $spooldir . '/mail.db3' ;
$dbh = mail_db_open ( $database );
if ( ! $dbh ) {
echo " Database error \n " ;
return false ;
}
$date = time ();
$msgid = '<' . md5 ( strtolower ( $to ) . strtolower ( $from ) . strtolower ( $subject ) . strtolower ( $message )) . '>' ;
$sql = 'INSERT OR IGNORE INTO messages(msgid, mail_from, rcpt_to, rcpt_target, date, subject, message, from_hide, to_hide, mail_viewed, rcpt_viewed) VALUES(?,?,?,?,?,?,?,?,?,?,?)' ;
$stmt = $dbh -> prepare ( $sql );
$target = " local " ;
$mail_viewed = " true " ;
$rcpt_viewed = null ;
$q = $stmt -> execute ([
$msgid ,
$from ,
$to ,
$target ,
$date ,
$subject ,
$message ,
null ,
null ,
false ,
false
]);
$dbh = null ;
return true ;
}
function delete_message ( $messageid , $group = null , $overview_dbh = null )
{
global $logfile , $logdir , $config_dir , $spooldir , $CONFIG , $webserver_group ;
2024-06-07 13:13:23 +02:00
if ( file_exists ( $config_dir . '/cache.inc.php' )) {
include $config_dir . '/cache.inc.php' ;
2024-06-05 13:05:17 +02:00
}
if ( $group == null ) {
$grouplist = get_newsgroups_by_msgid ( $messageid );
} else {
$grouplist [ 0 ] = $group ;
}
/* Find section */
$menulist = file ( $config_dir . " menu.conf " , FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES );
foreach ( $grouplist as $group ) {
$config_name = get_section_by_group ( $group , true );
if ( ! $config_name ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " Group not found: " . $group , FILE_APPEND );
2024-06-05 13:05:17 +02:00
continue ;
}
if ( $CONFIG [ 'article_database' ] == '1' ) {
$database = $spooldir . '/' . $group . '-articles.db3' ;
$articles_dbh = article_db_open ( $database );
if ( $articles_dbh ) {
$articles_stmt = $articles_dbh -> prepare ( 'DELETE FROM articles WHERE msgid=:messageid' );
$articles_stmt -> execute ([
'messageid' => $messageid
]);
$articles_dbh = null ;
} else {
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " " . $config_name . " Failed to access: " . $database , FILE_APPEND );
2024-06-05 13:05:17 +02:00
continue ;
}
}
// Handle overview and history
if ( $overview_dbh == null ) {
$database = $spooldir . '/articles-overview.db3' ;
$overview_dbh = overview_db_open ( $database );
if ( ! $overview_dbh ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " " . $config_name . " FAILED opening " . $database , FILE_APPEND );
2024-06-05 13:05:17 +02:00
return ;
}
$close_ovdb = true ;
}
$overview_stmt_del = $overview_dbh -> prepare ( 'DELETE FROM overview WHERE newsgroup=:newsgroup AND msgid=:msgid' );
$overview_query = $overview_dbh -> prepare ( 'SELECT * FROM overview WHERE newsgroup=:newsgroup AND msgid=:msgid' );
$overview_query -> execute ([
':newsgroup' => $group ,
':msgid' => $messageid
]);
$grouppath = preg_replace ( '/\./' , '/' , $group );
$status = " deleted " ;
$statusdate = time ();
$statusreason = " nocem " ;
$statusnotes = null ;
while ( $row = $overview_query -> fetch ()) {
if ( isset ( $row [ 'number' ])) {
// echo "\nFOUND: " . $messageid . " IN: " . $group;
2024-07-18 14:20:38 +02:00
file_put_contents ( $logfile , " \n " . logging_prefix () . " " . $config_name . " DELETING: " . $messageid . " IN: " . $group , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
if ( is_file ( $spooldir . '/articles/' . $grouppath . '/' . $row [ 'number' ])) {
unlink ( $spooldir . '/articles/' . $grouppath . '/' . $row [ 'number' ]);
}
delete_message_from_overboard ( $config_name , $group , $messageid );
add_to_history ( $group , $row [ 'number' ], $row [ 'msgid' ], $status , $statusdate , $statusreason , $statusnotes );
thread_cache_removearticle ( $group , $row [ 'number' ]);
$overview_stmt_del -> execute ([
':newsgroup' => $group ,
':msgid' => $messageid
]);
// Delete article from memcache
2024-06-07 13:13:23 +02:00
if ( $enable_cache ) {
$article_key = $cache_key_prefix . '_' . 'article.db3-' . $group . ':' . $row [ 'number' ];
2024-06-07 14:43:52 +02:00
$result = cache_delete ( $article_key , $memcacheD );
2024-06-07 13:13:23 +02:00
if ( $enable_cache_logging ) {
2024-06-05 13:05:17 +02:00
if ( $result ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " Deleted $article_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
} else {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " Failed to delete (or not found) $article_key " , FILE_APPEND );
2024-06-05 13:05:17 +02:00
}
}
}
}
}
if ( $close_ovdb ) {
$overview_dbh = null ;
}
return ;
}
// This function returns FALSE if article is OK
// Else returns a string with reason for failure
function check_article_integrity ( $rawmessage )
{
global $CONFIG , $logfile , $config_name ;
$returnval = false ;
$count_rawmessage = count ( $rawmessage );
$message = new messageType ();
$rawheader = array ();
$i = 0 ;
while ( $rawmessage [ $i ] != " " ) {
$rawheader [] = $rawmessage [ $i ];
2024-09-28 18:15:51 +02:00
$i ++ ;
2024-06-05 13:05:17 +02:00
}
// Parse the Header:
$message -> header = parse_header ( $rawheader );
// Check if date is in future (allow up to 60 seconds in future)
if ( $message -> header -> date > ( time () + 60 )) {
$returnval = " Skipping message (date in future): " . $message -> header -> id . " ( " . date ( 'M d H:i:s' , $message -> header -> date ) . " ) " ;
2024-09-29 19:17:13 +02:00
return $returnval ;
}
// Date is probably 1 Jan 1970
if ( $message -> header -> date < 100 ) {
$returnval = " Skipping message (date too old): " . $message -> header -> id . " ( " . date ( 'M d H:i:s' , $message -> header -> date ) . " ) " ;
2024-06-05 13:05:17 +02:00
return $returnval ;
}
// Now we know if the message is a mime-multipart message:
$content_type = explode ( " / " , $message -> header -> content_type [ 0 ]);
if ( $content_type [ 0 ] == " multipart " ) {
$message -> header -> content_type = array ();
// We have multible bodies, so we split the message into its parts
$boundary = " -- " . $message -> header -> content_type_boundary ;
// lets find the first part
while ( $rawmessage [ $i ] != $boundary ) {
2024-09-28 18:15:51 +02:00
$i ++ ;
2024-06-05 13:05:17 +02:00
if ( $i > $count_rawmessage ) {
$returnval = " Skipping malformed message: " . $message -> header -> id ;
return $returnval ;
}
}
}
return $returnval ;
}
2024-09-20 00:43:59 +02:00
/* Remove or replace characters in a string */
2024-09-28 18:15:51 +02:00
function sanitize_header ( $text )
{
2024-09-20 00:43:59 +02:00
return preg_replace ( " / \ `/ " , " ' " , $text );
}
2024-06-05 13:05:17 +02:00
function wrap_post ( $body )
{
2024-09-19 14:19:26 +02:00
global $wrap_width ;
2024-06-05 13:05:17 +02:00
$lines = preg_split ( " / \n / " , $body );
$wrapped = '' ;
foreach ( $lines as $line ) {
2024-06-24 22:57:51 +02:00
$line = rtrim ( $line );
2024-06-05 13:05:17 +02:00
if ( trim ( $line ) == '' ) {
$wrapped .= " \n " ;
continue ;
}
if ( $line [ 0 ] == '>' ) {
$depth = 0 ;
while ( $line [ $depth ] == '>' ) {
2024-09-28 18:15:51 +02:00
$depth ++ ;
2024-06-05 13:05:17 +02:00
if ( $depth > 30 ) {
break ;
}
}
2024-09-19 14:19:26 +02:00
if ( strlen ( $line ) > $wrap_width ) {
2024-06-05 13:05:17 +02:00
// HERE is where we wrap quoted lines (not so easy)
$start = substr ( $line , 0 , $depth + 1 );
$end = substr ( $line , $depth + 1 );
2024-09-19 14:19:26 +02:00
$line_wrapped = $start . mb_wordwrap ( $end , $wrap_width );
2024-06-05 13:05:17 +02:00
$line_wrapped = preg_split ( " / \n / " , $line_wrapped );
foreach ( $line_wrapped as $lw ) {
if ( $lw [ 0 ] != '>' ) {
$i = 0 ;
while ( $i < $depth ) {
$wrapped .= '>' ;
2024-09-28 18:15:51 +02:00
$i ++ ;
2024-06-05 13:05:17 +02:00
}
$wrapped .= ' ' ;
}
$wrapped .= $lw . " \n " ;
}
} else {
$wrapped .= $line . " \n " ;
}
} else {
2024-09-19 14:19:26 +02:00
if ( strlen ( $line ) > $wrap_width ) {
2024-06-05 13:05:17 +02:00
// HERE is where we wrap NON quoted lines (easy)
2024-09-19 14:19:26 +02:00
$wrapped .= mb_wordwrap ( $line , $wrap_width ) . " \n " ;
2024-06-05 13:05:17 +02:00
} else {
$wrapped .= $line . " \n " ;
}
}
}
return $wrapped ;
}
function delete_message_from_overboard ( $config_name , $group , $messageid )
{
2024-09-28 18:15:51 +02:00
global $spooldir ;
2024-06-05 13:05:17 +02:00
$cachefile = $spooldir . " / " . $config_name . " -overboard.dat " ;
if ( is_file ( $cachefile )) {
$cached_overboard = unserialize ( file_get_contents ( $cachefile ));
2024-06-11 12:22:21 +02:00
if ( isset ( $cached_overboard [ 'msgids' ][ $messageid ])) {
if ( $target = $cached_overboard [ 'msgids' ][ $messageid ]) {
unset ( $cached_overboard [ 'threads' ][ $target [ 'date' ]]);
unset ( $cached_overboard [ 'msgids' ][ $messageid ]);
unset ( $cached_overboard [ 'threadlink' ][ $messageid ]);
file_put_contents ( $cachefile , serialize ( $cached_overboard ));
}
2024-06-05 13:05:17 +02:00
}
}
$cachefile = $spooldir . " / " . $group . " -overboard.dat " ;
if ( is_file ( $cachefile )) {
$cached_overboard = unserialize ( file_get_contents ( $cachefile ));
2024-06-11 12:22:21 +02:00
if ( isset ( $cached_overboard [ 'msgids' ][ $messageid ])) {
if ( $target = $cached_overboard [ 'msgids' ][ $messageid ]) {
unset ( $cached_overboard [ 'threads' ][ $target [ 'date' ]]);
unset ( $cached_overboard [ 'msgids' ][ $messageid ]);
unset ( $cached_overboard [ 'threadlink' ][ $messageid ]);
file_put_contents ( $cachefile , serialize ( $cached_overboard ));
}
2024-06-05 13:05:17 +02:00
}
}
2024-06-07 13:13:23 +02:00
}
2024-06-11 12:22:21 +02:00
function cache_add ( $cache_key , $data , $cache_ttl , $memcacheD = null )
{
global $enable_cache , $cache_dir , $cache_log , $low_spool_disk_space ;
2024-06-07 16:39:33 +02:00
$cache_key = base64_encode ( $cache_key );
2024-06-11 12:22:21 +02:00
if ( $enable_cache == 'memcached' ) {
if ( $memcacheD ) {
if ( $nicole = $memcacheD -> add ( $cache_key , $data , $cache_ttl )) {
2024-06-07 13:13:23 +02:00
return $nicole ;
}
}
2024-06-11 12:22:21 +02:00
}
if ( $enable_cache == 'diskcache' ) {
if ( $low_spool_disk_space ) {
2024-07-18 14:20:38 +02:00
file_put_contents ( $cache_log , " \n " . logging_prefix () . " " . $config_name . " Low Disk Space (less than " . $min_spool_disk_space . " Gb available for cache). Pausing diskcache " , FILE_APPEND );
2024-06-11 12:22:21 +02:00
return false ;
}
if ( $nicole = file_put_contents ( $cache_dir . '/' . $cache_key , $data )) {
return $nicole ;
}
}
return false ;
2024-06-07 13:13:23 +02:00
}
2024-06-11 12:22:21 +02:00
function cache_delete ( $cache_key , $memcacheD = null )
{
2024-06-07 14:43:52 +02:00
global $enable_cache , $cache_dir ;
2024-06-07 16:39:33 +02:00
$cache_key = base64_encode ( $cache_key );
2024-06-11 12:22:21 +02:00
if ( $enable_cache == 'memcached' ) {
if ( $memcacheD ) {
if ( $nicole = $memcacheD -> delete ( $cache_key )) {
2024-06-07 13:13:23 +02:00
return $nicole ;
}
}
}
2024-06-11 12:22:21 +02:00
if ( $enable_cache == 'diskcache' ) {
if ( file_exists ( $cache_dir . '/' . $cache_key )) {
2024-06-07 14:43:52 +02:00
return unlink ( $cache_dir . '/' . $cache_key );
}
}
return false ;
2024-06-11 12:22:21 +02:00
}
2024-06-07 13:13:23 +02:00
2024-06-11 12:22:21 +02:00
function cache_get ( $cache_key , $memcacheD = null )
{
2024-06-07 14:43:52 +02:00
global $enable_cache , $cache_dir ;
2024-06-07 16:39:33 +02:00
$cache_key = base64_encode ( $cache_key );
2024-06-11 12:22:21 +02:00
if ( $enable_cache == 'memcached' ) {
if ( $memcacheD ) {
if ( $nicole = $memcacheD -> get ( $cache_key )) {
2024-06-07 13:13:23 +02:00
return $nicole ;
}
}
}
2024-06-11 12:22:21 +02:00
if ( $enable_cache == 'diskcache' ) {
if ( file_exists ( $cache_dir . '/' . $cache_key )) {
2024-06-07 14:43:52 +02:00
return file_get_contents ( $cache_dir . '/' . $cache_key );
}
}
return false ;
2024-06-07 13:13:23 +02:00
}
2024-07-26 17:31:40 +02:00
function change_identity ( $uid , $gid )
{
global $CONFIG ;
if ( ! posix_setgid ( $gid )) {
//print "Unable to setgid to " . $gid . "!\n";
print " Cannot change to user ' " . $CONFIG [ 'webserver_user' ] . " ' \n " ;
exit ();
}
if ( ! posix_setuid ( $uid )) {
//print "Unable to setuid to " . $uid . "!\n";
print " Cannot change to user ' " . $CONFIG [ 'webserver_user' ] . " ' \n " ;
exit ();
}
}
