How to Integrate Replit with Ahrefs

1// ahrefs-client.js — Ahrefs API v3 client
2const AHREFS_API_BASE = 'https://api.ahrefs.com/v3';
3
4function getToken() {
5  const token = process.env.AHREFS_API_TOKEN;
6  if (!token) throw new Error('AHREFS_API_TOKEN secret is not set');
7  return token;
8}
9
10function buildHeaders() {
11  return {
12    'Authorization': `Bearer ${getToken()}`,
13    'Accept': 'application/json'
14  };
15}
16
17// Fetch domain overview: DR, organic keywords, organic traffic
18async function getDomainOverview(domain) {
19  const params = new URLSearchParams({
20    target: domain,
21    output: 'json',
22    select: 'domain_rating,org_keywords,org_traffic'
23  });
24  const url = `${AHREFS_API_BASE}/site-explorer/metrics?${params}`;
25  const res = await fetch(url, { headers: buildHeaders() });
26  if (!res.ok) {
27    const err = await res.text();
28    throw new Error(`Ahrefs API error ${res.status}: ${err}`);
29  }
30  return res.json();
31}
32
33// Fetch top referring domains for a target
34async function getReferringDomains(domain, limit = 10) {
35  const params = new URLSearchParams({
36    target: domain,
37    output: 'json',
38    limit: limit,
39    select: 'domain,domain_rating,linked_domains,dofollow_linked_domains'
40  });
41  const url = `${AHREFS_API_BASE}/site-explorer/refdomains?${params}`;
42  const res = await fetch(url, { headers: buildHeaders() });
43  if (!res.ok) {
44    const err = await res.text();
45    throw new Error(`Ahrefs API error ${res.status}: ${err}`);
46  }
47  return res.json();
48}
49
50// Fetch top organic keywords for a domain
51async function getOrganicKeywords(domain, limit = 20) {
52  const params = new URLSearchParams({
53    target: domain,
54    output: 'json',
55    limit: limit,
56    select: 'keyword,volume,position,traffic'
57  });
58  const url = `${AHREFS_API_BASE}/site-explorer/organic-keywords?${params}`;
59  const res = await fetch(url, { headers: buildHeaders() });
60  if (!res.ok) {
61    const err = await res.text();
62    throw new Error(`Ahrefs API error ${res.status}: ${err}`);
63  }
64  return res.json();
65}
66
67module.exports = { getDomainOverview, getReferringDomains, getOrganicKeywords };

1// server.js — Express SEO metrics server using Ahrefs API
2const express = require('express');
3const { getDomainOverview, getReferringDomains, getOrganicKeywords } = require('./ahrefs-client');
4
5const app = express();
6app.use(express.json());
7
8// GET /metrics?domain=example.com
9app.get('/metrics', async (req, res) => {
10  const { domain } = req.query;
11  if (!domain) {
12    return res.status(400).json({ error: 'domain query parameter is required' });
13  }
14  try {
15    const overview = await getDomainOverview(domain);
16    res.json({ domain, metrics: overview });
17  } catch (err) {
18    console.error('Ahrefs error:', err.message);
19    res.status(500).json({ error: err.message });
20  }
21});
22
23// GET /backlinks?domain=example.com&limit=20
24app.get('/backlinks', async (req, res) => {
25  const { domain, limit = 10 } = req.query;
26  if (!domain) {
27    return res.status(400).json({ error: 'domain query parameter is required' });
28  }
29  try {
30    const data = await getReferringDomains(domain, parseInt(limit));
31    res.json({ domain, referring_domains: data });
32  } catch (err) {
33    console.error('Ahrefs error:', err.message);
34    res.status(500).json({ error: err.message });
35  }
36});
37
38// GET /keywords?domain=example.com&limit=20
39app.get('/keywords', async (req, res) => {
40  const { domain, limit = 20 } = req.query;
41  if (!domain) {
42    return res.status(400).json({ error: 'domain query parameter is required' });
43  }
44  try {
45    const data = await getOrganicKeywords(domain, parseInt(limit));
46    res.json({ domain, keywords: data });
47  } catch (err) {
48    console.error('Ahrefs error:', err.message);
49    res.status(500).json({ error: err.message });
50  }
51});
52
53const PORT = process.env.PORT || 3000;
54app.listen(PORT, '0.0.0.0', () => {
55  console.log(`Ahrefs SEO server running on port ${PORT}`);
56});

1# app.py — Flask SEO server using Ahrefs API
2import os
3import requests
4from flask import Flask, request, jsonify
5
6app = Flask(__name__)
7
8AHREFS_API_BASE = 'https://api.ahrefs.com/v3'
9
10def get_headers():
11    token = os.environ.get('AHREFS_API_TOKEN')
12    if not token:
13        raise ValueError('AHREFS_API_TOKEN environment variable is not set')
14    return {
15        'Authorization': f'Bearer {token}',
16        'Accept': 'application/json'
17    }
18
19def fetch_domain_overview(domain):
20    params = {
21        'target': domain,
22        'output': 'json',
23        'select': 'domain_rating,org_keywords,org_traffic'
24    }
25    resp = requests.get(
26        f'{AHREFS_API_BASE}/site-explorer/metrics',
27        headers=get_headers(),
28        params=params,
29        timeout=15
30    )
31    resp.raise_for_status()
32    return resp.json()
33
34def fetch_organic_keywords(domain, limit=20):
35    params = {
36        'target': domain,
37        'output': 'json',
38        'limit': limit,
39        'select': 'keyword,volume,position,traffic'
40    }
41    resp = requests.get(
42        f'{AHREFS_API_BASE}/site-explorer/organic-keywords',
43        headers=get_headers(),
44        params=params,
45        timeout=15
46    )
47    resp.raise_for_status()
48    return resp.json()
49
50@app.route('/metrics')
51def metrics():
52    domain = request.args.get('domain')
53    if not domain:
54        return jsonify({'error': 'domain parameter required'}), 400
55    try:
56        data = fetch_domain_overview(domain)
57        return jsonify({'domain': domain, 'metrics': data})
58    except requests.HTTPError as e:
59        return jsonify({'error': str(e)}), 500
60
61@app.route('/keywords')
62def keywords():
63    domain = request.args.get('domain')
64    limit = int(request.args.get('limit', 20))
65    if not domain:
66        return jsonify({'error': 'domain parameter required'}), 400
67    try:
68        data = fetch_organic_keywords(domain, limit)
69        return jsonify({'domain': domain, 'keywords': data})
70    except requests.HTTPError as e:
71        return jsonify({'error': str(e)}), 500
72
73if __name__ == '__main__':
74    app.run(host='0.0.0.0', port=3000)