[#1797,webstore][s]: introduce webstore write route (which auto 401s …

…atm).

ckan/config/routing.py

@@ -235,8 +235,13 @@ def make_map():
     map.connect('/dataset/{id}/resource/{resource_id}',
         controller='package', action="resource_read"
     )
-    map.connect('webstore', '/api/resource/{id}/data',
-        controller='webstore', action='data'
+    map.connect('webstore_read', '/api/resource/{id}/data',
+        controller='webstore', action='read',
+        conditions={'method': ['GET']}
+        )
+    map.connect('webstore_write', '/api/resource/{id}/data',
+        controller='webstore', action='write',
+        conditions={'method': ['PUT','POST']}
         )
 
     # group

ckan/controllers/webstore.py

@@ -1,10 +1,14 @@
-from ckan.lib.base import BaseController
+from ckan.lib.base import BaseController, abort, _
 import ckan.model as model
 
 class WebstoreController(BaseController):
-    def data(self, id):
+    def read(self, id):
         resource = model.Session.query(model.Resource).get(id)
+        print 'here'
         if not resource:
             abort(404)
         return resource.id
 
+    def write(self, id):
+        abort(401, _('Not authorized to see this page'))
+

ckan/tests/functional/test_webstore.py

@@ -18,8 +18,15 @@ def teardown_class(self):
     def test_read(self):
         dataset = model.Package.by_name(CreateTestData.pkg_names[0])
         resource_id = dataset.resources[0].id
-        offset = url_for('webstore', id=resource_id)
+        offset = url_for('webstore_read', id=resource_id)
         res = self.app.get(offset)
         assert_equal(res.status, 200)
         assert_equal(res.body, resource_id)
 
+    def test_update(self):
+        dataset = model.Package.by_name(CreateTestData.pkg_names[0])
+        resource_id = dataset.resources[0].id
+        offset = url_for('webstore_write', id=resource_id)
+        res = self.app.post(offset)
+        assert res.status in [401,302]
+