clivern / beaver Goto Github PK

https://github.com/Clivern/Hippo

Hi @Clivern
First, I appreciate you for making this library.
But sorry to say if I still didn't understand your documentation.

Is there a 'good' documentation about it like some documentations in GoDoc or documentation provided with image for better illustrating?

Second, do you have sample or demo app?

Thankyou in advance 🙏🏼

Allow ProtoBuff as communication protocol

• Gin SSL Support

You can now simplify config file loading with config.LoadFile(path).

Beaver nodes shall work as follow:

• All beaver nodes connected to same Redis cluster.
• Each Node join the cluster shares its info on Redis with other nodes.
• Using shared info, All nodes should be able to load balance across multiple nodes.
• All beaver nodes subscribe to a specific Redis Channel or RabbitMQ in order to get notified by all incoming messages, publish events and they will deliver these messages to their connected clients.
• Clients are free to connect to any node without getting affected.
• If node goes down, only connected clients are affected and connecting to a new node will fix the problem.

• Redis Driver.

Right now all requests forbidden do to cors restriction, when using the beaver from the browser. Is it possible to add cors middleware that will add required headers to the requests? All needed data can be described in the config file.

For example, the middleware may be something like that:

func Cors(allowedMethods, allowedHeaders []string, allowedOriginPattern string) gin.HandlerFunc {
	return func(c *gin.Context) {
		r := c.Request
		w := c.Writer

		w.Header().Set("Content-Type", "application/json; charset=utf-8")
		w.Header().Set("Access-Control-Allow-Methods", strings.Join(allowedMethods, ", "))
		w.Header().Set("Access-Control-Allow-Headers", strings.Join(allowedHeaders, ", "))

		reqOrigin := r.Header.Get("Origin")

		switch allowedOriginPattern {
		case "*", ".*", "/*":
			w.Header().Set("Access-Control-Allow-Origin", "*")
		default:
			if ok, _ := regexp.MatchString(allowedOriginPattern, reqOrigin); ok {
				w.Header().Set("Access-Control-Allow-Origin", reqOrigin)
			}
		}

		if r.Method == "OPTIONS" {
			c.AbortWithStatus(http.StatusOK)
		} else {
			c.Next()
		}
	}
}

Cloud u confirm that this could work with flutter, is there any docs for integration with flutter or just connect it as socket in flutter project

Describe the bug
the client get channel message after unsubscribe this channel

Development or production environment
https://github.com/Clivern/Beaver/releases/download/1.1.1/Beaver_1.1.1_Linux_x86_64.tar.gz

client send a ping message and beaver respond otherwise it has to restart the connection

Beaver.xml.zip

I checked the Dockerfile and I'd like to do some suggestions to you(of course, I can do the changes and send a PR, if you are interested).

beaver-alpine -> I changed FROM golang:1.11.1 to FROM golang:1.11-alpine, it need to add git and CGO_ENABLED=0.
beaver-builder ->I used the Dockerfile to build the image, but I used alpine(it could be scratch) to run the project.
As you can see in the screenshot, we can create smaller images.

Is your feature request related to a problem? Please describe.
It is not clear why there are the config REST API routes.

Describe the solution you'd like
Could you please explain in short?

Additional context

Create Architecture for:

• Public Channels.
• Private Channels.
• Presence Channels.
• Clients Workflow.

Describe the bug
I use beaver to build a socket server.But sometimes it panics with an error.
The error is : fatal error: concurrent map writes.

And the error's stacks info : github.com/clivern/beaver/internal/app/controller.(*Websocket).HandleConnections(0xc0001ca4d0, 0x7f033e218240, 0xc0004869a0, 0xc0000b1200, 0xc000233108, 0x24, 0xc00023312d, 0xbd, 0xc000029440, 0x24) /root/Beaver/internal/app/controller/socket.go:166 +0x505 fp=0xc000585688 sp=0xc0005854e8 pc=0xabd815.

The code in 166 line is:delete(e.Clients, ID)

I google for the reason and find it's unsafe that using map in goruntine. So I think Websocket.Clients should protected by mutex or use sync.Map directly?

Development or production environment

• OS: [Ubuntu 16.04]
• Go 1.12.17

Build a tool to mess up beaver with a private channels, clients and subscribers, and measure message delivery latency

Wrote a Go client for Beaver: https://github.com/domgolonka/beavergo

There is two types:

• Metrics that never change in case of node, so any node can provide these metrics.
• Node metrics like connected clients & overall connected clients.

• Logger.
• Auth.

Base branch is v2

the file with vscode-restclient, see file

For stability & reduce upgrade hurdles, i will switch to spf13/viper

$ go get -u

go: github.com/testcontainers/testcontainer-go@v0.0.2: parsing go.mod: unexpected module path "github.com/testcontainers/testcontainers-go"
go: finding github.com/gregjones/httpcache latest
go: finding github.com/dgryski/go-bitstream latest
go: finding github.com/k0kubun/colorstring latest
go get: error loading module requirements

Currently github.com/micro/go-config face a problem with one of the dependencies chain.