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()