mirror of
https://github.com/kevin-DL/services.git
synced 2026-01-12 19:25:16 +00:00
101 lines
2.6 KiB
Go
101 lines
2.6 KiB
Go
package handler_test
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"os"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/golang/protobuf/ptypes/timestamp"
|
|
"github.com/micro/micro/v3/service/auth"
|
|
"github.com/micro/services/threads/handler"
|
|
pb "github.com/micro/services/threads/proto"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func testHandler(t *testing.T) *handler.Threads {
|
|
// connect to the database
|
|
addr := os.Getenv("POSTGRES_URL")
|
|
if len(addr) == 0 {
|
|
addr = "postgresql://postgres@localhost:5432/postgres?sslmode=disable"
|
|
}
|
|
sqlDB, err := sql.Open("pgx", addr)
|
|
if err != nil {
|
|
t.Fatalf("Failed to open connection to DB %s", err)
|
|
}
|
|
|
|
// clean any data from a previous run
|
|
if _, err := sqlDB.Exec("DROP TABLE IF EXISTS micro_conversations, micro_messages CASCADE"); err != nil {
|
|
t.Fatalf("Error cleaning database: %v", err)
|
|
}
|
|
|
|
h := &handler.Threads{Time: func() time.Time { return time.Unix(1611327673, 0) }}
|
|
h.DBConn(sqlDB).Migrations(&handler.Conversation{}, &handler.Message{})
|
|
|
|
return h
|
|
}
|
|
|
|
func assertConversationsMatch(t *testing.T, exp, act *pb.Conversation) {
|
|
if act == nil {
|
|
t.Errorf("Conversation not returned")
|
|
return
|
|
}
|
|
|
|
// adapt this check so we can reuse the func in testing create, where we don't know the exact id
|
|
// which will be generated
|
|
if len(exp.Id) > 0 {
|
|
assert.Equal(t, exp.Id, act.Id)
|
|
} else {
|
|
assert.NotEmpty(t, act.Id)
|
|
}
|
|
|
|
assert.Equal(t, exp.Topic, act.Topic)
|
|
assert.Equal(t, exp.GroupId, act.GroupId)
|
|
|
|
if act.CreatedAt == nil {
|
|
t.Errorf("CreatedAt not set")
|
|
return
|
|
}
|
|
|
|
assert.True(t, microSecondTime(exp.CreatedAt).Equal(microSecondTime(act.CreatedAt)))
|
|
}
|
|
|
|
func assertMessagesMatch(t *testing.T, exp, act *pb.Message) {
|
|
if act == nil {
|
|
t.Errorf("Message not returned")
|
|
return
|
|
}
|
|
|
|
// adapt this check so we can reuse the func in testing create, where we don't know the exact id
|
|
// which will be generated
|
|
if len(exp.Id) > 0 {
|
|
assert.Equal(t, exp.Id, act.Id)
|
|
} else {
|
|
assert.NotEmpty(t, act.Id)
|
|
}
|
|
|
|
assert.Equal(t, exp.Text, act.Text)
|
|
assert.Equal(t, exp.AuthorId, act.AuthorId)
|
|
assert.Equal(t, exp.ConversationId, act.ConversationId)
|
|
|
|
if act.SentAt == nil {
|
|
t.Errorf("SentAt not set")
|
|
return
|
|
}
|
|
|
|
assert.True(t, microSecondTime(exp.SentAt).Equal(microSecondTime(act.SentAt)))
|
|
}
|
|
|
|
// postgres has a resolution of 100microseconds so just test that it's accurate to the second
|
|
func microSecondTime(t *timestamp.Timestamp) time.Time {
|
|
tt := t.AsTime()
|
|
return time.Unix(tt.Unix(), int64(tt.Nanosecond()-tt.Nanosecond()%1000))
|
|
}
|
|
|
|
func microAccountCtx() context.Context {
|
|
return auth.ContextWithAccount(context.TODO(), &auth.Account{
|
|
Issuer: "micro",
|
|
})
|
|
}
|