Revert Guid types for event source id and partition id (#63)

Author: woksin

Source/eventHorizon/SubscriptionBuilderForProducerStream.ts

@@ -33,9 +33,9 @@ export class SubscriptionBuilderForProducerStream {
 
     /**
      * Sets the producer stream to subscribe to events from.
-     * @param {PartitionId | string} partitionId Stream partition to subscribe to events from.
+     * @param {PartitionId | Guid | string} partitionId Stream partition to subscribe to events from.
      */
-    fromProducerPartition(partitionId: PartitionId | string): SubscriptionBuilderForProducerPartition {
+    fromProducerPartition(partitionId: PartitionId | Guid | string): SubscriptionBuilderForProducerPartition {
         this.throwIfProducerPartitionIsAlreadyDefined();
         this._producerPartitionId = PartitionId.from(partitionId);
         this._builder = new SubscriptionBuilderForProducerPartition(

Source/events.filtering/PartitionedFilterResult.ts

@@ -13,9 +13,9 @@ export class PartitionedFilterResult {
     /**
      * Initializes a new instance of {@link PartitionedFilterResult}.
      * @param {boolean} shouldInclude Tells whether or not the event should be included.
-     * @param {PartitionId | string} partitionId Tells which partition the event should be partitioned into.
+     * @param {PartitionId | Guid | string} partitionId Tells which partition the event should be partitioned into.
      */
-    constructor(readonly shouldInclude: boolean, partitionId: PartitionId | string) {
+    constructor(readonly shouldInclude: boolean, partitionId: PartitionId | Guid | string) {
         this.partitionId = PartitionId.from(partitionId);
     }
 }

Source/events/EventSourceId.ts

@@ -31,8 +31,8 @@ export class EventSourceId extends ConceptAs<string, '@dolittle/sdk.events.Event
      * @param {EventSourceId | Guid | string)} id
      * @returns {EventSourceId}
      */
-    static from(id: EventSourceId | string): EventSourceId {
+    static from(id: EventSourceId | Guid | string): EventSourceId {
         if (id instanceof EventSourceId) return id;
-        return new EventSourceId(id);
+        return new EventSourceId(id.toString());
     }
 };

Source/events/EventStore.ts

@@ -58,9 +58,9 @@ export class EventStore extends IEventStore {
     }
 
     /** @inheritdoc */
-    commit(event: any, eventSourceId: EventSourceId | string, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitEventsResult>;
+    commit(event: any, eventSourceId: EventSourceId | Guid | string, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitEventsResult>;
     commit(eventOrEvents: UncommittedEvent | UncommittedEvent[], cancellation?: Cancellation): Promise<CommitEventsResult>;
-    commit(eventOrEvents: any, eventSourceIdOrCancellation?: EventSourceId | string | Cancellation, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitEventsResult> {
+    commit(eventOrEvents: any, eventSourceIdOrCancellation?: EventSourceId | Guid | string | Cancellation, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitEventsResult> {
         if (this.isUncommittedEventOrEvents(eventOrEvents)) {
             return this.commitInternal(this.asArray(eventOrEvents), eventSourceIdOrCancellation as Cancellation);
         }
@@ -69,16 +69,16 @@ export class EventStore extends IEventStore {
     }
 
     /** @inheritdoc */
-    commitPublic(event: any, eventSourceId: EventSourceId | string, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitEventsResult> {
+    commitPublic(event: any, eventSourceId: EventSourceId | Guid | string, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitEventsResult> {
         const events: UncommittedEvent[] = [this.toUncommittedEvent(event, eventSourceId, eventType, true)];
         return this.commitInternal(events, cancellation);
     }
 
     /** @inheritdoc */
     /** @inheritdoc */
-    commitForAggregate(event: any, eventSourceId: EventSourceId | string, aggregateRootId: AggregateRootId, expectedAggregateRootVersion: AggregateRootVersion, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitAggregateEventsResult>;
+    commitForAggregate(event: any, eventSourceId: EventSourceId | Guid | string, aggregateRootId: AggregateRootId, expectedAggregateRootVersion: AggregateRootVersion, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitAggregateEventsResult>;
     commitForAggregate(events: UncommittedAggregateEvents, cancellation?: Cancellation): Promise<CommitAggregateEventsResult>;
-    commitForAggregate(eventOrEvents: any, eventSourceIdOrCancellation?: EventSourceId | string | Cancellation, aggregateRootId?: AggregateRootId, expectedAggregateRootVersion?: AggregateRootVersion, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitAggregateEventsResult> {
+    commitForAggregate(eventOrEvents: any, eventSourceIdOrCancellation?: EventSourceId | Guid | string | Cancellation, aggregateRootId?: AggregateRootId, expectedAggregateRootVersion?: AggregateRootVersion, eventType?: EventType | EventTypeId | Guid | string, cancellation?: Cancellation): Promise<CommitAggregateEventsResult> {
         if (this.isUncommittedAggregateEvents(eventOrEvents)) {
             return this.commitAggregateInternal(eventOrEvents, eventSourceIdOrCancellation as Cancellation);
         }
@@ -193,7 +193,7 @@ export class EventStore extends IEventStore {
         return new CommittedAggregateEvents(eventSourceId, aggregateRootId, ...convertedEvents);
     }
 
-    private toUncommittedEvent(content: any, eventSourceId: EventSourceId | string, eventTypeOrId?: EventType | EventTypeId | Guid | string, isPublic = false): UncommittedEvent {
+    private toUncommittedEvent(content: any, eventSourceId: EventSourceId | Guid | string, eventTypeOrId?: EventType | EventTypeId | Guid | string, isPublic = false): UncommittedEvent {
         let eventType: EventType | EventTypeId | undefined;
         if (eventTypeOrId !== undefined) {
             if (eventTypeOrId instanceof EventType) eventType = eventTypeOrId;

Source/events/PartitionId.ts

@@ -21,11 +21,11 @@ export class PartitionId extends ConceptAs<string, '@dolittle/sdk.events.Partiti
      * Creates a {PartitionId} from a guid.
      *
      * @static
-     * @param {PartitionId |  string} id
+     * @param {PartitionId | Guid | string} id
      * @returns {PartitionId}
      */
-    static from(id: PartitionId | string): PartitionId {
+    static from(id: PartitionId | Guid | string): PartitionId {
         if (id instanceof PartitionId) return id;
-        return new PartitionId(id);
+        return new PartitionId(id.toString());
     }
 };