Merge branch 'wasm' of https://github.com/talentlessguy/bee into wasm

Author: v1rtl

dist/style.css

@@ -1,3 +1,3 @@
 body {
-  background-color: orange;
+  background-color: rgb(71, 55, 24);
 }

dist/sw.js

@@ -107,7 +107,9 @@ async function main() {
 
   // Bootstrap addresses
   const bootstrapMultiaddrs = [
-    '/ip4/127.0.0.1/tcp/1634/ws/p2p/QmXaWHrPsmJ2CY1XNqRb2WTisWZXEzaCsawmcex1CiidvX',
+    '/ip4/127.0.0.1/tcp/1634/ws/p2p/QmbPUii1SGZ6hKiSQjgWV9WuGCmSGSA2L2RBpFQBHPHrTF',
+    // '/ip4/172.26.20.131/tcp/1634/ws/p2p/QmVQhnaTT84UBfW5EPivTd6SP2Rq62pCLKawtugPtd3yXH',
+    // '/ip4/188.245.222.246/tcp/1634/ws/p2p/QmccBpjXGFUS8ZydhUnZYLcMvTNcNSjF5ntyMS8sCfz3o2'
   ]
 
   go.argv = [
@@ -122,8 +124,9 @@ async function main() {
     '--verbosity',
     'debug',
     // '--blockchain-rpc-endpoint',
-    // 'wss://ethereum-sepolia-rpc.publicnode.com',
+    // 'https://ethereum-sepolia-rpc.publicnode.com/ac5b7f52aabd778861c2588f872f15c5fc34f0b343ec3d18ac2e91f5526e9c2b',
     '--mainnet=false',
+    '--network-id=5',
   ]
 
   // Override Go's `fs.readFile` with ZenFS readFile functionality

pkg/hive/hive_js.go

@@ -175,20 +175,41 @@ func (s *Service) checkAndAddPeers(ctx context.Context, peers pb.Peers) {
 	wg := sync.WaitGroup{}
 
 	addPeer := func(newPeer *pb.BzzAddress, multiUnderlay ma.Multiaddr) {
-		wsProto := false
-		ma.ForEach(multiUnderlay, func(c ma.Component) bool {
-			if c.Protocol().Name == "ws" {
-				wsProto = true
-				return false
+		parts := ma.Split(multiUnderlay)
+
+		var baseParts []ma.Component
+		var p2pID string
+
+		for _, c := range parts {
+			switch c.Protocol().Name {
+			case "ws", "wss":
+				continue // skip if already present
+			case "p2p":
+				p2pID = c.Value()
+			default:
+				baseParts = append(baseParts, c)
 			}
-			return true
-		})
+		}
 
-		if !wsProto {
-			s.logger.Debug("skipping non-websocket peer", "peer_address", hex.EncodeToString(newPeer.Overlay), "underlay", multiUnderlay)
-			return
+		baseAddr, _ := ma.NewMultiaddr("")
+		for _, c := range baseParts {
+			componentStr := "/" + c.Protocol().Name + "/" + c.Value()
+			component, err := ma.NewMultiaddr(componentStr)
+			if err != nil {
+				s.logger.Error(errors.New("invalid multiaddr component"), "component", componentStr, "error", err)
+				return
+			}
+			baseAddr = baseAddr.Encapsulate(component)
+		}
+
+		// Add /ws and /p2p
+		baseAddr = baseAddr.Encapsulate(ma.StringCast("/ws"))
+		if p2pID != "" {
+			baseAddr = baseAddr.Encapsulate(ma.StringCast("/p2p/" + p2pID))
 		}
 
+		s.logger.Debug("rewritten multiaddr to use websocket", "peer_address", hex.EncodeToString(newPeer.Overlay), "ws_underlay", baseAddr.String())
+
 		err := s.sem.Acquire(ctx, 1)
 		if err != nil {
 			return
@@ -206,15 +227,15 @@ func (s *Service) checkAndAddPeers(ctx context.Context, peers pb.Peers) {
 			defer cancel()
 
 			// check if the underlay is usable by doing a raw ping using libp2p
-			if _, err := s.streamer.Ping(ctx, multiUnderlay); err != nil {
+			if _, err := s.streamer.Ping(ctx, baseAddr); err != nil {
 
-				s.logger.Debug("unreachable peer underlay", "peer_address", hex.EncodeToString(newPeer.Overlay), "underlay", multiUnderlay)
+				s.logger.Debug("unreachable peer underlay", "peer_address", hex.EncodeToString(newPeer.Overlay), "underlay", multiUnderlay, "error", err)
 				return
 			}
 
 			bzzAddress := bzz.Address{
 				Overlay:   swarm.NewAddress(newPeer.Overlay),
-				Underlay:  multiUnderlay,
+				Underlay:  baseAddr,
 				Signature: newPeer.Signature,
 				Nonce:     newPeer.Nonce,
 			}