Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ describe.skipIf(!connectionString && !process.env.CI)('when erasing a subject ag
discoveryPatterns: [],
clientArtifactsProvider: artifacts
}));
store = await client.getEventStore(`PiiEndToEnd${randomUUID().replaceAll('-', '')}`);
store = await client.getEventStore(`Pii${randomUUID().replaceAll('-', '').slice(0, 12)}`);

// The event source is the registration; the explicit subject is the person the PII belongs to.
appended = await store.eventLog.append(eventSourceId, Object.assign(new PersonRegistered(), { personId, name, department: 'Accounting' }), { subject: personId });
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ async function eventually<T>(read: () => Promise<T>, accept: (value: T) => boole
}

describe.skipIf(!connectionString && !process.env.CI)('when replaying an older generation against a kernel', () => {
const eventStoreName = `MigrationReplay${randomUUID().replaceAll('-', '')}`;
const eventStoreName = `Migration${randomUUID().replaceAll('-', '').slice(0, 12)}`;
const eventSourceId = randomUUID();
let firstGenerationClient: ChronicleClient;
let secondGenerationClient: ChronicleClient;
Expand Down Expand Up @@ -134,7 +134,7 @@ describe.skipIf(!connectionString && !process.env.CI)('when replaying an older g

// Registering a second generation without a migration from the first is rejected.
const missingMigrationClient = clientWith(artifactsWith({ eventTypes: [AuthorRegisteredV1, AuthorRegistered] }));
missingMigrationError = await missingMigrationClient.getEventStore(`MigrationReplayMissing${randomUUID().replaceAll('-', '')}`).catch((error: unknown) => error);
missingMigrationError = await missingMigrationClient.getEventStore(`Missing${randomUUID().replaceAll('-', '').slice(0, 12)}`).catch((error: unknown) => error);
missingMigrationClient.dispose();
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ describe.skipIf(!connectionString && !process.env.CI)('when managing a replay jo
discoveryPatterns: [],
clientArtifactsProvider: artifacts
}));
store = await client.getEventStore(`JobsEndToEnd${randomUUID().replaceAll('-', '')}`);
store = await client.getEventStore(`Jobs${randomUUID().replaceAll('-', '').slice(0, 12)}`);

// Enough events that the replay is still running when it is stopped; a stopped job stays until deleted,
// where a completed one is removed and could not be listed reliably.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ describe.skipIf(!connectionString && !process.env.CI)('when registering and remo
discoveryPatterns: [],
clientArtifactsProvider: artifacts
}));
store = await client.getEventStore(`WebhooksEndToEnd${randomUUID().replaceAll('-', '')}`);
store = await client.getEventStore(`Webhooks${randomUUID().replaceAll('-', '').slice(0, 12)}`);

await store.webhooks.register(webhookId, targetUrl, _ => _
.withEventType(OrderShipped)
Expand Down
Loading