Update topic/subscription path patterns to match values found in the wild.

Author: tseaver

gcloud/pubsub/_helpers.py

@@ -14,9 +14,27 @@
 
 """Helper functions for shared behavior."""
 
+import re
+
 from gcloud._helpers import _name_from_project_path
 
 
+_TOPIC_TEMPLATE = re.compile(r"""
+    projects/            # static prefix
+    (?P<project>[^/]+)   # initial letter, wordchars + hyphen
+    /topics/             # static midfix
+    (?P<name>[^/]+)      # initial letter, wordchars + allowed punc
+""", re.VERBOSE)
+
+
+_SUBSCRIPTION_TEMPLATE = re.compile(r"""
+    projects/            # static prefix
+    (?P<project>[^/]+)   # initial letter, wordchars + hyphen
+    /subscriptions/      # static midfix
+    (?P<name>[^/]+)      # initial letter, wordchars + allowed punc
+""", re.VERBOSE)
+
+
 def topic_name_from_path(path, project):
     """Validate a topic URI path and get the topic name.
 
@@ -33,8 +51,7 @@ def topic_name_from_path(path, project):
              the project from the ``path`` does not agree with the
              ``project`` passed in.
     """
-    template = r'projects/(?P<project>\w+)/topics/(?P<name>\w+)'
-    return _name_from_project_path(path, project, template)
+    return _name_from_project_path(path, project, _TOPIC_TEMPLATE)
 
 
 def subscription_name_from_path(path, project):
@@ -53,5 +70,4 @@ def subscription_name_from_path(path, project):
              the project from the ``path`` does not agree with the
              ``project`` passed in.
     """
-    template = r'projects/(?P<project>\w+)/subscriptions/(?P<name>\w+)'
-    return _name_from_project_path(path, project, template)
+    return _name_from_project_path(path, project, _SUBSCRIPTION_TEMPLATE)

gcloud/pubsub/test__helpers.py

@@ -21,9 +21,16 @@ def _callFUT(self, path, project):
         from gcloud.pubsub._helpers import topic_name_from_path
         return topic_name_from_path(path, project)
 
-    def test_it(self):
+    def test_w_simple_name(self):
         TOPIC_NAME = 'TOPIC_NAME'
-        PROJECT = 'PROJECT'
+        PROJECT = 'my-project-1234'
+        PATH = 'projects/%s/topics/%s' % (PROJECT, TOPIC_NAME)
+        topic_name = self._callFUT(PATH, PROJECT)
+        self.assertEqual(topic_name, TOPIC_NAME)
+
+    def test_w_name_w_all_extras(self):
+        TOPIC_NAME = 'TOPIC_NAME-part.one~part.two%part-three'
+        PROJECT = 'my-project-1234'
         PATH = 'projects/%s/topics/%s' % (PROJECT, TOPIC_NAME)
         topic_name = self._callFUT(PATH, PROJECT)
         self.assertEqual(topic_name, TOPIC_NAME)
@@ -35,9 +42,16 @@ def _callFUT(self, path, project):
         from gcloud.pubsub._helpers import subscription_name_from_path
         return subscription_name_from_path(path, project)
 
-    def test_it(self):
-        TOPIC_NAME = 'TOPIC_NAME'
-        PROJECT = 'PROJECT'
-        PATH = 'projects/%s/subscriptions/%s' % (PROJECT, TOPIC_NAME)
+    def test_w_simple_name(self):
+        SUBSCRIPTION_NAME = 'SUBSCRIPTION_NAME'
+        PROJECT = 'my-project-1234'
+        PATH = 'projects/%s/subscriptions/%s' % (PROJECT, SUBSCRIPTION_NAME)
         subscription_name = self._callFUT(PATH, PROJECT)
-        self.assertEqual(subscription_name, TOPIC_NAME)
+        self.assertEqual(subscription_name, SUBSCRIPTION_NAME)
+
+    def test_w_name_w_all_extras(self):
+        SUBSCRIPTION_NAME = 'SUBSCRIPTION_NAME-part.one~part.two%part-three'
+        PROJECT = 'my-project-1234'
+        PATH = 'projects/%s/subscriptions/%s' % (PROJECT, SUBSCRIPTION_NAME)
+        topic_name = self._callFUT(PATH, PROJECT)
+        self.assertEqual(topic_name, SUBSCRIPTION_NAME)