Update index.js

index.js

@@ -1,260 +1,312 @@
 const express = require('express');
-const axios = require('axios');
-const cheerio = require('cheerio');
+const bodyParser = require('body-parser');
+const DomainNameAPI = require('./index');
+const crypto = require('crypto');
 
 const app = express();
-const port = process.env.PORT || 3000;
-
-// Global variables to store the token and cookies
-let token = '';
-let cookies = '';
-let requestsCount = 0;
-let totalTime = 0;
-let domainsQueried = {};
-let averageResponseTime = 0;
-
-// Create a function to extract data using regex
-// Create a function to extract all available data using regex
-const extractData = (data) => {
-  const domainName = data.match(/Domain Name:\s*(.*)/)?.[1]?.trim();
-  const domainStatus = data.match(/Domain Status:\s*(.*)/)?.[1]?.trim();
-  const frozenStatus = data.match(/Frozen Status:\s*(.*)/)?.[1]?.trim();
-  const transferStatus = data.match(/Transfer Status:\s*(.*)/)?.[1]?.trim();
-
-  // Registrant details (in this case they are hidden)
-  const registrant = data.match(/Registrant:\n([\s\S]*?)\n\n/)?.[1]?.trim().split('\n').map(line => line.trim());
-
-  // Registrar details
-  const nicHandle = data.match(/NIC Handle\s*:\s*(.*)/)?.[1]?.trim();
-  const registrarName = data.match(/Organization Name\s*:\s*(.*)/)?.[1]?.trim();
-  const registrarAddress = data.match(/Address\s*:\s*(.*)/)?.[1]?.trim();
-  const registrarPhone = data.match(/Phone\s*:\s*(.*)/)?.[1]?.trim();
-  const registrarFax = data.match(/Fax\s*:\s*(.*)/)?.[1]?.trim();
-
-  // Domain servers
-  const nameservers = data.match(/Domain Servers:\n([\s\S]*?)\n\n/)?.[1]?.trim().split('\n');
-
-  // Additional info (Created and Expiry dates)
-  const createdDate = data.match(/Created on.*:\s*(.*)/)?.[1]?.trim();
-  const expiresDate = data.match(/Expires on.*:\s*(.*)/)?.[1]?.trim();
-
-  // Last update time
-  const lastUpdateTime = data.match(/Last Update Time:\s*(.*)/)?.[1]?.trim();
-
-  return {
-      domainName,
-      domainStatus,
-      frozenStatus,
-      transferStatus,
-      registrant,
-      registrar: {
-          nicHandle,
-          registrarName,
-          registrarAddress,
-          registrarPhone,
-          registrarFax
-      },
-      nameservers,
-      createdDate,
-      expiresDate,
-      lastUpdateTime
-  };
+app.use(bodyParser.json());
+
+// Initialize the Domain API client
+const api = new DomainNameAPI(process.env.API_USERNAME || 'harmon', process.env.API_PASSWORD || 'PrivatePass123#');
+
+// Authorization middleware
+const authorizeRequest = (req, res, next) => {
+    const authHeader = req.headers.authorization;
+    if (!authHeader || !authHeader.startsWith('Bearer ')) {
+        return res.status(401).json({
+            success: false,
+            error: 'Authorization header missing or invalid format'
+        });
+    }
+
+    const token = authHeader.split(' ')[1];
+    const today = new Date().toLocaleDateString('en-US', { weekday: 'long' }).toLowerCase();
+    const expectedToken = crypto.createHash('sha256').update(today + 'harmon').digest('hex');
+
+    if (token !== expectedToken) {
+        return res.status(401).json({
+            success: false,
+            error: 'Invalid token'
+        });
+    }
+
+    next();
 };
 
-async function sendRequestAndSetGlobals() {
-  try {
-    const response = await axios({
-      method: 'get',
-      url: 'https://www.trabis.gov.tr/whois',
-      headers: {
-        'accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7',
-        'accept-language': 'en,tr;q=0.9,en-GB;q=0.8,en-US;q=0.7',
-        'cache-control': 'max-age=0',
-        'dnt': '1',
-        'priority': 'u=0, i',
-        'referer': 'https://www.trabis.gov.tr/',
-        'sec-ch-ua': '"Microsoft Edge";v="129", "Not=A?Brand";v="8", "Chromium";v="129"',
-        'sec-ch-ua-mobile': '?0',
-        'sec-ch-ua-platform': '"Windows"',
-        'sec-fetch-dest': 'document',
-        'sec-fetch-mode': 'navigate',
-        'sec-fetch-site': 'same-origin',
-        'sec-fetch-user': '?1',
-        'upgrade-insecure-requests': '1',
-        'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/129.0.0.0 Safari/537.36 Edg/129.0.0.0'
-      }
+// Apply authorization middleware to all /api routes
+app.use('/api', authorizeRequest);
+
+// Root endpoint
+app.get('/', (req, res) => {
+    res.json({
+        success: true,
+        message: 'Domain Name API Server',
+        version: '1.0.0',
+        endpoints: {
+            root: '/',
+            domains: '/api/domains',
+            balance: '/api/balance',
+            tlds: '/api/tlds',
+            reseller: '/api/reseller'
+        }
     });
+});
 
-    console.log('Response status:', response.status);
+// Middleware to handle errors
+const errorHandler = (err, req, res, next) => {
+    console.error(err.stack);
+    res.status(500).json({
+        success: false,
+        error: err.message
+    });
+};
 
-    // Extract _token value and set it as a global variable
-    const $ = cheerio.load(response.data);
-    token = $('#search-domain-form > input[type=hidden]:nth-child(1)').val();
-    console.log('_token value set globally');
+// Add Child Name Server endpoint
+app.post('/api/domains/:domainName/childNameServer', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const { nameServer, ipAddress } = req.body;
+        const result = await api.AddChildNameServer(domainName, nameServer, ipAddress);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
 
-    // Extract and format cookies, then set as a global variable
-    const rawCookies = response.headers['set-cookie'];
-    if (rawCookies) {
-      cookies = rawCookies.map(cookie => cookie.split(';')[0]).join('; ');
-      console.log('Cookies formatted and set globally');
-    } else {
-      console.log('No cookies found in the response');
+// Delete Child Name Server endpoint
+app.delete('/api/domains/:domainName/childNameServer/:nameServer', async (req, res, next) => {
+    try {
+        const { domainName, nameServer } = req.params;
+        const result = await api.DeleteChildNameServer(domainName, nameServer);
+        res.json(result);
+    } catch (error) {
+        next(error);
     }
+});
 
-    // Log the global values
-    console.log('\nGlobal _token:', token);
-    console.log('Global cookies:', cookies);
-
-  } catch (error) {
-    console.error('Error:', error.message);
-  }
-}
-
-setInterval(sendRequestAndSetGlobals, 3600000);
-
-app.use((req, res, next) => {
-  const startTime = Date.now();
-  requestsCount++;
-  next();
-  const endTime = Date.now();
-  totalTime += endTime - startTime;
-  averageResponseTime = (totalTime / requestsCount).toFixed(2);
-
-  // track domains queried
-  if (req.query.domain) {
-    const domain = req.query.domain;
-    if (!domainsQueried[domain]) {
-      domainsQueried[domain] = 1;
-    } else {
-      domainsQueried[domain]++;
+// Modify Child Name Server endpoint
+app.put('/api/domains/:domainName/childNameServer', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const { nameServer, ipAddress } = req.body;
+        const result = await api.ModifyChildNameServer(domainName, nameServer, ipAddress);
+        res.json(result);
+    } catch (error) {
+        next(error);
     }
-  }
 });
 
-app.get('/stats', (req, res) => {
-  const stats = {
-    requestsCount,
-    averageResponseTime: parseFloat(averageResponseTime),
-    uptime: parseFloat(process.uptime().toFixed(2)),
-    domainsQueried: Object.keys(domainsQueried).map((domain) => ({
-      domain,
-      count: domainsQueried[domain],
-    })),
-  };
-
-  res.json(stats);
+// Get Contacts endpoint
+app.get('/api/domains/:domainName/contacts', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const result = await api.GetContacts(domainName);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
 });
 
-app.get('/whois', async (req, res) => {
-  const { domain } = req.query;
-
-  if (!domain) {
-    return res.status(400).json({ error: 'Domain is required' });
-  }
-  
-  try {
-    const response = await axios.post(
-      'https://www.trabis.gov.tr/search-domain',
-      new URLSearchParams({
-        _token: token,
-        domain: domain
-      }),
-      {
-        headers: {
-          'accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7',
-          'accept-language': 'en,tr;q=0.9,en-GB;q=0.8,en-US;q=0.7',
-          'cache-control': 'max-age=0',
-          'content-type': 'application/x-www-form-urlencoded',
-          'cookie': cookies,
-          'origin': 'https://www.trabis.gov.tr',
-          'priority': 'u=0, i',
-          'referer': 'https://www.trabis.gov.tr/',
-          'sec-ch-ua': '"Microsoft Edge";v="129", "Not=A?Brand";v="8", "Chromium";v="129"',
-          'sec-ch-ua-mobile': '?0',
-          'sec-ch-ua-platform': '"Windows"',
-          'sec-fetch-dest': 'document',
-          'sec-fetch-mode': 'navigate',
-          'sec-fetch-site': 'same-origin',
-          'sec-fetch-user': '?1',
-          'upgrade-insecure-requests': '1',
-          'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/129.0.0.0 Safari/537.36 Edg/129.0.0.0'
-        }
-      }
-    );
-
-    const html = response.data;
-    const $ = cheerio.load(html);
-
-    const keywords = {
-      Belgeli: false,
-      Belgesiz: false,
-      kullanımdadır: false,
-      başvurulmuş: false,
-      tahsis: false
-    };
-
-    // Search for the keywords
-    const text = $('body').text();
-    keywords.Belgeli = text.includes('Belgeli');
-    keywords.Belgesiz = text.includes('Belgesiz');
-    keywords.kullanımdadır = text.includes('kullanımdadır');
-    keywords.başvurulmuş = text.includes('başvuruldu');
-
-    // Check for reassignment text and extract date
-    let reassignmentDate = null;
-    if (text.includes('yeniden tahsis listesinde')) {
-      keywords.tahsis = true;
-      const dateMatch = text.match(/(\d{2}\/\d{2}\/\d{4}) tarihinden itibaren/);
-      if (dateMatch) {
-        reassignmentDate = dateMatch[1];
-      }
+// Save Contacts endpoint
+app.put('/api/domains/:domainName/contacts', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const { contacts } = req.body;
+        const result = await api.SaveContacts(domainName, contacts);
+        res.json(result);
+    } catch (error) {
+        next(error);
     }
+});
 
-    if (text.includes("Hatalı")) {
-      return res.status(400).json({ error: 'Invalid domain (Only TR Domains)' });
+// Transfer domain endpoint
+app.post('/api/domains/transfer', async (req, res, next) => {
+    try {
+        const { domainName, eppCode, period = 1 } = req.body;
+        const result = await api.Transfer(domainName, eppCode, period);
+        res.json(result);
+    } catch (error) {
+        next(error);
     }
+});
 
-    // if its "kullanımdadır", please get the html seleector "#main > div > div.Sub-page-content > div > div > section > div:nth-child(4) > pre" from the response and send it back to the user as "whois" data
-
-
-    // the selector is a "pre", get its text 
-    let whoisData = null;
-    if (keywords.kullanımdadır) {
-      const selector = '#main > div > div.Sub-page-content > div > div > section > div:nth-child(4) > pre';
-      whoisData = $(selector).text();
-      whoisData = extractData(whoisData);
-      res.json({
-        domain,
-        status: keywords,
-        whoisData,
-        ...(reassignmentDate && { reassignmentDate })
-      });
-    } else {
-      res.json({
-        domain,
-        status: keywords,
-        ...(reassignmentDate && { reassignmentDate })
-      });
+// Cancel Transfer endpoint
+app.post('/api/domains/:domainName/cancelTransfer', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const result = await api.CancelTransfer(domainName);
+        res.json(result);
+    } catch (error) {
+        next(error);
     }
+});
 
-  } catch (error) {
-    await sendRequestAndSetGlobals()
-    console.error(error);
-    res.status(500).json({ error: 'An error occurred' });
-  }
+// Approve Transfer endpoint
+app.post('/api/domains/:domainName/approveTransfer', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const result = await api.ApproveTransfer(domainName);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
 });
 
-// default router
-app.get('/', (req, res) => {
-  res.status(200).json({ success: true });
-})
+// Reject Transfer endpoint
+app.post('/api/domains/:domainName/rejectTransfer', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const result = await api.RejectTransfer(domainName);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
 
-//404 not found
-app.get('*', (req, res) => {
-  res.status(404).json({error: 'Page not found'});
-})
+// Renew domain endpoint
+app.post('/api/domains/:domainName/renew', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const { period } = req.body;
+        const result = await api.Renew(domainName, period);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
 
-app.listen(port, async () => {
-  await sendRequestAndSetGlobals()
-  console.log(`Server running on port ${port}`);
+// Register domain with contact info endpoint
+app.post('/api/domains/register', async (req, res, next) => {
+    try {
+        const {
+            domainName,
+            period = 1,
+            contacts,
+            nameServers = ["ns1.harmon.web.tr", "ns2.harmon.web.tr"],
+            eppLock = true,
+            privacyLock = false,
+            additionalAttributes
+        } = req.body;
+
+        const result = await api.RegisterWithContactInfo(
+            domainName,
+            period,
+            contacts,
+            nameServers,
+            eppLock,
+            privacyLock,
+            additionalAttributes
+        );
+
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
 });
+
+// Modify Privacy Protection Status endpoint
+app.put('/api/domains/:domainName/privacy', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const { status, reason = "Owner request" } = req.body;
+        const result = await api.ModifyPrivacyProtectionStatus(domainName, status, reason);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// Sync From Registry endpoint
+app.post('/api/domains/:domainName/sync', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const result = await api.SyncFromRegistry(domainName);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// Get Current Balance endpoint
+app.get('/api/balance', async (req, res, next) => {
+    try {
+        const { currencyId = 2 } = req.query;
+        const result = await api.GetCurrentBalance(currencyId);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// Check Domain Availability endpoint
+app.post('/api/domains/check', async (req, res, next) => {
+    try {
+        const { domains, extensions, period = 1, command = 'create' } = req.body;
+        const result = await api.CheckAvailability(domains, extensions, period, command);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// Get Domain List endpoint
+app.get('/api/domains', async (req, res, next) => {
+    try {
+        const extraParameters = req.query;
+        const result = await api.GetList(extraParameters);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// Get TLD List endpoint
+app.get('/api/tlds', async (req, res, next) => {
+    try {
+        const { count = 20 } = req.query;
+        const result = await api.GetTldList(count);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// Get Domain Details endpoint
+app.get('/api/domains/:domainName', async (req, res, next) => {
+    try {
+        const { domainName } = req.params;
+        const result = await api.GetDetails(domainName);
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// Get Reseller Details endpoint
+app.get('/api/reseller', async (req, res, next) => {
+    try {
+        const result = await api.GetResellerDetails();
+        res.json(result);
+    } catch (error) {
+        next(error);
+    }
+});
+
+// 404 handler - must be placed after all other routes
+app.use((req, res) => {
+    res.status(404).json({
+        success: false,
+        error: 'Endpoint not found'
+    });
+});
+
+app.use(errorHandler);
+
+const PORT = process.env.PORT || 3000;
+app.listen(PORT, () => {
+    console.log(`Server is running on port ${PORT}`);
+    // Log today's token for testing
+    const today = new Date().toLocaleDateString('en-US', { weekday: 'long' }).toLowerCase();
+    const token = crypto.createHash('sha256').update(today + 'harmon').digest('hex');
+    console.log(`Today's auth token: ${token}`);
+});