Package net.tomp2p.storage

Examples of net.tomp2p.storage.Data.object()


    Data data = new Data(testData).protectEntryNow(keyPair1, factory);
    FuturePut futurePut1 = p1.put(lKey).domainKey(dKey).sign().data(cKey, data).keyPair(keyPair1).start();
    futurePut1.awaitUninterruptibly();
    Assert.assertTrue(futurePut1.isSuccess());
    Data retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair1.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair1.getPublic(), factory));
    // change the key pair to the new one using an empty data object
View Full Code Here


    Assert.assertTrue(futurePut1.isSuccess());
    Data retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair1.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair1.getPublic(), factory));
    // change the key pair to the new one using an empty data object
    data = new Data(testData).protectEntryNow(keyPair2, factory).duplicateMeta();
    // use the old protection key to sign the message
    FuturePut futurePut2 = p1.put(lKey).domainKey(dKey).sign().putMeta().data(cKey, data)
View Full Code Here

    FuturePut futurePut2 = p1.put(lKey).domainKey(dKey).sign().putMeta().data(cKey, data)
            .keyPair(keyPair1).start();
    futurePut2.awaitUninterruptibly();
    Assert.assertTrue(futurePut2.isSuccess());
    retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    // should be not possible to modify
View Full Code Here

    Assert.assertTrue(futurePut2.isSuccess());
    retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    // should be not possible to modify
    data = new Data().protectEntryNow(keyPair1, factory);
    FuturePut futurePut3 = p1.put(lKey).domainKey(dKey).sign().data(cKey, data).keyPair(keyPair1).start();
    futurePut3.awaitUninterruptibly();
View Full Code Here

    data = new Data().protectEntryNow(keyPair1, factory);
    FuturePut futurePut3 = p1.put(lKey).domainKey(dKey).sign().data(cKey, data).keyPair(keyPair1).start();
    futurePut3.awaitUninterruptibly();
    Assert.assertFalse(futurePut3.isSuccess());
    retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    // modify with new protection key
View Full Code Here

    Assert.assertFalse(futurePut3.isSuccess());
    retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(testData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    // modify with new protection key
    String newTestData = "new data";
    data = new Data(newTestData).protectEntryNow(keyPair2, factory);
    FuturePut futurePut4 = p1.put(lKey).domainKey(dKey).sign().data(cKey, data).keyPair(keyPair2).start();
View Full Code Here

    data = new Data(newTestData).protectEntryNow(keyPair2, factory);
    FuturePut futurePut4 = p1.put(lKey).domainKey(dKey).sign().data(cKey, data).keyPair(keyPair2).start();
    futurePut4.awaitUninterruptibly();
    Assert.assertTrue(futurePut4.isSuccess());
    retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(newTestData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(newTestData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    p1.shutdown().awaitUninterruptibly();
View Full Code Here

    Assert.assertTrue(futurePut4.isSuccess());
    retData = p1.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(newTestData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    retData = p2.get(lKey).domainKey(dKey).contentKey(cKey).start().awaitUninterruptibly().data();
    Assert.assertEquals(newTestData, (String) retData.object());
    Assert.assertTrue(retData.verify(keyPair2.getPublic(), factory));
    p1.shutdown().awaitUninterruptibly();
    p2.shutdown().awaitUninterruptibly();
  }
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.