Merge pull request #990 from scramjetorg/test/si-init

[CLI TEST] VDM-1507 si init

Author: a-tylenda

bdd/features/e2e/E2E-010-cli.feature

@@ -157,4 +157,14 @@ Feature: CLI tests
         Then I confirm instance id is: <instanceId>
         Examples:
             | instanceId                           |
-            | Supervisor-Instance-0000-11111111111 |
+            | Supervisor-Instance-0000-11111111111 |
+
+    @ci-api @cli @test-si-init
+    Scenario: E2E-010 TC-019 Test Init template sequence
+        When I execute CLI command si init <templateType>
+        Then I confirm template <templateType> is created
+        Examples:
+            | templateType |
+            | ts           |
+            | js           |
+            | py           |

bdd/lib/utils.ts

@@ -274,3 +274,106 @@ export async function removeProfile(profileName: string) {
         logger.debug(res);
     }
 }
+
+export function createDirectory(workingDirectory: string) {
+    if (!fs.existsSync(workingDirectory)) {
+        fs.mkdirSync(workingDirectory);
+        if (isLogActive) {
+            logger.debug(`Directory "${workingDirectory}" successfully created`);
+        }
+    } else {
+        logger.error(`Directory "${workingDirectory}" already exist`);
+    }
+}
+
+export function deleteDirectory(workingDirectory: string) {
+    try {
+        fs.rmdirSync(workingDirectory, { recursive: true });
+        if (isLogActive) {
+            logger.debug(`Directory "${workingDirectory}" was successfully deleted`);
+        }
+    } catch (error: any) {
+        logger.error(`Error while deleting direcory "${workingDirectory}": ${error.message}`);
+    }
+}
+
+export function spawnSiInit(
+    command: string,
+    templateType: string,
+    workingDirectory: string,
+    env: NodeJS.ProcessEnv = process.env
+) {
+    return new Promise<void>((resolve, reject) => {
+        const args = () => {
+            return [...si, "init", "seq", templateType, "-p", workingDirectory];
+        };
+
+        if (isLogActive) {
+            logger.debug("Spawning command: /usr/bin/env", ...args());
+        }
+
+        const childProcess = spawn(command, args(), {
+            env
+        });
+
+        childProcess.stdout.on("data", (data) => {
+            if (isLogActive) {
+                logger.debug(data.toString());
+            }
+            if (data.includes("Sequence template succesfully created")) {
+                resolve();
+            } else {
+                childProcess.stdin.write("\n");
+            }
+        });
+        childProcess.stderr.on("data", (data) => {
+            const stderrString = data.toString();
+
+            logger.warn(`Stderr: ${stderrString}`);
+        });
+        childProcess.on("error", (err) => {
+            logger.error(err);
+            reject();
+        });
+        childProcess.on("exit", (code) => {
+            if (isLogActive) {
+                logger.debug(`Exit code: ${code}`);
+            }
+            resolve();
+        });
+    });
+}
+
+export function isTemplateCreated(templateType: string, workingDirectory: string) {
+    return new Promise<boolean>((resolve, reject) => {
+        // eslint-disable-next-line complexity
+        fs.readdir(workingDirectory, (err, files) => {
+            if (err) {
+                logger.error(`Can not read from directory: ${workingDirectory}`);
+                reject(err);
+                return;
+            }
+            if (
+                templateType === "ts" &&
+                files.includes("index.ts") &&
+                files.includes("package.json") &&
+                files.includes("tsconfig.json")
+            ) {
+                resolve(true);
+            }
+            if (
+                templateType === "py" &&
+                files.includes("main.py") &&
+                files.includes("package.json") &&
+                files.includes("requirements.txt")
+            ) {
+                resolve(true);
+            }
+            if (templateType === "js" && files.includes("index.js") && files.includes("package.json")) {
+                resolve(true);
+            } else {
+                resolve(false);
+            }
+        });
+    });
+}

bdd/step-definitions/e2e/cli.ts

@@ -6,7 +6,15 @@
 import { Given, Then, When } from "@cucumber/cucumber";
 import { strict as assert } from "assert";
 import fs from "fs";
-import { getStreamsFromSpawn, defer, waitUntilStreamContains, killProcessByName, getSiCommand } from "../../lib/utils";
+import {
+    getStreamsFromSpawn,
+    defer,
+    waitUntilStreamContains,
+    killProcessByName,
+    getSiCommand,
+    spawnSiInit,
+    isTemplateCreated
+} from "../../lib/utils";
 import { expectedResponses } from "./expectedResponses";
 import { CustomWorld } from "../world";
 import { spawn } from "child_process";
@@ -359,3 +367,15 @@ Then(/^I confirm instance id is: (.*)$/, async function (this: CustomWorld, expe
 
     assert.equal(instance.id, expectedInstanceId);
 });
+
+When(/^I execute CLI command si init (.*)$/, { timeout: 30000 }, async function (templateType: string) {
+    const workingDirectory = "data/template_seq";
+
+    await spawnSiInit("/usr/bin/env", templateType, workingDirectory);
+});
+
+Then(/^I confirm template (.*) is created$/, async function (templateType: string) {
+    const workingDirectory = "data/template_seq";
+
+    assert.equal(await isTemplateCreated(templateType, workingDirectory), true);
+});

bdd/step-definitions/e2e/host-steps.ts

@@ -8,9 +8,11 @@ import {
     defer,
     waitUntilStreamEquals,
     waitUntilStreamContains,
+    removeProfile,
     createProfile,
     setProfile,
-    removeProfile
+    createDirectory,
+    deleteDirectory
 } from "../../lib/utils";
 import fs, { createReadStream, existsSync, ReadStream } from "fs";
 import { HostClient, InstanceOutputStream } from "@scramjet/api-client";
@@ -179,6 +181,13 @@ Before(() => {
 
 After({ tags: "@runner-cleanup" }, killRunner);
 
+Before({ tags: "@test-si-init" }, function() {
+    createDirectory("data/template_seq");
+});
+After({ tags: "@test-si-init" }, function() {
+    deleteDirectory("data/template_seq");
+});
+
 const startHost = async () => {
     let apiUrl = process.env.SCRAMJET_HOST_BASE_URL;
 
@@ -683,7 +692,7 @@ When("confirm that sequence and volumes are removed", async function(this: Custo
 
     if (!sequenceId) assert.fail();
 
-    const sequences = await hostClient.listSequences() || [];
+    const sequences = (await hostClient.listSequences()) || [];
     const sequenceExist = !!sequences.find((sequenceInfo) => sequenceId === sequenceInfo.id);
 
     assert.equal(sequenceExist, false);