Feat/pda

.github/workflows/test.yaml

@@ -1,4 +1,4 @@
-name: Build PR
+name: Run Eslint & Test cases
 
 on:
   pull_request:
@@ -9,7 +9,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout Project
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
       - name: Install pnpm
         run: npm install -g pnpm@7.33.5
       - name: Install Project Dependencies
@@ -20,3 +20,7 @@ jobs:
         run: pnpm mesh build
       - name: Test project
         run: pnpm test
+        env:
+          DATAMODEL_ID: ${{ secrets.DATAMODEL_ID }}
+          BEARER_TOKEN: ${{ secrets.BEARER_TOKEN }}
+          API_KEY: ${{ secrets.API_KEY }}

.gitignore

@@ -1,2 +1,4 @@
 node_modules/
-.mesh/
+.mesh/
+.vscode/
+.env

.meshrc.yml

@@ -1,10 +1,14 @@
 sources:
-  - name: MyGraphQLApi
+  - name: GatewaySDK
     handler:
       graphql:
         endpoint: https://develop.protocol.mygateway.xyz/v1/graphql
-        method: 'POST'
-        useGETForQueries: false
+    transforms:
+      - filterSchema:
+          mode: bare
+          filters:
+            - Query.!transaction
+            - Query.!transactions
 
 customFetch: ./custom-fetch.ts
 

package.json

@@ -17,13 +17,15 @@
     "@graphql-mesh/cli": "^0.87.14",
     "@graphql-mesh/graphql": "^0.95.7",
     "@graphql-mesh/runtime": "^0.96.11",
+    "@graphql-mesh/transform-filter-schema": "^0.96.0",
     "@types/node": "^20.8.4",
     "@whatwg-node/fetch": "^0.9.13",
     "graphql": "^16.8.1"
   },
   "devDependencies": {
     "@types/jest": "^29.5.7",
     "@typescript-eslint/eslint-plugin": "^6.4.0",
+    "dotenv": "^16.3.1",
     "eslint": "^8.53.0",
     "eslint-config-prettier": "^9.0.0",
     "eslint-config-standard-with-typescript": "^39.1.1",

src/Gateway.ts

@@ -2,7 +2,6 @@ import { getMeshSDK, Sdk } from '../.mesh';
 import { PDA } from './pda/pda';
 
 export class Gateway {
-  // public auth: Auth;
   public pda: PDA;
   private sdk: Sdk;
 
@@ -12,7 +11,6 @@ export class Gateway {
       apiKey,
       token,
     });
-    // this.auth = new Auth();
     this.pda = new PDA(this.sdk);
   }
 }

src/pda/pda.ts

@@ -0,0 +1,151 @@
+import {
+  CreatePDAInput,
+  Sdk,
+  FilterPDAInput,
+  UpdatePDAInput,
+} from '../../.mesh';
+import { PDAFilter, PDAStatus } from '../types';
+import { errorHandler } from '../utils/errorHandler';
+
+export class PDA {
+  private sdk: Sdk;
+
+  constructor(sdk: Sdk) {
+    this.sdk = sdk;
+  }
+
+  /**
+   * The function `getPDA` is an asynchronous function that takes an `id` parameter and returns a
+   * Promise that resolves to a `PDA_queryQuery` object.
+   * @param {string} id - A string representing the ID of the PDA that you
+   * want to query.
+   * @returns The function `getPda` is returning a Promise that resolves to a `PDA_queryQuery` object.
+   */
+  async getPDA(id: string) {
+    try {
+      return await this.sdk.PDA_query({ id });
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function `getPDACount` is an asynchronous function that retrieves the count of PDAs
+   *  based on an optional filter.
+   * @param {FilterPDAInput} [filter] - The `filter` parameter is an optional input that allows you to
+   * specify criteria for filtering the PDAs  before counting them. It is
+   * of type `FilterPDAInput`.
+   * @returns a Promise that resolves to a number.
+   */
+  async getPDACount(filter?: FilterPDAInput) {
+    try {
+      return (await this.sdk.PDACount_query({ filter })).PDACount;
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function `getPDAs` retrieves PDAs based on the provided filter, order, skip, and take
+   * parameters.
+   * @param {PDAFilter}  - - `filter`: An object that contains filter criteria for the query.
+   * @returns a Promise that resolves to a value of type PDAs_queryQuery.
+   */
+  async getPDAs({ filter, order, skip, take }: PDAFilter) {
+    try {
+      return await this.sdk.PDAs_query({ filter, order, skip, take });
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function `getIssuedPDAs` retrieves issued PDAs based on the provided filter, order, skip, and
+   * take parameters.
+   * @param {PDAFilter}  - - `filter`: An object that contains filter criteria for the query. It is
+   * used to specify conditions that the returned PDAs must meet.
+   * @returns a Promise that resolves to an object of type `issuedPDAs_queryQuery`.
+   */
+  async getIssuedPDAs({ filter, order, skip, take }: PDAFilter) {
+    try {
+      return await this.sdk.issuedPDAs_query({ filter, order, skip, take });
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function `getIssuedPDAsCount` is an asynchronous function that retrieves the count of issued
+   * PDAs based on an optional filter.
+   * @param {FilterPDAInput} [filter] - The `filter` parameter is an optional input that allows you to
+   * specify criteria for filtering the issued PDAs. It is of type `FilterPDAInput`.
+   * @returns a Promise that resolves to a number.
+   */
+  async getIssuedPDAsCount(filter?: FilterPDAInput) {
+    try {
+      return (await this.sdk.issuedPDAsCount_query({ filter })).issuedPDAsCount;
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function `myPDACount` is an asynchronous function that returns the count of myPDAs based on an
+   * optional filter.
+   * @param {FilterPDAInput} [filter] - The `filter` parameter is an optional input that can be used to
+   * filter the results of the query. It is of type `FilterPDAInput`.
+   * @returns a Promise that resolves to a number.
+   */
+  async myPDACount(filter?: FilterPDAInput) {
+    try {
+      return (await this.sdk.myPDACount_query({ filter })).myPDACount;
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function `changePDAStatus` is an asynchronous function that takes an `id` and a `status` as
+   * parameters and returns a Promise that resolves to a `changePDAStatus_mutationMutation` object.
+   * @param  - - `id`: The ID of the PDA  whose status needs to be changed.
+   * @returns a Promise that resolves to a `changePDAStatus_mutationMutation` object.
+   */
+  async changePDAStatus({ id, status }: { id: string; status: PDAStatus }) {
+    try {
+      return await this.sdk.changePDAStatus_mutation({ input: { id, status } });
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function creates a PDA  using the provided input and returns the result.
+   * @param {CreatePDAInput} pdaInput - The `pdaInput` parameter is an object that contains the input
+   * data for creating a PDA . It is of type `CreatePDAInput`.
+   * @returns the result of the `createPDA_mutation` method call, which is a Promise.
+   */
+  async createPDA(pdaInput: CreatePDAInput) {
+    try {
+      return await this.sdk.createPDA_mutation({ input: pdaInput });
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+
+  /**
+   * The function `updatePDA` updates a PDA  using the provided input and returns
+   * the result of the mutation.
+   * @param {UpdatePDAInput} updatedPDA - The parameter `updatedPDA` is of type `UpdatePDAInput`. It is
+   * an input object that contains the data to update a PDA. The specific
+   * properties and their types within `UpdatePDAInput` would depend on the implementation of the
+   * `updatePDA_m
+   * @returns a Promise that resolves to an object of type `updatePDA_mutationMutation`.
+   */
+  async updatePDA(updatedPDA: UpdatePDAInput) {
+    try {
+      return await this.sdk.updatePDA_mutation({ input: updatedPDA });
+    } catch (error) {
+      throw new Error(errorHandler(error));
+    }
+  }
+}