import 'dart:convert';

import 'package:stomp_dart_client/stomp.dart';
import 'package:stomp_dart_client/stomp_config.dart';
import 'package:stomp_dart_client/stomp_frame.dart';
final socketUrl="https://server.thejob.net/ws";

class ConnectToWebSocket{
  StompClient stompClient;
  String message='';
  void onConnect(StompFrame frame){
    print("connected");
    print(stompClient.connected);
    stompClient.subscribe(destination: '/topic/chat', callback: (StompFrame frame){
      if (frame.body != null) {
        Map<String, dynamic> result = json.decode(frame.body);
        print(result);
        message = result['message'];
      }
    });
  }
  Future<void> connectSock()async{
    print('Starting example');
    if (stompClient == null) {
      // stompClient = StompClient(
      //     config: StompConfig.SockJS(
      //       url: socketUrl ,
      //       onConnect: onConnect,
      //       onWebSocketError: (dynamic error) => print("onWebSocketError "+error.toString()),
      //       onStompError: (dynamic error) => print("onStompError "+error.toString()),
      //     ));

      stompClient.activate();

    }
  }
}