const WebSocket = require('ws');

async function main() {
    var ws = new WebSocket('wss://api.mainnet-beta.solana.com:443');
    ws.onopen = function() {
    console.log('Connect WebSocket...',new Date());
    ws.send('{"jsonrpc": "2.0","id": 1,"method": "logsSubscribe","params": [{"mentions": [ "675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8" ]}]}');
    };
    ws.onmessage = function(evt) {
    var data_json = JSON.parse(evt.data)

    if(data_json.params){
        let signature = data_json.params.result.value.signature
        find_init = evt.data.indexOf("process_initialize")
        if (find_init>=0){
            console.log(new Date(),'Got signature:',signature)
            console.log('===========================')
        }
        console.log('#')
    }else{
        console.log(data_json)
    }

    };
    ws.onclose = function(evt) {
    console.log('connect close,TRY reconnet');
    //
    main();
    };
}

main()