add flag and auto create benchmark environment

Author: dnsi0

config.json

@@ -93,6 +93,7 @@
   "claimDurationTimeout": 3600,
   "validateUnsignedDDO": true,
   "jwtSecret": "ocean-node-secret",
+  "enableBenchmark": true,
   "dockerComputeEnvironments": [
     {
       "socketPath": "/var/run/docker.sock",

src/@types/OceanNode.ts

@@ -139,6 +139,7 @@ export interface OceanNodeConfig {
   jwtSecret?: string
   httpCertPath?: string
   httpKeyPath?: string
+  enableBenchmark?: boolean
 }
 
 export interface P2PStatusResponse {

src/components/c2d/compute_engine_docker.ts

@@ -22,9 +22,10 @@ import type {
   ComputeResourceRequest,
   ComputeEnvFees,
   ComputeResource,
-  C2DEnvironmentConfig
+  C2DEnvironmentConfig,
+  ComputeResourcesPricingInfo
 } from '../../@types/C2D/C2D.js'
-import { getConfiguration } from '../../utils/config.js'
+import { BENCHMARK_MONITORING_ADDRESS, getConfiguration } from '../../utils/config.js'
 import { C2DEngine } from './compute_engine_base.js'
 import { C2DDatabase } from '../database/C2DDatabase.js'
 import { Escrow } from '../core/utils/escrow.js'
@@ -215,6 +216,54 @@ export class C2DEngineDocker extends C2DEngine {
     }
     const consumerAddress = this.getKeyManager().getEthAddress()
 
+    if (config.enableBenchmark) {
+      const ramGB = this.physicalLimits.get('ram') || 0
+      const physicalDiskGB = this.physicalLimits.get('disk') || 0
+
+      const gpuResources: ComputeResource[] = []
+      for (const env of envConfig.environments) {
+        if (env.resources) {
+          for (const res of env.resources) {
+            if (res.id !== 'cpu' && res.id !== 'ram' && res.id !== 'disk') {
+              gpuResources.push(res)
+            }
+          }
+        }
+      }
+
+      const benchmarkPrices: ComputeResourcesPricingInfo[] = gpuResources.map((gpu) => ({
+        id: gpu.id,
+        price: 1
+      }))
+
+      const sepoliaChainId = '11155111' // TODO: add Sepolia chain ID
+      const usdcToken = '0x1c7D4B196Cb0C7B01d743Fbc6116a902379C7238' // TODO: add USDC token address on Sepolia
+
+      const benchmarkFees: ComputeEnvFeesStructure = {
+        [sepoliaChainId]: [{ feeToken: usdcToken, prices: benchmarkPrices }]
+      }
+
+      const benchmarkEnv: C2DEnvironmentConfig = {
+        description: 'Auto-generated benchmark environment',
+        storageExpiry: 604800,
+        maxJobDuration: 180,
+        minJobDuration: 60,
+        resources: [
+          { id: 'cpu', total: sysinfo.NCPU, min: 1, max: sysinfo.NCPU },
+          { id: 'ram', total: ramGB, min: 1, max: ramGB },
+          { id: 'disk', total: physicalDiskGB, min: 0, max: physicalDiskGB },
+          ...gpuResources
+        ],
+        access: {
+          addresses: [BENCHMARK_MONITORING_ADDRESS],
+          accessLists: null
+        },
+        fees: benchmarkFees
+      }
+
+      envConfig.environments.push(benchmarkEnv)
+    }
+
     for (let envIdx = 0; envIdx < envConfig.environments.length; envIdx++) {
       const envDef: C2DEnvironmentConfig = envConfig.environments[envIdx]
 

src/utils/config/constants.ts

@@ -68,12 +68,14 @@ export const ENV_TO_CONFIG_MAPPING = {
   P2P_AUTODIALINTERVAL: 'p2pConfig.autoDialInterval',
   P2P_ENABLE_NETWORK_STATS: 'p2pConfig.enableNetworkStats',
   HTTP_CERT_PATH: 'httpCertPath',
-  HTTP_KEY_PATH: 'httpKeyPath'
+  HTTP_KEY_PATH: 'httpKeyPath',
+  ENABLE_BENCHMARK: 'enableBenchmark'
 } as const
 
 // Configuration defaults
 export const DEFAULT_RATE_LIMIT_PER_MINUTE = 30
 export const DEFAULT_MAX_CONNECTIONS_PER_MINUTE = 60 * 2 // 120 requests per minute
+export const BENCHMARK_MONITORING_ADDRESS = '0xC5ea7916f95D5a087A644f1Dc0f7d19955eC446F'
 
 export const DEFAULT_BOOTSTRAP_ADDRESSES = [
   // OPF nodes

src/utils/config/schemas.ts

@@ -319,6 +319,7 @@ export const OceanNodeConfigSchema = z
     INTERFACES: z.string().optional(),
     hasP2P: booleanFromString.optional().default(true),
     hasHttp: booleanFromString.optional().default(true),
+    enableBenchmark: booleanFromString.optional().default(false),
 
     p2pConfig: OceanNodeP2PConfigSchema.nullable().optional(),
     hasIndexer: booleanFromString.default(true),