Topics created by 91priyansh

Hi @91priyansh kindly let us know update of your above mentioned issue.

@91priyansh You can check if you are receiving ltp in the response or not. If you haven't received ltp let's say for 2 to 3 minutes, you can close the connection. Minutes depends on your choice.

@91priyansh You can use ltpData(exchange,symbol,token) function for it.

@rajanprabu Thanks

@admin ohh sorry i was accessing after 4 in evening

import 'dart:convert';
import 'dart:io';
import 'package:flutter/material.dart';
import 'package:web_socket_channel/web_socket_channel.dart';

class ScreenAngelWebSocket extends StatefulWidget {
const ScreenAngelWebSocket({Key? key}) : super(key: key);

@override
State<ScreenAngelWebSocket> createState() => _ScreenAngelWebSocketState();
}

class _ScreenAngelWebSocketState extends State<ScreenAngelWebSocket> {
WebSocketChannel? channel;

@override
void initState() {
super.initState();
channel = WebSocketChannel.connect(Uri.parse(ApiPath.WSS_ANGEL));
channel!.sink.add(
jsonEncode({
"task": "cn",
"channel": "",
"token": "feed_token",
"user": "client_id",
"acctid": "client_id"
}),
);

channel!.sink.add(
jsonEncode({
"task": "mw",
// "channel": "nse_cm|3045",
"channel": "nse_cm|3045&nse_cm|2885", // SBI & Reliance
"token": "feed_token",
"user": "client_id",
"acctid": "client_id"
}),
);
channel!.stream.listen(
(data) {
String response = data.toString();
debugPrint('wss Response before Decode: ' + response);
var step1 = base64.decode(response);
debugPrint('wss Response Decode Step 1: ' + step1.toString());
var inflated = zlib.decode(step1);
var step2 = utf8.decode(inflated);
debugPrint('wss Response Decode Step 2: ' + step2.toString());

var step3 = json.decode(step2);
debugPrint('wss Response Decode Step 3: ' + step3.toString());

if (step3.toString().contains('task') &&
step3[0]['task'].toString() == 'cn' &&
step3[0]['msg'].toString() == 'cn') {
debugPrint('wss Socket Connected');
}
},
onDone: () {
debugPrint('wss Socket Connected');
},
onError: (error) => debugPrint('wss Error: ' + error.toString()),
);
}

@override
void dispose() {
super.dispose();
channel!.sink.close();
}

@override
Widget build(BuildContext context) {
return Column(
mainAxisSize: MainAxisSize.max,
crossAxisAlignment: CrossAxisAlignment.stretch,
children: [
Text('Web Socket Demo'),
],
);
}
}

Decoded Data in Log

wss Response Decode Step 3: [{e: nse_cm, name: sf, ltp: 2597.25, ltq: 20, tk: 2885, ltt: NA}, {e: nse_cm, name: sf, ltp: 518.90, ltq: 8, tk: 3045, ltt: NA}]

Also find answer here https://smartapi.angelbroking.com/topic/1887/how-to-decode-web-socket-response-in-flutter-dart/2