refactor: from event -> procedural + async context (#137)

This PR is a big internal refactor.

* Removes all the EventEmitters all around.
* Replaces the events with procedural calls to the providers.
* A new class is added AsyncContext to handle all the async calls to the context and have a correct error handling.
* More centralization in the context.
* Separates the RunSQLCommand to its own file query.ts inside the providers folder. (We should do the same with Copy and Run)
* Providers are now created inside the context.
* Fix for the expiring token issue.

.github/workflows/test.yml

@@ -49,5 +49,8 @@ jobs:
         sudo apt-get install -y libnss3-dev libasound2 libgdk-pixbuf2.0-dev libgtk-3-dev libxss-dev libatk1.0-0
 
     - run: npm install
-    - run: xvfb-run -a npm test
-      if: runner.os == 'Linux'
+    - name: Run Tests on Linux
+      if: runner.os == 'Linux'
+      run: |
+        export MZ_CONFIG_PATH=$HOME/.config/materialize/test
+        xvfb-run -a npm test

.vscode/launch.json

@@ -28,7 +28,10 @@
                         "outFiles": [
                                 "${workspaceFolder}/out/test/**/*.js"
                         ],
-                        "preLaunchTask": "${defaultBuildTask}"
+                        "preLaunchTask": "${defaultBuildTask}",
+                        "env": {
+                                "MZ_CONFIG_PATH": "${env:HOME}/.config/materialize/test"
+                        }
                 }
         ]
 }

src/clients/admin.ts

@@ -38,7 +38,7 @@ export default class AdminClient {
 
     async getToken() {
         // TODO: Expire should be at the half of the expiring time.
-        if (!this.auth || (new Date(this.auth.expires) > new Date())) {
+        if (!this.auth || (new Date(this.auth.expires) < new Date())) {
             const authRequest: AuthenticationRequest = {
                 clientId: this.appPassword.clientId,
                 secret: this.appPassword.secretKey
@@ -67,7 +67,7 @@ export default class AdminClient {
     }
 
     /// Returns the JSON Web Key Set (JWKS) from the well known endpoint: `/.well-known/jwks.json`
-    async getJwks() {
+    private async getJwks() {
         const client = jwksClient({
             jwksUri: this.jwksEndpoint
         });
@@ -78,7 +78,7 @@ export default class AdminClient {
 
     /// Verifies the JWT signature using a JWK from the well-known endpoint and
     /// returns the user claims.
-    async getClaims() {
+    private async getClaims() {
         console.log("[AdminClient]", "Getting Token.");
         const token = await this.getToken();
 

src/clients/cloud.ts

@@ -1,6 +1,5 @@
 import fetch from "node-fetch";
 import AdminClient from "./admin";
-import * as vscode from 'vscode';
 import { Errors } from "../utilities/error";
 
 const DEFAULT_API_CLOUD_ENDPOINT = 'https://api.cloud.materialize.com';

src/clients/sql.ts

@@ -1,21 +1,21 @@
 import { Pool, QueryResult } from "pg";
 import AdminClient from "./admin";
 import CloudClient from "./cloud";
-import { Context, EventType } from "../context";
 import { Profile } from "../context/config";
+import AsyncContext from "../context/asyncContext";
 
 export default class SqlClient {
     private pool: Promise<Pool>;
     private adminClient: AdminClient;
     private cloudClient: CloudClient;
-    private context: Context;
+    private context: AsyncContext;
     private profile: Profile;
 
     constructor(
         adminClient: AdminClient,
         cloudClient: CloudClient,
         profile: Profile,
-        context: Context,
+        context: AsyncContext,
     ) {
         this.adminClient = adminClient;
         this.cloudClient = cloudClient;
@@ -39,7 +39,7 @@ export default class SqlClient {
                     });
                 } catch (err) {
                     console.error("[SqlClient]", "Error creating pool: ", err);
-                    this.context.emit("event", { type: EventType.error, message: err });
+                    rej(err);
                 }
             };