Node JS program to fetch bitcoin price and showing it in real time using socker.io

-

 File structure - 





package install - 












Server.js 

const express = require('express');
const app = express();
const ccxt = require('ccxt')
const http = require('http');
const server = http.createServer(app);
const { Server } = require("socket.io");
const { Console } = require('console');
const { BroadcastChannel } = require('worker_threads');
const io = new Server(server);


app.use(express.static('public'));
app.use(express.urlencoded({extended:false}))
app.use(express.json());

app.get('/sa', (req, res) => {
  res.send("sd");

});

io.on('connection', async (fun) => {
    i = 1;
    s = 2000;
    console.log('started')
     console.log(fun.id)
     const exchange = new ccxt.binance()

     // Load the markets
     let  real = 1
     await exchange.loadMarkets()
     fun.on('chat message', async (msg) => {
                 const ticker = await exchange.fetchTicker('BTC/USDT')
             
                // Get the ticker for the BTC/USDT market
                    if(ticker.last < real) {
                        console.log("BTC/USDT PRICE - " + ticker.last + "  " + i + "  price drop")
                    }
                    else if (ticker.last > real ){
                        console.log("BTC/USDT PRICE - " + ticker.last + "  " + i + "  price increase")

                    }
                    real = ticker.last
               
                // Log the last price
                const data = {
                    name: ticker.last,
                    surname:s
                }
               
               
                // console.log("check for dat first" , i)
                // console.log("check ", s)
                i++;    
                s++;
                io.emit('chat message', data);
             
         });
         
         fun.on('endchat_1', function (){
            console.log('ended')
            fun.disconnect(fun.id);
        });
         
         fun.on('chat_2', (msg) => {
            console.log('chat_2')
            for (let i = 0; i < 10000; i++) {
                io.emit('chat_2', msg + "  " + i + " chat_2" );
                // console.log( io.emit('chat_2', msg + "  " + i + " chat_2" ))
            }
        });
     });

 
server.listen(3000, () => {
  console.log('listening on *:3000');
});

index.html file - 

<!DOCTYPE html>
<html>
  <head>
    <title>Socket.IO chat</title>
 
  </head>
  <style>
    body{
      background-color: black;
    }
    h1{
      color: white;
    }
  </style>
  <body>
    <h1>BTC Price</h1>
    <ul id="messages"></ul>
    <ul id="">
        chat_2
        <span id="chat_2">
        </span>
    </ul>
    <form id="form" action="">
      <input id="input" autocomplete="off" /><button>Send</button>
    </form>
  </body>
  <script src="/socket.io/socket.io.js"></script>
  <script>
    var socket = io();
   
   
    var messages = document.getElementById('messages');
    var chat_2 = document.getElementById('chat_2');
    var form = document.getElementById('form');
    var input = document.getElementById('input');
 
    form.addEventListener('submit', function(e) {
      e.preventDefault();
      if (input.value) {
        console.log('er')
        socket.emit('chat message', input.value);
        input.value = '';
      }
    });
    let real = 0;
    const func = () =>{
        socket.emit('chat message', "");
        socket.on('chat message', function(msg) {
          if (msg.name < real) {
            messages.style.color = "red"
            messages.innerHTML =  msg.name;
          }
          else if (msg.name > real) {
            messages.style.color = "green"
            messages.innerHTML =  msg.name;
          }
          real = msg.name
    //   var item = document.createElement('li');
    //   item.textContent = msg;
    //   messages.appendChild(item);
    //   window.scrollTo(0, document.body.scrollHeight);
        // chat_2.innerHTML =  msg.surname;
    // console.log('run')
    });
    }
    const func_2 = async () =>{
        // await socket.emit('endchat_1');
        socket.emit('chat_2', "");
        console.log('chat_2')
        let real = 0;
        socket.on('chat_2', function(msg) {
          if (msg < real) {
            chat_2.innerHTML =  msg;
          }
          else if (msg > real) {
            chat_2.style.color = "green"
            chat_2.innerHTML =  msg;
          }
    });
    }
    setInterval(func,500)
    // func();
    // setInterval(func_2,1000)
  </script>
</html>


Output of the terminal -



















output of the index.html -







Comments

Post a Comment

All time Best Post

Write a program that declares a class named Person. It should have instance variables to record name, age and salary. Use new operator to create a Person object. Set and display its instance variables.

-
Image
 Program -  import java.util.*; public class persondata { public static void main(String[]args) { person a = new person(); a.set(); System.out.println("your data is \n\n"); a.display(); } }  class person { private String name; private int age; private int salary;   public void display() { System.out.println("your name is :"+name); System.out.println("your age is :"+age); System.out.println("your salary is "+salary); } public void set(){ Scanner sc = new Scanner(System.in); System.out.println("enter your name"); name = sc.next(); System.out.println("enter your age"); age = sc.nextInt(); System.out.println("enter your salary"); salary = sc.nextInt(); } } outpiut -   
Read more

IMAGE CRUD OPERATION USING EXPRESS MONGOOSE MULTER

-
Image
  IMAGE CRUD OPERATION USING EXPRESS MONGOOSE MULTER Dependencies Used -    File Structured -  Server.js file -  // requirements    const express = require ( 'express' ) const imgModel = require ( './db/user' ) const mongoose = require ( 'mongoose' ) const multer   = require ( 'multer' ) const path = require ( 'path' ) const app = express ();   // serving static files  app . use ( express . static ( 'public' ));     // connecting to database  mongoose . connect ( 'mongodb://localhost:27017/testten' , { useNewUrlParser: true , useUnifiedTopology: true , useFindAndModify: false   }) . then (() => console . log ( "database is connected" )) . catch (( err ) => console . log ( err ))   // multer destination set    var storage = multer . diskStorage ({      destination: "./public/uploads/" ,      filename : ( req , file , cb ) => {   ...
Read more

connect websocket to binance api and store t he true value in the db

-
  const WebSocket = require( 'ws' ); const bitcoindata = require( '../model/bitcoindata.model' ); function connectToBinanceWebSocket() {    // Connect to Binance's WebSocket API for the BTC/USDT trading pair    const socket = new WebSocket( 'wss://stream.binance.com:9443/ws/btcusdt@kline_1m' );    // Handle messages received from the WebSocket   socket.on( 'message' , (data) => {      const message = JSON.parse(data);      if (message.e === 'kline' ) {        const candle = message.k;       console.log( `[${new Date(candle.t).toLocaleTimeString()}] Open: ${candle.o}, High: ${candle.h}, Low: ${candle.l}, Close: ${candle.c}` );        if (candle.x == true ) {         console.log({candle})         bitcoindata.crea...
Read more

CRUD APP WITH SORT IN NODE EXPRESS AND MONGODB

-
Image
  CRUD APP WITH SORT IN NODE EXPRESS AND MONGODB wriitten in ecma script6  Dependencies -    File structure  - Server.js file -  //requirements  const express = require ( 'express' ); const mongoose = require ( 'mongoose' ); const bodyparser = require ( 'body-parser' ) const app = express ();   // database connection mongoose . connect ( 'mongodb://localhost:27017/testone' ,{ useNewUrlParser: true , useUnifiedTopology: true }) . then (() => console . log ( "databse is connected" )) . catch (( err ) => console . log ( err ))     // database schema var itemSchema = new mongoose . Schema ({      name : String ,      surname : String ,      event : String })   // database collection creation var item = new mongoose . model ( 'item' , itemSchema )   // setting view engine to ejs app . set ( 'view engine' , 'ejs' )   // using body parser because...
Read more

express session login system using node express mongodb

-
Image
express session login system using node express mongodb Dependencies used -  File -  Server.js file -  const express = require ( 'express' ); const mongoose = require ( 'mongoose' ); const bcrypt = require ( 'bcrypt' ) const session = require ( 'express-session' ) const mongoDBSession = require ( 'connect-mongodb-session' )( session ); const bodyparser = require ( 'body-parser' ); const userModel = require ( './models/user' ) const student = require ( './student' ) const app = express ();   const mongoURI = 'mongodb://localhost:27017/testsix'     mongoose . connect ( 'mongodb://localhost:27017/testsix' ,{ useNewUrlParser: true , useUnifiedTopology: true , useCreateIndex: true , }) . then (() => console . log ( "database is connected" )) . catch (( err ) => console . log ( err ))   app . set ( 'view engine' , 'ejs' )   app . use ( bodyparser . urlencod...
Read more

how to delete image from the folder directly from a Request (MULTER)

-
imported item -  const   path  =  require ( 'path' ) const   fs  =  require ( 'fs' ) // code : router . get ( '/delete/:id' , isAuth , async  ( req , res ) => {      await    addBlogmodel . findByIdAndRemove ( req . params . id ,( err , items ) => {          if ( err ){              res . send ( "sory we have some issuse" )         }          else         {              const   path  =  './public/uploads/' + items . image              try  {                  f...
Read more

calculate rsi

-
Image
  const newFunction = async () => {       // https://stackoverflow.com/questions/70452789/node-js-find-the-same-rsi-as-tradingview       // https://gist.github.com/jmoz/1f93b264650376131ed65875782df386       // https://stackoverflow.com/questions/50203625/calculate-rsi-based-on-kraken-ohlc       // topdown1.count({}, function( err, count){           //  console.log( "Number of data in db :", count );           // topdown1.find(async (err,items)=>{                 // if(err){                   //      console.log(err)                 // }                 // else{                     const ticker = await exchange . fetchTicker ( '...
Read more

java program for 1 to 10 print using while loop

-
 program-  public class Main {     public static void main(String[] args)     {         int i=0;                  while ( i<10 )         {             i++;             System.out.println(i);                      }     } } Output :- 1 2 3 4 5 6 7 8 9 10
Read more

How to fetch last one minute volume of BTC in CCXT Nodejs.

-
Image
  const exchange = new ccxt . binance (); async   function   getLastOneMinuteVolume () {     try {       const binance = new ccxt . binance ();       const symbol = "BTC/USDT" ;     //   const symbol = "USDT";       const ohlcv = await binance . fetchOHLCV ( symbol , "1m" );         console . log ( ohlcv [ ohlcv . length - 1 ])       const lastCandle = ohlcv [ ohlcv . length - 1 ];       const volume = lastCandle [ 5 ];     //   console.log(lastCandle[5])       console . log ( "Last one minute volume:" , volume );     } catch ( error ) {       console . error ( error );     }   }   //   getLastOneMinuteVolume();   setInterval ( getLastOneMinuteVolume , 1000 ) first data in array is volume in USDT , last is volume in BTC , second is price.
Read more