Add v1 migration for completeness, fix independent migration

lib/kafkaesque/migrations.ex

@@ -17,6 +17,8 @@ defmodule Kafkaesque.Migrations do
 
       timestamps()
     end
+
+    create_if_not_exists(index(:kafkaesque_messages, [:state]))
   end
 
   def down() do
@@ -25,6 +27,22 @@ defmodule Kafkaesque.Migrations do
 
   def up(current, next)
 
+  def up(nil, :v1) do
+    create table(:kafkaesque_messages, primary_key: false) do
+      add(:id, :bigserial, primary_key: true)
+      add(:state, :string, null: false, default: "pending")
+      add(:topic, :string, null: false)
+      add(:partition, :integer, null: false)
+      add(:body, :binary)
+      add(:attempt, :integer, null: false, default: 0)
+      add(:attempted_by, :string)
+      add(:attempted_at, :naive_datetime)
+      add(:published_at, :naive_datetime)
+
+      timestamps()
+    end
+  end
+
   def up(:v1, :v2) do
     alter table(:kafkaesque_messages) do
       add_if_not_exists(:key, :binary, default: "", null: false)
@@ -46,4 +64,8 @@ defmodule Kafkaesque.Migrations do
       remove_if_exists(:key, :binary)
     end
   end
+
+  def down(:v1, nil) do
+    drop(table(:kafkaesque_messages))
+  end
 end