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         way.reload
1171         assert_not_predicate way, :visible?
1172       end
1173
1174       def test_upload_delete_relation
1175         changeset = create(:changeset)
1176         relation = create(:relation)
1177         create(:relation_member, :relation => relation, :member => create(:node))
1178         create(:relation_tag, :relation => relation)
1179
1180         diff = <<~CHANGESET
1181           <osmChange>
1182             <delete>
1183               <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'/>
1184             </delete>
1185           </osmChange>
1186         CHANGESET
1187
1188         auth_header = bearer_authorization_header changeset.user
1189
1190         assert_difference "Relation.count" => 0,
1191                           "OldRelation.count" => 1,
1192                           "RelationTag.count" => -1,
1193                           "OldRelationTag.count" => 0,
1194                           "RelationMember.count" => -1,
1195                           "OldRelationMember.count" => 0 do
1196           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1197
1198           assert_response :success
1199         end
1200
1201         assert_dom "diffResult", 1 do
1202           assert_dom "> relation", 1 do
1203             assert_dom "> @old_id", relation.id.to_s
1204           end
1205         end
1206
1207         relation.reload
1208         assert_not_predicate relation, :visible?
1209       end
1210
1211       ##
1212       # test a complex delete where we delete elements which rely on each other
1213       # in the same transaction.
1214       def test_upload_delete_elements
1215         changeset = create(:changeset)
1216         super_relation = create(:relation)
1217         used_relation = create(:relation)
1218         used_way = create(:way)
1219         used_node = create(:node)
1220         create(:relation_member, :relation => super_relation, :member => used_relation)
1221         create(:relation_member, :relation => super_relation, :member => used_way)
1222         create(:relation_member, :relation => super_relation, :member => used_node)
1223
1224         diff = XML::Document.new
1225         diff.root = XML::Node.new "osmChange"
1226         delete = XML::Node.new "delete"
1227         diff.root << delete
1228         delete << xml_node_for_relation(super_relation)
1229         delete << xml_node_for_relation(used_relation)
1230         delete << xml_node_for_way(used_way)
1231         delete << xml_node_for_node(used_node)
1232         %w[node way relation].each do |type|
1233           delete.find("//osmChange/delete/#{type}").each do |n|
1234             n["changeset"] = changeset.id.to_s
1235           end
1236         end
1237
1238         auth_header = bearer_authorization_header changeset.user
1239
1240         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1241
1242         assert_response :success
1243
1244         assert_dom "diffResult", 1 do
1245           assert_dom "> node", 1
1246           assert_dom "> way", 1
1247           assert_dom "> relation", 2
1248         end
1249
1250         assert_not Node.find(used_node.id).visible
1251         assert_not Way.find(used_way.id).visible
1252         assert_not Relation.find(super_relation.id).visible
1253         assert_not Relation.find(used_relation.id).visible
1254       end
1255
1256       ##
1257       # test uploading a delete with no lat/lon, as they are optional in the osmChange spec.
1258       def test_upload_delete_node_without_latlon
1259         node = create(:node)
1260         changeset = create(:changeset)
1261
1262         diff = "<osmChange><delete><node id='#{node.id}' version='#{node.version}' changeset='#{changeset.id}'/></delete></osmChange>"
1263
1264         auth_header = bearer_authorization_header changeset.user
1265
1266         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1267
1268         assert_response :success
1269
1270         assert_dom "diffResult", 1 do
1271           assert_dom "> node", 1 do
1272             assert_dom "> @old_id", node.id.to_s
1273             assert_dom "> @new_id", 0
1274             assert_dom "> @new_version", 0
1275           end
1276         end
1277
1278         changeset.reload
1279         assert_equal 1, changeset.num_changes
1280         assert_predicate changeset, :num_type_changes_in_sync?
1281         assert_equal 1, changeset.num_deleted_nodes
1282
1283         node.reload
1284         assert_not node.visible
1285       end
1286
1287       ##
1288       # test that deleting stuff in a transaction doesn't bypass the checks
1289       # to ensure that used elements are not deleted.
1290       def test_upload_delete_referenced_elements
1291         changeset = create(:changeset)
1292         relation = create(:relation)
1293         other_relation = create(:relation)
1294         used_way = create(:way)
1295         used_node = create(:node)
1296         create(:relation_member, :relation => relation, :member => used_way)
1297         create(:relation_member, :relation => relation, :member => used_node)
1298
1299         diff = XML::Document.new
1300         diff.root = XML::Node.new "osmChange"
1301         delete = XML::Node.new "delete"
1302         diff.root << delete
1303         delete << xml_node_for_relation(other_relation)
1304         delete << xml_node_for_way(used_way)
1305         delete << xml_node_for_node(used_node)
1306         %w[node way relation].each do |type|
1307           delete.find("//osmChange/delete/#{type}").each do |n|
1308             n["changeset"] = changeset.id.to_s
1309           end
1310         end
1311
1312         auth_header = bearer_authorization_header changeset.user
1313
1314         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1315
1316         assert_response :precondition_failed
1317         assert_equal "Precondition failed: Way #{used_way.id} is still used by relations #{relation.id}.", @response.body
1318
1319         assert_no_changes_in changeset
1320
1321         assert Node.find(used_node.id).visible
1322         assert Way.find(used_way.id).visible
1323         assert Relation.find(relation.id).visible
1324         assert Relation.find(other_relation.id).visible
1325       end
1326
1327       ##
1328       # test that a conditional delete of an in use object works.
1329       def test_upload_delete_if_unused
1330         changeset = create(:changeset)
1331         super_relation = create(:relation)
1332         used_relation = create(:relation)
1333         used_way = create(:way)
1334         used_node = create(:node)
1335         create(:relation_member, :relation => super_relation, :member => used_relation)
1336         create(:relation_member, :relation => super_relation, :member => used_way)
1337         create(:relation_member, :relation => super_relation, :member => used_node)
1338
1339         diff = XML::Document.new
1340         diff.root = XML::Node.new "osmChange"
1341         delete = XML::Node.new "delete"
1342         diff.root << delete
1343         delete["if-unused"] = ""
1344         delete << xml_node_for_relation(used_relation)
1345         delete << xml_node_for_way(used_way)
1346         delete << xml_node_for_node(used_node)
1347         %w[node way relation].each do |type|
1348           delete.find("//osmChange/delete/#{type}").each do |n|
1349             n["changeset"] = changeset.id.to_s
1350           end
1351         end
1352
1353         auth_header = bearer_authorization_header changeset.user
1354
1355         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1356
1357         assert_response :success
1358
1359         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
1360           assert_dom "> node", 1 do
1361             assert_dom "> @old_id", used_node.id.to_s
1362             assert_dom "> @new_id", used_node.id.to_s
1363             assert_dom "> @new_version", used_node.version.to_s
1364           end
1365           assert_dom "> way", 1 do
1366             assert_dom "> @old_id", used_way.id.to_s
1367             assert_dom "> @new_id", used_way.id.to_s
1368             assert_dom "> @new_version", used_way.version.to_s
1369           end
1370           assert_dom "> relation", 1 do
1371             assert_dom "> @old_id", used_relation.id.to_s
1372             assert_dom "> @new_id", used_relation.id.to_s
1373             assert_dom "> @new_version", used_relation.version.to_s
1374           end
1375         end
1376
1377         assert_no_changes_in changeset
1378
1379         assert Node.find(used_node.id).visible
1380         assert Way.find(used_way.id).visible
1381         assert Relation.find(used_relation.id).visible
1382       end
1383
1384       def test_upload_delete_with_multiple_blocks_and_if_unused
1385         changeset = create(:changeset)
1386         node = create(:node)
1387         way = create(:way)
1388         create(:way_node, :way => way, :node => node)
1389         alone_node = create(:node)
1390
1391         diff = <<~CHANGESET
1392           <osmChange version='0.6'>
1393             <delete version="0.6">
1394               <node id="#{node.id}" version="#{node.version}" changeset="#{changeset.id}"/>
1395             </delete>
1396             <delete version="0.6" if-unused="true">
1397               <node id="#{alone_node.id}" version="#{alone_node.version}" changeset="#{changeset.id}"/>
1398             </delete>
1399           </osmChange>
1400         CHANGESET
1401
1402         auth_header = bearer_authorization_header changeset.user
1403
1404         post api_changeset_upload_path(changeset), :params => diff.to_s, :headers => auth_header
1405
1406         assert_response :precondition_failed
1407         assert_equal "Precondition failed: Node #{node.id} is still used by ways #{way.id}.", @response.body
1408
1409         assert_no_changes_in changeset
1410       end
1411
1412       def test_upload_delete_unknown_node_placeholder
1413         check_upload_results_in_not_found do |changeset|
1414           "<delete><node id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1415         end
1416       end
1417
1418       def test_upload_delete_unknown_way_placeholder
1419         check_upload_results_in_not_found do |changeset|
1420           "<delete><way id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1421         end
1422       end
1423
1424       def test_upload_delete_unknown_relation_placeholder
1425         check_upload_results_in_not_found do |changeset|
1426           "<delete><relation id='-1' changeset='#{changeset.id}' version='1'/></delete>"
1427         end
1428       end
1429
1430       # -------------------------------------
1431       # Test combined element changes.
1432       # -------------------------------------
1433
1434       ##
1435       # upload something which creates new objects and inserts them into
1436       # existing containers using placeholders.
1437       def test_upload_create_and_insert_elements
1438         way = create(:way)
1439         node = create(:node)
1440         relation = create(:relation)
1441         create(:way_node, :way => way, :node => node)
1442         changeset = create(:changeset)
1443
1444         diff = <<~CHANGESET
1445           <osmChange>
1446             <create>
1447               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1448                 <tag k='foo' v='bar'/>
1449                 <tag k='baz' v='bat'/>
1450               </node>
1451             </create>
1452             <modify>
1453               <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
1454                 <nd ref='-1'/>
1455                 <nd ref='#{node.id}'/>
1456               </way>
1457               <relation id='#{relation.id}' changeset='#{changeset.id}' version='1'>
1458                 <member type='way' role='some' ref='#{way.id}'/>
1459                 <member type='node' role='some' ref='-1'/>
1460                 <member type='relation' role='some' ref='#{relation.id}'/>
1461               </relation>
1462             </modify>
1463           </osmChange>
1464         CHANGESET
1465
1466         auth_header = bearer_authorization_header changeset.user
1467
1468         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1469
1470         assert_response :success
1471
1472         new_node_id = nil
1473         assert_dom "diffResult[version='#{Settings.api_version}'][generator='#{Settings.generator}']", 1 do
1474           assert_dom "> node", 1 do |(node_el)|
1475             new_node_id = node_el["new_id"].to_i
1476           end
1477           assert_dom "> way", 1
1478           assert_dom "> relation", 1
1479         end
1480
1481         changeset.reload
1482         assert_equal 3, changeset.num_changes
1483         assert_predicate changeset, :num_type_changes_in_sync?
1484         assert_equal 1, changeset.num_created_nodes
1485         assert_equal 1, changeset.num_modified_ways
1486         assert_equal 1, changeset.num_modified_relations
1487
1488         assert_equal 2, Node.find(new_node_id).tags.size, "new node should have two tags"
1489         assert_equal [new_node_id, node.id], Way.find(way.id).nds, "way nodes should match"
1490         Relation.find(relation.id).members.each do |type, id, _role|
1491           assert_equal new_node_id, id, "relation should contain new node" if type == "node"
1492         end
1493       end
1494
1495       ##
1496       # test that a placeholder can be reused within the same upload.
1497       def test_upload_create_modify_delete_node_reusing_placeholder
1498         changeset = create(:changeset)
1499
1500         diff = <<~CHANGESET
1501           <osmChange>
1502             <create>
1503               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1504                 <tag k="foo" v="bar"/>
1505               </node>
1506             </create>
1507             <modify>
1508               <node id='-1' lon='1' lat='1' changeset='#{changeset.id}' version='1'/>
1509             </modify>
1510             <delete>
1511               <node id='-1' lon='2' lat='2' changeset='#{changeset.id}' version='2'/>
1512             </delete>
1513           </osmChange>
1514         CHANGESET
1515
1516         auth_header = bearer_authorization_header changeset.user
1517
1518         assert_difference "Node.count", 1 do
1519           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1520
1521           assert_response :success
1522         end
1523
1524         assert_dom "diffResult>node", 3
1525         assert_dom "diffResult>node[old_id='-1']", 3
1526
1527         changeset.reload
1528         assert_equal 3, changeset.num_changes
1529         assert_predicate changeset, :num_type_changes_in_sync?
1530         assert_equal 1, changeset.num_created_nodes
1531         assert_equal 1, changeset.num_modified_nodes
1532         assert_equal 1, changeset.num_deleted_nodes
1533
1534         node = Node.last
1535         assert_equal 3, node.version
1536         assert_not node.visible
1537       end
1538
1539       def test_upload_create_and_duplicate_delete
1540         changeset = create(:changeset)
1541
1542         diff = <<~CHANGESET
1543           <osmChange>
1544             <create>
1545               <node id="-1" lat="39" lon="116" changeset="#{changeset.id}" />
1546             </create>
1547             <delete>
1548               <node id="-1" version="1" changeset="#{changeset.id}" />
1549               <node id="-1" version="1" changeset="#{changeset.id}" />
1550             </delete>
1551           </osmChange>
1552         CHANGESET
1553
1554         auth_header = bearer_authorization_header changeset.user
1555
1556         assert_no_difference "Node.count" do
1557           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1558
1559           assert_response :gone
1560         end
1561
1562         assert_no_changes_in changeset
1563       end
1564
1565       def test_upload_create_and_duplicate_delete_if_unused
1566         changeset = create(:changeset)
1567
1568         diff = <<~CHANGESET
1569           <osmChange>
1570             <create>
1571               <node id="-1" lat="39" lon="116" changeset="#{changeset.id}" />
1572             </create>
1573             <delete if-unused="true">
1574               <node id="-1" version="1" changeset="#{changeset.id}" />
1575               <node id="-1" version="1" changeset="#{changeset.id}" />
1576             </delete>
1577           </osmChange>
1578         CHANGESET
1579
1580         auth_header = bearer_authorization_header changeset.user
1581
1582         assert_difference "Node.count", 1 do
1583           post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1584
1585           assert_response :success
1586         end
1587
1588         assert_dom "diffResult>node", 3
1589         assert_dom "diffResult>node[old_id='-1']", 3
1590         assert_dom "diffResult>node[new_version='1']", 1
1591         assert_dom "diffResult>node[new_version='2']", 1
1592
1593         changeset.reload
1594         assert_equal 2, changeset.num_changes
1595         assert_predicate changeset, :num_type_changes_in_sync?
1596         assert_equal 1, changeset.num_created_nodes
1597         assert_equal 1, changeset.num_deleted_nodes
1598
1599         node = Node.last
1600         assert_equal 2, node.version
1601         assert_not node.visible
1602       end
1603
1604       # -------------------------------------
1605       # Test bounding boxes.
1606       # -------------------------------------
1607
1608       def test_upload_bbox_of_widely_spaced_nodes
1609         user = create(:user)
1610
1611         # create an old changeset to ensure we have the maximum rate limit
1612         create(:changeset, :user => user, :created_at => Time.now.utc - 28.days)
1613
1614         changeset = create(:changeset, :user => user)
1615
1616         # upload some widely-spaced nodes, spiralling positive and negative
1617         diff = <<~CHANGESET
1618           <osmChange>
1619             <create>
1620               <node id='-1' lon='-20' lat='-10' changeset='#{changeset.id}'/>
1621               <node id='-10' lon='20'  lat='10' changeset='#{changeset.id}'/>
1622               <node id='-2' lon='-40' lat='-20' changeset='#{changeset.id}'/>
1623               <node id='-11' lon='40'  lat='20' changeset='#{changeset.id}'/>
1624               <node id='-3' lon='-60' lat='-30' changeset='#{changeset.id}'/>
1625               <node id='-12' lon='60'  lat='30' changeset='#{changeset.id}'/>
1626               <node id='-4' lon='-80' lat='-40' changeset='#{changeset.id}'/>
1627               <node id='-13' lon='80'  lat='40' changeset='#{changeset.id}'/>
1628               <node id='-5' lon='-100' lat='-50' changeset='#{changeset.id}'/>
1629               <node id='-14' lon='100'  lat='50' changeset='#{changeset.id}'/>
1630               <node id='-6' lon='-120' lat='-60' changeset='#{changeset.id}'/>
1631               <node id='-15' lon='120'  lat='60' changeset='#{changeset.id}'/>
1632               <node id='-7' lon='-140' lat='-70' changeset='#{changeset.id}'/>
1633               <node id='-16' lon='140'  lat='70' changeset='#{changeset.id}'/>
1634               <node id='-8' lon='-160' lat='-80' changeset='#{changeset.id}'/>
1635               <node id='-17' lon='160'  lat='80' changeset='#{changeset.id}'/>
1636               <node id='-9' lon='-179.9' lat='-89.9' changeset='#{changeset.id}'/>
1637               <node id='-18' lon='179.9'  lat='89.9' changeset='#{changeset.id}'/>
1638             </create>
1639           </osmChange>
1640         CHANGESET
1641
1642         auth_header = bearer_authorization_header user
1643
1644         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1645
1646         assert_response :success
1647
1648         changeset.reload
1649         assert_equal 18, changeset.num_changes
1650         assert_predicate changeset, :num_type_changes_in_sync?
1651         assert_equal 18, changeset.num_created_nodes
1652
1653         # check that the changeset bbox is within bounds
1654         assert_operator changeset.min_lon, :>=, -180 * GeoRecord::SCALE, "Minimum longitude (#{changeset.min_lon / GeoRecord::SCALE}) should be >= -180 to be valid."
1655         assert_operator changeset.max_lon, :<=, 180 * GeoRecord::SCALE, "Maximum longitude (#{changeset.max_lon / GeoRecord::SCALE}) should be <= 180 to be valid."
1656         assert_operator changeset.min_lat, :>=, -90 * GeoRecord::SCALE, "Minimum latitude (#{changeset.min_lat / GeoRecord::SCALE}) should be >= -90 to be valid."
1657         assert_operator changeset.max_lat, :<=, 90 * GeoRecord::SCALE, "Maximum latitude (#{changeset.max_lat / GeoRecord::SCALE}) should be <= 90 to be valid."
1658       end
1659
1660       def test_upload_bbox_of_moved_node
1661         changeset = create(:changeset)
1662         node = create(:node, :lat => 1.0, :lon => 2.0)
1663
1664         diff = <<~CHANGESET
1665           <osmChange>
1666             <modify>
1667               <node id='#{node.id}' lat='1.1' lon='2.1' changeset='#{changeset.id}' version='1'/>
1668             </modify>
1669           </osmChange>
1670         CHANGESET
1671
1672         auth_header = bearer_authorization_header changeset.user
1673
1674         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1675
1676         assert_response :success
1677
1678         changeset.reload
1679         assert_equal 1, changeset.num_changes
1680         assert_predicate changeset, :num_type_changes_in_sync?
1681         assert_equal 1, changeset.num_modified_nodes
1682
1683         # check the bbox
1684         assert_equal 1.0 * GeoRecord::SCALE, changeset.min_lat, "min_lat should be 1.0 degrees"
1685         assert_equal 2.0 * GeoRecord::SCALE, changeset.min_lon, "min_lon should be 2.0 degrees"
1686         assert_equal 1.1 * GeoRecord::SCALE, changeset.max_lat, "max_lat should be 1.1 degrees"
1687         assert_equal 2.1 * GeoRecord::SCALE, changeset.max_lon, "max_lon should be 2.1 degrees"
1688       end
1689
1690       def test_upload_bbox_of_extended_way
1691         way = create(:way)
1692         initial_node = create(:node, :lat => 1.1, :lon => 2.1)
1693         create(:way_node, :way => way, :node => initial_node)
1694         added_node = create(:node, :lat => 1.3, :lon => 2.3)
1695         changeset = create(:changeset)
1696
1697         diff = <<~CHANGESET
1698           <osmChange>
1699             <modify>
1700               <way id='#{way.id}' changeset='#{changeset.id}' version='1'>
1701                 <nd ref='#{initial_node.id}'/>
1702                 <nd ref='#{added_node.id}'/>
1703               </way>
1704             </modify>
1705           </osmChange>
1706         CHANGESET
1707
1708         auth_header = bearer_authorization_header changeset.user
1709
1710         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1711
1712         assert_response :success
1713
1714         changeset.reload
1715         assert_equal 1, changeset.num_changes
1716         assert_predicate changeset, :num_type_changes_in_sync?
1717         assert_equal 1, changeset.num_modified_ways
1718
1719         # check the bbox
1720         assert_equal 1.1 * GeoRecord::SCALE, changeset.min_lat, "min_lat should be 1.1 degrees"
1721         assert_equal 2.1 * GeoRecord::SCALE, changeset.min_lon, "min_lon should be 2.1 degrees"
1722         assert_equal 1.3 * GeoRecord::SCALE, changeset.max_lat, "max_lat should be 1.3 degrees"
1723         assert_equal 2.3 * GeoRecord::SCALE, changeset.max_lon, "max_lon should be 2.3 degrees"
1724       end
1725
1726       # -------------------------------------
1727       # Test upload rate/size limits.
1728       # -------------------------------------
1729
1730       def test_upload_initial_rate_limit
1731         user = create(:user)
1732         node = create(:node)
1733         way = create(:way_with_nodes, :nodes_count => 2)
1734         relation = create(:relation)
1735
1736         # create a changeset that puts us near the initial rate limit
1737         num_changes = Settings.initial_changes_per_hour - 2
1738         changeset = create(:changeset, :user => user,
1739                                        :created_at => Time.now.utc - 5.minutes,
1740                                        :num_changes => num_changes,
1741                                        :num_created_nodes => num_changes)
1742
1743         diff = <<~CHANGESET
1744           <osmChange>
1745             <create>
1746               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1747                 <tag k='foo' v='bar'/>
1748                 <tag k='baz' v='bat'/>
1749               </node>
1750               <way id='-1' changeset='#{changeset.id}'>
1751                 <nd ref='#{node.id}'/>
1752               </way>
1753             </create>
1754             <create>
1755               <relation id='-1' changeset='#{changeset.id}'>
1756                 <member type='way' role='some' ref='#{way.id}'/>
1757                 <member type='node' role='some' ref='#{node.id}'/>
1758                 <member type='relation' role='some' ref='#{relation.id}'/>
1759               </relation>
1760             </create>
1761           </osmChange>
1762         CHANGESET
1763
1764         auth_header = bearer_authorization_header user
1765
1766         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1767
1768         assert_response :too_many_requests, "upload did not hit rate limit"
1769
1770         changeset.reload
1771         assert_equal num_changes, changeset.num_changes
1772         assert_predicate changeset, :num_type_changes_in_sync?
1773       end
1774
1775       def test_upload_maximum_rate_limit
1776         user = create(:user)
1777         node = create(:node)
1778         way = create(:way_with_nodes, :nodes_count => 2)
1779         relation = create(:relation)
1780
1781         # create a changeset to establish our initial edit time
1782         changeset = create(:changeset, :user => user,
1783                                        :created_at => Time.now.utc - 28.days)
1784
1785         # create changeset to put us near the maximum rate limit
1786         remaining_num_changes = Settings.max_changes_per_hour - 2
1787         num_changes = 0
1788         while remaining_num_changes.positive?
1789           num_changes = [remaining_num_changes, Changeset::MAX_ELEMENTS].min
1790           changeset = create(:changeset, :user => user,
1791                                          :created_at => Time.now.utc - 5.minutes,
1792                                          :num_changes => num_changes,
1793                                          :num_created_nodes => num_changes)
1794           remaining_num_changes -= num_changes
1795         end
1796
1797         diff = <<~CHANGESET
1798           <osmChange>
1799             <create>
1800               <node id='-1' lon='0' lat='0' changeset='#{changeset.id}'>
1801                 <tag k='foo' v='bar'/>
1802                 <tag k='baz' v='bat'/>
1803               </node>
1804               <way id='-1' changeset='#{changeset.id}'>
1805                 <nd ref='#{node.id}'/>
1806               </way>
1807             </create>
1808             <create>
1809               <relation id='-1' changeset='#{changeset.id}'>
1810                 <member type='way' role='some' ref='#{way.id}'/>
1811                 <member type='node' role='some' ref='#{node.id}'/>
1812                 <member type='relation' role='some' ref='#{relation.id}'/>
1813               </relation>
1814             </create>
1815           </osmChange>
1816         CHANGESET
1817
1818         auth_header = bearer_authorization_header user
1819
1820         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1821
1822         assert_response :too_many_requests, "upload did not hit rate limit"
1823
1824         changeset.reload
1825         assert_equal num_changes, changeset.num_changes
1826         assert_predicate changeset, :num_type_changes_in_sync?
1827       end
1828
1829       def test_upload_initial_size_limit
1830         user = create(:user)
1831
1832         # create a changeset that puts us near the initial size limit
1833         changeset = create(:changeset, :user => user,
1834                                        :min_lat => (-0.5 * GeoRecord::SCALE).round, :min_lon => (0.5 * GeoRecord::SCALE).round,
1835                                        :max_lat => (0.5 * GeoRecord::SCALE).round, :max_lon => (2.5 * GeoRecord::SCALE).round)
1836
1837         diff = <<~CHANGESET
1838           <osmChange>
1839             <create>
1840               <node id='-1' lon='0.9' lat='2.9' changeset='#{changeset.id}'>
1841                 <tag k='foo' v='bar'/>
1842                 <tag k='baz' v='bat'/>
1843               </node>
1844             </create>
1845           </osmChange>
1846         CHANGESET
1847
1848         auth_header = bearer_authorization_header user
1849
1850         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1851
1852         assert_response :payload_too_large, "upload did not hit size limit"
1853
1854         assert_no_changes_in changeset
1855       end
1856
1857       def test_upload_size_limit_after_one_week
1858         user = create(:user)
1859
1860         # create a changeset to establish our initial edit time
1861         create(:changeset, :user => user, :created_at => Time.now.utc - 7.days)
1862
1863         # create a changeset that puts us near the initial size limit
1864         changeset = create(:changeset, :user => user, :bbox => [0.5, -0.5, 2.5, 0.5])
1865
1866         diff = <<~CHANGESET
1867           <osmChange>
1868             <create>
1869               <node id='-1' lon='35' lat='35' changeset='#{changeset.id}'>
1870                 <tag k='foo' v='bar'/>
1871                 <tag k='baz' v='bat'/>
1872               </node>
1873             </create>
1874           </osmChange>
1875         CHANGESET
1876
1877         auth_header = bearer_authorization_header user
1878
1879         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1880
1881         assert_response :payload_too_large, "upload did not hit size limit"
1882
1883         assert_no_changes_in changeset
1884       end
1885
1886       private
1887
1888       def check_upload_results_in_not_found(&)
1889         changeset = create(:changeset)
1890         diff = "<osmChange>#{yield changeset}</osmChange>"
1891         auth_header = bearer_authorization_header changeset.user
1892
1893         post api_changeset_upload_path(changeset), :params => diff, :headers => auth_header
1894
1895         assert_response :not_found
1896
1897         assert_no_changes_in changeset
1898       end
1899
1900       def assert_no_changes_in(changeset)
1901         changeset.reload
1902         assert_equal 0, changeset.num_changes
1903         assert_predicate changeset, :num_type_changes_in_sync?
1904       end
1905     end
1906   end
1907 end