Protocol Architecture

// Campaign creation with escrow funding
pub fn create_campaign(
    ctx: Context<CreateCampaign>,
    budget: u64,
    target_engagement: EngagementTargets,
    duration: i64,
) -> Result<()> {
    // Initialize campaign account
    let campaign = &mut ctx.accounts.campaign;
    campaign.creator = ctx.accounts.creator.key();
    campaign.budget = budget;
    campaign.targets = target_engagement;
    
    // Set end time on Solana clock
    campaign.end_time = Clock::get()?.unix_timestamp + duration;
    
    // CPI call to transfer tokens to escrow
    token::transfer(
        ctx.accounts.into_transfer_context(),
        budget,
    )?;
    
    Ok(())
}

// Off-chain function run by AutoHive Oracle Nodes
import { ProtocolClient } from '@autohive/sdk';

const submitVerification = async (campaignId: string, metrics: number) => {
    const client = new ProtocolClient(ORACLE_WALLET, connection);

    // 1. Generate zkProof of TLS stream (placeholder for complexity)
    const zkProofHash = generateZkProof(campaignId);
    
    // 2. Submit the verification instruction
    const txSig = await client.reportEngagement({
        campaignId,
        metricValue: metrics,
        proofHash: zkProofHash,
    });
    
    console.log(`Report submitted: ${txSig}`);
};

// Frontend client fetching live data via SDK
import { ProgramAccount, Campaign } from '@autohive/sdk';

const fetchCampaignsByBrand = async (brandKey: PublicKey) => {
    // Use a read-only connection, no wallet needed here
    const client = new ProtocolClient(null, connection);

    // Query all campaigns created by this brand's key
    const campaigns = await client.getAllCampaigns([
        {
            memcmp: {
                offset: 8, // Anchor Discriminator size
                bytes: brandKey.toBase58(),
            },
        },
    ]);
    
    // Log results
    campaigns.forEach((acc: ProgramAccount<Campaign>) => {
        console.log(`Active Campaign: ${acc.account.budget} HIVE`);
    });
    return campaigns;
};