Sutty/panel
5
0
Fork 0
mirror of https://0xacab.org/sutty/sutty synced 2024-11-16 16:01:41 +00:00
Code Issues Projects Releases Wiki Activity

fix: estos cambios no pertenecen a esta rama

Browse source
This commit is contained in:
f 2023-04-15 14:39:55 -03:00
parent d59fa43082
commit bdac1fb0b8
1 changed files with 1 additions and 210 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

211
db/schema.rb
View file

@ -184,14 +184,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.index ["deploy_id"], name: "index_build_stats_on_deploy_id" t.index ["deploy_id"], name: "index_build_stats_on_deploy_id"
end end
create_table "codes_of_conduct", force: :cascade do |t|
t.datetime "created_at", precision: 6, null: false
t.datetime "updated_at", precision: 6, null: false
t.string "title"
t.text "description"
t.text "content"
end
create_table "csp_reports", id: :uuid, default: nil, force: :cascade do |t| create_table "csp_reports", id: :uuid, default: nil, force: :cascade do |t|
t.datetime "created_at", precision: 6, null: false t.datetime "created_at", precision: 6, null: false
t.datetime "updated_at", precision: 6, null: false t.datetime "updated_at", precision: 6, null: false
@ -233,14 +225,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.integer "priority" t.integer "priority"
end end
create_table "distributed_press_publishers", force: :cascade do |t|
t.datetime "created_at", precision: 6, null: false
t.datetime "updated_at", precision: 6, null: false
t.string "instance"
t.text "token_ciphertext", null: false
t.datetime "expires_at"
end
create_table "indexed_posts", id: :uuid, default: -> { "gen_random_uuid()" }, force: :cascade do |t| create_table "indexed_posts", id: :uuid, default: -> { "gen_random_uuid()" }, force: :cascade do |t|
t.bigint "site_id" t.bigint "site_id"
t.datetime "created_at", precision: 6, null: false t.datetime "created_at", precision: 6, null: false
@ -254,7 +238,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.tsvector "indexed_content" t.tsvector "indexed_content"
t.integer "order", default: 0 t.integer "order", default: 0
t.string "dictionary" t.string "dictionary"
t.uuid "post_id"
t.index ["front_matter"], name: "index_indexed_posts_on_front_matter", using: :gin t.index ["front_matter"], name: "index_indexed_posts_on_front_matter", using: :gin
t.index ["indexed_content"], name: "index_indexed_posts_on_indexed_content", using: :gin t.index ["indexed_content"], name: "index_indexed_posts_on_indexed_content", using: :gin
t.index ["layout"], name: "index_indexed_posts_on_layout" t.index ["layout"], name: "index_indexed_posts_on_layout"
@ -270,7 +253,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.text "deed" t.text "deed"
t.string "url" t.string "url"
t.string "icons" t.string "icons"
t.string "short_description"
end end
create_table "log_entries", force: :cascade do |t| create_table "log_entries", force: :cascade do |t|
@ -316,56 +298,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.index ["translatable_id", "translatable_type", "locale", "key"], name: "index_mobility_text_translations_on_keys", unique: true t.index ["translatable_id", "translatable_type", "locale", "key"], name: "index_mobility_text_translations_on_keys", unique: true
end end
create_table "privacy_policies", force: :cascade do |t|
t.datetime "created_at", precision: 6, null: false
t.datetime "updated_at", precision: 6, null: false
t.string "title"
t.text "description"
t.text "content"
end
create_table "que_jobs", comment: "7", force: :cascade do |t|
t.integer "priority", limit: 2, default: 100, null: false
t.datetime "run_at", default: -> { "now()" }, null: false
t.text "job_class", null: false
t.integer "error_count", default: 0, null: false
t.text "last_error_message"
t.text "queue", default: "default", null: false
t.text "last_error_backtrace"
t.datetime "finished_at"
t.datetime "expired_at"
t.jsonb "args", default: [], null: false
t.jsonb "data", default: {}, null: false
t.integer "job_schema_version", null: false
t.jsonb "kwargs", default: {}, null: false
t.index ["args"], name: "que_jobs_args_gin_idx", opclass: :jsonb_path_ops, using: :gin
t.index ["data"], name: "que_jobs_data_gin_idx", opclass: :jsonb_path_ops, using: :gin
t.index ["job_schema_version", "queue", "priority", "run_at", "id"], name: "que_poll_idx", where: "((finished_at IS NULL) AND (expired_at IS NULL))"
t.index ["kwargs"], name: "que_jobs_kwargs_gin_idx", opclass: :jsonb_path_ops, using: :gin
t.check_constraint "(char_length(last_error_message) <= 500) AND (char_length(last_error_backtrace) <= 10000)", name: "error_length"
t.check_constraint "(jsonb_typeof(data) = 'object'::text) AND ((NOT (data ? 'tags'::text)) OR ((jsonb_typeof((data -> 'tags'::text)) = 'array'::text) AND (jsonb_array_length((data -> 'tags'::text)) <= 5) AND que_validate_tags((data -> 'tags'::text))))", name: "valid_data"
t.check_constraint "char_length(queue) <= 100", name: "queue_length"
t.check_constraint "jsonb_typeof(args) = 'array'::text", name: "valid_args"
t.check_constraint nil, name: "job_class_length"
end
create_table "que_lockers", primary_key: "pid", id: :integer, default: nil, force: :cascade do |t|
t.integer "worker_count", null: false
t.integer "worker_priorities", null: false, array: true
t.integer "ruby_pid", null: false
t.text "ruby_hostname", null: false
t.text "queues", null: false, array: true
t.boolean "listening", null: false
t.integer "job_schema_version", default: 1
t.check_constraint "(array_ndims(queues) = 1) AND (array_length(queues, 1) IS NOT NULL)", name: "valid_queues"
t.check_constraint "(array_ndims(worker_priorities) = 1) AND (array_length(worker_priorities, 1) IS NOT NULL)", name: "valid_worker_priorities"
end
create_table "que_values", primary_key: "key", id: :text, force: :cascade do |t|
t.jsonb "value", default: {}, null: false
t.check_constraint "jsonb_typeof(value) = 'object'::text", name: "valid_value"
end
create_table "roles", force: :cascade do |t| create_table "roles", force: :cascade do |t|
t.datetime "created_at", null: false t.datetime "created_at", null: false
t.datetime "updated_at", null: false t.datetime "updated_at", null: false
@ -403,7 +335,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.string "tienda_api_key_ciphertext", default: "" t.string "tienda_api_key_ciphertext", default: ""
t.string "tienda_url", default: "" t.string "tienda_url", default: ""
t.string "api_key_ciphertext" t.string "api_key_ciphertext"
t.string "slugify_mode", default: "default"
t.index ["design_id"], name: "index_sites_on_design_id" t.index ["design_id"], name: "index_sites_on_design_id"
t.index ["licencia_id"], name: "index_sites_on_licencia_id" t.index ["licencia_id"], name: "index_sites_on_licencia_id"
t.index ["name"], name: "index_sites_on_name", unique: true t.index ["name"], name: "index_sites_on_name", unique: true
@ -433,6 +364,7 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.integer "failed_attempts", default: 0, null: false t.integer "failed_attempts", default: 0, null: false
t.string "unlock_token" t.string "unlock_token"
t.datetime "locked_at" t.datetime "locked_at"
t.boolean "acepta_politicas_de_privacidad", default: false
t.string "invitation_token" t.string "invitation_token"
t.datetime "invitation_created_at" t.datetime "invitation_created_at"
t.datetime "invitation_sent_at" t.datetime "invitation_sent_at"
@ -442,10 +374,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
t.bigint "invited_by_id" t.bigint "invited_by_id"
t.integer "invitations_count", default: 0 t.integer "invitations_count", default: 0
t.string "lang", default: "es" t.string "lang", default: "es"
t.datetime "privacy_policy_accepted_at"
t.datetime "terms_of_service_accepted_at"
t.datetime "code_of_conduct_accepted_at"
t.datetime "available_for_feedback_accepted_at"
t.index ["confirmation_token"], name: "index_usuaries_on_confirmation_token", unique: true t.index ["confirmation_token"], name: "index_usuaries_on_confirmation_token", unique: true
t.index ["email"], name: "index_usuaries_on_email", unique: true t.index ["email"], name: "index_usuaries_on_email", unique: true
t.index ["invitation_token"], name: "index_usuaries_on_invitation_token", unique: true t.index ["invitation_token"], name: "index_usuaries_on_invitation_token", unique: true
@ -458,143 +386,6 @@ ActiveRecord::Schema.define(version: 2023_04_15_153231) do
add_foreign_key "active_storage_attachments", "active_storage_blobs", column: "blob_id" add_foreign_key "active_storage_attachments", "active_storage_blobs", column: "blob_id"
add_foreign_key "active_storage_variant_records", "active_storage_blobs", column: "blob_id" add_foreign_key "active_storage_variant_records", "active_storage_blobs", column: "blob_id"
# no candidate create_trigger statement could be found, creating an adapter-specific one
execute(<<-SQL)
CREATE OR REPLACE FUNCTION public.que_job_notify()
RETURNS trigger
LANGUAGE plpgsql
AS $function$
DECLARE
locker_pid integer;
sort_key json;
BEGIN
-- Don't do anything if the job is scheduled for a future time.
IF NEW.run_at IS NOT NULL AND NEW.run_at > now() THEN
RETURN null;
END IF;
-- Pick a locker to notify of the job's insertion, weighted by their number
-- of workers. Should bounce pseudorandomly between lockers on each
-- invocation, hence the md5-ordering, but still touch each one equally,
-- hence the modulo using the job_id.
SELECT pid
INTO locker_pid
FROM (
SELECT *, last_value(row_number) OVER () + 1 AS count
FROM (
SELECT *, row_number() OVER () - 1 AS row_number
FROM (
SELECT *
FROM public.que_lockers ql, generate_series(1, ql.worker_count) AS id
WHERE
listening AND
queues @> ARRAY[NEW.queue] AND
ql.job_schema_version = NEW.job_schema_version
ORDER BY md5(pid::text || id::text)
) t1
) t2
) t3
WHERE NEW.id % count = row_number;
IF locker_pid IS NOT NULL THEN
-- There's a size limit to what can be broadcast via LISTEN/NOTIFY, so
-- rather than throw errors when someone enqueues a big job, just
-- broadcast the most pertinent information, and let the locker query for
-- the record after it's taken the lock. The worker will have to hit the
-- DB in order to make sure the job is still visible anyway.
SELECT row_to_json(t)
INTO sort_key
FROM (
SELECT
'job_available' AS message_type,
NEW.queue AS queue,
NEW.priority AS priority,
NEW.id AS id,
-- Make sure we output timestamps as UTC ISO 8601
to_char(NEW.run_at AT TIME ZONE 'UTC', 'YYYY-MM-DD"T"HH24:MI:SS.US"Z"') AS run_at
) t;
PERFORM pg_notify('que_listener_' || locker_pid::text, sort_key::text);
END IF;
RETURN null;
END
$function$
SQL
# no candidate create_trigger statement could be found, creating an adapter-specific one
execute("CREATE TRIGGER que_job_notify AFTER INSERT ON \"que_jobs\" FOR EACH ROW WHEN (NOT COALESCE(current_setting('que.skip_notify'::text, true), ''::text) = 'true'::text) EXECUTE FUNCTION que_job_notify()")
# no candidate create_trigger statement could be found, creating an adapter-specific one
execute(<<-SQL)
CREATE OR REPLACE FUNCTION public.que_state_notify()
RETURNS trigger
LANGUAGE plpgsql
AS $function$
DECLARE
row record;
message json;
previous_state text;
current_state text;
BEGIN
IF TG_OP = 'INSERT' THEN
previous_state := 'nonexistent';
current_state := public.que_determine_job_state(NEW);
row := NEW;
ELSIF TG_OP = 'DELETE' THEN
previous_state := public.que_determine_job_state(OLD);
current_state := 'nonexistent';
row := OLD;
ELSIF TG_OP = 'UPDATE' THEN
previous_state := public.que_determine_job_state(OLD);
current_state := public.que_determine_job_state(NEW);
-- If the state didn't change, short-circuit.
IF previous_state = current_state THEN
RETURN null;
END IF;
row := NEW;
ELSE
RAISE EXCEPTION 'Unrecognized TG_OP: %', TG_OP;
END IF;
SELECT row_to_json(t)
INTO message
FROM (
SELECT
'job_change' AS message_type,
row.id AS id,
row.queue AS queue,
coalesce(row.data->'tags', '[]'::jsonb) AS tags,
to_char(row.run_at AT TIME ZONE 'UTC', 'YYYY-MM-DD"T"HH24:MI:SS.US"Z"') AS run_at,
to_char(now() AT TIME ZONE 'UTC', 'YYYY-MM-DD"T"HH24:MI:SS.US"Z"') AS time,
CASE row.job_class
WHEN 'ActiveJob::QueueAdapters::QueAdapter::JobWrapper' THEN
coalesce(
row.args->0->>'job_class',
'ActiveJob::QueueAdapters::QueAdapter::JobWrapper'
)
ELSE
row.job_class
END AS job_class,
previous_state AS previous_state,
current_state AS current_state
) t;
PERFORM pg_notify('que_state', message::text);
RETURN null;
END
$function$
SQL
# no candidate create_trigger statement could be found, creating an adapter-specific one
execute("CREATE TRIGGER que_state_notify AFTER INSERT OR DELETE OR UPDATE ON \"que_jobs\" FOR EACH ROW WHEN (NOT COALESCE(current_setting('que.skip_notify'::text, true), ''::text) = 'true'::text) EXECUTE FUNCTION que_state_notify()")
create_trigger("indexed_posts_before_insert_update_row_tr", :compatibility => 1). create_trigger("indexed_posts_before_insert_update_row_tr", :compatibility => 1).
on("indexed_posts"). on("indexed_posts").