mirror of
https://github.com/PrivateCaptcha/PrivateCaptcha.git
synced 2026-02-11 08:18:52 -06:00
99 lines
2.6 KiB
Go
99 lines
2.6 KiB
Go
package api
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"flag"
|
|
"os"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/billing"
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/common"
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/config"
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/db"
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/difficulty"
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/email"
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/monitoring"
|
|
"github.com/PrivateCaptcha/PrivateCaptcha/pkg/ratelimit"
|
|
"github.com/jackc/pgx/v5/pgxpool"
|
|
)
|
|
|
|
var (
|
|
s *Server
|
|
cfg common.ConfigStore
|
|
cache common.Cache[db.CacheKey, any]
|
|
timeSeries *db.TimeSeriesDB
|
|
store *db.BusinessStore
|
|
testPlan billing.Plan
|
|
)
|
|
|
|
const (
|
|
authBackfillDelay = 100 * time.Millisecond
|
|
verifyFlushInterval = 1 * time.Second
|
|
)
|
|
|
|
func testsConfigStore() common.ConfigStore {
|
|
baseCfg := config.NewBaseConfig(config.NewEnvConfig(os.Getenv))
|
|
baseCfg.Add(config.NewStaticValue(common.RateLimitBurstKey, "20"))
|
|
baseCfg.Add(config.NewStaticValue(common.RateLimitRateKey, "10"))
|
|
return baseCfg
|
|
}
|
|
|
|
func TestMain(m *testing.M) {
|
|
flag.Parse()
|
|
|
|
if testing.Short() {
|
|
os.Exit(m.Run())
|
|
}
|
|
|
|
common.SetupLogs(common.StageTest, true)
|
|
|
|
cfg = testsConfigStore()
|
|
|
|
var pool *pgxpool.Pool
|
|
var clickhouse *sql.DB
|
|
var dberr error
|
|
pool, clickhouse, dberr = db.Connect(context.Background(), cfg, 3*time.Second, false /*admin*/)
|
|
if dberr != nil {
|
|
panic(dberr)
|
|
}
|
|
|
|
timeSeries = db.NewTimeSeries(clickhouse)
|
|
|
|
var err error
|
|
cache, err = db.NewMemoryCache[db.CacheKey, any]("default", 100, &struct{}{}, 1*time.Minute, 3*time.Minute, 30*time.Second)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
store = db.NewBusinessEx(pool, cache)
|
|
|
|
metrics := monitoring.NewStub()
|
|
|
|
planService := billing.NewPlanService(nil)
|
|
testPlan = planService.GetInternalTrialPlan()
|
|
|
|
s = &Server{
|
|
Stage: common.StageTest,
|
|
BusinessDB: store,
|
|
TimeSeries: timeSeries,
|
|
RateLimiter: &ratelimit.StubRateLimiter{Header: cfg.Get(common.RateLimitHeaderKey).Value()},
|
|
Auth: NewAuthMiddleware(store, NewUserLimiter(store), planService),
|
|
VerifyLogChan: make(chan *common.VerifyRecord, 10*VerifyBatchSize),
|
|
Verifier: NewVerifier(cfg, store),
|
|
Metrics: metrics,
|
|
Mailer: &email.StubMailer{},
|
|
Levels: difficulty.NewLevels(timeSeries, 100 /*levelsBatchSize*/, PropertyBucketSize),
|
|
VerifyLogCancel: func() {},
|
|
}
|
|
if err := s.Init(context.TODO(), verifyFlushInterval, authBackfillDelay); err != nil {
|
|
panic(err)
|
|
}
|
|
defer s.Shutdown()
|
|
|
|
// TODO: seed data
|
|
|
|
os.Exit(m.Run())
|
|
}
|