import {soldierFeatures,commanderFeatures,COMMANDS,FORMATIONS,STRATEGIES} from './sensors.js';
import {behaviorCatalog as C} from './catalog.js';
import {NEUTRAL_INPUT,validInput,applyCharacterInput} from './controls.js';
import {ObservationHistory,flagSignature,squadIndex} from './temporal.js';
import {availableSquads,applyMacroOrder,expireMacroOrders} from './macro.js';
const orderToken=(state,u)=>JSON.stringify([Boolean(u.commandOverride),u.commandOverride||state.commands[u.team]]);
export function createNeuralController({state,stats,model,worker,sensors,onError=()=>{},onReady=()=>{},onOrder=()=>{}}){
 let sequence=0,pending=null,decisionClock=.1,commanderClock=2.5;const inputs=new Map(),requestedCommanders=new Set(),history=new ObservationHistory(),commanderSignatures=new Map();
 function fail(message){model.ready=false;model.busy=false;model.disabled=true;inputs.clear();pending=null;state.paused=true;onError(message);}
 function reset(){sequence++;pending=null;inputs.clear();requestedCommanders.clear();history.reset();commanderSignatures.clear();decisionClock=.1;commanderClock=2.5;model.busy=false;}
 function tick(dt){
  if(!model.ready||!worker)return;decisionClock+=dt;commanderClock+=dt;if(model.models?.commander?.inputDim===116)expireMacroOrders(state);
  if(pending){if(performance.now()-pending.sent>3000)fail('Model yanıtı zaman aşımına uğradı.');return;}
  if(decisionClock<.1)return;decisionClock%=.1;const start=performance.now();
  sensors.shareIntel('viking');sensors.shareIntel('mongol');
  if(model.models?.commander?.inputDim===116)for(const team of ['viking','mongol']){
   const signature=flagSignature(state,sensors,team);
   if(state.commanders[team].mode==='ai'&&commanderSignatures.get(team)!==signature)requestedCommanders.add(team);
  }
  const units=state.units.filter(u=>u.alive),commanders=[];
  if(commanderClock>=2.5||requestedCommanders.size){commanderClock%=2.5;for(const team of ['viking','mongol'])if(state.commanders[team].mode==='ai'||requestedCommanders.has(team)){
   commanders.push({team,manual:requestedCommanders.has(team),generation:state.commanders[team].generation,revision:state.commands[team].revision,row:model.models?.commander?.inputDim===116?history.commander(state,sensors,team):commanderFeatures(state,sensors,team),squadMask:availableSquads(state,team)});
   commanderSignatures.set(team,flagSignature(state,sensors,team));
  }}
  requestedCommanders.clear();
  pending={matchId:stats.matchId,sequence:++sequence,sent:performance.now()};model.busy=true;
  worker.postMessage({type:'infer',matchId:stats.matchId,sequence,ids:units.map(u=>u.id),revisions:units.map(u=>orderToken(state,u)),rows:units.map(u=>model.models?.soldier?.inputDim===523?history.soldier(state,sensors,u):soldierFeatures(state,sensors,u)),commanders});
  stats.workloadSamples.push({t:performance.now(),ms:performance.now()-start});
 }
 function receive(data){
  if(data.type==='ready'){model.ready=true;model.disabled=false;model.models=data.models;model.label=data.label;model.method=data.method;onReady(data);return;}
  if(data.type==='error'){if(data.matchId&&data.matchId!==stats.matchId)return;if(data.sequence&&data.sequence!==pending?.sequence)return;fail(data.message);return;}
  if(data.type!=='inputs'||data.matchId!==stats.matchId||data.sequence!==pending?.sequence)return;
  if(data.inputs.length!==data.ids.length||data.inputs.some(i=>!validInput(i))){fail('Geçersiz model girdisi.');return;}
  model.busy=false;pending=null;stats.decisions++;stats.aiMs+=data.elapsed;stats.workloadSamples.push({t:performance.now(),ms:data.elapsed});
  data.ids.forEach((id,i)=>{const u=state.units.find(u=>u.id===id&&u.alive);if(!u)return;if(orderToken(state,u)!==data.revisions[i])return;inputs.set(id,{input:data.inputs[i],at:state.elapsed,order:data.revisions[i]});u.reason='Eğitilmiş sinir ağı · yön / nişan / ateş';u.intent=data.inputs[i].fire?'ateş et':'hareket girdisi';u.decisionMs=data.elapsed;model.latency[u.team].push(data.elapsed);model.latency[u.team]=model.latency[u.team].slice(-30);});
  if(stats.decisions%10===0){stats.examples ||= [];data.ids.forEach((id,i)=>stats.examples.push({time:state.elapsed,id,input:data.inputs[i],model:model.models?.soldier?.name||'soldier-v1'}));if(stats.examples.length>2000)stats.examples.splice(0,stats.examples.length-2000);}
  for(const c of data.commanders){const old=state.commands[c.team];if((state.commanders[c.team].mode!=='ai'&&!c.manual)||state.commanders[c.team].generation!==c.generation||old.revision!==c.revision)continue;
   if(c.macro){try{const result=applyMacroOrder(state,c.team,c.macro);if(result.count)onOrder(c.team,result.command);}catch(error){fail(error.message);}continue;}
   const commandId=COMMANDS[c.command],formation=FORMATIONS[c.formation],strategyId=STRATEGIES[c.strategy];if(!C.COMMAND_CATALOG[commandId]||!formation||!strategyId){fail('Geçersiz komutan çıktısı.');return;}
   const preset=C.COMMAND_CATALOG[commandId],changed=old.commandId!==commandId||old.formation!==C.FORMATION_LABELS[formation]||old.strategyId!==strategyId;
   Object.assign(old,preset,{commandId,formation:C.FORMATION_LABELS[formation],strategyId:strategyId==='none'?null:strategyId,combatMode:C.STRATEGIES[strategyId]?.combatMode||old.combatMode,source:'neural',strategySource:'neural',note:'Eğitilmiş komutan ağı',revision:old.revision+(changed?1:0)});
   if(changed)onOrder(c.team,old);
  }
 }
 function apply(u,dt){const entry=inputs.get(u.id),input=entry&&entry.order===orderToken(state,u)&&state.elapsed-entry.at<=.6?entry.input:NEUTRAL_INPUT;applyCharacterInput(state,stats,u,input,dt);}
 function recordHumanOrder(team,order,unitIds,source='human-live'){
  const selected=state.units.filter(u=>u.alive&&u.team===team&&unitIds.includes(u.id));if(!selected.length)return;
  const allies=state.units.filter(u=>u.alive&&u.team===team),equal=a=>a.length===selected.length&&a.every(u=>unitIds.includes(u.id));
  let group=equal(allies)?0:-1;for(let i=0;i<8&&group<0;i++)if(equal(allies.filter(u=>squadIndex(u)===i)))group=i+1;
  const task=order.task==='hold'?'defend':order.task==='capture_return'?'objective':order.task||'objective',commandId=order.commandId||(task==='defend'?'defend_base':'attack_flag');
  const action={command:COMMANDS.indexOf(commandId),formation:FORMATIONS.indexOf(order.formation||'line'),strategy:0,group,task:['objective','move','assault','defend','heal'].indexOf(commandId==='heal_at_base'?'heal':task),x:order.x??state.flags[team].home.x,y:order.y??state.flags[team].home.y,ttl:10};
  stats.commanderDemonstrations ||= [];stats.commanderDemonstrations.push({schema:'field-orders.commander-demonstration.v1',source,time:state.elapsed,team,unitIds:selected.map(u=>u.id),observation:history.commander(state,sensors,team),action,trainable:group>=0&&action.command>=0&&action.formation>=0&&action.task>=0});
  if(stats.commanderDemonstrations.length>2000)stats.commanderDemonstrations.shift();
 }
 return {recordHumanOrder,requestCommand(team){requestedCommanders.add(team);decisionClock=.1;},reset,tick,receive,apply,fail,get inputs(){return inputs;}};
}