dingo_amqp_redis_test.go

package dingo_test

import (
	"testing"

	"github.com/mission-liao/dingo"
	"github.com/mission-liao/dingo/amqp"
	"github.com/mission-liao/dingo/redis"
	"github.com/stretchr/testify/suite"
)

//
// Amqp(Broker) + Redis(Backend), single App
//

type amqpRedisSingleAppTestSuite struct {
	DingoSingleAppTestSuite
}

func TestDingoAmqpRedisSingleAppSuite(t *testing.T) {
	suite.Run(t, &amqpRedisSingleAppTestSuite{
		DingoSingleAppTestSuite{
			GenApp: func() (app *dingo.App, err error) {
				app, err = dingo.NewApp("remote", nil)
				if err != nil {
					return
				}
				brk, err := dgamqp.NewBroker(dgamqp.DefaultAmqpConfig())
				if err != nil {
					return
				}
				_, _, err = app.Use(brk, dingo.ObjT.Default)
				if err != nil {
					return
				}

				bkd, err := dgredis.NewBackend(dgredis.DefaultRedisConfig())
				if err != nil {
					return
				}
				_, _, err = app.Use(bkd, dingo.ObjT.Default)
				if err != nil {
					return
				}

				return
			},
		},
	})
}

//
// Amqp(Broker) + Redis(Backend), multi App
//

type amqpRedisMultiAppTestSuite struct {
	DingoMultiAppTestSuite
}

func TestDingoAmqpRedisMultiAppSuite(t *testing.T) {
	suite.Run(t, &amqpRedisMultiAppTestSuite{
		DingoMultiAppTestSuite{
			CountOfCallers: 3,
			CountOfWorkers: 3,
			GenCaller: func() (app *dingo.App, err error) {
				app, err = dingo.NewApp("remote", nil)
				if err != nil {
					return
				}
				brk, err := dgamqp.NewBroker(dgamqp.DefaultAmqpConfig())
				if err != nil {
					return
				}
				_, _, err = app.Use(brk, dingo.ObjT.Producer)
				if err != nil {
					return
				}
				bkd, err := dgredis.NewBackend(dgredis.DefaultRedisConfig())
				if err != nil {
					return
				}
				_, _, err = app.Use(bkd, dingo.ObjT.Store)
				if err != nil {
					return
				}

				return
			},
			GenWorker: func() (app *dingo.App, err error) {
				app, err = dingo.NewApp("remote", nil)
				if err != nil {
					return
				}
				brk, err := dgamqp.NewBroker(dgamqp.DefaultAmqpConfig())
				if err != nil {
					return
				}
				_, _, err = app.Use(brk, dingo.ObjT.NamedConsumer)
				if err != nil {
					return
				}
				bkd, err := dgredis.NewBackend(dgredis.DefaultRedisConfig())
				if err != nil {
					return
				}
				_, _, err = app.Use(bkd, dingo.ObjT.Reporter)
				if err != nil {
					return
				}

				return
			},
		},
	})
}