class MyModule {
  constructor(private corpus: Corpus) {
    this.corpus.on('message.received', this.handleInput.bind(this))
  }
}

// Emit an event
corpus.emit('tool.called', {
  taskId: 'TASK-42',
  tool: 'shell_exec',
  args: { command: 'ls -la' }
})

// Listen for an event
corpus.on('tool.completed', (payload) => {
  console.log(`${payload.tool} finished in ${payload.durationMs}ms`)
})

## 09:15:02
- message.received → {"content":"What PRs need review?","timestamp":"2026-07-03T09:15:02.114Z"}

## 09:15:02
- context.built → {"tokenCount":5012,"tokenBudget":200000,"sectionsIncluded":["identity","device","prefrontal","capabilities","memory_map"]}

## 09:15:04
- tool.called → {"taskId":"TASK-89","tool":"github_prs","args":{"state":"open"}}

## 09:15:05
- safety.allowed → {"tool":"github_prs","args":{"state":"open"}}

## 09:15:06
- tool.completed → {"taskId":"TASK-89","tool":"github_prs","durationMs":1204}

## 09:15:07
- memory.episodeSaved → {"date":"2026-07-03","section":"09:15"}

// Subscribe — returns an unsubscribe function
const off = corpus.on('task.completed', (payload) => {
  console.log('Task done:', payload.taskId)
})

// Unsubscribe when done
off()

class Hypothalamus {
  private failureCount = 0
  private lastContextTokens = 0

  constructor(private corpus: Corpus) {
    // Listen for problems from other modules
    corpus.on('llm.error', () => {
      this.failureCount++
      if (this.failureCount > 5) {
        corpus.emit('health.warning', {
          resource: 'llm',
          usage: this.failureCount,
          threshold: 5
        })
      }
    })

    corpus.on('context.built', (payload) => {
      this.lastContextTokens = payload.tokenCount
      if (payload.tokenCount > payload.tokenBudget * 0.9) {
        corpus.emit('health.warning', {
          resource: 'context',
          usage: payload.tokenCount,
          threshold: payload.tokenBudget
        })
      }
    })

    corpus.on('tool.failed', (payload) => {
      if (payload.attempt >= 3) {
        corpus.emit('health.critical', {
          resource: 'tool',
          message: `${payload.tool}: max retries exceeded`
        })
      }
    })

    // Reset failure count on success
    corpus.on('llm.response', () => {
      this.failureCount = 0
    })
  }
}