Bağlı sitelerde ajan erişimi anahtarı

Kullanıcı, Orbit hesabıyla girdiği bir siteyi ajanına açabiliyor: panelde
"Bağlı siteler" kartındaki her satırda "Ajan erişimini aç/kapat". Açık
olduğunda ajan o sitede kişinin YAPABİLDİKLERİNİ kişinin ADINA yapıyor —
ayrı ajan hesabı, ayrı ajan listesi doğmuyor. Orbit'in kendisi istisna
kalıyor; orada ajanlar kendi adına davranıyor ve o yol
`mcp_authorization_grants` üzerinden yürüyor.

Bu, kopyala-yapıştır anahtar tasarımının yerine geçiyor. Öncekinde son
kullanıcı bir yenileme anahtarını elle taşıyordu; Rota herkese açık bir
site ve oraya konan şeyin ürün olması gerekiyor.

İzin ayrı tabloda değil, `oauth_client_grants` satırının içinde: site
bağlantısı kesildiğinde ajan erişimi de düşmeli ve bunun ayrı bir temizlik
adımı gerektirmemesi lazım — unutulan temizlik açık kalan kapıdır. Test tam
bunu tutuyor: iptal edilmiş bir izinde anahtar açılmıyor. Depo katmanındaki
`revoked_at IS NULL` koşulunu kaldıran mutasyon testi düşürüyor (23→22).

Varsayılan kapalı. Bağlı her siteyi ajana açık saymak, kullanıcının hiç
sorulmamış bir soruya "evet" demesi olurdu.

Ayrıca tsconfig'den `baseUrl` kaldırıldı: TypeScript 6'da hata veriyordu ve
`tsc --noEmit` hiç koşmuyordu. `paths` zaten kullanılmıyor.

Author: sametbasbug

migrations/0044_agents_can_act_on_connected_sites.sql

@@ -0,0 +1,33 @@
+-- Ajanlar bağlı sitelerde insanın adına iş yapabilsin.
+--
+-- Kural insanın kendi cümlesiyle: alt sitelerde ajan, insanın yapabildiğini
+-- insanın adına yapar; ayrı ajan hesabı, ayrı ajan listesi olmaz. Tek istisna
+-- Orbit'in kendisi — orada ajanlar kendi adına davranır ve o yol
+-- `mcp_authorization_grants` üzerinden yürüyor, buraya karışmıyor.
+--
+-- İzin neden ayrı bir sütun, ayrı bir tablo değil: ajan erişimi insanın o
+-- siteye verdiği iznin İÇİNDE yaşıyor. Site bağlantısı kesildiğinde ajanın
+-- erişimi de kesilmeli ve bunun ayrı bir temizlik adımı gerektirmemesi lazım —
+-- unutulan temizlik, açık kalan kapıdır. Aynı satırda durunca `revoked_at`
+-- ikisini birden düşürüyor.
+--
+-- NULL = kapalı. Varsayılan bilerek kapalı: bağlı olan her site için ajan
+-- erişimini açık saymak, kullanıcının hiç sormadığımız bir soruya "evet"
+-- demesi olurdu.
+ALTER TABLE oauth_client_grants ADD COLUMN agent_access_at INTEGER;
+
+-- Açılma anı iznin kendisinden önce olamaz.
+-- SQLite ALTER TABLE ile CHECK eklenemediği için kontrol trigger'da.
+CREATE TRIGGER oauth_client_grants_agent_access_sane
+BEFORE UPDATE OF agent_access_at ON oauth_client_grants
+BEGIN
+  SELECT RAISE(ABORT, 'oauth_grant_agent_access_before_grant')
+  WHERE NEW.agent_access_at IS NOT NULL
+    AND NEW.agent_access_at < NEW.created_at;
+END;
+
+-- Ajan token'ı isterken bu sorgu koşuyor: "bu hesabın bu siteye verdiği,
+-- iptal edilmemiş ve ajana açık izni var mı".
+CREATE INDEX oauth_client_grants_agent_access_idx
+  ON oauth_client_grants (account_id, agent_access_at)
+  WHERE agent_access_at IS NOT NULL AND revoked_at IS NULL;

scripts/orbit-d1-test-worker.ts

@@ -863,6 +863,22 @@ async function handleAction(body: ActionRequest, env: Environment): Promise<Resp
       });
     }
 
+    case 'setSiteAgentAccess': {
+      return json({
+        grant: await siteRepository.setAgentAccess({
+          grantId: stringValue(data, 'grantId'),
+          allowed: data.allowed === true,
+          now: numberValue(data, 'now'),
+        }),
+      });
+    }
+
+    case 'listSiteAccountGrants': {
+      return json({
+        grants: await siteRepository.listAccountGrants(stringValue(data, 'accountId')),
+      });
+    }
+
     case 'revokeSiteGrant': {
       await siteRepository.revokeGrant({
         grantId: stringValue(data, 'grantId'),

scripts/orbit-site-authorization-tests.ts

@@ -128,6 +128,7 @@ interface GrantView {
   lastUsedAt: number | null;
   revokedAt: number | null;
   revokedReason: string | null;
+  agentAccessAt: number | null;
 }
 
 interface StateView {
@@ -599,6 +600,59 @@ describe('Orbit as a sign-in door for other sites', { concurrency: false }, () =
     assert.equal(afterReplay.tokens.filter((row) => row.revoked_at === null).length, 0);
   });
 
+  test('agent access is off until the person turns it on, and dies with the grant', async () => {
+    const now = 1_760_000_900_000;
+    const accountId = 'door-agent';
+    await seedClientAndAccount(accountId, now);
+    const grant = await consent({ prefix: 'agent', accountId, now });
+
+    /* Varsayılan kapalı. Bağlı olan her siteye ajan erişimini açık saymak,
+       kullanıcının hiç sorulmamış bir soruya "evet" demesi olurdu. */
+    assert.equal(grant.agentAccessAt, null, 'agent access must start closed');
+
+    const opened = await callAction<{ grant: GrantView }>('setSiteAgentAccess', {
+      grantId: grant.id, allowed: true, now: now + 1_000,
+    });
+    assert.equal(opened.grant.agentAccessAt, now + 1_000);
+
+    const listed = await callAction<{ grants: GrantView[] }>('listSiteAccountGrants', { accountId });
+    assert.equal(
+      listed.grants.find((row) => row.id === grant.id)?.agentAccessAt,
+      now + 1_000,
+      'the dashboard reads this list; the switch has to be visible there',
+    );
+
+    const closed = await callAction<{ grant: GrantView }>('setSiteAgentAccess', {
+      grantId: grant.id, allowed: false, now: now + 2_000,
+    });
+    assert.equal(closed.grant.agentAccessAt, null, 'closing must clear it, not just stamp a second time');
+
+    /* Asıl mesele: site bağlantısı kesildiğinde ajan erişimi de ölmeli ve bu
+       AYRI BİR TEMİZLİK ADIMI gerektirmemeli. Ajan erişimi izin satırının
+       içinde durduğu için `revoked_at` ikisini birden düşürüyor. Ayrı tabloda
+       olsaydı burası "iptal edildi ama ajan hâlâ açık" durumunu yakalardı. */
+    await callAction<{ grant: GrantView }>('setSiteAgentAccess', {
+      grantId: grant.id, allowed: true, now: now + 3_000,
+    });
+    await callAction('revokeSiteGrant', {
+      grantId: grant.id,
+      actorAccountId: accountId,
+      reason: 'disconnected_by_owner',
+      auditEventId: 'agent-access-audit',
+      requestId: 'agent-access-request',
+      now: now + 4_000,
+    });
+
+    const afterRevoke = await callAction<{ grant: GrantView }>('setSiteAgentAccess', {
+      grantId: grant.id, allowed: true, now: now + 5_000,
+    });
+    assert.notEqual(
+      afterRevoke.grant.agentAccessAt,
+      now + 5_000,
+      'a revoked grant must not accept agent access; that switch would look open and never work',
+    );
+  });
+
   test('revoking a grant kills its tokens and unredeemed codes in one step', async () => {
     const now = 1_760_000_800_000;
     const accountId = 'door-eight';

src/pages/dashboard.astro

@@ -177,7 +177,7 @@ import { LEGAL_LAST_UPDATED } from '../data/legal';
              kişinin neyi kestiğini bilmemesi olurdu. -->
         <article id="connected-sites-card" class="dashboard-card account-card section-card">
           <h2>Bağlı siteler</h2>
-          <p class="section-help">Orbit hesabınla giriş yaptığın siteler. Bağlantıyı kesmek Orbit’in o siteye verdiği anahtarları anında düşürür ve site Orbit’ten yeni bilgi alamaz. İki şeyi yapmaz: sitedeki oturumunu kapatmaz (oradan ayrıca çıkman gerekir) ve sitenin kendi kaydına aldığı bilgileri silmez.</p>
+          <p class="section-help">Orbit hesabınla giriş yaptığın siteler. Bağlantıyı kesmek Orbit’in o siteye verdiği anahtarları anında düşürür ve site Orbit’ten yeni bilgi alamaz. İki şeyi yapmaz: sitedeki oturumunu kapatmaz (oradan ayrıca çıkman gerekir) ve sitenin kendi kaydına aldığı bilgileri silmez. Ajan erişimini açtığın sitede ajanın, senin yapabildiklerini senin adına yapabilir — ayrı bir ajan hesabı ya da ayrı bir liste oluşmaz. Kapattığında erişim anında biter.</p>
           <div id="connected-sites" class="dashboard-list"></div>
         </article>
         <div class="truth-note">

src/scripts/dashboard.js

@@ -356,12 +356,36 @@ async function loadConnectedSites() {
     const lastUsed = site.lastUsedAt
       ? ` · son giriş ${new Date(site.lastUsedAt).toLocaleDateString('tr-TR')}`
       : '';
-    item.innerHTML = `<strong>${escapeHtml(site.label)}</strong><div class="meta">${escapeHtml(since)} tarihinden beri${escapeHtml(lastUsed)} · ${escapeHtml(site.scopes.join(', '))}</div>`;
+    item.innerHTML = `<strong>${escapeHtml(site.label)}</strong><div class="meta">${escapeHtml(since)} tarihinden beri${escapeHtml(lastUsed)} · ${escapeHtml(site.scopes.join(', '))}${site.agentAccess ? ' · <b>ajanın da kullanabilir</b>' : ''}</div>`;
     /* Uyarı metni bilerek "oturumun kapanır" DEMİYOR, çünkü kapanmıyor.
        İptal Orbit'in o siteye verdiği anahtarları düşürüyor; sitenin kendi
        açtığı oturum bize ait değil ve ona uzaktan dokunamıyoruz. Eski metin
        kapandığını söylüyordu ve bu, paylaşılan bir bilgisayarda "kestim,
        çıktım" diye kalkan birini açık oturumla bırakır. */
+    /* Ajan anahtarı. Kural insanın kendi cümlesiyle: alt sitelerde ajan,
+       insanın yapabildiğini insanın ADINA yapar — ayrı ajan listesi olmaz.
+       Açık olduğunda ajan bu site için Orbit'ten anahtar alabiliyor; kapalıysa
+       alamıyor ve elindeki bir sonraki istekte düşüyor.
+
+       Anahtar metni durumu değil EYLEMİ söylüyor ("Ajan erişimini aç/kapat"):
+       "Ajan erişimi açık" yazan bir düğmede basınca ne olacağı belirsiz
+       kalıyor. */
+    item.append(actionButton(
+      site.agentAccess ? 'Ajan erişimini kapat' : 'Ajan erişimini aç',
+      async () => {
+        try {
+          await mutate(
+            `/v1/me/connected-sites/${encodeURIComponent(site.id)}/agent-access`,
+            'POST',
+            { allowed: !site.agentAccess },
+          );
+          await loadConnectedSites();
+          flash(site.agentAccess
+            ? `${site.label} için ajan erişimi kapatıldı.`
+            : `${site.label} için ajan erişimi açıldı. Ajanın oradaki işleri senin adına yapabilir.`);
+        } catch (error) { flash(error.message, 'error'); }
+      },
+    ));
     item.append(actionButton('Bağlantıyı kes', async () => {
       if (!window.confirm(`${site.label} bağlantısı kesilsin mi? Orbit'in o siteye verdiği anahtarlar hemen düşer ve site Orbit'ten yeni bilgi alamaz. Sitedeki oturumun açık kalır; oradan ayrıca çıkman gerekir.`)) return;
       try {

src/server/http/api.ts

@@ -7413,6 +7413,10 @@ export async function handleApiRequest(
             scopes: grant.scopes,
             createdAt: grant.createdAt,
             lastUsedAt: grant.lastUsedAt,
+            /* Ajan erişimi. Panel bunu bir anahtar olarak gösteriyor; açık
+             * olması, kişinin ajanının o sitede KENDİ ADINA değil KİŞİNİN
+             * adına iş yapabildiği anlamına geliyor. */
+            agentAccess: grant.agentAccessAt !== null,
           })),
       });
     }
@@ -7444,6 +7448,42 @@ export async function handleApiRequest(
       return json({ connectedSite: { id: grantId, revoked: true } });
     }
 
+    /* Ajanın bu sitede insanın adına iş yapmasını açar/kapatır.
+     *
+     * Kapatmak ANINDA etkili olmalı: ajanın elindeki token bu satıra bakarak
+     * veriliyor ve kapatıldığında bir sonraki istek reddediliyor. Kullanıcı
+     * anahtarı kapattıktan sonra "acaba hâlâ yazabiliyor mu" diye
+     * düşünmemeli. */
+    const connectedSiteAgentAccessMatch =
+      /^\/v1\/me\/connected-sites\/([^/]+)\/agent-access$/u.exec(path);
+    if (request.method === 'POST' && connectedSiteAgentAccessMatch) {
+      const auth = await authenticateHuman(request, env, repository, now, true);
+      const body = await readJson(request);
+      requireExactFields(body, ['allowed'], 'invalid_agent_access_fields');
+      if (typeof body.allowed !== 'boolean') {
+        throw new ApiError(400, 'invalid_agent_access_fields', '`allowed` must be a boolean.');
+      }
+      const grantId = decodeURIComponent(connectedSiteAgentAccessMatch[1]);
+      const grant = await siteRepository.getGrantById(grantId);
+      /* Başkasının izni "bulunamadı" diye dönüyor — iptal ucundaki gerekçenin
+       * aynısı: "yetkin yok" demek, izin kimliklerinin taranmasına izin
+       * verirdi. */
+      if (!grant || grant.accountId !== auth.account.id) {
+        throw new ApiError(404, 'connected_site_not_found', 'Connected site was not found.');
+      }
+      if (grant.revokedAt !== null) {
+        throw new ApiError(409, 'connected_site_already_revoked', 'Connected site is already revoked.');
+      }
+      const updated = await siteRepository.setAgentAccess({
+        grantId,
+        allowed: body.allowed,
+        now,
+      });
+      return json({
+        connectedSite: { id: grantId, agentAccess: updated?.agentAccessAt != null },
+      });
+    }
+
     const mcpAuthorizationRevokeMatch = /^\/v1\/mcp\/authorizations\/([^/]+)\/revoke$/u.exec(path);
     if (request.method === 'POST' && mcpAuthorizationRevokeMatch) {
       const auth = await authenticateHuman(request, env, repository, now, true);

src/server/repositories/d1/d1-site-authorization-repository.ts

@@ -39,6 +39,7 @@ interface GrantSqlRow {
   last_used_at: number | null;
   revoked_at: number | null;
   revoked_reason: string | null;
+  agent_access_at: number | null;
 }
 
 interface CodeSqlRow {
@@ -74,7 +75,7 @@ const GRANT_SELECT = `
          client.site_url AS client_site_url, grant_row.account_id,
          grant_row.scopes, grant_row.consent_version, grant_row.created_at,
          grant_row.updated_at, grant_row.last_used_at, grant_row.revoked_at,
-         grant_row.revoked_reason
+         grant_row.revoked_reason, grant_row.agent_access_at
   FROM oauth_client_grants grant_row
   JOIN oauth_clients client ON client.id = grant_row.client_id
 `;
@@ -134,6 +135,7 @@ function grantFromSql(row: GrantSqlRow): SiteGrantView {
     lastUsedAt: row.last_used_at,
     revokedAt: row.revoked_at,
     revokedReason: row.revoked_reason,
+    agentAccessAt: row.agent_access_at,
   };
 }
 
@@ -294,6 +296,27 @@ export class D1SiteAuthorizationRepository implements SiteAuthorizationRepositor
     return rows.results.map(grantFromSql);
   }
 
+  async setAgentAccess(input: {
+    grantId: string;
+    allowed: boolean;
+    now: number;
+  }): Promise<SiteGrantView | null> {
+    /* `revoked_at IS NULL` koşulu WHERE'de, çağıranın kontrolüne bırakılmadı:
+     * iptal edilmiş bir izne ajan erişimi açmak sessizce "başarılı" dönerse
+     * panelde açık görünen ama hiçbir zaman çalışmayacak bir anahtar doğar. */
+    await this.#db.prepare(`
+      UPDATE oauth_client_grants
+         SET agent_access_at = ?, updated_at = ?
+       WHERE id = ? AND revoked_at IS NULL
+    `).bind(input.allowed ? input.now : null, input.now, input.grantId).run();
+
+    const row = await this.#db.prepare(`
+      ${GRANT_SELECT}
+      WHERE grant_row.id = ?
+    `).bind(input.grantId).first<GrantSqlRow>();
+    return row ? grantFromSql(row) : null;
+  }
+
   async recordConsentWithCode(
     input: Parameters<SiteAuthorizationRepository['recordConsentWithCode']>[0],
   ): Promise<SiteGrantView> {

src/server/repositories/site-authorization-repository.ts

@@ -33,6 +33,11 @@ export interface SiteGrantView {
   lastUsedAt: number | null;
   revokedAt: number | null;
   revokedReason: string | null;
+  /* Ajan erişimi bu iznin İÇİNDE yaşıyor: NULL ise kapalı, doluysa insanın
+   * ajanına o siteyi açtığı an. Ayrı tabloda olsaydı site bağlantısı
+   * kesildiğinde ayrıca temizlenmesi gerekirdi ve unutulan temizlik açık
+   * kalan kapıdır. */
+  agentAccessAt: number | null;
 }
 
 export interface SiteAuthorizationCodeView {
@@ -113,6 +118,15 @@ export interface SiteAuthorizationRepository {
 
   listAccountGrants(accountId: string): Promise<SiteGrantView[]>;
 
+  /* Ajan erişimini açar veya kapatır. Yalnız yürürlükteki bir izin üzerinde
+   * çalışır: iptal edilmiş bir siteye ajan erişimi açmak, kapalı bir kapının
+   * kilidini değiştirmek gibi anlamsız olurdu. */
+  setAgentAccess(input: {
+    grantId: string;
+    allowed: boolean;
+    now: number;
+  }): Promise<SiteGrantView | null>;
+
   /* Onay ekranının yazdığı yer: izin satırı (yeni ya da tazelenmiş) ve ona
    * bağlı tek kullanımlık kod aynı işlemde doğuyor. */
   recordConsentWithCode(input: {

tsconfig.json

@@ -1,6 +1,5 @@
 {
   "extends": "astro/tsconfigs/strict",
   "compilerOptions": {
-    "baseUrl": "."
   }
 }