fix: 5 bugs found during integration testing

src/commands/db/auth.ts

@@ -158,8 +158,8 @@ const roleSub = async (
   }
   const auth = await reg.getAuth();
   try {
-    if (op === "assign") auth.assignRole(targetUser, role);
-    else if (op === "remove") auth.removeRole(targetUser, role);
+    if (op === "assign") await auth.assignRole(targetUser, role);
+    else if (op === "remove") await auth.removeRole(targetUser, role);
     else throw new CommandError(EXIT.USAGE, `unknown role op: ${op}`);
   } catch (err) {
     if (err instanceof CommandError) throw err;

src/commands/db/crud.ts

@@ -250,9 +250,11 @@ export const aggregateHandler = async (
       case "$project":
         pipe = pipe.project(arg as Record<string, unknown>);
         break;
-      case "$unwind":
-        pipe = pipe.unwind(arg as string);
+      case "$unwind": {
+        const unwindField = typeof arg === "string" && arg.startsWith("$") ? arg.slice(1) : arg;
+        pipe = pipe.unwind(unwindField as string);
         break;
+      }
       default:
         throw new CommandError(EXIT.USAGE, `unknown aggregation operator: ${op}`);
     }

src/commands/db/meta.ts

@@ -26,7 +26,7 @@
       const sorted = flagBool(parsed.flags, "sorted");
       const unique = flagBool(parsed.flags, "unique");
       try {
-        c.createIndex(field, { sorted, unique });
+        c.createIndex(field, { type: sorted ? "sorted" : "hash", unique });
       } catch (err) {
         const msg = err instanceof Error ? err.message : String(err);
         if (msg.includes("Unique constraint")) {

src/commands/vec/ops.ts

@@ -220,7 +220,7 @@
       throw new CommandError(EXIT.VALIDATION, `validation: id collision: ${check.id}`);
     }
     const rec = parsedRec as Record<string, unknown>;
-    const recMeta = rec["meta"];
+    const recMeta = rec["metadata"] ?? rec["meta"];
     const meta = recMeta && typeof recMeta === "object" && !Array.isArray(recMeta)
       ? (recMeta as Record<string, unknown>)
       : {};
@@ -473,13 +473,17 @@
     throw new CommandError(EXIT.VALIDATION, "validation: invalid JSON for import");
   }
   if (!Array.isArray(parsedInput)) {
-    throw new CommandError(EXIT.VALIDATION, "validation: import expects an array of records");
+    if (parsedInput && typeof parsedInput === "object" && Array.isArray((parsedInput as Record<string, unknown>)["records"])) {
+      parsedInput = (parsedInput as Record<string, unknown>)["records"];
+    } else {
+      throw new CommandError(EXIT.VALIDATION, "validation: import expects an array of records");
+    }
   }
   // Validate every record before handing off to upstream — surface clear
   // errors with the offending index instead of letting upstream throw an
   // opaque "Cannot read property" mid-import.
   for (let i = 0; i < parsedInput.length; i++) {
     const check = checkVectorRecord(parsedInput[i], entry.dim);
     if (!check.ok) {
       throw new CommandError(
         EXIT.VALIDATION,
@@ -491,5 +495,5 @@
     coll,
     parsedInput as Array<{ id: string; vector: number[]; metadata?: Record<string, unknown> }>,
   );
   return { stdout: JSON.stringify({ imported: parsedInput.length }) };
 };