Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Partially cleaned up the APITest. #217

Merged
merged 1 commit into from
Feb 28, 2023
Merged

Partially cleaned up the APITest. #217

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
111 changes: 58 additions & 53 deletions src/test/java/io/ipfs/api/APITest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,20 +2,22 @@

import io.ipfs.api.cbor.*;
import io.ipfs.cid.*;
import io.ipfs.multibase.Multibase;
import io.ipfs.multihash.Multihash;
import io.ipfs.multiaddr.MultiAddress;
import org.junit.*;

import java.io.*;
import java.net.URLEncoder;
import java.nio.file.*;
import java.util.*;
import java.util.function.*;
import java.util.stream.*;

import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertArrayEquals;

@SuppressWarnings({"rawtypes", "unused"})
public class APITest {

private final IPFS ipfs = new IPFS(new MultiAddress("/ip4/127.0.0.1/tcp/5001"));
Expand All @@ -30,14 +32,14 @@ public void dag() throws IOException {
Cid expected = Cid.decode("bafyreidbm2zncsc3j25zn7lofgd4woeh6eygdy73thfosuni2rwr3bhcvu");

Multihash result = put.hash;
Assert.assertTrue("Correct cid returned", result.equals(expected));
assertEquals("Correct cid returned", result, expected);

byte[] get = ipfs.dag.get(expected);
Assert.assertTrue("Raw data equal", original.equals(new String(get).trim()));
assertEquals("Raw data equal", original, new String(get).trim());
Map res = ipfs.dag.resolve("bafyreidbm2zncsc3j25zn7lofgd4woeh6eygdy73thfosuni2rwr3bhcvu");
Assert.assertTrue("not resolved", res != null);
assertNotNull("not resolved", res);
res = ipfs.dag.stat(expected);
Assert.assertTrue("not found", res != null);
assertNotNull("not found", res);
}

@Test
Expand All @@ -52,10 +54,11 @@ public void dagCbor() throws IOException {
Cid cid = (Cid) put.hash;

byte[] get = ipfs.dag.get(cid);
Assert.assertTrue("Raw data equal", ((Map)JSONParser.parse(new String(get))).get("data").equals(value));
assertEquals("Raw data equal", ((Map) JSONParser.parse(new String(get))).get("data"),
value);

Cid expected = Cid.decode("zdpuApemz4XMURSCkBr9W5y974MXkSbeDfLeZmiQTPpvkatFF");
Assert.assertTrue("Correct cid returned", cid.equals(expected));
assertEquals("Correct cid returned", cid, expected);
}

@Test
Expand All @@ -67,14 +70,14 @@ public void keys() throws IOException {
Object rename = ipfs.key.rename(name, newName);
List<KeyInfo> rm = ipfs.key.rm(newName);
List<KeyInfo> remaining = ipfs.key.list();
Assert.assertTrue("removed key", remaining.equals(existing));
assertEquals("removed key", remaining, existing);
}

@Test
@Ignore("Not reliable")
public void log() throws IOException {
Map lsResult = ipfs.log.ls();
Assert.assertTrue("Log ls", !lsResult.isEmpty());
Assert.assertFalse("Log ls", lsResult.isEmpty());
Map levelResult = ipfs.log.level("all", "info");
Assert.assertTrue("Log level", ((String)levelResult.get("Message")).startsWith("Changed log level"));
}
Expand All @@ -89,7 +92,7 @@ public void ipldNode() {

IpldNode.CborIpldNode node = new IpldNode.CborIpldNode(cbor);
List<String> tree = node.tree("", -1);
Assert.assertTrue("Correct tree", tree.equals(Arrays.asList("/a/b", "/c")));
assertEquals("Correct tree", tree, Arrays.asList("/a/b", "/c"));
}

@Test
Expand Down Expand Up @@ -166,15 +169,17 @@ public void directoryTest() throws IOException {
throw new IllegalStateException("Different contents!");
}

// @Test
@Ignore
@Test
public void largeFileTest() throws IOException {
byte[] largerData = new byte[100*1024*1024];
new Random(1).nextBytes(largerData);
NamedStreamable.ByteArrayWrapper largeFile = new NamedStreamable.ByteArrayWrapper("nontrivial.txt", largerData);
fileTest(largeFile);
}

// @Test
@Ignore
@Test
public void hugeFileStreamTest() throws IOException {
byte[] hugeData = new byte[1000*1024*1024];
new Random(1).nextBytes(hugeData);
Expand Down Expand Up @@ -243,7 +248,7 @@ public void filesTest() throws IOException {
Map stat = ipfs.files.stat( path);
Map stat2 = ipfs.files.stat( path, Optional.of("<cumulsize>"), true);
String readContents = new String(ipfs.files.read(path));
Assert.assertTrue("Should be equals", contents.equals(readContents));
assertEquals("Should be equals", contents, readContents);
res = ipfs.files.rm(path, false, false);

String tempFilename = "temp.txt";
Expand Down Expand Up @@ -285,14 +290,14 @@ public void filesTest() throws IOException {
@Test
public void multibaseTest() throws IOException {
List<Map> encodings = ipfs.multibase.list(true, false);
Assert.assertTrue("multibase/list works", !encodings.isEmpty());
Assert.assertFalse("multibase/list works", encodings.isEmpty());
String encoded = ipfs.multibase.encode(Optional.empty(), new NamedStreamable.ByteArrayWrapper("hello".getBytes()));
Assert.assertTrue("multibase/encode works", encoded.equals("uaGVsbG8"));
assertEquals("multibase/encode works", "uaGVsbG8", encoded);
String decoded = ipfs.multibase.decode(new NamedStreamable.ByteArrayWrapper(encoded.getBytes()));
Assert.assertTrue("multibase/decode works", decoded.equals("hello"));
assertEquals("multibase/decode works", "hello", decoded);
String input = "f68656c6c6f";
String transcode = ipfs.multibase.transcode(Optional.of("base64url"), new NamedStreamable.ByteArrayWrapper(input.getBytes()));
Assert.assertTrue("multibase/transcode works", transcode.equals(encoded));
assertEquals("multibase/transcode works", transcode, encoded);
}

@Test
Expand Down Expand Up @@ -460,8 +465,8 @@ public void objectTest() throws IOException {
MerkleNode _new = ipfs.object._new(Optional.empty());
Multihash pointer = Multihash.fromBase58("QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB");
MerkleNode object = ipfs.object.get(pointer);
List<MerkleNode> newPointer = ipfs.object.put(Arrays.asList(object.toJSONString().getBytes()));
List<MerkleNode> newPointer2 = ipfs.object.put("json", Arrays.asList(object.toJSONString().getBytes()));
List<MerkleNode> newPointer = ipfs.object.put(Collections.singletonList(object.toJSONString().getBytes()));
List<MerkleNode> newPointer2 = ipfs.object.put("json", Collections.singletonList(object.toJSONString().getBytes()));
MerkleNode links = ipfs.object.links(pointer);
byte[] data = ipfs.object.data(pointer);
Map stat = ipfs.object.stat(pointer);
Expand All @@ -472,7 +477,7 @@ public void blockTest() throws IOException {
MerkleNode pointer = new MerkleNode("QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB");
Map stat = ipfs.block.stat(pointer.hash);
byte[] object = ipfs.block.get(pointer.hash);
List<MerkleNode> newPointer = ipfs.block.put(Arrays.asList("Some random data...".getBytes()));
List<MerkleNode> newPointer = ipfs.block.put(Collections.singletonList("Some random data...".getBytes()));
}

@Test
Expand All @@ -493,18 +498,18 @@ public void publish() throws Exception {

// Add a DAG node to IPFS
MerkleNode merkleNode = ipfs.dag.put("json", json.getBytes());
Assert.assertEquals("expected to be bafyreiafmbgul64c4nyybvgivswmkuhifamc24cdfuj4ij5xtnhpsfelky" , "bafyreiafmbgul64c4nyybvgivswmkuhifamc24cdfuj4ij5xtnhpsfelky", merkleNode.hash.toString());
assertEquals("expected to be bafyreiafmbgul64c4nyybvgivswmkuhifamc24cdfuj4ij5xtnhpsfelky" , "bafyreiafmbgul64c4nyybvgivswmkuhifamc24cdfuj4ij5xtnhpsfelky", merkleNode.hash.toString());

// Get a DAG node
byte[] res = ipfs.dag.get((Cid) merkleNode.hash);
Assert.assertEquals("Should be equals", JSONParser.parse(json), JSONParser.parse(new String(res)));
assertEquals("Should be equals", JSONParser.parse(json), JSONParser.parse(new String(res)));

// Publish to IPNS
Map result = ipfs.name.publish(merkleNode.hash);

// Resolve from IPNS
String resolved = ipfs.name.resolve(Cid.decode((String) result.get("Name")));
Assert.assertEquals("Should be equals", resolved, "/ipfs/" + merkleNode.hash.toString());
assertEquals("Should be equals", resolved, "/ipfs/" + merkleNode.hash);
}

@Test
Expand Down Expand Up @@ -536,7 +541,7 @@ public void pubsub() throws Exception {
ipfs.pubsub.pub(topic, data);
ipfs.pubsub.pub(topic, "G'day");
List<Map> results = sub.limit(2).collect(Collectors.toList());
Assert.assertTrue( ! results.get(0).equals(Collections.emptyMap()));
Assert.assertNotEquals(results.get(0), Collections.emptyMap());
}

private static String toEscapedHex(byte[] in) throws IOException {
Expand All @@ -556,15 +561,15 @@ public void merkleLinkInMap() throws IOException {
Random r = new Random();
CborObject.CborByteArray target = new CborObject.CborByteArray(("g'day IPFS!").getBytes());
byte[] rawTarget = target.toByteArray();
MerkleNode targetRes = ipfs.block.put(Arrays.asList(rawTarget), Optional.of("cbor")).get(0);
MerkleNode targetRes = ipfs.block.put(Collections.singletonList(rawTarget), Optional.of("cbor")).get(0);

CborObject.CborMerkleLink link = new CborObject.CborMerkleLink(targetRes.hash);
Map<String, CborObject> m = new TreeMap<>();
m.put("alink", link);
m.put("arr", new CborObject.CborList(Collections.emptyList()));
CborObject.CborMap source = CborObject.CborMap.build(m);
byte[] rawSource = source.toByteArray();
MerkleNode sourceRes = ipfs.block.put(Arrays.asList(rawSource), Optional.of("cbor")).get(0);
MerkleNode sourceRes = ipfs.block.put(Collections.singletonList(rawSource), Optional.of("cbor")).get(0);

CborObject.fromByteArray(rawSource);

Expand All @@ -576,7 +581,7 @@ public void merkleLinkInMap() throws IOException {
Assert.assertTrue("refs returns links", refs.contains(targetRes.hash));

byte[] bytes = ipfs.block.get(targetRes.hash);
Assert.assertTrue("same contents after GC", Arrays.equals(bytes, rawTarget));
assertArrayEquals("same contents after GC", bytes, rawTarget);
// These commands can be used to reproduce this on the command line
String reproCommand1 = "printf \"" + toEscapedHex(rawTarget) + "\" | ipfs block put --format=cbor";
String reproCommand2 = "printf \"" + toEscapedHex(rawSource) + "\" | ipfs block put --format=cbor";
Expand All @@ -587,34 +592,34 @@ public void merkleLinkInMap() throws IOException {
public void recursiveRefs() throws IOException {
CborObject.CborByteArray leaf1 = new CborObject.CborByteArray(("G'day IPFS!").getBytes());
byte[] rawLeaf1 = leaf1.toByteArray();
MerkleNode leaf1Res = ipfs.block.put(Arrays.asList(rawLeaf1), Optional.of("cbor")).get(0);
MerkleNode leaf1Res = ipfs.block.put(Collections.singletonList(rawLeaf1), Optional.of("cbor")).get(0);

CborObject.CborMerkleLink link = new CborObject.CborMerkleLink(leaf1Res.hash);
Map<String, CborObject> m = new TreeMap<>();
m.put("link1", link);
CborObject.CborMap source = CborObject.CborMap.build(m);
MerkleNode sourceRes = ipfs.block.put(Arrays.asList(source.toByteArray()), Optional.of("cbor")).get(0);
MerkleNode sourceRes = ipfs.block.put(Collections.singletonList(source.toByteArray()), Optional.of("cbor")).get(0);

CborObject.CborByteArray leaf2 = new CborObject.CborByteArray(("G'day again, IPFS!").getBytes());
byte[] rawLeaf2 = leaf2.toByteArray();
MerkleNode leaf2Res = ipfs.block.put(Arrays.asList(rawLeaf2), Optional.of("cbor")).get(0);
MerkleNode leaf2Res = ipfs.block.put(Collections.singletonList(rawLeaf2), Optional.of("cbor")).get(0);

Map<String, CborObject> m2 = new TreeMap<>();
m2.put("link1", new CborObject.CborMerkleLink(sourceRes.hash));
m2.put("link2", new CborObject.CborMerkleLink(leaf2Res.hash));
CborObject.CborMap source2 = CborObject.CborMap.build(m2);
MerkleNode rootRes = ipfs.block.put(Arrays.asList(source2.toByteArray()), Optional.of("cbor")).get(0);
MerkleNode rootRes = ipfs.block.put(Collections.singletonList(source2.toByteArray()), Optional.of("cbor")).get(0);

List<Multihash> refs = ipfs.refs(rootRes.hash, false);
boolean correct = refs.contains(sourceRes.hash) && refs.contains(leaf2Res.hash) && refs.size() == 2;
Assert.assertTrue("refs returns links", correct);

List<Multihash> refsRecurse = ipfs.refs(rootRes.hash, true);
boolean correctRecurse = refs.contains(sourceRes.hash)
&& refs.contains(leaf1Res.hash)
&& refs.contains(leaf2Res.hash)
&& refs.size() == 3;
Assert.assertTrue("refs returns links", correct);
boolean correctRecurse = refsRecurse.contains(sourceRes.hash)
&& refsRecurse.contains(leaf1Res.hash)
&& refsRecurse.contains(leaf2Res.hash)
&& refsRecurse.size() == 3;
Assert.assertTrue("refs returns links", correctRecurse);
}

/**
Expand All @@ -625,23 +630,23 @@ public void rootMerkleLink() throws IOException {
Random r = new Random();
CborObject.CborByteArray target = new CborObject.CborByteArray(("g'day IPFS!" + r.nextInt()).getBytes());
byte[] rawTarget = target.toByteArray();
MerkleNode block1 = ipfs.block.put(Arrays.asList(rawTarget), Optional.of("cbor")).get(0);
MerkleNode block1 = ipfs.block.put(Collections.singletonList(rawTarget), Optional.of("cbor")).get(0);
Multihash block1Hash = block1.hash;
byte[] retrievedObj1 = ipfs.block.get(block1Hash);
Assert.assertTrue("get inverse of put", Arrays.equals(retrievedObj1, rawTarget));
assertArrayEquals("get inverse of put", retrievedObj1, rawTarget);

CborObject.CborMerkleLink cbor2 = new CborObject.CborMerkleLink(block1.hash);
byte[] obj2 = cbor2.toByteArray();
MerkleNode block2 = ipfs.block.put(Arrays.asList(obj2), Optional.of("cbor")).get(0);
MerkleNode block2 = ipfs.block.put(Collections.singletonList(obj2), Optional.of("cbor")).get(0);
byte[] retrievedObj2 = ipfs.block.get(block2.hash);
Assert.assertTrue("get inverse of put", Arrays.equals(retrievedObj2, obj2));
assertArrayEquals("get inverse of put", retrievedObj2, obj2);

List<Multihash> add = ipfs.pin.add(block2.hash);
ipfs.repo.gc();
ipfs.repo.gc();

byte[] bytes = ipfs.block.get(block1.hash);
Assert.assertTrue("same contents after GC", Arrays.equals(bytes, rawTarget));
assertArrayEquals("same contents after GC", bytes, rawTarget);
// These commands can be used to reproduce this on the command line
String reproCommand1 = "printf \"" + toEscapedHex(rawTarget) + "\" | ipfs block put --format=cbor";
String reproCommand2 = "printf \"" + toEscapedHex(obj2) + "\" | ipfs block put --format=cbor";
Expand All @@ -655,9 +660,9 @@ public void rootMerkleLink() throws IOException {
public void rootNull() throws IOException {
CborObject.CborNull cbor = new CborObject.CborNull();
byte[] obj = cbor.toByteArray();
MerkleNode block = ipfs.block.put(Arrays.asList(obj), Optional.of("cbor")).get(0);
MerkleNode block = ipfs.block.put(Collections.singletonList(obj), Optional.of("cbor")).get(0);
byte[] retrievedObj = ipfs.block.get(block.hash);
Assert.assertTrue("get inverse of put", Arrays.equals(retrievedObj, obj));
assertArrayEquals("get inverse of put", retrievedObj, obj);

List<Multihash> add = ipfs.pin.add(block.hash);
ipfs.repo.gc();
Expand All @@ -676,19 +681,19 @@ public void merkleLinkInList() throws IOException {
Random r = new Random();
CborObject.CborByteArray target = new CborObject.CborByteArray(("g'day IPFS!" + r.nextInt()).getBytes());
byte[] rawTarget = target.toByteArray();
MerkleNode targetRes = ipfs.block.put(Arrays.asList(rawTarget), Optional.of("cbor")).get(0);
MerkleNode targetRes = ipfs.block.put(Collections.singletonList(rawTarget), Optional.of("cbor")).get(0);

CborObject.CborMerkleLink link = new CborObject.CborMerkleLink(targetRes.hash);
CborObject.CborList source = new CborObject.CborList(Arrays.asList(link));
CborObject.CborList source = new CborObject.CborList(Collections.singletonList(link));
byte[] rawSource = source.toByteArray();
MerkleNode sourceRes = ipfs.block.put(Arrays.asList(rawSource), Optional.of("cbor")).get(0);
MerkleNode sourceRes = ipfs.block.put(Collections.singletonList(rawSource), Optional.of("cbor")).get(0);

List<Multihash> add = ipfs.pin.add(sourceRes.hash);
ipfs.repo.gc();
ipfs.repo.gc();

byte[] bytes = ipfs.block.get(targetRes.hash);
Assert.assertTrue("same contents after GC", Arrays.equals(bytes, rawTarget));
assertArrayEquals("same contents after GC", bytes, rawTarget);
// These commands can be used to reproduce this on the command line
String reproCommand1 = "printf \"" + toEscapedHex(rawTarget) + "\" | ipfs block put --format=cbor";
String reproCommand2 = "printf \"" + toEscapedHex(rawSource) + "\" | ipfs block put --format=cbor";
Expand Down Expand Up @@ -819,12 +824,12 @@ public void swarmTestFilters() throws IOException {
Map rm = ipfs.swarm.rmFilter(multiAddrFilter);
Map filters = ipfs.swarm.filters();
List<String> filtersList = (List<String>)filters.get("Strings");
Assert.assertTrue("Filters empty", filtersList == null);
Assert.assertNull("Filters empty", filtersList);

Map added = ipfs.swarm.addFilter(multiAddrFilter);
filters = ipfs.swarm.filters();
filtersList = (List<String>)filters.get("Strings");
Assert.assertTrue("Filters NOT empty", !filtersList.isEmpty());
Assert.assertFalse("Filters NOT empty", filtersList.isEmpty());
rm = ipfs.swarm.rmFilter(multiAddrFilter);
}

Expand All @@ -838,7 +843,7 @@ public void swarmTestPeering() throws IOException {
Map addPeering = ipfs.swarm.addPeering(ma);
Map lsPeering = ipfs.swarm.lsPeering();
List<String> peeringList = (List<String>)lsPeering.get("Peers");
Assert.assertTrue("Filters not empty", !peeringList.isEmpty());
Assert.assertFalse("Filters not empty", peeringList.isEmpty());
Map rmPeering = ipfs.swarm.rmPeering(hash);
lsPeering = ipfs.swarm.lsPeering();
peeringList = (List<String>)lsPeering.get("Peers");
Expand Down Expand Up @@ -925,9 +930,9 @@ public void addArgsTest() {
.setCidVersion(1)
.build();
String res = args.toString();
Assert.assertTrue("args toString() format", res.equals("[cid-version = 1, inline = true]"));
assertEquals("args toString() format", "[cid-version = 1, inline = true]", res);
String queryStr = args.toQueryString();
Assert.assertTrue("args toQueryString() format", queryStr.equals("inline=true&cid-version=1"));
assertEquals("args toQueryString() format", "inline=true&cid-version=1", queryStr);
}

// this api is disabled until deployment over IPFS is enabled
Expand Down