blallo/circolog
1
0
Fork 0
forked from boyska/circolog
Code Releases Activity

Fix hub tests.

Browse source
This commit is contained in:
Blallo 2019-04-01 16:57:09 +02:00
parent aef8a277e5
commit c5eee0ea22
No known key found for this signature in database
GPG key ID: 0CBE577C9B72DC3F
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
hub_test.go
View file

@ -3,11 +3,12 @@ package circolog
import ( import (
"testing" "testing"
"git.lattuga.net/boyska/circolog/data"
"gopkg.in/mcuadros/go-syslog.v2/format" "gopkg.in/mcuadros/go-syslog.v2/format"
) )
func msg(s string) format.LogParts { func msg(s string) format.LogParts {
return format.LogParts{"text": s} return format.LogParts{"content": s}
} }
func hubCount(h Hub) int { func hubCount(h Hub) int {
@ -19,10 +20,10 @@ var DefaultClient ClientOptions = ClientOptions{Nofollow: true, BacklogLength: -
func hubToArrayOpt(h Hub, opt ClientOptions) []string { func hubToArrayOpt(h Hub, opt ClientOptions) []string {
r := make([]string, 0) r := make([]string, 0)
cl := Client{Options: opt} cl := Client{Options: opt}
cl.Messages = make(chan format.LogParts) cl.Messages = make(chan data.Message)
h.Register <- cl h.Register <- cl
for m := range cl.Messages { for m := range cl.Messages {
r = append(r, m["text"].(string)) r = append(r, m["msg"].(string))
} }
return r return r
} }