mirror of
https://github.com/discourse/discourse.git
synced 2024-12-02 03:13:43 +08:00
7c3a29c9d6
* Updates GitHub Actions * Switches from `bundler/inline` to an optional group in the `Gemfile` because the previous solution didn't work well with rspec * Adds the converter framework and tests * Allows loading private converters (see README) * Switches from multiple CLI tools to a single CLI * Makes DB connections reusable and adds a new abstraction for the `IntermediateDB` * `IntermediateDB` acts as an interface for IPC calls when a converter steps runs in parallel (forks). Only the main process writes to the DB. * Includes a simple example implementation of a converter for now.
60 lines
1.2 KiB
Ruby
60 lines
1.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "date"
|
|
require "extralite"
|
|
require "ipaddr"
|
|
|
|
module Migrations
|
|
module Database
|
|
INTERMEDIATE_DB_SCHEMA_PATH = File.join(::Migrations.root_path, "db", "intermediate_db_schema")
|
|
UPLOADS_DB_SCHEMA_PATH = File.join(::Migrations.root_path, "db", "uploads_db_schema")
|
|
|
|
module_function
|
|
|
|
def migrate(db_path, migrations_path:)
|
|
Migrator.new(db_path).migrate(migrations_path)
|
|
end
|
|
|
|
def reset!(db_path)
|
|
Migrator.new(db_path).reset!
|
|
end
|
|
|
|
def connect(path)
|
|
connection = Connection.new(path:)
|
|
return connection unless block_given?
|
|
|
|
begin
|
|
yield(connection)
|
|
ensure
|
|
connection.close
|
|
end
|
|
nil
|
|
end
|
|
|
|
def format_datetime(value)
|
|
value&.utc&.iso8601
|
|
end
|
|
|
|
def format_date(value)
|
|
value&.to_date&.iso8601
|
|
end
|
|
|
|
def format_boolean(value)
|
|
return nil if value.nil?
|
|
value ? 1 : 0
|
|
end
|
|
|
|
def format_ip_address(value)
|
|
return nil if value.blank?
|
|
IPAddr.new(value).to_s
|
|
rescue ArgumentError
|
|
nil
|
|
end
|
|
|
|
def to_blob(value)
|
|
return nil if value.blank?
|
|
Extralite::Blob.new(value)
|
|
end
|
|
end
|
|
end
|