Merge pull request #1032 from polywrap/origin-dev

Prep Origin 0.1.1

Author: dOrgJelli

CHANGELOG.md

@@ -1,3 +1,11 @@
+# Polywrap Origin (0.1.1)
+## Features
+* [PR-1017](https://github.com/polywrap/monorepo/pull/1017) `@polywrap/templates`, `polywrap` CLI: Rust wasm wrapper project template has been added, and made available via the `polywrap create ...` CLI command.
+
+## Bugs
+* [PR-1016](https://github.com/polywrap/monorepo/pull/1016) `polywrap` CLI: Improved logging when running workflows using the `polywrap run ...` command.
+* [PR-924](https://github.com/polywrap/monorepo/pull/924) `@polywrap/schema-parse`, `@polywrap/schema-bind`: Complex `Map<Key, Value>` type usages within wrapper schemas lead to incorrect bindings being generated. Additional tests + fixes have been added.
+
 # Polywrap Origin (0.1.0)
 ![Public Release Announcement (2)](https://user-images.githubusercontent.com/5522128/177474776-76886b67-6554-41a9-841b-939728e273ca.png)
 

VERSION

@@ -1 +1 @@
-0.1.0
+0.1.1

packages/cli/bin/polywrap

@@ -10,4 +10,4 @@ if (['v', 'version', '-v', '--v', '-version', '--version'].includes(process.argv
 }
 
 var sourceDir = __dirname + '/../build'
-require(sourceDir + '/cli').run(process.argv)
+require(sourceDir + '/cli').run(process.argv)

packages/cli/src/__tests__/e2e/create.spec.ts

@@ -13,7 +13,7 @@ Options:
 
 Commands:
   wasm [options] <language> <name>    Create a Polywrap wasm wrapper langs:
-                                      assemblyscript, interface
+                                      assemblyscript, rust, interface
   app [options] <language> <name>     Create a Polywrap application langs:
                                       typescript-node, typescript-react
   plugin [options] <language> <name>  Create a Polywrap plugin langs:

packages/cli/src/__tests__/e2e/run.spec.ts

@@ -230,32 +230,38 @@ describe("e2e tests for run command", () => {
         "./workflows/config.ts",
         "-v",
         "./workflows/validator.cue",
-        "-q",
       ],
       cwd: testCaseRoot,
       cli: polywrapCli,
     });
 
-    expect(stdout).toBe("");
+    const output = parseOutput(stdout);
+
+    expect(stdout).toBeTruthy();
+    expect(output.filter((o => o.status === "SUCCEED"))).toHaveLength(output.length);
     expect(stderr).toBe("");
     expect(code).toEqual(0);
 
   }, 48000);
 
   it("Should print error on stderr if validation fails", async () => {
-    const { exitCode: code, stderr } = await runCLI({
+    const { exitCode: code, stdout } = await runCLI({
       args: [
         "run",
         "./workflows/e2e.json",
         "-v",
         "./workflows/validator.cue",
-        "-q",
       ],
       cwd: testCaseRoot,
       cli: polywrapCli,
     });
 
+    const output = parseOutput(stdout);
+
     expect(code).toEqual(1);
-    expect(stderr).toBeDefined();
+    expect(output[0].status).toBe("FAILED");
+    expect(output[0].error).toBeTruthy();
+    expect(output[1].status).toBe("SKIPPED");
+    expect(output[2].status).toBe("SKIPPED");
   }, 48000);
 });

packages/cli/src/__tests__/e2e/utils.ts

@@ -7,20 +7,58 @@ export const clearStyle = (styled: string) => {
 
 export const parseOutput = (
   outputs: string
-): Array<{ id: string; data?: unknown, error?: unknown }> => {
+): Array<{
+  id: string;
+  data?: unknown;
+  error?: unknown;
+  validation?: string;
+  status: string;
+}> => {
   const outputsArr = outputs.split(/-{35}[\t \n]+-{35}/);
   return outputsArr.map((output) => {
     output = output.replace(/-{35}/, "");
     const idIdx = output.indexOf("ID: ");
+    const statusIdx = output.indexOf("Status: ");
     const dataIdx = output.indexOf("Data: ");
+    const validationIdx = output.indexOf("Validation: ");
     if (dataIdx !== -1) {
-      const id = output.substring(idIdx + 3, dataIdx - 1);
-      const data = output.substring(dataIdx + 6);
-      return { id: id.replace(/\s/g, ""), data: JSON.parse(data) };
+      const id = output.substring(idIdx + 3, statusIdx - 1);
+      const status = output.substring(statusIdx + 8, dataIdx - 1);
+      const data =
+        validationIdx !== -1
+          ? output.substring(dataIdx + 6, validationIdx - 1)
+          : output.substring(dataIdx + 6);
+      const validation =
+        validationIdx !== -1
+          ? output.substring(validationIdx + 12).replace(/\s/g, "")
+          : undefined;
+
+      return {
+        id: id.replace(/\s/g, ""),
+        status: status,
+        data: JSON.parse(data),
+        validation: validation,
+      };
     } else {
       const errIdx = output.indexOf("Error: ");
-      const id = output.substring(idIdx + 3);
-      return { id: id.replace(/\s/g, ""), error: output.substring(errIdx + 7) };
+
+      const id = output.substring(idIdx + 3, statusIdx - 1);
+      const status = output.substring(statusIdx + 8, errIdx - 1);
+      const error =
+        validationIdx !== -1
+          ? output.substring(errIdx + 6, validationIdx - 1)
+          : output.substring(errIdx + 6);
+      const validation =
+        validationIdx !== -1
+          ? output.substring(validationIdx + 12).replace(/\s/g, "")
+          : undefined;
+
+      return {
+        id: id.replace(/\s/g, ""),
+        status: status,
+        error: error,
+        validation: validation,
+      };
     }
   });
 };

packages/cli/src/commands/create.ts

@@ -13,7 +13,7 @@ const createPluginStr = intlMsg.commands_create_options_createPlugin();
 const pathStr = intlMsg.commands_create_options_o_path();
 
 export const supportedLangs = {
-  wasm: ["assemblyscript", "interface"] as const,
+  wasm: ["assemblyscript", "rust", "interface"] as const,
   app: ["typescript-node", "typescript-react"] as const,
   plugin: ["typescript"] as const,
 };

packages/cli/src/commands/run.ts

@@ -7,7 +7,7 @@ import {
   validateOutput,
 } from "../lib";
 
-import { InvokeResult, Workflow, JobResult } from "@polywrap/core-js";
+import { Workflow, JobResult, JobStatus } from "@polywrap/core-js";
 import { PolywrapClient, PolywrapClientConfig } from "@polywrap/client-js";
 import path from "path";
 import yaml from "js-yaml";
@@ -79,37 +79,39 @@ const _run = async (workflowPath: string, options: WorkflowCommandOptions) => {
   const workflow: Workflow = getParser(workflowPath)(
     fs.readFileSync(workflowPath).toString()
   );
-  const workflowOutput: (InvokeResult & { id: string })[] = [];
+  const workflowOutput: (JobResult & { id: string })[] = [];
 
   await client.run({
     workflow,
     config: clientConfig,
     ids: jobs,
     onExecution: async (id: string, jobResult: JobResult) => {
-      const { data, error } = jobResult;
+      const { data, error, status } = jobResult;
 
       if (!quiet) {
         console.log("-----------------------------------");
         console.log(`ID: ${id}`);
+        console.log(`Status: ${status}`);
       }
 
-      if (!quiet && data) {
+      if (!quiet && data !== undefined) {
         console.log(`Data: ${JSON.stringify(data, null, 2)}`);
-        console.log("-----------------------------------");
       }
 
-      if (!quiet && error) {
+      if (!quiet && error !== undefined) {
         console.log(`Error: ${error.message}`);
-        console.log(error.stack || "");
-        console.log("-----------------------------------");
         process.exitCode = 1;
       }
 
-      if (validateScript) {
-        await validateOutput(id, { data, error }, validateScript);
+      if (status !== JobStatus.SKIPPED && validateScript) {
+        await validateOutput(id, { data, error }, validateScript, quiet);
+      }
+
+      if (!quiet) {
+        console.log("-----------------------------------");
       }
 
-      workflowOutput.push({ id, data, error });
+      workflowOutput.push({ id, status, data, error });
     },
   });
 

packages/cli/src/lib/helpers/workflow-validator.ts

@@ -18,7 +18,8 @@ export async function cueExists(): Promise<boolean> {
 export async function validateOutput(
   id: string,
   result: InvokeResult,
-  validateScriptPath: string
+  validateScriptPath: string,
+  quiet?: boolean
 ): Promise<void> {
   if (!(await cueExists())) {
     console.warn(intlMsg.commands_run_error_cueDoesNotExist());
@@ -34,18 +35,25 @@ export async function validateOutput(
   await fs.promises.writeFile(jsonOutput, JSON.stringify(result, null, 2));
 
   try {
-    const { stderr } = await runCommand(
+    await runCommand(
       `cue vet -d ${selector} ${validateScriptPath} ${jsonOutput}`,
       true
     );
-
-    if (stderr) {
-      console.error(stderr);
-      console.log("-----------------------------------");
+    if (!quiet) {
+      console.log("Validation: SUCCEED");
     }
   } catch (e) {
-    console.error(e);
-    console.log("-----------------------------------");
+    const msgLines = e.split(/\r?\n/);
+    msgLines[1] = `${validateScriptPath}:${msgLines[1]
+      .split(":")
+      .slice(1)
+      .join(":")}`;
+    const errMsg = msgLines.slice(0, 2).join("\n");
+
+    if (!quiet) {
+      console.log("Validation: FAILED");
+      console.log(`Error: ${errMsg}`);
+    }
     process.exitCode = 1;
   }
 

packages/js/core/src/types/Workflow.ts

@@ -24,9 +24,9 @@ export type Workflow<TUri extends Uri | string = string> = {
 };
 
 export enum JobStatus {
-  SUCCEED,
-  FAILED,
-  SKIPPED,
+  SUCCEED = "SUCCEED",
+  FAILED = "FAILED",
+  SKIPPED = "SKIPPED",
 }
 
 export interface JobResult<TData extends unknown = unknown>