Rust server

packages/frontend/src/lib/libp2p.ts

@@ -39,8 +39,7 @@ export async function startLibp2p(options: {} = {}) {
 
   // libp2p is the networking layer that underpins Helia
   const libp2p = await createLibp2p({
-    // connectionManager: { autoDial: false },
-    dht: kadDHT(),
+    // dht: kadDHT(),
     datastore,
     transports: [webTransport(), webSockets(), webRTC()],
     connectionEncryption: [noise()],
@@ -57,33 +56,30 @@ export async function startLibp2p(options: {} = {}) {
     //   },
     // },
     peerDiscovery: [
-      bootstrap({
-        list: [
-          '/dnsaddr/bootstrap.libp2p.io/p2p/QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN',
-          '/dnsaddr/bootstrap.libp2p.io/p2p/QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa',
-          '/dnsaddr/bootstrap.libp2p.io/p2p/QmcZf59bWwK5XFi76CZX8cbJ4BhTzzA3gU1ZjYZcYW3dwt',
-          '/dnsaddr/bootstrap.libp2p.io/p2p/QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb',
-          // '/dns4/am6.bootstrap.libp2p.io/tcp/443/wss/p2p/QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb',
-          // '/dnsaddr/ny5.bootstrap.libp2p.io/p2p/QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa',
-          // '/dns4/ny5.bootstrap.libp2p.io/tcp/443/wss/p2p/QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa',
-
-          // '/dns4/node0.preload.ipfs.io/tcp/443/wss/p2p/QmZMxNdpMkewiVZLMRxaNxUeZpDUb34pWjZ1kZvsd16Zic',
-          // '/dns4/node1.preload.ipfs.io/tcp/443/wss/p2p/Qmbut9Ywz9YEDrz8ySBSgWyJk41Uvm2QJPhwDJzJyGFsD6',
-          // '/dns4/node2.preload.ipfs.io/tcp/443/wss/p2p/QmV7gnbW5VTcJ3oyM2Xk1rdFBJ3kTkvxc87UFGsun29STS',
-          // '/dns4/node3.preload.ipfs.io/tcp/443/wss/p2p/QmY7JB6MQXhxHvq7dBDh4HpbH29v4yE9JRadAVpndvzySN',
-        ],
-      }),
+      // bootstrap({
+      //   list: [
+      //     // '/dnsaddr/bootstrap.libp2p.io/p2p/QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN',
+      //     // '/dnsaddr/bootstrap.libp2p.io/p2p/QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa',
+      //     // '/dnsaddr/bootstrap.libp2p.io/p2p/QmcZf59bWwK5XFi76CZX8cbJ4BhTzzA3gU1ZjYZcYW3dwt',
+      //     // '/dnsaddr/bootstrap.libp2p.io/p2p/QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb',
+      //   ],
+      // }),
     ],
     pubsub: gossipsub({
       allowPublishToZeroPeers: true,
       allowedTopics: [CHAT_TOPIC],
     }),
+    // connectionManager: {
+    //   minConnections: 0,
+    //   maxConnections: 3,
+    // },
     // peerRouters: [delegatedPeerRouting(client)],
   })
 
   libp2p.pubsub.subscribe(CHAT_TOPIC)
 
   console.log(`this nodes peerID: ${libp2p.peerId.toString()}`)
+
   return libp2p
 }
 
@@ -148,6 +144,20 @@ export const connectToMultiaddrs =
     return conns
   }
 
+// Attempt to connect to an array of multiaddrs
+export const connectToMultiaddr =
+  (libp2p: Libp2p) => async (multiaddr: Multiaddr) => {
+    console.log(`dialling: ${multiaddr.toString()}`)
+    try {
+      const conn = await libp2p.dial(multiaddr)
+      console.info('connected to', conn.remotePeer, 'on', conn.remoteAddr)
+      return conn
+    } catch (e) {
+      console.error(e)
+      throw e
+    }
+  }
+
 /**
  * Returns a filtered list of public multiaddrs of a specific protocol
  *

packages/frontend/src/pages/index.tsx

@@ -6,6 +6,7 @@ import { useCallback, useState } from 'react'
 import { useInterval } from 'usehooks-ts'
 
 import {
+  connectToMultiaddr,
   connectToMultiaddrs,
   filterPublicMultiaddrs,
   getPeerMultiaddrs,
@@ -23,6 +24,7 @@ export default function Home() {
   const { libp2p } = useLibp2pContext()
   const [isConnected, setIsConnected] = useState(false)
   const [peerID, setPeerID] = useState(DEFAULT_APP_PEER)
+  const [maddr, setMultiaddr] = useState('')
   const [peers, setPeers] = useState<PeerId[]>([])
   const [connections, setConnections] = useState<Connection[]>([])
   const [latency, setLatency] = useState<number>()
@@ -37,10 +39,11 @@ export default function Home() {
     }
 
     const ping = async () => {
-      if (isConnected) {
-        return await libp2p.ping(peerIdFromString(peerID))
+      if(maddr) {
+        return libp2p.ping(multiaddr(maddr))
       }
     }
+
     ping()
       .then((lat) => {
         setLatency(lat)
@@ -131,6 +134,32 @@ export default function Home() {
     [libp2p, multiaddrs, peerID],
   )
 
+  const handleConnectToMultiaddr = useCallback(
+    async (e: React.MouseEvent<HTMLButtonElement>) => {
+      if (!maddr) {
+        return
+      }
+
+      try {
+        const connection = await connectToMultiaddr(libp2p)(multiaddr(maddr))
+        console.log('connection: ', connection)
+        return connection
+      } catch (e) {
+        console.error(e)
+      }
+    },
+    [libp2p, maddr],
+  )
+
+  // handleConnectToMultiaddr
+
+  const handleMultiaddrChange = useCallback(
+    (e: React.ChangeEvent<HTMLInputElement>) => {
+      setMultiaddr(e.target.value)
+    },
+    [setMultiaddr],
+  )
+
   const handlePeerIdChange = useCallback(
     (e: React.ChangeEvent<HTMLInputElement>) => {
       setPeerID(e.target.value)
@@ -193,6 +222,7 @@ export default function Home() {
                   Get Multiaddrs
                 </button>
               </div>
+
               <div>
                 {multiaddrs && multiaddrs.length > 0 ? (
                   <>
@@ -217,6 +247,33 @@ export default function Home() {
                   </>
                 ) : null}
               </div>
+              <div className="my-6 w-1/2">
+                <label
+                  htmlFor="peer-id"
+                  className="block text-sm font-medium leading-6 text-gray-900"
+                >
+                  multiaddr to connect to
+                </label>
+                <div className="mt-2">
+                  <input
+                    value={maddr}
+                    type="text"
+                    name="peer-id"
+                    id="peer-id"
+                    className="block w-full rounded-md border-0 py-1.5 px-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-indigo-600 sm:text-sm sm:leading-6"
+                    placeholder="12D3Koo..."
+                    aria-describedby="multiaddr-id-description"
+                    onChange={handleMultiaddrChange}
+                  />
+                </div>
+                <button
+                  type="button"
+                  className="rounded-md bg-indigo-600 my-2 py-2 px-3 text-sm font-semibold text-white shadow-sm hover:bg-indigo-500 focus-visible:outline focus-visible:outline-2 focus-visible:outline-offset-2 focus-visible:outline-indigo-600"
+                  onClick={handleConnectToMultiaddr}
+                >
+                  Connect to multiaddr
+                </button>
+              </div>
               <p className="my-4 inline-flex items-center text-xl">
                 Connected:{' '}
                 {isConnected ? (

rust-server/.gitignore

@@ -0,0 +1 @@
+target/