ban4ipd_init.php

<?php
// ------------------------------------------------------------
// 
// BAN for iptables/ip6tables
// 
// T.Kabu/MyDNS.JP           http://www.MyDNS.JP/
// Future Versatile Group    http://www.fvg-on.net/
// 
// ------------------------------------------------------------
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function local_time()
{
    global $TIME_OFFSET;
    return(time() + $TIME_OFFSET);
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function psearch($PP, $PATTERN)
{
    // リソース$PPから一行ずつ読み込む
    while (($DATA = fgets($PP)) !== false)
    {
        // もし$DATA内に$PATTERNに該当するデータがあるなら
        if (preg_match($PATTERN, rtrim($DATA)))
        {
            // TRUEを返す
            return TRUE;
        }
    }
    // 見つからなければ、FALSEを返す
    return FALSE;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function psearch2($PP, $PATTERN)
{
    // リソース$PPから一行ずつ読み込む
    while (($DATA = fgets($PP)) !== false)
    {
        // もし$DATA内に$PATTERNに該当するデータがあるなら
        if (preg_match($PATTERN, rtrim($DATA), $MATCH, PREG_UNMATCHED_AS_NULL))
        {
            // $MATCHを返す
            return $MATCH;
        }
    }
    // 見つからなければ、FALSEを返す
    return FALSE;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function log_write($BAN4IPD_CONF)
{
    // ログファイルの指定がないなら
    if (!isset($BAN4IPD_CONF['log_file']) || !is_file($BAN4IPD_CONF['log_file']))
    {
        print $BAN4IPD_CONF['log_msg'];
        return;
    }
    
    // ログファイルポインタが開かれていないなら
    if (!isset($BAN4IPD_CONF['log_p']))
    {
        $BAN4IPD_CONF['log_p'] = fopen($BAN4IPD_CONF['log_file'], 'a');
    }
    // ログファイルポインタが開かれているなら
    if (is_resource($BAN4IPD_CONF['log_p']))
    {
        // ログファイルを排他的ロック
        while(!flock($BAN4IPD_CONF['log_p'], LOCK_EX));
        // ログファイルの一番最後までシーク
        fseek($BAN4IPD_CONF['log_p'], 0, SEEK_END);
        // ログファイルに書き出し
        fprintf($BAN4IPD_CONF['log_p'], $BAN4IPD_CONF['log_msg']);
        // ログファイルをアンロック
        flock($BAN4IPD_CONF['log_p'], LOCK_UN);
    }
    else
    {
        print $BAN4IPD_CONF['log_msg'];
    }
    
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_db_exec($TARGET_CONF, $TARGET_DB, $SQL_STR)
{
    // データベースへの再接続中なら即戻る
    if (isset($TARGET_CONF['db_reconnect_flag']) && $TARGET_CONF['db_reconnect_flag'] == 1)
    {
        return $TARGET_CONF;
    }
    
    // 結果をfalseで初期化
    $RESULT = false;
    for ($RETRY_COUNT = 0; $RETRY_COUNT < 3; $RETRY_COUNT ++)
    {
        // 2025.09.09 T.Kabu PDO経由でMySQLやPostgreSQLと接続していると、何らかの理由で勝手に切断されていることがあり、この後のtry/catchで「General error: 2006 MySQL server has gone away」エラーとなることがある。
        try {
            $RESULT = $TARGET_CONF[$TARGET_DB]->exec($SQL_STR);
        }
        catch (PDOException $PDO_E) {
            // エラーの旨メッセージを設定
            $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: WARN PDOException:".$PDO_E->getMessage()." on ".__FILE__.":".__LINE__."\n";
            // ログに出力する
            log_write($TARGET_CONF);
            // 再接続フラグON
            $TARGET_CONF['db_reconnect_flag'] = 1;
            // 親プロセスのデータベースを再接続
            $TARGET_CONF = ban4ip_dbinit($TARGET_CONF);
            // 再接続フラグOFF
            unset($TARGET_CONF['db_reconnect_flag']);
            // リトライ
            continue;
        }
        break;
    }
    // 結果を返す
    $TARGET_CONF['exec_result'] = $RESULT;
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_sqlite3_count_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // SQLite3データベース用のディレクトリを作成(エラー出力を抑制)
    @mkdir($TARGET_CONF['db_dir']);
    // SQLite3データベース用のディレクトリがないなら
    if (!is_dir($TARGET_CONF['db_dir']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['db_dir']." not found!?"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // カウントデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['count_db']) && $TARGET_CONF['count_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['count_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // カウントデータベースに接続を試す
    try
    {
        $TARGET_CONF['count_db'] = new PDO($TARGET_CONF['pdo_dsn_count']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_count']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'CREATE TABLE IF NOT EXISTS count_tbl (address, service, registdate)');
    // インデックスを作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'CREATE INDEX IF NOT EXISTS count_idx ON count_tbl (address)');
    
    // journal_modeをWALにする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'PRAGMA journal_mode=WAL');
    // synchronousをNORMALにする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'PRAGMA synchronous=NORMAL');

    // カウントデータベースのロックタイムアウト時間を少し長くする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'PRAGMA busy_timeout='.$TARGET_CONF['db_timeout']);

    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_sqlite3_ban_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // SQLite3データベース用のディレクトリを作成(エラー出力を抑制)
    @mkdir($TARGET_CONF['db_dir']);
    // SQLite3データベース用のディレクトリがないなら
    if (!is_dir($TARGET_CONF['db_dir']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['db_dir']." not found!?"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // BANデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['ban_db']) && $TARGET_CONF['ban_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['ban_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // BANデータベースに接続を試す
    try
    {
        $TARGET_CONF['ban_db'] = new PDO($TARGET_CONF['pdo_dsn_ban']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_ban']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'CREATE TABLE IF NOT EXISTS ban_tbl (address, service, protcol, port, rule, unbandate)'); 
    // インデックスを作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'CREATE INDEX IF NOT EXISTS ban_idx ON ban_tbl (address)');
    
    // journal_modeをWALにする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'PRAGMA journal_mode=WAL');
    // synchronousをNORMALにする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'PRAGMA synchronous=NORMAL');
    
    // BANデータベースのロックタイムアウト時間を少し長くする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'PRAGMA busy_timeout='.$TARGET_CONF['db_timeout']);

    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_sqlite3_mailrate_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // SQLite3データベース用のディレクトリを作成(エラー出力を抑制)
    @mkdir($TARGET_CONF['db_dir']);
    // SQLite3データベース用のディレクトリがないなら
    if (!is_dir($TARGET_CONF['db_dir']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['db_dir']." not found!?"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // メール送信レートテーブルデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['mailrate_db']) && $TARGET_CONF['mailrate_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['mailrate_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // メール送信レートテーブルデータベースに接続を試す
    try
    {
        $TARGET_CONF['mailrate_db'] = new PDO($TARGET_CONF['pdo_dsn_mailrate']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_mailrate']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'CREATE TABLE IF NOT EXISTS mailrate_tbl (to_address, title, registdate, UNIQUE (to_address, title) )');
    // インデックスを作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'CREATE INDEX IF NOT EXISTS mailrate_idx ON mailrate_tbl (to_address, title)');

    // journal_modeをWALにする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'PRAGMA journal_mode=WAL');
    // synchronousをNORMALにする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'PRAGMA synchronous=NORMAL');

    // メール送信レートテーブルデータベースのロックタイムアウト時間を少し長くする
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'PRAGMA busy_timeout='.$TARGET_CONF['db_timeout']);
    
    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_pgsql_count_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // カウントデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['count_db']) && $TARGET_CONF['count_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['count_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // カウントデータベースに接続を試す
    try
    {
        $TARGET_CONF['count_db'] = new PDO($TARGET_CONF['pdo_dsn_count']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_count']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'CREATE TABLE IF NOT EXISTS count_tbl (address varchar(48), service varchar(128), registdate bigint)');
    // インデックスを作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'CREATE INDEX IF NOT EXISTS count_idx ON count_tbl (address)');

    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_pgsql_ban_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // BANデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['ban_db']) && $TARGET_CONF['ban_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['ban_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // BANデータベースに接続を試す
    try
    {
        $TARGET_CONF['ban_db'] = new PDO($TARGET_CONF['pdo_dsn_ban']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_ban']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'CREATE TABLE IF NOT EXISTS ban_tbl (address varchar(48), service varchar(128), protcol varchar(88), port varchar(8), rule varchar(8), unbandate bigint)');
    // インデックスを作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'CREATE INDEX IF NOT EXISTS ban_idx ON ban_tbl (address)');

    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_pgsql_mailrate_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // メール送信レートテーブルデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['mailrate_db']) && $TARGET_CONF['mailrate_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['mailrate_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // メール送信レートテーブルデータベースに接続を試す
    try
    {
        $TARGET_CONF['mailrate_db'] = new PDO($TARGET_CONF['pdo_dsn_mailrate']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_mailrate']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'CREATE TABLE IF NOT EXISTS mailrate_tbl (to_address varchar(128), title varchar(128), registdate bigint, UNIQUE (to_address, title) )');
    // インデックスを作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'CREATE INDEX IF NOT EXISTS mailrate_idx ON mailrate_tbl (to_address, title)');

    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_mysql_count_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // カウントデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['count_db']) && $TARGET_CONF['count_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['count_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // カウントデータベースに接続を試す
    try
    {
        $TARGET_CONF['count_db'] = new PDO($TARGET_CONF['pdo_dsn_count'], $TARGET_CONF['pdo_dsn_username'], $TARGET_CONF['pdo_dsn_password']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_count']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'CREATE TABLE IF NOT EXISTS count_tbl (address varchar(48), service varchar(128), registdate bigint)');
    // インデックスがあるかどうか確認する
    $SQL_STR = "SELECT COUNT(*) AS idx_exists FROM INFORMATION_SCHEMA.STATISTICS WHERE TABLE_SCHEMA = 'count_db' AND TABLE_NAME   = 'count_tbl' AND INDEX_NAME   = 'count_idx'";
    $RESULT = $TARGET_CONF['count_db']->query($SQL_STR);
    // インデックスがあるなら
    if ($RESULT !== false && $RESULT->rowCount() > 0)
    {
        // インデックスの作成はしないで、$TARGET_CONFを返す
        return $TARGET_CONF;
    }
    // インデックスが無いなら作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'count_db', 'ALTER TABLE count_tbl ADD INDEX count_idx (address)');

    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_mysql_ban_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // BANデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['ban_db']) && $TARGET_CONF['ban_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['ban_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // BANデータベースに接続を試す
    try
    {
        $TARGET_CONF['ban_db'] = new PDO($TARGET_CONF['pdo_dsn_ban'], $TARGET_CONF['pdo_dsn_username'], $TARGET_CONF['pdo_dsn_password']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_ban']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'CREATE TABLE IF NOT EXISTS ban_tbl (address varchar(48), service varchar(128), protcol varchar(88), port varchar(8), rule varchar(8), unbandate bigint)');
    // インデックスがあるかどうか確認する
    $SQL_STR = "SELECT COUNT(*) AS idx_exists FROM INFORMATION_SCHEMA.STATISTICS WHERE TABLE_SCHEMA = 'ban_db' AND TABLE_NAME   = 'ban_tbl' AND INDEX_NAME   = 'ban_idx'";
    $RESULT = $TARGET_CONF['ban_db']->query($SQL_STR);
    // インデックスがあるなら
    if ($RESULT !== false && $RESULT->rowCount() > 0)
    {
        // インデックスの作成はしないで、$TARGET_CONFを返す
        return $TARGET_CONF;
    }
    // インデックスが無いなら作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'ban_db', 'ALTER TABLE ban_tbl ADD INDEX ban_idx (address)');
    
    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit_mysql_mailrate_db($TARGET_CONF)
{
    // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
    
    // メール送信レートテーブルデータベースがすでに接続されていたら
    if (isset($TARGET_CONF['mailrate_db']) && $TARGET_CONF['mailrate_db'] != null)
    {
        // いったん切断
        $TARGET_CONF['mailrate_db'] = null;
        // 100msくらいのウェイトを置く
        usleep(100000);
    }
    // メール送信レートテーブルデータベースに接続を試す
    try
    {
        $TARGET_CONF['mailrate_db'] = new PDO($TARGET_CONF['pdo_dsn_mailrate'], $TARGET_CONF['pdo_dsn_username'], $TARGET_CONF['pdo_dsn_password']);
    }
    // 接続できなかったら(失敗した場合、 PDOException を投げてくる)
    catch(PDOException $e)
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_mailrate']." not Connection!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // テーブルがなかったら作成
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'CREATE TABLE IF NOT EXISTS mailrate_tbl (to_address varchar(128), title varchar(128), registdate bigint, UNIQUE (to_address, title) )');
    // インデックスがあるかどうか確認する
    $SQL_STR = "SELECT COUNT(*) AS idx_exists FROM INFORMATION_SCHEMA.STATISTICS WHERE TABLE_SCHEMA = 'mailrate_db' AND TABLE_NAME   = 'mailrate_tbl' AND INDEX_NAME   = 'mailrate_idx'";
    $RESULT = $TARGET_CONF['mailrate_db']->query($SQL_STR);
    // インデックスがあるなら
    if ($RESULT !== false && $RESULT->rowCount() > 0)
    {
        // インデックスの作成はしないで、$TARGET_CONFを返す
        return $TARGET_CONF;
    }
    // インデックスが無いなら作成する
    $TARGET_CONF = ban4ip_db_exec($TARGET_CONF, 'mailrate_db', 'ALTER TABLE mailrate_tbl ADD INDEX mailrate_idx (to_address, title)');

    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_dbinit($TARGET_CONF)
{
    // ----------------
    // カウントデータベースのデータソース名(DSN)の指定がなければ、
    // ----------------
    if (empty($TARGET_CONF['pdo_dsn_count']))
    {
        // カウントデータベースに接続(無ければ新規に作成)
        $TARGET_CONF['pdo_dsn_count'] = 'sqlite:' . $TARGET_CONF['db_dir'].'/count.db';
    }
    
    // ----------------
    // BANデータベースのデータソース名(DSN)の指定がなければ、
    // ----------------
    if (empty($TARGET_CONF['pdo_dsn_ban']))
    {
        // BANデータベースに接続(無ければ新規に作成)
        $TARGET_CONF['pdo_dsn_ban'] = 'sqlite:' . $TARGET_CONF['db_dir'].'/ban.db';
    }
    
    // ----------------
    // メール送信レートデータベースのデータソース名(DSN)の指定がなければ、
    // ----------------
    if (empty($TARGET_CONF['pdo_dsn_mailrate']))
    {
        // メール送信レートテーブルデータベースに接続(無ければ新規に作成)
        $TARGET_CONF['pdo_dsn_mailrate'] = 'sqlite:' . $TARGET_CONF['db_dir'].'/mailrate.db';
    }
    
    // ----------------
    // カウントデータベースのデータソース名(DSN)の指定により初期化処理分岐
    // ----------------
    // カウントデータベースのデータソース名(DSN)の指定が「pgsql」なら
    if (isset($TARGET_CONF['pdo_dsn_count']) && preg_match('/^pgsql/', $TARGET_CONF['pdo_dsn_count']))
    {
        // カウントデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_pgsql_count_db($TARGET_CONF);
    }
    // カウントデータベースのデータソース名(DSN)の指定が「mysql」なら
    else if (isset($TARGET_CONF['pdo_dsn_count']) && isset($TARGET_CONF['pdo_dsn_username']) && isset($TARGET_CONF['pdo_dsn_password']) && preg_match('/^mysql/', $TARGET_CONF['pdo_dsn_count']))
    {
        // カウントデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_mysql_count_db($TARGET_CONF);
    }
    // カウントデータベースのデータソース名(DSN)の指定が「sqlite」なら
    else if (isset($TARGET_CONF['pdo_dsn_count']) && preg_match('/^sqlite/', $TARGET_CONF['pdo_dsn_count']))
    {
        // カウントデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_sqlite3_count_db($TARGET_CONF);
    }
    // カウントデータベースのデータソース名(DSN)の指定が上記以外なら
    else
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_count'].", not supported!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // ----------------
    // BANデータベースのデータソース名(DSN)の指定により初期化処理分岐
    // ----------------
    // BANデータベースのデータソース名(DSN)の指定が「pgsql」なら
    if (isset($TARGET_CONF['pdo_dsn_ban']) && preg_match('/^pgsql/', $TARGET_CONF['pdo_dsn_ban']))
    {
        // BANデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_pgsql_ban_db($TARGET_CONF);
    }
    // BANデータベースのデータソース名(DSN)の指定が「mysql」なら
    else if (isset($TARGET_CONF['pdo_dsn_ban']) && isset($TARGET_CONF['pdo_dsn_username']) && isset($TARGET_CONF['pdo_dsn_password']) && preg_match('/^mysql/', $TARGET_CONF['pdo_dsn_ban']))
    {
        // BANデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_mysql_ban_db($TARGET_CONF);
    }
    // BANデータベースのデータソース名(DSN)の指定が「sqlite」なら
    else if (isset($TARGET_CONF['pdo_dsn_ban']) && preg_match('/^sqlite/', $TARGET_CONF['pdo_dsn_ban']))
    {
        // BANデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_sqlite3_ban_db($TARGET_CONF);
    }
    // BANデータベースのデータソース名(DSN)の指定が上記以外なら
    else
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_ban'].", not supported!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // ----------------
    // メール送信レートデータベースのデータソース名(DSN)の指定により初期化処理分岐
    // ----------------
    // メール送信レートデータベースのデータソース名(DSN)の指定が「pgsql」なら
    if (isset($TARGET_CONF['pdo_dsn_mailrate']) && preg_match('/^pgsql/', $TARGET_CONF['pdo_dsn_mailrate']))
    {
        // メール送信レートデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_pgsql_mailrate_db($TARGET_CONF);
    }
    // メール送信レートデータベースのデータソース名(DSN)の指定が「mysql」なら
    else if (isset($TARGET_CONF['pdo_dsn_mailrate']) && isset($TARGET_CONF['pdo_dsn_username']) && isset($TARGET_CONF['pdo_dsn_password']) && preg_match('/^mysql/', $TARGET_CONF['pdo_dsn_mailrate']))
    {
        // メール送信レートデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_mysql_mailrate_db($TARGET_CONF);
    }
    // メール送信レートデータベースのデータソース名(DSN)の指定が「sqlite」なら
    else if (isset($TARGET_CONF['pdo_dsn_mailrate']) && preg_match('/^sqlite/', $TARGET_CONF['pdo_dsn_mailrate']))
    {
        // メール送信レートデータベースの初期化処理
        // 2025.09.05 いつの間にかDBの初期化を親プロセスのみでするようになっていて処理構造がおかしくなっていたのでdbinitを見直し
        $TARGET_CONF = ban4ip_dbinit_sqlite3_mailrate_db($TARGET_CONF);
    }
    // メール送信レートデータベースのデータソース名(DSN)の指定が上記以外なら
    else
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR ".$TARGET_CONF['pdo_dsn_mailrate'].", not supported!? "."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // すべて正常終了なら、$TARGET_CONFを返す
    return $TARGET_CONF;
}
?>
<?php
// ----------------------------------------------------------------------
// Sub Routine
// ----------------------------------------------------------------------
function ban4ip_issinit($TARGET_CONF)
{
    // ----------------
    // 情報共有サーバー関連の初期化処理
    // ----------------
    // 情報共有サーバー名が設定されていないなら
    if (!isset($TARGET_CONF['iss_server']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR iss_server is not set!?"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    // 情報共有サーバーへ接続するユーザー名が設定されていないなら
    if (!isset($TARGET_CONF['iss_username']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR iss_username is not set!?"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    // 情報共有サーバーへ接続するユーザー名のパスワードが設定されていないなら
    if (!isset($TARGET_CONF['iss_password']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR iss_password is not set!?"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    
    // BAN情報取得秒数(現在時刻よりiss_get_time[秒]前までのデータを取得する)がおかしい場合には
    if (!isset($TARGET_CONF['iss_get_time']) || !is_numeric($TARGET_CONF['iss_get_time']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR iss_get_time(".$TARGET_CONF['iss_get_time'].")"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
    // BAN情報取得数(最大iss_get_limit[個]のデータを取得する)がおかしい場合には
    if (!isset($TARGET_CONF['iss_get_limit']) || !is_numeric($TARGET_CONF['iss_get_limit']))
    {
        $TARGET_CONF['log_msg'] = date("Y-m-d H:i:s", local_time())." ban4ip[".getmypid()."]: ERROR iss_get_limit(".$TARGET_CONF['iss_get_limit'].")"."\n";
        // ログに出力する
        log_write($TARGET_CONF);
        // 終わり
        exit -1;
    }
}
?>
<?php
// ----------------------------------------------------------------------
// Init Routine
// ----------------------------------------------------------------------
// 環境変数などを設定する
// 時刻オフセット初期化
$TIME_OFFSET = 0;

// Cannot find timezone
if (ini_get('date.timezone') == FALSE)
{
    // Set system timezone to UTC
    date_default_timezone_set(@date_default_timezone_get());
    
    // Get system time
    exec("/bin/date +'%Y/%m/%d %H:%M:%S'", $EXEC_RESULT, $EXEC_RETVAL);
    // Complete
    if ($EXEC_RETVAL == 0)
    {
        // Get difference between the values of system time and PHP time
        $TIME_OFFSET = strtotime($EXEC_RESULT[0]) - time();
        
        // Set offset time if it is more than 60sec
        if ($TIME_OFFSET && ($TIME_OFFSET % 60) == 0)
        {
        }
        else if ($TIME_OFFSET > 0)
        {
            // Set time offset in minutes
            $TIME_OFFSET += (60 - ($TIME_OFFSET % 60));
        }
        else if ($TIME_OFFSET < 0)
        {
            // Set time offset in minutes
            $TIME_OFFSET -= ($TIME_OFFSET % 60);
        }
    }
}

// 内部文字コード
mb_internal_encoding('UTF-8');

// 出力文字コード
mb_http_output('UTF-8');

// メイン設定ファイル名
$BAN4IPD_CONF['main_conf'] = '/etc/ban4ipd.conf';

?>
<?php
// ----------------------------------------------------------------------
// Check inotify module
// ----------------------------------------------------------------------
// inotifyモジュールがあるか確認
if (!extension_loaded('inotify'))
{
    print "inotify extension not loaded!?"."\n";
    exit -1;
}
?>
<?php
// ----------------------------------------------------------------------
// Check sqlite module
// ----------------------------------------------------------------------
// sqlite3モジュールがあるか確認
if (!extension_loaded('sqlite3'))
{
    print "sqlite3 extension not loaded!?"."\n";
    // 終わり
    exit -1;
}
?>
<?php
// ----------------------------------------------------------------------
// Check pdo_sqlite module
// ----------------------------------------------------------------------
// pdo_sqliteモジュールがあるか確認
if (!extension_loaded('pdo_sqlite'))
{
    print "pdo_sqlite extension not loaded!?"."\n";
    // 終わり
    exit -1;
}
?>
<?php
// ----------------------------------------------------------------------
// Check sockets module
// ----------------------------------------------------------------------
// socketsモジュールがあるか確認
if (!extension_loaded('sockets'))
{
    print "sockets extension not loaded!?"."\n";
    // 終わり
    exit -1;
}
?>
<?php
// ----------------------------------------------------------------------
// Read Configration
// ----------------------------------------------------------------------
// メイン設定ファイルがあるなら
if (is_file($BAN4IPD_CONF['main_conf']))
{
    // メイン設定ファイルを読み込んで変数展開する
    $BAN4IPD_CONF = parse_ini_file($BAN4IPD_CONF['main_conf'], FALSE, INI_SCANNER_NORMAL);
}
// 無ければ、
else
{
    print $BAN4IPD_CONF['main_conf']." not found!?"."\n";
    // 終わり
    exit -1;
}
// 読み込めなかったら
if ($BAN4IPD_CONF === FALSE)
{
    print "Cannot loaded main config file!?"."\n";
    // 終わり
    exit -1;
}
?>
<?php
// ----------------------------------------------------------------------
// Get init or systemd
// ----------------------------------------------------------------------
// システムがinit管理かsystemd管理かを取得
$BAN4IPD_CONF['system_pid0'] = file_get_contents('/proc/1/comm');
$BAN4IPD_CONF['system_pid0'] = rtrim($BAN4IPD_CONF['system_pid0']);
?>