server working

operator/@types/minipass-fetch.d.ts

@@ -0,0 +1,4 @@
+declare module 'minipass-fetch' {
+	const miniPassfetch: typeof fetch
+	export default miniPassfetch
+}

operator/api.ts

@@ -1,3 +1,4 @@
+console.log('Entering api.ts')
 import { ApolloServer } from '@apollo/server'
 import { ApolloServerPluginDrainHttpServer } from '@apollo/server/plugin/drainHttpServer'
 import { getSchema, GraphqlContext } from './core/graphql/schema'

operator/core/graphql/extensions/common/index.ts

@@ -1,3 +1,6 @@
 import gql from 'graphql-tag'
 
-export const typeDefs = gql``
+export const typeDefs = gql`
+	type Query
+	type Mutation
+`

operator/core/graphql/extensions/orders/index.ts

@@ -1,7 +1,44 @@
 import { default as gql } from 'graphql-tag'
 
-export const typeDefs = gql``
+export const typeDefs = gql`
+	extend type Query {
+		orders: [Order]
+	}
 
-interface OrdersResolvers {}
+	extend type Mutation {
+		createOrder(input: CreateOrderInput): Order
+	}
+`
 
-export const resolvers: OrdersResolvers = {}
+interface OrdersResolvers {
+	Query: {
+		orders: () => Promise<any[]>
+	}
+	Mutation: {
+		createOrder: (_: any, { input }: { input: any }) => Promise<any>
+	}
+}
+
+export const resolvers: OrdersResolvers = {
+	Query: {
+		orders: async () => {
+			return [
+				{
+					id: '1',
+					createdAt: new Date().toISOString(),
+					updatedAt: new Date().toISOString(),
+					status: 'CREATED',
+					amount: 100,
+				},
+			]
+		},
+	},
+	Mutation: {
+		createOrder: async (_: any, { input }: { input: any }) => {
+			return {
+				id: '1',
+				...input,
+			}
+		},
+	},
+}

operator/core/graphql/schema.ts

@@ -7,7 +7,8 @@ import {
 	typeDefs as ordersTypeDefs,
 } from './extensions/orders'
 
-import { merge } from 'lodash'
+import pkg from 'lodash'
+const { merge } = pkg
 
 const resolvers = merge(ordersResolvers)
 

operator/dist/api.js

@@ -0,0 +1,40 @@
+import { ApolloServer } from '@apollo/server';
+import { ApolloServerPluginDrainHttpServer } from '@apollo/server/plugin/drainHttpServer';
+import { getSchema } from './core/graphql/schema';
+import { app, httpServer } from './server';
+import { serverConfig } from './config/server';
+import bodyParser from 'body-parser';
+import compression from 'compression';
+import cookieParser from 'cookie-parser';
+const schema = getSchema();
+// The ApolloServer constructor requires two parameters: your schema
+// definition and your set of resolvers.
+const server = new ApolloServer({
+    schema,
+    introspection: true,
+    plugins: [
+        ApolloServerPluginDrainHttpServer({ httpServer }),
+        {
+            async serverWillStart() {
+                return {
+                    async drainServer() {
+                        console.log('Draining websocket server before shutdown');
+                        try {
+                            // TODO: Handle any subscriptions here
+                        }
+                        catch (e) {
+                            console.error('Error draining websocket server / cancelling any subscriptions', e);
+                        }
+                    },
+                };
+            },
+        },
+    ],
+});
+app.use(bodyParser.json());
+app.use(compression());
+app.use(cookieParser());
+server.start().then(() => { });
+httpServer.listen(serverConfig.port, () => {
+    console.log(`Milady Pool AVS API running on port: ${serverConfig.port}\n`);
+});

operator/dist/config/server.js

@@ -0,0 +1,3 @@
+export const serverConfig = {
+    port: 8081,
+};

operator/dist/core/graphql/extensions/common/index.js

@@ -0,0 +1,2 @@
+import gql from 'graphql-tag';
+export const typeDefs = gql ``;

operator/dist/core/graphql/extensions/orders/index.js

@@ -0,0 +1,3 @@
+import { default as gql } from 'graphql-tag';
+export const typeDefs = gql ``;
+export const resolvers = {};

operator/dist/core/graphql/schema.js

@@ -0,0 +1,11 @@
+import { stitchSchemas } from '@graphql-tools/stitch';
+import { typeDefs as commonTypeDefs } from './extensions/common';
+import { resolvers as ordersResolvers, typeDefs as ordersTypeDefs, } from './extensions/orders';
+import { merge } from 'lodash';
+const resolvers = merge(ordersResolvers);
+export const getSchema = () => {
+    return stitchSchemas({
+        resolvers,
+        typeDefs: [commonTypeDefs, ordersTypeDefs],
+    });
+};

operator/dist/server.js

@@ -0,0 +1,4 @@
+import express from 'express';
+import { createServer } from 'http';
+export const app = express();
+export const httpServer = createServer(app);

operator/lib/axios/index.ts

@@ -0,0 +1,38 @@
+import axios from 'axios'
+
+import Agent from 'agentkeepalive'
+
+export * from 'axios'
+
+export const globalHttpsKeepAliveAgent = new Agent.HttpsAgent({
+	keepAlive: true,
+	maxSockets: 15,
+	maxFreeSockets: 15,
+	timeout: 60000, // active socket keepalive for 60 seconds
+	freeSocketTimeout: 30000, // free socket keepalive for 30 seconds
+})
+export const globalHttpKeepAliveAgent = new Agent({
+	keepAlive: true,
+	maxSockets: 15,
+	maxFreeSockets: 15,
+	timeout: 60000, // active socket keepalive for 60 seconds
+	freeSocketTimeout: 30000, // free socket keepalive for 30 seconds
+})
+
+export const axiosInstance = axios.create({
+	//keepAlive pools and reuses TCP connections, so it's faster
+	httpAgent: globalHttpKeepAliveAgent,
+	httpsAgent: globalHttpsKeepAliveAgent,
+	//follow up to 10 HTTP 3xx redirects
+	maxRedirects: 10,
+
+	//cap the maximum content length we'll accept to 50MBs, just in case
+	maxContentLength: 50 * 1000 * 1000,
+})
+
+axiosInstance.interceptors.request.use((request) => {
+	console.log(`[${request.method?.toUpperCase()}]: ${request.url}`)
+	return request
+})
+
+export default axiosInstance

operator/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"ignore": ["node_modules"],
+	"watch": [".", ".env"],
+	"exec": "ts-node scripts/runSingleton.ts --project tsconfig.json",
+	"ext": "ts"
+}

operator/package.json

@@ -7,28 +7,37 @@
 	"license": "VPL-1.0",
 	"type": "module",
 	"scripts": {
-		"compile": "tsc",
-		"start": "yarn run compile && node .build/api.js"
+		"build": "rm -rf .build && tsc && yarn tsc-alias -p tsconfig.json && copyfiles -u 1 public/* .build/public && copyfiles **/*.graphql .build",
+		"dev": "nodemon"
 	},
 	"dependencies": {
 		"@apollo/server": "^4.11.0",
 		"@graphql-tools/stitch": "^9.0.1",
+		"agentkeepalive": "^4.5.0",
+		"axios": "^1.7.6",
 		"body-parser": "^1.20.2",
 		"compression": "^1.7.4",
 		"cookie-parser": "^1.4.6",
+		"copyfiles": "^2.4.1",
 		"cors": "^2.8.5",
+		"dotenv": "^16.4.5",
 		"express": "^4.19.2",
 		"graphql": "^16.9.0",
 		"graphql-tag": "^2.12.6",
 		"http": "^0.0.1-security",
 		"lodash": "^4.17.21",
+		"minipass-fetch": "^3.0.5",
+		"nodemon": "^3.1.4",
+		"tsc-alias": "^1.8.10",
+		"tsconfig-paths": "^4.2.0",
 		"uuid": "^10.0.0"
 	},
 	"devDependencies": {
 		"@types/compression": "^1.7.5",
 		"@types/cookie-parser": "^1.4.7",
 		"@types/lodash": "^4.17.7",
 		"@types/node": "^22.5.1",
+		"ts-node": "^10.9.2",
 		"typescript": "^5.5.4"
 	}
 }

operator/scripts/runSingleton.ts

@@ -0,0 +1,2 @@
+import './setupEnv'
+import '../api'

operator/scripts/setupEnv.ts

@@ -0,0 +1,30 @@
+import 'dotenv/config'
+import '../utils/import-graphql'
+import axios from 'axios'
+
+import {
+	globalHttpsKeepAliveAgent,
+	globalHttpKeepAliveAgent,
+} from '../lib/axios'
+
+import fetch from 'minipass-fetch'
+import http from 'http'
+import https from 'https'
+
+axios.defaults.httpAgent = globalHttpKeepAliveAgent
+axios.defaults.httpsAgent = globalHttpsKeepAliveAgent
+http.globalAgent = globalHttpKeepAliveAgent
+https.globalAgent = globalHttpsKeepAliveAgent
+
+// @ts-ignore
+global.fetch = fetch
+
+Object.assign(
+	BigInt.prototype,
+	'toJSON',
+	function (this: typeof BigInt.prototype) {
+		return this.toString()
+	}
+)
+
+// TODO: Need to add ws...

operator/tsconfig.json

@@ -1,17 +1,20 @@
 {
 	"ts-node": {
 		"esm": true,
-		"module": "CommonJS",
+		"experimentalSpecifierResolution": "node",
 		"require": ["tsconfig-paths/register"]
 	},
 	"compilerOptions": {
 		"target": "ES2020",
 		"lib": ["esnext"],
-		"module": "commonjs",
+		"module": "ESNext",
 		"rootDir": ".",
 		"moduleResolution": "node",
 		"baseUrl": ".",
 		"paths": {
+			"@/workers/*": ["workers/*"],
+			"@/test/*": ["test/*"],
+			"@uniswap/Permit2-sdk": ["permit2-sdk/src/index"],
 			"@/*": ["src/*"]
 		},
 		"typeRoots": ["./node_modules/@types", "./@types", "./@types/*"],

operator/utils/import-graphql.ts

@@ -0,0 +1,21 @@
+import { parse } from 'graphql'
+import { readFileSync } from 'fs'
+import { createRequire } from 'module'
+
+const require = createRequire(import.meta.url)
+
+export const supportImportGraphQL = () => {
+	const VALID_EXTENSIONS = ['graphql', 'graphqls', 'gql', 'gqls']
+
+	function handleModule(m: typeof module, filename: string) {
+		const content = readFileSync(filename, 'utf-8')
+
+		m.exports = parse(content)
+	}
+
+	VALID_EXTENSIONS.forEach((ext) => {
+		require.extensions[`.${ext}`] = handleModule
+	})
+}
+
+supportImportGraphQL()