# README

messenger

| | |

A simple messenger with socket notification. (This implementation should use for example rabbitmq to keep messages when shutdown)

Support for

Http

If i miss something or you have something interesting, please be part of this project. Let me know! My contact is at the end.

Dependency Management

Dep

Project dependencies are managed using Dep. Read more about Dep.

Install dependencies: dep ensure
Update dependencies: dep ensure -update

Configuration

{
  "messenger": {
    "host": "localhost:8001",
    "token_key": "banana",
    "socket": {
      "client": {
        "server_address": "localhost:9001/api/v1",
        "log": {
          "level": "info"
        }
      },
      "server": {
        "address": ":9001",
        "log": {
          "level": "info"
        }
      }
    },
    "dbr": {
      "db": {
        "driver": "postgres",
        "datasource": "postgres://user:password@localhost:7000/postgres?sslmode=disable&search_path=messenger"
      }
    },
    "log": {
      "level": "info"
    },
    "migration": {
      "path": {
        "database": "schema/db/postgres"
      },
      "db": {
        "schema": "messenger",
        "driver": "postgres",
        "datasource": "postgres://user:password@localhost:7000/postgres?sslmode=disable&search_path=messenger"
      },
      "log": {
        "level": "info"
      }
    }
  },
  "manager": {
    "log": {
      "level": "info"
    }
  },
  "socket": {
    "client": {
      "server_address": "localhost:9001/api/v1",
      "log": {
        "level": "info"
      }
    }
  }
}

Go

go get github.com/joaosoft/messenger

Usage

This examples are available in the project at messenger/examples

Server example

func main() {
	m, err := messenger.NewMessenger()
	if err != nil {
		panic(err)
	}

	if err := m.Start(); err != nil {
		panic(err)
	}
}

Client example

func main() {
	var user string
	flag.StringVar(&user, "listen", "", "The user identifier")
	flag.Parse()

	if user == "" {
		panic("invalid user identifier")
	}

	client, err := socket.NewClient()
	if err != nil {
		panic(err)
	}

	if err := client.Start(); err != nil {
		panic(err)
	}

	if err := client.Subscribe(user, "messenger::in-box"); err != nil {
		panic(err)
	}

	client.Listen(user, "messenger-in-box", func(message []byte) error {
		fmt.Printf("\nreceived on listener the message %s", string(message))
		return nil
	})

	// Unsubscribe
	//if err := client.Unsubscribe("topic_1", "channel_1"); err != nil {
	//	panic(err)
	//}

	client.Wait()
}

How to run this?

go run main/main.go
go run main/client.go -listen user_one
go run main/client.go -listen user_two
Make the next http requests to send messages

4.1. from user_one to user_two

Method: POST

Route: http://localhost:8001/api/v1/messenger/message/users/user_two

Header: user: user_one

Body:
```
{
    "message": "hello my friend"
}
```
4.2 from user_two to user_one

Method: POST

Route: http://localhost:8001/api/v1/messenger/message/users/user_one

Header: user: user_two

Body:
```
{
    "message": "hello my friend"
}
```