الانتقال إلى المحتوى الرئيسي

​
متى تضيف وحدة

تحتوي بيئة التشغيل على 15 وحدة. إضافة وحدة سادسة عشرة هو قرار مهم - افعل ذلك عندما لا تتناسب وظيفة جديدة مع أي منطقة موجودة وتكون مهمة بما يكفي لتكون جزءًا دائمًا من خط الأنابيب.
قبل إضافة وحدة، فكر فيما إذا كانت الوظيفة تنتمي لوحدة موجودة. إذا كانت أداة جديدة، فربما تنتمي إلى cerebellum كقدرة. إذا كانت فحص أمان جديد، فتنتمي إلى amygdala. الوحدات الجديدة هي للوظائف الإدراكية الجديدة فعلاً.

​
الخطوة 1: إنشاء المجلد

اتبع اتفاقية شيء واحد لكل مجلد: 
src/main/runtime/my-module/my-module.ts

​
الخطوة 2: تعريف الصنف

كل وحدة تتبع نفس نمط المُنشئ: 
import { Corpus } from '@main/runtime/corpus/corpus'

export interface MyModuleOpts {
  workspaceRoot: string
  corpus: Corpus
}

export class MyModule {
  private readonly workspaceRoot: string
  private readonly corpus: Corpus

  constructor(opts: MyModuleOpts) {
    this.workspaceRoot = opts.workspaceRoot
    this.corpus = opts.corpus

    // Subscribe to events this module cares about
    this.corpus.on('message.received', (payload) => this.handleMessage(payload))
  }

  async doSomething(input: string): Promise<MyResult> {
    // Module logic here

    // Emit events for other modules to react to
    this.corpus.emit('my-module.completed', { input, result })
    return result
  }

  private handleMessage(payload: MessagePayload): void {
    // React to events from other modules
  }
}

​
الخطوة 3: تعريف أحداث Corpus

أضف أحداث وحدتك إلى تعداد CorpusEvent في corpus.ts: 
// src/main/runtime/corpus/corpus.ts

export type CorpusEvents = {
  // ... existing events ...

  // My module events
  'my-module.started': { input: string }
  'my-module.completed': { input: string; result: MyResult }
  'my-module.failed': { input: string; error: string }
}
سمِّ الأحداث بصيغة module-name.past-tense-verb. هذا يجعل سجل الأحداث يُقرأ كقصة: “رسالة وُصلت، سياق بُني، أمان فُحص، استجابة بُثّت.”

​
الخطوة 4: الربط في Agent

استورد وأنشئ نسخة من وحدتك في agent.ts: 
// src/main/runtime/agent.ts

import { MyModule } from '@main/runtime/my-module/my-module'

export class Agent {
  private readonly myModule: MyModule

  constructor(opts: AgentOpts) {
    // ... existing modules ...

    this.myModule = new MyModule({
      workspaceRoot: opts.workspaceRoot,
      corpus: this.corpus,
    })
  }

  async processMessage(message: string): Promise<void> {
    // The pipeline — call your module at the right stage
    const context = await this.prefrontal.buildContext(message)
    const filtered = await this.ras.filter(context)

    // Example: call your module after context is built
    await this.myModule.doSomething(filtered)

    const response = await this.thalamus.stream(filtered)
    // ... rest of pipeline
  }
}
مكان تشغيل وحدتك في خط الأنابيب يعتمد على ما تفعله:
المرحلةمتى تُدرج
قبل prefrontalمعالجة المدخلات المسبقة، التوجيه
بعد prefrontal، قبل thalamusإثراء السياق، التصفية
بعد thalamus، قبل brocaمعالجة المخرجات، التحقق
بعد brocaإجراءات ما بعد الاستجابة، التسجيل

​
الخطوة 5: إضافة تخزين مساحة العمل (إذا لزم الأمر)

إذا احتاجت وحدتك لحالة دائمة، أنشئ مجلدًا في الافتراضيات: 
src/defaults/workspace/brain/my-module/
اقرأ واكتب ملفات Markdown للحالة: 
import { readFile, writeFile } from 'fs/promises'
import { join } from 'path'

async loadState(): Promise<MyState> {
  const path = join(this.workspaceRoot, 'brain', 'my-module', 'state.md')
  const content = await readFile(path, 'utf-8')
  return this.parseState(content)
}

async saveState(state: MyState): Promise<void> {
  const path = join(this.workspaceRoot, 'brain', 'my-module', 'state.md')
  await writeFile(path, this.serializeState(state), 'utf-8')
}

​
قواعد التصميم

جميع الاتصالات بين الوحدات تمر عبر أحداث corpus. هذا يحافظ على رسم التبعيات مسطحًا ويجعل الوحدات قابلة للاختبار بشكل مستقل.
// WRONG — direct import creates coupling
import { Hippocampus } from '@main/runtime/hippocampus/hippocampus'

// RIGHT — communicate via events
this.corpus.emit('memory.store-requested', { content })
this.corpus.on('memory.stored', (payload) => { /* ... */ })
كل وحدة تفعل شيئًا واحدًا بالضبط. إذا كنت تضيف وظيفتين غير مرتبطتين، فهما وحدتان (أو إحداهما تنتمي لوحدة موجودة).
قابلة للقراءة البشرية، قابلة لإصدار Git، قابلة لتحليل نموذج اللغة. لا تستخدم أبدًا الصيغ الثنائية أو JSON لحالة مساحة العمل. Markdown مع بيانات YAML الوصفية هو المعيار.
يجب أن تكون وحدتك قابلة للاختبار بمحاكاة corpus فقط. إذا احتجت لمحاكاة خمسة أشياء أخرى، فوحدتك لديها تبعيات كثيرة جدًا.
إذا احتاجت وحدتك لتكوين، اقرأه من config.json عبر مساعد مساحة العمل. لا تخترع آلية تكوين جديدة.
import { readConfig } from '@main/workspace/config'

const config = await readConfig(this.workspaceRoot)
const myModuleConfig = config.myModule ?? defaults

​
الاختبار

اختبر وحدتك بشكل معزول بمحاكاة corpus: 
import { describe, it, expect, vi } from 'vitest'
import { MyModule } from './my-module'

describe('MyModule', () => {
  function createMockCorpus() {
    const handlers = new Map<string, Function>()
    return {
      on: vi.fn((event, handler) => handlers.set(event, handler)),
      emit: vi.fn(),
      // Helper to simulate incoming events
      simulate: (event: string, payload: unknown) => handlers.get(event)?.(payload),
    }
  }

  it('emits completed event after processing', async () => {
    const corpus = createMockCorpus()
    const mod = new MyModule({
      workspaceRoot: '/tmp/test-workspace',
      corpus: corpus as any,
    })

    await mod.doSomething('test input')

    expect(corpus.emit).toHaveBeenCalledWith(
      'my-module.completed',
      expect.objectContaining({ input: 'test input' })
    )
  })

  it('reacts to incoming events', () => {
    const corpus = createMockCorpus()
    new MyModule({ workspaceRoot: '/tmp/test-workspace', corpus: corpus as any })

    corpus.simulate('message.received', { content: 'hello' })

    // Assert side effects
  })
})

نظرة عامة على البنية

فهم كيف تتكامل الوحدات الـ 15 معًا.

هيكل المشروع

أين يوجد كل شيء في الكود.