 77b0275572
			
		
	
	
	77b0275572
	
	
	
		
			
			- Set the right keyID and use the right signing keys for outgoing requests. - Verify the HTTP signature of all incoming requests, except for the server actor. - Caches keys of incoming requests for users and servers actors. Reviewed-on: https://codeberg.org/forgejo/forgejo/pulls/7035 Reviewed-by: Gusted <gusted@noreply.codeberg.org> Co-authored-by: famfo <famfo@famfo.xyz> Co-committed-by: famfo <famfo@famfo.xyz>
		
			
				
	
	
		
			54 lines
		
	
	
	
		
			1.5 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			54 lines
		
	
	
	
		
			1.5 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| // Copyright 2025 The Forgejo Authors. All rights reserved.
 | |
| // SPDX-License-Identifier: MIT
 | |
| 
 | |
| package integration
 | |
| 
 | |
| import (
 | |
| 	"net/url"
 | |
| 	"testing"
 | |
| 
 | |
| 	"forgejo.org/models/db"
 | |
| 	"forgejo.org/models/unittest"
 | |
| 	user_model "forgejo.org/models/user"
 | |
| 	"forgejo.org/modules/activitypub"
 | |
| 	"forgejo.org/modules/setting"
 | |
| 	"forgejo.org/modules/test"
 | |
| 	"forgejo.org/routers"
 | |
| 
 | |
| 	"github.com/stretchr/testify/assert"
 | |
| 	"github.com/stretchr/testify/require"
 | |
| )
 | |
| 
 | |
| func TestActivityPubClientBodySize(t *testing.T) {
 | |
| 	defer test.MockVariableValue(&setting.Federation.Enabled, true)()
 | |
| 	defer test.MockVariableValue(&testWebRoutes, routers.NormalRoutes())()
 | |
| 
 | |
| 	onGiteaRun(t, func(t *testing.T, u *url.URL) {
 | |
| 		user1 := unittest.AssertExistsAndLoadBean(t, &user_model.User{ID: 1})
 | |
| 
 | |
| 		clientFactory, err := activitypub.GetClientFactory(db.DefaultContext)
 | |
| 		require.NoError(t, err)
 | |
| 
 | |
| 		apClient, err := clientFactory.WithKeys(db.DefaultContext, user1, user1.APActorKeyID())
 | |
| 		require.NoError(t, err)
 | |
| 
 | |
| 		url := u.JoinPath("/api/v1/nodeinfo").String()
 | |
| 
 | |
| 		// Request with normal MaxSize
 | |
| 		t.Run("NormalMaxSize", func(t *testing.T) {
 | |
| 			resp, err := apClient.GetBody(url)
 | |
| 			require.NoError(t, err)
 | |
| 			assert.Contains(t, string(resp), "forgejo")
 | |
| 		})
 | |
| 
 | |
| 		// Set MaxSize to something very low to always fail
 | |
| 		// Request with low MaxSize
 | |
| 		t.Run("LowMaxSize", func(t *testing.T) {
 | |
| 			defer test.MockVariableValue(&setting.Federation.MaxSize, 100)()
 | |
| 
 | |
| 			_, err = apClient.GetBody(url)
 | |
| 			require.Error(t, err)
 | |
| 			assert.ErrorContains(t, err, "Request returned")
 | |
| 		})
 | |
| 	})
 | |
| }
 |