- tor-commits - lists.torproject.org

[stem/master] Add a Controller.get_streams method and its tests
by atagar＠torproject.org 05 Jan '13

05 Jan '13

commit 7e5377906b6b0e0bcc20fb442fb11554df929868 Author: Sean Robinson <seankrobinson(a)gmail.com> Date: Wed Jan 2 05:52:29 2013 -0700 Add a Controller.get_streams method and its tests Re-use Ravi's idea for parsing get_info("circuit-status") responses with get_info("stream-status"). The stream status GETINFO reply contains just the mandatory parts of a STREAM event, so the event optional keyword arguments are not (yet) used. Signed-off-by: Sean Robinson <seankrobinson(a)gmail.com> --- stem/control.py | 20 ++++++++++++++++++++ test/integ/control/controller.py | 25 +++++++++++++++++++++++++ test/unit/control/controller.py | 31 ++++++++++++++++++++++++++++++- 3 files changed, 75 insertions(+), 1 deletions(-) diff --git a/stem/control.py b/stem/control.py index d8ee940..8bb3a10 100644 --- a/stem/control.py +++ b/stem/control.py @@ -51,6 +51,7 @@ providing its own for interacting at a higher level. |- close_circuit - close a circuit | |- attach_stream - attach a stream to a circuit + |- get_streams - provides a list of active streams |- close_stream - close a stream | |- signal - sends a signal to the tor client @@ -1716,6 +1717,25 @@ class Controller(BaseController): else: raise stem.ProtocolError("ATTACHSTREAM returned unexpected response code: %s" % response.code) + def get_streams(self): + """ + Provides the list of streams tor is currently handling. + + :returns: list of :class:`stem.events.StreamEvent` objects + + :raises: :class:`stem.ControllerError` if the call fails + """ + + streams = [] + response = self.get_info("stream-status") + + for stream in response.splitlines(): + message = stem.socket.recv_message(StringIO.StringIO("650 STREAM " + stream + "\r\n")) + stem.response.convert("EVENT", message, arrived_at = 0) + streams.append(message) + + return streams + def close_stream(self, stream_id, reason = stem.RelayEndReason.MISC, flag = ''): """ Closes the specified stream. diff --git a/test/integ/control/controller.py b/test/integ/control/controller.py index 534bba2..25fc431 100644 --- a/test/integ/control/controller.py +++ b/test/integ/control/controller.py @@ -20,6 +20,7 @@ import stem.descriptor.router_status_entry import stem.response.protocolinfo import stem.socket import stem.version +import test.network import test.runner import test.util @@ -580,6 +581,30 @@ class TestController(unittest.TestCase): self.assertRaises(stem.InvalidArguments, controller.close_circuit, str(int(circ_id) + 1024)) self.assertRaises(stem.InvalidRequest, controller.close_circuit, "") + def test_get_streams(self): + """ + Tests Controller.get_streams(). + """ + + if test.runner.require_control(self): return + elif test.runner.require_online(self): return + + host = "38.229.72.14" # www.torproject.org + port = 443 + target = host + ":" + str(port) + + runner = test.runner.get_runner() + with runner.get_tor_controller() as controller: + # we only need one proxy port, so take the first + socks_listener = controller.get_socks_listeners()[0] + with test.network.Socks(socks_listener) as s: + s.settimeout(30) + s.connect((host, port)) + streams = controller.get_streams() + # Because we do not get a stream id when opening a stream, + # try to match the target for which we asked a stream. + self.assertTrue(target in [stream.target for stream in streams]) + def test_mapaddress(self): if test.runner.require_control(self): return elif test.runner.require_online(self): return diff --git a/test/unit/control/controller.py b/test/unit/control/controller.py index 695c2de..a6fc372 100644 --- a/test/unit/control/controller.py +++ b/test/unit/control/controller.py @@ -10,6 +10,7 @@ import stem.version from stem import InvalidArguments, InvalidRequest, ProtocolError from stem.control import _parse_circ_path, Controller, EventType +from stem.response import events from test import mocking class TestControl(unittest.TestCase): @@ -167,4 +168,32 @@ class TestControl(unittest.TestCase): for response in invalid_responses: mocking.mock_method(Controller, "get_info", mocking.return_value(response)) self.assertRaises(stem.ProtocolError, self.controller.get_socks_listeners) - + + def test_get_streams(self): + """ + Exercises the get_streams() method. + """ + + # get a list of fake, but good looking, streams + valid_streams = ( + ("1", "NEW", "4", "10.10.10.1:80"), + ("2", "SUCCEEDED", "4", "10.10.10.1:80"), + ("3", "SUCCEEDED", "4", "10.10.10.1:80") + ) + response = [] + for stream_parts in valid_streams: + stream = mocking.get_object(events.StreamEvent) + (stream.id, stream.status, stream.circ_id, stream.target) = stream_parts + line = "%s\r\n" % " ".join(stream_parts) + response.append(line) + + mocking.mock_method(Controller, "get_info", mocking.return_value( + "".join(response) + )) + streams = self.controller.get_streams() + self.assertEqual(len(valid_streams), len(streams)) + for index in range(len(streams)): + self.assertEqual(valid_streams[index][0], streams[index].id) + self.assertEqual(valid_streams[index][1], streams[index].status) + self.assertEqual(valid_streams[index][2], streams[index].circ_id) + self.assertEqual(valid_streams[index][3], streams[index].target)

1 0

[stem/master] Add integration tests for Controller.close_stream()
by atagar＠torproject.org 05 Jan '13

05 Jan '13

commit 4f8efd38bbaccb573d19f8ce98f1d590bd8918f5 Author: Sean Robinson <seankrobinson(a)gmail.com> Date: Fri Jan 4 07:37:33 2013 -0700 Add integration tests for Controller.close_stream() Signed-off-by: Sean Robinson <seankrobinson(a)gmail.com> --- test/integ/control/controller.py | 29 +++++++++++++++++++++++++++++ 1 files changed, 29 insertions(+), 0 deletions(-) diff --git a/test/integ/control/controller.py b/test/integ/control/controller.py index 25fc431..da091c0 100644 --- a/test/integ/control/controller.py +++ b/test/integ/control/controller.py @@ -605,6 +605,35 @@ class TestController(unittest.TestCase): # try to match the target for which we asked a stream. self.assertTrue(target in [stream.target for stream in streams]) + def test_close_stream(self): + """ + Tests Controller.close_stream with valid and invalid input. + """ + + if test.runner.require_control(self): return + elif test.runner.require_online(self): return + + runner = test.runner.get_runner() + + with runner.get_tor_controller() as controller: + # use the first socks listener + socks_listener = controller.get_socks_listeners()[0] + with test.network.Socks(socks_listener) as s: + s.settimeout(30) + s.connect(("www.torproject.org", 443)) + # There's only one stream right now. Right? + built_stream = controller.get_streams()[0] + # Make sure we have the stream for which we asked, otherwise + # the next assertion would be a false positive. + self.assertEqual([built_stream.id], [stream.id for stream in controller.get_streams()]) + # Try to close our stream... + controller.close_stream(built_stream.id) + # ...which means there are zero streams. + self.assertEqual([], controller.get_streams()) + + # unknown stream + self.assertRaises(stem.InvalidArguments, controller.close_stream, "blarg") + def test_mapaddress(self): if test.runner.require_control(self): return elif test.runner.require_online(self): return

1 0

[stem/master] Controller get_streams() method and close_stream() test
by atagar＠torproject.org 05 Jan '13

05 Jan '13

commit 80f03bdd427813eedf88d847e9229415ca42541f Merge: ec1078c 9808fbc Author: Damian Johnson <atagar(a)torproject.org> Date: Fri Jan 4 19:12:19 2013 -0800 Controller get_streams() method and close_stream() test Merging patches by Sean for... * adding a get_streams() method to the controller https://trac.torproject.org/7859 * integ test for the close_stream() method he added earlier https://trac.torproject.org/7687 stem/control.py | 27 ++++++++++++++++++ test/integ/control/controller.py | 56 ++++++++++++++++++++++++++++++++++++++ test/unit/control/controller.py | 28 +++++++++++++++++++ 3 files changed, 111 insertions(+), 0 deletions(-)

1 0

[stem/master] Adding a default arg to get_streams()
by atagar＠torproject.org 05 Jan '13

05 Jan '13

commit 7b2f6be091f4bb340277a49565bf37ec3a97e3c2 Author: Damian Johnson <atagar(a)torproject.org> Date: Fri Jan 4 09:34:39 2013 -0800 Adding a default arg to get_streams() Adding a default argument to the new get_streams() method (see ffdd61e). --- stem/control.py | 29 ++++++++++++++++++----------- 1 files changed, 18 insertions(+), 11 deletions(-) diff --git a/stem/control.py b/stem/control.py index 39b00b9..c7d52b4 100644 --- a/stem/control.py +++ b/stem/control.py @@ -1688,24 +1688,31 @@ class Controller(BaseController): else: raise stem.ProtocolError("CLOSECIRCUIT returned unexpected response code: %s" % response.code) - def get_streams(self): + def get_streams(self, default = UNDEFINED): """ Provides the list of streams tor is currently handling. + :param object default: response if the query fails + :returns: list of :class:`stem.events.StreamEvent` objects - :raises: :class:`stem.ControllerError` if the call fails + :raises: :class:`stem.ControllerError` if the call fails and no default was + provided """ - streams = [] - response = self.get_info("stream-status") - - for stream in response.splitlines(): - message = stem.socket.recv_message(StringIO.StringIO("650 STREAM " + stream + "\r\n")) - stem.response.convert("EVENT", message, arrived_at = 0) - streams.append(message) - - return streams + try: + streams = [] + response = self.get_info("stream-status") + + for stream in response.splitlines(): + message = stem.socket.recv_message(StringIO.StringIO("650 STREAM " + stream + "\r\n")) + stem.response.convert("EVENT", message, arrived_at = 0) + streams.append(message) + + return streams + except Exception, exc: + if default == UNDEFINED: raise exc + else: return default def attach_stream(self, stream_id, circuit_id, exiting_hop = None): """

1 0

[stem/master] Minor get_streams() testing revisions
by atagar＠torproject.org 05 Jan '13

05 Jan '13

commit 9808fbc0abf13ea0a6e5cef3249c286e36592494 Author: Damian Johnson <atagar(a)torproject.org> Date: Fri Jan 4 09:59:44 2013 -0800 Minor get_streams() testing revisions Minor tweaks for the get_streams() tests, for instance the 'stream' argument was unused (likely used to assert that the stream lists were equal, which didn't work due to mock objects leading it to be replaced when a len() check). --- test/integ/control/controller.py | 6 ++++-- test/unit/control/controller.py | 23 +++++++++++------------ 2 files changed, 15 insertions(+), 14 deletions(-) diff --git a/test/integ/control/controller.py b/test/integ/control/controller.py index da091c0..8fada2b 100644 --- a/test/integ/control/controller.py +++ b/test/integ/control/controller.py @@ -591,19 +591,21 @@ class TestController(unittest.TestCase): host = "38.229.72.14" # www.torproject.org port = 443 - target = host + ":" + str(port) runner = test.runner.get_runner() with runner.get_tor_controller() as controller: # we only need one proxy port, so take the first socks_listener = controller.get_socks_listeners()[0] + with test.network.Socks(socks_listener) as s: s.settimeout(30) s.connect((host, port)) streams = controller.get_streams() + # Because we do not get a stream id when opening a stream, # try to match the target for which we asked a stream. - self.assertTrue(target in [stream.target for stream in streams]) + + self.assertTrue("%s:%s" % (host, port) in [stream.target for stream in streams]) def test_close_stream(self): """ diff --git a/test/unit/control/controller.py b/test/unit/control/controller.py index a6fc372..fa06a2d 100644 --- a/test/unit/control/controller.py +++ b/test/unit/control/controller.py @@ -180,20 +180,19 @@ class TestControl(unittest.TestCase): ("2", "SUCCEEDED", "4", "10.10.10.1:80"), ("3", "SUCCEEDED", "4", "10.10.10.1:80") ) - response = [] - for stream_parts in valid_streams: - stream = mocking.get_object(events.StreamEvent) - (stream.id, stream.status, stream.circ_id, stream.target) = stream_parts - line = "%s\r\n" % " ".join(stream_parts) - response.append(line) + + responses = ["%s\r\n" % " ".join(entry) for entry in valid_streams] mocking.mock_method(Controller, "get_info", mocking.return_value( - "".join(response) + "".join(responses) )) + streams = self.controller.get_streams() self.assertEqual(len(valid_streams), len(streams)) - for index in range(len(streams)): - self.assertEqual(valid_streams[index][0], streams[index].id) - self.assertEqual(valid_streams[index][1], streams[index].status) - self.assertEqual(valid_streams[index][2], streams[index].circ_id) - self.assertEqual(valid_streams[index][3], streams[index].target) + + for index, stream in enumerate(streams): + self.assertEqual(valid_streams[index][0], stream.id) + self.assertEqual(valid_streams[index][1], stream.status) + self.assertEqual(valid_streams[index][2], stream.circ_id) + self.assertEqual(valid_streams[index][3], stream.target) +

1 0

[translation/https_everywhere_completed] Update translations for https_everywhere_completed
by translation＠torproject.org 05 Jan '13

05 Jan '13

commit 32065218efeaab7dae1e30099c51b638787a52ec Author: Translation commit bot <translation(a)torproject.org> Date: Sat Jan 5 01:15:52 2013 +0000 Update translations for https_everywhere_completed --- fr/ssl-observatory.dtd | 8 ++++---- 1 files changed, 4 insertions(+), 4 deletions(-) diff --git a/fr/ssl-observatory.dtd b/fr/ssl-observatory.dtd index 8696412..414acfc 100644 --- a/fr/ssl-observatory.dtd +++ b/fr/ssl-observatory.dtd @@ -27,7 +27,7 @@ to turn it on?">--> "Soumettre et vérifier les certificats signés par des autorités inhabituelles"> <!ENTITY ssl-observatory.prefs.alt_roots_tooltip -" Il est sûr (et c'est une bonne idée) d'activer cette option, sauf si vous utilisez un réseau d'entreprise intrusif ou le logicile antivirus Kaspersky qui surveille votre navigation avec un proxy TLS et une autorité racine privée du certificat. Si elle est activée sur un tel réseau, cette option pourrait publier des preuves que tel ou tel domaine a été visité en https:// à travers ce proxy, à cause des certificats uniques qu'elle produirait. Nous la désactivons donc par défaut"> +" Il est sûr (et c'est une bonne idée) d'activer cette option, sauf si vous utilisez un réseau d'entreprise intrusif ou le logiciel antivirus Kaspersky qui surveille votre navigation avec un proxy TLS et une autorité racine privée du certificat. Si elle est activée sur un tel réseau, cette option pourrait publier des preuves que tel ou tel domaine a été visité en https:// à travers ce proxy, à cause des certificats uniques qu'elle produirait. Nous la désactivons donc par défaut"> <!ENTITY ssl-observatory.prefs.anonymous "Vérifier les certificats et utiliser l'outil d'anonymat TOR"> <!ENTITY ssl-observatory.prefs.anonymous_unavailable @@ -39,7 +39,7 @@ to turn it on?">--> "Quand vous voyez un nouveau certificat, indiquez à l'Observatoire quel FAI vous utilisez maintenant."> <!ENTITY ssl-observatory.prefs.asn_tooltip -"Cette option récupérera et rapportera le « Autonomous System number » de votre réseau. Cela nous aidera à localiser les attaques contre HTTPS, et savoir si nous avons des observations à partir de réseaux dans des pays comme l'Iran et la Syrie ou ces attaques sont fréquentes."> +"Cette option récupérera et rapportera le « Autonomous System number » de votre réseau. Cela nous aidera à localiser les attaques contre HTTPS, et savoir si nous avons des observations à partir de réseaux dans des pays comme l'Iran et la Syrie où ces attaques sont fréquentes."> <!ENTITY ssl-observatory.prefs.done "OK"> @@ -55,7 +55,7 @@ Mouseover the options for further details:">--> <!ENTITY ssl-observatory.prefs.explanation2 -"Pqr exemple, si vous visitez https://www.something.com, le certificat reçu par l'Observatoire indiquera que quelqu'un a visité +"Par exemple, si vous visitez https://www.something.com, le certificat reçu par l'Observatoire indiquera que quelqu'un a visité www.something.com, mais pas qui a visité le site, ou quelle page a été lue. Passez votre souris sur les options pour plus d'informations:"> <!ENTITY ssl-observatory.prefs.hide "Cacher les options avancées"> @@ -70,7 +70,7 @@ www.something.com, mais pas qui a visité le site, ou quelle page a été lue. P "Soumettre et vérifier les certificats des DNS privés"> <!ENTITY ssl-observatory.prefs.priv_dns_tooltip -"Si cette option est activée, l'Observatoire conservera les certificats des domaines qui ne peuvent etre résolus par le système DNS public"> +"Si cette option est activée, l'Observatoire conservera les certificats des domaines qui ne peuvent être résolus par le système DNS public"> <!ENTITY ssl-observatory.prefs.show "Options avancées">

1 0

[translation/https_everywhere] Update translations for https_everywhere
by translation＠torproject.org 05 Jan '13

05 Jan '13

commit 6c523ec87052da38399314e02a14961391c0bb55 Author: Translation commit bot <translation(a)torproject.org> Date: Sat Jan 5 01:15:47 2013 +0000 Update translations for https_everywhere --- fr/ssl-observatory.dtd | 8 ++++---- 1 files changed, 4 insertions(+), 4 deletions(-) diff --git a/fr/ssl-observatory.dtd b/fr/ssl-observatory.dtd index 8696412..414acfc 100644 --- a/fr/ssl-observatory.dtd +++ b/fr/ssl-observatory.dtd @@ -27,7 +27,7 @@ to turn it on?">--> "Soumettre et vérifier les certificats signés par des autorités inhabituelles"> <!ENTITY ssl-observatory.prefs.alt_roots_tooltip -" Il est sûr (et c'est une bonne idée) d'activer cette option, sauf si vous utilisez un réseau d'entreprise intrusif ou le logicile antivirus Kaspersky qui surveille votre navigation avec un proxy TLS et une autorité racine privée du certificat. Si elle est activée sur un tel réseau, cette option pourrait publier des preuves que tel ou tel domaine a été visité en https:// à travers ce proxy, à cause des certificats uniques qu'elle produirait. Nous la désactivons donc par défaut"> +" Il est sûr (et c'est une bonne idée) d'activer cette option, sauf si vous utilisez un réseau d'entreprise intrusif ou le logiciel antivirus Kaspersky qui surveille votre navigation avec un proxy TLS et une autorité racine privée du certificat. Si elle est activée sur un tel réseau, cette option pourrait publier des preuves que tel ou tel domaine a été visité en https:// à travers ce proxy, à cause des certificats uniques qu'elle produirait. Nous la désactivons donc par défaut"> <!ENTITY ssl-observatory.prefs.anonymous "Vérifier les certificats et utiliser l'outil d'anonymat TOR"> <!ENTITY ssl-observatory.prefs.anonymous_unavailable @@ -39,7 +39,7 @@ to turn it on?">--> "Quand vous voyez un nouveau certificat, indiquez à l'Observatoire quel FAI vous utilisez maintenant."> <!ENTITY ssl-observatory.prefs.asn_tooltip -"Cette option récupérera et rapportera le « Autonomous System number » de votre réseau. Cela nous aidera à localiser les attaques contre HTTPS, et savoir si nous avons des observations à partir de réseaux dans des pays comme l'Iran et la Syrie ou ces attaques sont fréquentes."> +"Cette option récupérera et rapportera le « Autonomous System number » de votre réseau. Cela nous aidera à localiser les attaques contre HTTPS, et savoir si nous avons des observations à partir de réseaux dans des pays comme l'Iran et la Syrie où ces attaques sont fréquentes."> <!ENTITY ssl-observatory.prefs.done "OK"> @@ -55,7 +55,7 @@ Mouseover the options for further details:">--> <!ENTITY ssl-observatory.prefs.explanation2 -"Pqr exemple, si vous visitez https://www.something.com, le certificat reçu par l'Observatoire indiquera que quelqu'un a visité +"Par exemple, si vous visitez https://www.something.com, le certificat reçu par l'Observatoire indiquera que quelqu'un a visité www.something.com, mais pas qui a visité le site, ou quelle page a été lue. Passez votre souris sur les options pour plus d'informations:"> <!ENTITY ssl-observatory.prefs.hide "Cacher les options avancées"> @@ -70,7 +70,7 @@ www.something.com, mais pas qui a visité le site, ou quelle page a été lue. P "Soumettre et vérifier les certificats des DNS privés"> <!ENTITY ssl-observatory.prefs.priv_dns_tooltip -"Si cette option est activée, l'Observatoire conservera les certificats des domaines qui ne peuvent etre résolus par le système DNS public"> +"Si cette option est activée, l'Observatoire conservera les certificats des domaines qui ne peuvent être résolus par le système DNS public"> <!ENTITY ssl-observatory.prefs.show "Options avancées">

1 0

[translation/https_everywhere_completed] Update translations for https_everywhere_completed
by translation＠torproject.org 05 Jan '13

05 Jan '13

commit d0be8e6321a0f96bc0927c1bbb011128d06bf695 Author: Translation commit bot <translation(a)torproject.org> Date: Sat Jan 5 00:45:56 2013 +0000 Update translations for https_everywhere_completed --- fr/https-everywhere.dtd | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/fr/https-everywhere.dtd b/fr/https-everywhere.dtd index aefdaf6..cfaa41f 100644 --- a/fr/https-everywhere.dtd +++ b/fr/https-everywhere.dtd @@ -1,6 +1,6 @@ <!ENTITY https-everywhere.about.title "À propos de HTTPS Everywhere"> <!ENTITY https-everywhere.about.ext_name "HTTPS Everywhere"> -<!ENTITY https-everywhere.about.ext_description "Chiffrer le Web ! Utilisez HTTPS automatiquement avec nombreux sites."> +<!ENTITY https-everywhere.about.ext_description "Chiffrer le Web ! Utilisez HTTPS automatiquement avec de nombreux sites."> <!ENTITY https-everywhere.about.version "Version"> <!ENTITY https-everywhere.about.created_by "Créé par"> <!ENTITY https-everywhere.about.librarians "Bibliothécaires de règles">

1 0

[translation/https_everywhere] Update translations for https_everywhere
by translation＠torproject.org 05 Jan '13

05 Jan '13

commit 7e2b504e23bfe5d5f5575e42d85b9adacf674273 Author: Translation commit bot <translation(a)torproject.org> Date: Sat Jan 5 00:45:52 2013 +0000 Update translations for https_everywhere --- fr/https-everywhere.dtd | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/fr/https-everywhere.dtd b/fr/https-everywhere.dtd index aefdaf6..cfaa41f 100644 --- a/fr/https-everywhere.dtd +++ b/fr/https-everywhere.dtd @@ -1,6 +1,6 @@ <!ENTITY https-everywhere.about.title "À propos de HTTPS Everywhere"> <!ENTITY https-everywhere.about.ext_name "HTTPS Everywhere"> -<!ENTITY https-everywhere.about.ext_description "Chiffrer le Web ! Utilisez HTTPS automatiquement avec nombreux sites."> +<!ENTITY https-everywhere.about.ext_description "Chiffrer le Web ! Utilisez HTTPS automatiquement avec de nombreux sites."> <!ENTITY https-everywhere.about.version "Version"> <!ENTITY https-everywhere.about.created_by "Créé par"> <!ENTITY https-everywhere.about.librarians "Bibliothécaires de règles">

1 0

[flashproxy/master] Add a question above the Yes/No buttons.
by dcf＠torproject.org 05 Jan '13

05 Jan '13

commit 51bac41fc406cb05999a51c50f55d461ce86a2c5 Author: David Fifield <david(a)bamsoftware.com> Date: Fri Jan 4 16:23:55 2013 -0800 Add a question above the Yes/No buttons. Based on a suggestion by bastik. https://trac.torproject.org/projects/tor/ticket/7811#comment:3 --- proxy/options.html | 1 + 1 files changed, 1 insertions(+), 0 deletions(-) diff --git a/proxy/options.html b/proxy/options.html index a2b8480..9caa9e3 100644 --- a/proxy/options.html +++ b/proxy/options.html @@ -133,6 +133,7 @@ function update_setting_text() { setting.innerHTML = prefix + "do not use my browser as a proxy. " + "Click yes below to change your setting.</p>"; } + setting.innerHTML += "<p>Do you want your browser to act as a proxy?</p>"; } window.onload = function () {

1 0