feat(agent): add review queue, versioning, bundles, archive, and draft workflow

- Fix migration 0010 variable shadowing (inner_row)
- Add migration 0011: AgentStatus pending/rejected, ListingStatus archived,
  component_bundles table, bundle_id FK on all listing tables, rejection_reason
- Add semver utilities (parse, validate, bump, suggest) with full test coverage
- Add agent review routes: list pending agents with component readiness check,
  approve (gated on all components approved), reject with reason
- Add bundle review: atomic approve/reject all components in a bundle
- Add agent archive endpoint (soft delete, admin only)
- Add draft workflow: save draft, update draft, submit for review
- Add version-suggestions endpoint and version bump on update
- Add created_by_email to agent list, detail, and leaderboard responses
- Add component leaderboard endpoint with user filter
- Add interactive CLI search (-i flag) for agents and MCP servers
- CLI: version bump prompt on publish --update, --draft flag, --beta for init
- CLI: agent delete now archives instead of hard-deleting
- Create GitHub issue #339 for username field

Signed-off-by: Hari Srinivasan <harisrini21@gmail.com>

Author: Haz3-jolt

observal-server/alembic/versions/0010_add_agents_name_uniqueness.py

@@ -22,22 +22,23 @@ def upgrade() -> None:
         DO $$
         DECLARE
             dup_row RECORD;
+            inner_row RECORD;
             counter INT;
         BEGIN
             FOR dup_row IN
                 SELECT name, created_by FROM agents
                 GROUP BY name, created_by HAVING COUNT(*) > 1
             LOOP
                 counter := 0;
-                FOR dup_row IN
+                FOR inner_row IN
                     SELECT id FROM agents
                     WHERE name = dup_row.name AND created_by = dup_row.created_by
                     ORDER BY created_at DESC OFFSET 1
                 LOOP
                     counter := counter + 1;
                     UPDATE agents
                     SET name = name || '-dup' || counter
-                    WHERE id = dup_row.id;
+                    WHERE id = inner_row.id;
                 END LOOP;
             END LOOP;
         END

observal-server/alembic/versions/0011_agent_review_and_bundles.py

@@ -0,0 +1,92 @@
+"""Add agent review statuses, component bundles, and archive support.
+
+- Extend AgentStatus enum with 'pending' and 'rejected'
+- Extend ListingStatus enum with 'archived'
+- Create component_bundles table for MCP-linked skills
+- Add bundle_id FK to all 5 listing tables
+- Add rejection_reason column to agents
+
+Revision ID: 0011
+Revises: 0010
+Create Date: 2026-04-17
+"""
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects.postgresql import UUID
+
+revision = "0011"
+down_revision = "0010"
+branch_labels = None
+depends_on = None
+
+_LISTING_TABLES = [
+    "mcp_listings",
+    "skill_listings",
+    "hook_listings",
+    "prompt_listings",
+    "sandbox_listings",
+]
+
+
+def upgrade() -> None:
+    # Enum extensions must run outside a transaction in PostgreSQL
+    op.execute("COMMIT")
+    op.execute("ALTER TYPE agentstatus ADD VALUE IF NOT EXISTS 'pending'")
+    op.execute("ALTER TYPE agentstatus ADD VALUE IF NOT EXISTS 'rejected'")
+    op.execute("ALTER TYPE listingstatus ADD VALUE IF NOT EXISTS 'archived'")
+    op.execute("BEGIN")
+
+    # Component bundles table
+    op.execute("""
+        CREATE TABLE IF NOT EXISTS component_bundles (
+            id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
+            name VARCHAR(255) NOT NULL,
+            description TEXT DEFAULT '',
+            submitted_by UUID NOT NULL REFERENCES users(id),
+            created_at TIMESTAMPTZ DEFAULT NOW()
+        )
+    """)
+
+    # Add bundle_id FK + index to each listing table
+    for table in _LISTING_TABLES:
+        op.execute(f"""
+            DO $$
+            BEGIN
+                IF NOT EXISTS (
+                    SELECT 1 FROM information_schema.columns
+                    WHERE table_name = '{table}' AND column_name = 'bundle_id'
+                ) THEN
+                    ALTER TABLE {table}
+                    ADD COLUMN bundle_id UUID REFERENCES component_bundles(id);
+                END IF;
+            END $$;
+        """)
+        op.execute(f"""
+            CREATE INDEX IF NOT EXISTS ix_{table}_bundle_id ON {table}(bundle_id)
+        """)
+
+    # Add rejection_reason to agents
+    op.execute("""
+        DO $$
+        BEGIN
+            IF NOT EXISTS (
+                SELECT 1 FROM information_schema.columns
+                WHERE table_name = 'agents' AND column_name = 'rejection_reason'
+            ) THEN
+                ALTER TABLE agents ADD COLUMN rejection_reason TEXT;
+            END IF;
+        END $$;
+    """)
+
+    # Index on agents.status for review queries
+    op.execute("CREATE INDEX IF NOT EXISTS ix_agents_status ON agents(status)")
+
+
+def downgrade() -> None:
+    op.execute("DROP INDEX IF EXISTS ix_agents_status")
+    op.execute("ALTER TABLE agents DROP COLUMN IF EXISTS rejection_reason")
+    for table in _LISTING_TABLES:
+        op.execute(f"DROP INDEX IF EXISTS ix_{table}_bundle_id")
+        op.execute(f"ALTER TABLE {table} DROP COLUMN IF EXISTS bundle_id")
+    op.execute("DROP TABLE IF EXISTS component_bundles")