import { BaseAgent } from "@lantern/agents";

import { RevenueOntology } from "@lantern/ontology";

import { IntentScorer } from "@lantern/signals";

import { CampaignBuilder } from "@lantern/campaigns";

export class ABMStrategyAgent extends BaseAgent {

/**

* Monitors target accounts for buying signals and

* auto-builds personalized campaigns when intent spikes.

*/

constructor(ontology, { threshold = 0.75 } = {}) {

super({ name: "abm_strategist" });

this.ontology = ontology;

this.scorer = new IntentScorer();

this.threshold = threshold;

this.builder = new CampaignBuilder();

}

async run(accountId) {

const account = await this.ontology.getAccount(accountId);

const signals = await this.ontology.getSignals(account);

const committee = await this.ontology.getBuyingCommittee(account);

const score = this.scorer.evaluate(signals);

// Every decision is auditable

this.logReasoning({

step: "intent_evaluation",

inputs: { signals, accountId },

output: { score, committeeSize: committee.length },

confidence: this.scorer.confidence,

});

if (score < this.threshold) {

return this.skip(account, {

reason: `Score ${score.toFixed(2)} below threshold`,

});

}

// Build personalized campaign for each persona

const campaign = this.builder.create({

account,

committee,

channels: ["linkedin_ad", "email_sequence", "landing_page"],

});

for (const persona of committee) {

this.logReasoning({

step: "persona_personalization",

inputs: { role: persona.role, signals: persona.signals },

output: { contentVariant: persona.role },

confidence: this.scorer.confidence,

});

campaign.addVariant({

persona,

ad: await this.builder.generateAd(account, persona),

emailSequence: await this.builder.generateEmails(account, persona),

briefingDoc: await this.builder.generateAEBrief(account, persona),

});

}

// Nothing ships without human approval

await campaign.submitForReview();

return campaign;

}

}