3.0.6

.gitignore

@@ -1,6 +1,22 @@
+.nogit/
+
+# artifacts
 coverage/
-docs/
+public/
+pages/
+
+# installs
 node_modules/
 
-.nogit/
+# caches
-nogit/
+.yarn/
+.cache/
+.rpt2_cache
+
+# builds
+dist/
+dist_web/
+dist_serve/
+dist_ts_web/
+
+# custom

.gitlab-ci.yml

@@ -1,59 +1,126 @@
-image: hosttoday/ht-docker-node:npmts
+# gitzone ci_default
+image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+
+cache:
+  paths:
+    - .npmci_cache/
+  key: '$CI_BUILD_STAGE'
 
 stages:
-- test
+  - security
-- release
+  - test
-- trigger
+  - release
-- pages
+  - metadata
 
-testLEGACY:
+# ====================
-  stage: test
+# security stage
+# ====================
+mirror:
+  stage: security
   script:
-    - npmci test legacy
+    - npmci git mirror
   tags:
+    - lossless
     - docker
-  allow_failure: true
+    - notpriv
 
-testLTS:
+snyk:
+  image: registry.gitlab.com/hosttoday/ht-docker-node:snyk
+  stage: security
+  script:
+    - npmci npm prepare
+    - npmci command npm install --ignore-scripts
+    - npmci command snyk test
+  tags:
+    - lossless
+    - docker
+    - notpriv
+
+# ====================
+# test stage
+# ====================
+
+testStable:
   stage: test
   script:
-    - npmci test lts
+    - npmci npm prepare
+    - npmci node install stable
+    - npmci npm install
+    - npmci npm test
+  coverage: /\d+.?\d+?\%\s*coverage/
   tags:
+    - lossless
     - docker
-    
+    - priv
-testSTABLE:
+
+testBuild:
   stage: test
   script:
-    - npmci test stable
+    - npmci npm prepare
+    - npmci node install stable
+    - npmci npm install
+    - npmci command npm run build
+  coverage: /\d+.?\d+?\%\s*coverage/
   tags:
+    - lossless
     - docker
+    - notpriv
 
 release:
   stage: release
   script:
-    - npmci publish
+    - npmci node install stable
+    - npmci npm publish
   only:
     - tags
   tags:
+    - lossless
     - docker
+    - notpriv
+
+# ====================
+# metadata stage
+# ====================
+codequality:
+  stage: metadata
+  allow_failure: true
+  script:
+    - npmci command npm install -g tslint typescript
+    - npmci npm prepare
+    - npmci npm install
+    - npmci command "tslint -c tslint.json ./ts/**/*.ts"
+  tags:
+    - lossless
+    - docker
+    - priv
 
 trigger:
-  stage: trigger
+  stage: metadata
   script:
     - npmci trigger
   only:
     - tags
   tags:
+    - lossless
     - docker
+    - notpriv
 
 pages:
-  image: hosttoday/ht-docker-node:npmpage
+  stage: metadata
-  stage: pages
   script:
-    - npmci command npmpage --publish gitlab
+    - npmci node install lts
+    - npmci command npm install -g @gitzone/tsdoc
+    - npmci npm prepare
+    - npmci npm install
+    - npmci command tsdoc
+  tags:
+    - lossless
+    - docker
+    - notpriv
   only:
     - tags
   artifacts:
     expire_in: 1 week
     paths:
-    - public
+      - public
+  allow_failure: true

.travis.yml

@@ -1,12 +0,0 @@
-language: node_js
-node_js:
-- '4'
-- stable
-deploy:
-  provider: npm
-  email: npm@lossless.digital
-  api_key:
-    secure: uWqO634z8xMWI8tcIpSvUeVeG4ypX5fppXWxrSKbO5zOHCHGqJK90XiGFfKUekMf0cYQPb5dLT5+J/3nd4mf4KtU3+v1OK6ZikEqn/PcSeqOmK7EnI9wDFZwDTgJWIn0lRwX2mfB9meblSZ7XthTXumX78fmRTyeyImLm9P0ak+CrNzs8rzKauBoqeVryOez4/LaH3f0kxSz7o7zYLxFqx5xjQ7TFqd1kkVTf4pSQanLHY3z+7+mKrkbcNVxx2gF76hyx6E4pntSJHrOEE/VU/KMk2B6yzrVWYUHUiSRGYOV9U17YaaWlC9DZmnS1cvYcqq3YNujTwPWtci3It9S98hLrSTnCCqin6xhj8IuV6U4WADiXOUvNKuTRcd0/leQ4w3xpPJ1FR2gRtEhwQ0NsnY0vL9tuRAW71lf31122TTJI8lJQNrnaeIGbX7eE0Pq0jeTpmM2W/Tl8pl6s6zBjlEC/mCynQq1pBiz7UmxMYCPE162I8V5USeZOBLzDPZV2y7hmPWjMrWTT+i/IpFmXHjQtVrwlyU6fCOeYHgK/5GdyhnrRYYlx+ce6pCn4tmkVxduimC3m1G8cTkPl00fIpy7KSVcaeQrc1N+KQUqK4FpIjeqB904SVPsI5v3P7sdobaT1aqFqszhR+JK5tXaoesew8R2RncjFK69J7DHJWk=
-  on:
-    tags: true
-    repo: pushrocks/cflare

.vscode/launch.json

@@ -0,0 +1,29 @@
+{
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "name": "current file",
+      "type": "node",
+      "request": "launch",
+      "args": [
+        "${relativeFile}"
+      ],
+      "runtimeArgs": ["-r", "@gitzone/tsrun"],
+      "cwd": "${workspaceRoot}",
+      "protocol": "inspector",
+      "internalConsoleOptions": "openOnSessionStart"
+    },
+    {
+      "name": "test.ts",
+      "type": "node",
+      "request": "launch",
+      "args": [
+        "test/test.ts"
+      ],
+      "runtimeArgs": ["-r", "@gitzone/tsrun"],
+      "cwd": "${workspaceRoot}",
+      "protocol": "inspector",
+      "internalConsoleOptions": "openOnSessionStart"
+    }
+  ]
+}

.vscode/settings.json

@@ -0,0 +1,26 @@
+{
+  "json.schemas": [
+    {
+      "fileMatch": ["/npmextra.json"],
+      "schema": {
+        "type": "object",
+        "properties": {
+          "npmci": {
+            "type": "object",
+            "description": "settings for npmci"
+          },
+          "gitzone": {
+            "type": "object",
+            "description": "settings for gitzone",
+            "properties": {
+              "projectType": {
+                "type": "string",
+                "enum": ["website", "element", "service", "npm"]
+              }
+            }
+          }
+        }
+      }
+    }
+  ]
+}

README.md

@@ -1,31 +0,0 @@
-# cflare
-allows you to manage multiple cloudflare accounts.
-
-> Note: this package is still in alpha, so some things do not yet work.
-I (Phil from Lossless) expect this package to be ready 1. of June 2016.
-
-## Status
-[![Build Status](https://travis-ci.org/pushrocks/cflare.svg?branch=master)](https://travis-ci.org/pushrocks/cflare)
-
-## Usage
-
-```javascript
-var cflare = require("cflare");
-var cflareInstance = new cflare();
-
-cflareInstance.auth({
-    email:"",
-    key:""
-});
-
-cflareInstance.createRecord(); // returns promise with resolve function getting the response;
-cflareInstance.removeRecord(); // returns promise with resolve function getting the response;
-cflareInstance.copyRecord(); // returns promise with resolve function getting the response;
-cflareInstance.listRecords(); // returns promise with resolve function getting the response;
-cflareInstance.listDomains(); // returns promise with resolve function getting the response;
-```
-
-### About the authors:
-[![Project Phase](https://mediaserve.lossless.digital/lossless.com/img/createdby_github.svg)](https://lossless.com/)
-
-[![Gitter](https://img.shields.io/badge/Support%20us-PayPal-blue.svg)](https://paypal.me/lossless)

dist/cflare.classes.cflareaccount.d.ts

@@ -1,20 +0,0 @@
-import 'typings-global';
-import * as interfaces from './cflare.interfaces';
-export declare class CflareAccount {
-    private authEmail;
-    private authKey;
-    constructor();
-    auth(optionsArg: {
-        email: string;
-        key: string;
-    }): void;
-    getZoneId(domainName: string): Promise<{}>;
-    getRecord(domainNameArg: string, typeArg: string): Promise<interfaces.ICflareRecord>;
-    createRecord(domainNameArg: string, typeArg: string, contentArg: string): Promise<{}>;
-    removeRecord(domainNameArg: string, typeArg: string): Promise<{}>;
-    updateRecord(domainNameArg: string, typeArg: string, valueArg: any): Promise<{}>;
-    listRecords(domainNameArg: string): Promise<interfaces.ICflareRecord[]>;
-    listZones(domainName?: string): Promise<interfaces.ICflareZone[]>;
-    request(methodArg: string, routeArg: string, dataArg?: {}): Promise<{}>;
-    private authCheck();
-}

dist/cflare.classes.helpers.d.ts

@@ -1 +0,0 @@
-import "typings-global";

dist/cflare.classes.helpers.js

@@ -1,3 +0,0 @@
-"use strict";
-require("typings-global");
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY2ZsYXJlLmNsYXNzZXMuaGVscGVycy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL2NmbGFyZS5jbGFzc2VzLmhlbHBlcnMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLDBCQUF3QiJ9

dist/cflare.interfaces.d.ts

@@ -1,56 +0,0 @@
-export interface ICflareZone {
-    "id": string;
-    "name": string;
-    "development_mode": number;
-    "original_name_servers": string[];
-    "original_registrar": string;
-    "original_dnshost": string;
-    "created_on": string;
-    "modified_on": string;
-    "name_servers": string[];
-    "owner": {
-        "id": string;
-        "email": string;
-        "owner_type": string;
-    };
-    "permissions": string[];
-    "plan": {
-        "id": string;
-        "name": string;
-        "price": number;
-        "currency": string;
-        "frequency": string;
-        "legacy_id": string;
-        "is_subscribed": boolean;
-        "can_subscribe": boolean;
-    };
-    "plan_pending": {
-        "id": string;
-        "name": string;
-        "price": number;
-        "currency": string;
-        "frequency": string;
-        "legacy_id": string;
-        "is_subscribed": string;
-        "can_subscribe": string;
-    };
-    "status": string;
-    "paused": boolean;
-    "type": string;
-    "checked_on": string;
-}
-export interface ICflareRecord {
-    "id": string;
-    "type": string;
-    "name": string;
-    "content": string;
-    "proxiable": boolean;
-    "proxied": boolean;
-    "ttl": number;
-    "locked": boolean;
-    "zone_id": string;
-    "zone_name": string;
-    "created_on": string;
-    "modified_on": string;
-    "data": any;
-}

dist/cflare.interfaces.js

@@ -1,2 +0,0 @@
-"use strict";
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY2ZsYXJlLmludGVyZmFjZXMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9jZmxhcmUuaW50ZXJmYWNlcy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiIn0=

dist/cflare.plugins.d.ts

@@ -1,6 +0,0 @@
-import "typings-global";
-export declare let beautylog: any;
-export import q = require("smartq");
-export import smartrequest = require("smartrequest");
-export import smartstring = require("smartstring");
-export import smartdelay = require('smartdelay');

dist/cflare.plugins.js

@@ -1,8 +0,0 @@
-"use strict";
-require("typings-global");
-exports.beautylog = require("beautylog");
-exports.q = require("smartq");
-exports.smartrequest = require("smartrequest");
-exports.smartstring = require("smartstring");
-exports.smartdelay = require("smartdelay");
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY2ZsYXJlLnBsdWdpbnMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9jZmxhcmUucGx1Z2lucy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsMEJBQXdCO0FBQ2IsUUFBQSxTQUFTLEdBQUcsT0FBTyxDQUFDLFdBQVcsQ0FBQyxDQUFDO0FBQzVDLDhCQUFvQztBQUNwQywrQ0FBcUQ7QUFDckQsNkNBQW1EO0FBQ25ELDJDQUFpRCJ9

dist/index.d.ts

@@ -1,2 +0,0 @@
-import "typings-global";
-export { CflareAccount } from "./cflare.classes.cflareaccount";

dist/index.js

@@ -1,5 +0,0 @@
-"use strict";
-require("typings-global");
-var cflare_classes_cflareaccount_1 = require("./cflare.classes.cflareaccount");
-exports.CflareAccount = cflare_classes_cflareaccount_1.CflareAccount;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsMEJBQXdCO0FBQ3hCLCtFQUE2RDtBQUFyRCx1REFBQSxhQUFhLENBQUEifQ==

npmextra.json

@@ -0,0 +1,17 @@
+{
+  "npmci": {
+    "npmGlobalTools": [],
+    "npmAccessLevel": "public"
+  },
+  "gitzone": {
+    "projectType": "npm",
+    "module": {
+      "githost": "gitlab.com",
+      "gitscope": "mojoio",
+      "gitrepo": "cloudflare",
+      "shortDescription": "easy cloudflare management",
+      "npmPackagename": "@mojoio/cloudflare",
+      "license": "MIT"
+    }
+  }
+}

package.json

@@ -1,38 +1,55 @@
 {
-  "name": "cflare",
+  "name": "@mojoio/cloudflare",
-  "version": "0.0.15",
+  "version": "3.0.6",
-  "description": "cloudflare management for CoreOS",
+  "private": false,
+  "description": "easy cloudflare management",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
   "scripts": {
-    "test": "(npmts)"
+    "test": "(tstest test/)",
+    "build": "(tsbuild)"
   },
   "repository": {
     "type": "git",
-    "url": "git+https://github.com/pushrocks/cflare.git"
+    "url": "git+https://gitlab.com/pushrocks/cflare.git"
   },
   "keywords": [
-    "CoreOS",
+    "Push.Rocks",
     "cloudflare"
   ],
   "author": "Lossless GmbH",
   "license": "MIT",
   "bugs": {
-    "url": "https://github.com/pushrocks/cflare/issues"
+    "url": "https://gitlab.com/pushrocks/cflare/issues"
   },
-  "homepage": "https://github.com/pushrocks/cflare#readme",
+  "homepage": "https://gitlab.com/pushrocks/cflare#readme",
   "dependencies": {
-    "beautylog": "^6.1.1",
+    "@pushrocks/smartdelay": "^2.0.6",
-    "smartdelay": "^1.0.1",
+    "@pushrocks/smartlog": "^2.0.21",
-    "smartq": "^1.1.0",
+    "@pushrocks/smartpromise": "^3.0.6",
-    "smartrequest": "^1.0.4",
+    "@pushrocks/smartrequest": "^1.1.47",
-    "smartstring": "^2.0.22",
+    "@pushrocks/smartstring": "^3.0.18",
-    "typings-global": "^1.0.14"
+    "@tsclass/tsclass": "^3.0.4"
   },
   "devDependencies": {
-    "npmts-g": "^6.0.0",
+    "@gitzone/tsbuild": "^2.1.17",
-    "qenv": "^1.1.3",
+    "@gitzone/tsrun": "^1.2.8",
-    "smartchai": "^1.0.1",
+    "@gitzone/tstest": "^1.0.28",
-    "typings-test": "^1.0.3"
+    "@pushrocks/qenv": "^4.0.6",
-  }
+    "@pushrocks/tapbundle": "^3.2.0",
+    "@types/node": "^13.7.0",
+    "tslint": "^6.0.0",
+    "tslint-config-prettier": "^1.18.0"
+  },
+  "files": [
+    "ts/**/*",
+    "ts_web/**/*",
+    "dist/**/*",
+    "dist_web/**/*",
+    "dist_ts_web/**/*",
+    "assets/**/*",
+    "cli.js",
+    "npmextra.json",
+    "readme.md"
+  ]
 }

qenv.yml

@@ -1,3 +1,3 @@
-vars:
+required:
   - CF_EMAIL
   - CF_KEY

test/test.d.ts

@@ -1 +0,0 @@
-import 'typings-test';

test/test.js

@@ -1,88 +0,0 @@
-"use strict";
-require("typings-test");
-const cflare = require("../dist/index");
-const qenv_1 = require("qenv");
-let testQenv = new qenv_1.Qenv(process.cwd(), process.cwd() + '/.nogit');
-console.log(testQenv.missingEnvVars);
-let testCflareAccount = new cflare.CflareAccount();
-testCflareAccount.auth({
-    email: process.env.CF_EMAIL,
-    key: process.env.CF_KEY
-});
-describe('cflare', function () {
-    describe('.CflareAccount', function () {
-        describe('.listZones()', function () {
-            it('should display an entire account', function (done) {
-                this.timeout(600000);
-                testCflareAccount.listZones()
-                    .then((responseArg) => {
-                    done();
-                });
-            });
-        });
-        describe('.getZoneId(domainName)', function () {
-            it('should get an Cloudflare Id for a domain string', function (done) {
-                this.timeout(600000);
-                testCflareAccount.getZoneId('bleu.de')
-                    .then((responseArg) => {
-                    done();
-                });
-            });
-        });
-        describe('.listRecords(domainName)', function () {
-            it('should list all records for a specific Domain Name', function (done) {
-                this.timeout(600000);
-                testCflareAccount.listRecords('bleu.de')
-                    .then((responseArg) => {
-                    console.log(responseArg);
-                    done();
-                });
-            });
-        });
-        describe('.createRecord', function () {
-            it('should create a valid record for a level 2 domain', function (done) {
-                this.timeout(600000);
-                testCflareAccount.createRecord('bleu.de', 'A', '127.0.0.1')
-                    .then(function (responseArg) {
-                    done();
-                });
-            });
-            it('should create a valid record for a subdomain', function (done) {
-                this.timeout(600000);
-                testCflareAccount.createRecord('subdomain.bleu.de', 'A', '127.0.0.1')
-                    .then(function (responseArg) {
-                    done();
-                });
-            });
-        });
-        describe('.getRecord', function () {
-            it('should get a record from Cloudflare', function (done) {
-                this.timeout(600000);
-                testCflareAccount.getRecord('bleu.de', 'A')
-                    .then(function (responseArg) {
-                    console.log(responseArg);
-                    done();
-                });
-            });
-        });
-        describe('.removeRecord', function () {
-            it('should remove a record from Cloudflare', function (done) {
-                this.timeout(600000);
-                testCflareAccount.removeRecord('bleu.de', 'A')
-                    .then(function (responseArg) {
-                    console.log(responseArg);
-                    done();
-                });
-            });
-            it('should remove a subdomain record from Cloudflare', function (done) {
-                this.timeout(600000);
-                testCflareAccount.removeRecord('subdomain.bleu.de', 'A')
-                    .then(function (responseArg) {
-                    console.log(responseArg);
-                    done();
-                });
-            });
-        });
-    });
-});
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHdCQUFxQjtBQUNyQix3Q0FBd0M7QUFFeEMsK0JBQTJCO0FBQzNCLElBQUksUUFBUSxHQUFHLElBQUksV0FBSSxDQUFDLE9BQU8sQ0FBQyxHQUFHLEVBQUUsRUFBRSxPQUFPLENBQUMsR0FBRyxFQUFFLEdBQUcsU0FBUyxDQUFDLENBQUE7QUFDakUsT0FBTyxDQUFDLEdBQUcsQ0FBQyxRQUFRLENBQUMsY0FBYyxDQUFDLENBQUE7QUFDcEMsSUFBSSxpQkFBaUIsR0FBRyxJQUFJLE1BQU0sQ0FBQyxhQUFhLEVBQUUsQ0FBQTtBQUNsRCxpQkFBaUIsQ0FBQyxJQUFJLENBQUM7SUFDbkIsS0FBSyxFQUFFLE9BQU8sQ0FBQyxHQUFHLENBQUMsUUFBUTtJQUMzQixHQUFHLEVBQUUsT0FBTyxDQUFDLEdBQUcsQ0FBQyxNQUFNO0NBQzFCLENBQUMsQ0FBQTtBQUVGLFFBQVEsQ0FBQyxRQUFRLEVBQUU7SUFDZixRQUFRLENBQUMsZ0JBQWdCLEVBQUU7UUFDdkIsUUFBUSxDQUFDLGNBQWMsRUFBRTtZQUNyQixFQUFFLENBQUMsa0NBQWtDLEVBQUUsVUFBVSxJQUFJO2dCQUNqRCxJQUFJLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFBO2dCQUNwQixpQkFBaUIsQ0FBQyxTQUFTLEVBQUU7cUJBQ3hCLElBQUksQ0FBQyxDQUFDLFdBQVc7b0JBQ2QsSUFBSSxFQUFFLENBQUE7Z0JBQ1YsQ0FBQyxDQUFDLENBQUE7WUFDVixDQUFDLENBQUMsQ0FBQTtRQUNOLENBQUMsQ0FBQyxDQUFBO1FBQ0YsUUFBUSxDQUFDLHdCQUF3QixFQUFFO1lBQy9CLEVBQUUsQ0FBQyxpREFBaUQsRUFBRSxVQUFVLElBQUk7Z0JBQ2hFLElBQUksQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUE7Z0JBQ3BCLGlCQUFpQixDQUFDLFNBQVMsQ0FBQyxTQUFTLENBQUM7cUJBQ2pDLElBQUksQ0FBQyxDQUFDLFdBQVc7b0JBQ2QsSUFBSSxFQUFFLENBQUE7Z0JBQ1YsQ0FBQyxDQUFDLENBQUE7WUFDVixDQUFDLENBQUMsQ0FBQTtRQUNOLENBQUMsQ0FBQyxDQUFBO1FBQ0YsUUFBUSxDQUFDLDBCQUEwQixFQUFFO1lBQ2pDLEVBQUUsQ0FBQyxvREFBb0QsRUFBRSxVQUFVLElBQUk7Z0JBQ25FLElBQUksQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUE7Z0JBQ3BCLGlCQUFpQixDQUFDLFdBQVcsQ0FBQyxTQUFTLENBQUM7cUJBQ25DLElBQUksQ0FBQyxDQUFDLFdBQVc7b0JBQ2QsT0FBTyxDQUFDLEdBQUcsQ0FBQyxXQUFXLENBQUMsQ0FBQTtvQkFDeEIsSUFBSSxFQUFFLENBQUE7Z0JBQ1YsQ0FBQyxDQUFDLENBQUE7WUFDVixDQUFDLENBQUMsQ0FBQTtRQUNOLENBQUMsQ0FBQyxDQUFBO1FBQ0YsUUFBUSxDQUFDLGVBQWUsRUFBRTtZQUN0QixFQUFFLENBQUMsbURBQW1ELEVBQUUsVUFBVSxJQUFJO2dCQUNsRSxJQUFJLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFBO2dCQUNwQixpQkFBaUIsQ0FBQyxZQUFZLENBQUMsU0FBUyxFQUFFLEdBQUcsRUFBRSxXQUFXLENBQUM7cUJBQ3RELElBQUksQ0FBQyxVQUFVLFdBQVc7b0JBQ3ZCLElBQUksRUFBRSxDQUFBO2dCQUNWLENBQUMsQ0FBQyxDQUFBO1lBQ1YsQ0FBQyxDQUFDLENBQUE7WUFDRixFQUFFLENBQUMsOENBQThDLEVBQUUsVUFBVSxJQUFJO2dCQUM3RCxJQUFJLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFBO2dCQUNwQixpQkFBaUIsQ0FBQyxZQUFZLENBQUMsbUJBQW1CLEVBQUUsR0FBRyxFQUFFLFdBQVcsQ0FBQztxQkFDaEUsSUFBSSxDQUFDLFVBQVUsV0FBVztvQkFDdkIsSUFBSSxFQUFFLENBQUE7Z0JBQ1YsQ0FBQyxDQUFDLENBQUE7WUFDVixDQUFDLENBQUMsQ0FBQTtRQUNOLENBQUMsQ0FBQyxDQUFBO1FBQ0YsUUFBUSxDQUFDLFlBQVksRUFBRTtZQUNuQixFQUFFLENBQUMscUNBQXFDLEVBQUUsVUFBVSxJQUFJO2dCQUNwRCxJQUFJLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFBO2dCQUNwQixpQkFBaUIsQ0FBQyxTQUFTLENBQUMsU0FBUyxFQUFFLEdBQUcsQ0FBQztxQkFDdEMsSUFBSSxDQUFDLFVBQVUsV0FBVztvQkFDdkIsT0FBTyxDQUFDLEdBQUcsQ0FBQyxXQUFXLENBQUMsQ0FBQTtvQkFDeEIsSUFBSSxFQUFFLENBQUE7Z0JBQ1YsQ0FBQyxDQUFDLENBQUE7WUFDVixDQUFDLENBQUMsQ0FBQTtRQUNOLENBQUMsQ0FBQyxDQUFBO1FBQ0YsUUFBUSxDQUFDLGVBQWUsRUFBRTtZQUN0QixFQUFFLENBQUMsd0NBQXdDLEVBQUUsVUFBVSxJQUFJO2dCQUN2RCxJQUFJLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFBO2dCQUNwQixpQkFBaUIsQ0FBQyxZQUFZLENBQUMsU0FBUyxFQUFFLEdBQUcsQ0FBQztxQkFDekMsSUFBSSxDQUFDLFVBQVUsV0FBVztvQkFDdkIsT0FBTyxDQUFDLEdBQUcsQ0FBQyxXQUFXLENBQUMsQ0FBQTtvQkFDeEIsSUFBSSxFQUFFLENBQUE7Z0JBQ1YsQ0FBQyxDQUFDLENBQUE7WUFDVixDQUFDLENBQUMsQ0FBQTtZQUNGLEVBQUUsQ0FBQyxrREFBa0QsRUFBRSxVQUFVLElBQUk7Z0JBQ2pFLElBQUksQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUE7Z0JBQ3BCLGlCQUFpQixDQUFDLFlBQVksQ0FBQyxtQkFBbUIsRUFBRSxHQUFHLENBQUM7cUJBQ25ELElBQUksQ0FBQyxVQUFVLFdBQVc7b0JBQ3ZCLE9BQU8sQ0FBQyxHQUFHLENBQUMsV0FBVyxDQUFDLENBQUE7b0JBQ3hCLElBQUksRUFBRSxDQUFBO2dCQUNWLENBQUMsQ0FBQyxDQUFBO1lBQ1YsQ0FBQyxDQUFDLENBQUE7UUFDTixDQUFDLENBQUMsQ0FBQTtJQUNOLENBQUMsQ0FBQyxDQUFBO0FBQ04sQ0FBQyxDQUFDLENBQUEifQ==

test/test.ts

@@ -1,88 +1,91 @@
-import 'typings-test'
+// tslint:disable-next-line: no-implicit-dependencies
-import cflare = require('../dist/index')
+import { expect, tap } from '@pushrocks/tapbundle';
-import { expect } from 'smartchai'
+// tslint:disable-next-line: no-implicit-dependencies
-import { Qenv } from 'qenv'
+import { Qenv } from '@pushrocks/qenv';
-let testQenv = new Qenv(process.cwd(), process.cwd() + '/.nogit')
-console.log(testQenv.missingEnvVars)
-let testCflareAccount = new cflare.CflareAccount()
-testCflareAccount.auth({
-    email: process.env.CF_EMAIL,
-    key: process.env.CF_KEY
-})
 
-describe('cflare', function () {
+import cloudflare = require('../ts/index');
-    describe('.CflareAccount', function () {
+
-        describe('.listZones()', function () {
+const testQenv = new Qenv(process.cwd(), process.cwd() + '/.nogit');
-            it('should display an entire account', function (done) {
+
-                this.timeout(600000)
+const randomPrefix = Math.floor(Math.random() * 2000);
-                testCflareAccount.listZones()
+let testCloudflareAccount: cloudflare.CloudflareAccount;
-                    .then((responseArg) => {
+
-                        done()
+tap.test('should create a valid instance of CloudflareAccount', async () => {
-                    })
+  testCloudflareAccount = new cloudflare.CloudflareAccount({
-            })
+    email: testQenv.getEnvVarOnDemand('CF_EMAIL'),
-        })
+    key: testQenv.getEnvVarOnDemand('CF_KEY')
-        describe('.getZoneId(domainName)', function () {
+  });
-            it('should get an Cloudflare Id for a domain string', function (done) {
+});
-                this.timeout(600000)
+
-                testCflareAccount.getZoneId('bleu.de')
+tap.test('.listZones() -> should display an entire account', async tools => {
-                    .then((responseArg) => {
+  tools.timeout(600000);
-                        done()
+  const result = await testCloudflareAccount.listZones();
-                    })
+  console.log(result);
-            })
+});
-        })
+
-        describe('.listRecords(domainName)', function () {
+tap.test(
-            it('should list all records for a specific Domain Name', function (done) {
+  '.getZoneId(domainName) -> should get an Cloudflare Id for a domain string',
-                this.timeout(600000)
+  async tools => {
-                testCflareAccount.listRecords('bleu.de')
+    tools.timeout(600000);
-                    .then((responseArg) => {
+    await testCloudflareAccount.getZoneId('bleu.de');
-                        console.log(responseArg)
+  }
-                        done()
+);
-                    })
+
-            })
+tap.test(
-        })
+  '.listRecords(domainName) -> should list all records for a specific Domain Name',
-        describe('.createRecord', function () {
+  async tools => {
-            it('should create a valid record for a level 2 domain', function (done) {
+    tools.timeout(600000);
-                this.timeout(600000)
+    await testCloudflareAccount.listRecords('bleu.de').then(async responseArg => {
-                testCflareAccount.createRecord('bleu.de', 'A', '127.0.0.1')
+      console.log(responseArg);
-                    .then(function (responseArg) {
+    });
-                        done()
+  }
-                    })
+);
-            })
+
-            it('should create a valid record for a subdomain', function (done) {
+tap.test('should create a valid record for a subdomain', async tools => {
-                this.timeout(600000)
+  tools.timeout(600000);
-                testCflareAccount.createRecord('subdomain.bleu.de', 'A', '127.0.0.1')
+  await testCloudflareAccount.createRecord(`${randomPrefix}subdomain.bleu.de`, 'A', '127.0.0.1');
-                    .then(function (responseArg) {
+});
-                        done()
+
-                    })
+tap.test('should get a record from Cloudflare', async tools => {
-            })
+  tools.timeout(600000);
-        })
+  await testCloudflareAccount
-        describe('.getRecord', function () {
+    .getRecord(`${randomPrefix}subdomain.bleu.de`, 'A')
-            it('should get a record from Cloudflare', function (done) {
+    .then(responseArg => {
-                this.timeout(600000)
+      console.log(responseArg);
-                testCflareAccount.getRecord('bleu.de', 'A')
+    });
-                    .then(function (responseArg) {
+});
-                        console.log(responseArg)
+
-                        done()
+tap.test('should remove a subdomain record from Cloudflare', async tools => {
-                    })
+  tools.timeout(600000);
-            })
+  await testCloudflareAccount
-        })
+    .removeRecord(`${randomPrefix}subdomain.bleu.de`, 'A')
-        describe('.removeRecord', function () {
+    .then(async responseArg => {
-            it('should remove a record from Cloudflare', function (done) {
+      console.log(responseArg);
-                this.timeout(600000)
+    });
-                testCflareAccount.removeRecord('bleu.de', 'A')
+});
-                    .then(function (responseArg) {
+
-                        console.log(responseArg)
+tap.test('.purge(some.domain) -> should purge everything', async () => {
-                        done()
+  await testCloudflareAccount.purgeZone('bleu.de');
-                    })
+});
-            })
+
-            it('should remove a subdomain record from Cloudflare', function (done) {
+// WORKERS
-                this.timeout(600000)
+tap.test('should create a worker', async () => {
-                testCflareAccount.removeRecord('subdomain.bleu.de', 'A')
+  const worker = await testCloudflareAccount.workerManager.createWorker(
-                    .then(function (responseArg) {
+    'myawesomescript',
-                        console.log(responseArg)
+    `addEventListener('fetch', event => { event.respondWith(fetch(event.request)) })`
-                        done()
+  );
-                    })
+  await worker.setRoutes([
-            })
+    {
-        })
+      zoneName: 'bleu.de',
-    })
+      pattern: 'https://*bleu.de/hello'
-})
+    }
+  ]);
+  console.log(worker);
+});
+
+tap.test('should get workers', async () => {
+  const workerArray = await testCloudflareAccount.workerManager.listWorkers();
+  console.log(workerArray);
+});
+
+tap.start();

ts/cflare.classes.cflareaccount.ts

@@ -1,159 +0,0 @@
-import 'typings-global';
-import plugins = require('./cflare.plugins')
-import helpers = require('./cflare.classes.helpers')
-import * as interfaces from './cflare.interfaces'
-
-export class CflareAccount {
-    private authEmail: string
-    private authKey: string
-    constructor() {
-
-    }
-
-    auth(optionsArg: { email: string, key: string }) {
-        this.authEmail = optionsArg.email
-        this.authKey = optionsArg.key
-    }
-
-    getZoneId(domainName: string) {
-        let done = plugins.q.defer()
-        this.listZones(domainName)
-            .then(zoneArrayArg => {
-                let filteredResponse = zoneArrayArg.filter((zoneArg) => {
-                    return zoneArg.name === domainName
-                })
-                if (filteredResponse.length >= 1) {
-                    done.resolve(filteredResponse[ 0 ].id)
-                } else {
-                    plugins.beautylog.error(`the domain ${domainName} does not appear to be in this account!`)
-                    done.reject(undefined)
-                }
-            })
-        return done.promise
-    }
-    getRecord(domainNameArg: string, typeArg: string): Promise<interfaces.ICflareRecord> {
-        let done = plugins.q.defer()
-        let result: interfaces.ICflareRecord
-
-        let domain = new plugins.smartstring.Domain(domainNameArg)
-        this.listRecords(domain.zoneName)
-            .then((recordArrayArg) => {
-                let filteredResponse = recordArrayArg.filter((recordArg) => {
-                    return (recordArg.type === typeArg && recordArg.name === domainNameArg)
-                })
-                done.resolve(filteredResponse[ 0 ])
-            })
-        return done.promise
-    };
-    createRecord(domainNameArg: string, typeArg: string, contentArg: string) {
-        let done = plugins.q.defer()
-        let domain = new plugins.smartstring.Domain(domainNameArg)
-        this.getZoneId(domain.zoneName)
-            .then((domainIdArg) => {
-                let dataObject = {
-                    name: domain.fullName,
-                    type: typeArg,
-                    content: contentArg
-                }
-                this.request('POST', '/zones/' + domainIdArg + '/dns_records', dataObject)
-                    .then(function (responseArg) {
-                        done.resolve(responseArg)
-                    })
-            })
-        return done.promise
-    };
-    removeRecord(domainNameArg: string, typeArg: string) {
-        let done = plugins.q.defer()
-        let domain = new plugins.smartstring.Domain(domainNameArg)
-        this.getRecord(domain.fullName, typeArg)
-            .then((responseArg) => {
-                if (responseArg) {
-                    let requestRoute: string = '/zones/' + responseArg.zone_id + '/dns_records/' + responseArg.id
-                    this.request('DELETE', requestRoute)
-                        .then((responseArg) => {
-                            done.resolve(responseArg)
-                        })
-                } else {
-                    done.reject()
-                }
-            })
-        return done.promise
-    };
-    updateRecord(domainNameArg: string, typeArg: string, valueArg) {
-        let done = plugins.q.defer()
-        let domain = new plugins.smartstring.Domain(domainNameArg)
-        return done.promise
-    };
-    listRecords(domainNameArg: string): Promise<interfaces.ICflareRecord[]> {
-        let done = plugins.q.defer<interfaces.ICflareRecord[]>()
-        let result: interfaces.ICflareRecord[] = []
-
-        let domain = new plugins.smartstring.Domain(domainNameArg)
-        this.getZoneId(domain.zoneName)
-            .then((domainIdArg) => {
-                this.request('GET', '/zones/' + domainIdArg + '/dns_records?per_page=100')
-                    .then(function (responseArg: any) {
-                        result = responseArg.result
-                        done.resolve(result)
-                    })
-            })
-        return done.promise
-    }
-    listZones(domainName?: string): Promise<interfaces.ICflareZone[]> { // TODO: handle pagination
-        let done = plugins.q.defer<interfaces.ICflareZone[]>()
-        let requestRoute = '/zones?per_page=50'
-        if (domainName) requestRoute = requestRoute + '&name=' + domainName
-        let result = []
-        this.request('GET', requestRoute)
-            .then((responseArg: any) => {
-                result = responseArg.result
-                done.resolve(result)
-            })
-        return done.promise
-    };
-    request(methodArg: string, routeArg: string, dataArg = {}) {
-        let done = plugins.q.defer()
-        let jsonArg: string = JSON.stringify(dataArg)
-        let options: plugins.smartrequest.ISmartRequestOptions = {
-            method: methodArg,
-            headers: {
-                'Content-Type': 'application/json',
-                'X-Auth-Email': this.authEmail,
-                'X-Auth-Key': this.authKey
-            },
-            requestBody: jsonArg
-        }
-        // console.log(options);
-        let retryCount = 0
-
-        let makeRequest = async () => {
-            let response: any = await plugins.smartrequest.request(
-                `https://api.cloudflare.com/client/v4${routeArg}`,
-                options
-            )
-            if (response.statusCode === 200) {
-                done.resolve(response.body)
-            } else if (response.statusCode === 429) {
-                console.log('rate limited! Waiting for retry!')
-                retryRequest()
-            } else {
-                console.log(response.statusCode)
-                done.reject(new Error('request failed'))
-            }
-        }
-        let retryRequest = async (delayTimeArg = Math.floor(Math.random() * (60000 - 8000) + 8000)) => {
-            console.log(`retry started and waiting for ${delayTimeArg} ms`)
-            await plugins.smartdelay.delayFor(delayTimeArg)
-            if (retryCount < 10) {
-                retryCount++
-                return await makeRequest()
-            }
-        }
-        makeRequest()
-        return done.promise
-    }
-
-    private authCheck() {
-        return (this.authEmail && this.authKey) // check if auth is available
-    }
-}

ts/cflare.classes.helpers.ts

@@ -1,2 +0,0 @@
-import "typings-global";
-import plugins = require("./cflare.plugins");

ts/cflare.interfaces.ts

@@ -1,59 +0,0 @@
-import * as plugins from './cflare.plugins'
-
-export interface ICflareZone {
-    "id": string
-    "name": string
-    "development_mode": number
-    "original_name_servers": string[]
-    "original_registrar": string
-    "original_dnshost": string
-    "created_on": string
-    "modified_on": string
-    "name_servers": string[]
-    "owner": {
-        "id": string
-        "email": string
-        "owner_type": string
-    },
-    "permissions": string []
-    "plan": {
-        "id": string
-        "name": string
-        "price": number
-        "currency": string
-        "frequency": string
-        "legacy_id": string
-        "is_subscribed": boolean
-        "can_subscribe": boolean
-    },
-    "plan_pending": {
-        "id": string
-        "name": string
-        "price": number
-        "currency": string
-        "frequency": string
-        "legacy_id": string
-        "is_subscribed": string
-        "can_subscribe": string
-    },
-    "status": string
-    "paused": boolean
-    "type": string
-    "checked_on": string
-}
-
-export interface ICflareRecord {
-    "id": string
-    "type": string
-    "name": string
-    "content": string
-    "proxiable": boolean
-    "proxied": boolean
-    "ttl": number
-    "locked": boolean
-    "zone_id": string
-    "zone_name": string
-    "created_on": string
-    "modified_on": string
-    "data": any
-}

ts/cflare.plugins.ts

@@ -1,6 +0,0 @@
-import "typings-global";
-export let beautylog = require("beautylog");
-export import q = require("smartq");
-export import smartrequest = require("smartrequest");
-export import smartstring = require("smartstring");
-export import smartdelay = require('smartdelay');

ts/cloudflare.classes.account.ts

@@ -0,0 +1,228 @@
+import plugins = require('./cloudflare.plugins');
+import * as interfaces from './interfaces';
+
+// interfaces
+import { WorkerManager } from './cloudflare.classes.workermanager';
+import { ZoneManager } from './cloudflare.classes.zonemanager';
+
+export class CloudflareAccount {
+  private authEmail: string;
+  private authKey: string;
+  private accountIdentifier: string;
+
+  public workerManager = new WorkerManager(this);
+  public zoneManager = new ZoneManager(this);
+
+  /**
+   * constructor sets auth information on the CloudflareAccountInstance
+   * @param optionsArg
+   */
+  constructor(optionsArg: { email: string; key: string }) {
+    this.authEmail = optionsArg.email;
+    this.authKey = optionsArg.key;
+  }
+
+  public async getAccountIdentifier() {
+    if (!this.accountIdentifier) {
+      const route = `/accounts?page=1&per_page=20&direction=desc`;
+      const response: any = await this.request('GET', route);
+      this.accountIdentifier = response.result[0].id;
+      // console.log('Account identifier is: ' + this.accountIdentifier);
+    }
+    return this.accountIdentifier;
+  }
+
+  /**
+   * gets a zone id of a domain from cloudflare
+   * @param domainName
+   */
+  public async getZoneId(domainName: string) {
+    const domain = new plugins.smartstring.Domain(domainName);
+    const zoneArray = await this.listZones(domain.zoneName);
+    const filteredResponse = zoneArray.filter(zoneArg => {
+      return zoneArg.name === domainName;
+    });
+    if (filteredResponse.length >= 1) {
+      return filteredResponse[0].id;
+    } else {
+      plugins.smartlog.defaultLogger.log(
+        'error',
+        `the domain ${domainName} does not appear to be in this account!`
+      );
+      throw new Error(`the domain ${domainName} does not appear to be in this account!`);
+    }
+  }
+
+  /**
+   * gets a record
+   * @param domainNameArg
+   * @param typeArg
+   */
+  public async getRecord(
+    domainNameArg: string,
+    typeArg: plugins.tsclass.network.TDnsRecord
+  ): Promise<interfaces.ICflareRecord> {
+    const domain = new plugins.smartstring.Domain(domainNameArg);
+    const recordArrayArg = await this.listRecords(domain.zoneName);
+    const filteredResponse = recordArrayArg.filter(recordArg => {
+      return recordArg.type === typeArg && recordArg.name === domainNameArg;
+    });
+    return filteredResponse[0];
+  }
+
+  public async createRecord(
+    domainNameArg: string,
+    typeArg: plugins.tsclass.network.TDnsRecord,
+    contentArg: string
+  ): Promise<any> {
+    const domain = new plugins.smartstring.Domain(domainNameArg);
+    const domainIdArg = await this.getZoneId(domain.zoneName);
+    const dataObject = {
+      name: domain.fullName,
+      type: typeArg,
+      content: contentArg
+    };
+    const response = await this.request(
+      'POST',
+      '/zones/' + domainIdArg + '/dns_records',
+      dataObject
+    );
+    return response;
+  }
+
+  /**
+   * removes a record from Cloudflare
+   * @param domainNameArg
+   * @param typeArg
+   */
+  public async removeRecord(
+    domainNameArg: string,
+    typeArg: plugins.tsclass.network.TDnsRecord
+  ): Promise<any> {
+    const domain = new plugins.smartstring.Domain(domainNameArg);
+    const cflareRecord = await this.getRecord(domain.fullName, typeArg);
+    if (cflareRecord) {
+      const requestRoute: string = `/zones/${cflareRecord.zone_id}/dns_records/${cflareRecord.id}`;
+      return await this.request('DELETE', requestRoute);
+    } else {
+      throw new Error(`could not remove record for ${domainNameArg} with type ${typeArg}`);
+    }
+  }
+
+  /**
+   * updates a record
+   * @param domainNameArg
+   * @param typeArg
+   * @param valueArg
+   */
+  public updateRecord(domainNameArg: string, typeArg: string, valueArg) {
+    // TODO: implement
+    const done = plugins.smartpromise.defer();
+    const domain = new plugins.smartstring.Domain(domainNameArg);
+    return done.promise;
+  }
+
+  /**
+   * list all records of a specified domain name
+   * @param domainNameArg - the domain name that you want to get the records from
+   */
+  public async listRecords(domainNameArg: string): Promise<interfaces.ICflareRecord[]> {
+    const domain = new plugins.smartstring.Domain(domainNameArg);
+    const domainId = await this.getZoneId(domain.zoneName);
+    const responseArg: any = await this.request(
+      'GET',
+      '/zones/' + domainId + '/dns_records?per_page=100'
+    );
+    const result: interfaces.ICflareRecord[] = responseArg.result;
+    return result;
+  }
+
+  /**
+   * list all zones in the associated authenticated account
+   * @param domainName
+   */
+  public async listZones(domainName?: string): Promise<interfaces.ICflareZone[]> {
+    // TODO: handle pagination
+    let requestRoute = `/zones?per_page=50`;
+
+    // may be optionally filtered by domain name
+    if (domainName) {
+      requestRoute = `${requestRoute}&name=${domainName}`;
+    }
+
+    const response: any = await this.request('GET', requestRoute);
+    const result = response.result;
+    return result;
+  }
+
+  public async purgeZone(domainName: string) {
+    const domain = new plugins.smartstring.Domain(domainName);
+    const domainId = await this.getZoneId(domain.zoneName);
+    const requestUrl = `/zones/${domainId}/purge_cache`;
+    const payload = {
+      purge_everything: true
+    };
+    const respone = await this.request('DELETE', requestUrl, payload);
+  }
+
+  public request(
+    methodArg: string,
+    routeArg: string,
+    dataArg: any = {},
+    requestHeadersArg = {}
+  ): Promise<any> {
+    const done = plugins.smartpromise.defer();
+    const options: plugins.smartrequest.ISmartRequestOptions = {
+      method: methodArg,
+      headers: {
+        'Content-Type': 'application/json',
+        'X-Auth-Email': this.authEmail,
+        'X-Auth-Key': this.authKey,
+        'Content-Length': Buffer.byteLength(JSON.stringify(dataArg)),
+        ...requestHeadersArg
+      },
+      requestBody: dataArg
+    };
+
+    // console.log(options);
+
+    let retryCount = 0; // count the amount of retries
+
+    const makeRequest = async () => {
+      const response: any = await plugins.smartrequest.request(
+        `https://api.cloudflare.com/client/v4${routeArg}`,
+        options
+      );
+      if (response.statusCode === 200) {
+        done.resolve(response.body);
+      } else if (response.statusCode === 429) {
+        console.log('rate limited! Waiting for retry!');
+        retryRequest();
+      } else if (response.statusCode === 400) {
+        console.log(`bad request for route ${routeArg}! Going to retry!`);
+        console.log(response.body);
+      } else {
+        console.log(response.statusCode);
+        done.reject(new Error('request failed'));
+      }
+    };
+    const retryRequest = async (
+      delayTimeArg = Math.floor(Math.random() * (60000 - 8000) + 8000)
+    ) => {
+      console.log(`retry started and waiting for ${delayTimeArg} ms`);
+      await plugins.smartdelay.delayFor(delayTimeArg);
+      if (retryCount < 10) {
+        retryCount++;
+        return await makeRequest();
+      }
+    };
+    makeRequest();
+    return done.promise;
+  }
+
+  private authCheck() {
+    return this.authEmail && this.authKey; // check if auth is available
+  }
+
+  // acme convenience functions
+}

ts/cloudflare.classes.worker.ts

@@ -0,0 +1,92 @@
+import * as plugins from './cloudflare.plugins';
+import * as interfaces from './interfaces';
+import { WorkerManager } from './cloudflare.classes.workermanager';
+
+export interface IWorkerRoute extends interfaces.ICflareWorkerRoute {
+  zoneName: string;
+}
+
+export class CloudflareWorker {
+  // STATIC
+  public static async fromApiObject(
+    workerManager: WorkerManager,
+    apiObject
+  ): Promise<CloudflareWorker> {
+    const newWorker = new CloudflareWorker(workerManager);
+    Object.assign(newWorker, apiObject.result);
+    await newWorker.getRoutes();
+    return newWorker;
+  }
+
+  // INSTANCE
+  private workerManager: WorkerManager;
+
+  public script: string;
+  public id: string;
+  public etag: string;
+  // tslint:disable-next-line: variable-name
+  public created_on: string;
+  // tslint:disable-next-line: variable-name
+  public modified_on: string;
+
+  public routes: IWorkerRoute[] = [];
+  constructor(workerManagerArg: WorkerManager) {
+    this.workerManager = workerManagerArg;
+  }
+
+  /**
+   * gets all routes for a worker
+   */
+  public async getRoutes() {
+    const zones = await this.workerManager.cfAccount.listZones();
+    for (const zone of zones) {
+      const requestRoute = `/zones/${zone.id}/workers/routes`;
+      const response: {
+        result: interfaces.ICflareWorkerRoute[];
+      } = await this.workerManager.cfAccount.request('GET', requestRoute);
+      for (const route of response.result) {
+        console.log('hey');
+        console.log(route);
+        console.log(this.id);
+        if (route.script === this.id) {
+          this.routes.push({ ...route, zoneName: zone.name });
+        }
+      }
+    }
+  }
+
+  public async setRoutes(routeArray: Array<{ zoneName: string; pattern: string }>) {
+    for (const newRoute of routeArray) {
+      // lets determine wether a route is new, needs an update or already up to date.
+      let routeStatus: 'new' | 'needsUpdate' | 'alreadyUpToDate' = 'new';
+      let routeIdForUpdate: string;
+      for (const existingRoute of this.routes) {
+        if (existingRoute.pattern === newRoute.pattern) {
+          routeStatus = 'needsUpdate';
+          routeIdForUpdate = existingRoute.id;
+          if (existingRoute.script === this.id) {
+            routeStatus = 'alreadyUpToDate';
+            plugins.smartlog.defaultLogger.log('info', `route already exists, no update needed`);
+          }
+        }
+      }
+
+      // lets care about actually setting routes
+      if (routeStatus === 'new') {
+        const zoneId = await this.workerManager.cfAccount.getZoneId(newRoute.zoneName);
+        const requestRoute = `/zones/${zoneId}/workers/routes`;
+        await this.workerManager.cfAccount.request('POST', requestRoute, {
+          pattern: newRoute.pattern,
+          script: this.id
+        });
+      } else if (routeStatus === 'needsUpdate') {
+        const zoneId = await this.workerManager.cfAccount.getZoneId(newRoute.zoneName);
+        const requestRoute = `/zones/${zoneId}/workers/routes/${routeIdForUpdate}`;
+        await this.workerManager.cfAccount.request('PUT', requestRoute, {
+          pattern: newRoute.pattern,
+          script: this.id
+        });
+      }
+    }
+  }
+}

ts/cloudflare.classes.workermanager.ts

@@ -0,0 +1,36 @@
+import * as plugins from './cloudflare.plugins';
+import { CloudflareAccount } from './cloudflare.classes.account';
+import { CloudflareWorker } from './cloudflare.classes.worker';
+
+export class WorkerManager {
+  public cfAccount: CloudflareAccount;
+
+  constructor(cfAccountArg: CloudflareAccount) {
+    this.cfAccount = cfAccountArg;
+  }
+
+  public async createWorker(workerName: string, workerScript: string): Promise<CloudflareWorker> {
+    const accountIdentifier = await this.cfAccount.getAccountIdentifier();
+    const route = `/accounts/${accountIdentifier}/workers/scripts/${workerName}`;
+    const responseBody = await this.cfAccount.request('PUT', route, workerScript, {
+      'Content-Type': 'application/javascript',
+      'Content-Length': Buffer.byteLength(workerScript)
+    });
+    return CloudflareWorker.fromApiObject(this, responseBody);
+  }
+
+  /**
+   * lists workers
+   */
+  public async listWorkers() {
+    const accountIdentifier = await this.cfAccount.getAccountIdentifier();
+    const route = `/accounts/${accountIdentifier}/workers/scripts`;
+    const response = await this.cfAccount.request('GET', route);
+    const results = response.result;
+    const workers: CloudflareWorker[] = [];
+    for (const apiObject of results) {
+      workers.push(await CloudflareWorker.fromApiObject(this, apiObject));
+    }
+    return workers;
+  }
+}

ts/cloudflare.classes.zone.ts

@@ -0,0 +1,6 @@
+import * as plugins from './cloudflare.plugins';
+import * as interfaces from './interfaces';
+
+export class CloudflareZone {
+  // TODO
+}

ts/cloudflare.classes.zonemanager.ts

@@ -0,0 +1,11 @@
+import * as plugins from './cloudflare.plugins';
+import { CloudflareAccount } from './cloudflare.classes.account';
+
+export class ZoneManager {
+  public cfAccount: CloudflareAccount;
+  public zoneName: string;
+
+  constructor(cfAccountArg: CloudflareAccount) {
+    this.cfAccount = cfAccountArg;
+  }
+}

ts/cloudflare.plugins.ts

@@ -0,0 +1,8 @@
+import * as smartlog from '@pushrocks/smartlog';
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartdelay from '@pushrocks/smartdelay';
+import * as smartrequest from '@pushrocks/smartrequest';
+import * as smartstring from '@pushrocks/smartstring';
+import * as tsclass from '@tsclass/tsclass';
+
+export { smartlog, smartpromise, smartdelay, smartrequest, smartstring, tsclass };

ts/index.ts

@@ -1,2 +1,2 @@
-import "typings-global";
+export { CloudflareAccount } from './cloudflare.classes.account';
-export {CflareAccount} from "./cflare.classes.cflareaccount";
+export { CloudflareWorker } from './cloudflare.classes.worker';

ts/interfaces/cloudflare.api.record.ts

@@ -0,0 +1,15 @@
+export interface ICflareRecord {
+  id: string;
+  type: string;
+  name: string;
+  content: string;
+  proxiable: boolean;
+  proxied: boolean;
+  ttl: number;
+  locked: boolean;
+  zone_id: string;
+  zone_name: string;
+  created_on: string;
+  modified_on: string;
+  data: any;
+}

ts/interfaces/cloudflare.api.workerroute.ts

@@ -0,0 +1,5 @@
+export interface ICflareWorkerRoute {
+  id: string;
+  pattern: string;
+  script: string;
+}

ts/interfaces/cloudflare.api.zone.ts

@@ -0,0 +1,41 @@
+export interface ICflareZone {
+  id: string;
+  name: string;
+  development_mode: number;
+  original_name_servers: string[];
+  original_registrar: string;
+  original_dnshost: string;
+  created_on: string;
+  modified_on: string;
+  name_servers: string[];
+  owner: {
+    id: string;
+    email: string;
+    owner_type: string;
+  };
+  permissions: string[];
+  plan: {
+    id: string;
+    name: string;
+    price: number;
+    currency: string;
+    frequency: string;
+    legacy_id: string;
+    is_subscribed: boolean;
+    can_subscribe: boolean;
+  };
+  plan_pending: {
+    id: string;
+    name: string;
+    price: number;
+    currency: string;
+    frequency: string;
+    legacy_id: string;
+    is_subscribed: string;
+    can_subscribe: string;
+  };
+  status: string;
+  paused: boolean;
+  type: string;
+  checked_on: string;
+}

ts/interfaces/index.ts

@@ -0,0 +1,3 @@
+export * from './cloudflare.api.record';
+export * from './cloudflare.api.zone';
+export * from './cloudflare.api.workerroute';

tslint.json

@@ -1,3 +1,17 @@
 {
-    "extends": "tslint-config-standard"
+  "extends": ["tslint:latest", "tslint-config-prettier"],
+  "rules": {
+    "semicolon": [true, "always"],
+    "no-console": false,
+    "ordered-imports": false,
+    "object-literal-sort-keys": false,
+    "member-ordering": {
+      "options":{
+        "order": [
+          "static-method"
+        ]
+      }
+    }
+  },
+  "defaultSeverity": "warning"
 }