0bbaafe18f
We previously disabled the 4x storage option for Postgres in the US region. Now, with the introduction of new smallest size, new 2x option become equivalent to old 1x option. This change re-enables the option 4x option.
104 lines
4.4 KiB
Ruby
104 lines
4.4 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Clover
|
|
def postgres_post(name)
|
|
authorize("Postgres:create", @project.id)
|
|
fail Validation::ValidationFailed.new({billing_info: "Project doesn't have valid billing information"}) unless @project.has_valid_payment_method?
|
|
|
|
Validation.validate_postgres_location(@location)
|
|
|
|
required_parameters = ["size"]
|
|
required_parameters << "name" << "location" if web?
|
|
allowed_optional_parameters = ["storage_size", "ha_type", "version", "flavor"]
|
|
request_body_params = validate_request_params(required_parameters, allowed_optional_parameters)
|
|
parsed_size = Validation.validate_postgres_size(@location, request_body_params["size"])
|
|
|
|
ha_type = request_body_params["ha_type"] || PostgresResource::HaType::NONE
|
|
requested_standby_count = case ha_type
|
|
when PostgresResource::HaType::ASYNC then 1
|
|
when PostgresResource::HaType::SYNC then 2
|
|
else 0
|
|
end
|
|
|
|
requested_postgres_vcpu_count = (requested_standby_count + 1) * parsed_size.vcpu
|
|
Validation.validate_vcpu_quota(@project, "PostgresVCpu", requested_postgres_vcpu_count)
|
|
|
|
st = Prog::Postgres::PostgresResourceNexus.assemble(
|
|
project_id: @project.id,
|
|
location: @location,
|
|
name:,
|
|
target_vm_size: parsed_size.vm_size,
|
|
target_storage_size_gib: request_body_params["storage_size"] || parsed_size.storage_size_options.first,
|
|
ha_type: request_body_params["ha_type"] || PostgresResource::HaType::NONE,
|
|
version: request_body_params["version"] || PostgresResource::DEFAULT_VERSION,
|
|
flavor: request_body_params["flavor"] || PostgresResource::Flavor::STANDARD
|
|
)
|
|
send_notification_mail_to_partners(st.subject, current_account.email)
|
|
|
|
if api?
|
|
Serializers::Postgres.serialize(st.subject, {detailed: true})
|
|
else
|
|
flash["notice"] = "'#{name}' will be ready in a few minutes"
|
|
request.redirect "#{@project.path}#{PostgresResource[st.id].path}"
|
|
end
|
|
end
|
|
|
|
def postgres_list
|
|
dataset = dataset_authorize(@project.postgres_resources_dataset, "Postgres:view").eager(:semaphores, :strand)
|
|
if api?
|
|
dataset = dataset.where(location: @location) if @location
|
|
result = dataset.paginated_result(
|
|
start_after: request.params["start_after"],
|
|
page_size: request.params["page_size"],
|
|
order_column: request.params["order_column"]
|
|
)
|
|
|
|
{
|
|
items: Serializers::Postgres.serialize(result[:records]),
|
|
count: result[:count]
|
|
}
|
|
else
|
|
dataset = dataset.eager(:representative_server, :timeline)
|
|
@postgres_databases = Serializers::Postgres.serialize(dataset.all, {include_path: true})
|
|
view "postgres/index"
|
|
end
|
|
end
|
|
|
|
def send_notification_mail_to_partners(resource, user_email)
|
|
if [PostgresResource::Flavor::PARADEDB, PostgresResource::Flavor::LANTERN].include?(resource.flavor) && (email = Config.send(:"postgres_#{resource.flavor}_notification_email"))
|
|
flavor_name = resource.flavor.capitalize
|
|
Util.send_email(email, "New #{flavor_name} Postgres database has been created.",
|
|
greeting: "Hello #{flavor_name} team,",
|
|
body: ["New #{flavor_name} Postgres database has been created.",
|
|
"ID: #{resource.ubid}",
|
|
"Location: #{resource.location}",
|
|
"Name: #{resource.name}",
|
|
"E-mail: #{user_email}",
|
|
"Instance VM Size: #{resource.target_vm_size}",
|
|
"Instance Storage Size: #{resource.target_storage_size_gib}",
|
|
"HA: #{resource.ha_type}"])
|
|
end
|
|
end
|
|
|
|
def generate_postgres_options(flavor: "standard")
|
|
options = OptionTreeGenerator.new
|
|
|
|
options.add_option(name: "name")
|
|
options.add_option(name: "flavor", values: flavor)
|
|
options.add_option(name: "location", values: Option.postgres_locations.map(&:display_name), parent: "flavor")
|
|
options.add_option(name: "size", values: [2, 4, 8, 16, 30, 60].map { "standard-#{_1}" }, parent: "location")
|
|
|
|
options.add_option(name: "storage_size", values: ["64", "128", "256", "512", "1024", "2048", "4096"], parent: "size") do |flavor, location, size, storage_size|
|
|
size = size.split("-").last.to_i
|
|
lower_limit = [size * 32, 1024].min
|
|
upper_limit = (2**Math.log2(size).ceil) * 128
|
|
storage_size.to_i >= lower_limit && storage_size.to_i <= upper_limit
|
|
end
|
|
|
|
options.add_option(name: "version", values: ["16", "17"], parent: "flavor")
|
|
|
|
options.add_option(name: "ha_type", values: ["none", "async", "sync"], parent: "storage_size")
|
|
options.serialize
|
|
end
|
|
end
|