<?php

$mysql_conn = false;

function mysql_reconnect()

{

  global $mysql_conn, $mysql_host, $mysql_user, $mysql_pass, $mysql_dbname;

  if ( $mysql_conn )

  {

    @mysql_close($mysql_conn);

    if ( defined('LIBIRC_DEBUG') )

    {

      echo "< > Reconnecting to MySQL\n";

    }

  }

  // connect to MySQL

  $mysql_conn = @mysql_connect($mysql_host, $mysql_user, $mysql_pass);

  if ( !$mysql_conn )

  {

    $m_e = mysql_error();

    echo "Error connecting to MySQL: $m_e\n";

    exit(1);

  }

  $q = @mysql_query("USE `$mysql_dbname`;", $mysql_conn);

  if ( !$q )

  {

    $m_e = mysql_error();

    echo "Error selecting database: $m_e\n";

    exit(1);

  }

}

function eb_mysql_query($sql, $conn = false)

{

  global $mysql_conn, $irc;

  $m_et = false;

  while ( true )

  {

    $q = mysql_query($sql, $mysql_conn);

    if ( !$q )

    {

      $m_e = mysql_error();

      if ( strpos($m_e, 'gone away') && !$m_et )

      {

        mysql_reconnect();

        continue;

      }

      $m_et = true;

      // alert everyone on the bot's alert list

      if ( is_object($irc) )

      {

        global $permissions;

        foreach ( $permissions as $nick => $perms )

        {

          if ( check_permissions($nick, array('context' => 'alert')) )

            $irc->privmsg($nick, "MySQL query error: $m_e");

        }

      }

      else

      {

        echo "\nQUERY ERROR: $m_e\nQuery: $sql\n";

        exit(1);

      }

      return false;

    }

    break;

  }

  return $q;

}

function db_escape($str)

{

  return mysql_real_escape_string($str);

}