mirror of
				https://github.com/superseriousbusiness/gotosocial.git
				synced 2025-10-31 04:02:26 -05:00 
			
		
		
		
	* [bugfix] process account delete side effects in serial, not in parallel * StartWorkers / StartNoopWorkers for tests * undo testrig trace logging * log errors instead of immediately returning
		
			
				
	
	
		
			132 lines
		
	
	
	
		
			4.8 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			132 lines
		
	
	
	
		
			4.8 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| // GoToSocial
 | |
| // Copyright (C) GoToSocial Authors admin@gotosocial.org
 | |
| // SPDX-License-Identifier: AGPL-3.0-or-later
 | |
| //
 | |
| // This program is free software: you can redistribute it and/or modify
 | |
| // it under the terms of the GNU Affero General Public License as published by
 | |
| // the Free Software Foundation, either version 3 of the License, or
 | |
| // (at your option) any later version.
 | |
| //
 | |
| // This program is distributed in the hope that it will be useful,
 | |
| // but WITHOUT ANY WARRANTY; without even the implied warranty of
 | |
| // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 | |
| // GNU Affero General Public License for more details.
 | |
| //
 | |
| // You should have received a copy of the GNU Affero General Public License
 | |
| // along with this program.  If not, see <http://www.gnu.org/licenses/>.
 | |
| 
 | |
| package auth_test
 | |
| 
 | |
| import (
 | |
| 	"bytes"
 | |
| 	"fmt"
 | |
| 	"net/http/httptest"
 | |
| 
 | |
| 	"github.com/gin-contrib/sessions"
 | |
| 	"github.com/gin-contrib/sessions/memstore"
 | |
| 	"github.com/gin-gonic/gin"
 | |
| 	"github.com/stretchr/testify/suite"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/api/auth"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/config"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/db"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/email"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/federation"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/media"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/middleware"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/oidc"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/processing"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/state"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/storage"
 | |
| 	"github.com/superseriousbusiness/gotosocial/testrig"
 | |
| )
 | |
| 
 | |
| type AuthStandardTestSuite struct {
 | |
| 	suite.Suite
 | |
| 	db           db.DB
 | |
| 	storage      *storage.Driver
 | |
| 	state        state.State
 | |
| 	mediaManager *media.Manager
 | |
| 	federator    *federation.Federator
 | |
| 	processor    *processing.Processor
 | |
| 	emailSender  email.Sender
 | |
| 	idp          oidc.IDP
 | |
| 
 | |
| 	// standard suite models
 | |
| 	testTokens       map[string]*gtsmodel.Token
 | |
| 	testClients      map[string]*gtsmodel.Client
 | |
| 	testApplications map[string]*gtsmodel.Application
 | |
| 	testUsers        map[string]*gtsmodel.User
 | |
| 	testAccounts     map[string]*gtsmodel.Account
 | |
| 
 | |
| 	// module being tested
 | |
| 	authModule *auth.Module
 | |
| }
 | |
| 
 | |
| const (
 | |
| 	sessionUserID   = "userid"
 | |
| 	sessionClientID = "client_id"
 | |
| )
 | |
| 
 | |
| func (suite *AuthStandardTestSuite) SetupSuite() {
 | |
| 	suite.testTokens = testrig.NewTestTokens()
 | |
| 	suite.testClients = testrig.NewTestClients()
 | |
| 	suite.testApplications = testrig.NewTestApplications()
 | |
| 	suite.testUsers = testrig.NewTestUsers()
 | |
| 	suite.testAccounts = testrig.NewTestAccounts()
 | |
| }
 | |
| 
 | |
| func (suite *AuthStandardTestSuite) SetupTest() {
 | |
| 	suite.state.Caches.Init()
 | |
| 
 | |
| 	testrig.InitTestConfig()
 | |
| 	testrig.InitTestLog()
 | |
| 
 | |
| 	suite.db = testrig.NewTestDB(&suite.state)
 | |
| 	suite.state.DB = suite.db
 | |
| 	suite.storage = testrig.NewInMemoryStorage()
 | |
| 	suite.state.Storage = suite.storage
 | |
| 	suite.mediaManager = testrig.NewTestMediaManager(&suite.state)
 | |
| 	suite.federator = testrig.NewTestFederator(&suite.state, testrig.NewTestTransportController(&suite.state, testrig.NewMockHTTPClient(nil, "../../../testrig/media")), suite.mediaManager)
 | |
| 	suite.emailSender = testrig.NewEmailSender("../../../web/template/", nil)
 | |
| 	suite.processor = testrig.NewTestProcessor(&suite.state, suite.federator, suite.emailSender, suite.mediaManager)
 | |
| 	suite.authModule = auth.New(suite.db, suite.processor, suite.idp)
 | |
| 
 | |
| 	testrig.StandardDBSetup(suite.db, suite.testAccounts)
 | |
| 	testrig.StartNoopWorkers(&suite.state)
 | |
| }
 | |
| 
 | |
| func (suite *AuthStandardTestSuite) TearDownTest() {
 | |
| 	testrig.StandardDBTeardown(suite.db)
 | |
| 	testrig.StopWorkers(&suite.state)
 | |
| }
 | |
| 
 | |
| func (suite *AuthStandardTestSuite) newContext(requestMethod string, requestPath string, requestBody []byte, bodyContentType string) (*gin.Context, *httptest.ResponseRecorder) {
 | |
| 	// create the recorder and gin test context
 | |
| 	recorder := httptest.NewRecorder()
 | |
| 	ctx, engine := testrig.CreateGinTestContext(recorder, nil)
 | |
| 
 | |
| 	// load templates into the engine
 | |
| 	testrig.ConfigureTemplatesWithGin(engine, "../../../web/template")
 | |
| 
 | |
| 	// create the request
 | |
| 	protocol := config.GetProtocol()
 | |
| 	host := config.GetHost()
 | |
| 	baseURI := fmt.Sprintf("%s://%s", protocol, host)
 | |
| 	requestURI := fmt.Sprintf("%s/%s", baseURI, requestPath)
 | |
| 
 | |
| 	ctx.Request = httptest.NewRequest(requestMethod, requestURI, bytes.NewReader(requestBody)) // the endpoint we're hitting
 | |
| 	ctx.Request.Header.Set("accept", "text/html")
 | |
| 
 | |
| 	if bodyContentType != "" {
 | |
| 		ctx.Request.Header.Set("Content-Type", bodyContentType)
 | |
| 	}
 | |
| 
 | |
| 	// trigger the session middleware on the context
 | |
| 	store := memstore.NewStore(make([]byte, 32), make([]byte, 32))
 | |
| 	store.Options(middleware.SessionOptions())
 | |
| 	sessionMiddleware := sessions.Sessions("gotosocial-localhost", store)
 | |
| 	sessionMiddleware(ctx)
 | |
| 
 | |
| 	return ctx, recorder
 | |
| }
 |