From 6cd57d56a2873897fa1a037e89e66dd02c59511d Mon Sep 17 00:00:00 2001
From: Gianni Ceccarelli <gianni.ceccarelli@net-a-porter.com>
Date: Fri, 14 Dec 2012 14:09:36 +0000
Subject: dedupe schema & trace update

---
 lib/Feed/Role/DeDupe.pm | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

(limited to 'lib')

diff --git a/lib/Feed/Role/DeDupe.pm b/lib/Feed/Role/DeDupe.pm
index 164e3ec..9cd19c8 100644
--- a/lib/Feed/Role/DeDupe.pm
+++ b/lib/Feed/Role/DeDupe.pm
@@ -60,7 +60,8 @@ sub _maybe_build_schema {
     } catch {
         $dbh->do(<<'SQL');
 CREATE TABLE seen_items (
-    id VARCHAR(255) PRIMARY KEY
+    id VARCHAR(255) PRIMARY KEY,
+    last_seen TIMESTAMP
 )
 SQL
 $dbh->commit;
@@ -121,7 +122,7 @@ sub seen_already {
 
     my $id = $self->_entry_id($e);
 
-    my $count = $self->_update_sth->execute($id);
+    my $count = 0 + $self->_update_sth->execute($id);
 
     $self->log->trace("seen_already - end ($count)");
 
@@ -145,15 +146,21 @@ sub _entry_id {
 
     my $id = $e->id;
 
+    $self->log->trace("_entry_id: $id");
+
     if ($self->dedupe_use_date) {
         my $date = $e->modified // $e->issued;
-        if ($date) { $id .= '-' . $date->iso8601 }
+        if ($date) {
+            $id .= '-' . $date->iso8601;
+            $self->log->trace("_entry_id: (with date) $id");
+        }
     }
 
     if ($self->dedupe_use_body) {
         my $body = $e->content->body;
         my $content_digest = sha1_base64(encode('utf-8',$body));
         $id .= '-' . $content_digest;
+        $self->log->trace("_entry_id: (with content) $id");
     }
 
     return encode('utf-8',$id);
-- 
cgit v1.2.3