Janady13/AI_Brain / infra/omnicron_iface.py

Source identity

Field	Recorded value
Source type	GitHub source
Original record	Janady13/AI_Brain / infra/omnicron_iface.py
Date	Not specified in source
Repository	Janady13/AI_Brain
Revision	11aa50ef5d7692e8abd1b8d74ae31c5c29201b14
Branch	codex/build-online-github-ani-irqa7y
Path or archive member	infra/omnicron_iface.py
Original SHA-256	96948b5e70120353b410cf325a28cdba5971e9405d0ac6c2c5c9a4803cd45d4d
Git blob SHA	7c352e59c8e24cf822087d99cee40dbcac3c916b
Reading-copy SHA-256	96948b5e70120353b410cf325a28cdba5971e9405d0ac6c2c5c9a4803cd45d4d

Original source ↗

Every recorded occurrence

These 23 records contain identical original source bytes. Their paths and revisions remain part of the archive.

Original record	Branch or archive	Revision / identifier	Original location
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-irqa7y	11aa50ef5d7692e8abd1b8d74ae31c5c29201b14	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-hr4y0z	366ab848896ae49159cfb3f6c201b8c5a731e9c8	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-i3cigl	3a6e002311c48c27ffd41ef4a2a31c63947128cd	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani	49db80a641b10ab62d16cc7643bd0b367f93951c	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-hrtsoc	50285aff347685f043e7a72e4d72891eebaa6cd6	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-7v4kug	5cd0bbf744b0aee9445913337e852889d9a8098e	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-nbgsix	840945d70b88674d8f40d330001cc63d871dc8e2	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	copilot/vscode1760283895982	9e1c1a5b171addb5bb4a83b2ea7dede50c1cc81e	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-jf5olo	c6653627c453ab428d665226167fa5f4aa05e9a5	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	feature/seeder-engine-tests	cdb497ece2d1a770ca8c83eb1de8923cfaa9eceb	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-7nmb21	d0f50071c85cddaaebbf9c4dd1313bd7676986da	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-0etkns	e250b19d446bdffd542c9eea31cead12e30800d6	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-hr4y0z	366ab848896ae49159cfb3f6c201b8c5a731e9c8	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-irqa7y	11aa50ef5d7692e8abd1b8d74ae31c5c29201b14	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-i3cigl	3a6e002311c48c27ffd41ef4a2a31c63947128cd	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-7v4kug	5cd0bbf744b0aee9445913337e852889d9a8098e	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-nbgsix	840945d70b88674d8f40d330001cc63d871dc8e2	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	copilot/vscode1760283895982	9e1c1a5b171addb5bb4a83b2ea7dede50c1cc81e	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-7nmb21	d0f50071c85cddaaebbf9c4dd1313bd7676986da	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	feature/seeder-engine-tests	cdb497ece2d1a770ca8c83eb1de8923cfaa9eceb	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani	49db80a641b10ab62d16cc7643bd0b367f93951c	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-jf5olo	c6653627c453ab428d665226167fa5f4aa05e9a5	Open original
Janady13/AI_Brain / infra/omnicron_iface.py	codex/build-online-github-ani-hrtsoc	50285aff347685f043e7a72e4d72891eebaa6cd6	Open original

Recovered source transcript

Download complete source text ↓101 lines · 2.3 KB

from __future__ import annotations
import contextlib
import json
import os
import sys
import time
import uuid
from dataclasses import dataclass
from typing import Any, Dict, Iterator

REDACTIONS = [
    ("OMNICRON_TOKEN", "***REDACTED***"),
]


def _redact_env(data: Dict[str, Any]) -> Dict[str, Any]:
    out = dict(data)
    token = os.getenv("OMNICRON_TOKEN")
    if token:
        for k, v in list(out.items()):
            if isinstance(v, str) and token in v:
                out[k] = v.replace(token, "***REDACTED***")
    return out


def _emit(payload: Dict[str, Any]) -> None:
    # Structured JSON log to stdout; redacts token in values
    payload = _redact_env(payload)
    try:
        sys.stdout.write(json.dumps(payload, ensure_ascii=False) + "\n")
        sys.stdout.flush()
    except Exception:
        # Avoid breaking callers on logging failures
        pass


@contextlib.contextmanager
def task(name: str, **fields: Any) -> Iterator[None]:
    run_id = str(uuid.uuid4())
    start = time.time()
    _emit({
        "ts": time.time(),
        "type": "task_start",
        "task": name,
        "run_id": run_id,
        **fields,
    })
    try:
        yield
        status = "ok"
        err = None
    except Exception as exc:  # pragma: no cover
        status = "error"
        err = {
            "type": exc.__class__.__name__,
            "msg": str(exc),
        }
        raise
    finally:
        _emit({
            "ts": time.time(),
            "type": "task_end",
            "task": name,
            "run_id": run_id,
            "status": status,
            "err": err,
            "elapsed_s": round(time.time() - start, 6),
            **fields,
        })


def log(event: str, **fields: Any) -> None:
    _emit({
        "ts": time.time(),
        "type": "event",
        "event": event,
        **fields,
    })


def notify(level: str, message: str, **ctx: Any) -> None:
    _emit({
        "ts": time.time(),
        "type": "notify",
        "level": level,
        "message": message,
        **ctx,
    })


@dataclass
class _Artifact:
    def put(self, path: str, name: str) -> None:  # no-op shim
        log("artifact_put", path=path, name=name, provider="shim")

    def get(self, name: str, dest: str) -> None:  # no-op shim
        log("artifact_get", name=name, dest=dest, provider="shim")


artifact = _Artifact()