sky_connection 0.0.6

A plugin to create local connection.

example/lib/main.dart

import 'dart:io';

import 'package:flutter/material.dart';
import 'package:fluttertoast/fluttertoast.dart';
import 'package:sky_connection/sky_connection.dart';
import 'package:sky_connection/utils/utils.dart';
import 'package:sky_connection/websocket/beans.dart';
import 'package:sky_device_info/beans.dart';
import 'package:sky_device_info/sky_device_info.dart';

void main() {
  runApp(const MyApp());
}

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

  @override
  State<MyApp> createState() => _MyAppState();
}

class _MyAppState extends State<MyApp> {
  @override
  void initState() {
    super.initState();
  }

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: const Text('Plugin sky connection'),
        ),
        body: Container(
          padding: const EdgeInsets.symmetric(horizontal: 10),
          child: Column(
            crossAxisAlignment: CrossAxisAlignment.stretch,
            children: [
              const SizedBox(height: 4),
              ElevatedButton(
                  child: Text(
                      '${_deviceFindServer != null ? 'Stop' : 'Start'} find server'),
                  onPressed: () => setState(_deviceFindServer != null
                      ? stopDeviceFindServer
                      : startDeviceFindServer)),
              const SizedBox(height: 4),
              ElevatedButton(
                  child: Text(
                      '${_deviceFindClient != null ? 'Stop' : 'Start'} find client'),
                  onPressed: () => setState(_deviceFindClient != null
                      ? stopDeviceFindClient
                      : startDeviceFindClient)),
              const SizedBox(height: 4),
              ElevatedButton(
                child: Text(
                    '${wsServer.isOpen ? 'Stop' : 'Start'} websocket server'),
                onPressed: () =>
                    setState(wsServer.isOpen ? stopWSServer : startWSServer),
              ),
              const SizedBox(height: 4),
              Column(
                children: [
                  ..._findDeviceList.map((ipAddress) => TextButton(onPressed: () async {
                    wsClient?.stop();
                    wsClient = WSClientDelegate(serverIp: ipAddress);
                    wsClient!.connect();
                  }, child: Text(ipAddress))),
                ],
              ),
            ],
          ),
        ),
      ),
    );
  }

  WSServerDelegate wsServer = WSServerDelegate();
  WSClientDelegate? wsClient;
  DeviceFindFactory? _deviceFindServer;

  void startDeviceFindServer() {
    stopDeviceFindServer();
    _deviceFindServer = DeviceFindFactory(onState: onState);
    _deviceFindServer!.init().then(
        (value) => _deviceFindServer!.startServer(SSNWT_FLAG_FLY_SCREEN_SERVER));
  }

  void stopDeviceFindServer() {
    if (_deviceFindServer != null) {
      _deviceFindServer?.stopServer();
      _deviceFindServer?.release();
    }
    _deviceFindServer = null;
  }

  void onState(int state) {
    log('onState $state');
    if (state == STATE_BROADCAST_INIT_SOCKET_ERROR ||
        state == STATE_SSDP_INIT_SOCKET_ERROR) {
      Fluttertoast.showToast(msg: "网络发现服务异常");
    }
  }

  DeviceFindFactory? _deviceFindClient;
  final Set<String> _findDeviceList = {};

  void startDeviceFindClient() {
    stopDeviceFindClient();
    _deviceFindClient = DeviceFindFactory(onState: onState);
    _deviceFindClient!.init().then(
            (value) => _deviceFindClient!.startClient(SSNWT_FLAG_FLY_SCREEN_SERVER, onDeviceFind));
  }

  void onDeviceFind(String address, int flag, String data) {
    setState(() {
      _findDeviceList.add(address);
    });
  }

  void stopDeviceFindClient() {
    if (_deviceFindClient != null) {
      _deviceFindClient?.stopClient();
      _deviceFindClient?.release();
    }
    _deviceFindClient = null;
  }

  void startWSServer() {
    wsServer.start(ServerInfo(type: deviceTypeAndroid, name: 'Huawei'));
  }

  void stopWSServer() {
    wsServer.stop();
  }
}

class WSServerDelegate implements ServerListener {
  WSServer? wsServer;

  bool get isOpen => wsServer != null;

  start(ServerInfo serverInfo) async {
    stop();
    wsServer = WSServer(
        serverInfo: serverInfo);
    wsServer!.start(WSConnectionType.flyScreen, listener: this);
  }

  void stop() {
    wsServer?.stop();
    wsServer = null;
  }

  @override
  void onClientChanged(List<ClientInfo> clients) {
    log('WSServerDelegate onClientChanged $clients');
  }

  @override
  void onHttpRequest(HttpRequest request) {
    log('WSServerDelegate onHttpRequest $request');
  }

  @override
  void onMessage(WebSocket webSocket, WSMessage message) {
    log('WSServerDelegate onMessage $message');
  }

  @override
  void onServerError({error}) {
    log('WSServerDelegate onServerError $error');
  }

  @override
  void onServerStart() {
    getIntranetIp().then((value) => log('WSServerDelegate onServerStart $value'));
  }
}

class WSClientDelegate implements ClientListener {
  final String serverIp;
  WSClient? wsClient;

  WSClientDelegate({required this.serverIp});

  connect() async {
    stop();
    DeviceInfo? deviceInfo = await SkyDeviceInfo().loadDeviceInfo();
    ClientInfo clientInfo = ClientInfo(
        model: generateRandomString(6),
        sn: generateRandomString(6),
        extra: deviceInfo?.deviceName ?? 'unknown');
    wsClient = WSClient();
    wsClient!.start(WSConnectionType.flyScreen, serverIp, clientInfo,
        listener: this);
  }

  @override
  void onConnected(ServerInfo serverInfo) {
    log('WSClientDelegate onConnected $serverInfo');
  }

  @override
  void onDisconnected({error, isConnecting}) {
    log('WSClientDelegate onDisconnected $error $isConnecting');
  }

  @override
  void onMessage(WSMessage message) {
    log('WSClientDelegate onConnected $message');
  }

  void stop() {
    wsClient?.stop();
    wsClient = null;
  }
}