Database Migrations

def up(db: Any)
  db.create_collection("users")
  db.create_index("users", "idx_email", ["email"], { "unique": true })
end

def down(db: Any)
  db.drop_index("users", "idx_email")
  db.drop_collection("users")
end

def up(db)
  for user in User.all()
    next unless user.slug.blank?
    user.slug = user.name.downcase().gsub(" ", "-")
    user.save()
  end
end

def down(db)
  # irreversible backfill
end

def up(db: Any)
  db.create_collection("users")                       # document
  db.create_collection("posts")
  db.create_collection("contact_documents", "blob")   # blob
  db.create_collection("follows", "edge")             # edge (graph)
  db.create_collection("metrics", "timeseries")       # timeseries

  # Columnar stores use the dedicated helper (create_collection with
  # "columnar" raises — columnar stores are not document collections)
  db.create_columnar("page_views", [
    { "name": "url", "type": "string" },
    { "name": "country", "type": "string", "indexed": true }
  ])

  # Edge collections: hash-index the endpoints so traversals stay fast
  # (dev auto-create does both steps for you)
  db.create_index("follows", "idx_follows_from", ["_from"], {})
  db.create_index("follows", "idx_follows_to", ["_to"], {})

  # Timeseries collections: one-off cleanup of old rows
  db.prune_collection("metrics", "2026-01-01T00:00:00Z")
end

def down(db: Any)
  db.drop_collection("comments")
  db.drop_collection("posts")
  db.drop_collection("users")
end

def up(db: Any)    # Simple index
  db.create_index("users", "idx_email", ["email"], {})
  # Unique index
  db.create_index("users", "idx_username", ["username"], { "unique": true })
  # Typed index — "hash" is the default; "persistent" for sorted/range lookups
  db.create_index("users", "idx_age", ["age"], { "type": "persistent" })
  # Fulltext index
  db.create_index("articles", "idx_articles_ft", ["title", "body"], { "type": "fulltext" })
  # Compound index on multiple fields
  db.create_index("users", "idx_name", ["first_name", "last_name"], {})
  # Unique compound index
  db.create_index("posts", "idx_user_slug", ["user_id", "slug"], { "unique": true })
end

def down(db: Any)
  db.drop_index("posts", "idx_user_slug")
  db.drop_index("users", "idx_name")
  db.drop_index("articles", "idx_articles_ft")
  db.drop_index("users", "idx_age")
  db.drop_index("users", "idx_username")
  db.drop_index("users", "idx_email")
end

def up(db: Any)    # Insert seed data
  db.query("INSERT { name: 'Admin', role: 'admin' } INTO users")
  # Update existing data
  db.query("FOR u IN users FILTER u.role == 'guest' UPDATE u WITH { role: 'user' } IN users")

  # Bind variables (preferred for user data — avoids escaping issues)
  digest = bcrypt_hash("changeme")
  db.query(
    "INSERT { email: @e, name: @n, role: @r, password_digest: @d } INTO users",
    { "e": "admin@example.com", "n": "Admin", "r": "admin", "d": digest }
  )

  # Bind variables work in FILTER / RETURN too
  db.query(
    "FOR doc IN users FILTER doc.status == @status RETURN doc",
    { "status": "active" }
  )
end

def up(db: Any)    # Create collections
  db.create_collection("users")
  db.create_collection("posts")
  db.create_collection("comments")
  db.create_collection("tags")
  # User indexes
  db.create_index("users", "idx_users_email", ["email"], { "unique": true })
  db.create_index("users", "idx_users_username", ["username"], { "unique": true })
  # Post indexes
  db.create_index("posts", "idx_posts_author", ["author_id"], {})
  db.create_index("posts", "idx_posts_slug", ["slug"], { "unique": true })
  db.create_index("posts", "idx_posts_published", ["published_at"], { "sparse": true })
  # Comment indexes
  db.create_index("comments", "idx_comments_post", ["post_id"], {})
  db.create_index("comments", "idx_comments_author", ["author_id"], {})
  # Tag indexes
  db.create_index("tags", "idx_tags_name", ["name"], { "unique": true })
end

def down(db: Any)    # Drop indexes first
  db.drop_index("tags", "idx_tags_name")
  db.drop_index("comments", "idx_comments_author")
  db.drop_index("comments", "idx_comments_post")
  db.drop_index("posts", "idx_posts_published")
  db.drop_index("posts", "idx_posts_slug")
  db.drop_index("posts", "idx_posts_author")
  db.drop_index("users", "idx_users_username")
  db.drop_index("users", "idx_users_email")
  # Drop collections
  db.drop_collection("tags")
  db.drop_collection("comments")
  db.drop_collection("posts")
  db.drop_collection("users")
end

3.times do |i|
  let email = "user#{i}@example.com"
  User.create({ "name": "User #{i}", "email": email }) if User.first_by("email", email).nil?
end

print("Seeded users")

connection "analytics"

def up(db)
  db.create_table("events", { "id": "pk", "name": "string" })
end

def down(db)
  db.drop_table("events")
end

def up(db)
  db.create_table("orders", {
    "id":         "pk",
    "code":       { "type": "string", "limit": 32, "null": false },
    "amount":     "decimal(10,2)",
    "qty":        "integer",
    "paid":       { "type": "boolean", "default": false },
    "meta":       "json",
    "user_id":    { "type": "bigint", "references": "users" },
    "timestamps": true
  })
  db.add_index("orders", ["code"], { "unique": true })
end

def down(db)
  db.drop_table("orders")
end

SOLIDB_HOST=http://localhost:6745
SOLIDB_DATABASE=myapp_development
SOLIDB_USERNAME=root
SOLIDB_PASSWORD=secret