worker-module.js

/**
 * Attempt to use Claude Code as a direct module import
 * This would be the most elegant solution if Claude exposes a programmatic API
 */

// Approach 1: Try to import Claude's internal modules
async function tryDirectImport () {
  try {
    // Claude Code is installed via npm as @anthropic-ai/claude-code
    // Try to access its internal API
    const claudePath = require.resolve('@anthropic-ai/claude-code')
    console.log('Claude Code found at:', claudePath)

    // Try to import the main module
    const claude = await import('@anthropic-ai/claude-code')
    console.log('Claude exports:', Object.keys(claude))

    return claude
  } catch (err) {
    console.error('Cannot import Claude as module:', err.message)
    return null
  }
}

// Approach 2: Use require.cache to intercept Claude's modules
function interceptClaudeModules () {
  const originalRequire = Module.prototype.require
  const interceptedModules = new Map()

  Module.prototype.require = function (id) {
    const module = originalRequire.apply(this, arguments)

    // Intercept any Claude-related modules
    if (id.includes('claude') || id.includes('anthropic')) {
      console.log('Intercepted module:', id)
      interceptedModules.set(id, module)

      // You can wrap or modify the module here
      return new Proxy(module, {
        get (target, prop) {
          console.log(`Accessing ${id}.${String(prop)}`)
          return target[prop]
        }
      })
    }

    return module
  }

  return interceptedModules
}

// Approach 3: Monkey-patch child_process to intercept Claude spawning
function interceptClaudeSpawn () {
  const { spawn } = require('child_process')
  const originalSpawn = spawn

  require('child_process').spawn = function (...args) {
    const [command, cmdArgs, options] = args

    // Detect if this is spawning Claude
    if (command.includes('claude')) {
      console.log('Intercepting Claude spawn:', { command, cmdArgs, options })

      // You can modify args, inject hooks, etc.
      // Example: Add custom environment variables
      if (options && options.env) {
        options.env.CLAUDE_HOOK = 'enabled'
      }
    }

    return originalSpawn.apply(this, args)
  }
}

// Example usage in your worker
export class ModuleBasedClaudeWorker {
  constructor () {
    this.claudeModule = null
  }

  async initialize () {
    // Try method 1: Direct import
    this.claudeModule = await tryDirectImport()

    if (!this.claudeModule) {
      // Fall back to method 2: Interception
      console.log('Using interception-based approach')
      this.interceptedModules = interceptClaudeModules()
      interceptClaudeSpawn()
    }
  }

  async send (message) {
    if (this.claudeModule && this.claudeModule.sendMessage) {
      // If Claude exposes a programmatic API
      return this.claudeModule.sendMessage(message)
    }

    // Otherwise fall back to process spawning
    throw new Error('No programmatic API available')
  }
}

// Export for testing
export { tryDirectImport, interceptClaudeModules, interceptClaudeSpawn }