コミットを比較
3
コミット
| 作成者 | SHA1 | 日付 | |
|---|---|---|---|
|
|
d6486cda3e | ||
|
|
62f501be2e | ||
|
|
da63b46d4b |
@@ -5,7 +5,6 @@ class MaterialVersionsController < ApplicationController
|
|||||||
|
|
||||||
page = 1 if page < 1
|
page = 1 if page < 1
|
||||||
limit = 1 if limit < 1
|
limit = 1 if limit < 1
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
offset = (page - 1) * limit
|
offset = (page - 1) * limit
|
||||||
|
|
||||||
|
|||||||
@@ -14,7 +14,6 @@ class MaterialsController < ApplicationController
|
|||||||
|
|
||||||
page = 1 if page < 1
|
page = 1 if page < 1
|
||||||
limit = 1 if limit < 1
|
limit = 1 if limit < 1
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
offset = (page - 1) * limit
|
offset = (page - 1) * limit
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,6 @@ class NicoTagsController < ApplicationController
|
|||||||
|
|
||||||
page = 1 if page < 1
|
page = 1 if page < 1
|
||||||
limit = 1 if limit < 1
|
limit = 1 if limit < 1
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
post_tag_max_sql =
|
post_tag_max_sql =
|
||||||
PostExternalTag
|
PostExternalTag
|
||||||
|
|||||||
@@ -11,7 +11,6 @@ class PostVersionsController < ApplicationController
|
|||||||
|
|
||||||
page = 1 if page < 1
|
page = 1 if page < 1
|
||||||
limit = 1 if limit < 1
|
limit = 1 if limit < 1
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
offset = (page - 1) * limit
|
offset = (page - 1) * limit
|
||||||
|
|
||||||
|
|||||||
@@ -34,7 +34,6 @@ class PostsController < ApplicationController
|
|||||||
|
|
||||||
page = 1 if page < 1
|
page = 1 if page < 1
|
||||||
limit = 1 if limit < 1
|
limit = 1 if limit < 1
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
offset = (page - 1) * limit
|
offset = (page - 1) * limit
|
||||||
|
|
||||||
|
|||||||
@@ -7,7 +7,6 @@ class TagVersionsController < ApplicationController
|
|||||||
|
|
||||||
page = 1 if page < 1
|
page = 1 if page < 1
|
||||||
limit = 1 if limit < 1
|
limit = 1 if limit < 1
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
offset = (page - 1) * limit
|
offset = (page - 1) * limit
|
||||||
|
|
||||||
|
|||||||
@@ -33,7 +33,6 @@ class TagsController < ApplicationController
|
|||||||
|
|
||||||
page = 1 if page < 1
|
page = 1 if page < 1
|
||||||
limit = 1 if limit < 1
|
limit = 1 if limit < 1
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
offset = (page - 1) * limit
|
offset = (page - 1) * limit
|
||||||
|
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ class TheatreCommentsController < ApplicationController
|
|||||||
def index
|
def index
|
||||||
limit = params[:limit].to_i
|
limit = params[:limit].to_i
|
||||||
limit = 20 if limit <= 0
|
limit = 20 if limit <= 0
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
no_gt = params[:no_gt].to_i
|
no_gt = params[:no_gt].to_i
|
||||||
no_gt = 0 if no_gt < 0
|
no_gt = 0 if no_gt < 0
|
||||||
@@ -10,7 +9,6 @@ class TheatreCommentsController < ApplicationController
|
|||||||
comments = TheatreComment
|
comments = TheatreComment
|
||||||
.where(theatre_id: params[:theatre_id])
|
.where(theatre_id: params[:theatre_id])
|
||||||
.where('no > ?', no_gt)
|
.where('no > ?', no_gt)
|
||||||
.includes(:user)
|
|
||||||
.order(no: :desc)
|
.order(no: :desc)
|
||||||
.limit(limit)
|
.limit(limit)
|
||||||
|
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ class TheatreProgrammesController < ApplicationController
|
|||||||
def index
|
def index
|
||||||
limit = params[:limit].to_i
|
limit = params[:limit].to_i
|
||||||
limit = 100 if limit <= 0
|
limit = 100 if limit <= 0
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
position_gt = params[:position_gt].to_i
|
position_gt = params[:position_gt].to_i
|
||||||
position_gt = 0 if position_gt < 0
|
position_gt = 0 if position_gt < 0
|
||||||
@@ -11,7 +10,7 @@ class TheatreProgrammesController < ApplicationController
|
|||||||
.where(theatre_id: params[:theatre_id])
|
.where(theatre_id: params[:theatre_id])
|
||||||
.where('position > ?', position_gt)
|
.where('position > ?', position_gt)
|
||||||
.includes(:post)
|
.includes(:post)
|
||||||
.order(position: :desc)
|
.order(position: :desc).limit(100)
|
||||||
.limit(limit)
|
.limit(limit)
|
||||||
|
|
||||||
render json: programmes.map { |programme|
|
render json: programmes.map { |programme|
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ class TheatreSkipEventsController < ApplicationController
|
|||||||
def index
|
def index
|
||||||
limit = params[:limit].to_i
|
limit = params[:limit].to_i
|
||||||
limit = 50 if limit <= 0
|
limit = 50 if limit <= 0
|
||||||
limit = 100 if limit > 100
|
|
||||||
|
|
||||||
events =
|
events =
|
||||||
TheatreSkipEvent
|
TheatreSkipEvent
|
||||||
|
|||||||
@@ -3,8 +3,8 @@ class PostTagSearch
|
|||||||
def self.literals(locale, raw)
|
def self.literals(locale, raw)
|
||||||
tokens = raw.split.reject { _1.downcase == 'type:or' }
|
tokens = raw.split.reject { _1.downcase == 'type:or' }
|
||||||
names = tokens.map { _1.sub(/\Anot:/i, '') }
|
names = tokens.map { _1.sub(/\Anot:/i, '') }
|
||||||
registered = TagName.where(language_code: locale.language_code, name: names)
|
registered = matching_names(TagName.where(language_code: locale.language_code),
|
||||||
.pluck(:name, :tag_id).to_h
|
names, 'tag_names.name', :tag_id).to_h
|
||||||
primary = TagName.where(language_code: locale.language_code,
|
primary = TagName.where(language_code: locale.language_code,
|
||||||
tag_id: registered.values, primary_flg: true).pluck(:tag_id, :name).to_h
|
tag_id: registered.values, primary_flg: true).pluck(:tag_id, :name).to_h
|
||||||
tokens.zip(names).map do |token, name|
|
tokens.zip(names).map do |token, name|
|
||||||
@@ -19,12 +19,25 @@ class PostTagSearch
|
|||||||
|
|
||||||
def self.references_for(locale, literals)
|
def self.references_for(locale, literals)
|
||||||
names = literals.map { _1[:name] }.uniq
|
names = literals.map { _1[:name] }.uniq
|
||||||
internal = TagName.where(language_code: locale.language_code, name: names)
|
internal = matching_names(TagName.where(language_code: locale.language_code),
|
||||||
.pluck(:name, :tag_id).group_by(&:first)
|
names, 'tag_names.name', :tag_id).group_by(&:first)
|
||||||
external = names.empty? ? {} : ExternalTag.where(
|
external = matching_names(ExternalTag.all, names,
|
||||||
"CONCAT(platform, ':', name) IN (?)", names)
|
"CONCAT(external_tags.platform, ':', external_tags.name)", :id).group_by(&:first)
|
||||||
.pluck(Arel.sql("CONCAT(platform, ':', name)"), :id).group_by(&:first)
|
|
||||||
names.to_h { |name| [name, [internal.fetch(name, []).map(&:last).uniq,
|
names.to_h { |name| [name, [internal.fetch(name, []).map(&:last).uniq,
|
||||||
external.fetch(name, []).map(&:last).uniq]] }
|
external.fetch(name, []).map(&:last).uniq]] }
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def self.matching_names(scope, names, expression, identifier)
|
||||||
|
return [] if names.empty?
|
||||||
|
|
||||||
|
queries = names.uniq.map do |name|
|
||||||
|
scope.klass.sanitize_sql_array(['SELECT ? AS name', name])
|
||||||
|
end
|
||||||
|
# Return the input spelling so Ruby does not recheck database equivalence.
|
||||||
|
scope.joins(<<~SQL).pluck(Arel.sql('search_names.name'), identifier)
|
||||||
|
INNER JOIN (#{ queries.join(' UNION ALL ') }) AS search_names
|
||||||
|
ON #{ expression } = search_names.name COLLATE utf8mb4_0900_ai_ci
|
||||||
|
SQL
|
||||||
|
end
|
||||||
|
private_class_method :matching_names
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -1,174 +0,0 @@
|
|||||||
require 'rails_helper'
|
|
||||||
|
|
||||||
RSpec.describe 'List API limits', type: :request do
|
|
||||||
shared_examples 'a capped list' do |default_count, minimum_count, paginated|
|
|
||||||
def response_rows
|
|
||||||
body = json
|
|
||||||
body.is_a?(Array) ? body : body.fetch(collection_key)
|
|
||||||
end
|
|
||||||
|
|
||||||
it 'caps oversized limits at 100 and preserves the 100 boundary' do
|
|
||||||
get path, params: { locale: 'ja', limit: 100 }
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(response_rows.size).to eq(100)
|
|
||||||
boundary_rows = response_rows
|
|
||||||
|
|
||||||
[101, 10_000].each do |limit|
|
|
||||||
get path, params: { locale: 'ja', limit: }
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(response_rows).to eq(boundary_rows)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
it 'preserves the default, nonpositive and small positive limits' do
|
|
||||||
get path, params: { locale: 'ja' }
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(response_rows.size).to eq(default_count)
|
|
||||||
|
|
||||||
[0, -1].each do |limit|
|
|
||||||
get path, params: { locale: 'ja', limit: }
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(response_rows.size).to eq(minimum_count)
|
|
||||||
end
|
|
||||||
|
|
||||||
get path, params: { locale: 'ja', limit: 2 }
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(response_rows.size).to eq(2)
|
|
||||||
end
|
|
||||||
|
|
||||||
if paginated
|
|
||||||
it 'uses the capped limit for page offsets and preserves total count' do
|
|
||||||
get path, params: { locale: 'ja', limit: 100 }
|
|
||||||
first_page = response_rows
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(json.fetch('count')).to eq(101)
|
|
||||||
|
|
||||||
get path, params: { locale: 'ja', limit: 100, page: 2 }
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(response_rows.size).to eq(1)
|
|
||||||
second_page = response_rows
|
|
||||||
expect(first_page & second_page).to be_empty
|
|
||||||
|
|
||||||
get path, params: { locale: 'ja', limit: 101, page: 2 }
|
|
||||||
expect(response).to have_http_status(:ok)
|
|
||||||
expect(response_rows).to eq(second_page)
|
|
||||||
expect(json.fetch('count')).to eq(101)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'posts' do
|
|
||||||
let(:path) { '/posts' }
|
|
||||||
let(:collection_key) { 'posts' }
|
|
||||||
before { create_list(:post, 101) }
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 1, true
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'tags' do
|
|
||||||
let(:path) { '/tags' }
|
|
||||||
let(:collection_key) { 'tags' }
|
|
||||||
before { create_list(:tag, 101) }
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 1, true
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'nico tags' do
|
|
||||||
let(:path) { '/tags/nico' }
|
|
||||||
let(:collection_key) { 'tags' }
|
|
||||||
before { create_list(:external_tag, 101) }
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 1, true
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'materials' do
|
|
||||||
let(:path) { '/materials' }
|
|
||||||
let(:collection_key) { 'materials' }
|
|
||||||
before do
|
|
||||||
101.times { |index| Material.create!(url: "https://example.com/material-#{ index }") }
|
|
||||||
end
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 1, true
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'post versions' do
|
|
||||||
let(:path) { '/posts/versions' }
|
|
||||||
let(:collection_key) { 'versions' }
|
|
||||||
let(:post) { create(:post) }
|
|
||||||
before do
|
|
||||||
101.times do |index|
|
|
||||||
PostVersion.create!(post:, version_no: index + 1, event_type: 'update',
|
|
||||||
url: post.url, tags: '', tags_json: [], parent_post_ids: '')
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 1, true
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'tag versions' do
|
|
||||||
let(:path) { '/tags/versions' }
|
|
||||||
let(:collection_key) { 'versions' }
|
|
||||||
let(:tag) { create(:tag) }
|
|
||||||
before do
|
|
||||||
101.times do |index|
|
|
||||||
TagVersion.create!(tag:, version_no: index + 1, event_type: 'update',
|
|
||||||
name: 'limit tag', category: 'general', aliases: '',
|
|
||||||
parent_tag_ids: '', names: {
|
|
||||||
ja: { name: 'limit tag', script_code: 'Jpan',
|
|
||||||
auto_generated: false, aliases: [] } })
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 1, true
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'material versions' do
|
|
||||||
let(:path) { '/materials/versions' }
|
|
||||||
let(:collection_key) { 'versions' }
|
|
||||||
let(:material) { Material.create!(url: 'https://example.com/material') }
|
|
||||||
before do
|
|
||||||
101.times do |index|
|
|
||||||
MaterialVersion.create!(material:, version_no: index + 1,
|
|
||||||
event_type: 'update', url: material.url)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 1, true
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'theatre lists' do
|
|
||||||
let(:theatre) { create(:theatre) }
|
|
||||||
let(:post) { create(:post) }
|
|
||||||
|
|
||||||
context 'comments' do
|
|
||||||
let(:path) { "/theatres/#{ theatre.id }/comments" }
|
|
||||||
before { create_list(:theatre_comment, 101, theatre:, user: theatre.created_by_user) }
|
|
||||||
|
|
||||||
include_examples 'a capped list', 20, 20, false
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'programmes' do
|
|
||||||
let(:path) { "/theatres/#{ theatre.id }/programmes" }
|
|
||||||
before do
|
|
||||||
101.times do |index|
|
|
||||||
TheatreProgramme.create!(theatre:, post:, position: index + 1)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
include_examples 'a capped list', 100, 100, false
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'skip events' do
|
|
||||||
let(:path) { "/theatres/#{ theatre.id }/skip_events" }
|
|
||||||
before do
|
|
||||||
101.times do |index|
|
|
||||||
TheatreSkipEvent.create!(theatre:, post:,
|
|
||||||
skipped_by_user: theatre.created_by_user,
|
|
||||||
created_at: Time.utc(2026, 1, 1) + index.seconds)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
include_examples 'a capped list', 50, 50, false
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
@@ -206,6 +206,25 @@ RSpec.describe 'Posts API', type: :request do
|
|||||||
end
|
end
|
||||||
|
|
||||||
context 'when q is provided' do
|
context 'when q is provided' do
|
||||||
|
['SPEC_TAG', 'SpEc_TaG', 'spec_tág', 'MANKO', 'MaNkO', 'mánko'].each do |name|
|
||||||
|
it "matches #{ name } using database collation" do
|
||||||
|
get '/posts', params: { locale: 'ja', tags: name }
|
||||||
|
|
||||||
|
expect(response).to have_http_status(:ok)
|
||||||
|
expect(json.fetch('count')).to eq(2)
|
||||||
|
expect(json.fetch('posts').map { _1.fetch('id') })
|
||||||
|
.to contain_exactly(post_record.id, hit_post.id)
|
||||||
|
end
|
||||||
|
|
||||||
|
it "excludes #{ name } using database collation" do
|
||||||
|
get '/posts', params: { locale: 'ja', tags: "not:#{ name }" }
|
||||||
|
|
||||||
|
expect(response).to have_http_status(:ok)
|
||||||
|
expect(json.fetch('count')).to eq(1)
|
||||||
|
expect(json.fetch('posts').map { _1.fetch('id') }).to eq([miss_post.id])
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
it 'filters posts by q (hit case)' do
|
it 'filters posts by q (hit case)' do
|
||||||
get '/posts', params: { tags: 'spec_tag' }
|
get '/posts', params: { tags: 'spec_tag' }
|
||||||
|
|
||||||
@@ -266,6 +285,26 @@ RSpec.describe 'Posts API', type: :request do
|
|||||||
PostExternalTag.create!(post: miss_post, external_tag:)
|
PostExternalTag.create!(post: miss_post, external_tag:)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
['NICO:SEARCH_EXTERNAL', 'NiCo:SeArCh_ExTeRnAl', 'nico:séarch_external'].each do |name|
|
||||||
|
it "matches #{ name } using database collation" do
|
||||||
|
get '/posts', params: { locale: 'ja', tags: name }
|
||||||
|
|
||||||
|
expect(response).to have_http_status(:ok)
|
||||||
|
expect(json.fetch('count')).to eq(2)
|
||||||
|
expect(json.fetch('posts').map { _1.fetch('id') })
|
||||||
|
.to contain_exactly(miss_post.id, both_post.id)
|
||||||
|
end
|
||||||
|
|
||||||
|
it "excludes #{ name } using database collation" do
|
||||||
|
get '/posts', params: { locale: 'ja', tags: "not:#{ name }" }
|
||||||
|
|
||||||
|
expect(response).to have_http_status(:ok)
|
||||||
|
expect(json.fetch('count')).to eq(2)
|
||||||
|
expect(json.fetch('posts').map { _1.fetch('id') })
|
||||||
|
.to contain_exactly(post_record.id, hit_post.id)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
it 'keeps internal name searches independent of colliding external ids' do
|
it 'keeps internal name searches independent of colliding external ids' do
|
||||||
get '/posts', params: { tags: primary_tag_name_for(tag, 'ja').name }
|
get '/posts', params: { tags: primary_tag_name_for(tag, 'ja').name }
|
||||||
|
|
||||||
|
|||||||
新しいイシューから参照
ユーザーをブロックする