WIP ArtifactRepository.Get()

emacsway · May 24, 2024 · fa8287d · fa8287d
1 parent 5fcbd15
commit fa8287d
Show file tree

Hide file tree

Showing 4 changed files with 42 additions and 27 deletions.
diff --git a/grade/internal/infrastructure/repositories/artifact/artifact_repository.go b/grade/internal/infrastructure/repositories/artifact/artifact_repository.go
@@ -14,7 +14,7 @@ import (
 func NewArtifactRepository(currentSession session.DbSession) *ArtifactRepository {
 	return &ArtifactRepository{
 		session:    currentSession,
-		eventStore: repository.NewEventStore(currentSession, "Artifact", eventQuery),
+		eventStore: repository.NewEventStore(currentSession, "Artifact", eventToQuery),
 	}
 }
 
@@ -32,10 +32,35 @@ func (r *ArtifactRepository) NextId(tenantId tenantVal.TenantId) (artifactVal.Ar
 	return q.Get(r.session)
 }
 
-func eventQuery(iEvent aggregate.PersistentDomainEvent) (q session.EventSourcedQueryEvaluator) {
+func (r *ArtifactRepository) Get(id artifactVal.ArtifactId) (*artifact.Artifact, error) {
+	idExporter := &artifactVal.ArtifactIdExporter{}
+	id.Export(idExporter)
+	streamId, err := r.eventStore.NewStreamId(int(idExporter.TenantId), idExporter.ArtifactId.String())
+	if err != nil {
+		return nil, err
+	}
+	q := repository.EventGetQuery{
+		StreamId:           streamId,
+		EventReconstitutor: rowsToEvent,
+	}
+	stream, err := q.Stream(r.session)
+	if err != nil {
+		return nil, err
+	}
+	rec := &artifact.ArtifactReconstitutor{
+		PastEvents: stream,
+	}
+	return rec.Reconstitute()
+}
+
+func eventToQuery(iEvent aggregate.PersistentDomainEvent) (q session.EventSourcedQueryEvaluator) {
 	switch event := iEvent.(type) {
 	case *events.ArtifactProposed:
 		q = queries.NewArtifactProposedQuery(event)
 	}
 	return q
 }
+
+func rowsToEvent(*session.Rows) (aggregate.PersistentDomainEvent, error) {
+	return nil, nil
+}
diff --git a/grade/internal/infrastructure/repositories/artifact/queries/artifact_get_query.go b/grade/internal/infrastructure/repositories/artifact/queries/artifact_get_query.go
diff --git a/grade/internal/infrastructure/seedwork/repository/event_get_query.go b/grade/internal/infrastructure/seedwork/repository/event_get_query.go
@@ -5,9 +5,12 @@ import (
 	"github.com/emacsway/grade/grade/internal/infrastructure/seedwork/session"
 )
 
+type EventReconstitutor func(*session.Rows) (aggregate.PersistentDomainEvent, error)
+
 type EventGetQuery struct {
-	StreamId      StreamId
-	SincePosition uint
+	StreamId           StreamId
+	SincePosition      uint
+	EventReconstitutor EventReconstitutor
 }
 
 func (q EventGetQuery) sql() string {
@@ -32,10 +35,12 @@ func (q *EventGetQuery) Stream(s session.DbSessionQuerier) ([]aggregate.Persiste
 	}
 	defer rows.Close()
 	for rows.Next() {
-		err := rows.Scan() // TODO: implement me
+		// err := rows.Scan() // TODO: implement me
+		event, err := q.EventReconstitutor(&rows)
 		if err != nil {
 			return nil, err
 		}
+		stream = append(stream, event)
 	}
 	err = rows.Err()
 	if err != nil {

diff --git a/grade/internal/infrastructure/seedwork/repository/event_store.go b/grade/internal/infrastructure/seedwork/repository/event_store.go
@@ -21,6 +21,13 @@ type EventStore struct {
 	eventQuery EventQueryFactory
 }
 
+func (r EventStore) NewStreamId(
+	tenantId int,
+	streamId string,
+) (StreamId, error) {
+	return NewStreamId(tenantId, r.streamType, streamId)
+}
+
 func (r *EventStore) Save(
 	agg aggregate.DomainEventAccessor[aggregate.PersistentDomainEvent],
 	eventMeta aggregate.EventMeta,