create-network-volume

Implementation Reference

• src/index.ts:1267-1287 (registration)

  Registration of the 'create-network-volume' tool via server.tool() with name, schema, and handler.

  // Create Network Volume
  server.tool(
    'create-network-volume',
    {
      name: z.string().describe('Name for the network volume'),
      size: z.number().describe('Size in GB (1-4000)'),
      dataCenterId: z.string().describe('Data center ID'),
    },
    async (params) => {
      const result = await runpodRequest('/networkvolumes', 'POST', params);
  
      return {
        content: [
          {
            type: 'text',
            text: JSON.stringify(result, null, 2),
          },
        ],
      };
    }
  );

• src/index.ts:1270-1274 (schema)

  Input schema for 'create-network-volume' tool: name (string), size (number, 1-4000 GB), dataCenterId (string).

  {
    name: z.string().describe('Name for the network volume'),
    size: z.number().describe('Size in GB (1-4000)'),
    dataCenterId: z.string().describe('Data center ID'),
  },

• src/index.ts:1275-1286 (handler)

  Handler function that sends a POST request to /networkvolumes with the params and returns the response.

  async (params) => {
    const result = await runpodRequest('/networkvolumes', 'POST', params);
  
    return {
      content: [
        {
          type: 'text',
          text: JSON.stringify(result, null, 2),
        },
      ],
    };
  }

• src/index.ts:60-99 (helper)

  The runpodRequest helper function used by the handler to make authenticated API calls to RunPod.

  async function runpodRequest(
    endpoint: string,
    method: string = 'GET',
    body?: Record<string, unknown>
  ) {
    const url = `${API_BASE_URL}${endpoint}`;
    const headers = {
      Authorization: `Bearer ${API_KEY}`,
      'Content-Type': 'application/json',
    };
  
    const options: NodeFetchRequestInit = {
      method,
      headers,
    };
  
    if (body && (method === 'POST' || method === 'PATCH')) {
      options.body = JSON.stringify(body);
    }
  
    try {
      const response = await fetch(url, options);
  
      if (!response.ok) {
        const errorText = await response.text();
        throw new Error(`RunPod API Error: ${response.status} - ${errorText}`);
      }
  
      // Some endpoints might not return JSON
      const contentType = response.headers.get('content-type');
      if (contentType && contentType.includes('application/json')) {
        return await response.json();
      }
  
      return { success: true, status: response.status };
    } catch (error) {
      console.error('Error calling RunPod API:', error);
      throw error;
    }
  }