correctly handle max block size in api

src/main/java/org/peergos/EmbeddedIpfs.java

@@ -70,6 +70,10 @@ public EmbeddedIpfs(Host node,
                 () -> blockstore.refs(false).join().stream(), node, dht, q));
     }
 
+    public int maxBlockSize() {
+        return bitswap.maxBlockSize();
+    }
+
     public List<HashedBlock> getBlocks(List<Want> wants, Set<PeerId> peers, boolean addToLocal) {
         List<HashedBlock> blocksFound = new ArrayList<>();
 

src/main/java/org/peergos/net/APIHandler.java

@@ -31,9 +31,11 @@ public class APIHandler extends Handler {
     public static final String FIND_PROVS = "dht/findprovs";
 
     private final EmbeddedIpfs ipfs;
+    private final int maxBlockSize;
 
     public APIHandler(EmbeddedIpfs ipfs) {
         this.ipfs = ipfs;
+        this.maxBlockSize = ipfs.maxBlockSize();
     }
 
     public void handleCallToAPI(HttpExchange httpExchange) {
@@ -109,7 +111,7 @@ public void handleCallToAPI(HttpExchange httpExchange) {
                         throw new APIException("Multiple input not supported");
                     }
                     byte[] block = data.get(0);
-                    if (block.length >  1024 * 1024 * 2) { //todo what should the limit be?
+                    if (block.length > maxBlockSize) {
                         throw new APIException("Block too large");
                     }
                     Cid cid = ipfs.blockstore.put(block, Cid.Codec.lookupIPLDName(reqFormat)).join();

src/main/java/org/peergos/protocol/bitswap/Bitswap.java

@@ -42,6 +42,10 @@ public void setAddressBook(AddressBook addrs) {
         this.addrs = addrs;
     }
 
+    public int maxBlockSize() {
+        return engine.maxMessageSize();
+    }
+
     @Override
     public void handleConnection(@NotNull Connection connection) {
         // add all outgoing connections to an LRU of candidates