Skip to content

Commit be26168

Browse files
committed
derive table mappings from schema mappings
1 parent 5d841a3 commit be26168

File tree

1 file changed

+2
-23
lines changed

1 file changed

+2
-23
lines changed

scripts/database_migration.exs

Lines changed: 2 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -34,27 +34,6 @@ defmodule DatabaseMigration do
3434

3535
require Logger
3636

37-
@table_mappings %{
38-
"User" => "users",
39-
"Org" => "users",
40-
"GithubUser" => "users",
41-
"Account" => "identities",
42-
"OrgMember" => "members",
43-
"Task" => "tickets",
44-
"GithubIssue" => nil,
45-
"GithubPullRequest" => nil,
46-
"Bounty" => "bounties",
47-
"Reward" => nil,
48-
"Attempt" => "attempts",
49-
"Claim" => "claims",
50-
"BountyCharge" => "transactions",
51-
"BountyTransfer" => "transactions",
52-
"GithubInstallation" => "installations",
53-
"StripeAccount" => "accounts",
54-
"StripeCustomer" => "customers",
55-
"StripePaymentMethod" => "payment_methods"
56-
}
57-
5837
@schema_mappings %{
5938
"User" => User,
6039
"Org" => User,
@@ -92,7 +71,7 @@ defmodule DatabaseMigration do
9271
"users"
9372
]
9473

95-
@relevant_tables Map.keys(@table_mappings)
74+
@relevant_tables Map.keys(@schema_mappings)
9675

9776
defp transform("Task", row, db) do
9877
if row["forge"] != "github" do
@@ -687,7 +666,7 @@ defmodule DatabaseMigration do
687666
end
688667
end
689668

690-
defp transform_table_name(table_name), do: @table_mappings[table_name]
669+
defp transform_table_name(table_name), do: if(schema = @schema_mappings[table_name], do: schema.__schema__(:source))
691670

692671
defp post_transform(table_name, row) do
693672
schema = @schema_mappings[table_name]

0 commit comments

Comments
 (0)