|
|
@ -54,21 +54,21 @@ namespace Migrations.Migrations.MongoDb |
|
|
|
|
|
|
|
|
if (TryGetAppId(document, out var appId)) |
|
|
if (TryGetAppId(document, out var appId)) |
|
|
{ |
|
|
{ |
|
|
var indexOfType = eventStream.IndexOf('-'); |
|
|
if (!eventStream.StartsWith("app-", StringComparison.OrdinalIgnoreCase)) |
|
|
var indexOfId = indexOfType + 1; |
|
|
{ |
|
|
|
|
|
var indexOfType = eventStream.IndexOf('-'); |
|
|
|
|
|
var indexOfId = indexOfType + 1; |
|
|
|
|
|
|
|
|
var indexOfOldId = eventStream.LastIndexOf("--", StringComparison.OrdinalIgnoreCase); |
|
|
var indexOfOldId = eventStream.LastIndexOf("--", StringComparison.OrdinalIgnoreCase); |
|
|
|
|
|
|
|
|
if (indexOfOldId > 0) |
|
|
if (indexOfOldId > 0) |
|
|
{ |
|
|
{ |
|
|
indexOfId = indexOfOldId + 2; |
|
|
indexOfId = indexOfOldId + 2; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
var domainType = eventStream.Substring(0, indexOfType); |
|
|
var domainType = eventStream.Substring(0, indexOfType); |
|
|
var domainId = eventStream[indexOfId..]; |
|
|
var domainId = eventStream[indexOfId..]; |
|
|
|
|
|
|
|
|
if (!eventStream.StartsWith("app-", StringComparison.OrdinalIgnoreCase)) |
|
|
|
|
|
{ |
|
|
|
|
|
var newDomainId = DomainId.Combine(DomainId.Create(appId), DomainId.Create(domainId)).ToString(); |
|
|
var newDomainId = DomainId.Combine(DomainId.Create(appId), DomainId.Create(domainId)).ToString(); |
|
|
var newStreamName = $"{domainType}-{newDomainId}"; |
|
|
var newStreamName = $"{domainType}-{newDomainId}"; |
|
|
|
|
|
|
|
|
|