Works now?

.eslintrc.json

@@ -0,0 +1,26 @@
+{
+  "env": {
+    "commonjs": true,
+    "es2021": true,
+    "node": true
+  },
+  "extends": [
+    "standard-with-typescript",
+    "prettier"
+  ],
+  "overrides": [
+  ],
+  "parserOptions": {
+    "ecmaVersion": "latest",
+    "project": [
+      "tsconfig.json"
+    ]
+  },
+  "rules": {
+    "indent": [
+      "warn",
+      4
+    ],
+    "@typescript-eslint/explicit-function-return-type": "off"
+  }
+}

.prettierrc

@@ -1 +1,4 @@
-{}
+{
+  "singleQuote": true,
+  "tabWidth": 4
+}

lib/gcp-specific.ts

@@ -0,0 +1,34 @@
+import { type Bucket, type File, Storage } from '@google-cloud/storage';
+
+export interface GCPBucketOptions {
+    googleProject: string;
+    bucketName: string;
+}
+
+export async function getGCSBucket(options: GCPBucketOptions) {
+    const bucketURL = options.bucketName;
+    const storageClient = new Storage({
+        projectId: options.googleProject,
+        retryOptions: {
+            autoRetry: true,
+            maxRetries: 4,
+        },
+    });
+    const bucket = storageClient.bucket(bucketURL);
+
+    const [bucketExists] = await bucket.exists();
+    if (!bucketExists) {
+        throw Error(`The given Bucket ${bucketURL} does not exist`);
+    }
+
+    return bucket;
+}
+
+export function constructGCSFile(bucket: Bucket, filename: string) {
+    return bucket.file(filename);
+}
+
+export async function bucketFileExists(bucketFile: File): Promise<boolean> {
+    const [exists] = await bucketFile.exists();
+    return exists;
+}

lib/index.ts

@@ -1,44 +1,37 @@
-import { createCustomRunner, initEnv } from "nx-remotecache-custom";
-import { Storage } from "@google-cloud/storage";
-
-const ENV_GCP_BUCKET_URL = "gs://";
-
-const getEnv = (key: string) => process.env[key];
-
-async function getGCPFileClient(filename: string, options: AzureBlobRunnerOptions) {
-  const bucketURL = process.env.GCP_BUCKET_URL;
-  const storageClient = new Storage();
-  const bucket = storageClient.bucket(bucketURL);
-  const bucketFile = bucket.file(filename);
-
-
-  if (!await bucket.exists()) {
-    throw Error(
-      `The given Bucket ${bucketURL} does not exist`
-    );
-  }
-
-  return bucketFile;
-}
-
-interface AzureBlobRunnerOptions {
-  connectionString: string;
-  accountKey: string;
-  accountName: string;
-  container: string;
-  azureUrl: string;
-  sasUrl: string;
-}
-
-export default createCustomRunner<AzureBlobRunnerOptions>(async (options) => {
-  initEnv(options);
-  const GCPFile = async (filename: string) => await getGCPFileClient(filename, options);
-
-  return {
-    name: "Azure Blob Storage",
-    fileExists: async (filename) => (await GCPFile(filename)).exists(),
-    retrieveFile: async (filename) =>
-      (await blob(filename).download()).readableStreamBody!,
-    storeFile: (filename, stream) => blob(filename).uploadStream(stream)
-  };
-});
+import { createCustomRunner, initEnv } from 'nx-remotecache-custom';
+import { Readable } from 'stream';
+import { pipeline } from 'stream/promises';
+import type { GCPBucketOptions } from './gcp-specific';
+import {
+    bucketFileExists,
+    constructGCSFile,
+    getGCSBucket,
+} from './gcp-specific';
+import type { RemoteCacheImplementation } from 'nx-remotecache-custom/types/remote-cache-implementation';
+
+export default createCustomRunner<GCPBucketOptions>(
+    async (options): Promise<RemoteCacheImplementation> => {
+        initEnv(options);
+        const bucket = await getGCSBucket(options);
+
+        return {
+            name: 'Google Cloud Bucket',
+            fileExists: async (filename) => {
+                const bucketFile = constructGCSFile(bucket, filename);
+                return await bucketFileExists(bucketFile);
+            },
+            retrieveFile: async (filename) => {
+                const bucketFile = constructGCSFile(bucket, filename);
+                const downloadedFile = bucketFile.download();
+                return Readable.from(await downloadedFile);
+            },
+            storeFile: async (filename, stream) => {
+                const uploadStream = constructGCSFile(
+                    bucket,
+                    filename
+                ).createWriteStream();
+                await pipeline(stream, uploadStream);
+            },
+        };
+    }
+);

package.json

@@ -2,13 +2,13 @@
   "name": "nx-remotecache-gcp",
   "version": "1.0.0",
   "description": "Remote caching for @nrwl/nx using Google Cloud Buckets",
-  "main": "index.js",
-  "typings": "index.d.ts",
+  "main": "dist/index.js",
+  "typings": "dist/index.d.ts",
   "scripts": {
     "build": "rm -rf dist && tsc && cp package.json dist/package.json && cp README.md dist/README.md && cp CHANGELOG.md dist/CHANGELOG.md",
+    "prepare": "yarn build",
     "release": "yarn run build && cd dist && yarn publish && cd ..",
-    "local-release": "yarn run build && cd dist && yarn publish --registry=http://localhost:4873/ && cd ..",
-    "link": "yarn run build && cd dist && yarn link && cd .."
+    "link": "yarn run build && cd dist && yarn link -A . && cd .."
   },
   "repository": {
     "type": "git",
@@ -34,6 +34,15 @@
   "devDependencies": {
     "@types/node": "^18.16.0",
     "@types/yargs": "^17.0.24",
+    "@typescript-eslint/eslint-plugin": "^5.43.0",
+    "@typescript-eslint/parser": "^5.59.1",
+    "eslint": "^8.0.1",
+    "eslint-config-prettier": "^8.8.0",
+    "eslint-config-standard-with-typescript": "latest",
+    "eslint-plugin-import": "^2.25.2",
+    "eslint-plugin-n": "^15.0.0",
+    "eslint-plugin-promise": "^6.0.0",
+    "prettier": "^2.8.8",
     "typescript": "^5.0.4"
   },
   "dependencies": {