DeepSeek Harness: البرمجة الدفاعية ومراجعة الحوادث

// ❌ مفتاح API مُرمَّد
const apiKey = 'sk-abc123def456'

// ❌ مفتاح API مكتوب في السجلات
ctx.logger.info(`connecting with key: ${apiKey}`)

// ❌ مفتاح API في URL
const url = `https://api.example.com?key=${apiKey}`

// ❌ مفتاح API في رسالة الخطأ
throw new Error(`Authentication failed for key: ${apiKey}`)

// ✅ القراءة من التكوين
export const Config = Schema.object({
  apiKey: Schema.string().required().hidden()
})

export function apply(ctx: Context) {
  const apiKey = ctx.config.apiKey
  // apiKey يُستخدم فقط داخل apply، لا يتسرب للخارج
}

// ✅ استخدام متغيرات البيئة
const apiKey = process.env.MY_PLUGIN_API_KEY

// ✅ التمرير عبر ترويسة الطلب (ليس في URL)
const response = await fetch(url, {
  headers: { 'Authorization': `Bearer ${apiKey}` }
})

// ✅ إخفاء المعلومات الحساسة في السجلات
ctx.logger.info(`جاري الاتصال بـ ${endpoint}`)  // لا تسجّل المفتاح

// ✅ فلتر سجلات مخصص
function sanitize(obj: any): any {
  const sanitized = { ...obj }
  if (sanitized.apiKey) sanitized.apiKey = '***'
  if (sanitized.authorization) sanitized.authorization = '***'
  return sanitized
}

ctx.logger.info('طلب:', sanitize(request))

export const Config = Schema.object({
  apiKey: Schema.string().required().hidden(),
  keyRotationDays: Schema.number().default(90)
})

export function apply(ctx: Context) {
  ctx.setInterval(() => {
    const age = getKeyAge()
    if (age > ctx.config.keyRotationDays * 86400000) {
      ctx.logger.warn('مفتاح API متأخر عن التدوير')
    }
  }, 86400000)
}

// ❌ عدم التحقق من نتائج الأداة
async execute({ path }, ctx) {
  const result = await ctx.shell.execute(`ls ${path}`)
  return result.stdout  // قد يكون فارغًا أو مشوّهًا
}

// ✅ التحقق من نتائج الأداة
async execute({ path }, ctx) {
  const result = await ctx.shell.execute(`ls ${path}`)
  
  if (result.exitCode !== 0) {
    return {
      error: true,
      message: `فشل ls: ${result.stderr}`,
      exitCode: result.exitCode
    }
  }
  
  if (!result.stdout || result.stdout.trim().length === 0) {
    return {
      error: true,
      message: 'الدليل فارغ أو غير موجود'
    }
  }
  
  const files = result.stdout.trim().split('\n')
  return { count: files.length, files }
}

// ❌ عدم التحقق من استجابات API
const data = await response.json()
return data.result

// ✅ التحقق من استجابات API
async function callAPI(ctx: Context, endpoint: string): Promise<any> {
  const response = await fetch(endpoint)
  
  if (!response.ok) {
    throw new Error(`خطأ API: ${response.status} ${response.statusText}`)
  }
  
  let data: any
  try {
    data = await response.json()
  } catch {
    throw new Error('API أرجع JSON غير صالح')
  }
  
  if (!data || typeof data !== 'object') {
    throw new Error('API أرجع صيغة غير متوقعة')
  }
  
  return data
}

// ❌ عدم التحقق من مدخلات المستخدم
async execute({ command }, ctx) {
  return await ctx.shell.execute(command)  // خطر حقن الأوامر
}

// ✅ التحقق وتنظيف المدخلات
async execute({ command }, ctx) {
  if (!command || typeof command !== 'string') {
    return { error: true, message: 'أمر غير صالح' }
  }
  
  if (command.length > 1000) {
    return { error: true, message: 'الأمر طويل جدًا' }
  }
  
  // فحص القائمة البيضاء
  const allowed = ['ls', 'cat', 'grep', 'wc', 'head', 'tail']
  const baseCommand = command.split(' ')[0]
  if (!allowed.includes(baseCommand)) {
    return { error: true, message: `أمر غير مسموح: ${baseCommand}` }
  }
  
  return await ctx.shell.execute(command)
}

export function apply(ctx: Context) {
  // جميع الموارد التي تحتاج تنظيف
  const resources: { close: () => void | Promise<void> }[] = []

  // سجّل التنظيف فورًا عند اكتساب المورد
  function acquireResource<T extends { close: () => void | Promise<void> }>(
    resource: T
  ): T {
    resources.push(resource)
    return resource
  }

  // تنظيف موحَّد
  ctx.effect(() => {
    return async () => {
      for (const r of resources.reverse()) {
        try {
          await r.close()
        } catch (e) {
          ctx.logger.warn('خطأ في التنظيف:', e)
        }
      }
    }
  })

  // الاستخدام
  const db = acquireResource(openDatabase())
  const ws = acquireResource(new WebSocket('ws://localhost:8080'))
}

export function apply(ctx: Context) {
  const tempFiles: string[] = []

  ctx.effect(() => {
    return async () => {
      for (const file of tempFiles.reverse()) {
        try {
          await ctx.fs.unlink(file)
        } catch {}
      }
    }
  })

  async function createTempFile(content: string): Promise<string> {
    const path = `/tmp/dsh-${Date.now()}-${Math.random().toString(36).slice(2)}`
    await ctx.fs.writeFile(path, content)
    tempFiles.push(path)
    return path
  }
}

المبدأ 1: قلّل الآثار الجانبية
  → نفِّذ فقط العمليات الضرورية
  → فضِّل للقراءة فقط، ثم الكتابة المُمكِنة

المبدأ 2: الآثار الجانبية يجب أن تكون قابلة للعكس
  → احفظ الحالة الأصلية قبل الكتابة
  → وفّر عمليات تراجع

المبدأ 3: الآثار الجانبية يجب أن تكون قابلة للتدقيق
  → سجّل تفاصيل كل أثر جانبي
  → يمكن للمستخدمين عرض سجل العمليات

المبدأ 4: الآثار الجانبية تتطلب موافقة
  → العمليات الهدّامة يجب أن تحظى بموافقة
  → العمليات غير المُمكِنة يجب أن تحظى بموافقة

interface ReversibleAction {
  execute(): Promise<void>
  rollback(): Promise<void>
}

class FileEditAction implements ReversibleAction {
  private originalContent: string | null = null

  constructor(
    private path: string,
    private newContent: string,
    private ctx: Context
  ) {}

  async execute() {
    try {
      this.originalContent = await this.ctx.fs.readFile(this.path)
    } catch {
      this.originalContent = null
    }
    await this.ctx.fs.writeFile(this.path, this.newContent)
  }

  async rollback() {
    if (this.originalContent !== null) {
      await this.ctx.fs.writeFile(this.path, this.originalContent)
    } else {
      await this.ctx.fs.unlink(this.path)
    }
  }
}

const auditLog: AuditEntry[] = []

function audit(action: string, details: any, reversible: boolean) {
  auditLog.push({
    timestamp: Date.now(),
    action,
    details,
    reversible,
    user: 'agent'
  })
  ctx.emit('audit/action', { action, details, reversible })
}

// الاستخدام
audit('file_edit', { path: 'src/app.ts', operation: 'edit' }, true)
audit('email_send', { to: 'alice@example.com' }, false)

# مراجعة حادث: [العنوان]

## معلومات أساسية
- التاريخ: YYYY-MM-DD
- التأثير: [الميزات/المستخدمون المتأثرون]
- الخطورة: P0/P1/P2
- المُعالِج: [الاسم]

## الجدول الزمني
- HH:MM — [الحدث 1]
- HH:MM — [الحدث 2]
- HH:MM — [الإصلاح]

## تحليل السبب الجذري
[تحليل الـ 5 لماذا]

## الإصلاح
- قصير المدى: [الإصلاح الفوري]
- طويل المدى: [إجراء الوقاية]

## الدروس المستفادة
- [الدرس 1]
- [الدرس 2]

حادث: وكيل حذف ملفات مشروع مستخدم

لماذا 1: الوكيل نفّذ rm -rf /project
  → لأن الأداة لم يكن لديها تحقق من المسار

لماذا 2: الأداة لم يكن لديها تحقق من المسار
  → لأن المطور لم ينفّذ فحص القائمة البيضاء

لماذا 3: المطور لم ينفّذ فحص القائمة البيضاء
  → لأنه لم تكن هناك عملية مراجعة أمنية

لماذا 4: لا توجد عملية مراجعة أمنية
  → لأن الفريق لم يُنشئ قائمة تدقيق أمنية

لماذا 5: الفريق لم يُنشئ قائمة تدقيق أمنية
  → بسبب تدريب وعي أمني غير كافٍ

الإصلاح: أنشئ قائمة تدقيق أمنية؛ جميع الإضافات يجب فحصها قبل النشر

# تشغيل التدقيق الأمني
dsh audit my-plugin

# المخرجات
🔒 Security Audit: my-plugin

✅ No hardcoded credentials
✅ All ctx.effect() have cleanup functions
⚠️ Tool 'db_query' has no input validation
❌ API response not validated in 'fetch_data'
✅ Approval policy configured for destructive operations
⚠️ Permission 'shell.execute' may not be necessary

2 errors, 2 warnings found. Fix before publishing.