-
Notifications
You must be signed in to change notification settings - Fork 2
/
rpc.js
88 lines (77 loc) · 2.17 KB
/
rpc.js
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
79
80
81
82
83
84
85
86
87
88
const { RAN, NoopTransport, RasBridge } = require('random-access-network')
const RPC = require('frame-rpc')
const ANY_ORIGIN = '*'
class Client {
/**
* Creates the client for frame-rpc for reading dat content
* @param {Window} window The window the client is running in
* @param {Window} server The window the parent of the service is running in
*/
constructor (window, server) {
this._rpc = RPC(window, server, ANY_ORIGIN, this._methods())
}
getStorage () {
return (name) => {
return RAN(name, new RPCTransport(name, this._rpc))
}
}
selectArchive (options, callback) {
this._rpc.call('selectArchive', options, callback)
}
addArchive (key, secretKey, options, callback) {
this._rpc.call('addArchive', key, secretKey, options, callback)
}
_methods () {
return {
// Client doesn't provide any methods
}
}
}
class Server {
/**
* Creates the server for frame-rpc for serving dat content
* @param {Window} window The window serving the content
* @param {Window} client The child window using the service
* @param {Object} options Should contain `storage`, `selectArchive`, and `addArchive` implementations
*/
constructor (window, client, options) {
Object.assign(this, options)
this._rpc = RPC(window, client, ANY_ORIGIN, this._methods())
this._bridge = RasBridge((name) => this._getStorage(name))
}
_getStorage (name) {
const storage = this.storage(name)
return storage
}
_methods () {
return {
selectArchive: (options, callback) => {
this.selectArchive(options, callback)
},
addArchive: (key, secretKey, options, callback) => {
this.addArchive(key, secretKey, options, callback)
},
storage: (name, request, callback) => {
this._bridge(Buffer.from(request), callback)
}
}
}
}
class RPCTransport extends NoopTransport {
constructor (name, rpc) {
super(name)
this._rpc = rpc
}
send (request) {
this._rpc.call('storage', this._name, request, (response) => {
this._next(Buffer.from(response))
})
}
close () {
// ¯\_(ツ)_/¯
}
}
module.exports = {
Client: Client,
Server: Server
}