working API interface in Node

Author: tloen

daemonist/.gitignore

@@ -0,0 +1,90 @@
+build
+
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+
+# Diagnostic reports (https://nodejs.org/api/report.html)
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+*.lcov
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# TypeScript v1 declaration files
+typings/
+
+# TypeScript cache
+*.tsbuildinfo
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+.env.test
+
+# parcel-bundler cache (https://parceljs.org/)
+.cache
+
+# next.js build output
+.next
+
+# nuxt.js build output
+.nuxt
+
+# vuepress build output
+.vuepress/dist
+
+# Serverless directories
+.serverless/
+
+# FuseBox cache
+.fusebox/
+
+# DynamoDB Local files
+.dynamodb/

daemonist/package-lock.json

@@ -2,8 +2,9 @@
   "name": "daemonist",
   "version": "0.1.0",
   "description": "Makes dynalist dynamic.",
-  "main": "index.js",
+  "main": "build/index.js",
   "scripts": {
+    "start": "tsc && node build/index.js",
     "test": "echo \"Error: no test specified\" && exit 1"
   },
   "repository": {
@@ -18,5 +19,9 @@
   "bugs": {
     "url": "https://github.com/tloen/eudaemon/issues"
   },
-  "homepage": "https://github.com/tloen/eudaemon#readme"
+  "homepage": "https://github.com/tloen/eudaemon#readme",
+  "dependencies": {
+    "node-fetch": "^2.6.0",
+    "typescript": "^3.5.3"
+  }
 }

daemonist/package.json

@@ -0,0 +1,44 @@
+import { Dynalist } from "./dynalist";
+
+export const ENDPOINTS = {
+  GET_FILES: "https://dynalist.io/api/v1/file/list",
+  READ_DOCUMENT: "https://dynalist.io/api/v1/doc/read"
+};
+
+type FailCode =
+  | "Invalid"
+  | "TooManyRequests"
+  | "InvalidToken"
+  | "LockFail"
+  | "Unauthorized"
+  | "NotFound"
+  | "NodeNotFound"
+  | "NoInbox";
+
+type SuccessCode = "OK";
+
+export interface SuccessfulResponse {
+  _code: SuccessCode;
+}
+
+export interface FailedResponse {
+  _code: FailCode;
+  _msg: string;
+}
+
+export type APIResponse = SuccessfulResponse | FailedResponse;
+
+export interface GetFilesResponse extends SuccessfulResponse {
+  root_file_id: string;
+  files: Dynalist.File[];
+}
+
+export interface DocumentReadResponse extends SuccessfulResponse {
+  title: string;
+  nodes: Dynalist.Node[];
+}
+
+export interface NodeKey {
+  fileID: string;
+  nodeID: string;
+}

daemonist/src/api.ts

@@ -0,0 +1,53 @@
+export namespace Dynalist {
+  export type FileType = "document" | "folder";
+
+  export interface File {
+    id: string;
+    title: string;
+    type: FileType;
+    permission: number;
+  }
+
+  export interface Folder extends File {
+    collapsed: boolean;
+    children: string[];
+  }
+
+  export enum Color {
+    None = 0,
+    Red,
+    Orange,
+    Yellow,
+    Green,
+    Blue,
+    Violet
+  }
+
+  export enum HeadingLevel {
+    P = 0,
+    H1,
+    H2,
+    H3
+  }
+
+  export interface Node {
+    id: string;
+    content: string;
+    note: string;
+    created: number;
+    modified: number;
+    children: string[];
+
+    checked?: boolean;
+    checkbox?: boolean;
+    color?: Color;
+    heading?: HeadingLevel;
+    collapsed?: boolean;
+  }
+
+  export interface Document {
+    id: string;
+    title: string;
+    nodes: Node[];
+  }
+}

daemonist/src/dynalist.ts

@@ -0,0 +1,6 @@
+import { DynalistAPI } from "./session";
+
+const api = new DynalistAPI("<|key|>");
+
+// api.getFileTree().then(console.log);
+api.readDocument("HP3Ov2goSBuIPEzMA2T3jRkk").then(console.log);

daemonist/src/index.ts

@@ -0,0 +1,96 @@
+import {
+  GetFilesResponse,
+  ENDPOINTS,
+  DocumentReadResponse,
+  SuccessfulResponse
+} from "./api";
+import { Dynalist } from "./dynalist";
+import fetch from "node-fetch";
+
+interface FetchRequest {
+  url: string;
+  params?: any;
+}
+
+export class DynalistAPI {
+  private token: string;
+  // private fileTree: Dynalist.File[] | undefined;
+  // private cache; // TODO
+
+  constructor(token: string) {
+    this.token = token;
+  }
+
+  // Limit: 60 times per minute
+  public async readAllDocuments(): Promise<Dynalist.Document[]> {
+    return this.getFileTree()
+      .then(
+        (files): Promise<DocumentReadResponse[]> => {
+          const requests = files.map(
+            (file): FetchRequest => ({
+              url: ENDPOINTS.READ_DOCUMENT,
+              params: {
+                file_id: file.id
+              }
+            })
+          );
+          return this.batchPostFetch<DocumentReadResponse>(requests, 1500);
+        }
+      )
+      .then(responses =>
+        responses.map(response => {
+          return {
+            id: "abc",
+            title: response.title,
+            nodes: response.nodes
+          };
+        })
+      );
+  }
+
+  public readDocument(documentId: string): Promise<Dynalist.Document> {
+    return this.postFetch(ENDPOINTS.READ_DOCUMENT, {
+      file_id: documentId
+    }).then((body: DocumentReadResponse) => ({
+      id: documentId,
+      nodes: body.nodes,
+      title: body.title
+    }));
+  }
+
+  public getFileTree(): Promise<Dynalist.File[]> {
+    return this.postFetch<GetFilesResponse>(ENDPOINTS.GET_FILES).then(
+      body => body.files
+    );
+  }
+
+  private async batchPostFetch<T extends SuccessfulResponse>(
+    requests: FetchRequest[],
+    waitMilliseconds: number
+  ): Promise<T[]> {
+    const results: T[] = [];
+    for (const request of requests) {
+      results.push(await this.postFetch<T>(request.url, request.params));
+      await new Promise(_ => setTimeout(_, waitMilliseconds));
+    }
+    return results;
+  }
+
+  private postFetch<T extends SuccessfulResponse>(
+    url: string,
+    params?: any
+  ): Promise<T> {
+    return fetch(url, {
+      headers: {
+        "Content-Type": "application/json"
+      },
+      body: JSON.stringify({ token: this.token, ...params }),
+      method: "POST"
+    })
+      .then(response => response.json())
+      .then(body => {
+        if (body._code !== "Ok") return Promise.reject(body._msg);
+        else return body as T;
+      });
+  }
+}

daemonist/src/session.ts

@@ -0,0 +1,8 @@
+{
+  "compilerOptions": {
+    "lib": ["es2015", "es6", "dom"],
+    "outDir": "./build",
+    "target": "es5"
+  },
+  "include": ["src/**/*"]
+}