Data Services Streaming (WebSocket) - All Segments-Login

                        
                        

      //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;

      //Production
     ws = new WebSocket('wss://feedws1.tickermarket.com/TPILWebSocket/user?username='+userName+'&jwt='+inputval+"&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"
                 }

                       };

                    };

});