REDEFINING THE
FUTURE OF DATA SYSTEMS.

from topospatia import DB
import json

# 1. Открытие встроенной базы данных TopoSpatiaDB через прямой C-FFI
db = DB("./data", max_dim=2, stalk_dim=2, fsync=False)

try:
    # 2. Добавление симплексов топологического графа знаний
    c0 = db.add_cell([0])
    c1 = db.add_cell([1])
    c_edge = db.add_cell([0, 1])
    db.compile()  # Построение матрицы оператора Лапласа Delta_0

    # 3. Атомарное сохранение векторных эмбеддингов
    db.put(
        doc_id="node_vector_0",
        cell_id=c0,
        dim=0,
        vector=[0.85, 0.42],
        payload={"title": "Hodge Sheaf Embedding", "confidence": 0.99}
    )

    # 4. Вычисление гармонических чисел Бетти (H_0, H_1) комплексов
    betti = db.betti(tolerance=1e-5)
    print(f"Числа Бетти хранилища: {betti}")

    # 5. Симплициальное распространение RAG-контекста для LLM
    scores = db.rag_diffuse(seeds=[0], steps=3, alpha=0.1)
    print(f"Топологический контекст RAG: {scores}")
finally:
    db.close()

package main

import (
    "log"
    "topospatia"
)

func main() {
    // 1. Инициализация клеточного комплекса (размерность 2, векторный стебель 2D)
    sheaf := topospatia.NewSimplicialSheaf(2, 2)
    sheaf.AddCell([]int{0})
    sheaf.AddCell([]int{1})
    sheaf.AddCell([]int{2})
    sheaf.AddCell([]int{0, 1, 2})
    sheaf.CompileOperators()

    // 2. Открытие высокопроизводительного WAL хранилища и движка консенсуса
    storage, err := topospatia.OpenStorage("./data", sheaf)
    if err != nil {
        log.Fatal(err)
    }
    consensus := topospatia.NewConsensusEngine(sheaf, storage)

    // 3. Запуск градиентной тепловой диффузии: сведение вихрей H^1 к гармоническому ядру
    iters, initE, finalE := consensus.DiffuseHeatKernel(0.1, 100, 1e-6)
    log.Printf("Консенсус сошелся за %d шагов: E(x) %.6f -> %.6f (Дедлоки: 0%%)", iters, initE, finalE)
}

/* Подключение libtopospatia.h и линковка с -ltopospatia */
#include <stdio.h>
#include <stdlib.h>
#include "libtopospatia.h"

int main(void) {
    // 1. Открытие дескриптора БД: dataDir, maxDim=2, stalkDim=2, fsync=0
    GoUintptr db = topospatia_open("./data", 2, 2, 0);
    if (db == 0) {
        fprintf(stderr, "Ошибка инициализации TopoSpatiaDB\n");
        return 1;
    }

    // 2. Добавление симплициального ребра [0, 1]
    int verts[] = {0, 1};
    char* cell_id = topospatia_add_cell(db, verts, 2);
    topospatia_compile(db);

    // 3. Запись вектора состояния без блокировок
    double vec[] = {12.8, -4.5};
    topospatia_put(db, "record_c", cell_id, 1, vec, 2, "{\"engine\":\"c99\"}");

    // 4. Исполнение диффузии Ходжа: возврат JSON строки отчета
    char* report_json = topospatia_diffuse(db);
    printf("Отчет диффузии: %s\n", report_json);

    // 5. Освобождение памяти, выделенной Go runtime, и закрытие базы
    topospatia_free_string(cell_id);
    topospatia_free_string(report_json);
    topospatia_close(db);
    return 0;
}

# 1. Запрос метрик и структуры клеточного комплекса
curl -X GET http://localhost:8089/api/v1/status

# 2. Запуск теплового консенсуса Ходжа exp(-t * Delta_0)
curl -X POST http://localhost:8089/api/v1/consensus/diffuse

# 3. Симплициальное RAG-распространение контекста по гиперграфу
curl -X POST http://localhost:8089/api/v1/rag/diffuse \
  -H "Content-Type: application/json" \
  -d '{"seeds": [0], "steps": 3, "alpha": 0.1}'

# 4. Атомарный коммит векторного стебля в WAL журнал
curl -X POST http://localhost:8089/api/v1/records \
  -H "Content-Type: application/json" \
  -d '{"id": "rec-1", "cell_id": "[0]", "dimension": 0, "vector": [10.5, 4.2], "payload": {"source": "rest_gateway"}}'

# 5. Вычисление топологических инвариантов и чисел Бетти комплекса
curl -X GET http://localhost:8089/api/v1/betti?tol=0.0001