include method to execute tx across parifi relayer

.env.example

@@ -4,3 +4,4 @@ PYTH_SERVICE_USERNAME =
 PYTH_SERVICE_PASSWORD = 
 GELATO_KEY = 
 SUBGRAPH_ENDPOINT = 
+PARIFI_RELAYER_JWT_TOKEN=

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@parifi/sdk",
-  "version": "0.1.5",
+  "version": "0.1.8",
   "description": "Parifi SDK with common utility functions",
   "files": [
     "dist",
@@ -46,7 +46,7 @@
   },
   "dependencies": {
     "@gelatonetwork/relay-sdk": "^5.5.5",
-    "@parifi/references": "^1.1.0-dev",
+    "@parifi/references": "1.1.0-dev",
     "axios": "^1.6.7",
     "decimal.js": "^10.4.3",
     "dotenv": "^16.4.1",

src/index.ts

@@ -3,6 +3,8 @@ import { Subgraph } from './subgraph';
 import { PythConfig, RelayerConfig, RpcConfig, SubgraphConfig } from './interfaces/classConfigs';
 import { Core } from './core';
 import { Gelato } from './gelato';
+import { relayerRepository } from './interfaces/repositories/relayer';
+import { ParifiRelayer } from './relayers/parifi';
 
 export * from './common';
 export * from './core';
@@ -16,6 +18,9 @@ export class ParifiSdk {
   pyth: Pyth;
   core: Core;
   gelato: Gelato;
+  relayer: {
+    parifi: relayerRepository;
+  };
 
   constructor(
     rpcConfig: RpcConfig,
@@ -27,6 +32,9 @@ export class ParifiSdk {
     this.pyth = new Pyth(pythConfig);
     this.core = new Core(rpcConfig, subgraphConfig, relayerConfig, pythConfig);
     this.gelato = new Gelato(relayerConfig['gelatoConfig'], rpcConfig);
+    this.relayer = {
+      parifi: new ParifiRelayer(relayerConfig['parifiRealyerConfig'], rpcConfig.chainId),
+    };
   }
 
   async init() {

src/interfaces/repositories/relayer.ts

@@ -0,0 +1,13 @@
+import { TransactionStatusResponse } from '@gelatonetwork/relay-sdk';
+
+export type RelayerTransaction = {
+  to: string;
+  data: string;
+  value: string | number;
+  customTxId?: string;
+};
+
+export interface relayerRepository {
+  executeTx: (tx: RelayerTransaction) => Promise<string>;
+  checkStatus: (identifier: string) => Promise<TransactionStatusResponse | undefined>;
+}

src/relayers/parifi/index.ts

@@ -0,0 +1,32 @@
+import { RelayerConfig } from '../../interfaces';
+import { RelayerTransaction, relayerRepository } from '../../interfaces/repositories/relayer';
+
+export class ParifiRelayer implements relayerRepository {
+  private token: string;
+  public url: string;
+  public chainId: number;
+
+  constructor(relayerConfig: RelayerConfig['parifiRealyerConfig'], chainId: number) {
+    this.token = relayerConfig?.jwtToken ?? '';
+    this.url = relayerConfig?.relayerEndpoint ?? 'https://balancer.parifi.org';
+    this.chainId = chainId;
+  }
+
+  async executeTx({ customTxId, ...tx }: RelayerTransaction) {
+    const response = await fetch(`${this.url}/send`, {
+      headers: {
+        Authorization: `Bearer ${this.token}`,
+        'Content-Type': 'application/json',
+      },
+      method: 'POST',
+      body: JSON.stringify({ tx, chainId: this.chainId.toString(), customTxId }),
+    });
+    const data = await response.json();
+
+    return (customTxId ?? data.txId) as string;
+  }
+
+  async checkStatus(_hash: string) {
+    return undefined;
+  }
+}

src/relayers/parifi/utils.ts

@@ -0,0 +1 @@
+export const executeTxUsingParifi = ({}) => {};

src/subgraph/common/index.ts

@@ -3,9 +3,8 @@ import { Chain } from '@parifi/references';
 export const publicSubgraphEndpoints: { [key in Chain]: string } = {
   [Chain.ARBITRUM_SEPOLIA]: 'https://api.thegraph.com/subgraphs/name/parifi/parifi-sepolia',
   [Chain.ARBITRUM_MAINNET]: 'https://subgraph.satsuma-prod.com/ac10c1d41dcb/parifis-team--3804602/parifi-arbitrum/api',
-
 };
 
 export const getPublicSubgraphEndpoint = (chainId: Chain) => {
   return publicSubgraphEndpoints[chainId];
-};
+};

src/subgraph/vaults/index.ts

@@ -10,6 +10,10 @@ import Decimal from 'decimal.js';
 import { getLatestPricesFromPyth, normalizePythPriceForParifi } from '../../pyth/pyth';
 import { AxiosInstance } from 'axios';
 
+// const matchChain: Record<SupportedChain, Chain> = {
+//   [SupportedChain.ARBITRUM_SEPOLIA]: arbitrumSepolia,
+// };
+
 // Get all vaults from subgraph
 export const getAllVaults = async (subgraphEndpoint: string): Promise<Vault[]> => {
   try {

test/core/relayer.test.ts

@@ -0,0 +1,41 @@
+import { Chain } from '@parifi/references';
+import { ParifiSdk, PythConfig, RelayerConfig, RelayerI, RpcConfig, SubgraphConfig } from '../../src';
+
+const chain = Chain.ARBITRUM_SEPOLIA;
+const rpcConfig: RpcConfig = {
+  chainId: chain,
+};
+
+const pythConfig: PythConfig = {
+  pythEndpoint: process.env.PYTH_SERVICE_ENDPOINT,
+  username: process.env.PYTH_SERVICE_USERNAME,
+  password: process.env.PYTH_SERVICE_PASSWORD,
+  isStable: true,
+};
+
+const parifiConfig: RelayerI = {
+  jwtToken: process.env.PARIFI_RELAYER_JWT_TOKEN || '',
+  // relayerEndpoint: 'http://localhost:3001',
+};
+
+const relayerConfig: RelayerConfig = {
+  parifiRealyerConfig: parifiConfig,
+};
+
+const subgraphConfig: SubgraphConfig = {
+  subgraphEndpoint: 'https://api.studio.thegraph.com/query/68480/parifi-arb-sepolia-test-dev/v0.0.6',
+};
+
+const parifiSdk = new ParifiSdk(rpcConfig, subgraphConfig, relayerConfig, pythConfig);
+
+describe('ParifiSdk parifi relayer', () => {
+  it('should return txId', async () => {
+    const txId = await parifiSdk.relayer.parifi.executeTx({
+      to: '0x15758472aF37950028ad27e4a7F99e65A4A997Cc',
+      data: '0x095ea7b30000000000000000000000003232f21a6e08312654270c78a773f00dd61d60f500000000000000000000000000000000000000000000000000000000000003e8',
+      value: '0',
+    });
+    console.log('=== txId', txId);
+    expect(txId).toBeTruthy();
+  });
+});