Modular Block System

// Examples of block granularity
MonitorTokenPrice();
ExecuteUniswapSwap();
InvokeSmartContractMethod();
QuerySalesforceRecord();
SendSlackNotification();
ApplySentimentAnalysis();

interface IBlockHandler {
  execute(inputs: BlockInputs, config: BlockConfig): Promise<BlockOutputs>;
  validate(inputs: BlockInputs, config: BlockConfig): ValidationResult;
  getMetadata(): BlockMetadata;
}

interface IBlockMetadata {
  id: string;
  name: string;
  description: string;
  category: BlockCategory;
  inputs: InputDefinition[];
  outputs: OutputDefinition[];
  configFields: ConfigField[];
  version: string;
  author: string;
}

class DynamicBlockRegistry {
  private blockHandlers: Map<string, IBlockHandler> = new Map();

  async loadBlock(blockId: string): Promise<IBlockHandler> {
    // Dynamic import and instantiation
    const blockModule = await import(`./blocks/${blockId}`);
    const handler = new blockModule.default();
    this.blockHandlers.set(blockId, handler);
    return handler;
  }

  discoverBlocks(): BlockMetadata[] {
    // Scan available blocks and return metadata
    return this.scanBlockDirectory();
  }
}

import { BlockHandler, BlockMetadata } from "@zzyra/sdk";

export class CustomGasMonitorBlock extends BlockHandler {
  getMetadata(): BlockMetadata {
    return {
      id: "custom-gas-monitor",
      name: "Gas Price Monitor",
      description: "Monitor Ethereum gas prices and send alerts",
      category: "web3",
      inputs: [
        {
          name: "threshold",
          type: "number",
          required: true,
          description: "Gas price threshold in gwei",
        },
      ],
      outputs: [
        {
          name: "currentGasPrice",
          type: "number",
          description: "Current gas price in gwei",
        },
        {
          name: "alertTriggered",
          type: "boolean",
          description: "Whether alert was triggered",
        },
      ],
      configFields: [
        {
          name: "alertChannel",
          type: "select",
          label: "Alert Channel",
          required: true,
          options: ["email", "slack", "discord"],
        },
      ],
    };
  }

  async execute(inputs: any, config: any): Promise<any> {
    // Implementation logic
    const gasPrice = await this.getCurrentGasPrice();
    const alertTriggered = gasPrice < inputs.threshold;

    if (alertTriggered) {
      await this.sendAlert(config.alertChannel, gasPrice);
    }

    return {
      currentGasPrice: gasPrice,
      alertTriggered,
    };
  }
}