Merge pull request #16 from official-stallion/15-connection-uri

15 connection uri

README.md

@@ -3,8 +3,8 @@
 </p>
 
 <p align="center">
-<img src="https://img.shields.io/badge/Golang-1.18-66ADD8?style=for-the-badge&logo=go" alt="go version" />
-<img src="https://img.shields.io/badge/Version-1.1.2-red?style=for-the-badge&logo=github" alt="version" /><br />
+<img src="https://img.shields.io/badge/Golang-1.19-66ADD8?style=for-the-badge&logo=go" alt="go version" />
+<img src="https://img.shields.io/badge/Version-1.1.3-red?style=for-the-badge&logo=github" alt="version" /><br />
 <img src="https://img.shields.io/badge/MacOS-black?style=for-the-badge&logo=apple" alt="version" />
 <img src="https://img.shields.io/badge/Linux-white?style=for-the-badge&logo=linux" alt="version" />
 <img src="https://img.shields.io/badge/Windows-blue?style=for-the-badge&logo=windows" alt="version" />
@@ -51,7 +51,7 @@ import (
 )
 
 func main() {
-	client, err := stallion.NewClient("localhost:9090")
+	client, err := stallion.NewClient("st://localhost:9090")
 	if err != nil {
 		panic(err)
 	}

client.go

@@ -22,7 +22,12 @@ type Client interface {
 
 // NewClient creates a new client to connect to broker server.
 func NewClient(uri string) (Client, error) {
-	conn, err := net.Dial("tcp", uri)
+	url, err := urlUnpack(uri)
+	if err != nil {
+		return nil, fmt.Errorf("invalid uri: %w", err)
+	}
+
+	conn, err := net.Dial("tcp", url.address)
 	if err != nil {
 		return nil, fmt.Errorf("failed to connect to server: %w", err)
 	}

example/client/multi-subscribe/main.go

@@ -8,14 +8,14 @@ import (
 )
 
 func main() {
-	client, err := stallion.NewClient("localhost:9090")
+	client, err := stallion.NewClient("st://localhost:9090")
 	if err != nil {
 		panic(err)
 	}
 
 	for i := 0; i < 2; i++ {
 		go func(j int) {
-			cli, er := stallion.NewClient("localhost:9090")
+			cli, er := stallion.NewClient("st://localhost:9090")
 			if er != nil {
 				log.Fatal(er)
 			}

example/client/simple-publish/main.go

@@ -8,7 +8,7 @@ import (
 )
 
 func main() {
-	client, err := stallion.NewClient("localhost:9090")
+	client, err := stallion.NewClient("st://localhost:9090")
 	if err != nil {
 		panic(err)
 	}

url.go

@@ -0,0 +1,38 @@
+package stallion
+
+import (
+	"fmt"
+	"strings"
+)
+
+// url
+// each url contains of the following parts:
+// - host
+// - port
+type url struct {
+	address string
+}
+
+// urlUnpack
+// manages to create url struct from url string.
+func urlUnpack(inputUrl string) (*url, error) {
+	// check the input url protocol
+	protocolSplit := strings.Split(inputUrl, "://")
+	if len(protocolSplit) < 2 {
+		return nil, fmt.Errorf("invalid uri")
+	}
+
+	// protocol must be 'st'
+	if protocolSplit[0] != "st" {
+		return nil, fmt.Errorf("not using stallion protocol (st://...)")
+	}
+
+	// exporting the host:port pair.
+	if len(strings.Split(protocolSplit[1], ":")) < 2 {
+		return nil, fmt.Errorf("server ip or port is not given")
+	}
+
+	return &url{
+		address: protocolSplit[1],
+	}, nil
+}