dao_test.go 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. package block
  2. import (
  3. "flag"
  4. "os"
  5. "strings"
  6. "testing"
  7. "go-common/app/job/main/member/conf"
  8. "go-common/library/cache/memcache"
  9. xsql "go-common/library/database/sql"
  10. bm "go-common/library/net/http/blademaster"
  11. . "github.com/smartystreets/goconvey/convey"
  12. "gopkg.in/h2non/gock.v1"
  13. )
  14. func TestTool(t *testing.T) {
  15. Convey("tool", t, func() {
  16. var (
  17. mids = []int64{1, 2, 3, 46333, 35858}
  18. )
  19. str := midsToParam(mids)
  20. So(str, ShouldEqual, "1,2,3,46333,35858")
  21. })
  22. }
  23. var (
  24. d *Dao
  25. )
  26. func TestMain(m *testing.M) {
  27. if os.Getenv("DEPLOY_ENV") != "" {
  28. flag.Set("app_id", "main.account.member-job")
  29. flag.Set("conf_token", "VEc5eqZNZHGQi6fsx7J6lJTqOGR9SnEO")
  30. flag.Set("tree_id", "2134")
  31. flag.Set("conf_version", "docker-1")
  32. flag.Set("deploy_env", "uat")
  33. flag.Set("conf_host", "config.bilibili.co")
  34. flag.Set("conf_path", "/tmp")
  35. flag.Set("region", "sh")
  36. flag.Set("zone", "sh001")
  37. } else {
  38. flag.Set("conf", "../cmd/member-job-dev.toml")
  39. }
  40. flag.Parse()
  41. if err := conf.Init(); err != nil {
  42. panic(err)
  43. }
  44. config := conf.Conf
  45. //d.New().BlockImpl()
  46. d = New(conf.Conf, memcache.NewPool(config.Memcache.Config), xsql.NewMySQL(config.BlockDB), bm.NewClient(config.HTTPClient), nil)
  47. d.httpClient.SetTransport(gock.DefaultTransport)
  48. os.Exit(m.Run())
  49. }
  50. func httpMock(method, url string) *gock.Request {
  51. r := gock.New(url)
  52. r.Method = strings.ToUpper(method)
  53. return r
  54. }