publish_test.go

package app_test

import (
	"context"
	"testing"
	"time"

	logging "github.com/ipfs/go-log"
	application "github.com/pravahio/go-mesh/application"
	cfg "github.com/pravahio/go-mesh/config"
	driver "github.com/pravahio/go-mesh/driver/eth"
	fpubsub "github.com/pravahio/go-mesh/pubsub"
	bootservice "github.com/pravahio/go-mesh/service/bootstrap"
	pubservice "github.com/pravahio/go-mesh/service/publisher"
)

func TestPublish(t *testing.T) {
	logging.SetLogLevel("svc-bootstrap", "DEBUG")
	logging.SetLogLevel("application", "DEBUG")
	logging.SetLogLevel("svc-publisher", "DEBUG")
	logging.SetLogLevel("fpubsub", "DEBUG")
	logging.SetLogLevel("pubsub", "DEBUG")
	logging.SetLogLevel("eth-driver", "DEBUG")

	app, err := application.NewApplication(context.Background(), nil, nil, "0.0.0.0", "0", false)
	if err != nil {
		t.Fatal(err)
	}

	ethDriver, err := driver.NewEthDriver("", nil)
	if err != nil {
		t.Fatal(err)
	}

	bservice := bootservice.NewBootstrapService(
		false,
		"abc",
		cfg.BootstrapList,
		15*time.Second)
	pubService := pubservice.NewPublisherService(ethDriver)

	app.InjectService(bservice)
	app.InjectService(pubService)

	f := fpubsub.NewFilter(ethDriver)
	app.SetGossipPeerFilter(f)

	err = app.Start()
	if err != nil {
		t.Fatal(err)
	}

	time.Sleep(3 * time.Second)

	err = pubService.RegisterToPublish("GGN.BUS")
	if err != nil {
		t.Fatal(err)
	}

	err = pubService.PublishData("GGN.BUS", []byte("yyyy"))
	if err != nil {
		t.Fatal(err)
	}
}