33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
# File 'lib/webhookdb/organization/database_migration.rb', line 33
def self.enqueue(admin_connection_url_raw:, readonly_connection_url_raw:, public_host:, started_by:, organization:)
self.guard_ongoing!(organization)
self.db.transaction do
dbm = self.create(
started_by:,
organization:,
organization_schema: organization.replication_schema,
source_admin_connection_url: organization.admin_connection_url_raw,
destination_admin_connection_url: admin_connection_url_raw,
)
organization.update(
public_host:,
admin_connection_url_raw:,
readonly_connection_url_raw:,
)
return dbm
end
end
|