noplanman / php-telegram-bot

     * @return bool If the insert was successful

     * @throws TelegramException

     */

    public static function insertInlineQueryRequest(InlineQuery $inline_query)

    {

        if (!self::isDbConnected()) {

            return false;

        }

        try {

            $sth = self::$pdo->prepare('

                INSERT IGNORE INTO `' . TB_INLINE_QUERY . '`

                (`id`, `user_id`, `location`, `query`, `offset`, `created_at`)

                VALUES

                (:id, :user_id, :location, :query, :offset, :created_at)

            ');

            $date    = self::getTimestamp();

            $user_id = null;

            $user = $inline_query->getFrom();

            if ($user instanceof User) {

                $user_id = $user->getId();

                self::insertUser($user, $date);

            }

            $sth->bindValue(':id', $inline_query->getId());

            $sth->bindValue(':user_id', $user_id);

            $sth->bindValue(':location', $inline_query->getLocation());

            $sth->bindValue(':query', $inline_query->getQuery());

            $sth->bindValue(':offset', $inline_query->getOffset());

            $sth->bindValue(':created_at', $date);

            return $sth->execute();

        } catch (PDOException $e) {

            throw new TelegramException($e->getMessage());

        }

    }

    /**

     * Insert chosen inline result request into database

     * @return bool If the insert was successful

     * @throws TelegramException

     */

    public static function insertChosenInlineResultRequest(ChosenInlineResult $chosen_inline_result)

    {

        if (!self::isDbConnected()) {

            return false;

        }

        try {

            $sth = self::$pdo->prepare('

                INSERT INTO `' . TB_CHOSEN_INLINE_RESULT . '`

                (`result_id`, `user_id`, `location`, `inline_message_id`, `query`, `created_at`)

                VALUES

                (:result_id, :user_id, :location, :inline_message_id, :query, :created_at)

            ');

            $date    = self::getTimestamp();

            $user_id = null;

            $user = $chosen_inline_result->getFrom();

            if ($user instanceof User) {

                $user_id = $user->getId();

                self::insertUser($user, $date);

            }

            $sth->bindValue(':result_id', $chosen_inline_result->getResultId());

            $sth->bindValue(':user_id', $user_id);

            $sth->bindValue(':location', $chosen_inline_result->getLocation());

            $sth->bindValue(':inline_message_id', $chosen_inline_result->getInlineMessageId());

            $sth->bindValue(':query', $chosen_inline_result->getQuery());

            $sth->bindValue(':created_at', $date);

            return $sth->execute();

        } catch (PDOException $e) {

            throw new TelegramException($e->getMessage());

        }

    }

    /**

     * Insert callback query request into database

     * @return bool If the insert was successful

     * @throws TelegramException

     */

    public static function insertShippingQueryRequest(ShippingQuery $shipping_query)

    {

        if (!self::isDbConnected()) {

            return false;

        }

        try {

            $sth = self::$pdo->prepare('

                INSERT IGNORE INTO `' . TB_SHIPPING_QUERY . '`

                (`id`, `user_id`, `invoice_payload`, `shipping_address`, `created_at`)

                VALUES

                (:id, :user_id, :invoice_payload, :shipping_address, :created_at)

            ');

            $date    = self::getTimestamp();

            $user_id = null;

            $user = $shipping_query->getFrom();

            if ($user instanceof User) {

                $user_id = $user->getId();

                self::insertUser($user, $date);

            }

            $sth->bindValue(':id', $shipping_query->getId());

            $sth->bindValue(':user_id', $user_id);

            $sth->bindValue(':invoice_payload', $shipping_query->getInvoicePayload());

            $sth->bindValue(':shipping_address', $shipping_query->getShippingAddress());

            $sth->bindValue(':created_at', $date);

            return $sth->execute();

        } catch (PDOException $e) {

            throw new TelegramException($e->getMessage());

        }

    }

    /**

     * Insert pre checkout query request into database