Data Services Streaming (WebSocket) - All Segments-Subscribe Data

                    
                      
    //1.WS connect - Hand Shake Connection
   //2.Heart Beat connection
   //3.Subscribe the Data  
var ws;
function setConnected(connected) {
     $("#connect").prop("disabled", connected);
       $("#disconnect").prop("disabled", !connected);
       if (connected) {
          $("#conversation").show();
        }
        else {
           $("#conversation").hide();
         }
         $("#greetings").html("");
}

function connect() {
    	var inputval = document.getElementById("myInput").value;
    	var utoken = document.getElementById("Token").value;
    	var userName = document.getElementById("Username").value;

     //UAT
    	ws = new WebSocket('ws://uat.tickermarket.com/TPILWebSocket/user?username='+userName+'&jwt='+Jwttoken+"&token="+utoken);

    	ws.onmessage = function(data){
     	showGreeting(data.data);
    	}
    	 setConnected(true);
}

function exchsend(){
    	if (ws != null) {
           ws.close();
      }

    	var exdata = JSON.stringify({'exchname': $("#exchanges").val()})
    	 alert(exdata);
        ws.send(exdata);
}

function disconnect() {
      if (ws != null) {
          ws.close();
      }
     setConnected(false);
     console.log("Disconnected");
     document.getElementById("myInput").value="";
     document.getElementById("Token").value="";
}


//  Submit function - send subscription data
$(function () {
      $("form").on('submit', function (e) {
         e.preventDefault();
  });
  $( "#connect" ).click(function() { connect(); });
  $( "#disconnect" ).click(function() { disconnect(); });
  $( "#send" ).click(function() { sendName(); });

  const btn = document.querySelector("#exchsend");

  const sb = document.querySelector('#exchanges');

  const unsub = document.querySelector('#Unsub');

  btn.onclick = (event) => {

           event.preventDefault();
  }
//Heart Beat - Every 30 Seconds need to send the request continously

var subscribe_HB =
      {
           		"rqh": {
              	"mcd": "1010",
              	"tst" :"1654325456"
         },

      "rqd":{


          	  "key": {

         		"sid": "-1"
         		  iid: "-1",
         		  sym: "-1",
         		  ser: "-1",
         		  exd: "-1",
         		  stp: "-1",
       	 },
           	 "act":"beat",
           	 "oif":"1654325456"
        }

      };
         var exdata =  JSON.stringify(subscribe_HB);
         ws.send(exdata);



//subscribe FX Data- Request Header, Body and Data


     if($("#exchanges").val()=="INTLFX"){
             var symbol = $("#symbols").val();

           alert( $("#symbols").val());
           var subscribe_intlfx =
          	{
         	"rqh": {
             	"mcd": "1001",
             	"tst" :"1654325456"
              },

      "rqd":{


        "key": {

             	"sid": "12",
             	  iid: "2",
             	  sym: "EURUSD",
             	  ser: "-1",
             	  exd: "-1",
             	  stp: "-1",
         },
         "act":"subscribe",
         "oif":"1654325456"
        }

      };
         var exdata =  JSON.stringify(subscribe_intlfx);
         ws.send(exdata);

     }

//subscribe NSE Data- Request Header, Body and Data

else if($("#exchanges").val()=="NSE"){
          var symbol = $("#symbols").val();
          alert( $("#symbols").val());


         var subscribe_nse =
         {
             "rqh": {
                   "mcd": "1001",
                   "tst" :"1654325456"
                },

         "rqd":{


           "key": {

                   "sid": "4",
                     iid: "1",
                     sym: "SBIN",
                     ser: "-1",
                     exd: "-1",
                     stp: "-1",
              },
                 "act":"subscribe",
                 "oif":"1654325456"
             }

         };


          var exdata =  JSON.stringify(subscribe_nse);
          alert($("#exchanges").val());
          ws.send(exdata);
     }

//subscribe NSE Data- Request Header, Body and Data
else if($("#exchanges").val()=="BSE"){
          var symbol = $("#symbols").val();
     	var subscribe_bse =
         {
                "rqh": {
                   "mcd": "1001",
                   "tst" :"1654325456"
              },

         "rqd":{


           "key": {

                    "sid": "3",
                      iid: "1",
                      sym: "SBIN",
                      ser: "-1",
                      exd: "-1",
                      stp: "-1",
              },
              "act":"subscribe",
              "oif":"1654325456"
             }

         };


       var bseexdata =  JSON.stringify(subscribe_bse);
       alert($(subscribe_bse));
       ws.send(bseexdata);

    }else if($("#exchanges").val()=="MCX"){
            var symbol = $("#symbols").val();
              var exdata =  JSON.stringify(subscribe_mcx);



            ws.send(exdata);
          }
   };


   //unsubscribe - Fx

   unsub.onclick = (event) =>{
          var symbol = $("#symbols").val();
          alert( $("#symbols").val());

       if($("#exchanges").val()=="INTLFX"){

          var intlfxdata =     {
          	"rqh": {
          		"mcd": "1001",
          		"tst" :"1654325456"
         },

      "rqd":{


        "key": {

          		"sid": "12",
          		  iid: "2",
        			  sym: symbol,
          		  ser: "-1",
          		  exd: "-1",
          		  stp: "-1",
         },
         "act":"unsubscribe",
         "oif":"1654325456"
        }

      };


              var exdata =  JSON.stringify(intlfxdata);
              ws.send(exdata);


//unsubscribe - NSE

       }else if($("#exchanges").val()=="NSE"){
          var symbol = $("#symbols").val();
          var subscribe_nse =
          {
          "rqh": {
                    "mcd": "1001",
                    "tst" :"1654325456"
             },

          "rqd":{


            "key": {

                    "sid": "4",
                      iid: "1",
                      sym: symbol,
                      ser: "-1",
                      exd: "-1",
                      stp: "-1",
               },
               "act":"unsubscribe",
               "oif":"1654325456"
              }

          };


          var exdata =  JSON.stringify(subscribe_nse);
          ws.send(exdata);
       }

// Unsubscribe BSE

else if($("#exchanges").val()=="BSE"){
          var symbol = $("#symbols").val();
     var subscribe_bse =
         {
         "rqh": {
                   "mcd": "1001",
                   "tst" :"1654325456"
            },

         "rqd":{


                 "key": {

                   "sid": "3",
                     iid: "1",
                     sym: "SBIN",
                     ser: "-1",
                     exd: "-1",
                     stp: "-1",
            },
              "act":"subscribe",
              "oif":"1654325456"
               }

                     };

                  };

});