server2_io_reflected_for_client_test.dart

import 'dart:convert';
import 'dart:io';

import 'package:jsonrpc2/src/server_base.dart';
import 'package:reflector_dispatcher/reflector_dispatcher.dart';

import 'package:reflectable/reflectable.dart';
import 'package:rpc_dispatcher/rpc_dispatcher.dart';

import 'reflected_rpc_methods.dart';
import 'server2_io_reflected_for_client_test.reflectable.dart';

class Reflector extends Reflectable {
  const Reflector()
      : super(
            invokingCapability, // Request the capability to invoke methods.
            declarationsCapability); // needed for introspecting methods.
}

const reflectable = Reflector();

final port = 8394;

///
/// Test server for test_client.dart. Uses HttpServer from dart:io package.
///
void main() async {
  initializeReflectable();
  var server = await HttpServer.bind(InternetAddress.loopbackIPv4, port);
  print('Test Server running at '
      'http://${InternetAddress.loopbackIPv4.address}:$port\n');
  await for (var request in server) {
    var content = await utf8.decoder.bind(request).join();
    // useful for debugging!
    // print(content);
    switch (request.method) {
      case 'OPTIONS':
        setCrossOriginHeaders(request);
        request.response.statusCode = 204;
        await request.response.close();
        break;
      case 'POST':

        //_logger.fine(body.body);
        var pathCheck = request.uri.pathSegments[0];
        Dispatcher dispatcher;
        if (pathCheck == 'friend') {
          var friendName = request.uri.pathSegments[1];
          dispatcher =
              ReflectorDispatcher(Friend(friendName), friendReflectable);
        } else {
          dispatcher =
              ReflectorDispatcher(ExampleMethodsClass(), myReflectable);
        }

        /// import this function from [jsonrpc2/jsonrpc_service.dart]
        var result = await jsonRpc(content, dispatcher);
        //_logger.fine(result);
        setCrossOriginHeaders(request);
        var response = request.response;
        response.headers.set('Content-Type', 'application/json; charset=UTF-8');
        response.statusCode = 200;
        var out = result;
        // useful debugger!
        // print('${request.method}: $out');
        response.write(out);
        await response.close();
        break;
      default:
      // print(request.method);
    }
  }
  ;
}

void setCrossOriginHeaders(request) {
  HttpResponse response = request.response;
  response.headers.set('Access-Control-Allow-Origin', '*');
  response.headers.set('Access-Control-Allow-Methods', 'POST, GET, OPTIONS');
  response.headers.set('Access-Control-Allow-Headers',
      'Origin, X-Requested-With, Content-Type, Accept');
}