Dev/nodejs support

.github/workflows/publish.yml

@@ -0,0 +1,56 @@
+name: Build and Publish Packages
+
+on:
+  release:
+    types: [created]
+  # push:
+  #   branches:
+  #     - dev/nodejs-support
+  workflow_dispatch:
+    inputs:
+      version:
+        description: "Version for Manual Release (e.g., 1.2.3-beta)"
+        required: true
+
+jobs:
+  build-and-publish:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+
+      - name: Set up Deno
+        uses: denoland/setup-deno@v1
+        with:
+          deno-version: "v1.x"
+
+      - name: Determine Version
+        id: get_version
+        run: |
+          SHORT_SHA=$(echo ${{ github.sha }} | cut -c1-7)
+          if [ "${{ github.event_name }}" = "release" ]; then
+            VERSION=${{ github.event.release.tag_name }}
+          elif [ "${{ github.event_name }}" = "workflow_dispatch" ]; then
+            VERSION=${{ github.event.inputs.version }}-$SHORT_SHA
+          elif [ "${{ github.ref }}" = "refs/heads/dev/nodejs-support" ]; then
+            VERSION=0.0.0-test-$SHORT_SHA
+          fi
+          echo "VERSION=$VERSION" >> $GITHUB_ENV
+
+      - name: Build NPM Package
+        run: |
+          echo "Building Version ${{ env.VERSION }}"
+          deno run -A  npm-support/build-npm.ts ${{ env.VERSION }}
+
+      - name: Publish to NPM
+        run: |
+          cd npm
+          echo "//registry.npmjs.org/:_authToken=${{ secrets.NPM_TOKEN }}" > .npmrc
+          npm publish --access public
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}
+
+      - name: Install Dependencies for Test
+        run: npm install @stackql/stackqljs@${{ env.VERSION }}
+
+      - name: Run Integration Test Script
+        run: node ./.github/workflows/scripts/npm-module-test.mjs

.github/workflows/scripts/npm-module-test.mjs

@@ -0,0 +1,35 @@
+import { StackQL } from "@stackql/stackqljs"; // Adjust this if the import path differs
+const assert = require("assert").strict;
+
+async function runTests() {
+  try {
+    // Initialize stackQL
+    await StackQL.initialize({ serverMode: false });
+
+    // Define queries
+    const providerQuery = "SHOW PROVIDERS";
+    const githubTestQuery = `SELECT id, name from github.repos.repos where org='stackql' and name='stackql'`;
+
+    // Execute queries
+    const result = await stackQL.executeStatement(providerQuery);
+    const githubResult = await stackQL.execute(githubTestQuery);
+    const githubResultObj = githubResult[0];
+
+    // Assert
+    assert(result.includes("name"), 'Result should include "name"');
+    assert(result.includes("version"), 'Result should include "version"');
+    assert(result.includes("github"), 'Result should include "github"');
+    assert.equal(
+      githubResultObj.name,
+      "stackql",
+      'GitHub result name should be "stackql"'
+    );
+
+    console.log("All tests passed!");
+  } catch (error) {
+    console.error("Test failed:", error);
+    process.exit(1); // Exit with error code
+  }
+}
+
+runTests();

.gitignore

@@ -34,4 +34,8 @@ yarn-error.log*
 # typescript
 *.tsbuildinfo
 next-env.d.ts
-.stackql*
+.stackql*
+
+# npm
+npm/*
+*/node_modules/

.vscode/settings.json

@@ -1,8 +1,8 @@
 {
-  "deno.enable": true,
+  "deno.enablePaths": ["/deno"],
   "deno.lint": true,
   "deno.unstable": true,
-  "deno.config": "./deno.json",
+  "deno.config": "./deno/deno.json",
   "editor.formatOnSave": true,
   "[typescript]": {
     "editor.defaultFormatter": "denoland.vscode-deno"

README.md

@@ -29,3 +29,7 @@
 ```
 deno task test <optional: test file path>
 ```
+
+## NPM Support
+
+- run ` deno run -A scripts/npm-build.ts`

deno.json → deno/deno.json

@@ -1,7 +1,5 @@
 {
   "lint": {
-    "include": ["src/"],
-    "exclude": ["src/testing/", "src/**/*.test.ts", "src/*test.ts/"],
     "rules": {
       "tags": ["recommended"],
       "include": [],
@@ -15,8 +13,8 @@
     "semiColons": true,
     "singleQuote": true,
     "proseWrap": "preserve",
-    "include": ["src/"],
-    "exclude": ["*.md"]
+    "exclude": ["/esm"],
+    "include": ["./**/*.ts"]
   },
   "tasks": {
     "test": "deno test --allow-net --allow-read --allow-write --allow-env --allow-run"

deno/deps.ts

@@ -0,0 +1,4 @@
+export { Client } from 'https://deno.land/x/[email protected]/client.ts';
+export { assertExists } from 'https://deno.land/[email protected]/assert/assert_exists.ts';
+export { decompress } from 'https://deno.land/x/[email protected]/mod.ts';
+export { join } from 'https://deno.land/[email protected]/path/mod.ts';

deno/dev_deps.ts

@@ -0,0 +1,17 @@
+export {
+	assertRejects,
+	assertStringIncludes,
+	assertThrows,
+} from 'https://deno.land/[email protected]/assert/mod.ts';
+export {
+	assert,
+	assertEquals,
+	assertExists,
+} from 'https://deno.land/[email protected]/testing/asserts.ts';
+
+export {
+	assertSpyCall,
+	assertSpyCalls,
+	spy,
+	stub,
+} from 'https://deno.land/[email protected]/testing/mock.ts';

deno/mod.ts

@@ -0,0 +1,3 @@
+import { StackQL } from './src/stackql.ts';
+
+export { StackQL };

src/services/downloader.test.ts → deno/src/services/downloader.test.ts

@@ -1,6 +1,6 @@
 import { assertExists, assertSpyCalls, spy } from '../../dev_deps.ts';
 import { Downloader } from './downloader.ts';
-import { removeStackQLDownload } from '../../testing/utils.ts';
+import { removeStackQLDownload } from '../../../testing/utils.ts';
 
 Deno.test('Downloader setupStackQL and upgrade Test', async () => {
 	// Arrange

src/services/server.test.ts → deno/src/services/server.test.ts

@@ -1,6 +1,6 @@
 import { Server } from './server.ts';
 import { assert } from '../../dev_deps.ts';
-import { startStackQLServer } from '../../testing/utils.ts';
+import { startStackQLServer } from '../../../testing/utils.ts';
 
 Deno.test('Successful Connection', async () => {
 	const { closeProcess } = await startStackQLServer();

src/stackql.test.ts → deno/src/stackql.test.ts

@@ -8,7 +8,7 @@ import {
 } from '../dev_deps.ts';
 
 import { StackQL } from './stackql.ts';
-import { isCsvString, startStackQLServer } from '../testing/utils.ts';
+import { isCsvString, startStackQLServer } from '../../testing/utils.ts';
 import { Downloader } from './services/downloader.ts';
 import osUtils from './utils/os.ts';
 
@@ -176,7 +176,7 @@ Deno.test('Server mode: csv output throw error', async () => {
 			connectionString:
 				'postgres://postgres:password@localhost:5444/postgres',
 		});
-		const testQuery = 'SHOW SERVICES IN github LIKE \'%repos%\';'; // Replace with a valid query for your context
+		const testQuery = "SHOW SERVICES IN github LIKE '%repos%';"; // Replace with a valid query for your context
 
 		await stackQL.execute(testQuery);
 	} catch (error) {
@@ -204,7 +204,7 @@ Deno.test('Server mode: Query', async () => {
 				'postgres://postgres:password@localhost:5444/postgres',
 		});
 		const pullQuery = 'REGISTRY PULL github;';
-		const showServiceQuery = 'SHOW SERVICES IN github LIKE \'%repos%\';'; // Replace with a valid query for your context
+		const showServiceQuery = "SHOW SERVICES IN github LIKE '%repos%';"; // Replace with a valid query for your context
 
 		// Act
 		await stackQL.executeStatement(pullQuery);

src/utils/os.ts → deno/src/utils/os.ts

@@ -1,48 +1,48 @@
 const fileExists = (path?: string) => {
 	if (!path) {
-		return false
+		return false;
 	}
 	try {
-		Deno.statSync(path)
-		return true
+		Deno.statSync(path);
+		return true;
 	} catch (error) {
 		if (error instanceof Deno.errors.NotFound) {
-			return false
+			return false;
 		}
-		throw error
+		throw error;
 	}
-}
+};
 
 const chmod = async (path: string, mode: number) => {
 	if (Deno.build.os !== 'windows') {
-		await Deno.chmod(path, mode)
+		await Deno.chmod(path, mode);
 	}
-}
+};
 
 const runCommand = async (path: string, args: string[]) => {
 	const process = new Deno.Command(path, {
 		args,
 		stdout: 'piped',
 		stderr: 'piped',
-	})
+	});
 
-	const { code, stdout, stderr } = await process.output()
+	const { code, stdout, stderr } = await process.output();
 
 	if (code === 0) {
-		const output = stdout
-		const result = new TextDecoder().decode(output)
-		return result
+		const output = stdout;
+		const result = new TextDecoder().decode(output);
+		return result;
 	} else {
-		const errorOutput = stderr
-		const errorMessage = new TextDecoder().decode(errorOutput)
-		throw new Error(errorMessage)
+		const errorOutput = stderr;
+		const errorMessage = new TextDecoder().decode(errorOutput);
+		throw new Error(errorMessage);
 	}
-}
+};
 
 const osUtils = {
 	fileExists,
 	chmod,
 	runCommand,
-}
+};
 
-export default osUtils
+export default osUtils;