5 class UploadsControllerTest < ActionDispatch::IntegrationTest
7 # test all routes which lead to this controller
10 { :path => "/api/0.6/changeset/1/upload", :method => :post },
11 { :controller => "api/changesets/uploads", :action => "create", :changeset_id => "1" }
15 def test_upload_when_unauthorized
16 changeset = create(:changeset)
17 node = create(:node, :latitude => 0, :longitude => 0)
22 <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
27 post api_changeset_upload_path(changeset), :params => diff
29 assert_response :unauthorized
32 assert_equal 0, changeset.num_changes
34 assert_equal 1, node.version
35 assert_equal 0, node.latitude
36 assert_equal 0, node.longitude
39 def test_upload_by_private_user
40 user = create(:user, :data_public => false)
41 changeset = create(:changeset, :user => user)
42 node = create(:node, :latitude => 0, :longitude => 0)
47 <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
52 auth_header = bearer_authorization_header user
54 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
56 assert_response :forbidden
59 assert_equal 0, changeset.num_changes
61 assert_equal 1, node.version
62 assert_equal 0, node.latitude
63 assert_equal 0, node.longitude
66 def test_upload_without_required_scope
68 changeset = create(:changeset, :user => user)
69 node = create(:node, :latitude => 0, :longitude => 0)
74 <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
79 auth_header = bearer_authorization_header user, :scopes => %w[read_prefs]
81 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
83 assert_response :forbidden
86 assert_equal 0, changeset.num_changes
88 assert_equal 1, node.version
89 assert_equal 0, node.latitude
90 assert_equal 0, node.longitude
93 def test_upload_with_required_scope
95 changeset = create(:changeset, :user => user)
96 node = create(:node, :latitude => 0, :longitude => 0)
101 <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
106 auth_header = bearer_authorization_header user, :scopes => %w[write_api]
108 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
110 assert_response :success
112 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
113 assert_dom "> node", 1 do
114 assert_dom "> @old_id", node.id.to_s
115 assert_dom "> @new_id", node.id.to_s
116 assert_dom "> @new_version", "2"
121 assert_equal 1, changeset.num_changes
123 assert_equal 2, node.version
124 assert_equal 2 * GeoRecord::SCALE, node.latitude
125 assert_equal 1 * GeoRecord::SCALE, node.longitude
129 # try to upload with commands other than create, modify, or delete
130 def test_upload_unknown_action
131 changeset = create(:changeset)
136 <node id='1' lon='1' lat='1' changeset='#{changeset.id}' />
141 auth_header = bearer_authorization_header changeset.user
143 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
145 assert_response :bad_request
146 assert_equal "Unknown action ping, choices are create, modify, delete", @response.body
150 # test for issues in https://github.com/openstreetmap/trac-tickets/issues/1568
151 def test_upload_empty_changeset
152 changeset = create(:changeset)
154 auth_header = bearer_authorization_header changeset.user
157 "<osmChange></osmChange>",
158 "<osmChange><modify/></osmChange>",
159 "<osmChange><modify></modify></osmChange>"].each do |diff|
160 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
162 assert_response :success
167 # test that the X-Error-Format header works to request XML errors
168 def test_upload_xml_errors
169 changeset = create(:changeset)
171 create(:relation_member, :member => node)
173 # try and delete a node that is in use
174 diff = XML::Document.new
175 diff.root = XML::Node.new "osmChange"
176 delete = XML::Node.new "delete"
178 delete << xml_node_for_node(node)
180 auth_header = bearer_authorization_header changeset.user
181 error_header = error_format_header "xml"
183 post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header.merge(error_header)
185 assert_response :success
187 assert_dom "osmError[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1
188 assert_dom "osmError>status", 1
189 assert_dom "osmError>message", 1
192 # -------------------------------------
193 # Test creating elements.
194 # -------------------------------------
196 def test_upload_create_node
198 changeset = create(:changeset, :user => user)
203 <node id='-1' lon='30' lat='60' changeset='#{changeset.id}'>
204 <tag k='amenity' v='bar'/>
205 <tag k='name' v='Foo'/>
211 auth_header = bearer_authorization_header user
213 assert_difference "Node.count" => 1,
214 "OldNode.count" => 1,
215 "NodeTag.count" => 2,
216 "OldNodeTag.count" => 2 do
217 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
219 assert_response :success
223 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
224 assert_dom "> node", 1 do |(node_el)|
225 node = Node.find(node_el["new_id"].to_i)
226 assert_dom "> @old_id", "-1"
227 assert_dom "> @new_version", "1"
231 assert_equal 1, node.version
232 assert_equal changeset, node.changeset
233 assert_predicate node, :visible?
234 assert_equal({ "name" => "Foo", "amenity" => "bar" }, node.tags)
235 assert_equal 60, node.lat
236 assert_equal 30, node.lon
239 def test_upload_create_way
240 node1 = create(:node)
241 node2 = create(:node)
243 changeset = create(:changeset, :user => user)
248 <way id='-1' changeset='#{changeset.id}'>
249 <tag k='highway' v='primary'/>
250 <tag k='name' v='Foo'/>
251 <nd ref='#{node1.id}'/>
252 <nd ref='#{node2.id}'/>
258 auth_header = bearer_authorization_header user
260 assert_difference "Way.count" => 1,
263 "OldWayTag.count" => 2,
264 "WayNode.count" => 2,
265 "OldWayNode.count" => 2 do
266 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
268 assert_response :success
272 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
273 assert_dom "> way", 1 do |(way_el)|
274 way = Way.find(way_el["new_id"].to_i)
275 assert_dom "> @old_id", "-1"
276 assert_dom "> @new_version", "1"
280 assert_equal 1, way.version
281 assert_equal changeset, way.changeset
282 assert_predicate way, :visible?
283 assert_equal({ "name" => "Foo", "highway" => "primary" }, way.tags)
284 assert_equal [node1, node2], way.nodes
287 def test_upload_create_relation
288 node1 = create(:node)
289 way1 = create(:way_with_nodes)
290 relation1 = create(:relation)
292 changeset = create(:changeset, :user => user)
297 <relation id='-1' changeset='#{changeset.id}'>
298 <member type='node' role='n_role' ref='#{node1.id}'/>
299 <member type='way' role='w_role' ref='#{way1.id}'/>
300 <member type='relation' role='r_role' ref='#{relation1.id}'/>
301 <tag k='type' v='collection'/>
307 auth_header = bearer_authorization_header user
309 assert_difference "Relation.count" => 1,
310 "OldRelation.count" => 1,
311 "RelationTag.count" => 1,
312 "OldRelationTag.count" => 1,
313 "RelationMember.count" => 3,
314 "OldRelationMember.count" => 3 do
315 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
317 assert_response :success
321 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
322 assert_dom "> relation", 1 do |(relation_el)|
323 relation = Relation.find(relation_el["new_id"].to_i)
324 assert_dom "> @old_id", "-1"
325 assert_dom "> @new_version", "1"
329 assert_equal 1, relation.version
330 assert_equal changeset, relation.changeset
331 assert_predicate relation, :visible?
332 assert_equal({ "type" => "collection" }, relation.tags)
333 assert_equal [["Node", node1.id, "n_role"],
334 ["Way", way1.id, "w_role"],
335 ["Relation", relation1.id, "r_role"]], relation.members
338 def test_upload_create_elements
340 changeset = create(:changeset, :user => user)
342 way = create(:way_with_nodes, :nodes_count => 2)
343 relation = create(:relation)
348 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
349 <tag k='foo' v='bar'/>
350 <tag k='baz' v='bat'/>
352 <way id='-1' changeset='#{changeset.id}'>
353 <nd ref='#{node.id}'/>
357 <relation id='-1' changeset='#{changeset.id}'>
358 <member type='way' role='some' ref='#{way.id}'/>
359 <member type='node' role='some' ref='#{node.id}'/>
360 <member type='relation' role='some' ref='#{relation.id}'/>
366 auth_header = bearer_authorization_header user
368 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
370 assert_response :success
372 new_node_id, new_way_id, new_rel_id = nil
373 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
374 # inspect the response to find out what the new element IDs are
375 # check the old IDs are all present and negative one
376 # check the versions are present and equal one
377 assert_dom "> node", 1 do |(node_el)|
378 new_node_id = node_el["new_id"].to_i
379 assert_dom "> @old_id", "-1"
380 assert_dom "> @new_version", "1"
382 assert_dom "> way", 1 do |(way_el)|
383 new_way_id = way_el["new_id"].to_i
384 assert_dom "> @old_id", "-1"
385 assert_dom "> @new_version", "1"
387 assert_dom "> relation", 1 do |(rel_el)|
388 new_rel_id = rel_el["new_id"].to_i
389 assert_dom "> @old_id", "-1"
390 assert_dom "> @new_version", "1"
394 assert_equal 2, Node.find(new_node_id).tags.size, "new node should have two tags"
395 assert_equal 0, Way.find(new_way_id).tags.size, "new way should have no tags"
396 assert_equal 0, Relation.find(new_rel_id).tags.size, "new relation should have no tags"
400 # upload an element with a really long tag value
401 def test_upload_create_node_with_tag_too_long
402 changeset = create(:changeset)
407 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
408 <tag k='foo' v='#{'x' * 256}'/>
414 auth_header = bearer_authorization_header changeset.user
416 assert_no_difference "Node.count" do
417 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
419 assert_response :bad_request
423 def test_upload_create_nodes_with_invalid_placeholder_reuse_in_one_action_block
424 changeset = create(:changeset)
429 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}' version='1'/>
430 <node id='-1' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
435 auth_header = bearer_authorization_header changeset.user
437 assert_no_difference "Node.count" do
438 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
440 assert_response :bad_request
444 def test_upload_create_nodes_with_invalid_placeholder_reuse_in_two_action_blocks
445 changeset = create(:changeset)
450 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}' version='1'/>
453 <node id='-1' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
458 auth_header = bearer_authorization_header changeset.user
460 assert_no_difference "Node.count" do
461 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
463 assert_response :bad_request
467 def test_upload_create_way_referring_node_placeholder_defined_later
468 changeset = create(:changeset)
473 <way id="-1" changeset="#{changeset.id}">
476 <node id="-1" lat="1" lon="2" changeset="#{changeset.id}"/>
481 auth_header = bearer_authorization_header changeset.user
483 assert_no_difference "Node.count" do
484 assert_no_difference "Way.count" do
485 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
487 assert_response :bad_request
490 assert_equal "Placeholder node not found for reference -1 in way -1", @response.body
493 def test_upload_create_way_referring_undefined_node_placeholder
494 changeset = create(:changeset)
499 <way id="-1" changeset="#{changeset.id}">
506 auth_header = bearer_authorization_header changeset.user
508 assert_no_difference "Way.count" do
509 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
511 assert_response :bad_request
513 assert_equal "Placeholder node not found for reference -1 in way -1", @response.body
516 def test_upload_create_existing_way_referring_undefined_node_placeholder
517 changeset = create(:changeset)
523 <way id="#{way.id}" changeset="#{changeset.id}" version="1">
530 auth_header = bearer_authorization_header changeset.user
532 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
534 assert_response :bad_request
535 assert_equal "Placeholder node not found for reference -1 in way #{way.id}", @response.body
538 assert_equal 1, way.version
541 def test_upload_create_relation_referring_undefined_node_placeholder
542 changeset = create(:changeset)
547 <relation id="-1" changeset="#{changeset.id}" version="1">
548 <member type="node" role="foo" ref="-1"/>
554 auth_header = bearer_authorization_header changeset.user
556 assert_no_difference "Relation.count" do
557 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
559 assert_response :bad_request
561 assert_equal "Placeholder Node not found for reference -1 in relation -1.", @response.body
564 def test_upload_create_existing_relation_referring_undefined_way_placeholder
565 changeset = create(:changeset)
566 relation = create(:relation)
571 <relation id="#{relation.id}" changeset="#{changeset.id}" version="1">
572 <member type="way" role="bar" ref="-1"/>
578 auth_header = bearer_authorization_header changeset.user
580 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
582 assert_response :bad_request
583 assert_equal "Placeholder Way not found for reference -1 in relation #{relation.id}.", @response.body
586 assert_equal 1, relation.version
589 def test_upload_create_relations_with_circular_references
590 changeset = create(:changeset)
593 <osmChange version='0.6'>
595 <relation id='-2' version='0' changeset='#{changeset.id}'>
596 <member type='relation' role='' ref='-4' />
597 <tag k='type' v='route' />
598 <tag k='name' v='AtoB' />
600 <relation id='-3' version='0' changeset='#{changeset.id}'>
601 <tag k='type' v='route' />
602 <tag k='name' v='BtoA' />
604 <relation id='-4' version='0' changeset='#{changeset.id}'>
605 <member type='relation' role='' ref='-2' />
606 <member type='relation' role='' ref='-3' />
607 <tag k='type' v='route_master' />
608 <tag k='name' v='master' />
614 auth_header = bearer_authorization_header changeset.user
616 post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
618 assert_response :bad_request
619 assert_equal "Placeholder Relation not found for reference -4 in relation -2.", @response.body
622 # -------------------------------------
623 # Test modifying elements.
624 # -------------------------------------
626 def test_upload_modify_elements
628 changeset = create(:changeset, :user => user)
629 node = create(:node, :latitude => 0, :longitude => 0)
631 relation = create(:relation)
632 other_relation = create(:relation)
634 # create some tags, since we test that they are removed later
635 create(:node_tag, :node => node)
636 create(:way_tag, :way => way)
637 create(:relation_tag, :relation => relation)
639 # simple diff to change a node, way and relation by removing their tags
643 <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
644 <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
645 <nd ref='#{node.id}'/>
649 <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'>
650 <member type='way' role='some' ref='#{way.id}'/>
651 <member type='node' role='some' ref='#{node.id}'/>
652 <member type='relation' role='some' ref='#{other_relation.id}'/>
658 auth_header = bearer_authorization_header user
660 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
662 assert_response :success
664 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
665 assert_dom "> node", 1 do
666 assert_dom "> @old_id", node.id.to_s
667 assert_dom "> @new_id", node.id.to_s
668 assert_dom "> @new_version", "2"
670 assert_dom "> way", 1 do
671 assert_dom "> @old_id", way.id.to_s
672 assert_dom "> @new_id", way.id.to_s
673 assert_dom "> @new_version", "2"
675 assert_dom "> relation", 1 do
676 assert_dom "> @old_id", relation.id.to_s
677 assert_dom "> @new_id", relation.id.to_s
678 assert_dom "> @new_version", "2"
683 assert_equal 3, changeset.num_changes
685 assert_equal 2, node.version
686 assert_equal 2 * GeoRecord::SCALE, node.latitude
687 assert_equal 1 * GeoRecord::SCALE, node.longitude
688 assert_equal 0, node.tags.size, "node #{node.id} should now have no tags"
690 assert_equal 2, way.version
691 assert_equal 0, way.tags.size, "way #{way.id} should now have no tags"
692 assert_equal [node], way.nodes
694 assert_equal 2, relation.version
695 assert_equal 0, relation.tags.size, "relation #{relation.id} should now have no tags"
696 assert_equal [["Way", way.id, "some"], ["Node", node.id, "some"], ["Relation", other_relation.id, "some"]], relation.members
700 # upload multiple versions of the same element in the same diff.
701 def test_upload_modify_multiple_node_versions
703 changeset = create(:changeset)
705 # change the location of a node multiple times, each time referencing
706 # the last version. doesn't this depend on version numbers being
711 <node id='#{node.id}' lon='0.0' lat='0.0' changeset='#{changeset.id}' version='1'/>
712 <node id='#{node.id}' lon='0.1' lat='0.0' changeset='#{changeset.id}' version='2'/>
713 <node id='#{node.id}' lon='0.1' lat='0.1' changeset='#{changeset.id}' version='3'/>
714 <node id='#{node.id}' lon='0.1' lat='0.2' changeset='#{changeset.id}' version='4'/>
715 <node id='#{node.id}' lon='0.2' lat='0.2' changeset='#{changeset.id}' version='5'/>
716 <node id='#{node.id}' lon='0.3' lat='0.2' changeset='#{changeset.id}' version='6'/>
717 <node id='#{node.id}' lon='0.3' lat='0.3' changeset='#{changeset.id}' version='7'/>
718 <node id='#{node.id}' lon='0.9' lat='0.9' changeset='#{changeset.id}' version='8'/>
723 auth_header = bearer_authorization_header changeset.user
725 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
727 assert_response :success
729 assert_dom "diffResult>node", 8
732 assert_equal 9, node.version
733 assert_equal 0.9 * GeoRecord::SCALE, node.latitude
734 assert_equal 0.9 * GeoRecord::SCALE, node.longitude
738 # upload multiple versions of the same element in the same diff, but
739 # keep the version numbers the same.
740 def test_upload_modify_duplicate_node_versions
741 node = create(:node, :latitude => 0, :longitude => 0)
742 changeset = create(:changeset)
747 <node id='#{node.id}' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
748 <node id='#{node.id}' lon='2' lat='2' changeset='#{changeset.id}' version='1'/>
753 auth_header = bearer_authorization_header changeset.user
755 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
757 assert_response :conflict
760 assert_equal 1, node.version
761 assert_equal 0, node.latitude
762 assert_equal 0, node.longitude
766 # try to upload some elements without specifying the version
767 def test_upload_modify_missing_node_version
768 node = create(:node, :latitude => 0, :longitude => 0)
769 changeset = create(:changeset)
774 <node id='#{node.id}' lon='1' lat='1' changeset='#{changeset.id}'/>
779 auth_header = bearer_authorization_header changeset.user
781 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
783 assert_response :bad_request
786 assert_equal 1, node.version
787 assert_equal 0, node.latitude
788 assert_equal 0, node.longitude
792 # create a diff which references several changesets, which should cause
793 # a rollback and none of the diff gets committed
794 def test_upload_modify_with_references_to_different_changesets
795 changeset1 = create(:changeset)
796 changeset2 = create(:changeset, :user => changeset1.user)
797 node1 = create(:node)
798 node2 = create(:node)
800 # simple diff to create a node way and relation using placeholders
804 <node id='#{node1.id}' lon='0' lat='0' changeset='#{changeset1.id}' version='1'/>
807 <node id='#{node2.id}' lon='0' lat='0' changeset='#{changeset2.id}' version='1'/>
812 auth_header = bearer_authorization_header changeset1.user
814 post api_changeset_upload_path(changeset1), :params => diff, :headers => auth_header
816 assert_response :conflict
818 assert_nodes_are_equal(node1, Node.find(node1.id))
819 assert_nodes_are_equal(node2, Node.find(node2.id))
823 # upload a valid changeset which has a mixture of whitespace
824 # to check a bug https://github.com/openstreetmap/trac-tickets/issues/1565
825 def test_upload_modify_with_mixed_whitespace
826 changeset = create(:changeset)
828 way = create(:way_with_nodes, :nodes_count => 2)
829 relation = create(:relation)
830 other_relation = create(:relation)
831 create(:relation_tag, :relation => relation)
835 <modify><node id='#{node.id}' lon='0' lat='0' changeset='#{changeset.id}'
837 <node id='#{node.id}' lon='1' lat='1' changeset='#{changeset.id}' version='2'><tag k='k' v='v'/></node></modify>
839 <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'><member
840 type='way' role='some' ref='#{way.id}'/><member
841 type='node' role='some' ref='#{node.id}'/>
842 <member type='relation' role='some' ref='#{other_relation.id}'/>
844 </modify></osmChange>
847 auth_header = bearer_authorization_header changeset.user
849 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
851 assert_response :success
853 assert_dom "diffResult>node", 2
854 assert_dom "diffResult>relation", 1
856 assert_equal 1, Node.find(node.id).tags.size, "node #{node.id} should now have one tag"
857 assert_equal 0, Relation.find(relation.id).tags.size, "relation #{relation.id} should now have no tags"
860 def test_upload_modify_unknown_node_placeholder
861 check_upload_results_in_not_found do |changeset|
862 "<modify><node id='-1' lon='0' lat='0' changeset='#{changeset.id}' version='1'/></modify>"
866 def test_upload_modify_unknown_way_placeholder
867 check_upload_results_in_not_found do |changeset|
868 "<modify><way id='-1' changeset='#{changeset.id}' version='1'/></modify>"
872 def test_upload_modify_unknown_relation_placeholder
873 check_upload_results_in_not_found do |changeset|
874 "<modify><relation id='-1' changeset='#{changeset.id}' version='1'/></modify>"
878 # -------------------------------------
879 # Test deleting elements.
880 # -------------------------------------
883 # test a complex delete where we delete elements which rely on each other
884 # in the same transaction.
885 def test_upload_delete_elements
886 changeset = create(:changeset)
887 super_relation = create(:relation)
888 used_relation = create(:relation)
889 used_way = create(:way)
890 used_node = create(:node)
891 create(:relation_member, :relation => super_relation, :member => used_relation)
892 create(:relation_member, :relation => super_relation, :member => used_way)
893 create(:relation_member, :relation => super_relation, :member => used_node)
895 diff = XML::Document.new
896 diff.root = XML::Node.new "osmChange"
897 delete = XML::Node.new "delete"
899 delete << xml_node_for_relation(super_relation)
900 delete << xml_node_for_relation(used_relation)
901 delete << xml_node_for_way(used_way)
902 delete << xml_node_for_node(used_node)
903 %w[node way relation].each do |type|
904 delete.find("//osmChange/delete/#{type}").each do |n|
905 n["changeset"] = changeset.id.to_s
909 auth_header = bearer_authorization_header changeset.user
911 post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
913 assert_response :success
915 assert_dom "diffResult", 1 do
916 assert_dom "> node", 1
917 assert_dom "> way", 1
918 assert_dom "> relation", 2
921 assert_not Node.find(used_node.id).visible
922 assert_not Way.find(used_way.id).visible
923 assert_not Relation.find(super_relation.id).visible
924 assert_not Relation.find(used_relation.id).visible
928 # test uploading a delete with no lat/lon, as they are optional in the osmChange spec.
929 def test_upload_delete_node_without_latlon
931 changeset = create(:changeset)
933 diff = "<osmChange><delete><node id='#{node.id}' version='#{node.version}' changeset='#{changeset.id}'/></delete></osmChange>"
935 auth_header = bearer_authorization_header changeset.user
937 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
939 assert_response :success
941 assert_dom "diffResult", 1 do
942 assert_dom "> node", 1 do
943 assert_dom "> @old_id", node.id.to_s
944 assert_dom "> @new_id", 0
945 assert_dom "> @new_version", 0
950 assert_not node.visible
954 # test that deleting stuff in a transaction doesn't bypass the checks
955 # to ensure that used elements are not deleted.
956 def test_upload_delete_referenced_elements
957 changeset = create(:changeset)
958 relation = create(:relation)
959 other_relation = create(:relation)
960 used_way = create(:way)
961 used_node = create(:node)
962 create(:relation_member, :relation => relation, :member => used_way)
963 create(:relation_member, :relation => relation, :member => used_node)
965 diff = XML::Document.new
966 diff.root = XML::Node.new "osmChange"
967 delete = XML::Node.new "delete"
969 delete << xml_node_for_relation(other_relation)
970 delete << xml_node_for_way(used_way)
971 delete << xml_node_for_node(used_node)
972 %w[node way relation].each do |type|
973 delete.find("//osmChange/delete/#{type}").each do |n|
974 n["changeset"] = changeset.id.to_s
978 auth_header = bearer_authorization_header changeset.user
980 post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
982 assert_response :precondition_failed
983 assert_equal "Precondition failed: Way #{used_way.id} is still used by relations #{relation.id}.", @response.body
985 assert Node.find(used_node.id).visible
986 assert Way.find(used_way.id).visible
987 assert Relation.find(relation.id).visible
988 assert Relation.find(other_relation.id).visible
992 # test that a conditional delete of an in use object works.
993 def test_upload_delete_if_unused
994 changeset = create(:changeset)
995 super_relation = create(:relation)
996 used_relation = create(:relation)
997 used_way = create(:way)
998 used_node = create(:node)
999 create(:relation_member, :relation => super_relation, :member => used_relation)
1000 create(:relation_member, :relation => super_relation, :member => used_way)
1001 create(:relation_member, :relation => super_relation, :member => used_node)
1003 diff = XML::Document.new
1004 diff.root = XML::Node.new "osmChange"
1005 delete = XML::Node.new "delete"
1007 delete["if-unused"] = ""
1008 delete << xml_node_for_relation(used_relation)
1009 delete << xml_node_for_way(used_way)
1010 delete << xml_node_for_node(used_node)
1011 %w[node way relation].each do |type|
1012 delete.find("//osmChange/delete/#{type}").each do |n|
1013 n["changeset"] = changeset.id.to_s
1017 auth_header = bearer_authorization_header changeset.user
1019 post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1021 assert_response :success
1023 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
1024 assert_dom "> node", 1 do
1025 assert_dom "> @old_id", used_node.id.to_s
1026 assert_dom "> @new_id", used_node.id.to_s
1027 assert_dom "> @new_version", used_node.version.to_s
1029 assert_dom "> way", 1 do
1030 assert_dom "> @old_id", used_way.id.to_s
1031 assert_dom "> @new_id", used_way.id.to_s
1032 assert_dom "> @new_version", used_way.version.to_s
1034 assert_dom "> relation", 1 do
1035 assert_dom "> @old_id", used_relation.id.to_s
1036 assert_dom "> @new_id", used_relation.id.to_s
1037 assert_dom "> @new_version", used_relation.version.to_s
1041 assert Node.find(used_node.id).visible
1042 assert Way.find(used_way.id).visible
1043 assert Relation.find(used_relation.id).visible
1046 def test_upload_delete_with_multiple_blocks_and_if_unused
1047 changeset = create(:changeset)
1048 node = create(:node)
1050 create(:way_node, :way => way, :node => node)
1051 alone_node = create(:node)
1054 <osmChange version='0.6'>
1055 <delete version="0.6">
1056 <node id="#{node.id}" version="#{node.version}" changeset="#{changeset.id}"/>
1058 <delete version="0.6" if-unused="true">
1059 <node id="#{alone_node.id}" version="#{alone_node.version}" changeset="#{changeset.id}"/>
1064 auth_header = bearer_authorization_header changeset.user
1066 post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1068 assert_response :precondition_failed
1070 assert_equal "Precondition failed: Node #{node.id} is still used by ways #{way.id}.", @response.body
1073 def test_upload_delete_unknown_node_placeholder
1074 check_upload_results_in_not_found do |changeset|
1075 "<delete><node id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1079 def test_upload_delete_unknown_way_placeholder
1080 check_upload_results_in_not_found do |changeset|
1081 "<delete><way id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1085 def test_upload_delete_unknown_relation_placeholder
1086 check_upload_results_in_not_found do |changeset|
1087 "<delete><relation id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1091 # -------------------------------------
1092 # Test combined element changes.
1093 # -------------------------------------
1096 # upload something which creates new objects and inserts them into
1097 # existing containers using placeholders.
1098 def test_upload_create_and_insert_elements
1100 node = create(:node)
1101 relation = create(:relation)
1102 create(:way_node, :way => way, :node => node)
1103 changeset = create(:changeset)
1108 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1109 <tag k='foo' v='bar'/>
1110 <tag k='baz' v='bat'/>
1114 <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
1116 <nd ref='#{node.id}'/>
1118 <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'>
1119 <member type='way' role='some' ref='#{way.id}'/>
1120 <member type='node' role='some' ref='-1'/>
1121 <member type='relation' role='some' ref='#{relation.id}'/>
1127 auth_header = bearer_authorization_header changeset.user
1129 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1131 assert_response :success
1134 assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
1135 assert_dom "> node", 1 do |(node_el)|
1136 new_node_id = node_el["new_id"].to_i
1138 assert_dom "> way", 1
1139 assert_dom "> relation", 1
1142 assert_equal 2, Node.find(new_node_id).tags.size, "new node should have two tags"
1143 assert_equal [new_node_id, node.id], Way.find(way.id).nds, "way nodes should match"
1144 Relation.find(relation.id).members.each do |type, id, _role|
1145 assert_equal new_node_id, id, "relation should contain new node" if type == "node"
1150 # test that a placeholder can be reused within the same upload.
1151 def test_upload_create_modify_delete_node_reusing_placeholder
1152 changeset = create(:changeset)
1157 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1158 <tag k="foo" v="bar"/>
1162 <node id='-1' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
1165 <node id='-1' lon='2' lat='2' changeset='#{changeset.id}' version='2'/>
1170 auth_header = bearer_authorization_header changeset.user
1172 assert_difference "Node.count", 1 do
1173 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1175 assert_response :success
1178 assert_dom "diffResult>node", 3
1179 assert_dom "diffResult>node[old_id='-1']", 3
1182 assert_equal 3, node.version
1183 assert_not node.visible
1186 def test_upload_create_and_duplicate_delete
1187 changeset = create(:changeset)
1192 <node id="-1" lat="39" lon="116" changeset="#{changeset.id}" />
1195 <node id="-1" version="1" changeset="#{changeset.id}" />
1196 <node id="-1" version="1" changeset="#{changeset.id}" />
1201 auth_header = bearer_authorization_header changeset.user
1203 assert_no_difference "Node.count" do
1204 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1206 assert_response :gone
1210 def test_upload_create_and_duplicate_delete_if_unused
1211 changeset = create(:changeset)
1216 <node id="-1" lat="39" lon="116" changeset="#{changeset.id}" />
1218 <delete if-unused="true">
1219 <node id="-1" version="1" changeset="#{changeset.id}" />
1220 <node id="-1" version="1" changeset="#{changeset.id}" />
1225 auth_header = bearer_authorization_header changeset.user
1227 assert_difference "Node.count", 1 do
1228 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1230 assert_response :success
1233 assert_dom "diffResult>node", 3
1234 assert_dom "diffResult>node[old_id='-1']", 3
1235 assert_dom "diffResult>node[new_version='1']", 1
1236 assert_dom "diffResult>node[new_version='2']", 1
1239 assert_equal 2, node.version
1240 assert_not node.visible
1243 # -------------------------------------
1244 # Test bounding boxes.
1245 # -------------------------------------
1247 def test_upload_bbox_of_widely_spaced_nodes
1248 user = create(:user)
1250 # create an old changeset to ensure we have the maximum rate limit
1251 create(:changeset, :user => user, :created_at => Time.now.utc - 28.days)
1253 changeset = create(:changeset, :user => user)
1255 # upload some widely-spaced nodes, spiralling positive and negative
1259 <node id='-1' lon='-20' lat='-10' changeset='#{changeset.id}'/>
1260 <node id='-10' lon='20' lat='10' changeset='#{changeset.id}'/>
1261 <node id='-2' lon='-40' lat='-20' changeset='#{changeset.id}'/>
1262 <node id='-11' lon='40' lat='20' changeset='#{changeset.id}'/>
1263 <node id='-3' lon='-60' lat='-30' changeset='#{changeset.id}'/>
1264 <node id='-12' lon='60' lat='30' changeset='#{changeset.id}'/>
1265 <node id='-4' lon='-80' lat='-40' changeset='#{changeset.id}'/>
1266 <node id='-13' lon='80' lat='40' changeset='#{changeset.id}'/>
1267 <node id='-5' lon='-100' lat='-50' changeset='#{changeset.id}'/>
1268 <node id='-14' lon='100' lat='50' changeset='#{changeset.id}'/>
1269 <node id='-6' lon='-120' lat='-60' changeset='#{changeset.id}'/>
1270 <node id='-15' lon='120' lat='60' changeset='#{changeset.id}'/>
1271 <node id='-7' lon='-140' lat='-70' changeset='#{changeset.id}'/>
1272 <node id='-16' lon='140' lat='70' changeset='#{changeset.id}'/>
1273 <node id='-8' lon='-160' lat='-80' changeset='#{changeset.id}'/>
1274 <node id='-17' lon='160' lat='80' changeset='#{changeset.id}'/>
1275 <node id='-9' lon='-179.9' lat='-89.9' changeset='#{changeset.id}'/>
1276 <node id='-18' lon='179.9' lat='89.9' changeset='#{changeset.id}'/>
1281 auth_header = bearer_authorization_header user
1283 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1285 assert_response :success
1287 # check that the changeset bbox is within bounds
1289 assert_operator changeset.min_lon, :>=, -180 * GeoRecord::SCALE, "Minimum longitude (#{changeset.min_lon / GeoRecord::SCALE}) should be >= -180 to be valid."
1290 assert_operator changeset.max_lon, :<=, 180 * GeoRecord::SCALE, "Maximum longitude (#{changeset.max_lon / GeoRecord::SCALE}) should be <= 180 to be valid."
1291 assert_operator changeset.min_lat, :>=, -90 * GeoRecord::SCALE, "Minimum latitude (#{changeset.min_lat / GeoRecord::SCALE}) should be >= -90 to be valid."
1292 assert_operator changeset.max_lat, :<=, 90 * GeoRecord::SCALE, "Maximum latitude (#{changeset.max_lat / GeoRecord::SCALE}) should be <= 90 to be valid."
1295 def test_upload_bbox_of_moved_node
1296 changeset = create(:changeset)
1297 node = create(:node, :lat => 1.0, :lon => 2.0)
1302 <node id='#{node.id}' lat='1.1' lon='2.1' changeset='#{changeset.id}' version='1'/>
1307 auth_header = bearer_authorization_header changeset.user
1309 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1311 assert_response :success
1315 assert_equal 1.0 * GeoRecord::SCALE, changeset.min_lat, "min_lat should be 1.0 degrees"
1316 assert_equal 2.0 * GeoRecord::SCALE, changeset.min_lon, "min_lon should be 2.0 degrees"
1317 assert_equal 1.1 * GeoRecord::SCALE, changeset.max_lat, "max_lat should be 1.1 degrees"
1318 assert_equal 2.1 * GeoRecord::SCALE, changeset.max_lon, "max_lon should be 2.1 degrees"
1321 def test_upload_bbox_of_extended_way
1323 initial_node = create(:node, :lat => 1.1, :lon => 2.1)
1324 create(:way_node, :way => way, :node => initial_node)
1325 added_node = create(:node, :lat => 1.3, :lon => 2.3)
1326 changeset = create(:changeset)
1331 <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
1332 <nd ref='#{initial_node.id}'/>
1333 <nd ref='#{added_node.id}'/>
1339 auth_header = bearer_authorization_header changeset.user
1341 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1343 assert_response :success
1347 assert_equal 1.1 * GeoRecord::SCALE, changeset.min_lat, "min_lat should be 1.1 degrees"
1348 assert_equal 2.1 * GeoRecord::SCALE, changeset.min_lon, "min_lon should be 2.1 degrees"
1349 assert_equal 1.3 * GeoRecord::SCALE, changeset.max_lat, "max_lat should be 1.3 degrees"
1350 assert_equal 2.3 * GeoRecord::SCALE, changeset.max_lon, "max_lon should be 2.3 degrees"
1353 # -------------------------------------
1354 # Test upload rate/size limits.
1355 # -------------------------------------
1357 def test_upload_initial_rate_limit
1358 user = create(:user)
1359 node = create(:node)
1360 way = create(:way_with_nodes, :nodes_count => 2)
1361 relation = create(:relation)
1363 # create a changeset that puts us near the initial rate limit
1364 changeset = create(:changeset, :user => user,
1365 :created_at => Time.now.utc - 5.minutes,
1366 :num_changes => Settings.initial_changes_per_hour - 2)
1371 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1372 <tag k='foo' v='bar'/>
1373 <tag k='baz' v='bat'/>
1375 <way id='-1' changeset='#{changeset.id}'>
1376 <nd ref='#{node.id}'/>
1380 <relation id='-1' changeset='#{changeset.id}'>
1381 <member type='way' role='some' ref='#{way.id}'/>
1382 <member type='node' role='some' ref='#{node.id}'/>
1383 <member type='relation' role='some' ref='#{relation.id}'/>
1389 auth_header = bearer_authorization_header user
1391 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1393 assert_response :too_many_requests, "upload did not hit rate limit"
1396 def test_upload_maximum_rate_limit
1397 user = create(:user)
1398 node = create(:node)
1399 way = create(:way_with_nodes, :nodes_count => 2)
1400 relation = create(:relation)
1402 # create a changeset to establish our initial edit time
1403 changeset = create(:changeset, :user => user,
1404 :created_at => Time.now.utc - 28.days)
1406 # create changeset to put us near the maximum rate limit
1407 total_changes = Settings.max_changes_per_hour - 2
1408 while total_changes.positive?
1409 changes = [total_changes, Changeset::MAX_ELEMENTS].min
1410 changeset = create(:changeset, :user => user,
1411 :created_at => Time.now.utc - 5.minutes,
1412 :num_changes => changes)
1413 total_changes -= changes
1419 <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1420 <tag k='foo' v='bar'/>
1421 <tag k='baz' v='bat'/>
1423 <way id='-1' changeset='#{changeset.id}'>
1424 <nd ref='#{node.id}'/>
1428 <relation id='-1' changeset='#{changeset.id}'>
1429 <member type='way' role='some' ref='#{way.id}'/>
1430 <member type='node' role='some' ref='#{node.id}'/>
1431 <member type='relation' role='some' ref='#{relation.id}'/>
1437 auth_header = bearer_authorization_header user
1439 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1441 assert_response :too_many_requests, "upload did not hit rate limit"
1444 def test_upload_initial_size_limit
1445 user = create(:user)
1447 # create a changeset that puts us near the initial size limit
1448 changeset = create(:changeset, :user => user,
1449 :min_lat => (-0.5 * GeoRecord::SCALE).round, :min_lon => (0.5 * GeoRecord::SCALE).round,
1450 :max_lat => (0.5 * GeoRecord::SCALE).round, :max_lon => (2.5 * GeoRecord::SCALE).round)
1455 <node id='-1' lon='0.9' lat='2.9' changeset='#{changeset.id}'>
1456 <tag k='foo' v='bar'/>
1457 <tag k='baz' v='bat'/>
1463 auth_header = bearer_authorization_header user
1465 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1467 assert_response :payload_too_large, "upload did not hit size limit"
1470 def test_upload_size_limit_after_one_week
1471 user = create(:user)
1473 # create a changeset to establish our initial edit time
1474 create(:changeset, :user => user, :created_at => Time.now.utc - 7.days)
1476 # create a changeset that puts us near the initial size limit
1477 changeset = create(:changeset, :user => user, :bbox => [0.5, -0.5, 2.5, 0.5])
1482 <node id='-1' lon='35' lat='35' changeset='#{changeset.id}'>
1483 <tag k='foo' v='bar'/>
1484 <tag k='baz' v='bat'/>
1490 auth_header = bearer_authorization_header user
1492 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1494 assert_response :payload_too_large, "upload did not hit size limit"
1499 def check_upload_results_in_not_found(&)
1500 changeset = create(:changeset)
1501 diff = "<osmChange>#{yield changeset}</osmChange>"
1502 auth_header = bearer_authorization_header changeset.user
1504 post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1506 assert_response :not_found
1508 assert_equal 0, changeset.num_changes