[fix] Backport issues found with #67 (#71)

Author: marcellanz

cloudstate/discovery/server.go

@@ -138,8 +138,9 @@ func (s *EntityDiscoveryServer) RegisterCRDTEntity(entity *crdt.Entity, config p
 		return fmt.Errorf("failed to resolveFileDescriptor for DescriptorConfig: %+v: %w", config, err)
 	}
 	s.entitySpec.Entities = append(s.entitySpec.Entities, &protocol.Entity{
-		EntityType:  protocol.CRDT,
-		ServiceName: entity.ServiceName.String(),
+		EntityType:    protocol.CRDT,
+		ServiceName:   entity.ServiceName.String(),
+		PersistenceId: entity.ServiceName.String(), // make sure CRDT entities have unique keys per service
 	})
 	return s.updateSpec()
 }

cloudstate/eventsourced/context.go

@@ -94,6 +94,13 @@ func (c *Context) fail(err error) {
 	c.failed = err
 }
 
+func (c *Context) reset() {
+	c.events = nil
+	c.failed = nil
+	c.forward = nil
+	c.sideEffects = nil
+}
+
 func (c *Context) resetSnapshotEvery() {
 	c.shouldSnapshot = false
 }

cloudstate/eventsourced/server.go

@@ -128,6 +128,7 @@ func (s *Server) handle(stream entity.EventSourced_HandleServer) error {
 			// see: https://github.com/cloudstateio/cloudstate/pull/119#discussion_r444851439
 			return fmt.Errorf("failed context was not reported: %w", r.context.failed)
 		}
+		r.context.reset()
 		msg, err := r.stream.Recv()
 		switch err {
 		case nil: