Merge pull request #82 from eclipse/couchbase-ttl-fix

Couchbase ttl fix

Author: furlaneto

couchbase-driver/src/main/java/org/jnosql/diana/couchbase/document/DefaultCouchbaseDocumentCollectionManager.java

@@ -38,7 +38,6 @@
 
 import static java.util.Objects.nonNull;
 import static java.util.Objects.requireNonNull;
-import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import static java.util.stream.Collectors.toSet;
 import static org.jnosql.diana.couchbase.document.EntityConverter.ID_FIELD;
 import static org.jnosql.diana.couchbase.document.EntityConverter.KEY_FIELD;
@@ -81,7 +80,7 @@ public DocumentEntity insert(DocumentEntity entity, Duration ttl) {
 
         String prefix = getPrefix(id, entity.getName());
         jsonObject.put(KEY_FIELD, prefix);
-        bucket.upsert(JsonDocument.create(prefix, jsonObject), ttl.toMillis(), MILLISECONDS);
+        bucket.upsert(JsonDocument.create(prefix, (int) ttl.getSeconds(), jsonObject));
         return entity;
     }
 

couchbase-driver/src/test/java/org/jnosql/diana/couchbase/document/CouchbaseDocumentCollectionManagerAsyncTest.java

@@ -98,7 +98,7 @@ public void shouldInserAsyncTTL() throws InterruptedException {
         Document id = entity.find("name").get();
         DocumentQuery query = select().from(COLLECTION_NAME).where(id.getName()).eq(id.get()).build();
         List<DocumentEntity> entities = entityManager.select(query);
-        assertFalse(entities.isEmpty());
+        assertTrue(entities.isEmpty());
 
     }
 
@@ -115,7 +115,7 @@ public void shouldInserAsyncCalbackTTL() throws InterruptedException {
         Document id = entity.find("name").get();
         DocumentQuery query = select().from(COLLECTION_NAME).where(id.getName()).eq(id.get()).build();
         List<DocumentEntity> entities = entityManager.select(query);
-        assertFalse(entities.isEmpty());
+        assertTrue(entities.isEmpty());
 
     }