mirror of
https://github.com/google/nomulus.git
synced 2025-05-05 14:37:52 +02:00
3f1a8eebdc
As part of our commit log layer that we have built on top of Objectify, we enforce the constraint of a monotonically increasing transaction time with a millisecond granularity. Thus, if two transactions occur at exactly the same millisecond, as had been the case with these tests, one will get a TimestampInversionException and retry. However, since we're mocking time in these tests as well, they will retry at exactly the same millisecond, and thus continue failing for the same reason until the max retry threshold is hit. The EPP flow then ultimately fails with a generic "Command failed" response. All of this is actual findings from looking at test logs from a flake. It's a mystery to me why these tests were merely flaky; it seems like they should have always been failing for this reason, but they were still only sometimes failing. Who knows. The fix is simple -- Adjust the tests so that no two commands are run at exactly the same millisecond. Note that this is a test-only problem; in the real world, a command that temporarily fails will simply then succeed the next time it is retried, since time is actually elapsing. This implies that our commit log system imposes a max mutation rate of 1,000 QPS across our entire system. This is unlikely to be a problem in practice for any existing registry of any size. Also note that, as far the EPP XML itself is concerned, times only have second granularity, so up to a thousand commands can execute in the same second and still "appear" to have taken place at the same time as far as EPP is concerned. That's why this CL only adds millisecond precision to the actual run time, not to the expected values in the commands. ------------- Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=184777558
271 lines
11 KiB
Java
271 lines
11 KiB
Java
// Copyright 2017 The Nomulus Authors. All Rights Reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package google.registry.flows;
|
|
|
|
import static com.google.common.truth.Truth.assertThat;
|
|
import static google.registry.model.EppResourceUtils.loadByForeignKey;
|
|
import static google.registry.model.eppoutput.Result.Code.SUCCESS;
|
|
import static google.registry.model.eppoutput.Result.Code.SUCCESS_WITH_ACTION_PENDING;
|
|
import static google.registry.testing.DatastoreHelper.createTld;
|
|
import static google.registry.testing.DatastoreHelper.createTlds;
|
|
import static google.registry.testing.EppMetricSubject.assertThat;
|
|
import static google.registry.testing.HostResourceSubject.assertAboutHosts;
|
|
|
|
import com.google.common.collect.ImmutableMap;
|
|
import com.googlecode.objectify.Key;
|
|
import google.registry.model.domain.DomainResource;
|
|
import google.registry.model.host.HostResource;
|
|
import google.registry.testing.AppEngineRule;
|
|
import org.joda.time.DateTime;
|
|
import org.junit.Rule;
|
|
import org.junit.Test;
|
|
import org.junit.runner.RunWith;
|
|
import org.junit.runners.JUnit4;
|
|
|
|
/** Tests for host lifecycle. */
|
|
@RunWith(JUnit4.class)
|
|
public class EppLifecycleHostTest extends EppTestCase {
|
|
|
|
@Rule
|
|
public final AppEngineRule appEngine = AppEngineRule.builder()
|
|
.withDatastore()
|
|
.withTaskQueue()
|
|
.build();
|
|
|
|
@Test
|
|
public void testLifecycle() throws Exception {
|
|
assertCommandAndResponse("login_valid.xml", "login_response.xml");
|
|
assertCommandAndResponse(
|
|
"hello.xml",
|
|
ImmutableMap.of(),
|
|
"greeting.xml",
|
|
ImmutableMap.of("DATE", "2000-06-02T00:00:00Z"),
|
|
DateTime.parse("2000-06-02T00:00:00Z"));
|
|
// Note that Hello commands don't set a status code on the response.
|
|
assertThat(getRecordedEppMetric())
|
|
.hasClientId("NewRegistrar")
|
|
.and()
|
|
.hasCommandName("Hello")
|
|
.and()
|
|
.hasNoStatus();
|
|
assertCommandAndResponse(
|
|
"host_create.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.tld"),
|
|
"host_create_response.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.tld", "CRDATE", "2000-06-02T00:01:00Z"),
|
|
DateTime.parse("2000-06-02T00:01:00Z"));
|
|
assertThat(getRecordedEppMetric())
|
|
.hasClientId("NewRegistrar")
|
|
.and()
|
|
.hasCommandName("HostCreate")
|
|
.and()
|
|
.hasEppTarget("ns1.example.tld")
|
|
.and()
|
|
.hasStatus(SUCCESS);
|
|
assertCommandAndResponse(
|
|
"host_info.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.tld"),
|
|
"host_info_response.xml",
|
|
ImmutableMap.of(
|
|
"HOSTNAME", "ns1.example.tld", "ROID", "1-ROID", "CRDATE", "2000-06-02T00:01:00Z"),
|
|
DateTime.parse("2000-06-02T00:02:00Z"));
|
|
assertThat(getRecordedEppMetric())
|
|
.hasClientId("NewRegistrar")
|
|
.and()
|
|
.hasCommandName("HostInfo")
|
|
.and()
|
|
.hasEppTarget("ns1.example.tld")
|
|
.and()
|
|
.hasStatus(SUCCESS);
|
|
assertCommandAndResponse(
|
|
"host_delete.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.tld"),
|
|
"generic_success_action_pending_response.xml",
|
|
ImmutableMap.of(),
|
|
DateTime.parse("2000-06-02T00:03:00Z"));
|
|
assertThat(getRecordedEppMetric())
|
|
.hasClientId("NewRegistrar")
|
|
.and()
|
|
.hasCommandName("HostDelete")
|
|
.and()
|
|
.hasEppTarget("ns1.example.tld")
|
|
.and()
|
|
.hasStatus(SUCCESS_WITH_ACTION_PENDING);
|
|
assertCommandAndResponse("logout.xml", "logout_response.xml");
|
|
}
|
|
|
|
@Test
|
|
public void testRenamingHostToExistingHost_fails() throws Exception {
|
|
createTld("example");
|
|
assertCommandAndResponse("login_valid.xml", "login_response.xml");
|
|
// Create the fakesite domain.
|
|
assertCommandAndResponse(
|
|
"contact_create_sh8013.xml",
|
|
ImmutableMap.of(),
|
|
"contact_create_response_sh8013.xml",
|
|
ImmutableMap.of("CRDATE", "2000-06-01T00:00:00Z"),
|
|
DateTime.parse("2000-06-01T00:00:00Z"));
|
|
assertCommandAndResponse(
|
|
"contact_create_jd1234.xml",
|
|
"contact_create_response_jd1234.xml",
|
|
DateTime.parse("2000-06-01T00:01:00Z"));
|
|
assertCommandAndResponse(
|
|
"domain_create_fakesite_no_nameservers.xml",
|
|
ImmutableMap.of(),
|
|
"domain_create_response.xml",
|
|
ImmutableMap.of(
|
|
"NAME", "fakesite.example",
|
|
"CRDATE", "2000-06-01T00:04:00.0Z",
|
|
"EXDATE", "2002-06-01T00:04:00.0Z"),
|
|
DateTime.parse("2000-06-01T00:04:00Z"));
|
|
assertCommandAndResponse(
|
|
"domain_info_fakesite.xml",
|
|
"domain_info_response_fakesite_inactive.xml",
|
|
DateTime.parse("2000-06-05T00:02:00Z"));
|
|
// Add the fakesite subordinate host (requires that domain is already created).
|
|
assertCommandAndResponse(
|
|
"host_create_fakesite.xml",
|
|
"host_create_response_fakesite.xml",
|
|
DateTime.parse("2000-06-06T00:01:00Z"));
|
|
// Add the 2nd fakesite subordinate host.
|
|
assertCommandAndResponse(
|
|
"host_create_fakesite2.xml",
|
|
"host_create_response_fakesite2.xml",
|
|
DateTime.parse("2000-06-09T00:01:00Z"));
|
|
// Attempt overwriting of 2nd fakesite subordinate host with the 1st.
|
|
assertCommandAndResponse(
|
|
"host_update_fakesite1_to_fakesite2.xml",
|
|
ImmutableMap.of(),
|
|
"response_error.xml",
|
|
ImmutableMap.of(
|
|
"MSG", "Object with given ID (ns4.fakesite.example) already exists", "CODE", "2302"),
|
|
DateTime.parse("2000-06-10T00:01:00Z"));
|
|
// Verify that fakesite hosts still exist in their unmodified states.
|
|
assertCommandAndResponse(
|
|
"host_info_fakesite.xml",
|
|
"host_info_response_fakesite_ok.xml",
|
|
DateTime.parse("2000-06-11T00:07:00Z"));
|
|
assertCommandAndResponse(
|
|
"host_info_fakesite2.xml",
|
|
"host_info_response_fakesite2.xml",
|
|
DateTime.parse("2000-06-11T00:08:00Z"));
|
|
assertCommandAndResponse("logout.xml", "logout_response.xml");
|
|
}
|
|
|
|
@Test
|
|
public void testSuccess_multipartTldsWithSharedSuffixes() throws Exception {
|
|
createTlds("bar.foo.tld", "foo.tld", "tld");
|
|
|
|
assertCommandAndResponse("login_valid.xml", "login_response.xml");
|
|
|
|
assertCommandAndResponse(
|
|
"contact_create_sh8013.xml",
|
|
ImmutableMap.of(),
|
|
"contact_create_response_sh8013.xml",
|
|
ImmutableMap.of("CRDATE", "2000-06-01T00:00:00Z"),
|
|
DateTime.parse("2000-06-01T00:00:00Z"));
|
|
assertCommandAndResponse(
|
|
"contact_create_jd1234.xml",
|
|
"contact_create_response_jd1234.xml",
|
|
DateTime.parse("2000-06-01T00:01:00Z"));
|
|
|
|
// Create domain example.bar.foo.tld
|
|
assertCommandAndResponse(
|
|
"domain_create_wildcard.xml",
|
|
ImmutableMap.of("HOSTNAME", "example.bar.foo.tld"),
|
|
"domain_create_response.xml",
|
|
ImmutableMap.of(
|
|
"NAME", "example.bar.foo.tld",
|
|
"CRDATE", "2000-06-01T00:02:00Z",
|
|
"EXDATE", "2002-06-01T00:02:00Z"),
|
|
DateTime.parse("2000-06-01T00:02:00.000Z"));
|
|
|
|
// Create domain example.foo.tld
|
|
assertCommandAndResponse(
|
|
"domain_create_wildcard.xml",
|
|
ImmutableMap.of("HOSTNAME", "example.foo.tld"),
|
|
"domain_create_response.xml",
|
|
ImmutableMap.of(
|
|
"NAME", "example.foo.tld",
|
|
"CRDATE", "2000-06-01T00:02:00Z",
|
|
"EXDATE", "2002-06-01T00:02:00Z"),
|
|
DateTime.parse("2000-06-01T00:02:00.001Z"));
|
|
|
|
// Create domain example.tld
|
|
assertCommandAndResponse(
|
|
"domain_create_wildcard.xml",
|
|
ImmutableMap.of("HOSTNAME", "example.tld"),
|
|
"domain_create_response.xml",
|
|
ImmutableMap.of(
|
|
"NAME", "example.tld",
|
|
"CRDATE", "2000-06-01T00:02:00Z",
|
|
"EXDATE", "2002-06-01T00:02:00Z"),
|
|
DateTime.parse("2000-06-01T00:02:00.002Z"));
|
|
|
|
// Create host ns1.example.bar.foo.tld
|
|
assertCommandAndResponse(
|
|
"host_create_with_ips.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.bar.foo.tld"),
|
|
"host_create_response.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.bar.foo.tld", "CRDATE", "2000-06-01T00:03:00Z"),
|
|
DateTime.parse("2000-06-01T00:03:00Z"));
|
|
|
|
// Create host ns1.example.foo.tld
|
|
assertCommandAndResponse(
|
|
"host_create_with_ips.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.foo.tld"),
|
|
"host_create_response.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.foo.tld", "CRDATE", "2000-06-01T00:04:00Z"),
|
|
DateTime.parse("2000-06-01T00:04:00Z"));
|
|
|
|
// Create host ns1.example.tld
|
|
assertCommandAndResponse(
|
|
"host_create_with_ips.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.tld"),
|
|
"host_create_response.xml",
|
|
ImmutableMap.of("HOSTNAME", "ns1.example.tld", "CRDATE", "2000-06-01T00:05:00Z"),
|
|
DateTime.parse("2000-06-01T00:05:00Z"));
|
|
|
|
DateTime timeAfterCreates = DateTime.parse("2000-06-01T00:06:00Z");
|
|
|
|
HostResource exampleBarFooTldHost =
|
|
loadByForeignKey(HostResource.class, "ns1.example.bar.foo.tld", timeAfterCreates);
|
|
DomainResource exampleBarFooTldDomain =
|
|
loadByForeignKey(DomainResource.class, "example.bar.foo.tld", timeAfterCreates);
|
|
assertAboutHosts()
|
|
.that(exampleBarFooTldHost)
|
|
.hasSuperordinateDomain(Key.create(exampleBarFooTldDomain));
|
|
assertThat(exampleBarFooTldDomain.getSubordinateHosts())
|
|
.containsExactly("ns1.example.bar.foo.tld");
|
|
|
|
HostResource exampleFooTldHost =
|
|
loadByForeignKey(HostResource.class, "ns1.example.foo.tld", timeAfterCreates);
|
|
DomainResource exampleFooTldDomain =
|
|
loadByForeignKey(DomainResource.class, "example.foo.tld", timeAfterCreates);
|
|
assertAboutHosts()
|
|
.that(exampleFooTldHost)
|
|
.hasSuperordinateDomain(Key.create(exampleFooTldDomain));
|
|
assertThat(exampleFooTldDomain.getSubordinateHosts()).containsExactly("ns1.example.foo.tld");
|
|
|
|
HostResource exampleTldHost =
|
|
loadByForeignKey(HostResource.class, "ns1.example.tld", timeAfterCreates);
|
|
DomainResource exampleTldDomain =
|
|
loadByForeignKey(DomainResource.class, "example.tld", timeAfterCreates);
|
|
assertAboutHosts().that(exampleTldHost).hasSuperordinateDomain(Key.create(exampleTldDomain));
|
|
assertThat(exampleTldDomain.getSubordinateHosts()).containsExactly("ns1.example.tld");
|
|
|
|
assertCommandAndResponse("logout.xml", "logout_response.xml");
|
|
}
|
|
}
|