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
|
from twisted.internet.endpoints import clientFromString
from txi2p import sam
DEFAULT_ENDPOINT = {
'BOB': 'tcp:127.0.0.1:2827',
'SAM': 'tcp:127.0.0.1:7656',
}
DEFAULT_API = 'SAM'
def getApi(api, apiEndpoint, apiDict):
if not api:
if apiEndpoint:
raise ValueError('api must be specified if apiEndpoint is given')
else:
api = DEFAULT_API
if api not in apiDict:
raise ValueError('Specified I2P API is invalid or unsupported')
if not apiEndpoint:
apiEndpoint = DEFAULT_ENDPOINT[api]
return (api, apiEndpoint)
_apiTesters = {
'SAM': sam.testAPI,
}
def testAPI(reactor, api=None, apiEndpoint=None):
"""Test whether an API is reachable.
The function returns a :class:`twisted.internet.defer.Deferred`; register
callbacks to receive the return value or errors.
Args:
reactor: The API endpoint will be constructed with this reactor.
api (str): The API to test.
apiEndpoint (str): An endpoint string that may connect to the API.
Alternatively, the caller can directly provide an
:class:`twisted.internet.interfaces.IStreamClientEndpoint`, and the
``reactor`` will be ignored.
Returns:
True if the API is reachable.
Raises:
ValueError: if the API doesn't support this method.
"""
api, apiEndpoint = getApi(api, apiEndpoint, _apiTesters)
if isinstance(apiEndpoint, str):
apiEndpoint = clientFromString(reactor, apiEndpoint)
return _apiTesters[api](apiEndpoint)
_apiGenerators = {
'SAM': sam.generateDestination,
}
def generateDestination(reactor, keyfile, api=None, apiEndpoint=None):
"""Generate a new I2P Destination.
The function returns a :class:`twisted.internet.defer.Deferred`; register
callbacks to receive the return value or errors.
Args:
reactor: The API endpoint will be constructed with this reactor.
keyfile (str): Path to a local file where the keypair for the new
Destination should be stored.
api (str): The API to use.
apiEndpoint (str): An endpoint string that will connect to the API.
Alternatively, the caller can directly provide an
:class:`twisted.internet.interfaces.IStreamClientEndpoint`, and the
``reactor`` will be ignored.
Returns:
txi2p.I2PAddress: The new Destination. Once this is received via the
Deferred callback, the ``keyfile`` will have been written.
Raises:
ValueError: if the API doesn't support this method.
ValueError: if the ``keyfile`` already exists.
IOError: if the ``keyfile`` write fails.
"""
api, apiEndpoint = getApi(api, apiEndpoint, _apiGenerators)
if isinstance(apiEndpoint, str):
apiEndpoint = clientFromString(reactor, apiEndpoint)
return _apiGenerators[api](keyfile, apiEndpoint)
|
