[CLI TEST] VDM-1507 si init

.gitignore

@@ -124,6 +124,9 @@ dist
 bdd/.work/
 bdd/reports/*.html
 bdd/*-test-result.txt
+bdd/data/template_seq/
+
+!bdd/data/template_seq/.gitkeep
 
 # pre-runner sample-package
 packages/pre-runner/sample-package/

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
+    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

@@ -85,7 +85,7 @@ export function fileContains(filename: any, key: any) {
     let line;
 
     // eslint-disable-next-line no-cond-assign
-    while (line = stdoutFile.next()) {
+    while ((line = stdoutFile.next())) {
         if (line.includes(key)) {
             return;
         }
@@ -274,3 +274,107 @@ export async function removeProfile(profileName: string) {
         logger.debug(res);
     }
 }
+
+export async function deleteAllFilesInDirectory(workingDirectory: string) {
+    try {
+        const files = await fs.promises.readdir(workingDirectory);
+
+        await Promise.all(
+            files.map(async (file) => {
+                const filePath = `${workingDirectory}/${file}`;
+
+                try {
+                    await fs.promises.unlink(filePath);
+                    if (isLogActive) {
+                        logger.debug(`File ${filePath} was deleted`);
+                    }
+                } catch (error) {
+                    logger.error(`Deleting error file ${file}: ${error}`);
+                }
+            })
+        );
+    } catch (err) {
+        logger.error(`Can not read from directory: ${workingDirectory}`);
+    }
+}
+
+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,16 @@
 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,
+    deleteAllFilesInDirectory,
+    spawnSiInit,
+    isTemplateCreated
+} from "../../lib/utils";
 import { expectedResponses } from "./expectedResponses";
 import { CustomWorld } from "../world";
 import { spawn } from "child_process";
@@ -359,3 +368,16 @@ 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 deleteAllFilesInDirectory(workingDirectory);
+    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,9 @@ import {
     defer,
     waitUntilStreamEquals,
     waitUntilStreamContains,
+    removeProfile,
     createProfile,
-    setProfile,
-    removeProfile
+    setProfile
 } from "../../lib/utils";
 import fs, { createReadStream, existsSync, ReadStream } from "fs";
 import { HostClient, InstanceOutputStream } from "@scramjet/api-client";