respond_to :activitystreams2
def show
- headers['Access-Control-Allow-Origin'] = '*'
+ if params[:max_id] || params[:since_id]
+ show_outbox_page
+ else
+ show_base_outbox
+ end
+ end
+
+ private
- @statuses = Status.as_outbox_timeline(@account).paginate_by_max_id(limit_param(DEFAULT_STATUSES_LIMIT), params[:max_id], params[:since_id])
+ def show_base_outbox
+ @statuses = Status.as_outbox_timeline(@account)
@statuses = cache_collection(@statuses)
set_maps(@statuses)
- # Since the statuses are in reverse chronological order, last is the lowest ID.
- @next_path = api_activitypub_outbox_url(max_id: @statuses.last.id) if @statuses.size == limit_param(DEFAULT_STATUSES_LIMIT)
+ set_first_last_page(@statuses)
- unless @statuses.empty?
- if @statuses.first.id == 1
- @prev_path = api_activitypub_outbox_url
- elsif params[:max_id]
- @prev_path = api_activitypub_outbox_url(since_id: @statuses.first.id)
- end
- end
+ render :show
+ end
- @paginated = @next_path || @prev_path
+ def show_outbox_page
+ all_statuses = Status.as_outbox_timeline(@account)
+ @statuses = all_statuses.paginate_by_max_id(limit_param(DEFAULT_STATUSES_LIMIT), params[:max_id], params[:since_id])
- set_pagination_headers(@next_path, @prev_path)
- end
+ all_statuses = cache_collection(all_statuses)
+ @statuses = cache_collection(@statuses)
- private
+ set_maps(@statuses)
+
+ set_first_last_page(all_statuses)
+
+ @next_page_url = api_activitypub_outbox_url(pagination_params(max_id: @statuses.last.id)) unless @statuses.empty?
+ @prev_page_url = api_activitypub_outbox_url(pagination_params(since_id: @statuses.first.id)) unless @statuses.empty?
+
+ @paginated = @next_page_url || @prev_page_url
+ @part_of_url = api_activitypub_outbox_url
+
+ set_pagination_headers(@next_page_url, @prev_page_url)
+
+ render :show_page
+ end
def cache_collection(raw)
super(raw, Status)
def set_account
@account = Account.find(params[:id])
end
+
+ def set_first_last_page(statuses) # rubocop:disable Style/AccessorMethodName
+ return if statuses.empty?
+
+ @first_page_url = api_activitypub_outbox_url(max_id: statuses.first.id + 1)
+ @last_page_url = api_activitypub_outbox_url(since_id: statuses.last.id - 1)
+ end
+
+ def pagination_params(core_params)
+ params.permit(:local, :limit).merge(core_params)
+ end
end
public_status = nil
before do
- public_status = Status.create!(account: user.account, text: 'Hello world', visibility: :public)
+ public_status = Fabricate(:status, account: user.account, text: 'Hello world', visibility: :public)
@request.env['HTTP_ACCEPT'] = 'application/activity+json'
get :show_status, params: { id: public_status.id }
expect(response.header['Content-Type']).to include 'application/activity+json'
end
- it 'sets Access-Control-Allow-Origin header to *' do
- expect(response.header['Access-Control-Allow-Origin']).to eq '*'
- end
-
it 'returns http success' do
json_data = JSON.parse(response.body)
expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
reblog = nil
before do
- original = Status.create!(account: user.account, text: 'Hello world', visibility: :public)
- reblog = Status.create!(account: user.account, reblog_of_id: original.id, visibility: :public)
+ original = Fabricate(:status, account: user.account, text: 'Hello world', visibility: :public)
+ reblog = Fabricate(:status, account: user.account, reblog_of_id: original.id, visibility: :public)
@request.env['HTTP_ACCEPT'] = 'application/activity+json'
get :show_status, params: { id: reblog.id }
expect(response.header['Content-Type']).to include 'application/activity+json'
end
- it 'sets Access-Control-Allow-Origin header to *' do
- expect(response.header['Access-Control-Allow-Origin']).to eq '*'
- end
-
it 'returns http success' do
json_data = JSON.parse(response.body)
expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
public_status = nil
before do
- public_status = Status.create!(account: user_alice.account, text: 'Hello world', visibility: :public)
+ public_status = Fabricate(:status, account: user_alice.account, text: 'Hello world', visibility: :public)
@request.env['HTTP_ACCEPT'] = 'application/activity+json'
get :show, params: { id: public_status.id }
expect(response.header['Content-Type']).to include 'application/activity+json'
end
- it 'sets Access-Control-Allow-Origin header to *' do
- expect(response.header['Access-Control-Allow-Origin']).to eq '*'
- end
-
it 'returns http success' do
json_data = JSON.parse(response.body)
expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
reply = nil
before do
- original = Status.create!(account: user_alice.account, text: 'Hello world', visibility: :public)
- reply = Status.create!(account: user_bob.account, text: 'Hello world', in_reply_to_id: original.id, visibility: :public)
+ original = Fabricate(:status, account: user_alice.account, text: 'Hello world', visibility: :public)
+ reply = Fabricate(:status, account: user_bob.account, text: 'Hello world', in_reply_to_id: original.id, visibility: :public)
@request.env['HTTP_ACCEPT'] = 'application/activity+json'
get :show, params: { id: reply.id }
expect(response.header['Content-Type']).to include 'application/activity+json'
end
- it 'sets Access-Control-Allow-Origin header to *' do
- expect(response.header['Access-Control-Allow-Origin']).to eq '*'
- end
-
it 'returns http success' do
json_data = JSON.parse(response.body)
expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
describe 'GET #show' do
before do
- @request.env['HTTP_ACCEPT'] = 'application/activity+json'
+ @request.headers['ACCEPT'] = 'application/activity+json'
end
- describe 'small number of statuses' do
+ describe 'collection with small number of statuses' do
public_status = nil
before do
- public_status = Status.create!(account: user.account, text: 'Hello world', visibility: :public)
- Status.create!(account: user.account, text: 'Hello world', visibility: :private)
- Status.create!(account: user.account, text: 'Hello world', visibility: :unlisted)
- Status.create!(account: user.account, text: 'Hello world', visibility: :direct)
+ public_status = Fabricate(:status, account: user.account, text: 'Hello world', visibility: :public)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :private)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :unlisted)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :direct)
get :show, params: { id: user.account.id }
end
expect(response.header['Content-Type']).to include 'application/activity+json'
end
- it 'sets Access-Control-Allow-Origin header to *' do
- expect(response.header['Access-Control-Allow-Origin']).to eq '*'
- end
-
it 'returns AS2 JSON body' do
json_data = JSON.parse(response.body)
expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
expect(json_data).to include('id' => @request.url)
expect(json_data).to include('type' => 'OrderedCollection')
expect(json_data).to include('totalItems' => 1)
- expect(json_data).to include('items')
- expect(json_data['items'].count).to eq(1)
- expect(json_data['items']).to include(api_activitypub_status_url(public_status))
+ expect(json_data).to include('current')
+ expect(json_data).to include('first')
+ expect(json_data).to include('last')
end
end
- describe 'large number of statuses' do
+ describe 'collection with large number of statuses' do
before do
30.times do
- Status.create!(account: user.account, text: 'Hello world', visibility: :public)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :public)
end
- Status.create!(account: user.account, text: 'Hello world', visibility: :private)
- Status.create!(account: user.account, text: 'Hello world', visibility: :unlisted)
- Status.create!(account: user.account, text: 'Hello world', visibility: :direct)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :private)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :unlisted)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :direct)
+
+ get :show, params: { id: user.account.id }
end
- describe 'first page' do
- before do
- get :show, params: { id: user.account.id }
- end
+ it 'returns http success' do
+ expect(response).to have_http_status(:success)
+ end
- it 'returns http success' do
- expect(response).to have_http_status(:success)
- end
+ it 'sets Content-Type header to AS2' do
+ expect(response.header['Content-Type']).to include 'application/activity+json'
+ end
- it 'sets Content-Type header to AS2' do
- expect(response.header['Content-Type']).to include 'application/activity+json'
- end
+ it 'returns AS2 JSON body' do
+ json_data = JSON.parse(response.body)
+ expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
+ expect(json_data).to include('id' => @request.url)
+ expect(json_data).to include('type' => 'OrderedCollection')
+ expect(json_data).to include('totalItems' => 30)
+ expect(json_data).to include('current')
+ expect(json_data).to include('first')
+ expect(json_data).to include('last')
+ end
+ end
+
+ describe 'page with small number of statuses' do
+ statuses = []
- it 'sets Access-Control-Allow-Origin header to *' do
- expect(response.header['Access-Control-Allow-Origin']).to eq '*'
+ before do
+ 5.times do
+ statuses << Fabricate(:status, account: user.account, text: 'Hello world', visibility: :public)
end
- it 'returns AS2 JSON body' do
- json_data = JSON.parse(response.body)
- expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
- expect(json_data).to include('id' => @request.url)
- expect(json_data).to include('type' => 'OrderedCollectionPage')
- expect(json_data).to include('totalItems' => 20)
- expect(json_data).to include('items')
- expect(json_data['items'].count).to eq(20)
- expect(json_data).to include('current' => @request.url)
- expect(json_data).to include('next')
- expect(json_data).to_not include('prev')
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :private)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :unlisted)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :direct)
+
+ get :show, params: { id: user.account.id, max_id: statuses.last.id + 1 }
+ end
+
+ it 'returns http success' do
+ expect(response).to have_http_status(:success)
+ end
+
+ it 'sets Content-Type header to AS2' do
+ expect(response.header['Content-Type']).to include 'application/activity+json'
+ end
+
+ it 'returns AS2 JSON body' do
+ json_data = JSON.parse(response.body)
+ expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
+ expect(json_data).to include('id' => @request.url)
+ expect(json_data).to include('type' => 'OrderedCollectionPage')
+ expect(json_data).to include('partOf')
+ expect(json_data).to include('items')
+ expect(json_data['items'].length).to eq(5)
+ expect(json_data).to include('prev')
+ expect(json_data).to include('next')
+ expect(json_data).to include('current')
+ expect(json_data).to include('first')
+ expect(json_data).to include('last')
+ end
+ end
+
+ describe 'page with large number of statuses' do
+ statuses = []
+
+ before do
+ 30.times do
+ statuses << Fabricate(:status, account: user.account, text: 'Hello world', visibility: :public)
end
+
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :private)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :unlisted)
+ Fabricate(:status, account: user.account, text: 'Hello world', visibility: :direct)
+
+ get :show, params: { id: user.account.id, max_id: statuses.last.id + 1 }
+ end
+
+ it 'returns http success' do
+ expect(response).to have_http_status(:success)
+ end
+
+ it 'sets Content-Type header to AS2' do
+ expect(response.header['Content-Type']).to include 'application/activity+json'
+ end
+
+ it 'returns AS2 JSON body' do
+ json_data = JSON.parse(response.body)
+ expect(json_data).to include('@context' => 'https://www.w3.org/ns/activitystreams')
+ expect(json_data).to include('id' => @request.url)
+ expect(json_data).to include('type' => 'OrderedCollectionPage')
+ expect(json_data).to include('partOf')
+ expect(json_data).to include('items')
+ expect(json_data['items'].length).to eq(20)
+ expect(json_data).to include('prev')
+ expect(json_data).to include('next')
+ expect(json_data).to include('current')
+ expect(json_data).to include('first')
+ expect(json_data).to include('last')
end
end
end
cat aescling's git repositories / mastodon.git / commitdiff