mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2024-11-30 09:41:11 -05:00
2b97800dd8
(cherry picked from commit6623630d10) (cherry picked from commit5e30a4f950) (cherry picked from commit355a117e74) (cherry picked from commit2e98ceccbc) (cherry picked from commite1687f1e20)
111 lines
3.1 KiB
Go
111 lines
3.1 KiB
Go
// Copyright 2022 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package integration
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"net/url"
|
|
"testing"
|
|
|
|
user_model "code.gitea.io/gitea/models/user"
|
|
"code.gitea.io/gitea/modules/activitypub"
|
|
"code.gitea.io/gitea/modules/setting"
|
|
|
|
ap "github.com/go-ap/activitypub"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestActivityPubPerson(t *testing.T) {
|
|
setting.Federation.Enabled = true
|
|
setNormalRoutes()
|
|
defer func() {
|
|
setting.Federation.Enabled = false
|
|
setNormalRoutes()
|
|
}()
|
|
|
|
onGiteaRun(t, func(*testing.T, *url.URL) {
|
|
userID := 2
|
|
username := "user2"
|
|
req := NewRequestf(t, "GET", fmt.Sprintf("/api/v1/activitypub/user-id/%v", userID))
|
|
resp := MakeRequest(t, req, http.StatusOK)
|
|
body := resp.Body.Bytes()
|
|
assert.Contains(t, string(body), "@context")
|
|
|
|
var person ap.Person
|
|
err := person.UnmarshalJSON(body)
|
|
assert.NoError(t, err)
|
|
|
|
assert.Equal(t, ap.PersonType, person.Type)
|
|
assert.Equal(t, username, person.PreferredUsername.String())
|
|
keyID := person.GetID().String()
|
|
assert.Regexp(t, fmt.Sprintf("activitypub/user-id/%v$", userID), keyID)
|
|
assert.Regexp(t, fmt.Sprintf("activitypub/user-id/%v/outbox$", userID), person.Outbox.GetID().String())
|
|
assert.Regexp(t, fmt.Sprintf("activitypub/user-id/%v/inbox$", userID), person.Inbox.GetID().String())
|
|
|
|
pubKey := person.PublicKey
|
|
assert.NotNil(t, pubKey)
|
|
publicKeyID := keyID + "#main-key"
|
|
assert.Equal(t, pubKey.ID.String(), publicKeyID)
|
|
|
|
pubKeyPem := pubKey.PublicKeyPem
|
|
assert.NotNil(t, pubKeyPem)
|
|
assert.Regexp(t, "^-----BEGIN PUBLIC KEY-----", pubKeyPem)
|
|
})
|
|
}
|
|
|
|
func TestActivityPubMissingPerson(t *testing.T) {
|
|
setting.Federation.Enabled = true
|
|
setNormalRoutes()
|
|
defer func() {
|
|
setting.Federation.Enabled = false
|
|
setNormalRoutes()
|
|
}()
|
|
|
|
onGiteaRun(t, func(*testing.T, *url.URL) {
|
|
req := NewRequestf(t, "GET", "/api/v1/activitypub/user-id/999999999")
|
|
resp := MakeRequest(t, req, http.StatusNotFound)
|
|
assert.Contains(t, resp.Body.String(), "user does not exist")
|
|
})
|
|
}
|
|
|
|
func TestActivityPubPersonInbox(t *testing.T) {
|
|
setting.Federation.Enabled = true
|
|
setNormalRoutes()
|
|
defer func() {
|
|
setting.Federation.Enabled = false
|
|
setNormalRoutes()
|
|
}()
|
|
|
|
srv := httptest.NewServer(c)
|
|
defer srv.Close()
|
|
|
|
onGiteaRun(t, func(*testing.T, *url.URL) {
|
|
appURL := setting.AppURL
|
|
setting.AppURL = srv.URL + "/"
|
|
defer func() {
|
|
setting.Database.LogSQL = false
|
|
setting.AppURL = appURL
|
|
}()
|
|
username1 := "user1"
|
|
ctx := context.Background()
|
|
user1, err := user_model.GetUserByName(ctx, username1)
|
|
assert.NoError(t, err)
|
|
user1url := fmt.Sprintf("%s/api/v1/activitypub/user-id/1#main-key", srv.URL)
|
|
c, err := activitypub.NewClient(user1, user1url)
|
|
assert.NoError(t, err)
|
|
user2inboxurl := fmt.Sprintf("%s/api/v1/activitypub/user-id/2/inbox", srv.URL)
|
|
|
|
// Signed request succeeds
|
|
resp, err := c.Post([]byte{}, user2inboxurl)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, http.StatusNoContent, resp.StatusCode)
|
|
|
|
// Unsigned request fails
|
|
req := NewRequest(t, "POST", user2inboxurl)
|
|
MakeRequest(t, req, http.StatusInternalServerError)
|
|
})
|
|
}
|