main.go

@@ -42,8 +42,8 @@ type InterServiceMessage struct {
 
 // NewServiceInitializationInformation creates a new ServiceInitializationInformation and is only ever meant to be called
 // by fulgens or a compliant implementation of fulgens.
-func NewServiceInitializationInformation(domain *string, outbox chan<- InterServiceMessage, inbox <-chan InterServiceMessage, router *chi.Mux, configuration map[string]interface{}, resourceDir fs.FS) *ServiceInitializationInformation {
+func NewServiceInitializationInformation(domain *string, outbox chan<- InterServiceMessage, inbox <-chan InterServiceMessage, router *chi.Mux, configuration map[string]interface{}, resourceDir fs.FS) ServiceInitializationInformation {
-	return &ServiceInitializationInformation{
+	return ServiceInitializationInformation{
 		Domain:        domain,
 		Outbox:        outbox,
 		inbox:         inbox,
@@ -108,6 +108,7 @@ const (
 
 func (s *ServiceInitializationInformation) StartISProcessor() {
 	if s.internal.ispStarted {
+		println("IS Processor already started")
 		return
 	} else {
 		s.internal.ispStarted = true
@@ -115,6 +116,7 @@ func (s *ServiceInitializationInformation) StartISProcessor() {
 	listener := NewListener(s.inbox)
 	for {
 		msg := listener.AcceptMessage()
+		println("Received message on ID: " + msg.ForServiceID.String() + "for id: " + msg.MessageID.String())
 		s.internal.mutex.Lock()
 		s.internal.buffer[msg.MessageID] = msg
 		s.internal.mutex.Unlock()
@@ -158,7 +160,9 @@ func NewListener(c <-chan InterServiceMessage) Listener {
 }
 
 func (l DefaultListener) AcceptMessage() InterServiceMessage {
+	println("Listener has pointer address: ", l)
 	msg := <-l
+	println("Received message on ID: " + msg.ForServiceID.String())
 	return msg
 }
 
@@ -179,12 +183,13 @@ func (s *ServiceInitializationInformation) SendISMessage(forService uuid.UUID, m
 	return id
 }
 
-func (s *InterServiceMessage) Respond(messageType MessageCode, message any, information *ServiceInitializationInformation) {
+func (s *InterServiceMessage) Respond(messageType MessageCode, message any, information ServiceInitializationInformation) {
 	n := *s
 	n.ServiceID, n.ForServiceID = n.ForServiceID, n.ServiceID
 	n.MessageType = messageType
 	n.Message = message
 	n.SentAt = time.Now()
+	println(information.Outbox)
 	information.Outbox <- n
 }