Adds Send method to Address

address.go

@@ -5,14 +5,10 @@ import (
 	"os"
 	"strings"
 
+	"github.com/mustafaturan/bus"
 	"pkg.glorieux.io/mantra/internal/log"
 )
 
-// Addressable means a type has an Address
-type Addressable interface {
-	Address() *Address
-}
-
 // Address is a service's address
 type Address struct {
 	// TODO find a better representation
@@ -46,6 +42,16 @@ func parseAddress(a string) *Address {
 	}
 }
 
+// Send sends a message
+func (a *Address) Send(method string, args ...interface{}) {
+	topic := newTopic(a, method)
+	log.Debug("TOPIC: ", topic)
+	_, err := bus.Emit(topic.String(), args, "")
+	if err != nil {
+		log.Error(err)
+	}
+}
+
 func (a *Address) String() string {
 	return fmt.Sprintf(
 		"%d@%s#%s",

internal/structs/structs_test.go

@@ -28,7 +28,6 @@ func TestName(t *testing.T) {
 		testInt := TestInt(42)
 		assert.Equal(t, "TestInt", structs.Name(testInt))
 	})
-
 }
 
 func TestMethods(t *testing.T) {

mantra.go

@@ -60,6 +60,7 @@ func Stop() {
 }
 
 // Send supperseeds Send
+// Deprecated: use it from address directly
 func Send(address *Address, method interface{}, args ...interface{}) {
 	topic := newTopic(address, structs.FuncName(method))
 	log.Debug("TOPIC: ", topic)

mantra_test.go

@@ -34,9 +34,10 @@ func TestServiceCommunication(t *testing.T) {
 		t.Error(err)
 	}
 
+	ts := mantra.Lookup("testService")
+	ts.Send("TestWithoutParams")
 	ack := make(chan string)
-	mantra.Send(mantra.Lookup("testService"), ts1.TestWithoutParams)
-	mantra.Send(mantra.Lookup("testService"), ts1.TestMessage, ack)
+	ts.Send("TestMessage", ack)
 	assert.NotEmpty(t, <-ack)
 	mantra.Stop()
 }

sms/sms_test.go

@@ -18,6 +18,7 @@ func TestMain(m *testing.M) {
 func TestSend(t *testing.T) {
 	s := sms.New("", "", func(*sms.Message) error { return nil })
 	mantra.New(s)
-	mantra.Send(mantra.Lookup("ShortMessageService"), s.Send, &sms.Message{})
+	shortMessageService := mantra.Lookup("ShortMessageService")
+	shortMessageService.Send("Send", &sms.Message{})
 	mantra.Stop()
 }