-
Notifications
You must be signed in to change notification settings - Fork 1
/
JsonRpcServer.cs
78 lines (64 loc) · 2.02 KB
/
JsonRpcServer.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
using System;
using System.Collections.Concurrent;
using System.IO;
using System.Net;
using System.Threading;
using Newtonsoft.Json;
namespace UnityJsonRpc
{
public class JsonRpcServer
{
private HttpListener server;
public void Stop()
{
server.Stop();
}
public ConcurrentQueue<JsonRpcRequest> Start(string address)
{
server = new HttpListener();
var queue = new ConcurrentQueue<JsonRpcRequest>();
server.Prefixes.Add(address);
if (!HttpListener.IsSupported)
{
throw new NotSupportedException();
}
server.Start();
new Thread(() =>
{
while (server.IsListening)
{
HttpListenerContext context = null;
try
{
context = server.GetContext();
}
catch
{
break;
}
var data = "{}";
using (var stream = new StreamReader(context.Request.InputStream))
{
data = stream.ReadToEnd();
}
JsonRpcRequestData jrpcData = null;
try
{
jrpcData = JsonConvert.DeserializeObject<JsonRpcRequestData>(data);
}
catch
{
}
var jsonRpcRequest = new JsonRpcRequest(context.Response, jrpcData);
if (jrpcData == null || string.IsNullOrEmpty(jrpcData.method))
{
jsonRpcRequest.Error("bad request");
}
queue.Enqueue(new JsonRpcRequest(context.Response, jrpcData));
}
server.Close();
}).Start();
return queue;
}
}
}