Janady13/seferim-agi-g16 / apps/agi_bridge_v2/main.cpp

1#include "g16_v2_core.h" 2#include <iostream> 3#include <iomanip> 4#include <cstdlib> 5#include <cstring> 6#include <fstream> 7#include <sstream> 8#include <vector> 9 10// seferim C API (implemented in src/seferim/seferim_federation.cpp) 11extern "C" { 12 typedef void* seferim_federation_t; 13 seferim_federation_t seferim_federation_create(); 14 void seferim_federation_destroy(seferim_federation_t fed); 15 double seferim_federation_coherence(seferim_federation_t fed); 16 double seferim_federation_consciousness(seferim_federation_t fed); 17 void seferim_federation_tick(seferim_federation_t fed, double dt); 18 int seferim_federation_learn(seferim_federation_t fed, const char* item, int family); 19 int seferim_federation_save(seferim_federation_t fed, const char* path); 20 double seferim_family_coherence(seferim_federation_t fed, int family); 21} 22 23using namespace g16v2; 24 25struct IndexItem { 26 std::string path; 27 std::string type; 28 std::string content; 29 int family = -1; 30}; 31 32struct FamilyQueues { 33 std::vector<IndexItem> q[NUM_FAMILIES]; 34 size_t borrowed = 0; 35 std::array<uint64_t, NUM_FAMILIES> served{}; 36 FamilyQueues() { for (auto& s : served) s = 0; } 37}; 38 39static int detect_family(const std::string& type, const std::string& path) { 40 if (type == "c" || type == "cpp" || type == "h" || 41 type == "js" || type == "ts" || type == "go" || 42 type == "rs" || type == "java" || type == "swift" || 43 type == "kt" || type == "m" || type == "mm") { 44 return 10; // Yad 45 } 46 if (type == "txt" || type == "md" || type == "json" || 47 type == "yaml" || type == "xml") { 48 return 11; // Lashon 49 } 50 if (type == "png" || type == "jpg" || type == "jpeg") { 51 return 1; // Iris 52 } 53 // path hints 54 if (path.find("/code/") != std::string::npos) return 10; 55 if (path.find("/lang/") != std::string::npos) return 11; 56 return -1; 57} 58 59static std::vector<IndexItem> load_index(const char* path) { 60 std::vector<IndexItem> items; 61 std::ifstream f(path); 62 if (!f) { 63 std::cerr << "Index not found: " << path << "\n"; 64 return items; 65 } 66 std::string line; 67 while (std::getline(f, line)) { 68 // very light JSONL extraction (expects {"path":"..","type":"..","content":"..","family":N}) 69 IndexItem it; 70 auto grab = [&](const std::string& key)->std::string{ 71 std::string pat = "\"" + key + "\""; 72 size_t p = line.find(pat); 73 if (p == std::string::npos) return ""; 74 p = line.find(':', p); 75 if (p == std::string::npos) return ""; 76 // if quoted value 77 size_t q1 = line.find('"', p+1); 78 size_t q2 = std::string::npos; 79 if (q1 != std::string::npos) q2 = line.find('"', q1+1); 80 if (q1 != std::string::npos && q2 != std::string::npos) { 81 return line.substr(q1+1, q2-q1-1); 82 } 83 return ""; 84 }; 85 it.path = grab("path"); 86 it.type = grab("type"); 87 it.content = grab("content"); 88 // optional explicit family 89 size_t pf = line.find("\"family\""); 90 if (pf != std::string::npos) { 91 pf = line.find(':', pf); 92 if (pf != std::string::npos) { 93 std::string tail = line.substr(pf+1); 94 it.family = std::atoi(tail.c_str()); 95 } 96 } 97 if (it.family < 0) it.family = detect_family(it.type, it.path); 98 items.push_back(std::move(it)); 99 } 100 return items; 101} 102 103static void build_family_queues(const std::vector<IndexItem>& items, FamilyQueues& fq) { 104 for (const auto& it : items) { 105 int fam = it.family >= 0 ? it.family : detect_family(it.type, it.path); 106 if (fam < 0 || fam >= NUM_FAMILIES) continue; 107 fq.q[fam].push_back(it); 108 } 109} 110 111static Config load_config() { 112 Config cfg; 113 const char* w_env = std::getenv("G16_WEIGHTS"); 114 if (w_env) { 115 std::istringstream ss(w_env); 116 std::string tok; 117 int i = 0; 118 while (std::getline(ss, tok, ',') && i < NUM_FAMILIES) cfg.w[i++] = std::stod(tok); 119 } else { 120 cfg.w = {8.11856, 7.82319, 7.53323, 3.9886, 7.70958, 8.36018, 3.94711, 121 4.3281, 6.95926, 3.68361, 3.90775, 3.04808, 3.30263, 8.4151, 122 4.64597, 2.18988}; 123 } 124 if (auto* v = std::getenv("G16_GAMMA_MIN")) cfg.gamma_min = std::stod(v); 125 if (auto* v = std::getenv("G16_LAMBDA")) cfg.lambda = std::stod(v); 126 if (auto* v = std::getenv("SEFERIM_TARGET_COH")) cfg.target_coh = std::stod(v); 127 if (auto* v = std::getenv("SEFERIM_LR_BASE")) cfg.lr_base = std::stod(v); 128 if (auto* v = std::getenv("SEFERIM_LR_GAIN")) cfg.lr_gain = std::stod(v); 129 if (auto* v = std::getenv("AGI_INGEST_GATE")) cfg.ingest_gate = std::stod(v); 130 if (auto* v = std::getenv("AGI_INGEST_MAX")) cfg.ingest_max = std::stoi(v); 131 if (std::getenv("G16_NO_FIBONACCI")) cfg.use_fibonacci_timing = false; 132 if (std::getenv("G16_NO_SPIRAL")) cfg.use_golden_spiral = false; 133 if (std::getenv("G16_NO_RESONANCE")) cfg.use_cross_family_resonance = false; 134 if (std::getenv("G16_SEQUENTIAL_PLANES")) cfg.use_semantic_planes = false; 135 return cfg; 136} 137 138int main(int argc, char** argv) { 139 uint64_t max_ticks = 1000; 140 if (argc > 1) max_ticks = std::stoull(argv[1]); 141 142 Config cfg = load_config(); 143 SystemState state; 144 init_state(state); 145 CouplingMatrix J; 146 build_golden_coupling_matrix(J, cfg); 147 GoldenRotation R; 148 init_rotation(R); 149 150 seferim_federation_t fed = seferim_federation_create(); 151 if (!fed) { 152 std::cerr << "Failed to create federation\n"; 153 return 1; 154 } 155 156 std::vector<IndexItem> index; 157 if (const char* idx_path = std::getenv("AGI_INGEST_INDEX")) { 158 index = load_index(idx_path); 159 } 160 FamilyQueues fq; 161 build_family_queues(index, fq); 162 size_t fib_events = 0; 163 double prev_coh = seferim_federation_coherence(fed); 164 165 std::cout << std::fixed << std::setprecision(6); 166 for (uint64_t t = 0; t < max_ticks; ++t) { 167 seferim_federation_tick(fed, 0.01); 168 double coh = seferim_federation_coherence(fed); 169 double cons = seferim_federation_consciousness(fed); 170 171 Signals signals; 172 signals.dx_norm = std::abs(coh - prev_coh); 173 signals.ed_error = std::abs(cfg.target_coh - coh); 174 signals.utility = 0.5 * cons + 0.5 * coh; 175 signals.stability = 1.0 - signals.dx_norm; 176 177 for (int f = 0; f < NUM_FAMILIES; ++f) { 178 state.phi.phi[f] = seferim_family_coherence(fed, f); 179 } 180 181 update_psi(state, signals, J, cfg); // controller dynamics remain 182 183 // Continuous learning each tick (no Fibonacci gate) 184 { 185 fib_events++; // service quanta for fairness proportions 186 // Select family with largest deficit: s_f * fib_events - served[f] 187 int select_f = -1; 188 double best_deficit = -1e9; 189 double s_f = 1.0 / NUM_FAMILIES; 190 for (int f = 0; f < NUM_FAMILIES; ++f) { 191 double deficit = s_f * static_cast<double>(fib_events) - static_cast<double>(fq.served[f]); 192 if (deficit > best_deficit) { 193 best_deficit = deficit; 194 select_f = f; 195 } 196 } 197 // Try to serve from select_f; if empty, borrow from neighbor (simple ring) 198 IndexItem item{}; 199 bool have = false; 200 if (select_f >= 0 && !fq.q[select_f].empty()) { 201 item = fq.q[select_f].back(); 202 fq.q[select_f].pop_back(); 203 have = true; 204 } else { 205 // borrow 206 for (int k = 1; k < NUM_FAMILIES; ++k) { 207 int left = (select_f - k + NUM_FAMILIES) % NUM_FAMILIES; 208 int right = (select_f + k) % NUM_FAMILIES; 209 if (!fq.q[left].empty()) { 210 item = fq.q[left].back(); 211 fq.q[left].pop_back(); 212 have = true; 213 fq.borrowed++; 214 break; 215 } 216 if (!fq.q[right].empty()) { 217 item = fq.q[right].back(); 218 fq.q[right].pop_back(); 219 have = true; 220 fq.borrowed++; 221 break; 222 } 223 } 224 } 225 if (have && !item.content.empty()) { 226 int fam = item.family >= 0 ? item.family : detect_family(item.type, item.path); 227 seferim_federation_learn(fed, item.content.c_str(), fam); 228 fq.served[fam] += 1; 229 state.items_ingested++; 230 } 231 } 232 233 std::cout << "t=" << t 234 << " coh=" << coh 235 << " cons=" << cons 236 << " dx=" << signals.dx_norm 237 << " err=" << signals.ed_error 238 << " stab=" << signals.stability 239 << " | Ω=" << state.omega.total 240 << " κ=" << state.kappa 241 << " b=" << state.b 242 << " Φ=" << state.phi.global 243 << " ing=" << state.items_ingested 244 << "\n"; 245 prev_coh = coh; 246 } 247 248 if (const char* save_dir = std::getenv("SEFERIM_SAVE_DIR")) { 249 std::string path = std::string(save_dir) + "/federation_state.bin"; 250 seferim_federation_save(fed, path.c_str()); 251 std::cout << "Saved snapshot to " << path << "\n"; 252 } 253 254 seferim_federation_destroy(fed); 255 return 0; 256} 257