domain

type AggregateDataModel struct {
	*EntityDataModel
	OriginalVersion int64 `json:"originalVersion" bson:"originalVersion,omitempty"`
}

type AggregateRoot struct {
	*Entity
	// contains filtered or unexported fields
}

type DomainEvent struct {
	*events.Event
	AggregateId             uuid.UUID `json:"aggregate_id"`
	AggregateSequenceNumber int64     `json:"aggregate_sequence_number"`
}

type Entity struct {
	// contains filtered or unexported fields
}

type EntityDataModel struct {
	Id         uuid.UUID `json:"id"          bson:"id,omitempty"`
	EntityType string    `json:"entity_type" bson:"entity_type,omitempty"`
	CreatedAt  time.Time `json:"created_at"  bson:"created_at,omitempty"`
	UpdatedAt  time.Time `json:"updated_at"  bson:"updated_at"`
}

type EventEnvelope struct {
	EventData interface{}
	Metadata  metadata.Metadata
}

type IAggregateRoot interface {
	IEntity

	// OriginalVersion Gets the original version is the aggregate version we got from the store. This is used to ensure optimistic concurrency,
	// to check if there were no changes made to the aggregate state between load and save for the current operation.
	OriginalVersion() int64

	// AddDomainEvents adds a new domain_events event to the aggregate's uncommitted events.
	AddDomainEvents(event IDomainEvent) error

	// MarkUncommittedEventAsCommitted Mark all changes (events) as committed, clears uncommitted changes and updates the current version of the aggregate.
	MarkUncommittedEventAsCommitted()

	// HasUncommittedEvents Does the aggregate have change that have not been committed to storage
	HasUncommittedEvents() bool

	// GetUncommittedEvents Gets a list of uncommitted events for this aggregate.
	GetUncommittedEvents() []IDomainEvent

	// String Returns a string representation of the aggregate.
	String() string
}

type IDomainEvent interface {
	events.IEvent
	GetAggregateId() uuid.UUID
	GetAggregateSequenceNumber() int64
	WithAggregate(aggregateId uuid.UUID, aggregateSequenceNumber int64) *DomainEvent
}

type IEntity interface {
	Id() uuid.UUID
	CreatedAt() time.Time
	UpdatedAt() time.Time
	SetUpdatedAt(updatedAt time.Time)
	SetEntityType(entityType string)
	SetId(id uuid.UUID)
}