106 lines
3.6 KiB
Go
106 lines
3.6 KiB
Go
package pub
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"testing"
|
|
|
|
"github.com/golang/mock/gomock"
|
|
)
|
|
|
|
// TestActivityStreamsHandler tests the handler for serving ActivityPub
|
|
// requests.
|
|
func TestActivityStreamsHandler(t *testing.T) {
|
|
ctx := context.Background()
|
|
setupFn := func(ctl *gomock.Controller) (db *MockDatabase, clock *MockClock, hf HandlerFunc) {
|
|
db = NewMockDatabase(ctl)
|
|
clock = NewMockClock(ctl)
|
|
hf = NewActivityStreamsHandler(db, clock)
|
|
return
|
|
}
|
|
t.Run("IgnoresIfNotActivityPubGetRequest", func(t *testing.T) {
|
|
// Setup
|
|
ctl := gomock.NewController(t)
|
|
defer ctl.Finish()
|
|
_, _, hf := setupFn(ctl)
|
|
resp := httptest.NewRecorder()
|
|
req := httptest.NewRequest("GET", testNoteId1, nil)
|
|
// Run & Verify
|
|
isAPReq, err := hf(ctx, resp, req)
|
|
assertEqual(t, isAPReq, false)
|
|
assertEqual(t, err, nil)
|
|
assertEqual(t, len(resp.Result().Header), 0)
|
|
})
|
|
t.Run("ReturnsErrorWhenDatabaseFetchReturnsError", func(t *testing.T) {
|
|
// Setup
|
|
ctl := gomock.NewController(t)
|
|
defer ctl.Finish()
|
|
mockDb, _, hf := setupFn(ctl)
|
|
resp := httptest.NewRecorder()
|
|
req := toAPRequest(httptest.NewRequest("GET", testNoteId1, nil))
|
|
testErr := fmt.Errorf("test error")
|
|
// Mock
|
|
mockDb.EXPECT().Lock(ctx, mustParse(testNoteId1))
|
|
mockDb.EXPECT().Get(ctx, mustParse(testNoteId1)).Return(nil, testErr)
|
|
mockDb.EXPECT().Unlock(ctx, mustParse(testNoteId1))
|
|
// Run & Verify
|
|
isAPReq, err := hf(ctx, resp, req)
|
|
assertEqual(t, isAPReq, true)
|
|
assertEqual(t, err, testErr)
|
|
assertEqual(t, len(resp.Result().Header), 0)
|
|
})
|
|
t.Run("ServesTombstoneWithStatusGone", func(t *testing.T) {
|
|
// Setup
|
|
ctl := gomock.NewController(t)
|
|
defer ctl.Finish()
|
|
mockDb, mockClock, hf := setupFn(ctl)
|
|
resp := httptest.NewRecorder()
|
|
req := toAPRequest(httptest.NewRequest("GET", testNoteId1, nil))
|
|
// Mock
|
|
mockDb.EXPECT().Lock(ctx, mustParse(testNoteId1))
|
|
mockDb.EXPECT().Get(ctx, mustParse(testNoteId1)).Return(testTombstone, nil)
|
|
mockDb.EXPECT().Unlock(ctx, mustParse(testNoteId1))
|
|
mockClock.EXPECT().Now().Return(now())
|
|
// Run & Verify
|
|
isAPReq, err := hf(ctx, resp, req)
|
|
assertEqual(t, isAPReq, true)
|
|
assertEqual(t, err, nil)
|
|
assertEqual(t, resp.Code, http.StatusGone)
|
|
respV := resp.Result()
|
|
assertEqual(t, respV.Header.Get(contentTypeHeader), "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\"")
|
|
assertEqual(t, respV.Header.Get(dateHeader), nowDateHeader())
|
|
assertNotEqual(t, len(respV.Header.Get(digestHeader)), 0)
|
|
b, err := ioutil.ReadAll(respV.Body)
|
|
assertEqual(t, err, nil)
|
|
assertByteEqual(t, b, mustSerializeToBytes(testTombstone))
|
|
})
|
|
t.Run("ServesContentWithStatusOk", func(t *testing.T) {
|
|
// Setup
|
|
ctl := gomock.NewController(t)
|
|
defer ctl.Finish()
|
|
mockDb, mockClock, hf := setupFn(ctl)
|
|
resp := httptest.NewRecorder()
|
|
req := toAPRequest(httptest.NewRequest("GET", testNoteId1, nil))
|
|
// Mock
|
|
mockDb.EXPECT().Lock(ctx, mustParse(testNoteId1))
|
|
mockDb.EXPECT().Get(ctx, mustParse(testNoteId1)).Return(testMyNote, nil)
|
|
mockDb.EXPECT().Unlock(ctx, mustParse(testNoteId1))
|
|
mockClock.EXPECT().Now().Return(now())
|
|
// Run & Verify
|
|
isAPReq, err := hf(ctx, resp, req)
|
|
assertEqual(t, isAPReq, true)
|
|
assertEqual(t, err, nil)
|
|
assertEqual(t, resp.Code, http.StatusOK)
|
|
respV := resp.Result()
|
|
assertEqual(t, respV.Header.Get(contentTypeHeader), "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\"")
|
|
assertEqual(t, respV.Header.Get(dateHeader), nowDateHeader())
|
|
assertNotEqual(t, len(respV.Header.Get(digestHeader)), 0)
|
|
b, err := ioutil.ReadAll(respV.Body)
|
|
assertEqual(t, err, nil)
|
|
assertByteEqual(t, b, mustSerializeToBytes(testMyNote))
|
|
})
|
|
}
|