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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
var HttpProvider = require('web3/lib/web3/httpprovider.js')
var ethUtils = require('ethereumjs-util')
var async = require('async')
module.exports = MetamaskProvider
function MetamaskProvider(forwardPayload, host) {
this.handlers = []
this.forwardPayload = forwardPayload
this.http = new HttpProvider(host)
}
MetamaskProvider.prototype.send = function (payload) {
if (Array.isArray(payload)) {
return payload.map( this.handlePayload.bind(this) )
} else {
return this.handlePayload( payload )
}
}
MetamaskProvider.prototype.sendAsync = function (payload, cb) {
if (Array.isArray(payload)) {
async.map( payload, this.handlePayload.bind(this), cb )
} else {
this.handlePayload( payload, cb )
}
}
MetamaskProvider.prototype.handlePayload = function (payload, cb) {
var _this = this
var isSync = !cb
var resolvedSync = true
var result = undefined
// TODO - this should be injected from Vapor dapp starts
var exposedAccounts = ['0xa06ef3ed1ce41ade87f764de6ce8095c569d6d57']
switch (payload.method) {
case 'web3_sha3':
var inputHex = stripHexStringPrefix(payload.params[0])
var hash = '0x'+ethUtils.sha3(new Buffer(inputHex, 'hex')).toString('hex')
return handleResult(null, wrapResponse(payload, hash))
case 'eth_sendTransaction':
this.forwardPayload(payload)
return handleResult(null, wrapResponse(payload, ''))
case 'eth_coinbase':
var currentAddress = exposedAccounts[0]
return handleResult(null, wrapResponse(payload, currentAddress))
case 'eth_accounts':
return handleResult(null, wrapResponse(payload, exposedAccounts))
case 'eth_gasPrice':
// TODO - this should be dynamically set somehow
var gasPrice = '0x01'
return handleResult(null, wrapResponse(payload, [gasPrice]))
case 'eth_call':
var params = payload.params
// default 'from' to default account
var args = params[0]
if (!args.from) {
var currentAddress = exposedAccounts[0]
args.from = currentAddress
}
// default block to latest
params[1] = params[1] || 'latest'
// turn on debug trace
params[2] = global.DEBUG_RPC
return handleNormally()
default:
return handleNormally()
}
resolvedSync = false
function handleNormally(){
if (isSync) {
return handleResult(null, _this.http.send(payload))
} else {
_this.http.sendAsync(payload, handleResult)
}
}
// helper for normalizing handling of sync+async responses
function handleResult(err, resp) {
if (isSync) {
return resp
} else {
if (resolvedSync) {
process.nextTick(cb.bind(null, err, resp))
} else {
cb(err, resp)
}
}
}
}
function wrapResponse(payload, result){
return {
jsonrpc: payload.jsonrpc,
id: payload.id,
result: result,
}
}
function stripHexStringPrefix(hex) {
if (!hex) {
return hex
}
if (hex.slice(0, 2) === '0x') {
return hex.slice(2);
} else {
return hex;
}
}
|
