Refactor

Author: Mqxx

src/api/index.ts

@@ -0,0 +1,17 @@
+import createDnsRecord from './create_dns_record.ts';
+import listDnsRecords from './list_dns_records.ts'
+import updateDnsRecord from './update_dns_record.ts'
+
+const api = {
+  createDnsRecord,
+  listDnsRecords,
+  updateDnsRecord
+}
+
+export {
+  createDnsRecord,
+  listDnsRecords,
+  updateDnsRecord
+}
+
+export default api;

src/api/list_dns_records.ts

@@ -1,6 +1,6 @@
 import ApiRequestError from '../error/api_request_error.ts';
 import FetchRequestError from '../error/fetch_request_error.ts';
-import { DnsRecord } from '../record/dns_record.ts';
+import { DnsRecordList } from '../record/dns_record_list.ts';
 import supportedDnsRecordTypes from '../record/dns_record_type.ts';
 import { ApiRequestOptions } from './api_request_options.ts';
 
@@ -10,7 +10,7 @@ import { ApiRequestOptions } from './api_request_options.ts';
  * @param options Options for the API fetch
  * @returns List of all DNS records found.
  */
-export default function listDnsRecordsFromApi(options : ApiRequestOptions) : Promise<DnsRecord[]> {
+export default function listDnsRecordsFromApi(options : ApiRequestOptions) : Promise<DnsRecordList[]> {
   return fetch(
     `${options.apiEndpoint}zones/${options.zoneId}/dns_records?type=${supportedDnsRecordTypes.join(',')}`,
     {

src/index.ts

@@ -1,6 +1,5 @@
-import createDnsRecord from './api/create_dns_record.ts';
-import listDnsRecords from './api/list_dns_records.ts';
-import {parseRequestURL} from './request/url/index.ts'
+import requestUrl from './request_url/index.ts';
+import api from './api/index.ts';
 
 export default {
   /**
@@ -9,16 +8,24 @@ export default {
    * @param request Incoming http request
    */
   async fetch(request : Request) : Promise<void> {
-    const requestUrl = new URL(request.url)
-    const {token, zoneId, records} = parseRequestURL(requestUrl)
+    const {
+      token,
+      zoneId,
+      records: requestedRecords
+    } = requestUrl.parse(request.url);
 
-    const existingRecords = await listDnsRecords({token, zoneId})
+    const existingRecords = await api.listDnsRecords({token, zoneId})
 
-    existingRecords.forEach((record) => {
-      
-    })
-    records.forEach((record) => {
-      createDnsRecord(record, {token, zoneId})
+    requestedRecords.forEach((requestedRecord) => {
+      existingRecords.filter(
+        (existingRecord) => existingRecord.name === requestedRecord.name
+      ).forEach((selectedRecord) => api.updateDnsRecord(
+        selectedRecord.id,
+        requestedRecord,
+        {token, zoneId}
+      ))
+
+      api.createDnsRecord(requestedRecord, {token, zoneId})
     })
   }
 }

src/record/dns_record_list.ts

@@ -0,0 +1,7 @@
+import { DnsRecord } from './dns_record.ts';
+
+export interface DnsRecordList extends DnsRecord {
+  
+  /** Id of the record */
+  id : string;
+}

src/request/url/index.ts

@@ -1,4 +1,4 @@
-import CustomError from '../../../error/custom_error.ts'
+import CustomError from '../../error/custom_error.ts'
 
 /**
  * This class represents a missing URL parameters error. This error is thrown if there is a missing URL parameter.

src/request/url/interface/update_request_url_parameters.ts

@@ -1,4 +1,4 @@
-import CustomError from '../../../error/custom_error.ts'
+import CustomError from '../../error/custom_error.ts'
 
 /**
  * This class represents a missing URL parameters error. This error is thrown if there is a missing URL parameter.

src/request/url/parameter/url_object.ts

@@ -0,0 +1,9 @@
+import parse from './parameter/parse.ts';
+
+const requestUrl = {
+  parse
+};
+
+export { parse }
+
+export default requestUrl;