diff --git a/docs/quality/uygulama-durumu.md b/docs/quality/uygulama-durumu.md index 88f6eb7..cb0bac4 100644 --- a/docs/quality/uygulama-durumu.md +++ b/docs/quality/uygulama-durumu.md @@ -623,3 +623,11 @@ Taslak bölümleri istenen başlıklara göre, kaynak sırasıyla birleştirilir Doğrulama: 50 bin karakteri aşan kaynakta tüm karakterlerin sağlayıcı yardımcı çağrılarına kayıpsız ulaşması, son koşulun birleşik bölümde korunması, ara parça hatasının görünürlüğü, iptalde sonraki grupların durması. Sağlayıcı yanıtları yerel test taklididir; gerçek uzun belge üretim kalitesi/tarayıcı kabulü değildir. Tüm 135 test ve üretim derlemesi geçti. Sınırlar: Bir parçanın işlenmesi tüm şartlarının anlam bakımından taslağa doğru aktarıldığını kanıtlamaz. İki dakikalık istemci sınırı ile kalıcı iş/sürdürme ihtiyacı açık; gerçek firma ve beş resmi dosya kabulü yapılmadı. Büyük paket uyarıları sürüyor; canlı yayın yok. + +### D09 — API anahtarı kotasının işlem bütünlüğü + +Önceki uç nokta anahtar sayısını okuyup kotayı kontrol ettikten sonra istek gövdesini bekliyordu; bekleyen eşzamanlı istekler aynı boş kapasiteyi kullanabilirdi. Sayım, kota denetimi ve INSERT artık BEGIN IMMEDIATE işlemi içinde; başarısızlık geri alınır. İptal edilmiş anahtarlar aktif kotaya katılmaz. Sunucudaki güncel plan limiti kayıt işlevine aktarılır. + +Bozuk JSON'un boş gövdeye çevrilip varsayılan anahtar oluşturması kaldırıldı. Anahtar adı metin ve en fazla 120 karakter olmalı; çevresindeki boşluklar temizlenir. GET/POST/DELETE dışındaki metotlar 405 döner. + +Doğrulama: yerel izole HTTP testinde eşzamanlı 16 oluşturma isteğinden tam 10 başarı, 6 kota reddi; bir anahtar iptal edilince yeni kayıt mümkün. Bozuk JSON/geçersiz ad kayıt oluşturmuyor. Gerçek SQLite testinde kota reddi sonrası işlem kapanıyor, iptal ve yeni kayıt çalışıyor. Tüm 137 test geçti; ön yüz değişmediğinden derleme tekrarlanmadı. Farklı sunucu süreçlerinden yük testi yapılmadı. Planın diğer kabul işleri ve canlı yayın açık. diff --git a/server/index.js b/server/index.js index 6befbf9..2f0ffd9 100644 --- a/server/index.js +++ b/server/index.js @@ -1174,10 +1174,8 @@ const server = http.createServer(async (req, res) => { if (req.method === 'POST') { try { - const mevcut = store.listApiKeys(user.email).length; - kotaKontrol(user.email, 'apiAnahtari', mevcut, 1, { isAdmin: user.isAdmin }); - const body = await readBody(req).catch(() => ({})); - const k = store.createApiKey(user.email, body.ad); + const body = await readBody(req); + const k = store.createApiKey(user.email, body.ad, { limit: haklar(user.email, { isAdmin: user.isAdmin }).apiAnahtari }); // `anahtar` YALNIZCA burada döner; sunucuda yalnızca hash'i saklanır return json(res, 200, { success: true, anahtar: k }); } catch (e) { @@ -1188,6 +1186,7 @@ const server = http.createServer(async (req, res) => { const ok = store.revokeApiKey(user.email, url.searchParams.get('id')); return json(res, ok ? 200 : 404, { success: ok, error: ok ? undefined : 'Anahtar bulunamadı veya bu hesaba ait değil.', anahtarlar: store.listApiKeys(user.email), limit: haklar(user.email, { isAdmin: user.isAdmin }).apiAnahtari }); } + if (req.method !== 'GET') return json(res, 405, { success: false, error: 'Desteklenmeyen metot.' }); return json(res, 200, { success: true, anahtarlar: store.listApiKeys(user.email), limit: haklar(user.email, { isAdmin: user.isAdmin }).apiAnahtari }); } diff --git a/server/user-store.mjs b/server/user-store.mjs index c555bcd..cf9f848 100644 --- a/server/user-store.mjs +++ b/server/user-store.mjs @@ -224,13 +224,28 @@ export function setData(email, anahtar, deger) { const sha256 = (s) => crypto.createHash('sha256').update(String(s)).digest('hex'); /** Yeni anahtar üretir. Ham değer YALNIZCA bir kez döner, saklanmaz. */ -export function createApiKey(email, ad) { - const ham = 'ih_live_' + crypto.randomBytes(24).toString('base64url'); - const id = crypto.randomUUID(); - withDb((db) => db.prepare( - 'INSERT INTO api_anahtarlari (id,email,ad,onek,hash,olusturma) VALUES (?,?,?,?,?,?)' - ).run(id, email, ad || 'API Anahtarı', ham.slice(0, 12), sha256(ham), now())); - return { id, ad: ad || 'API Anahtarı', onek: ham.slice(0, 12), anahtar: ham, olusturma: now() }; +export function createApiKey(email, ad, { limit = null } = {}) { + if (ad != null && typeof ad !== 'string') throw new Error('Anahtar adı metin olmalı.'); + const name = ad?.trim() || 'API Anahtarı'; + if (name.length > 120) throw new Error('Anahtar adı en fazla 120 karakter olabilir.'); + if (limit !== null && (!Number.isInteger(limit) || limit < 0)) throw new Error('Geçersiz anahtar kotası.'); + return withDb((db) => { + db.exec('BEGIN IMMEDIATE'); + try { + const count = db.prepare('SELECT COUNT(*) n FROM api_anahtarlari WHERE email=? AND iptal=0').get(email).n; + if (limit !== null && count >= limit) { + const error = new Error(`Planınızda en fazla ${limit} API anahtarı oluşturabilirsiniz. Kullanılmayan bir anahtarı iptal edin veya Planlar sekmesini kontrol edin.`); + error.kod = 'KOTA_ASILDI'; + throw error; + } + const ham = 'ih_live_' + crypto.randomBytes(24).toString('base64url'); + const id = crypto.randomUUID(), olusturma = now(); + db.prepare('INSERT INTO api_anahtarlari (id,email,ad,onek,hash,olusturma) VALUES (?,?,?,?,?,?)') + .run(id, email, name, ham.slice(0, 12), sha256(ham), olusturma); + db.exec('COMMIT'); + return { id, ad:name, onek:ham.slice(0,12), anahtar:ham, olusturma }; + } catch (error) { db.exec('ROLLBACK'); throw error; } + }); } export function listApiKeys(email) { diff --git a/tests/http-state.test.mjs b/tests/http-state.test.mjs index 407993a..97e1b85 100644 --- a/tests/http-state.test.mjs +++ b/tests/http-state.test.mjs @@ -155,3 +155,20 @@ test('HTTP API key creation, private listing, MCP use and revocation form a comp assert.deepEqual(revoked.data.anahtarlar,[]); assert.equal((await request('/mcp','POST',rpc,anahtar)).status,401); }); + +test('concurrent API key requests never exceed quota and malformed input creates nothing',async()=>{ + const auth=signToken({email:'quota-http@example.test',name:'Quota QA',isAdmin:true}); + const pending=Array.from({length:16},(_,i)=>request('/api/me/apikeys','POST',{ad:`QA ${i}`},auth)); + const results=await Promise.all(pending); + assert.equal(results.filter(r=>r.status===200).length,10); + assert.equal(results.filter(r=>r.status===402&&r.data.kod==='KOTA_ASILDI').length,6); + const keys=await request('/api/me/apikeys','GET',null,auth); + assert.equal(keys.data.anahtarlar.length,10); + await request('/api/me/apikeys?id='+keys.data.anahtarlar[0].id,'DELETE',null,auth); + const invalid=await fetch(base+'/api/me/apikeys',{method:'POST',headers:{Authorization:'Bearer '+auth,'Content-Type':'application/json'},body:'{broken'}); + assert.equal(invalid.status,400); + assert.equal((await request('/api/me/apikeys','POST',{ad:{}},auth)).status,400); + assert.equal((await request('/api/me/apikeys','GET',null,auth)).data.anahtarlar.length,9); + assert.equal((await request('/api/me/apikeys','POST',{ad:'replacement'},auth)).status,200); + assert.equal((await request('/api/me/apikeys','PUT',{},auth)).status,405); +}); diff --git a/tests/user-store.test.mjs b/tests/user-store.test.mjs index 5722351..41d4604 100644 --- a/tests/user-store.test.mjs +++ b/tests/user-store.test.mjs @@ -56,3 +56,16 @@ test('per-tender versions prevent stale updates; five tasks persist', () => { assert.equal(Object.keys(store.getTenderStates('c@example.test')).length,5); assert.deepEqual(store.getTenderStates('d@example.test'),{}); }); + +test('API key quota is transactional and revoked slots can be reused', () => { + const email='quota@example.test'; + const key=store.createApiKey(email,' ERP ',{limit:1}); + assert.equal(key.ad,'ERP'); + assert.throws(()=>store.createApiKey(email,'excess',{limit:1}), {kod:'KOTA_ASILDI'}); + assert.equal(store.listApiKeys(email).length,1); + assert.equal(store.revokeApiKey(email,key.id),true); + assert.ok(store.createApiKey(email,'replacement',{limit:1}).id); + assert.equal(store.listApiKeys(email).length,1); + for(const ad of [{},[],42,'x'.repeat(121)])assert.throws(()=>store.createApiKey('invalid-name@example.test',ad)); + assert.deepEqual(store.listApiKeys('invalid-name@example.test'),[]); +});