flutter_socket_io

Flutter Socket IO Plugin, supported Android + iOS (iOS installation guide is coming soon)

How to install on iOS

• 1. Copy the folder example/ios/Runner/SocketObj to ${PROJECT_ROOT}/ios/Runner/
• 2. Replace the example/ios/Runner/AppDelegate.m line with ${PROJECT_ROOT}/ios/Runner/AppDelegate.m. (Notice: You should merge the old one in your project to merge with the new from this plugin if you have some change on that file)
• 3. Open ${PROJECT_ROOT}/ios/Podfile, paste this line pod 'Socket.IO-Client-Swift', '~> 13.3.0' before the end of target 'Runner' do block
• 4. Run and Enjoy the plugin :)

Use the plugin

1. Add the following import to your Dart code:

import 'package:flutter_socket_io/flutter_socket_io.dart';

2. SocketIOManager: to manage (create/destroy) list of SocketIO

Create SocketIO with SocketIOManager:

SocketIO socketIO = SocketIOManager().createSocketIO("http://127.0.0.1:3000", "/chat", query: "userId=21031", socketStatusCallback: _socketStatus); 

Destroy SocketIO with socketIOManager:

SocketIOManager().destroySocket(socketIO); 

3. SocketIO:

Get Id (Url + Namespace) of the socket

String getId();

Create a new socket and connects the client

Future<void> connect();

Init socket before doing anything with socket

Future<void> init();

Subscribe to a channel with a callback

Future<void> subscribe(String event, Function callback); 

Unsubscribe from a channel. When no callback is provided, unsubscribe all subscribers of the channel. Otherwise, unsubscribe only the callback passed in

Future<void> unSubscribe(String event, [Function callback]); 

Send a message via a channel (i.e. event, the native code will convert string message to JsonObject before sending)

Future<void> sendMessage(String event, dynamic message, [Function callback]);

Disconnect from the socket

Future<void> disconnect(); 

Unsubscribe all subscribers from all channels

Future<void> unSubscribesAll();

4. Example:Link

SocketIO socketIO;
_connectSocket01() { //update your domain before using socketIO = SocketIOManager().createSocketIO("http://127.0.0.1:3000", "/chat", query: "userId=21031", socketStatusCallback: _socketStatus); //call init socket before doing anything socketIO.init(); //subscribe event
socketIO.subscribe("socket_info", _onSocketInfo); //connect socket socketIO.connect(); }
_socketStatus(dynamic data) { print("Socket status: " + data); }
_subscribes() { if (socketIO != null) { socketIO.subscribe("chat_direct", _onReceiveChatMessage); } }
void _onReceiveChatMessage(dynamic message) { print("Message from UFO: " + message); }
void _sendChatMessage(String msg) async { if (socketIO != null) { String jsonData = '{"message":{"type":"Text","content": ${(msg != null && msg.isNotEmpty) ? '"${msg}"' : '"Hello SOCKET IO PLUGIN :))"'},"owner":"589f10b9bbcd694aa570988d","avatar":"img/avatar-default.png"},"sender":{"userId":"589f10b9bbcd694aa570988d","first":"Ha","last":"Test 2","location":{"lat":10.792273999999999,"long":106.6430356,"accuracy":38,"regionId":null,"vendor":"gps","verticalAccuracy":null},"name":"Ha Test 2"},"receivers":["587e1147744c6260e2d3a4af"],"conversationId":"589f116612aa254aa4fef79f","name":null,"isAnonymous":null}'; socketIO.sendMessage("chat_direct", jsonData, _onReceiveChatMessage); }
}
_destroySocket() { if (socketIO != null) { SocketIOManager().destroySocket(socketIO); } }