Add Consistem: Create Item workflow integrated with IRIS /namespaces/{ns}/createItem (#42)

* Add `Consistem: Create Item` workflow integrated with IRIS `/namespaces/{ns}/createItem`
* Show API validation errors inline in `Consistem: Create Item` input

Author: LeoAnders

package.json

@@ -651,6 +651,11 @@
         }
       ],
       "file/newFile": [
+        {
+          "command": "vscode-objectscript.ccs.createItem",
+          "when": "workspaceFolderCount != 0",
+          "group": "file"
+        },
         {
           "command": "vscode-objectscript.newFile.kpi",
           "when": "workspaceFolderCount != 0",
@@ -883,6 +888,11 @@
         "command": "vscode-objectscript.ccs.followSourceAnalysisLink",
         "title": "Follow Source Analysis Link"
       },
+      {
+        "category": "Consistem",
+        "command": "vscode-objectscript.ccs.createItem",
+        "title": "Create Item"
+      },
       {
         "category": "ObjectScript",
         "command": "vscode-objectscript.compile",

src/ccs/commands/createItem.ts

@@ -0,0 +1,304 @@
+import * as vscode from "vscode";
+import * as path from "path";
+
+import { AtelierAPI } from "../../api";
+import { getWsFolder, handleError } from "../../utils";
+import { logDebug, logError, logInfo } from "../core/logging";
+import { SourceControlApi } from "../sourcecontrol/client";
+import { CreateItemClient } from "../sourcecontrol/clients/createItemClient";
+import { getCcsSettings } from "../config/settings";
+
+interface PromptForItemNameOptions {
+  initialValue?: string;
+  validationMessage?: string;
+}
+
+async function promptForItemName(options: PromptForItemNameOptions = {}): Promise<string | undefined> {
+  const hasValidExt = (s: string) => /\.cls$/i.test(s) || /\.mac$/i.test(s);
+  const hasBadChars = (s: string) => /[\\/]/.test(s) || /\s/.test(s);
+
+  const ib = vscode.window.createInputBox();
+  ib.title = "Criar Item Consistem";
+  ib.prompt = "Informe o nome da classe ou rotina a ser criada (.cls ou .mac)";
+  ib.placeholder = "MeuPacote.MinhaClasse.cls ou MINHAROTINA.mac";
+  ib.ignoreFocusOut = true;
+  if (options.initialValue) {
+    ib.value = options.initialValue;
+  }
+  if (options.validationMessage) {
+    ib.validationMessage = {
+      message: options.validationMessage,
+      severity: vscode.InputBoxValidationSeverity.Error,
+    };
+  }
+
+  return await new Promise<string | undefined>((resolve) => {
+    const disposeAll = () => {
+      ib.dispose();
+      d1.dispose();
+      d2.dispose();
+      d3.dispose();
+    };
+
+    // Do not show an error while typing (silent mode)
+    const d1 = ib.onDidChangeValue(() => {
+      ib.validationMessage = undefined;
+    });
+
+    // When pressing Enter, validate EVERYTHING and highlight in red if invalid
+    const d2 = ib.onDidAccept(() => {
+      const name = ib.value.trim();
+
+      if (!name) {
+        ib.validationMessage = {
+          message: "Informe o nome do item",
+          severity: vscode.InputBoxValidationSeverity.Error,
+        };
+        return;
+      }
+      if (hasBadChars(name)) {
+        ib.validationMessage = {
+          message: "Nome inválido: não use espaços nem separadores de caminho (\\ ou /)",
+          severity: vscode.InputBoxValidationSeverity.Error,
+        };
+        return;
+      }
+      if (!hasValidExt(name)) {
+        ib.validationMessage = {
+          message: "Inclua uma extensão válida: .cls ou .mac",
+          severity: vscode.InputBoxValidationSeverity.Error,
+        };
+        return;
+      }
+
+      resolve(name);
+      disposeAll();
+    });
+
+    const d3 = ib.onDidHide(() => {
+      resolve(undefined);
+      disposeAll();
+    });
+
+    ib.show();
+  });
+}
+
+function ensureWorkspaceConnection(folder: vscode.WorkspaceFolder): AtelierAPI | undefined {
+  const api = new AtelierAPI(folder.uri);
+  if (!api.active) {
+    void vscode.window.showErrorMessage("Workspace folder is not connected to an InterSystems server.");
+    return undefined;
+  }
+
+  const { host, port } = api.config;
+  if (!host || !port || !api.ns) {
+    void vscode.window.showErrorMessage(
+      "Workspace folder does not have a fully configured InterSystems server connection."
+    );
+    return undefined;
+  }
+
+  return api;
+}
+
+async function openCreatedFile(filePath: string): Promise<void> {
+  // Ensure file exists before opening to avoid noisy errors
+  const uri = vscode.Uri.file(filePath);
+  await vscode.workspace.fs.stat(uri);
+  const document = await vscode.workspace.openTextDocument(uri);
+  await vscode.window.showTextDocument(document, { preview: false });
+}
+
+function extractModuleName(filePath: string, ws: vscode.WorkspaceFolder): string | undefined {
+  const rel = path.relative(ws.uri.fsPath, filePath);
+  if (!rel || rel.startsWith("..") || path.isAbsolute(rel)) return undefined;
+
+  const parts = rel.split(path.sep).filter(Boolean);
+  // Drop filename
+  parts.pop();
+  if (!parts.length) return undefined;
+
+  // Ignore common code folders
+  const ignored = new Set(["src", "classes", "classescls", "mac", "int", "inc", "cls", "udl"]);
+  for (let i = parts.length - 1; i >= 0; i--) {
+    const seg = parts[i];
+    if (!seg) continue;
+    if (seg.endsWith(":")) continue; // Windows drive guard (e.g., "C:")
+    if (ignored.has(seg.toLowerCase())) continue;
+    return seg;
+  }
+  return undefined;
+}
+
+function isTimeoutError(err: unknown): boolean {
+  return typeof err === "object" && err !== null && (err as any).code === "ECONNABORTED";
+}
+
+async function withTimeoutRetry<T>(fn: () => Promise<T>, attempts = 2, delayMs = 300): Promise<T> {
+  try {
+    return await fn();
+  } catch (e) {
+    if (!isTimeoutError(e) || attempts <= 0) throw e;
+    await new Promise((r) => setTimeout(r, delayMs));
+    return withTimeoutRetry(fn, attempts - 1, delayMs);
+  }
+}
+
+function getErrorMessage(err: unknown): string | undefined {
+  // Try to extract a meaningful message without hard axios dependency
+  const anyErr = err as any;
+  if (anyErr?.response?.data) {
+    const d = anyErr.response.data;
+    if (typeof d === "string" && d.trim()) return d.trim();
+    if (typeof d?.error === "string" && d.error.trim()) return d.error.trim();
+    if (typeof d?.message === "string" && d.message.trim()) return d.message.trim();
+    if (typeof d?.Message === "string" && d.Message.trim()) return d.Message.trim();
+  }
+  if (typeof anyErr?.message === "string" && anyErr.message.trim()) return anyErr.message.trim();
+  return undefined;
+}
+
+function getApiValidationMessage(err: unknown): string | undefined {
+  const anyErr = err as any;
+  const response = anyErr?.response;
+  if (!response?.data) return undefined;
+
+  const status = typeof response.status === "number" ? response.status : undefined;
+  if (typeof status === "number" && status >= 500) {
+    return undefined;
+  }
+
+  const data = response.data;
+  if (typeof data === "string" && data.trim()) return data.trim();
+  if (typeof data?.error === "string" && data.error.trim()) return data.error.trim();
+  if (typeof data?.message === "string" && data.message.trim()) return data.message.trim();
+  if (typeof data?.Message === "string" && data.Message.trim()) return data.Message.trim();
+  return undefined;
+}
+
+export async function createItem(): Promise<void> {
+  const workspaceFolder = await getWsFolder(
+    "Pick the workspace folder where you want to create the item",
+    false,
+    false,
+    false,
+    true
+  );
+
+  if (workspaceFolder === undefined) {
+    void vscode.window.showErrorMessage("No workspace folders are open.");
+    return;
+  }
+  if (!workspaceFolder) {
+    return;
+  }
+
+  const api = ensureWorkspaceConnection(workspaceFolder);
+  if (!api) {
+    return;
+  }
+
+  const ns = api.ns;
+  if (!ns) {
+    void vscode.window.showErrorMessage("Unable to determine active namespace for this workspace.");
+    return;
+  }
+  const namespace = ns.toUpperCase();
+
+  let sourceControlApi: SourceControlApi;
+  try {
+    sourceControlApi = SourceControlApi.fromAtelierApi(api);
+  } catch (error) {
+    handleError(error, "Failed to connect to the InterSystems SourceControl API.");
+    return;
+  }
+
+  const createItemClient = new CreateItemClient(sourceControlApi);
+
+  // Use configured requestTimeout to scale retry backoff (10%, clamped 150–500ms)
+  const { requestTimeout } = getCcsSettings();
+  const backoff = Math.min(500, Math.max(150, Math.floor(requestTimeout * 0.1)));
+
+  let lastValue: string | undefined;
+  let lastValidationMessage: string | undefined;
+
+  while (true) {
+    const itemName = await promptForItemName({ initialValue: lastValue, validationMessage: lastValidationMessage });
+    if (!itemName) {
+      return;
+    }
+
+    lastValue = itemName;
+    lastValidationMessage = undefined;
+
+    logDebug("Consistem createItem invoked", { namespace, itemName });
+
+    try {
+      const { data, status } = await vscode.window.withProgress(
+        {
+          location: vscode.ProgressLocation.Notification,
+          title: "Creating item...",
+          cancellable: false,
+        },
+        async () => withTimeoutRetry(() => createItemClient.create(namespace, itemName), 2, backoff)
+      );
+
+      if (data.error) {
+        logError("Consistem createItem failed", { namespace, itemName, status, error: data.error });
+        lastValidationMessage = data.error;
+        continue;
+      }
+
+      if (status < 200 || status >= 300) {
+        const message = `Item creation failed with status ${status}.`;
+        logError("Consistem createItem failed", { namespace, itemName, status });
+        void vscode.window.showErrorMessage(message);
+        return;
+      }
+
+      if (!data.file) {
+        const message = "Item created on server but no file path was returned.";
+        logError("Consistem createItem missing file path", { namespace, itemName, response: data });
+        void vscode.window.showErrorMessage(message);
+        return;
+      }
+
+      try {
+        await openCreatedFile(data.file);
+      } catch (openErr) {
+        logError("Failed to open created file", { file: data.file, error: openErr });
+        void vscode.window.showWarningMessage("Item created, but the returned file could not be opened.");
+      }
+
+      const createdNamespace = data.namespace ?? namespace;
+      const createdItem = (data as any).itemIdCriado ?? itemName;
+      const moduleName = extractModuleName(data.file, workspaceFolder);
+      const location = moduleName ? `${createdNamespace}/${moduleName}` : createdNamespace;
+      const successMessage = `Item created successfully in ${location}: ${createdItem}`;
+      logInfo("Consistem createItem succeeded", {
+        namespace: createdNamespace,
+        module: moduleName,
+        itemName: createdItem,
+        file: data.file,
+      });
+      void vscode.window.showInformationMessage(successMessage);
+      return;
+    } catch (error) {
+      const apiValidationMessage = getApiValidationMessage(error);
+      if (apiValidationMessage) {
+        logError("Consistem createItem API validation failed", { namespace, itemName, error: apiValidationMessage });
+        lastValidationMessage = apiValidationMessage;
+        continue;
+      }
+
+      const errorMessage =
+        (CreateItemClient as any).getErrorMessage?.(error) ??
+        getErrorMessage(error) ??
+        (isTimeoutError(error) ? "Item creation timed out." : "Item creation failed.");
+      logError("Consistem createItem encountered an unexpected error", error);
+      void vscode.window.showErrorMessage(errorMessage);
+      return;
+    }
+  }
+}

src/ccs/config/schema.md

@@ -6,7 +6,7 @@ para o fork da Consistem.
 | Chave            | Tipo                      | Padrão      | Descrição                                                                                                       |
 | ---------------- | ------------------------- | ----------- | --------------------------------------------------------------------------------------------------------------- |
 | `endpoint`       | `string`                  | `undefined` | URL base alternativa para a API. Se não definida, a URL é derivada da conexão ativa do Atelier.                 |
-| `requestTimeout` | `number`                  | `500`       | Tempo limite (ms) aplicado às chamadas HTTP do módulo. Valores menores ou inválidos são normalizados para zero. |
+| `requestTimeout` | `number`                  | `5000`       | Tempo limite (ms) aplicado às chamadas HTTP do módulo. Valores menores ou inválidos são normalizados para zero. |
 | `debugLogging`   | `boolean`                 | `false`     | Quando verdadeiro, registra mensagens detalhadas no `ObjectScript` Output Channel.                              |
 | `flags`          | `Record<string, boolean>` | `{}`        | Feature flags opcionais que podem ser lidas pelas features do módulo.                                           |
 

src/ccs/config/settings.ts

@@ -8,7 +8,7 @@ export interface CcsSettings {
 }
 
 const CCS_CONFIGURATION_SECTION = "objectscript.ccs";
-const DEFAULT_TIMEOUT = 500;
+const DEFAULT_TIMEOUT = 5000;
 
 export function getCcsSettings(): CcsSettings {
   const configuration = vscode.workspace.getConfiguration(CCS_CONFIGURATION_SECTION);

src/ccs/core/types.ts

@@ -19,3 +19,14 @@ export interface GlobalDocumentationResponse {
   content?: string | string[] | Record<string, unknown> | null;
   message?: string;
 }
+
+export interface CreateItemResponse {
+  item?: Record<string, unknown>;
+  name?: string;
+  documentName?: string;
+  namespace?: string;
+  module?: string;
+  message?: string;
+  path?: string;
+  uri?: string;
+}

src/ccs/index.ts

@@ -26,3 +26,4 @@ export {
   followSourceAnalysisLink,
   followSourceAnalysisLinkCommand,
 } from "./providers/SourceAnalysisLinkProvider";
+export { createItem } from "./commands/createItem";