# distutils: language = c++ # distutils: extra_compile_args = -std=c++11 # distutils: include_dirs = ../../include # distutils: library_dirs = ../../src # distutils: libraries = opendht gnutls # cython: language_level=3 # # Copyright (c) 2015 Savoir-Faire Linux Inc. # Author: Guillaume Roguez # Author: Adrien Béraud # # This wrapper is written for Cython 0.22 # # This file is part of OpenDHT Python Wrapper. # # OpenDHT Python Wrapper is free software: you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # # OpenDHT Python Wrapper is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with OpenDHT Python Wrapper. If not, see . # from libcpp.map cimport map as map from libcpp cimport bool from libcpp.utility cimport pair from cython.parallel import parallel, prange from cython.operator cimport dereference as deref, preincrement as inc, predecrement as dec from cpython cimport ref cimport opendht_cpp as cpp cdef inline bool get_callback(cpp.shared_ptr[cpp.Value] value, void *user_data) with gil: cb = (user_data)['get'] pv = Value() pv._value = value return cb(pv) cdef inline void done_callback(bool done, cpp.vector[cpp.shared_ptr[cpp.Node]]* nodes, void *user_data) with gil: node_ids = [] for n in deref(nodes): h = NodeEntry() h._v.first = n.get().getId() h._v.second = n node_ids.append(h) cbs = user_data if 'done' in cbs and cbs['done']: cbs['done'](done, node_ids) ref.Py_DECREF(cbs) cdef class _WithID(object): def __repr__(self): return "<%s '%s'>" % (self.__class__.__name__, str(self)) def __str__(self): return self.getId().toString().decode() cdef class InfoHash(_WithID): cdef cpp.InfoHash _infohash def __init__(self, bytes str=b''): self._infohash = cpp.InfoHash(str) def getBit(self, bit): return self._infohash.getBit(bit) def setBit(self, bit, b): self._infohash.setBit(bit, b) def getId(self): return self def toString(self): return self._infohash.toString() def toFloat(self): return self._infohash.toFloat() @staticmethod def commonBits(InfoHash a, InfoHash b): return cpp.InfoHash.commonBits(a._infohash, b._infohash) @staticmethod def get(str key): h = InfoHash() h._infohash = cpp.InfoHash.get(key.encode()) return h @staticmethod def getRandom(): h = InfoHash() h._infohash = cpp.InfoHash.getRandom() return h cdef class Node(_WithID): cdef cpp.shared_ptr[cpp.Node] _node def getId(self): h = InfoHash() h._infohash = self._node.get().getId() return h def getAddr(self): return self._node.get().getAddrStr() def isExpired(self): return self._node.get().isExpired() cdef class NodeEntry(_WithID): cdef cpp.pair[cpp.InfoHash, cpp.shared_ptr[cpp.Node]] _v def getId(self): h = InfoHash() h._infohash = self._v.first return h def getNode(self): n = Node() n._node = self._v.second return n cdef class Value(object): cdef cpp.shared_ptr[cpp.Value] _value def __init__(self, bytes val=b''): self._value.reset(new cpp.Value(val, len(val))) def __str__(self): return self._value.get().toString().decode() cdef class NodeSetIter(object): cdef map[cpp.InfoHash, cpp.shared_ptr[cpp.Node]]* _nodes cdef map[cpp.InfoHash, cpp.shared_ptr[cpp.Node]].iterator _curIter def __init__(self, NodeSet s): self._nodes = &s._nodes self._curIter = self._nodes.begin() def __next__(self): if self._curIter == self._nodes.end(): raise StopIteration h = NodeEntry() h._v = deref(self._curIter) inc(self._curIter) return h cdef class NodeSet(object): cdef map[cpp.InfoHash, cpp.shared_ptr[cpp.Node]] _nodes def size(self): return self._nodes.size() def insert(self, NodeEntry l): self._nodes.insert(l._v) def extend(self, li): for n in li: self.insert(n) def first(self): if self._nodes.empty(): raise IndexError() h = InfoHash() h._infohash = deref(self._nodes.begin()).first return h def last(self): if self._nodes.empty(): raise IndexError() h = InfoHash() h._infohash = deref(dec(self._nodes.end())).first return h def __str__(self): s = '' cdef map[cpp.InfoHash, cpp.shared_ptr[cpp.Node]].iterator it = self._nodes.begin() while it != self._nodes.end(): s += deref(it).first.toString().decode() + ' ' + deref(it).second.get().getAddrStr().decode() + '\n' inc(it) return s def __iter__(self): return NodeSetIter(self) cdef class PublicKey(_WithID): cdef cpp.PublicKey _key def getId(self): h = InfoHash() h._infohash = self._key.getId() return h cdef class Certificate(_WithID): cdef cpp.shared_ptr[cpp.Certificate] _cert def getId(self): h = InfoHash() h._infohash = self._cert.get().getId() return h cdef class ListenToken(object): cdef cpp.InfoHash _h cdef cpp.shared_future[size_t] _t _cb = dict() cdef class Identity(object): cdef cpp.Identity _id def generate(self, str name = "pydht", Identity ca = Identity(), unsigned bits = 4096): self._id = cpp.generateIdentity(name.encode(), ca._id, bits) property PublicKey: def __get__(self): k = PublicKey() k._key = self._id.first.get().getPublicKey() return k property Certificate: def __get__(self): c = Certificate() c._cert = self._id.second return c cdef class DhtConfig(object): cdef cpp.Config _config def __init__(self): self._config = cpp.Config() self._config.threaded = True; def setIdentity(self, Identity id): self._config.dht_config.id = id._id def setBootstrapMode(self, bool bootstrap): self._config.dht_config.node_config.is_bootstrap = bootstrap cdef class DhtRunner(_WithID): cdef cpp.DhtRunner* thisptr def __cinit__(self): self.thisptr = new cpp.DhtRunner() def getId(self): h = InfoHash() h._infohash = self.thisptr.getId() return h def getNodeId(self): return self.thisptr.getNodeId().toString() def bootstrap(self, str host, str port): self.thisptr.bootstrap(host.encode(), port.encode()) def run(self, Identity id = Identity(), is_bootstrap=False, cpp.in_port_t port=0, str ipv4="", str ipv6=""): config = DhtConfig() config.setIdentity(id) if ipv4 or ipv6: self.thisptr.run(ipv4.encode(), ipv6.encode(), str(port).encode(), config._config) else: self.thisptr.run(port, config._config) def join(self): self.thisptr.join() def isRunning(self): return self.thisptr.isRunning() def getStorageLog(self): return self.thisptr.getStorageLog().decode() def getRoutingTablesLog(self, cpp.sa_family_t af): return self.thisptr.getRoutingTablesLog(af).decode() def getSearchesLog(self, cpp.sa_family_t af): return self.thisptr.getSearchesLog(af).decode() def get(self, InfoHash key, get_cb, done_cb): cb_obj = {'get':get_cb, 'done':done_cb} ref.Py_INCREF(cb_obj) self.thisptr.get(key._infohash, cpp.Dht.bindGetCb(get_callback, cb_obj), cpp.Dht.bindDoneCb(done_callback, cb_obj)) def put(self, InfoHash key, Value val, done_cb=None): cb_obj = {'done':done_cb} ref.Py_INCREF(cb_obj) self.thisptr.put(key._infohash, val._value, cpp.Dht.bindDoneCb(done_callback, cb_obj)) def listen(self, InfoHash key, get_cb): t = ListenToken() t._h = key._infohash cb_obj = {'get':get_cb} t._cb['cb'] = cb_obj # avoid the callback being destructed if the token is destroyed ref.Py_INCREF(cb_obj) t._t = self.thisptr.listen(t._h, cpp.Dht.bindGetCb(get_callback, cb_obj)).share() return t def cancelListen(self, ListenToken token): self.thisptr.cancelListen(token._h, token._t) # fixme: not thread safe ref.Py_DECREF(token._cb['cb'])