Compare commits
8
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1f13b86e5f | ||
|
|
7a479e46be | ||
|
|
db46a470ea | ||
|
|
21a8f3b8e9 | ||
|
|
fb62f31be3 | ||
|
|
1bf80e06a3 | ||
|
|
69e2f98e18 | ||
|
|
0d8c521a3c |
No files matched your search
@@ -5,6 +5,10 @@ on:
|
|||||||
branches: [aiturk/main, fix/ide-windows-vcruntime]
|
branches: [aiturk/main, fix/ide-windows-vcruntime]
|
||||||
workflow_dispatch:
|
workflow_dispatch:
|
||||||
|
|
||||||
|
concurrency:
|
||||||
|
group: ${{ github.workflow }}-${{ github.ref }}
|
||||||
|
cancel-in-progress: true
|
||||||
|
|
||||||
permissions:
|
permissions:
|
||||||
contents: read
|
contents: read
|
||||||
|
|
||||||
@@ -19,6 +23,16 @@ jobs:
|
|||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
with:
|
with:
|
||||||
github-server-url: https://gitea.turkservis.online
|
github-server-url: https://gitea.turkservis.online
|
||||||
|
- name: Require main and Windows release to share the exact source
|
||||||
|
run: |
|
||||||
|
set -eu
|
||||||
|
main_sha="$(git ls-remote origin refs/heads/aiturk/main | cut -f1)"
|
||||||
|
release_sha="$(git ls-remote origin refs/heads/fix/ide-windows-vcruntime | cut -f1)"
|
||||||
|
if [ "$main_sha" != "$GITHUB_SHA" ] || [ "$release_sha" != "$GITHUB_SHA" ]; then
|
||||||
|
echo "Both IDE branches must be updated together to the same merged commit."
|
||||||
|
echo "Use one atomic push; refusing to publish a divergent branch."
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
- name: Exact source and Linux test environment
|
- name: Exact source and Linux test environment
|
||||||
run: |
|
run: |
|
||||||
set -eu
|
set -eu
|
||||||
|
|||||||
@@ -27,6 +27,33 @@ Run: `python bridge.py --home <data dir> --hermes-home <agent home>`. The IDE wr
|
|||||||
|
|
||||||
Tests: `python -m unittest discover` in this directory.
|
Tests: `python -m unittest discover` in this directory.
|
||||||
|
|
||||||
|
## Version 24: portable model switches and summary coverage (IDE beta.45)
|
||||||
|
|
||||||
|
Cross-provider requests replace encrypted reasoning and every typed encrypted
|
||||||
|
peer-message part with a short visible omission note. Ciphertext is never
|
||||||
|
interpreted, guessed from its alphabet, or forwarded to another provider. Visible
|
||||||
|
messages, peer text, tool calls/results and their order remain intact. Projection
|
||||||
|
is idempotent and changes only the outgoing copy. Returning to a subscription
|
||||||
|
model retains its original encrypted execution state, including large histories.
|
||||||
|
Actual conversation compaction is still rendered through its issuing endpoint;
|
||||||
|
unreadable conversation summaries retain the existing explicit error.
|
||||||
|
|
||||||
|
Other external-provider switches reuse the same transcript, with destination
|
||||||
|
context preparation only when necessary. This follows the Hermes runtime model
|
||||||
|
switch contract: `agent/agent_runtime_helpers.py::switch_model` updates the client,
|
||||||
|
provider, cache policy and compressor without resetting conversation history;
|
||||||
|
`website/docs/user-guide/configuring-models.md` documents in-session `/model`.
|
||||||
|
Native voice routing is unchanged.
|
||||||
|
|
||||||
|
The compression target is a maximum, not a minimum length. All of the available
|
||||||
|
target budget is offered to the summarizer; compression level controls prose
|
||||||
|
density and no longer multiplies that budget down a second time. Numbered
|
||||||
|
decision identifiers, file references and numeric settings must survive the
|
||||||
|
summary before it is accepted or cached. An incomplete provider summary tries
|
||||||
|
the configured fallback; a deficient old checkpoint is ignored and rebuilt.
|
||||||
|
These literal checks detect concrete omissions; they do not prove semantic
|
||||||
|
equivalence of every sentence.
|
||||||
|
|
||||||
## Version 19: decision stages (14 October 2026)
|
## Version 19: decision stages (14 October 2026)
|
||||||
|
|
||||||
The decision model (Jev or another System One compatible service such as Celeris) can now be asked at
|
The decision model (Jev or another System One compatible service such as Celeris) can now be asked at
|
||||||
|
|||||||
@@ -35,7 +35,7 @@ import gecis_context
|
|||||||
import terminal_stream
|
import terminal_stream
|
||||||
|
|
||||||
HERE = os.path.dirname(os.path.abspath(__file__))
|
HERE = os.path.dirname(os.path.abspath(__file__))
|
||||||
SURUM = "22" # AITURK IDE'nin bekledigi kopru surumu (codex-link-config.ts CODEX_BRIDGE_VERSION)
|
SURUM = "24" # AITURK IDE'nin bekledigi kopru surumu (codex-link-config.ts CODEX_BRIDGE_VERSION)
|
||||||
try:
|
try:
|
||||||
with open(os.path.abspath(__file__), "rb") as _f:
|
with open(os.path.abspath(__file__), "rb") as _f:
|
||||||
KOD = hashlib.sha256(_f.read()).hexdigest()[:8]
|
KOD = hashlib.sha256(_f.read()).hexdigest()[:8]
|
||||||
@@ -521,16 +521,6 @@ class H(http.server.BaseHTTPRequestHandler):
|
|||||||
except Exception:
|
except Exception:
|
||||||
req = {}
|
req = {}
|
||||||
if external:
|
if external:
|
||||||
# Opaque peer tasks cannot be sent to another provider. Detect
|
|
||||||
# this permanent transfer error before committing SSE headers:
|
|
||||||
# stock Codex retries unknown response.failed stream errors.
|
|
||||||
# Projection validates a copy; the saved/request history stays
|
|
||||||
# intact and no task is dropped or sent to the worker.
|
|
||||||
try:
|
|
||||||
gecis_context.portable_reasoning(req)
|
|
||||||
except gecis_context.TransferError as e:
|
|
||||||
return self._json(400, {"error": {"type": "invalid_request_error",
|
|
||||||
"code": "aiturk_transfer_failed", "message": str(e), "retryable": False}})
|
|
||||||
self._failure_key = terminal_stream.request_key(req or {"raw": govde.hex()}, self.headers)
|
self._failure_key = terminal_stream.request_key(req or {"raw": govde.hex()}, self.headers)
|
||||||
previous_failure = self.server.failure_replays.take(self._failure_key)
|
previous_failure = self.server.failure_replays.take(self._failure_key)
|
||||||
if previous_failure:
|
if previous_failure:
|
||||||
@@ -547,6 +537,8 @@ class H(http.server.BaseHTTPRequestHandler):
|
|||||||
if external or mixed or gecis_context.foreign(req):
|
if external or mixed or gecis_context.foreign(req):
|
||||||
try:
|
try:
|
||||||
normalized = gecis_context.normalize(req)
|
normalized = gecis_context.normalize(req)
|
||||||
|
if external:
|
||||||
|
normalized = gecis_context.portable_reasoning(normalized)
|
||||||
except gecis_context.TransferError as e:
|
except gecis_context.TransferError as e:
|
||||||
self._transfer_begin()
|
self._transfer_begin()
|
||||||
return self._transfer_fail(str(e))
|
return self._transfer_fail(str(e))
|
||||||
|
|||||||
@@ -142,6 +142,7 @@ def call(handler, module, slug, source, budget, settings, deadline, depth=0):
|
|||||||
text = ozet_kopru.sse_metni(bytes(raw))
|
text = ozet_kopru.sse_metni(bytes(raw))
|
||||||
if not text or len(text.strip()) < 80:
|
if not text or len(text.strip()) < 80:
|
||||||
raise gc.TransferError('Sıkıştırıcı tamamlanmış bir özet döndürmedi')
|
raise gc.TransferError('Sıkıştırıcı tamamlanmış bir özet döndürmedi')
|
||||||
|
gc.require_summary_coverage(chunk, text)
|
||||||
results.append(text)
|
results.append(text)
|
||||||
combined = '\n\n'.join(results)
|
combined = '\n\n'.join(results)
|
||||||
if not combined:
|
if not combined:
|
||||||
@@ -211,6 +212,8 @@ def prepare(handler, module, payload, checkpoints):
|
|||||||
protected, old, recent = gc.split_history(req.get('input') or [], settings['keepTurns'])
|
protected, old, recent = gc.split_history(req.get('input') or [], settings['keepTurns'])
|
||||||
checkpoints.begin(scope, old, settings)
|
checkpoints.begin(scope, old, settings)
|
||||||
saved = checkpoints.get(scope, old, settings) if old else None
|
saved = checkpoints.get(scope, old, settings) if old else None
|
||||||
|
if saved and gc.summary_missing(old[:saved[0]], saved[1]):
|
||||||
|
saved = None
|
||||||
effective = dict(req, input=protected + [ozet_kopru._ozet_mesaji(saved[1])] + old[saved[0]:] + recent) if saved else req
|
effective = dict(req, input=protected + [ozet_kopru._ozet_mesaji(saved[1])] + old[saved[0]:] + recent) if saved else req
|
||||||
if not compact and gc.tokens(effective) <= trigger:
|
if not compact and gc.tokens(effective) <= trigger:
|
||||||
return {'request': effective, 'window': window}
|
return {'request': effective, 'window': window}
|
||||||
|
|||||||
@@ -12,11 +12,52 @@ import threading
|
|||||||
from collections import OrderedDict
|
from collections import OrderedDict
|
||||||
|
|
||||||
import ozet_kopru
|
import ozet_kopru
|
||||||
import compression_settings
|
|
||||||
|
|
||||||
PREFIXES = {"custom_tool_call": "ctc", "custom_tool_call_output": "ctco",
|
PREFIXES = {"custom_tool_call": "ctc", "custom_tool_call_output": "ctco",
|
||||||
"function_call": "fc", "function_call_output": "fco"}
|
"function_call": "fc", "function_call_output": "fco"}
|
||||||
RATIO = 0.70
|
RATIO = 0.70
|
||||||
|
PEER_OMITTED = "[Aktarım notu: Burada okunamayan şifreli bir alt ajan iletisi vardı; aktarılmadı.]"
|
||||||
|
REASONING_OMITTED = "[Aktarım notu: Şifreli model düşünme kaydı aktarılmadı.]"
|
||||||
|
|
||||||
|
|
||||||
|
def summary_missing(source, summary):
|
||||||
|
"""Check literal decisions, file paths and numeric settings, never secrets.
|
||||||
|
|
||||||
|
This is a loss detector for concrete references, not a semantic proof of
|
||||||
|
every sentence. Missing references must not enter a durable checkpoint.
|
||||||
|
"""
|
||||||
|
if isinstance(source, str):
|
||||||
|
try:
|
||||||
|
source = json.loads(source)
|
||||||
|
except ValueError:
|
||||||
|
pass
|
||||||
|
def strings(value):
|
||||||
|
if isinstance(value, str):
|
||||||
|
yield value
|
||||||
|
elif isinstance(value, dict):
|
||||||
|
for child in value.values():
|
||||||
|
yield from strings(child)
|
||||||
|
elif isinstance(value, list):
|
||||||
|
for child in value:
|
||||||
|
yield from strings(child)
|
||||||
|
text = '\n'.join(strings(source)).replace('\\', '/')
|
||||||
|
target = summary.replace('\\', '/').replace('`', '')
|
||||||
|
identifiers = set(re.findall(r'\b[A-Z][A-Z0-9]{0,23}(?:-[A-Z][A-Z0-9]{0,23}){0,3}-\d[A-Za-z0-9_-]{0,63}\b', text))
|
||||||
|
identifiers = {x for x in identifiers if not re.match(r'(?:SECRET|TOKEN|APIKEY|PASSWORD|OTP)-', x)}
|
||||||
|
paths = set(re.findall(r'(?<![A-Za-z0-9_.-])(?:[A-Za-z]:/(?:[A-Za-z0-9_.-]{1,160}/){0,24}|(?:[A-Za-z0-9_.-]{1,160}/){1,24})[A-Za-z0-9_.-]{1,160}\.(?:json|py|tsx?|jsx?|md|txt|ya?ml|toml|ini|sql|csv|log)\b', text)) if '/' in text else set()
|
||||||
|
assignments = set(re.findall(r'\b([A-Za-z_][A-Za-z0-9_]{0,63})\s*=\s*(\d{1,16}|true|false)\b', text))
|
||||||
|
assignments = {(key, value) for key, value in assignments
|
||||||
|
if not re.search(r'key|token|secret|password|sifre|anahtar|otp', key, re.I)}
|
||||||
|
missing = sum(value not in target for value in identifiers | paths)
|
||||||
|
missing += sum(not re.search(re.escape(key) + r'\s*[=:]\s*' + re.escape(value) + r'\b', target)
|
||||||
|
for key, value in assignments)
|
||||||
|
return missing
|
||||||
|
|
||||||
|
|
||||||
|
def require_summary_coverage(source, summary):
|
||||||
|
missing = summary_missing(source, summary)
|
||||||
|
if missing:
|
||||||
|
raise TransferError(f'Özet {missing} karar, dosya yolu veya sayısal ayarı korumadı; eksik özet kabul edilmedi.')
|
||||||
|
|
||||||
|
|
||||||
class TransferError(ValueError):
|
class TransferError(ValueError):
|
||||||
@@ -56,11 +97,16 @@ def foreign(req):
|
|||||||
|
|
||||||
def native_opaque(req):
|
def native_opaque(req):
|
||||||
"""Native encrypted state belongs to the subscription, even in mixed history."""
|
"""Native encrypted state belongs to the subscription, even in mixed history."""
|
||||||
return any(isinstance(item, dict) and item.get("type") == "compaction" and item.get("encrypted_content")
|
return any(isinstance(item, dict) and (
|
||||||
and not str(item["encrypted_content"]).startswith(ozet_kopru.ISARET)
|
(item.get("type") in ("compaction", "reasoning") and item.get("encrypted_content")
|
||||||
|
and not str(item["encrypted_content"]).startswith(ozet_kopru.ISARET))
|
||||||
|
or (item.get("type") == "agent_message" and any(
|
||||||
|
isinstance(part, dict) and part.get("type") == "encrypted_content"
|
||||||
|
for part in item.get("content") or [])))
|
||||||
for item in req.get("input") or [])
|
for item in req.get("input") or [])
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def foreign_history(req):
|
def foreign_history(req):
|
||||||
"""Semantic migration evidence, excluding tool ID format mismatches."""
|
"""Semantic migration evidence, excluding tool ID format mismatches."""
|
||||||
return any(isinstance(item, dict) and (
|
return any(isinstance(item, dict) and (
|
||||||
@@ -135,14 +181,10 @@ def portable_reasoning(req):
|
|||||||
portable = []
|
portable = []
|
||||||
for part in content:
|
for part in content:
|
||||||
if isinstance(part, dict) and part.get("type") == "encrypted_content":
|
if isinstance(part, dict) and part.get("type") == "encrypted_content":
|
||||||
# Codex peer delivery can put the literal task/result in
|
# Treat the typed wrapper as opaque regardless of whether
|
||||||
# this wrapper. It is distinct from encrypted reasoning.
|
# its bytes happen to look like plaintext. Never decrypt,
|
||||||
# External translators otherwise silently drop the task.
|
# guess, or forward it to a different provider.
|
||||||
text = part.get("encrypted_content")
|
portable.append({"type": "input_text", "text": PEER_OMITTED})
|
||||||
if (not isinstance(text, str) or text.startswith("gAAAA")
|
|
||||||
or re.fullmatch(r"[A-Za-z0-9_+/=-]{128,}", text)):
|
|
||||||
raise TransferError("Alt ajan iletisi şifreli veya okunamıyor; görev eksik gönderilmedi.")
|
|
||||||
portable.append({"type": "input_text", "text": text})
|
|
||||||
else:
|
else:
|
||||||
portable.append(part)
|
portable.append(part)
|
||||||
result.append({"type": "message", "role": "user", "content": [
|
result.append({"type": "message", "role": "user", "content": [
|
||||||
@@ -158,6 +200,8 @@ def portable_reasoning(req):
|
|||||||
for part in item.get(field) or []:
|
for part in item.get(field) or []:
|
||||||
if isinstance(part, dict) and isinstance(part.get("text"), str) and part["text"]:
|
if isinstance(part, dict) and isinstance(part.get("text"), str) and part["text"]:
|
||||||
visible.append(part["text"])
|
visible.append(part["text"])
|
||||||
|
if item.get("encrypted_content"):
|
||||||
|
visible.append(REASONING_OMITTED)
|
||||||
if visible:
|
if visible:
|
||||||
# Keep this on the assistant side: a synthetic user message would
|
# Keep this on the assistant side: a synthetic user message would
|
||||||
# change split_history's count of protected user turns.
|
# change split_history's count of protected user turns.
|
||||||
@@ -214,6 +258,8 @@ class Preparer:
|
|||||||
protected, old, recent = split_history(req.get("input") or [], keep)
|
protected, old, recent = split_history(req.get("input") or [], keep)
|
||||||
original_old = old
|
original_old = old
|
||||||
saved = checkpoints.get(scope, old, settings) if checkpoints and old else None
|
saved = checkpoints.get(scope, old, settings) if checkpoints and old else None
|
||||||
|
if saved and summary_missing(old[:saved[0]], saved[1]):
|
||||||
|
saved = None
|
||||||
if saved:
|
if saved:
|
||||||
old = [ozet_kopru._ozet_mesaji(saved[1])] + old[saved[0]:]
|
old = [ozet_kopru._ozet_mesaji(saved[1])] + old[saved[0]:]
|
||||||
req = dict(req, input=protected + old + recent)
|
req = dict(req, input=protected + old + recent)
|
||||||
@@ -233,8 +279,10 @@ class Preparer:
|
|||||||
if any(isinstance(x, dict) and x.get("encrypted_content") for x in old):
|
if any(isinstance(x, dict) and x.get("encrypted_content") for x in old):
|
||||||
raise TransferError("Şifreli geçmiş önce sahibi tarafından okunabilir özete çevrilmeli.")
|
raise TransferError("Şifreli geçmiş önce sahibi tarafından okunabilir özete çevrilmeli.")
|
||||||
source = encoded(old)
|
source = encoded(old)
|
||||||
factor = compression_settings.LEVELS[settings['level']] if settings else .5
|
# The configured target already bounds the resulting context. Applying
|
||||||
budget = max(512, int(available * factor))
|
# the level's ratio again denied the summarizer most of that budget.
|
||||||
|
# Level controls writing style; the whole available budget stays usable.
|
||||||
|
budget = max(512, available)
|
||||||
key = hashlib.sha256((scope + str(budget) + encoded(settings) + source).encode()).hexdigest()
|
key = hashlib.sha256((scope + str(budget) + encoded(settings) + source).encode()).hexdigest()
|
||||||
with self.lock:
|
with self.lock:
|
||||||
summary = self.cache.get(key)
|
summary = self.cache.get(key)
|
||||||
@@ -242,6 +290,7 @@ class Preparer:
|
|||||||
summary = summarize(source, budget)
|
summary = summarize(source, budget)
|
||||||
if not isinstance(summary, str) or len(summary.strip()) < 80:
|
if not isinstance(summary, str) or len(summary.strip()) < 80:
|
||||||
raise TransferError("AITURK özeti tamamlanamadı; eski geçmiş korundu.")
|
raise TransferError("AITURK özeti tamamlanamadı; eski geçmiş korundu.")
|
||||||
|
require_summary_coverage(old, summary)
|
||||||
candidate = dict(req, input=protected + [ozet_kopru._ozet_mesaji(summary)] + recent)
|
candidate = dict(req, input=protected + [ozet_kopru._ozet_mesaji(summary)] + recent)
|
||||||
if tokens(candidate) > limit:
|
if tokens(candidate) > limit:
|
||||||
raise TransferError("Hazırlanan özet hedef bütçesine sığmadı; eski geçmiş korundu.")
|
raise TransferError("Hazırlanan özet hedef bütçesine sığmadı; eski geçmiş korundu.")
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ class AgentPayloadTests(unittest.TestCase):
|
|||||||
],
|
],
|
||||||
}]}
|
}]}
|
||||||
|
|
||||||
def test_actual_peer_wrapper_survives_external_text_extraction(self):
|
def test_typed_encrypted_wrapper_is_omitted_even_if_bytes_look_like_text(self):
|
||||||
task = "Run exec_command: Write-Output (157 * 29); report the exit code."
|
task = "Run exec_command: Write-Output (157 * 29); report the exit code."
|
||||||
request = self.request(task)
|
request = self.request(task)
|
||||||
original = copy.deepcopy(request)
|
original = copy.deepcopy(request)
|
||||||
@@ -26,7 +26,8 @@ class AgentPayloadTests(unittest.TestCase):
|
|||||||
# encrypted_content part. Checking the JSON string alone misses loss.
|
# encrypted_content part. Checking the JSON string alone misses loss.
|
||||||
text = "\n".join(part["text"] for item in request["input"]
|
text = "\n".join(part["text"] for item in request["input"]
|
||||||
for part in item["content"] if part["type"] == "input_text")
|
for part in item["content"] if part["type"] == "input_text")
|
||||||
self.assertIn(task, text)
|
self.assertNotIn(task, text)
|
||||||
|
self.assertIn(gecis_context.PEER_OMITTED, text)
|
||||||
self.assertIn('/root/test', text)
|
self.assertIn('/root/test', text)
|
||||||
self.assertEqual(request["input"][0]["role"], "user")
|
self.assertEqual(request["input"][0]["role"], "user")
|
||||||
self.assertEqual(original["input"][0]["content"][1]["type"], "encrypted_content")
|
self.assertEqual(original["input"][0]["content"][1]["type"], "encrypted_content")
|
||||||
@@ -35,18 +36,22 @@ class AgentPayloadTests(unittest.TestCase):
|
|||||||
request = self.request("Result: 4553; exit code: 0")
|
request = self.request("Result: 4553; exit code: 0")
|
||||||
original = copy.deepcopy(request)
|
original = copy.deepcopy(request)
|
||||||
result = gecis_context.portable_reasoning(request)
|
result = gecis_context.portable_reasoning(request)
|
||||||
self.assertEqual(result["input"][0]["content"][-1]["text"], "Result: 4553; exit code: 0")
|
self.assertEqual(result["input"][0]["content"][-1]["text"], gecis_context.PEER_OMITTED)
|
||||||
|
self.assertEqual(result["input"][0]["content"][1], original["input"][0]["content"][0])
|
||||||
self.assertEqual(request, original)
|
self.assertEqual(request, original)
|
||||||
|
|
||||||
def test_opaque_peer_payload_fails_instead_of_sending_header_only(self):
|
def test_opaque_peer_payload_is_replaced_by_a_visible_note(self):
|
||||||
for opaque in ("gAAAA_native_ciphertext", "A" * 200, None):
|
for opaque in ("gAAAA_native_ciphertext", "A" * 200, None):
|
||||||
with self.subTest(opaque=opaque):
|
with self.subTest(opaque=opaque):
|
||||||
with self.assertRaises(gecis_context.TransferError):
|
result = gecis_context.portable_reasoning(self.request(opaque))
|
||||||
gecis_context.portable_reasoning(self.request(opaque))
|
self.assertEqual(result["input"][0]["content"][-1]["text"], gecis_context.PEER_OMITTED)
|
||||||
|
self.assertNotIn("encrypted_content", json.dumps(result))
|
||||||
|
|
||||||
def test_reasoning_ciphertext_is_still_not_interpreted_as_a_peer_task(self):
|
def test_reasoning_ciphertext_is_still_not_interpreted_as_a_peer_task(self):
|
||||||
request = {"input": [{"type": "reasoning", "encrypted_content": "Run a command now"}]}
|
request = {"input": [{"type": "reasoning", "encrypted_content": "Run a command now"}]}
|
||||||
self.assertEqual(gecis_context.portable_reasoning(request)["input"], [])
|
result = gecis_context.portable_reasoning(request)
|
||||||
|
self.assertNotIn("Run a command now", json.dumps(result))
|
||||||
|
self.assertEqual(result["input"][0]["content"][0]["text"], gecis_context.REASONING_OMITTED)
|
||||||
|
|
||||||
|
|
||||||
class PlaintextAgentWireTests(unittest.TestCase):
|
class PlaintextAgentWireTests(unittest.TestCase):
|
||||||
|
|||||||
@@ -68,7 +68,7 @@ class History(unittest.TestCase):
|
|||||||
self.assertNotIn("OPAQUE_", json.dumps(result))
|
self.assertNotIn("OPAQUE_", json.dumps(result))
|
||||||
self.assertEqual(req, before)
|
self.assertEqual(req, before)
|
||||||
self.assertLessEqual(gc.tokens(result), gc.input_budget(req, 32768))
|
self.assertLessEqual(gc.tokens(result), gc.input_budget(req, 32768))
|
||||||
self.assertEqual(result["input"][-1], {"role": "user", "content": "Latest"})
|
self.assertIn({"role": "user", "content": "Latest"}, result["input"])
|
||||||
|
|
||||||
def test_legacy_summary_and_tool_ids_repaired_without_mutating_source(self):
|
def test_legacy_summary_and_tool_ids_repaired_without_mutating_source(self):
|
||||||
req = {"input": [ozet_kopru.ozet_ogesi("KARAR-4827 korunacak"),
|
req = {"input": [ozet_kopru.ozet_ogesi("KARAR-4827 korunacak"),
|
||||||
@@ -259,19 +259,18 @@ class PreparationService(unittest.TestCase):
|
|||||||
self.assertNotIn("OPAQUE_REASONING", json.dumps(result))
|
self.assertNotIn("OPAQUE_REASONING", json.dumps(result))
|
||||||
self.assertEqual(req, before)
|
self.assertEqual(req, before)
|
||||||
|
|
||||||
def test_large_native_return_summarizes_visible_history_without_ciphertext(self):
|
def test_large_native_return_keeps_original_encrypted_execution_state(self):
|
||||||
|
for opaque in ({"type": "reasoning", "encrypted_content": "OPAQUE_NATIVE"},
|
||||||
|
{"type": "agent_message", "content": [
|
||||||
|
{"type": "encrypted_content", "encrypted_content": "OPAQUE_PEER"}]}):
|
||||||
req = {"model": "gpt-6-astra", "input": [
|
req = {"model": "gpt-6-astra", "input": [
|
||||||
{"role": "user", "content": "KARAR-4827 " + "x" * 190000},
|
{"role": "user", "content": "KARAR-4827 " + "x" * 190000},
|
||||||
{"type": "reasoning", "encrypted_content": "OPAQUE_NATIVE"},
|
opaque, {"role": "user", "content": "Latest"}]}
|
||||||
{"role": "user", "content": "Latest"}]}
|
|
||||||
before = copy.deepcopy(req)
|
before = copy.deepcopy(req)
|
||||||
result = self.service._prepare_transfer({"request": req, "source_model": "ide/test"})["request"]
|
result = self.service._prepare_transfer({"request": req, "source_model": "ide/test"})["request"]
|
||||||
self.assertEqual(result["model"], "gpt-6-astra")
|
self.assertEqual(result, before)
|
||||||
self.assertIn("KARAR-4827", json.dumps(result))
|
|
||||||
self.assertLessEqual(gc.tokens(result), gc.input_budget(req, 128000))
|
|
||||||
self.assertEqual(req, before)
|
self.assertEqual(req, before)
|
||||||
self.assertTrue(self.server.gelen)
|
self.assertEqual(self.server.gelen, [])
|
||||||
self.assertTrue(all(b"OPAQUE_NATIVE" not in call["govde"] for call in self.server.gelen))
|
|
||||||
|
|
||||||
def test_external_compaction_uses_external_summary_not_subscription(self):
|
def test_external_compaction_uses_external_summary_not_subscription(self):
|
||||||
req = {"model": "ide/test", "input": [{"role": "assistant", "content": "KARAR-4827"}, {"role": "user", "content": "KARAR-4827"}, {"type": "compaction_trigger"}]}
|
req = {"model": "ide/test", "input": [{"role": "assistant", "content": "KARAR-4827"}, {"role": "user", "content": "KARAR-4827"}, {"type": "compaction_trigger"}]}
|
||||||
@@ -281,30 +280,38 @@ class PreparationService(unittest.TestCase):
|
|||||||
|
|
||||||
|
|
||||||
class SocketMigration(fixtures.Ayirici):
|
class SocketMigration(fixtures.Ayirici):
|
||||||
def test_opaque_peer_transfer_fails_as_http_400_before_sse_or_upstream(self):
|
def test_opaque_peer_transfer_succeeds_without_ciphertext_or_transfer_error(self):
|
||||||
req = {"model": "ide/agy-gemini-3.8-flash-high", "prompt_cache_key": "opaque-peer",
|
req = {"model": "ide/agy-gemini-3.8-flash-high", "prompt_cache_key": "opaque-peer",
|
||||||
"input": [{"type": "agent_message", "author": "/root", "recipient": "/root/peer",
|
"input": [{"role": "user", "content": "USER_DECISION"},
|
||||||
"content": [{"type": "input_text", "text": "Message Type: NEW_TASK\nPayload:\n"},
|
{"type": "agent_message", "author": "/root", "recipient": "/root/peer",
|
||||||
{"type": "encrypted_content", "encrypted_content": "gAAAA_synthetic_opaque"}]}]}
|
"content": [{"type": "input_text", "text": "VISIBLE_PEER_HEADER"},
|
||||||
|
{"type": "encrypted_content", "encrypted_content": "gAAAA_synthetic_opaque"}]},
|
||||||
|
{"role": "assistant", "content": "VISIBLE_ANSWER"},
|
||||||
|
{"type": "function_call", "id": "fc_1", "call_id": "c1", "name": "read", "arguments": "{}"},
|
||||||
|
{"type": "function_call_output", "id": "fco_1", "call_id": "c1", "output": "VISIBLE_RESULT"}]}
|
||||||
original = copy.deepcopy(req)
|
original = copy.deepcopy(req)
|
||||||
raw = json.dumps(req).encode()
|
for model in (req["model"], "ide/another-provider"):
|
||||||
# Identical retries must receive the same permanent error without a
|
req["model"] = model
|
||||||
# preparation request, a stream heartbeat, or provider inference.
|
status, body, _ = self.iste("POST", "/backend-api/codex/responses", json.dumps(req).encode())
|
||||||
for _ in range(2):
|
self.assertEqual(status, 200)
|
||||||
status, body, headers = self.iste("POST", "/backend-api/codex/responses", raw)
|
self.assertNotIn(b"aiturk_transfer_failed", body)
|
||||||
self.assertEqual(status, 400)
|
sent = json.loads(self.kopru.gelen[-1]["govde"])
|
||||||
self.assertEqual(headers["Content-Type"].split(";")[0], "application/json")
|
wire = json.dumps(sent, ensure_ascii=False)
|
||||||
self.assertNotIn("Transfer-Encoding", headers)
|
self.assertNotIn("gAAAA_synthetic_opaque", wire)
|
||||||
error = json.loads(body)["error"]
|
self.assertNotIn("encrypted_content", wire)
|
||||||
self.assertEqual(error["code"], "aiturk_transfer_failed")
|
self.assertIn(gc.PEER_OMITTED, wire)
|
||||||
self.assertEqual(error["type"], "invalid_request_error")
|
self.assertIn("VISIBLE_PEER_HEADER", wire)
|
||||||
self.assertFalse(error["retryable"])
|
for item in original["input"][:1] + original["input"][2:]:
|
||||||
self.assertIn("görev eksik gönderilmedi", error["message"])
|
self.assertIn(item, sent["input"])
|
||||||
self.assertNotIn(b"response.failed", body)
|
self.assertEqual(req["input"], original["input"])
|
||||||
self.assertEqual(req, original)
|
|
||||||
self.assertEqual(self.ozgun.gelen, [])
|
self.assertEqual(self.ozgun.gelen, [])
|
||||||
self.assertEqual(self.kopru.gelen, [])
|
# Returning uses the client's original transcript, including opaque peer
|
||||||
self.assertEqual(bridge.TRANSFERS, {})
|
# state. Projection never rewrites the persisted source or a native turn.
|
||||||
|
req["model"] = "gpt-6-astra"
|
||||||
|
raw = zstd(json.dumps(req).encode())
|
||||||
|
status, _, _ = self.iste("POST", "/backend-api/codex/responses", raw, {"Content-Encoding": "zstd"})
|
||||||
|
self.assertEqual(status, 200)
|
||||||
|
self.assertEqual(self.ozgun.gelen[-1]["govde"], raw)
|
||||||
|
|
||||||
def test_native_opaque_peer_history_remains_byte_identical_on_owner_route(self):
|
def test_native_opaque_peer_history_remains_byte_identical_on_owner_route(self):
|
||||||
req = {"model": "gpt-6-astra", "input": [{"type": "agent_message", "author": "/root",
|
req = {"model": "gpt-6-astra", "input": [{"type": "agent_message", "author": "/root",
|
||||||
|
|||||||
@@ -0,0 +1,64 @@
|
|||||||
|
import copy
|
||||||
|
import tempfile
|
||||||
|
import unittest
|
||||||
|
|
||||||
|
import compression_settings as cs
|
||||||
|
import gecis_context as gc
|
||||||
|
|
||||||
|
|
||||||
|
class SummaryCoverage(unittest.TestCase):
|
||||||
|
def test_long_noise_is_not_misclassified_as_one_giant_identifier(self):
|
||||||
|
gc.require_summary_coverage('A' * 60000 + 'KARAR-4827' + 'B' * 60000,
|
||||||
|
'KARAR-4827: original decision preserved.')
|
||||||
|
|
||||||
|
def test_partial_decision_ledger_is_rejected_and_full_ledger_is_accepted(self):
|
||||||
|
records = [f'DEC-{i:04d}: src/feature_{i:04d}/config.json limit_{i:04d}={30000+i} TEST-QA-{i:04d} NO-DELETE-{i:04d}'
|
||||||
|
for i in range(200)]
|
||||||
|
source = [{'role': 'user', 'content': '\n'.join(records)}]
|
||||||
|
with self.assertRaises(gc.TransferError):
|
||||||
|
gc.require_summary_coverage(source, '\n'.join(records[:95]))
|
||||||
|
gc.require_summary_coverage(source, '\n'.join(records))
|
||||||
|
|
||||||
|
def test_assignment_values_stay_associated_with_their_keys(self):
|
||||||
|
source = [{'content': 'limit_a=123 limit_b=456 src/a.py DEC-1'}]
|
||||||
|
self.assertGreater(gc.summary_missing(source, 'limit_a=456 limit_b=123 src/a.py DEC-1'), 0)
|
||||||
|
gc.require_summary_coverage(source, 'DEC-1: `src/a.py`; limit_a: 123; limit_b: 456')
|
||||||
|
|
||||||
|
def test_secret_named_assignments_are_not_required_in_a_summary(self):
|
||||||
|
gc.require_summary_coverage([{'content': 'api_key=123456 password=7890 otp=1234'}], 'Secrets omitted.')
|
||||||
|
|
||||||
|
def test_target_budget_is_not_multiplied_by_compression_level_again(self):
|
||||||
|
settings = dict(cs.DEFAULTS, keepTurns=1, triggerPercent=60, targetPercent=25, level='fazla')
|
||||||
|
req = {'input': [{'role': 'user', 'content': 'DEC-1 ' + 'x' * 60000},
|
||||||
|
{'role': 'user', 'content': 'Keep this recent turn.'}]}
|
||||||
|
observed = []
|
||||||
|
def summarize(source, budget):
|
||||||
|
observed.append(budget)
|
||||||
|
return 'DEC-1: All accepted decisions, paths, settings and outstanding work are retained. ' * 2
|
||||||
|
prepared = gc.Preparer().prepare(req, 32768, summarize, settings=settings, automatic=True)
|
||||||
|
protected, _, recent = gc.split_history(req['input'], 1)
|
||||||
|
available = gc.input_budget(req, 32768, settings, True) - gc.tokens(dict(req, input=protected + recent)) - 256
|
||||||
|
self.assertEqual(observed, [available])
|
||||||
|
self.assertLessEqual(gc.tokens(prepared), 32768 * .25)
|
||||||
|
|
||||||
|
def test_incomplete_old_checkpoint_is_rebuilt_without_overwriting_source(self):
|
||||||
|
settings = dict(cs.DEFAULTS, keepTurns=1)
|
||||||
|
req = {'input': [{'role': 'user', 'content': 'DEC-1 src/a.py limit_a=123 ' + 'x' * 60000},
|
||||||
|
{'role': 'user', 'content': 'Latest'}]}
|
||||||
|
original = copy.deepcopy(req)
|
||||||
|
with tempfile.TemporaryDirectory() as home:
|
||||||
|
store = cs.Checkpoints(home)
|
||||||
|
old = gc.split_history(req['input'], 1)[1]
|
||||||
|
store.save('scope', old, settings, 'Incomplete old summary without the required details. ' * 3)
|
||||||
|
calls = []
|
||||||
|
def summarize(source, budget):
|
||||||
|
calls.append(1)
|
||||||
|
return 'DEC-1 src/a.py limit_a=123. Accepted decision and all relevant constraints retained. ' * 2
|
||||||
|
result = gc.Preparer().prepare(req, 32768, summarize, 'scope', settings=settings, checkpoints=store)
|
||||||
|
self.assertEqual(calls, [1])
|
||||||
|
self.assertEqual(req, original)
|
||||||
|
gc.require_summary_coverage(old, gc.encoded(result))
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
unittest.main()
|
||||||
@@ -27,7 +27,7 @@ export const CODEX_LINK_REFRESH_URL = `${CODEX_LINK_ORIGIN}/aiturk/codex-baglama
|
|||||||
export const CODEX_LINK_MARKER = '# AITURK IDE Codex Baglama'
|
export const CODEX_LINK_MARKER = '# AITURK IDE Codex Baglama'
|
||||||
// Must equal SURUM in assets/codex-bridge/bridge.py; a running bridge that reports
|
// Must equal SURUM in assets/codex-bridge/bridge.py; a running bridge that reports
|
||||||
// another version is restarted so an updated IDE never keeps an old bridge alive.
|
// another version is restarted so an updated IDE never keeps an old bridge alive.
|
||||||
export const CODEX_BRIDGE_VERSION = '22'
|
export const CODEX_BRIDGE_VERSION = '24'
|
||||||
export const CODEX_LINK_LINE = `openai_base_url = "${CODEX_LINK_ORIGIN}/backend-api/codex" ${CODEX_LINK_MARKER}`
|
export const CODEX_LINK_LINE = `openai_base_url = "${CODEX_LINK_ORIGIN}/backend-api/codex" ${CODEX_LINK_MARKER}`
|
||||||
|
|
||||||
export const CODEX_LINK_RUN_KEY = 'HKCU\\Software\\Microsoft\\Windows\\CurrentVersion\\Run'
|
export const CODEX_LINK_RUN_KEY = 'HKCU\\Software\\Microsoft\\Windows\\CurrentVersion\\Run'
|
||||||
|
|||||||
@@ -2,7 +2,7 @@
|
|||||||
"name": "aiturk-ide",
|
"name": "aiturk-ide",
|
||||||
"productName": "AITURK IDE",
|
"productName": "AITURK IDE",
|
||||||
"private": true,
|
"private": true,
|
||||||
"version": "1.0.0-beta.44",
|
"version": "1.0.0-beta.45",
|
||||||
"description": "TurkServis resmi yapay zekâ geliştirme ortamı. Hermes Agent tabanlıdır.",
|
"description": "TurkServis resmi yapay zekâ geliştirme ortamı. Hermes Agent tabanlıdır.",
|
||||||
"author": "AITURK / TurkServis",
|
"author": "AITURK / TurkServis",
|
||||||
"repository": {
|
"repository": {
|
||||||
|
|||||||
@@ -63,7 +63,8 @@ export function CompressionSettingsView() {
|
|||||||
{draft.budgetMode === 'percent' ? numeric('transferPercent', t('Hedef model bağlamı (%)', 'Target model context (%)'), 10, 90) : numeric('maxTokens', t('Maksimum giriş tokenı', 'Maximum input tokens'), 1024, 2000000)}
|
{draft.budgetMode === 'percent' ? numeric('transferPercent', t('Hedef model bağlamı (%)', 'Target model context (%)'), 10, 90) : numeric('maxTokens', t('Maksimum giriş tokenı', 'Maximum input tokens'), 1024, 2000000)}
|
||||||
<ListRow title={t('Otomatik sıkıştırma', 'Automatic compression')} action={<Switch aria-label={t('Otomatik sıkıştırma', 'Automatic compression')} disabled={busy} checked={draft.autoEnabled} onCheckedChange={v => change('autoEnabled', v)} />} />
|
<ListRow title={t('Otomatik sıkıştırma', 'Automatic compression')} action={<Switch aria-label={t('Otomatik sıkıştırma', 'Automatic compression')} disabled={busy} checked={draft.autoEnabled} onCheckedChange={v => change('autoEnabled', v)} />} />
|
||||||
{numeric('triggerPercent', t('Başlama eşiği (%)', 'Trigger threshold (%)'), 20, 90)}
|
{numeric('triggerPercent', t('Başlama eşiği (%)', 'Trigger threshold (%)'), 20, 90)}
|
||||||
{numeric('targetPercent', t('Sıkıştırma sonrası hedef (%)', 'Target after compression (%)'), 10, 80)}
|
{numeric('targetPercent', t('Sıkıştırma sonrası üst sınır (%)', 'Maximum after compression (%)'), 10, 80)}
|
||||||
|
<p className="text-sm text-(--ui-text-secondary)">{t('Bu bir üst sınırdır; tekrarlar azaldığında özet daha küçük olabilir. Sıkıştırma seviyesi anlatım yoğunluğunu belirler, bu sınırı ayrıca küçültmez.', 'This is an upper limit; removing repetition can produce a smaller summary. Compression level controls writing density without shrinking this budget again.')}</p>
|
||||||
{numeric('timeoutSeconds', t('Sıkıştırıcı bekleme süresi (saniye)', 'Summarizer timeout (seconds)'), 1, 3600)}
|
{numeric('timeoutSeconds', t('Sıkıştırıcı bekleme süresi (saniye)', 'Summarizer timeout (seconds)'), 1, 3600)}
|
||||||
<Button disabled={busy || draft.targetPercent >= draft.triggerPercent} onClick={async () => {
|
<Button disabled={busy || draft.targetPercent >= draft.triggerPercent} onClick={async () => {
|
||||||
setBusy(true); setMessage(''); setFailed(false)
|
setBusy(true); setMessage(''); setFailed(false)
|
||||||
|
|||||||
Generated
+1
-1
@@ -65,7 +65,7 @@
|
|||||||
},
|
},
|
||||||
"apps/desktop": {
|
"apps/desktop": {
|
||||||
"name": "aiturk-ide",
|
"name": "aiturk-ide",
|
||||||
"version": "1.0.0-beta.44",
|
"version": "1.0.0-beta.45",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@assistant-ui/core": "0.2.23",
|
"@assistant-ui/core": "0.2.23",
|
||||||
|
|||||||
Reference in new issue
Block a user