fennec_socket_io_server 0.0.1

this plugin belongs to Fennec Framework. it can be used to implement a performant realtime connection from server side.

example/example.dart

import 'dart:io';

import 'package:fennec/fennec.dart';
import 'package:fennec_socket_io_server/server_io.dart';

void main(List<String> arguments) async {
  /// Connect SOCKET IO Server with Fennec HTTP Server
  Application application = Application();
  ServerIO serverIO = ServerIO();
  application.setPort(8000).setHost(InternetAddress.loopbackIPv4);
  application.get(
      path: '/dynamic_routes/@userId',
      requestHandler: (req, res) {
        serverIO.emit('fromServer', DateTime.now().toIso8601String());
        res.json({'userId': req.pathParams['userId']});
      },
      middlewares: []);

  Router testRouter = Router(routerPath: '/v1/api');
  testRouter.get(
      path: '/simple', requestHandler: TestController().test, middlewares: []);
  testRouter.get(
    path: '/simple1',
    requestHandler: (Request req, Response res) {
      serverIO.emit('message', 'JACK AISSA');
      res.send('ss');
    },
  );
  application.addRouter(testRouter);
  application.addRoute(Route(
      path: '/show',
      requestMethod: RequestMethod.get(),
      requestHandler: (Request req, Response res) {
        res.ok().send('show received');
      },
      middlewares: [
        (req, res) {
          if (1 == 2) {
            return MiddleWareResponse(MiddleWareResponseEnum.next);
          }
          res.forbidden().send('not allowed');
          return MiddleWareResponse(MiddleWareResponseEnum.stop);
        }
      ]));
  application.useSocketIOServer(true);

  Server server = Server(application);
  await server.startServer();

  serverIO.on('connection', (client) {
    print('coo');
  });

  await serverIO.listenToHttpServer(server.httpServerStream);

  /// run SOCKET IO Server as own Server
  ServerIO serverIO1 = ServerIO();
  serverIO1.on('connection', (client) {
    print('connection');
    serverIO1.emit('fromServer', 'ok');
  });

  await serverIO1.listen('0.0.0.0', 3000);
}

class TestController {
  void test(Request request, Response response) {
    response.ok().send('hellow world');
  }

  Future<MiddleWareResponse> testMiddleware(Request req, Response res) async {
    res.html("You are not allowed to do that");
    return MiddleWareResponse(MiddleWareResponseEnum.stop);
  }
}