mirror of
https://github.com/internetee/registry.git
synced 2025-07-28 05:26:17 +02:00
Added market share growth rate data endpoint
This commit is contained in:
parent
261e2d3162
commit
dc4c3cf616
6 changed files with 90 additions and 11 deletions
|
@ -1,11 +1,14 @@
|
||||||
module Repp
|
module Repp
|
||||||
module V1
|
module V1
|
||||||
class StatsController < BaseController
|
class StatsController < BaseController
|
||||||
api :get, '/repp/v1/stats/market_share'
|
api :get, '/repp/v1/stats/market_share_distribution'
|
||||||
desc 'Get market share and distribution of registrars'
|
desc 'Get market share and distribution of registrars'
|
||||||
def market_share
|
param :q, Hash, required: true, desc: 'Period parameters for data' do
|
||||||
|
param :end_date, String, required: true, desc: 'Period end date'
|
||||||
|
end
|
||||||
|
def market_share_distribution
|
||||||
registrars = ::Registrar.where(test_registrar: false).joins(:domains)
|
registrars = ::Registrar.where(test_registrar: false).joins(:domains)
|
||||||
registrars = registrars.where(from_condition).where(to_condition)
|
.where(from_condition).where(to_condition)
|
||||||
grouped = registrars.group(:name).count
|
grouped = registrars.group(:name).count
|
||||||
|
|
||||||
result = grouped.map do |key, value|
|
result = grouped.map do |key, value|
|
||||||
|
@ -16,22 +19,67 @@ module Repp
|
||||||
render_success(data: result)
|
render_success(data: result)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
api :get, '/repp/v1/stats/market_share_growth_rate'
|
||||||
|
desc 'Get market share and growth rate of registrars'
|
||||||
|
param :q, Hash, required: true, desc: 'Period parameters for data' do
|
||||||
|
param :end_date, String, required: true, desc: 'Period end date'
|
||||||
|
param :compare_to_date, String, required: true, desc: 'Comparison date'
|
||||||
|
end
|
||||||
|
def market_share_growth_rate
|
||||||
|
registrars = ::Registrar.where(test_registrar: false).joins(:domains)
|
||||||
|
.where(from_condition)
|
||||||
|
|
||||||
|
domains_by_registrar = registrars.where(to_condition).group(:name).count
|
||||||
|
prev_domains_by_registrar = registrars.where(compare_to_condition).group(:name).count
|
||||||
|
|
||||||
|
set_zero_values!(domains_by_registrar, prev_domains_by_registrar)
|
||||||
|
|
||||||
|
result = { prev_data: { name: search_params[:compare_to_date],
|
||||||
|
domains: serialize(prev_domains_by_registrar) },
|
||||||
|
data: { name: search_params[:end_date],
|
||||||
|
domains: serialize(domains_by_registrar) } }
|
||||||
|
render_success(data: result)
|
||||||
|
end
|
||||||
|
|
||||||
private
|
private
|
||||||
|
|
||||||
def search_params
|
def search_params
|
||||||
params.permit(:q, q: %i[start_date end_date]).fetch(:q, {}) || {}
|
params.permit(:q, q: %i[start_date end_date compare_to_date])
|
||||||
|
.fetch(:q, {}) || {}
|
||||||
end
|
end
|
||||||
|
|
||||||
def from_condition
|
def from_condition
|
||||||
return unless search_params[:start_date]
|
return unless search_params[:start_date]
|
||||||
|
|
||||||
"domains.created_at >= '#{Date.strptime(search_params[:start_date], '%m.%y')}'"
|
"domains.created_at >= '#{to_date(search_params[:start_date])}'"
|
||||||
end
|
end
|
||||||
|
|
||||||
def to_condition
|
def to_condition
|
||||||
return unless search_params[:end_date]
|
return unless search_params[:end_date]
|
||||||
|
|
||||||
"domains.created_at <= '#{Date.strptime(search_params[:end_date], '%m.%y').end_of_month}'"
|
"domains.created_at <= '#{to_date(search_params[:end_date]).end_of_month}'"
|
||||||
|
end
|
||||||
|
|
||||||
|
def compare_to_condition
|
||||||
|
return unless search_params[:compare_to_date]
|
||||||
|
|
||||||
|
"domains.created_at <= '#{to_date(search_params[:compare_to_date]).end_of_month}'"
|
||||||
|
end
|
||||||
|
|
||||||
|
def to_date(date_param)
|
||||||
|
Date.strptime(date_param, '%m.%y')
|
||||||
|
end
|
||||||
|
|
||||||
|
def serialize(rars)
|
||||||
|
rars.map { |key, value| [key, value] }
|
||||||
|
end
|
||||||
|
|
||||||
|
def set_zero_values!(cur, prev)
|
||||||
|
cur_dup = cur.dup
|
||||||
|
cur_dup.each_key do |k|
|
||||||
|
cur_dup[k] = prev[k] || 0
|
||||||
|
end
|
||||||
|
prev.clear.merge!(cur_dup)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -8,8 +8,11 @@ en:
|
||||||
date_long: "%d. %B %Y"
|
date_long: "%d. %B %Y"
|
||||||
filename: "%Y-%m-%d_%H.%M"
|
filename: "%Y-%m-%d_%H.%M"
|
||||||
date:
|
date:
|
||||||
|
month_names:
|
||||||
|
[~, January, February, March, April, May, June, July, August, September, October, November, December]
|
||||||
formats:
|
formats:
|
||||||
default: "%Y-%m-%d"
|
default: "%Y-%m-%d"
|
||||||
|
month_year: "%B, %Y"
|
||||||
|
|
||||||
activerecord:
|
activerecord:
|
||||||
errors:
|
errors:
|
||||||
|
|
|
@ -3,8 +3,11 @@ et:
|
||||||
password: 'Parool'
|
password: 'Parool'
|
||||||
|
|
||||||
date:
|
date:
|
||||||
# Don't forget the nil at the beginning; there's no such thing as a 0th month
|
month_names:
|
||||||
month_names: [~, Jaanuar, Veebruar, Märts, Aprill, Mai, Juuni, Juuli, August, September, Oktoober, November, Detsember]
|
[~, Jaanuar, Veebruar, Märts, April, Mai, Juuni, Juuli, August, September, Oktoober, November, Detsember]
|
||||||
|
formats:
|
||||||
|
default: "%Y-%m-%d"
|
||||||
|
month_year: "%B, %Y"
|
||||||
emails: "Meillaadressid"
|
emails: "Meillaadressid"
|
||||||
invoice:
|
invoice:
|
||||||
title: 'Arve'
|
title: 'Arve'
|
||||||
|
|
|
@ -101,7 +101,8 @@ Rails.application.routes.draw do
|
||||||
resources :retained_domains, only: %i[index]
|
resources :retained_domains, only: %i[index]
|
||||||
resources :stats do
|
resources :stats do
|
||||||
collection do
|
collection do
|
||||||
get '/market_share', to: 'stats#market_share'
|
get '/market_share_distribution', to: 'stats#market_share_distribution'
|
||||||
|
get '/market_share_growth_rate', to: 'stats#market_share_growth_rate'
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
namespace :registrar do
|
namespace :registrar do
|
||||||
|
|
4
test/fixtures/domains.yml
vendored
4
test/fixtures/domains.yml
vendored
|
@ -12,6 +12,7 @@ shop:
|
||||||
period: 1
|
period: 1
|
||||||
period_unit: m
|
period_unit: m
|
||||||
uuid: 1b3ee442-e8fe-4922-9492-8fcb9dccc69c
|
uuid: 1b3ee442-e8fe-4922-9492-8fcb9dccc69c
|
||||||
|
created_at: <%= 2.days.ago.to_s :db %>
|
||||||
|
|
||||||
airport:
|
airport:
|
||||||
name: airport.test
|
name: airport.test
|
||||||
|
@ -24,6 +25,7 @@ airport:
|
||||||
period: 1
|
period: 1
|
||||||
period_unit: m
|
period_unit: m
|
||||||
uuid: 2df2c1a1-8f6a-490a-81be-8bdf29866880
|
uuid: 2df2c1a1-8f6a-490a-81be-8bdf29866880
|
||||||
|
created_at: <%= 2.days.ago.to_s :db %>
|
||||||
|
|
||||||
library:
|
library:
|
||||||
name: library.test
|
name: library.test
|
||||||
|
@ -36,6 +38,7 @@ library:
|
||||||
period: 1
|
period: 1
|
||||||
period_unit: m
|
period_unit: m
|
||||||
uuid: 647bcc48-8d5e-4a04-8ce5-2a3cd17b6eab
|
uuid: 647bcc48-8d5e-4a04-8ce5-2a3cd17b6eab
|
||||||
|
created_at: <%= 2.days.ago.to_s :db %>
|
||||||
|
|
||||||
metro:
|
metro:
|
||||||
name: metro.test
|
name: metro.test
|
||||||
|
@ -48,6 +51,7 @@ metro:
|
||||||
period: 1
|
period: 1
|
||||||
period_unit: m
|
period_unit: m
|
||||||
uuid: ef97cb80-333b-4893-b9df-163f2b452798
|
uuid: ef97cb80-333b-4893-b9df-163f2b452798
|
||||||
|
created_at: <%= 2.days.ago.to_s :db %>
|
||||||
|
|
||||||
hospital:
|
hospital:
|
||||||
name: hospital.test
|
name: hospital.test
|
||||||
|
|
|
@ -7,10 +7,12 @@ class ReppV1StatsMarketShareTest < ActionDispatch::IntegrationTest
|
||||||
token = "Basic #{token}"
|
token = "Basic #{token}"
|
||||||
|
|
||||||
@auth_headers = { 'Authorization' => token }
|
@auth_headers = { 'Authorization' => token }
|
||||||
|
@today = Time.zone.today.strftime('%m.%y')
|
||||||
end
|
end
|
||||||
|
|
||||||
def test_shows_market_share_data
|
def test_shows_market_share_distribution_data
|
||||||
get '/repp/v1/stats/market_share', headers: @auth_headers
|
get '/repp/v1/stats/market_share_distribution', headers: @auth_headers,
|
||||||
|
params: { q: { end_date: @today } }
|
||||||
json = JSON.parse(response.body, symbolize_names: true)
|
json = JSON.parse(response.body, symbolize_names: true)
|
||||||
|
|
||||||
assert_response :ok
|
assert_response :ok
|
||||||
|
@ -22,4 +24,22 @@ class ReppV1StatsMarketShareTest < ActionDispatch::IntegrationTest
|
||||||
assert_equal json[:data][0][:name], 'Best Names'
|
assert_equal json[:data][0][:name], 'Best Names'
|
||||||
assert json[:data][0][:selected]
|
assert json[:data][0][:selected]
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def test_shows_market_share_growth_rate_data
|
||||||
|
prev_date = Time.zone.today.last_month.strftime('%m.%y')
|
||||||
|
get '/repp/v1/stats/market_share_growth_rate', headers: @auth_headers,
|
||||||
|
params: { q: { end_date: @today,
|
||||||
|
compare_to_date: prev_date } }
|
||||||
|
json = JSON.parse(response.body, symbolize_names: true)
|
||||||
|
|
||||||
|
assert_response :ok
|
||||||
|
assert_equal 1000, json[:code]
|
||||||
|
assert_equal 'Command completed successfully', json[:message]
|
||||||
|
|
||||||
|
data = json[:data]
|
||||||
|
assert data[:data].is_a? Hash
|
||||||
|
assert data[:prev_data].is_a? Hash
|
||||||
|
assert_equal data[:data][:name], @today
|
||||||
|
assert data[:data][:domains].is_a? Array
|
||||||
|
end
|
||||||
end
|
end
|
Loading…
Add table
Add a link
Reference in a new issue