From 2586aca34e241b5ad253db7ce2e6435987453274 Mon Sep 17 00:00:00 2001
From: Sebastian Grewe <sebastian@grewe.ca>
Date: Sun, 7 Jul 2013 19:52:24 +0200
Subject: [PATCH] Revert "Fixing issue with delayed inserts for shares"

This reverts commit 752b3e810fa9687e964122d602d2291123b3640a.
---
 cronjobs/findblock.php                 | 2 +-
 public/include/classes/share.class.php | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/cronjobs/findblock.php b/cronjobs/findblock.php
index 78bacd3e..efcc9f11 100755
--- a/cronjobs/findblock.php
+++ b/cronjobs/findblock.php
@@ -77,7 +77,7 @@ if (empty($aAllBlocks)) {
   foreach ($aAllBlocks as $iIndex => $aBlock) {
     if (empty($aBlock['share_id'])) {
       // Fetch this blocks upstream ID
-      if ($share->setUpstream($block->getLastUpstreamId())) {
+      if ($share->setUpstream($block->getLastUpstreamId(), $aBlock['time'])) {
         $iCurrentUpstreamId = $share->getUpstreamId();
         $iAccountId = $user->getUserId($share->getUpstreamFinder());
       } else {
diff --git a/public/include/classes/share.class.php b/public/include/classes/share.class.php
index 85935a2d..6653814a 100644
--- a/public/include/classes/share.class.php
+++ b/public/include/classes/share.class.php
@@ -177,15 +177,16 @@ class Share {
    * @param last int Skips all shares up to last to find new share
    * @return bool
    **/
-  public function setUpstream($last=0) {
+  public function setUpstream($last=0, $time=0) {
     $stmt = $this->mysqli->prepare("
       SELECT
       SUBSTRING_INDEX( `username` , '.', 1 ) AS account, id
       FROM $this->table
       WHERE upstream_result = 'Y'
       AND id > ?
+      AND UNIX_TIMESTAMP(time) >= ?
       ORDER BY id ASC LIMIT 1");
-    if ($this->checkStmt($stmt) && $stmt->bind_param('i', $last) && $stmt->execute() && $result = $stmt->get_result()) {
+    if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $last, $time) && $stmt->execute() && $result = $stmt->get_result()) {
       $this->oUpstream = $result->fetch_object();
       if (!empty($this->oUpstream->account) && is_int($this->oUpstream->id))
         return true;