server.js

import {createLibp2p} from 'libp2p'
import {autoNAT} from '@libp2p/autonat'
import {identify} from '@libp2p/identify'
import {noise} from '@chainsafe/libp2p-noise'
import {yamux} from '@chainsafe/libp2p-yamux'
import {gossipsub} from '@chainsafe/libp2p-gossipsub'
import {webSockets} from '@libp2p/websockets'
import {tcp} from '@libp2p/tcp'
import {circuitRelayServer} from '@libp2p/circuit-relay-v2'
import {DISCOVERY_PROTOCOL, MESSAGE_PROTOCOL} from './src/constants.js'
import {generateKeyPairFromSeed} from "@libp2p/crypto/keys";
import {peerIdFromKeys} from "@libp2p/peer-id";
import {liquid} from "./service.js";

// TODO: Import seed
const kp = [32, 131, 177, 47, 115, 213, 166, 145, 111, 140, 36, 73, 144, 83, 221, 248, 183, 157, 57, 90, 240, 221, 74, 59, 216, 239, 246, 36, 162, 254, 163, 41]
const key = await generateKeyPairFromSeed("Ed25519", new Uint8Array(kp))
const peerId = await peerIdFromKeys(key.public.bytes, key.bytes)

const publicIp = process.env.PUBLIC_IP || '184.169.220.207'
const port = typeof process.env.PORT != "undefined" ? parseInt(process.env.PORT) : 9001
const hostname = process.env.RENDER_EXTERNAL_HOSTNAME || 'liquid-gossip.onrender.com'

const libp2p = await createLibp2p({
    peerId: peerId,
    addresses: {
        listen: [
            `/ip4/0.0.0.0/tcp/${port}/ws`,
            `/ip4/0.0.0.0/tcp/${port+1}`,
        ],
        announce: [
            `/ip4/${publicIp}/tcp/${port}/ws`,
            `/ip4/${publicIp}/tcp/${port}`,
            // TODO: `/dnsaddr/${hostname}/tcp/443/ws`,
        ],
    },
    transports: [
        webSockets(),
        tcp(),
    ],
    connectionEncryption: [noise()],
    streamMuxers: [yamux()],
    connectionGater: {
        denyDialMultiaddr: async () => false,
    },
    services: {
        // TODO: fix this hot garbage, just messing around
        liquid: liquid(),
        identify: identify(),
        autoNat: autoNAT(),
        relay: circuitRelayServer({
            reservations:{
                maxReservations: Infinity
            }
        }),
        pubsub: gossipsub(),
    },
})

libp2p.services.pubsub.subscribe(DISCOVERY_PROTOCOL)
libp2p.handle(MESSAGE_PROTOCOL, async (data)=>{

    const { stream, connection } = data
    const remotePeerId = connection.remotePeer.toString();
    console.log(`Received connection from: ${remotePeerId}`);

    // Read incoming data from the stream
    let string = ''
    const decoder = new TextDecoder()
    for await (const chunk of stream.source) {
        string += decoder.decode(chunk.subarray())

    }
    // User talking to server
    console.log(`Message from ${remotePeerId}: ${string}`);
})

console.log('ID: ', libp2p.peerId.toString())
console.log('Announced: ', libp2p.getMultiaddrs().map(ma => ma.toString()))