test/controllers/api/changesets/uploads_controller_test.rb

   1 require "test_helper"
   2
   3 module Api
   4   module Changesets
   5     class UploadsControllerTest < ActionDispatch::IntegrationTest
   6       ##
   7       # test all routes which lead to this controller
   8       def test_routes
   9         assert_routing(
  10           { :path => "/api/0.6/changeset/1/upload", :method => :post },
  11           { :controller => "api/changesets/uploads", :action => "create", :changeset_id => "1" }
  12         )
  13       end
  14
  15       def test_upload_when_unauthorized
  16         changeset = create(:changeset)
  17         node = create(:node, :latitude => 0, :longitude => 0)
  18
  19         diff = <<~CHANGESET
  20           <osmChange>
  21             <modify>
  22               <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
  23             </modify>
  24           </osmChange>
  25         CHANGESET
  26
  27         post api_changeset_upload_path(changeset), :params => diff
  28
  29         assert_response :unauthorized
  30
  31         assert_no_changes_in changeset
  32
  33         node.reload
  34         assert_equal 1, node.version
  35         assert_equal 0, node.latitude
  36         assert_equal 0, node.longitude
  37       end
  38
  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)
  43
  44         diff = <<~CHANGESET
  45           <osmChange>
  46             <modify>
  47               <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
  48             </modify>
  49           </osmChange>
  50         CHANGESET
  51
  52         auth_header = bearer_authorization_header user
  53
  54         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
  55
  56         assert_response :forbidden
  57
  58         assert_no_changes_in changeset
  59
  60         node.reload
  61         assert_equal 1, node.version
  62         assert_equal 0, node.latitude
  63         assert_equal 0, node.longitude
  64       end
  65
  66       def test_upload_without_required_scope
  67         user = create(:user)
  68         changeset = create(:changeset, :user => user)
  69         node = create(:node, :latitude => 0, :longitude => 0)
  70
  71         diff = <<~CHANGESET
  72           <osmChange>
  73             <modify>
  74               <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
  75             </modify>
  76           </osmChange>
  77         CHANGESET
  78
  79         auth_header = bearer_authorization_header user, :scopes => %w[read_prefs]
  80
  81         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
  82
  83         assert_response :forbidden
  84
  85         assert_no_changes_in changeset
  86
  87         node.reload
  88         assert_equal 1, node.version
  89         assert_equal 0, node.latitude
  90         assert_equal 0, node.longitude
  91       end
  92
  93       def test_upload_with_required_scope
  94         user = create(:user)
  95         changeset = create(:changeset, :user => user)
  96         node = create(:node, :latitude => 0, :longitude => 0)
  97
  98         diff = <<~CHANGESET
  99           <osmChange>
 100             <modify>
 101               <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
 102             </modify>
 103           </osmChange>
 104         CHANGESET
 105
 106         auth_header = bearer_authorization_header user, :scopes => %w[write_api]
 107
 108         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 109
 110         assert_response :success
 111
 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"
 117           end
 118         end
 119
 120         changeset.reload
 121         assert_equal 1, changeset.num_changes
 122         assert_predicate changeset, :num_type_changes_in_sync?
 123         assert_equal 1, changeset.num_modified_nodes
 124
 125         node.reload
 126         assert_equal 2, node.version
 127         assert_equal 2 * GeoRecord::SCALE, node.latitude
 128         assert_equal 1 * GeoRecord::SCALE, node.longitude
 129       end
 130
 131       ##
 132       # try to upload with commands other than create, modify, or delete
 133       def test_upload_unknown_action
 134         changeset = create(:changeset)
 135
 136         diff = <<~CHANGESET
 137           <osmChange>
 138             <ping>
 139               <node id='1' lon='1' lat='1' changeset='#{changeset.id}' />
 140             </ping>
 141           </osmChange>
 142         CHANGESET
 143
 144         auth_header = bearer_authorization_header changeset.user
 145
 146         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 147
 148         assert_response :bad_request
 149         assert_equal "Unknown action ping, choices are create, modify, delete", @response.body
 150
 151         assert_no_changes_in changeset
 152       end
 153
 154       ##
 155       # test for issues in https://github.com/openstreetmap/trac-tickets/issues/1568
 156       def test_upload_empty_changeset
 157         changeset = create(:changeset)
 158
 159         auth_header = bearer_authorization_header changeset.user
 160
 161         ["<osmChange/>",
 162          "<osmChange></osmChange>",
 163          "<osmChange><modify/></osmChange>",
 164          "<osmChange><modify></modify></osmChange>"].each do |diff|
 165           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 166
 167           assert_response :success
 168         end
 169
 170         assert_no_changes_in changeset
 171       end
 172
 173       ##
 174       # test that the X-Error-Format header works to request XML errors
 175       def test_upload_xml_errors
 176         changeset = create(:changeset)
 177         node = create(:node)
 178         create(:relation_member, :member => node)
 179
 180         # try and delete a node that is in use
 181         diff = XML::Document.new
 182         diff.root = XML::Node.new "osmChange"
 183         delete = XML::Node.new "delete"
 184         diff.root << delete
 185         delete << xml_node_for_node(node)
 186
 187         auth_header = bearer_authorization_header changeset.user
 188         error_header = error_format_header "xml"
 189
 190         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header.merge(error_header)
 191
 192         assert_response :success
 193
 194         assert_dom "osmError[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1
 195         assert_dom "osmError>status", 1
 196         assert_dom "osmError>message", 1
 197       end
 198
 199       # -------------------------------------
 200       # Test creating elements.
 201       # -------------------------------------
 202
 203       def test_upload_create_node
 204         user = create(:user)
 205         changeset = create(:changeset, :user => user)
 206
 207         diff = <<~CHANGESET
 208           <osmChange>
 209             <create>
 210               <node id='-1' lon='30' lat='60' changeset='#{changeset.id}'>
 211                 <tag k='amenity' v='bar'/>
 212                 <tag k='name' v='Foo'/>
 213               </node>
 214             </create>
 215           </osmChange>
 216         CHANGESET
 217
 218         auth_header = bearer_authorization_header user
 219
 220         assert_difference "Node.count" => 1,
 221                           "OldNode.count" => 1,
 222                           "NodeTag.count" => 2,
 223                           "OldNodeTag.count" => 2 do
 224           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 225
 226           assert_response :success
 227         end
 228
 229         node = nil
 230         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 231           assert_dom "> node", 1 do |(node_el)|
 232             node = Node.find(node_el["new_id"].to_i)
 233             assert_dom "> @old_id", "-1"
 234             assert_dom "> @new_version", "1"
 235           end
 236         end
 237
 238         changeset.reload
 239         assert_equal 1, changeset.num_changes
 240         assert_predicate changeset, :num_type_changes_in_sync?
 241         assert_equal 1, changeset.num_created_nodes
 242
 243         assert_equal 1, node.version
 244         assert_equal changeset, node.changeset
 245         assert_predicate node, :visible?
 246         assert_equal({ "name" => "Foo", "amenity" => "bar" }, node.tags)
 247         assert_equal 60, node.lat
 248         assert_equal 30, node.lon
 249       end
 250
 251       def test_upload_create_way
 252         node1 = create(:node)
 253         node2 = create(:node)
 254         user = create(:user)
 255         changeset = create(:changeset, :user => user)
 256
 257         diff = <<~CHANGESET
 258           <osmChange>
 259             <create>
 260               <way id='-1' changeset='#{changeset.id}'>
 261                 <tag k='highway' v='primary'/>
 262                 <tag k='name' v='Foo'/>
 263                 <nd ref='#{node1.id}'/>
 264                 <nd ref='#{node2.id}'/>
 265               </way>
 266             </create>
 267           </osmChange>
 268         CHANGESET
 269
 270         auth_header = bearer_authorization_header user
 271
 272         assert_difference "Way.count" => 1,
 273                           "OldWay.count" => 1,
 274                           "WayTag.count" => 2,
 275                           "OldWayTag.count" => 2,
 276                           "WayNode.count" => 2,
 277                           "OldWayNode.count" => 2 do
 278           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 279
 280           assert_response :success
 281         end
 282
 283         way = nil
 284         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 285           assert_dom "> way", 1 do |(way_el)|
 286             way = Way.find(way_el["new_id"].to_i)
 287             assert_dom "> @old_id", "-1"
 288             assert_dom "> @new_version", "1"
 289           end
 290         end
 291
 292         changeset.reload
 293         assert_equal 1, changeset.num_changes
 294         assert_predicate changeset, :num_type_changes_in_sync?
 295         assert_equal 1, changeset.num_created_ways
 296
 297         assert_equal 1, way.version
 298         assert_equal changeset, way.changeset
 299         assert_predicate way, :visible?
 300         assert_equal({ "name" => "Foo", "highway" => "primary" }, way.tags)
 301         assert_equal [node1, node2], way.nodes
 302       end
 303
 304       def test_upload_create_relation
 305         node1 = create(:node)
 306         way1 = create(:way_with_nodes)
 307         relation1 = create(:relation)
 308         user = create(:user)
 309         changeset = create(:changeset, :user => user)
 310
 311         diff = <<~CHANGESET
 312           <osmChange>
 313             <create>
 314               <relation id='-1' changeset='#{changeset.id}'>
 315                 <member type='node' role='n_role' ref='#{node1.id}'/>
 316                 <member type='way' role='w_role' ref='#{way1.id}'/>
 317                 <member type='relation' role='r_role' ref='#{relation1.id}'/>
 318                 <tag k='type' v='collection'/>
 319               </relation>
 320             </create>
 321           </osmChange>
 322         CHANGESET
 323
 324         auth_header = bearer_authorization_header user
 325
 326         assert_difference "Relation.count" => 1,
 327                           "OldRelation.count" => 1,
 328                           "RelationTag.count" => 1,
 329                           "OldRelationTag.count" => 1,
 330                           "RelationMember.count" => 3,
 331                           "OldRelationMember.count" => 3 do
 332           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 333
 334           assert_response :success
 335         end
 336
 337         relation = nil
 338         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 339           assert_dom "> relation", 1 do |(relation_el)|
 340             relation = Relation.find(relation_el["new_id"].to_i)
 341             assert_dom "> @old_id", "-1"
 342             assert_dom "> @new_version", "1"
 343           end
 344         end
 345
 346         changeset.reload
 347         assert_equal 1, changeset.num_changes
 348         assert_predicate changeset, :num_type_changes_in_sync?
 349         assert_equal 1, changeset.num_created_relations
 350
 351         assert_equal 1, relation.version
 352         assert_equal changeset, relation.changeset
 353         assert_predicate relation, :visible?
 354         assert_equal({ "type" => "collection" }, relation.tags)
 355         assert_equal [["Node", node1.id, "n_role"],
 356                       ["Way", way1.id, "w_role"],
 357                       ["Relation", relation1.id, "r_role"]], relation.members
 358       end
 359
 360       def test_upload_create_elements
 361         user = create(:user)
 362         changeset = create(:changeset, :user => user)
 363         node = create(:node)
 364         way = create(:way_with_nodes, :nodes_count => 2)
 365         relation = create(:relation)
 366
 367         diff = <<~CHANGESET
 368           <osmChange>
 369             <create>
 370               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
 371                 <tag k='foo' v='bar'/>
 372                 <tag k='baz' v='bat'/>
 373               </node>
 374               <way id='-1' changeset='#{changeset.id}'>
 375                 <nd ref='#{node.id}'/>
 376               </way>
 377             </create>
 378             <create>
 379               <relation id='-1' changeset='#{changeset.id}'>
 380                 <member type='way' role='some' ref='#{way.id}'/>
 381                 <member type='node' role='some' ref='#{node.id}'/>
 382                 <member type='relation' role='some' ref='#{relation.id}'/>
 383               </relation>
 384             </create>
 385           </osmChange>
 386         CHANGESET
 387
 388         auth_header = bearer_authorization_header user
 389
 390         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 391
 392         assert_response :success
 393
 394         new_node_id, new_way_id, new_rel_id = nil
 395         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 396           # inspect the response to find out what the new element IDs are
 397           # check the old IDs are all present and negative one
 398           # check the versions are present and equal one
 399           assert_dom "> node", 1 do |(node_el)|
 400             new_node_id = node_el["new_id"].to_i
 401             assert_dom "> @old_id", "-1"
 402             assert_dom "> @new_version", "1"
 403           end
 404           assert_dom "> way", 1 do |(way_el)|
 405             new_way_id = way_el["new_id"].to_i
 406             assert_dom "> @old_id", "-1"
 407             assert_dom "> @new_version", "1"
 408           end
 409           assert_dom "> relation", 1 do |(rel_el)|
 410             new_rel_id = rel_el["new_id"].to_i
 411             assert_dom "> @old_id", "-1"
 412             assert_dom "> @new_version", "1"
 413           end
 414         end
 415
 416         changeset.reload
 417         assert_equal 3, changeset.num_changes
 418         assert_predicate changeset, :num_type_changes_in_sync?
 419         assert_equal 1, changeset.num_created_nodes
 420         assert_equal 1, changeset.num_created_ways
 421         assert_equal 1, changeset.num_created_relations
 422
 423         assert_equal 2, Node.find(new_node_id).tags.size, "new node should have two tags"
 424         assert_equal 0, Way.find(new_way_id).tags.size, "new way should have no tags"
 425         assert_equal 0, Relation.find(new_rel_id).tags.size, "new relation should have no tags"
 426       end
 427
 428       ##
 429       # upload an element with a really long tag value
 430       def test_upload_create_node_with_tag_too_long
 431         changeset = create(:changeset)
 432
 433         diff = <<~CHANGESET
 434           <osmChange>
 435             <create>
 436               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
 437                 <tag k='foo' v='#{'x' * 256}'/>
 438               </node>
 439             </create>
 440           </osmChange>
 441         CHANGESET
 442
 443         auth_header = bearer_authorization_header changeset.user
 444
 445         assert_no_difference "Node.count" do
 446           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 447
 448           assert_response :bad_request
 449         end
 450
 451         assert_no_changes_in changeset
 452       end
 453
 454       def test_upload_create_nodes_with_invalid_placeholder_reuse_in_one_action_block
 455         changeset = create(:changeset)
 456
 457         diff = <<~CHANGESET
 458           <osmChange>
 459             <create>
 460               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}' version='1'/>
 461               <node id='-1' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
 462             </create>
 463           </osmChange>
 464         CHANGESET
 465
 466         auth_header = bearer_authorization_header changeset.user
 467
 468         assert_no_difference "Node.count" do
 469           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 470
 471           assert_response :bad_request
 472         end
 473
 474         assert_no_changes_in changeset
 475       end
 476
 477       def test_upload_create_nodes_with_invalid_placeholder_reuse_in_two_action_blocks
 478         changeset = create(:changeset)
 479
 480         diff = <<~CHANGESET
 481           <osmChange>
 482             <create>
 483               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}' version='1'/>
 484             </create>
 485             <create>
 486               <node id='-1' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
 487             </create>
 488           </osmChange>
 489         CHANGESET
 490
 491         auth_header = bearer_authorization_header changeset.user
 492
 493         assert_no_difference "Node.count" do
 494           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 495
 496           assert_response :bad_request
 497         end
 498
 499         assert_no_changes_in changeset
 500       end
 501
 502       def test_upload_create_way_referring_node_placeholder_defined_later
 503         changeset = create(:changeset)
 504
 505         diff = <<~CHANGESET
 506           <osmChange>
 507             <create>
 508               <way id="-1" changeset="#{changeset.id}">
 509                 <nd ref="-1"/>
 510               </way>
 511               <node id="-1" lat="1" lon="2" changeset="#{changeset.id}"/>
 512             </create>
 513           </osmChange>
 514         CHANGESET
 515
 516         auth_header = bearer_authorization_header changeset.user
 517
 518         assert_no_difference "Node.count" do
 519           assert_no_difference "Way.count" do
 520             post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 521
 522             assert_response :bad_request
 523           end
 524         end
 525         assert_equal "Placeholder node not found for reference -1 in way -1", @response.body
 526
 527         assert_no_changes_in changeset
 528       end
 529
 530       def test_upload_create_way_referring_undefined_node_placeholder
 531         changeset = create(:changeset)
 532
 533         diff = <<~CHANGESET
 534           <osmChange>
 535             <create>
 536               <way id="-1" changeset="#{changeset.id}">
 537                 <nd ref="-1"/>
 538               </way>
 539             </create>
 540           </osmChange>
 541         CHANGESET
 542
 543         auth_header = bearer_authorization_header changeset.user
 544
 545         assert_no_difference "Way.count" do
 546           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 547
 548           assert_response :bad_request
 549         end
 550         assert_equal "Placeholder node not found for reference -1 in way -1", @response.body
 551
 552         assert_no_changes_in changeset
 553       end
 554
 555       def test_upload_create_existing_way_referring_undefined_node_placeholder
 556         changeset = create(:changeset)
 557         way = create(:way)
 558
 559         diff = <<~CHANGESET
 560           <osmChange>
 561             <create>
 562               <way id="#{way.id}" changeset="#{changeset.id}" version="1">
 563                 <nd ref="-1"/>
 564               </way>
 565             </create>
 566           </osmChange>
 567         CHANGESET
 568
 569         auth_header = bearer_authorization_header changeset.user
 570
 571         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 572
 573         assert_response :bad_request
 574         assert_equal "Placeholder node not found for reference -1 in way #{way.id}", @response.body
 575
 576         assert_no_changes_in changeset
 577
 578         way.reload
 579         assert_equal 1, way.version
 580       end
 581
 582       def test_upload_create_relation_referring_undefined_node_placeholder
 583         changeset = create(:changeset)
 584
 585         diff = <<~CHANGESET
 586           <osmChange>
 587             <create>
 588               <relation id="-1" changeset="#{changeset.id}" version="1">
 589                 <member type="node" role="foo" ref="-1"/>
 590               </relation>
 591             </create>
 592           </osmChange>
 593         CHANGESET
 594
 595         auth_header = bearer_authorization_header changeset.user
 596
 597         assert_no_difference "Relation.count" do
 598           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 599
 600           assert_response :bad_request
 601         end
 602         assert_equal "Placeholder Node not found for reference -1 in relation -1.", @response.body
 603
 604         assert_no_changes_in changeset
 605       end
 606
 607       def test_upload_create_existing_relation_referring_undefined_way_placeholder
 608         changeset = create(:changeset)
 609         relation = create(:relation)
 610
 611         diff = <<~CHANGESET
 612           <osmChange>
 613             <create>
 614               <relation id="#{relation.id}" changeset="#{changeset.id}" version="1">
 615                 <member type="way" role="bar" ref="-1"/>
 616               </relation>
 617             </create>
 618           </osmChange>
 619         CHANGESET
 620
 621         auth_header = bearer_authorization_header changeset.user
 622
 623         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 624
 625         assert_response :bad_request
 626         assert_equal "Placeholder Way not found for reference -1 in relation #{relation.id}.", @response.body
 627
 628         assert_no_changes_in changeset
 629
 630         relation.reload
 631         assert_equal 1, relation.version
 632       end
 633
 634       def test_upload_create_relations_with_circular_references
 635         changeset = create(:changeset)
 636
 637         diff = <<~CHANGESET
 638           <osmChange version='0.6'>
 639             <create>
 640               <relation id='-2' version='0' changeset='#{changeset.id}'>
 641                 <member type='relation' role='' ref='-4' />
 642                 <tag k='type' v='route' />
 643                 <tag k='name' v='AtoB' />
 644               </relation>
 645               <relation id='-3' version='0' changeset='#{changeset.id}'>
 646                 <tag k='type' v='route' />
 647                 <tag k='name' v='BtoA' />
 648               </relation>
 649               <relation id='-4' version='0' changeset='#{changeset.id}'>
 650                 <member type='relation' role='' ref='-2' />
 651                 <member type='relation' role='' ref='-3' />
 652                 <tag k='type' v='route_master' />
 653                 <tag k='name' v='master' />
 654               </relation>
 655             </create>
 656           </osmChange>
 657         CHANGESET
 658
 659         auth_header = bearer_authorization_header changeset.user
 660
 661         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
 662
 663         assert_response :bad_request
 664         assert_equal "Placeholder Relation not found for reference -4 in relation -2.", @response.body
 665
 666         assert_no_changes_in changeset
 667       end
 668
 669       # -------------------------------------
 670       # Test modifying elements.
 671       # -------------------------------------
 672
 673       def test_upload_modify_node
 674         user = create(:user)
 675         changeset = create(:changeset, :user => user)
 676         node = create(:node, :latitude => 0, :longitude => 0)
 677         create(:node_tag, :node => node)
 678
 679         diff = <<~CHANGESET
 680           <osmChange>
 681             <modify>
 682               <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
 683             </modify>
 684           </osmChange>
 685         CHANGESET
 686
 687         auth_header = bearer_authorization_header user
 688
 689         assert_difference "Node.count" => 0,
 690                           "OldNode.count" => 1,
 691                           "NodeTag.count" => -1,
 692                           "OldNodeTag.count" => 0 do
 693           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 694
 695           assert_response :success
 696         end
 697
 698         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 699           assert_dom "> node", 1 do
 700             assert_dom "> @old_id", node.id.to_s
 701             assert_dom "> @new_id", node.id.to_s
 702             assert_dom "> @new_version", "2"
 703           end
 704         end
 705
 706         changeset.reload
 707         assert_equal 1, changeset.num_changes
 708         assert_predicate changeset, :num_type_changes_in_sync?
 709         assert_equal 1, changeset.num_modified_nodes
 710
 711         node.reload
 712         assert_equal 2, node.version
 713         assert_equal 2 * GeoRecord::SCALE, node.latitude
 714         assert_equal 1 * GeoRecord::SCALE, node.longitude
 715         assert_equal 0, node.tags.size, "node #{node.id} should now have no tags"
 716       end
 717
 718       def test_upload_modify_way
 719         user = create(:user)
 720         changeset = create(:changeset, :user => user)
 721         node = create(:node)
 722         way = create(:way_with_nodes, :nodes_count => 3)
 723         create(:way_tag, :way => way)
 724
 725         diff = <<~CHANGESET
 726           <osmChange>
 727             <modify>
 728               <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
 729                 <nd ref='#{node.id}'/>
 730               </way>
 731             </modify>
 732           </osmChange>
 733         CHANGESET
 734
 735         auth_header = bearer_authorization_header user
 736
 737         assert_difference "Way.count" => 0,
 738                           "OldWay.count" => 1,
 739                           "WayTag.count" => -1,
 740                           "OldWayTag.count" => 0,
 741                           "WayNode.count" => -2,
 742                           "OldWayNode.count" => 1 do
 743           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 744
 745           assert_response :success
 746         end
 747
 748         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 749           assert_dom "> way", 1 do
 750             assert_dom "> @old_id", way.id.to_s
 751             assert_dom "> @new_id", way.id.to_s
 752             assert_dom "> @new_version", "2"
 753           end
 754         end
 755
 756         changeset.reload
 757         assert_equal 1, changeset.num_changes
 758         assert_predicate changeset, :num_type_changes_in_sync?
 759         assert_equal 1, changeset.num_modified_ways
 760
 761         way.reload
 762         assert_equal 2, way.version
 763         assert_equal 0, way.tags.size, "way #{way.id} should now have no tags"
 764         assert_equal [node], way.nodes
 765       end
 766
 767       def test_upload_modify_relation
 768         user = create(:user)
 769         changeset = create(:changeset, :user => user)
 770         node = create(:node)
 771         way = create(:way_with_nodes)
 772         relation = create(:relation)
 773         other_relation = create(:relation)
 774         create(:relation_tag, :relation => relation)
 775
 776         diff = <<~CHANGESET
 777           <osmChange>
 778             <modify>
 779               <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'>
 780                 <member type='way' role='some' ref='#{way.id}'/>
 781                 <member type='node' role='some' ref='#{node.id}'/>
 782                 <member type='relation' role='some' ref='#{other_relation.id}'/>
 783               </relation>
 784             </modify>
 785           </osmChange>
 786         CHANGESET
 787
 788         auth_header = bearer_authorization_header user
 789
 790         assert_difference "Relation.count" => 0,
 791                           "OldRelation.count" => 1,
 792                           "RelationTag.count" => -1,
 793                           "OldRelationTag.count" => 0,
 794                           "RelationMember.count" => 3,
 795                           "OldRelationMember.count" => 3 do
 796           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 797
 798           assert_response :success
 799         end
 800
 801         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 802           assert_dom "> relation", 1 do
 803             assert_dom "> @old_id", relation.id.to_s
 804             assert_dom "> @new_id", relation.id.to_s
 805             assert_dom "> @new_version", "2"
 806           end
 807         end
 808
 809         changeset.reload
 810         assert_equal 1, changeset.num_changes
 811         assert_predicate changeset, :num_type_changes_in_sync?
 812         assert_equal 1, changeset.num_modified_relations
 813
 814         relation.reload
 815         assert_equal 2, relation.version
 816         assert_equal 0, relation.tags.size, "relation #{relation.id} should now have no tags"
 817         assert_equal [["Way", way.id, "some"], ["Node", node.id, "some"], ["Relation", other_relation.id, "some"]], relation.members
 818       end
 819
 820       def test_upload_modify_elements
 821         user = create(:user)
 822         changeset = create(:changeset, :user => user)
 823         node = create(:node, :latitude => 0, :longitude => 0)
 824         way = create(:way)
 825         relation = create(:relation)
 826         other_relation = create(:relation)
 827
 828         # create some tags, since we test that they are removed later
 829         create(:node_tag, :node => node)
 830         create(:way_tag, :way => way)
 831         create(:relation_tag, :relation => relation)
 832
 833         # simple diff to change a node, way and relation by removing their tags
 834         diff = <<~CHANGESET
 835           <osmChange>
 836             <modify>
 837               <node id='#{node.id}' lon='1' lat='2' changeset='#{changeset.id}' version='1'/>
 838               <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
 839                 <nd ref='#{node.id}'/>
 840               </way>
 841             </modify>
 842             <modify>
 843               <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'>
 844                 <member type='way' role='some' ref='#{way.id}'/>
 845                 <member type='node' role='some' ref='#{node.id}'/>
 846                 <member type='relation' role='some' ref='#{other_relation.id}'/>
 847               </relation>
 848             </modify>
 849           </osmChange>
 850         CHANGESET
 851
 852         auth_header = bearer_authorization_header user
 853
 854         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 855
 856         assert_response :success
 857
 858         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
 859           assert_dom "> node", 1 do
 860             assert_dom "> @old_id", node.id.to_s
 861             assert_dom "> @new_id", node.id.to_s
 862             assert_dom "> @new_version", "2"
 863           end
 864           assert_dom "> way", 1 do
 865             assert_dom "> @old_id", way.id.to_s
 866             assert_dom "> @new_id", way.id.to_s
 867             assert_dom "> @new_version", "2"
 868           end
 869           assert_dom "> relation", 1 do
 870             assert_dom "> @old_id", relation.id.to_s
 871             assert_dom "> @new_id", relation.id.to_s
 872             assert_dom "> @new_version", "2"
 873           end
 874         end
 875
 876         changeset.reload
 877         assert_equal 3, changeset.num_changes
 878         assert_predicate changeset, :num_type_changes_in_sync?
 879         assert_equal 1, changeset.num_modified_nodes
 880         assert_equal 1, changeset.num_modified_ways
 881         assert_equal 1, changeset.num_modified_relations
 882
 883         node.reload
 884         assert_equal 2, node.version
 885         assert_equal 2 * GeoRecord::SCALE, node.latitude
 886         assert_equal 1 * GeoRecord::SCALE, node.longitude
 887         assert_equal 0, node.tags.size, "node #{node.id} should now have no tags"
 888         way.reload
 889         assert_equal 2, way.version
 890         assert_equal 0, way.tags.size, "way #{way.id} should now have no tags"
 891         assert_equal [node], way.nodes
 892         relation.reload
 893         assert_equal 2, relation.version
 894         assert_equal 0, relation.tags.size, "relation #{relation.id} should now have no tags"
 895         assert_equal [["Way", way.id, "some"], ["Node", node.id, "some"], ["Relation", other_relation.id, "some"]], relation.members
 896       end
 897
 898       ##
 899       # upload multiple versions of the same element in the same diff.
 900       def test_upload_modify_multiple_node_versions
 901         node = create(:node)
 902         changeset = create(:changeset)
 903
 904         # change the location of a node multiple times, each time referencing
 905         # the last version. doesn't this depend on version numbers being
 906         # sequential?
 907         diff = <<~CHANGESET
 908           <osmChange>
 909             <modify>
 910               <node id='#{node.id}' lon='0.0' lat='0.0' changeset='#{changeset.id}' version='1'/>
 911               <node id='#{node.id}' lon='0.1' lat='0.0' changeset='#{changeset.id}' version='2'/>
 912               <node id='#{node.id}' lon='0.1' lat='0.1' changeset='#{changeset.id}' version='3'/>
 913               <node id='#{node.id}' lon='0.1' lat='0.2' changeset='#{changeset.id}' version='4'/>
 914               <node id='#{node.id}' lon='0.2' lat='0.2' changeset='#{changeset.id}' version='5'/>
 915               <node id='#{node.id}' lon='0.3' lat='0.2' changeset='#{changeset.id}' version='6'/>
 916               <node id='#{node.id}' lon='0.3' lat='0.3' changeset='#{changeset.id}' version='7'/>
 917               <node id='#{node.id}' lon='0.9' lat='0.9' changeset='#{changeset.id}' version='8'/>
 918             </modify>
 919           </osmChange>
 920         CHANGESET
 921
 922         auth_header = bearer_authorization_header changeset.user
 923
 924         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 925
 926         assert_response :success
 927
 928         assert_dom "diffResult>node", 8
 929
 930         changeset.reload
 931         assert_equal 8, changeset.num_changes
 932         assert_predicate changeset, :num_type_changes_in_sync?
 933         assert_equal 8, changeset.num_modified_nodes
 934
 935         node.reload
 936         assert_equal 9, node.version
 937         assert_equal 0.9 * GeoRecord::SCALE, node.latitude
 938         assert_equal 0.9 * GeoRecord::SCALE, node.longitude
 939       end
 940
 941       ##
 942       # upload multiple versions of the same element in the same diff, but
 943       # keep the version numbers the same.
 944       def test_upload_modify_duplicate_node_versions
 945         node = create(:node, :latitude => 0, :longitude => 0)
 946         changeset = create(:changeset)
 947
 948         diff = <<~CHANGESET
 949           <osmChange>
 950             <modify>
 951               <node id='#{node.id}' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
 952               <node id='#{node.id}' lon='2' lat='2' changeset='#{changeset.id}' version='1'/>
 953             </modify>
 954           </osmChange>
 955         CHANGESET
 956
 957         auth_header = bearer_authorization_header changeset.user
 958
 959         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 960
 961         assert_response :conflict
 962
 963         assert_no_changes_in changeset
 964
 965         node.reload
 966         assert_equal 1, node.version
 967         assert_equal 0, node.latitude
 968         assert_equal 0, node.longitude
 969       end
 970
 971       ##
 972       # try to upload some elements without specifying the version
 973       def test_upload_modify_missing_node_version
 974         node = create(:node, :latitude => 0, :longitude => 0)
 975         changeset = create(:changeset)
 976
 977         diff = <<~CHANGESET
 978           <osmChange>
 979             <modify>
 980               <node id='#{node.id}' lon='1' lat='1' changeset='#{changeset.id}'/>
 981             </modify>
 982           </osmChange>
 983         CHANGESET
 984
 985         auth_header = bearer_authorization_header changeset.user
 986
 987         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
 988
 989         assert_response :bad_request
 990
 991         assert_no_changes_in changeset
 992
 993         node.reload
 994         assert_equal 1, node.version
 995         assert_equal 0, node.latitude
 996         assert_equal 0, node.longitude
 997       end
 998
 999       ##
1000       # create a diff which references several changesets, which should cause
1001       # a rollback and none of the diff gets committed
1002       def test_upload_modify_with_references_to_different_changesets
1003         changeset1 = create(:changeset)
1004         changeset2 = create(:changeset, :user => changeset1.user)
1005         node1 = create(:node)
1006         node2 = create(:node)
1007
1008         # simple diff to create a node way and relation using placeholders
1009         diff = <<~CHANGESET
1010           <osmChange>
1011             <modify>
1012               <node id='#{node1.id}' lon='0' lat='0' changeset='#{changeset1.id}' version='1'/>
1013             </modify>
1014             <modify>
1015               <node id='#{node2.id}' lon='0' lat='0' changeset='#{changeset2.id}' version='1'/>
1016             </modify>
1017           </osmChange>
1018         CHANGESET
1019
1020         auth_header = bearer_authorization_header changeset1.user
1021
1022         post api_changeset_upload_path(changeset1), :params => diff, :headers => auth_header
1023
1024         assert_response :conflict
1025
1026         assert_no_changes_in changeset1
1027         assert_no_changes_in changeset2
1028
1029         assert_nodes_are_equal(node1, Node.find(node1.id))
1030         assert_nodes_are_equal(node2, Node.find(node2.id))
1031       end
1032
1033       ##
1034       # upload a valid changeset which has a mixture of whitespace
1035       # to check a bug https://github.com/openstreetmap/trac-tickets/issues/1565
1036       def test_upload_modify_with_mixed_whitespace
1037         changeset = create(:changeset)
1038         node = create(:node)
1039         way = create(:way_with_nodes, :nodes_count => 2)
1040         relation = create(:relation)
1041         other_relation = create(:relation)
1042         create(:relation_tag, :relation => relation)
1043
1044         diff = <<~CHANGESET
1045           <osmChange>
1046           <modify><node id='#{node.id}' lon='0' lat='0' changeset='#{changeset.id}'
1047             version='1'></node>
1048             <node id='#{node.id}' lon='1' lat='1' changeset='#{changeset.id}' version='2'><tag k='k' v='v'/></node></modify>
1049           <modify>
1050           <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'><member
1051             type='way' role='some' ref='#{way.id}'/><member
1052               type='node' role='some' ref='#{node.id}'/>
1053             <member type='relation' role='some' ref='#{other_relation.id}'/>
1054             </relation>
1055           </modify></osmChange>
1056         CHANGESET
1057
1058         auth_header = bearer_authorization_header changeset.user
1059
1060         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1061
1062         assert_response :success
1063
1064         assert_dom "diffResult>node", 2
1065         assert_dom "diffResult>relation", 1
1066
1067         changeset.reload
1068         assert_equal 3, changeset.num_changes
1069         assert_predicate changeset, :num_type_changes_in_sync?
1070         assert_equal 2, changeset.num_modified_nodes
1071         assert_equal 1, changeset.num_modified_relations
1072
1073         assert_equal 1, Node.find(node.id).tags.size, "node #{node.id} should now have one tag"
1074         assert_equal 0, Relation.find(relation.id).tags.size, "relation #{relation.id} should now have no tags"
1075       end
1076
1077       def test_upload_modify_unknown_node_placeholder
1078         check_upload_results_in_not_found do |changeset|
1079           "<modify><node id='-1' lon='0' lat='0' changeset='#{changeset.id}' version='1'/></modify>"
1080         end
1081       end
1082
1083       def test_upload_modify_unknown_way_placeholder
1084         check_upload_results_in_not_found do |changeset|
1085           "<modify><way id='-1' changeset='#{changeset.id}' version='1'/></modify>"
1086         end
1087       end
1088
1089       def test_upload_modify_unknown_relation_placeholder
1090         check_upload_results_in_not_found do |changeset|
1091           "<modify><relation id='-1' changeset='#{changeset.id}' version='1'/></modify>"
1092         end
1093       end
1094
1095       # -------------------------------------
1096       # Test deleting elements.
1097       # -------------------------------------
1098
1099       def test_upload_delete_node
1100         changeset = create(:changeset)
1101         node = create(:node, :lat => 0, :lon => 0)
1102         create(:node_tag, :node => node)
1103
1104         diff = <<~CHANGESET
1105           <osmChange>
1106             <delete>
1107               <node id='#{node.id}' changeset='#{changeset.id}' version='1' lat='0' lon='0'/>
1108             </delete>
1109           </osmChange>
1110         CHANGESET
1111
1112         auth_header = bearer_authorization_header changeset.user
1113
1114         assert_difference "Node.count" => 0,
1115                           "OldNode.count" => 1,
1116                           "NodeTag.count" => -1,
1117                           "OldNodeTag.count" => 0 do
1118           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1119
1120           assert_response :success
1121         end
1122
1123         assert_dom "diffResult", 1 do
1124           assert_dom "> node", 1 do
1125             assert_dom "> @old_id", node.id.to_s
1126           end
1127         end
1128
1129         changeset.reload
1130         assert_equal 1, changeset.num_changes
1131         assert_predicate changeset, :num_type_changes_in_sync?
1132         assert_equal 1, changeset.num_deleted_nodes
1133
1134         node.reload
1135         assert_not_predicate node, :visible?
1136       end
1137
1138       def test_upload_delete_way
1139         changeset = create(:changeset)
1140         way = create(:way_with_nodes, :nodes_count => 3)
1141         create(:way_tag, :way => way)
1142
1143         diff = <<~CHANGESET
1144           <osmChange>
1145             <delete>
1146               <way id='#{way.id}' changeset='#{changeset.id}' version='1'/>
1147             </delete>
1148           </osmChange>
1149         CHANGESET
1150
1151         auth_header = bearer_authorization_header changeset.user
1152
1153         assert_difference "Way.count" => 0,
1154                           "OldWay.count" => 1,
1155                           "WayTag.count" => -1,
1156                           "OldWayTag.count" => 0,
1157                           "WayNode.count" => -3,
1158                           "OldWayNode.count" => 0 do
1159           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1160
1161           assert_response :success
1162         end
1163
1164         assert_dom "diffResult", 1 do
1165           assert_dom "> way", 1 do
1166             assert_dom "> @old_id", way.id.to_s
1167           end
1168         end
1169
1170         changeset.reload
1171         assert_equal 1, changeset.num_changes
1172         assert_predicate changeset, :num_type_changes_in_sync?
1173         assert_equal 1, changeset.num_deleted_ways
1174
1175         way.reload
1176         assert_not_predicate way, :visible?
1177       end
1178
1179       def test_upload_delete_relation
1180         changeset = create(:changeset)
1181         relation = create(:relation)
1182         create(:relation_member, :relation => relation, :member => create(:node))
1183         create(:relation_tag, :relation => relation)
1184
1185         diff = <<~CHANGESET
1186           <osmChange>
1187             <delete>
1188               <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'/>
1189             </delete>
1190           </osmChange>
1191         CHANGESET
1192
1193         auth_header = bearer_authorization_header changeset.user
1194
1195         assert_difference "Relation.count" => 0,
1196                           "OldRelation.count" => 1,
1197                           "RelationTag.count" => -1,
1198                           "OldRelationTag.count" => 0,
1199                           "RelationMember.count" => -1,
1200                           "OldRelationMember.count" => 0 do
1201           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1202
1203           assert_response :success
1204         end
1205
1206         assert_dom "diffResult", 1 do
1207           assert_dom "> relation", 1 do
1208             assert_dom "> @old_id", relation.id.to_s
1209           end
1210         end
1211
1212         relation.reload
1213         assert_not_predicate relation, :visible?
1214       end
1215
1216       ##
1217       # test a complex delete where we delete elements which rely on each other
1218       # in the same transaction.
1219       def test_upload_delete_elements
1220         changeset = create(:changeset)
1221         super_relation = create(:relation)
1222         used_relation = create(:relation)
1223         used_way = create(:way)
1224         used_node = create(:node)
1225         create(:relation_member, :relation => super_relation, :member => used_relation)
1226         create(:relation_member, :relation => super_relation, :member => used_way)
1227         create(:relation_member, :relation => super_relation, :member => used_node)
1228
1229         diff = XML::Document.new
1230         diff.root = XML::Node.new "osmChange"
1231         delete = XML::Node.new "delete"
1232         diff.root << delete
1233         delete << xml_node_for_relation(super_relation)
1234         delete << xml_node_for_relation(used_relation)
1235         delete << xml_node_for_way(used_way)
1236         delete << xml_node_for_node(used_node)
1237         %w[node way relation].each do |type|
1238           delete.find("//osmChange/delete/#{type}").each do |n|
1239             n["changeset"] = changeset.id.to_s
1240           end
1241         end
1242
1243         auth_header = bearer_authorization_header changeset.user
1244
1245         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1246
1247         assert_response :success
1248
1249         assert_dom "diffResult", 1 do
1250           assert_dom "> node", 1
1251           assert_dom "> way", 1
1252           assert_dom "> relation", 2
1253         end
1254
1255         assert_not Node.find(used_node.id).visible
1256         assert_not Way.find(used_way.id).visible
1257         assert_not Relation.find(super_relation.id).visible
1258         assert_not Relation.find(used_relation.id).visible
1259       end
1260
1261       ##
1262       # test uploading a delete with no lat/lon, as they are optional in the osmChange spec.
1263       def test_upload_delete_node_without_latlon
1264         node = create(:node)
1265         changeset = create(:changeset)
1266
1267         diff = "<osmChange><delete><node id='#{node.id}' version='#{node.version}' changeset='#{changeset.id}'/></delete></osmChange>"
1268
1269         auth_header = bearer_authorization_header changeset.user
1270
1271         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1272
1273         assert_response :success
1274
1275         assert_dom "diffResult", 1 do
1276           assert_dom "> node", 1 do
1277             assert_dom "> @old_id", node.id.to_s
1278             assert_dom "> @new_id", 0
1279             assert_dom "> @new_version", 0
1280           end
1281         end
1282
1283         changeset.reload
1284         assert_equal 1, changeset.num_changes
1285         assert_predicate changeset, :num_type_changes_in_sync?
1286         assert_equal 1, changeset.num_deleted_nodes
1287
1288         node.reload
1289         assert_not node.visible
1290       end
1291
1292       ##
1293       # test that deleting stuff in a transaction doesn't bypass the checks
1294       # to ensure that used elements are not deleted.
1295       def test_upload_delete_referenced_elements
1296         changeset = create(:changeset)
1297         relation = create(:relation)
1298         other_relation = create(:relation)
1299         used_way = create(:way)
1300         used_node = create(:node)
1301         create(:relation_member, :relation => relation, :member => used_way)
1302         create(:relation_member, :relation => relation, :member => used_node)
1303
1304         diff = XML::Document.new
1305         diff.root = XML::Node.new "osmChange"
1306         delete = XML::Node.new "delete"
1307         diff.root << delete
1308         delete << xml_node_for_relation(other_relation)
1309         delete << xml_node_for_way(used_way)
1310         delete << xml_node_for_node(used_node)
1311         %w[node way relation].each do |type|
1312           delete.find("//osmChange/delete/#{type}").each do |n|
1313             n["changeset"] = changeset.id.to_s
1314           end
1315         end
1316
1317         auth_header = bearer_authorization_header changeset.user
1318
1319         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1320
1321         assert_response :precondition_failed
1322         assert_equal "Precondition failed: Way #{used_way.id} is still used by relations #{relation.id}.", @response.body
1323
1324         assert_no_changes_in changeset
1325
1326         assert Node.find(used_node.id).visible
1327         assert Way.find(used_way.id).visible
1328         assert Relation.find(relation.id).visible
1329         assert Relation.find(other_relation.id).visible
1330       end
1331
1332       ##
1333       # test that a conditional delete of an in use object works.
1334       def test_upload_delete_if_unused
1335         changeset = create(:changeset)
1336         super_relation = create(:relation)
1337         used_relation = create(:relation)
1338         used_way = create(:way)
1339         used_node = create(:node)
1340         create(:relation_member, :relation => super_relation, :member => used_relation)
1341         create(:relation_member, :relation => super_relation, :member => used_way)
1342         create(:relation_member, :relation => super_relation, :member => used_node)
1343
1344         diff = XML::Document.new
1345         diff.root = XML::Node.new "osmChange"
1346         delete = XML::Node.new "delete"
1347         diff.root << delete
1348         delete["if-unused"] = ""
1349         delete << xml_node_for_relation(used_relation)
1350         delete << xml_node_for_way(used_way)
1351         delete << xml_node_for_node(used_node)
1352         %w[node way relation].each do |type|
1353           delete.find("//osmChange/delete/#{type}").each do |n|
1354             n["changeset"] = changeset.id.to_s
1355           end
1356         end
1357
1358         auth_header = bearer_authorization_header changeset.user
1359
1360         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1361
1362         assert_response :success
1363
1364         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
1365           assert_dom "> node", 1 do
1366             assert_dom "> @old_id", used_node.id.to_s
1367             assert_dom "> @new_id", used_node.id.to_s
1368             assert_dom "> @new_version", used_node.version.to_s
1369           end
1370           assert_dom "> way", 1 do
1371             assert_dom "> @old_id", used_way.id.to_s
1372             assert_dom "> @new_id", used_way.id.to_s
1373             assert_dom "> @new_version", used_way.version.to_s
1374           end
1375           assert_dom "> relation", 1 do
1376             assert_dom "> @old_id", used_relation.id.to_s
1377             assert_dom "> @new_id", used_relation.id.to_s
1378             assert_dom "> @new_version", used_relation.version.to_s
1379           end
1380         end
1381
1382         assert_no_changes_in changeset
1383
1384         assert Node.find(used_node.id).visible
1385         assert Way.find(used_way.id).visible
1386         assert Relation.find(used_relation.id).visible
1387       end
1388
1389       def test_upload_delete_with_multiple_blocks_and_if_unused
1390         changeset = create(:changeset)
1391         node = create(:node)
1392         way = create(:way)
1393         create(:way_node, :way => way, :node => node)
1394         alone_node = create(:node)
1395
1396         diff = <<~CHANGESET
1397           <osmChange version='0.6'>
1398             <delete version="0.6">
1399               <node id="#{node.id}" version="#{node.version}" changeset="#{changeset.id}"/>
1400             </delete>
1401             <delete version="0.6" if-unused="true">
1402               <node id="#{alone_node.id}" version="#{alone_node.version}" changeset="#{changeset.id}"/>
1403             </delete>
1404           </osmChange>
1405         CHANGESET
1406
1407         auth_header = bearer_authorization_header changeset.user
1408
1409         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1410
1411         assert_response :precondition_failed
1412         assert_equal "Precondition failed: Node #{node.id} is still used by ways #{way.id}.", @response.body
1413
1414         assert_no_changes_in changeset
1415       end
1416
1417       def test_upload_delete_unknown_node_placeholder
1418         check_upload_results_in_not_found do |changeset|
1419           "<delete><node id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1420         end
1421       end
1422
1423       def test_upload_delete_unknown_way_placeholder
1424         check_upload_results_in_not_found do |changeset|
1425           "<delete><way id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1426         end
1427       end
1428
1429       def test_upload_delete_unknown_relation_placeholder
1430         check_upload_results_in_not_found do |changeset|
1431           "<delete><relation id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1432         end
1433       end
1434
1435       # -------------------------------------
1436       # Test combined element changes.
1437       # -------------------------------------
1438
1439       ##
1440       # upload something which creates new objects and inserts them into
1441       # existing containers using placeholders.
1442       def test_upload_create_and_insert_elements
1443         way = create(:way)
1444         node = create(:node)
1445         relation = create(:relation)
1446         create(:way_node, :way => way, :node => node)
1447         changeset = create(:changeset)
1448
1449         diff = <<~CHANGESET
1450           <osmChange>
1451             <create>
1452               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1453                 <tag k='foo' v='bar'/>
1454                 <tag k='baz' v='bat'/>
1455               </node>
1456             </create>
1457             <modify>
1458               <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
1459                 <nd ref='-1'/>
1460                 <nd ref='#{node.id}'/>
1461               </way>
1462               <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'>
1463                 <member type='way' role='some' ref='#{way.id}'/>
1464                 <member type='node' role='some' ref='-1'/>
1465                 <member type='relation' role='some' ref='#{relation.id}'/>
1466               </relation>
1467             </modify>
1468           </osmChange>
1469         CHANGESET
1470
1471         auth_header = bearer_authorization_header changeset.user
1472
1473         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1474
1475         assert_response :success
1476
1477         new_node_id = nil
1478         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
1479           assert_dom "> node", 1 do |(node_el)|
1480             new_node_id = node_el["new_id"].to_i
1481           end
1482           assert_dom "> way", 1
1483           assert_dom "> relation", 1
1484         end
1485
1486         changeset.reload
1487         assert_equal 3, changeset.num_changes
1488         assert_predicate changeset, :num_type_changes_in_sync?
1489         assert_equal 1, changeset.num_created_nodes
1490         assert_equal 1, changeset.num_modified_ways
1491         assert_equal 1, changeset.num_modified_relations
1492
1493         assert_equal 2, Node.find(new_node_id).tags.size, "new node should have two tags"
1494         assert_equal [new_node_id, node.id], Way.find(way.id).nds, "way nodes should match"
1495         Relation.find(relation.id).members.each do |type, id, _role|
1496           assert_equal new_node_id, id, "relation should contain new node" if type == "node"
1497         end
1498       end
1499
1500       ##
1501       # test that a placeholder can be reused within the same upload.
1502       def test_upload_create_modify_delete_node_reusing_placeholder
1503         changeset = create(:changeset)
1504
1505         diff = <<~CHANGESET
1506           <osmChange>
1507             <create>
1508               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1509                 <tag k="foo" v="bar"/>
1510               </node>
1511             </create>
1512             <modify>
1513               <node id='-1' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
1514             </modify>
1515             <delete>
1516               <node id='-1' lon='2' lat='2' changeset='#{changeset.id}' version='2'/>
1517             </delete>
1518           </osmChange>
1519         CHANGESET
1520
1521         auth_header = bearer_authorization_header changeset.user
1522
1523         assert_difference "Node.count", 1 do
1524           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1525
1526           assert_response :success
1527         end
1528
1529         assert_dom "diffResult>node", 3
1530         assert_dom "diffResult>node[old_id='-1']", 3
1531
1532         changeset.reload
1533         assert_equal 3, changeset.num_changes
1534         assert_predicate changeset, :num_type_changes_in_sync?
1535         assert_equal 1, changeset.num_created_nodes
1536         assert_equal 1, changeset.num_modified_nodes
1537         assert_equal 1, changeset.num_deleted_nodes
1538
1539         node = Node.last
1540         assert_equal 3, node.version
1541         assert_not node.visible
1542       end
1543
1544       def test_upload_create_and_duplicate_delete
1545         changeset = create(:changeset)
1546
1547         diff = <<~CHANGESET
1548           <osmChange>
1549             <create>
1550               <node id="-1" lat="39" lon="116" changeset="#{changeset.id}" />
1551             </create>
1552             <delete>
1553               <node id="-1" version="1" changeset="#{changeset.id}" />
1554               <node id="-1" version="1" changeset="#{changeset.id}" />
1555             </delete>
1556           </osmChange>
1557         CHANGESET
1558
1559         auth_header = bearer_authorization_header changeset.user
1560
1561         assert_no_difference "Node.count" do
1562           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1563
1564           assert_response :gone
1565         end
1566
1567         assert_no_changes_in changeset
1568       end
1569
1570       def test_upload_create_and_duplicate_delete_if_unused
1571         changeset = create(:changeset)
1572
1573         diff = <<~CHANGESET
1574           <osmChange>
1575             <create>
1576               <node id="-1" lat="39" lon="116" changeset="#{changeset.id}" />
1577             </create>
1578             <delete if-unused="true">
1579               <node id="-1" version="1" changeset="#{changeset.id}" />
1580               <node id="-1" version="1" changeset="#{changeset.id}" />
1581             </delete>
1582           </osmChange>
1583         CHANGESET
1584
1585         auth_header = bearer_authorization_header changeset.user
1586
1587         assert_difference "Node.count", 1 do
1588           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1589
1590           assert_response :success
1591         end
1592
1593         assert_dom "diffResult>node", 3
1594         assert_dom "diffResult>node[old_id='-1']", 3
1595         assert_dom "diffResult>node[new_version='1']", 1
1596         assert_dom "diffResult>node[new_version='2']", 1
1597
1598         changeset.reload
1599         assert_equal 2, changeset.num_changes
1600         assert_predicate changeset, :num_type_changes_in_sync?
1601         assert_equal 1, changeset.num_created_nodes
1602         assert_equal 1, changeset.num_deleted_nodes
1603
1604         node = Node.last
1605         assert_equal 2, node.version
1606         assert_not node.visible
1607       end
1608
1609       # -------------------------------------
1610       # Test bounding boxes.
1611       # -------------------------------------
1612
1613       def test_upload_bbox_of_widely_spaced_nodes
1614         user = create(:user)
1615
1616         # create an old changeset to ensure we have the maximum rate limit
1617         create(:changeset, :user => user, :created_at => Time.now.utc - 28.days)
1618
1619         changeset = create(:changeset, :user => user)
1620
1621         # upload some widely-spaced nodes, spiralling positive and negative
1622         diff = <<~CHANGESET
1623           <osmChange>
1624             <create>
1625               <node id='-1' lon='-20' lat='-10' changeset='#{changeset.id}'/>
1626               <node id='-10' lon='20'  lat='10' changeset='#{changeset.id}'/>
1627               <node id='-2' lon='-40' lat='-20' changeset='#{changeset.id}'/>
1628               <node id='-11' lon='40'  lat='20' changeset='#{changeset.id}'/>
1629               <node id='-3' lon='-60' lat='-30' changeset='#{changeset.id}'/>
1630               <node id='-12' lon='60'  lat='30' changeset='#{changeset.id}'/>
1631               <node id='-4' lon='-80' lat='-40' changeset='#{changeset.id}'/>
1632               <node id='-13' lon='80'  lat='40' changeset='#{changeset.id}'/>
1633               <node id='-5' lon='-100' lat='-50' changeset='#{changeset.id}'/>
1634               <node id='-14' lon='100'  lat='50' changeset='#{changeset.id}'/>
1635               <node id='-6' lon='-120' lat='-60' changeset='#{changeset.id}'/>
1636               <node id='-15' lon='120'  lat='60' changeset='#{changeset.id}'/>
1637               <node id='-7' lon='-140' lat='-70' changeset='#{changeset.id}'/>
1638               <node id='-16' lon='140'  lat='70' changeset='#{changeset.id}'/>
1639               <node id='-8' lon='-160' lat='-80' changeset='#{changeset.id}'/>
1640               <node id='-17' lon='160'  lat='80' changeset='#{changeset.id}'/>
1641               <node id='-9' lon='-179.9' lat='-89.9' changeset='#{changeset.id}'/>
1642               <node id='-18' lon='179.9'  lat='89.9' changeset='#{changeset.id}'/>
1643             </create>
1644           </osmChange>
1645         CHANGESET
1646
1647         auth_header = bearer_authorization_header user
1648
1649         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1650
1651         assert_response :success
1652
1653         changeset.reload
1654         assert_equal 18, changeset.num_changes
1655         assert_predicate changeset, :num_type_changes_in_sync?
1656         assert_equal 18, changeset.num_created_nodes
1657
1658         # check that the changeset bbox is within bounds
1659         assert_operator changeset.min_lon, :>=, -180 * GeoRecord::SCALE, "Minimum longitude (#{changeset.min_lon / GeoRecord::SCALE}) should be >= -180 to be valid."
1660         assert_operator changeset.max_lon, :<=, 180 * GeoRecord::SCALE, "Maximum longitude (#{changeset.max_lon / GeoRecord::SCALE}) should be <= 180 to be valid."
1661         assert_operator changeset.min_lat, :>=, -90 * GeoRecord::SCALE, "Minimum latitude (#{changeset.min_lat / GeoRecord::SCALE}) should be >= -90 to be valid."
1662         assert_operator changeset.max_lat, :<=, 90 * GeoRecord::SCALE, "Maximum latitude (#{changeset.max_lat / GeoRecord::SCALE}) should be <= 90 to be valid."
1663       end
1664
1665       def test_upload_bbox_of_moved_node
1666         changeset = create(:changeset)
1667         node = create(:node, :lat => 1.0, :lon => 2.0)
1668
1669         diff = <<~CHANGESET
1670           <osmChange>
1671             <modify>
1672               <node id='#{node.id}' lat='1.1' lon='2.1' changeset='#{changeset.id}' version='1'/>
1673             </modify>
1674           </osmChange>
1675         CHANGESET
1676
1677         auth_header = bearer_authorization_header changeset.user
1678
1679         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1680
1681         assert_response :success
1682
1683         changeset.reload
1684         assert_equal 1, changeset.num_changes
1685         assert_predicate changeset, :num_type_changes_in_sync?
1686         assert_equal 1, changeset.num_modified_nodes
1687
1688         # check the bbox
1689         assert_equal 1.0 * GeoRecord::SCALE, changeset.min_lat, "min_lat should be 1.0 degrees"
1690         assert_equal 2.0 * GeoRecord::SCALE, changeset.min_lon, "min_lon should be 2.0 degrees"
1691         assert_equal 1.1 * GeoRecord::SCALE, changeset.max_lat, "max_lat should be 1.1 degrees"
1692         assert_equal 2.1 * GeoRecord::SCALE, changeset.max_lon, "max_lon should be 2.1 degrees"
1693       end
1694
1695       def test_upload_bbox_of_extended_way
1696         way = create(:way)
1697         initial_node = create(:node, :lat => 1.1, :lon => 2.1)
1698         create(:way_node, :way => way, :node => initial_node)
1699         added_node = create(:node, :lat => 1.3, :lon => 2.3)
1700         changeset = create(:changeset)
1701
1702         diff = <<~CHANGESET
1703           <osmChange>
1704             <modify>
1705               <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
1706                 <nd ref='#{initial_node.id}'/>
1707                 <nd ref='#{added_node.id}'/>
1708               </way>
1709             </modify>
1710           </osmChange>
1711         CHANGESET
1712
1713         auth_header = bearer_authorization_header changeset.user
1714
1715         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1716
1717         assert_response :success
1718
1719         changeset.reload
1720         assert_equal 1, changeset.num_changes
1721         assert_predicate changeset, :num_type_changes_in_sync?
1722         assert_equal 1, changeset.num_modified_ways
1723
1724         # check the bbox
1725         assert_equal 1.1 * GeoRecord::SCALE, changeset.min_lat, "min_lat should be 1.1 degrees"
1726         assert_equal 2.1 * GeoRecord::SCALE, changeset.min_lon, "min_lon should be 2.1 degrees"
1727         assert_equal 1.3 * GeoRecord::SCALE, changeset.max_lat, "max_lat should be 1.3 degrees"
1728         assert_equal 2.3 * GeoRecord::SCALE, changeset.max_lon, "max_lon should be 2.3 degrees"
1729       end
1730
1731       # -------------------------------------
1732       # Test upload rate/size limits.
1733       # -------------------------------------
1734
1735       def test_upload_initial_rate_limit
1736         user = create(:user)
1737         node = create(:node)
1738         way = create(:way_with_nodes, :nodes_count => 2)
1739         relation = create(:relation)
1740
1741         # create a changeset that puts us near the initial rate limit
1742         num_changes = Settings.initial_changes_per_hour - 2
1743         changeset = create(:changeset, :user => user,
1744                                        :created_at => Time.now.utc - 5.minutes,
1745                                        :num_changes => num_changes,
1746                                        :num_created_nodes => num_changes)
1747
1748         diff = <<~CHANGESET
1749           <osmChange>
1750             <create>
1751               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1752                 <tag k='foo' v='bar'/>
1753                 <tag k='baz' v='bat'/>
1754               </node>
1755               <way id='-1' changeset='#{changeset.id}'>
1756                 <nd ref='#{node.id}'/>
1757               </way>
1758             </create>
1759             <create>
1760               <relation id='-1' changeset='#{changeset.id}'>
1761                 <member type='way' role='some' ref='#{way.id}'/>
1762                 <member type='node' role='some' ref='#{node.id}'/>
1763                 <member type='relation' role='some' ref='#{relation.id}'/>
1764               </relation>
1765             </create>
1766           </osmChange>
1767         CHANGESET
1768
1769         auth_header = bearer_authorization_header user
1770
1771         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1772
1773         assert_response :too_many_requests, "upload did not hit rate limit"
1774
1775         changeset.reload
1776         assert_equal num_changes, changeset.num_changes
1777         assert_predicate changeset, :num_type_changes_in_sync?
1778       end
1779
1780       def test_upload_maximum_rate_limit
1781         user = create(:user)
1782         node = create(:node)
1783         way = create(:way_with_nodes, :nodes_count => 2)
1784         relation = create(:relation)
1785
1786         # create a changeset to establish our initial edit time
1787         changeset = create(:changeset, :user => user,
1788                                        :created_at => Time.now.utc - 28.days)
1789
1790         # create changeset to put us near the maximum rate limit
1791         remaining_num_changes = Settings.max_changes_per_hour - 2
1792         num_changes = 0
1793         while remaining_num_changes.positive?
1794           num_changes = [remaining_num_changes, Changeset::MAX_ELEMENTS].min
1795           changeset = create(:changeset, :user => user,
1796                                          :created_at => Time.now.utc - 5.minutes,
1797                                          :num_changes => num_changes,
1798                                          :num_created_nodes => num_changes)
1799           remaining_num_changes -= num_changes
1800         end
1801
1802         diff = <<~CHANGESET
1803           <osmChange>
1804             <create>
1805               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1806                 <tag k='foo' v='bar'/>
1807                 <tag k='baz' v='bat'/>
1808               </node>
1809               <way id='-1' changeset='#{changeset.id}'>
1810                 <nd ref='#{node.id}'/>
1811               </way>
1812             </create>
1813             <create>
1814               <relation id='-1' changeset='#{changeset.id}'>
1815                 <member type='way' role='some' ref='#{way.id}'/>
1816                 <member type='node' role='some' ref='#{node.id}'/>
1817                 <member type='relation' role='some' ref='#{relation.id}'/>
1818               </relation>
1819             </create>
1820           </osmChange>
1821         CHANGESET
1822
1823         auth_header = bearer_authorization_header user
1824
1825         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1826
1827         assert_response :too_many_requests, "upload did not hit rate limit"
1828
1829         changeset.reload
1830         assert_equal num_changes, changeset.num_changes
1831         assert_predicate changeset, :num_type_changes_in_sync?
1832       end
1833
1834       def test_upload_initial_size_limit
1835         user = create(:user)
1836
1837         # create a changeset that puts us near the initial size limit
1838         changeset = create(:changeset, :user => user,
1839                                        :min_lat => (-0.5 * GeoRecord::SCALE).round, :min_lon => (0.5 * GeoRecord::SCALE).round,
1840                                        :max_lat => (0.5 * GeoRecord::SCALE).round, :max_lon => (2.5 * GeoRecord::SCALE).round)
1841
1842         diff = <<~CHANGESET
1843           <osmChange>
1844             <create>
1845               <node id='-1' lon='0.9' lat='2.9' changeset='#{changeset.id}'>
1846                 <tag k='foo' v='bar'/>
1847                 <tag k='baz' v='bat'/>
1848               </node>
1849             </create>
1850           </osmChange>
1851         CHANGESET
1852
1853         auth_header = bearer_authorization_header user
1854
1855         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1856
1857         assert_response :payload_too_large, "upload did not hit size limit"
1858
1859         assert_no_changes_in changeset
1860       end
1861
1862       def test_upload_size_limit_after_one_week
1863         user = create(:user)
1864
1865         # create a changeset to establish our initial edit time
1866         create(:changeset, :user => user, :created_at => Time.now.utc - 7.days)
1867
1868         # create a changeset that puts us near the initial size limit
1869         changeset = create(:changeset, :user => user, :bbox => [0.5, -0.5, 2.5, 0.5])
1870
1871         diff = <<~CHANGESET
1872           <osmChange>
1873             <create>
1874               <node id='-1' lon='35' lat='35' changeset='#{changeset.id}'>
1875                 <tag k='foo' v='bar'/>
1876                 <tag k='baz' v='bat'/>
1877               </node>
1878             </create>
1879           </osmChange>
1880         CHANGESET
1881
1882         auth_header = bearer_authorization_header user
1883
1884         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1885
1886         assert_response :payload_too_large, "upload did not hit size limit"
1887
1888         assert_no_changes_in changeset
1889       end
1890
1891       private
1892
1893       def check_upload_results_in_not_found(&)
1894         changeset = create(:changeset)
1895         diff = "<osmChange>#{yield changeset}</osmChange>"
1896         auth_header = bearer_authorization_header changeset.user
1897
1898         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1899
1900         assert_response :not_found
1901
1902         assert_no_changes_in changeset
1903       end
1904
1905       def assert_no_changes_in(changeset)
1906         changeset.reload
1907         assert_equal 0, changeset.num_changes
1908         assert_predicate changeset, :num_type_changes_in_sync?
1909       end
1910     end
1911   end
1912 end