How to Integrate Replit with Moz

1// moz-client.js — Moz Links API v2 client
2const MOZ_API = 'https://api.moz.com/jsonrpc';
3
4function getAuthHeader() {
5  const accessId = process.env.MOZ_ACCESS_ID;
6  const secretKey = process.env.MOZ_SECRET_KEY;
7  if (!accessId || !secretKey) throw new Error('MOZ_ACCESS_ID or MOZ_SECRET_KEY not set');
8  const encoded = Buffer.from(`${accessId}:${secretKey}`).toString('base64');
9  return `Basic ${encoded}`;
10}
11
12// Fetch metrics for a single URL
13async function getUrlMetrics(url) {
14  const response = await fetch(MOZ_API, {
15    method: 'POST',
16    headers: {
17      'Authorization': getAuthHeader(),
18      'Content-Type': 'application/json'
19    },
20    body: JSON.stringify({
21      jsonrpc: '2.0',
22      id: '1',
23      method: 'data.site.metrics.fetch',
24      params: {
25        data: { site: url },
26        limit: 1
27      }
28    })
29  });
30
31  if (!response.ok) {
32    const err = await response.text();
33    throw new Error(`Moz API error ${response.status}: ${err}`);
34  }
35
36  const data = await response.json();
37  if (data.error) throw new Error(`Moz API error: ${JSON.stringify(data.error)}`);
38  return data.result;
39}
40
41// Fetch metrics for multiple URLs in one request
42async function getBulkMetrics(urls) {
43  const response = await fetch(MOZ_API, {
44    method: 'POST',
45    headers: {
46      'Authorization': getAuthHeader(),
47      'Content-Type': 'application/json'
48    },
49    body: JSON.stringify({
50      jsonrpc: '2.0',
51      id: '1',
52      method: 'data.site.metrics.fetch',
53      params: {
54        data: urls.map(url => ({ site: url })),
55        limit: urls.length
56      }
57    })
58  });
59
60  if (!response.ok) {
61    const err = await response.text();
62    throw new Error(`Moz API error ${response.status}: ${err}`);
63  }
64
65  const data = await response.json();
66  if (data.error) throw new Error(`Moz API error: ${JSON.stringify(data.error)}`);
67  return data.result;
68}
69
70module.exports = { getUrlMetrics, getBulkMetrics };

1// server.js — Express DA checker using Moz API
2const express = require('express');
3const { getUrlMetrics, getBulkMetrics } = require('./moz-client');
4
5const app = express();
6app.use(express.json());
7
8// GET /da?url=example.com
9app.get('/da', async (req, res) => {
10  const { url } = req.query;
11  if (!url) return res.status(400).json({ error: 'url parameter required' });
12  try {
13    const metrics = await getUrlMetrics(url);
14    res.json({ url, metrics });
15  } catch (err) {
16    console.error('Moz error:', err.message);
17    res.status(500).json({ error: err.message });
18  }
19});
20
21// POST /da/bulk — { urls: ['example.com', 'another.com'] }
22app.post('/da/bulk', async (req, res) => {
23  const { urls } = req.body;
24  if (!Array.isArray(urls) || urls.length === 0) {
25    return res.status(400).json({ error: 'urls array required in request body' });
26  }
27  if (urls.length > 50) {
28    return res.status(400).json({ error: 'Maximum 50 URLs per bulk request' });
29  }
30  try {
31    const results = await getBulkMetrics(urls);
32    res.json({ count: urls.length, results });
33  } catch (err) {
34    console.error('Moz bulk error:', err.message);
35    res.status(500).json({ error: err.message });
36  }
37});
38
39const PORT = process.env.PORT || 3000;
40app.listen(PORT, '0.0.0.0', () => {
41  console.log(`Moz DA checker running on port ${PORT}`);
42});

1# app.py — Moz Links API server in Python
2import os
3import base64
4import requests
5from flask import Flask, request, jsonify
6
7app = Flask(__name__)
8
9MOZ_API = 'https://api.moz.com/jsonrpc'
10
11def get_auth_header():
12    access_id = os.environ.get('MOZ_ACCESS_ID')
13    secret_key = os.environ.get('MOZ_SECRET_KEY')
14    if not access_id or not secret_key:
15        raise ValueError('MOZ_ACCESS_ID or MOZ_SECRET_KEY not set')
16    encoded = base64.b64encode(f'{access_id}:{secret_key}'.encode()).decode()
17    return {'Authorization': f'Basic {encoded}', 'Content-Type': 'application/json'}
18
19def fetch_metrics(url):
20    payload = {
21        'jsonrpc': '2.0',
22        'id': '1',
23        'method': 'data.site.metrics.fetch',
24        'params': {'data': {'site': url}, 'limit': 1}
25    }
26    resp = requests.post(MOZ_API, headers=get_auth_header(), json=payload, timeout=15)
27    resp.raise_for_status()
28    data = resp.json()
29    if 'error' in data:
30        raise ValueError(f"Moz API error: {data['error']}")
31    return data.get('result', {})
32
33@app.route('/da')
34def da():
35    url = request.args.get('url')
36    if not url:
37        return jsonify({'error': 'url parameter required'}), 400
38    try:
39        metrics = fetch_metrics(url)
40        return jsonify({'url': url, 'metrics': metrics})
41    except Exception as e:
42        return jsonify({'error': str(e)}), 500
43
44if __name__ == '__main__':
45    app.run(host='0.0.0.0', port=3000)