From 44036f40927b87abda28c40c3209d34ff057e3c5 Mon Sep 17 00:00:00 2001
From: Joe Ma <rikkaneko23@gmail.com>
Date: Wed, 1 Jun 2022 02:11:52 +0800
Subject: [PATCH] Initial commit

---
 .gitignore    | 191 +++++++++++++++++++++++++++++++++++++++
 package.json  |  13 +++
 src/index.ts  | 245 ++++++++++++++++++++++++++++++++++++++++++++++++++
 tsconfig.json | 105 ++++++++++++++++++++++
 wrangler.toml |  11 +++
 5 files changed, 565 insertions(+)
 create mode 100644 .gitignore
 create mode 100644 package.json
 create mode 100644 src/index.ts
 create mode 100644 tsconfig.json
 create mode 100644 wrangler.toml

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..9452459
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,191 @@
+### JetBrains template
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio, WebStorm and Rider
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+# User-specific stuff
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/**/usage.statistics.xml
+.idea/**/dictionaries
+.idea/**/shelf
+
+# Generated files
+.idea/**/contentModel.xml
+
+# Sensitive or high-churn files
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+.idea/**/dbnavigator.xml
+
+# Gradle
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# Gradle and Maven with auto-import
+# When using Gradle or Maven with auto-import, you should exclude module files,
+# since they will be recreated, and may cause churn.  Uncomment if using
+# auto-import.
+# .idea/artifacts
+# .idea/compiler.xml
+# .idea/jarRepositories.xml
+# .idea/modules.xml
+# .idea/*.iml
+# .idea/modules
+# *.iml
+# *.ipr
+
+# CMake
+cmake-build-*/
+
+# Mongo Explorer plugin
+.idea/**/mongoSettings.xml
+
+# File-based project format
+*.iws
+
+# IntelliJ
+out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+
+# Editor-based Rest Client
+.idea/httpRequests
+
+# Android studio 3.1+ serialized cache file
+.idea/caches/build_file_checksums.ser
+
+### Node template
+# 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/
+
+# Snowpack dependency directory (https://snowpack.dev/)
+web_modules/
+
+# TypeScript cache
+*.tsbuildinfo
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Microbundle cache
+.rpt2_cache/
+.rts2_cache_cjs/
+.rts2_cache_es/
+.rts2_cache_umd/
+
+# 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
+.parcel-cache
+
+# Next.js build output
+.next
+out
+
+# Nuxt.js build / generate output
+.nuxt
+dist
+
+# Gatsby files
+.cache/
+# Comment in the public line in if your project uses Gatsby and not Next.js
+# https://nextjs.org/blog/next-9-1#public-directory-support
+# public
+
+# vuepress build output
+.vuepress/dist
+
+# Serverless directories
+.serverless/
+
+# FuseBox cache
+.fusebox/
+
+# DynamoDB Local files
+.dynamodb/
+
+# TernJS port file
+.tern-port
+
+# Stores VSCode versions used for testing VSCode extensions
+.vscode-test
+
+# yarn v2
+.yarn/cache
+.yarn/unplugged
+.yarn/build-state.yml
+.yarn/install-state.gz
+.pnp.*
+
diff --git a/package.json b/package.json
new file mode 100644
index 0000000..8ca6d90
--- /dev/null
+++ b/package.json
@@ -0,0 +1,13 @@
+{
+    "name": "paste",
+    "version": "1.0.0",
+    "dependencies": {
+        "aws4fetch": "^1.0.13",
+        "nanoid": "^3.3.4"
+    },
+    "devDependencies": {
+        "@cloudflare/workers-types": "^3.11.0",
+        "typescript": "^4.7.2",
+        "wrangler": "^2.0.7"
+    }
+}
diff --git a/src/index.ts b/src/index.ts
new file mode 100644
index 0000000..f356f85
--- /dev/null
+++ b/src/index.ts
@@ -0,0 +1,245 @@
+import {AwsClient} from "aws4fetch";
+import { customAlphabet } from 'nanoid'
+
+// Constants
+const SERVICE_URL = "https://paste.nekoul.com"
+
+export interface Env {
+    PASTE_INDEX: KVNamespace;
+    AWS_ACCESS_KEY_ID: string;
+    AWS_SECRET_ACCESS_KEY: string;
+    ENDPOINT: string
+}
+
+const API_DOCS =
+    `Paste service https://paste.nekoul.com
+
+[API Draft]
+GET /                Fetch the HTML for uploading text/file [ ]
+GET /<uuid>          Fetch the paste by uuid [x]
+GET /<uuid>/<lang>   Fetch the paste (code) in rendered HTML with syntax highlighting [ ]
+GET /<uuid>/settings   Fetch the paste information [x]
+GET /status          Fetch service information [x]
+PUT /                Create new paste [x]
+POST /<uuid>         Update the paste by uuid [x]
+DELETE /<uuid>       Delete paste by uuid [x]
+POST /<uuid>/settings  Update paste setting, i.e., passcode and valid time [ ]
+
+[ ] indicated not implemented
+
+Limitation
+* Max. 10MB file size upload (Max. 100MB body size for free Cloudflare plan) 
+
+Last update on 30 May.
+`;
+
+const gen_id = customAlphabet(
+    "1234567890ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz", 8);
+
+export default {
+    async fetch(
+        request: Request,
+        env: Env,
+        ctx: ExecutionContext
+    ): Promise<Response> {
+        const {url, method, headers} = request;
+        const {hostname, pathname, searchParams} = new URL(url);
+        const path = pathname.replace(/\/+$/, "") || "/"
+        const s3 = new AwsClient({
+            accessKeyId: env.AWS_ACCESS_KEY_ID,
+            secretAccessKey: env.AWS_SECRET_ACCESS_KEY
+        });
+
+        // if (hostname !== SERVICE_URL) {
+        //     // Invalid case
+        //     return new Response(null, { status: 403 })
+        // }
+
+        if (path === "/") {
+            switch (method) {
+                // Fetch the HTML for uploading text/file
+                case "GET":
+                    return new Response(API_DOCS);
+
+                // Create new paste
+                case "PUT":
+                    let uuid = gen_id();
+                    let buffer = await request.arrayBuffer();
+                    // Check request.body size <= 10MB
+                    if (buffer.byteLength > 10485760) {
+                        return new Response("File size must be under 10MB.\n");
+                    }
+
+                    let res = await s3.fetch(`${env.ENDPOINT}/${uuid}`, {
+                        method: "PUT",
+                        body: buffer
+                    });
+
+                    if (res.ok) {
+                        // Upload success
+                        let descriptor: PasteIndexEntry = {
+                            title: headers.get("title") || undefined,
+                            last_modified: Date.now(),
+                            password: undefined,
+                            editable: undefined // Default: true
+                        };
+
+                        let counter = await env.PASTE_INDEX.get("__count__") || "0";
+                        await env.PASTE_INDEX.put(uuid, JSON.stringify(descriptor));
+                        await env.PASTE_INDEX.put("__count__", (Number(counter) + 1).toString());
+                        return new Response(get_paste_info(uuid, descriptor));
+                    } else {
+                        return new Response("Unable to upload the paste.\n", {
+                            status: 500
+                        });
+                    }
+
+            }
+
+        } else if (path.length >= 9) {
+            // RegExpr to match /<uuid>/<option>
+            const found = path.match("/(?<uuid>[A-z0-9]+)(?:/(?<option>[A-z]+))?$");
+            if (found === null) {
+                return new Response("Invalid path.\n", {
+                    status: 422
+                })
+            }
+            // @ts-ignore
+            const {uuid, option} = found.groups;
+            // UUID format: [A-z0-9]{8}
+            if (uuid.length !== 8) {
+                return new Response("Invalid UUID.\n", {
+                    status: 422
+                })
+            }
+            let val = await env.PASTE_INDEX.get(uuid);
+            if (val === null) {
+                return new Response("Paste not found.\n", {
+                    status: 404
+                });
+            }
+            let descriptor: PasteIndexEntry = JSON.parse(val);
+
+            // Handling /<uuid>/settings
+            if (option !== undefined) {
+                if (option === "settings") {
+                    switch(method) {
+                        case "GET":
+                            return new Response(get_paste_info(uuid, descriptor))
+
+                        case "POST": {
+
+                        }
+                    }
+
+                } else if (option.length !== 0) {
+                    return new Response("Unsupported language.\n", {
+                        status: 405
+                    })
+                }
+            }
+
+
+            switch (method) {
+                // Fetch the paste by uuid
+                case "GET": {
+                    let res = await s3.fetch(`${env.ENDPOINT}/${uuid}`, {
+                        method: "GET"
+                    });
+                    // Stream request
+                    let {readable, writable} = new TransformStream();
+                    if (res.body === null) {
+                        // UUID exists in index but not found in remote object storage service
+                        return new Response("Internal server error.\n", {
+                            status: 500
+                        });
+                    }
+                    // Streaming request
+                    res.body.pipeTo(writable);
+                    return new Response(readable, {
+                        // headers: {
+                        //     "Content-Disposition": `attachment; filename="${encodeURIComponent(descriptor.title ?? uuid)}"`
+                        // }
+                    });
+                }
+
+                // Update the paste by uuid
+                case "POST": {
+                    if (!descriptor.editable) {
+                        return new Response("This paste does not allow editing.\n", {
+                            status: 405
+                        });
+                    }
+
+                    let buffer = await request.arrayBuffer();
+                    // Check request.body size <= 10MB
+                    if (buffer.byteLength > 10485760) {
+                        return new Response("File size must be under 10MB.\n");
+                    }
+                    let res = await s3.fetch(`${env.ENDPOINT}/${uuid}`, {
+                        method: "PUT",
+                        body: buffer
+                    });
+
+                    if (res.ok) {
+                        // Update last modified time
+                        descriptor.last_modified = Date.now();
+                        await env.PASTE_INDEX.put(uuid, JSON.stringify(descriptor));
+                        return new Response("OK\n");
+                    } else {
+                        return new Response("Unable to update the paste.\n", {
+                            status: 500
+                        });
+                    }
+                }
+
+                // Delete paste by uuid
+                case "DELETE": {
+                    if (descriptor.editable !== undefined && descriptor.editable) {
+                        return new Response("This paste is immutable.\n", {
+                            status: 405
+                        });
+                    }
+
+                    let res = await s3.fetch(`${env.ENDPOINT}/${uuid}`, {
+                        method: "DELETE"
+                    });
+
+                    if (res.ok) {
+                        await env.PASTE_INDEX.delete(uuid);
+                        let counter = await env.PASTE_INDEX.get("__count__") || "1";
+                        await env.PASTE_INDEX.put("__count__", (Number(counter) - 1).toString());
+                        return new Response("OK\n");
+                    } else {
+                        return new Response("Unable to process such request.\n", {
+                            status: 500
+                        });
+                    }
+                }
+            }
+        }
+
+        // Default response
+        return new Response("Invalid path.\n", {
+            status: 403
+        });
+    },
+};
+
+function get_paste_info(uuid: string, descriptor: PasteIndexEntry): string {
+    let date = new Date(descriptor.last_modified)
+    return `${SERVICE_URL}/${uuid}
+ID: ${uuid}
+Title: ${descriptor.title || "<empty>"}
+Password: ${(!!descriptor.password)}
+Editable: ${descriptor.editable? descriptor.editable: true}
+Last modified at ${date.toISOString()}
+`
+}
+
+interface PasteIndexEntry {
+    title?: string
+    last_modified: number,
+    password?: string
+    editable?: boolean
+}
\ No newline at end of file
diff --git a/tsconfig.json b/tsconfig.json
new file mode 100644
index 0000000..2591fb1
--- /dev/null
+++ b/tsconfig.json
@@ -0,0 +1,105 @@
+{
+  "compilerOptions": {
+    /* Visit https://aka.ms/tsconfig.json to read more about this file */
+
+    /* Projects */
+    // "incremental": true,                              /* Enable incremental compilation */
+    // "composite": true,                                /* Enable constraints that allow a TypeScript project to be used with project references. */
+    // "tsBuildInfoFile": "./",                          /* Specify the folder for .tsbuildinfo incremental compilation files. */
+    // "disableSourceOfProjectReferenceRedirect": true,  /* Disable preferring source files instead of declaration files when referencing composite projects */
+    // "disableSolutionSearching": true,                 /* Opt a project out of multi-project reference checking when editing. */
+    // "disableReferencedProjectLoad": true,             /* Reduce the number of projects loaded automatically by TypeScript. */
+
+    /* Language and Environment */
+    "target": "es2021" /* Set the JavaScript language version for emitted JavaScript and include compatible library declarations. */,
+    "lib": [
+      "es2021"
+    ] /* Specify a set of bundled library declaration files that describe the target runtime environment. */,
+    // "jsx": "preserve",                                /* Specify what JSX code is generated. */
+    // "experimentalDecorators": true,                   /* Enable experimental support for TC39 stage 2 draft decorators. */
+    // "emitDecoratorMetadata": true,                    /* Emit design-type metadata for decorated declarations in source files. */
+    // "jsxFactory": "",                                 /* Specify the JSX factory function used when targeting React JSX emit, e.g. 'React.createElement' or 'h' */
+    // "jsxFragmentFactory": "",                         /* Specify the JSX Fragment reference used for fragments when targeting React JSX emit e.g. 'React.Fragment' or 'Fragment'. */
+    // "jsxImportSource": "",                            /* Specify module specifier used to import the JSX factory functions when using `jsx: react-jsx*`.` */
+    // "reactNamespace": "",                             /* Specify the object invoked for `createElement`. This only applies when targeting `react` JSX emit. */
+    // "noLib": true,                                    /* Disable including any library files, including the default lib.d.ts. */
+    // "useDefineForClassFields": true,                  /* Emit ECMAScript-standard-compliant class fields. */
+
+    /* Modules */
+    "module": "es2022" /* Specify what module code is generated. */,
+    // "rootDir": "./",                                  /* Specify the root folder within your source files. */
+    "moduleResolution": "node" /* Specify how TypeScript looks up a file from a given module specifier. */,
+    // "baseUrl": "./",                                  /* Specify the base directory to resolve non-relative module names. */
+    // "paths": {},                                      /* Specify a set of entries that re-map imports to additional lookup locations. */
+    // "rootDirs": [],                                   /* Allow multiple folders to be treated as one when resolving modules. */
+    // "typeRoots": [],                                  /* Specify multiple folders that act like `./node_modules/@types`. */
+    "types": [
+      "@cloudflare/workers-types"
+    ] /* Specify type package names to be included without being referenced in a source file. */,
+    // "allowUmdGlobalAccess": true,                     /* Allow accessing UMD globals from modules. */
+    "resolveJsonModule": true /* Enable importing .json files */,
+    // "noResolve": true,                                /* Disallow `import`s, `require`s or `<reference>`s from expanding the number of files TypeScript should add to a project. */
+
+    /* JavaScript Support */
+    "allowJs": true /* Allow JavaScript files to be a part of your program. Use the `checkJS` option to get errors from these files. */,
+    "checkJs": true /* Enable error reporting in type-checked JavaScript files. */,
+    // "maxNodeModuleJsDepth": 1,                        /* Specify the maximum folder depth used for checking JavaScript files from `node_modules`. Only applicable with `allowJs`. */
+
+    /* Emit */
+    // "declaration": true,                              /* Generate .d.ts files from TypeScript and JavaScript files in your project. */
+    // "declarationMap": true,                           /* Create sourcemaps for d.ts files. */
+    // "emitDeclarationOnly": true,                      /* Only output d.ts files and not JavaScript files. */
+    // "sourceMap": true,                                /* Create source map files for emitted JavaScript files. */
+    // "outFile": "./",                                  /* Specify a file that bundles all outputs into one JavaScript file. If `declaration` is true, also designates a file that bundles all .d.ts output. */
+    // "outDir": "./",                                   /* Specify an output folder for all emitted files. */
+    // "removeComments": true,                           /* Disable emitting comments. */
+    "noEmit": true /* Disable emitting files from a compilation. */,
+    // "importHelpers": true,                            /* Allow importing helper functions from tslib once per project, instead of including them per-file. */
+    // "importsNotUsedAsValues": "remove",               /* Specify emit/checking behavior for imports that are only used for types */
+    // "downlevelIteration": true,                       /* Emit more compliant, but verbose and less performant JavaScript for iteration. */
+    // "sourceRoot": "",                                 /* Specify the root path for debuggers to find the reference source code. */
+    // "mapRoot": "",                                    /* Specify the location where debugger should locate map files instead of generated locations. */
+    // "inlineSourceMap": true,                          /* Include sourcemap files inside the emitted JavaScript. */
+    // "inlineSources": true,                            /* Include source code in the sourcemaps inside the emitted JavaScript. */
+    // "emitBOM": true,                                  /* Emit a UTF-8 Byte Order Mark (BOM) in the beginning of output files. */
+    // "newLine": "crlf",                                /* Set the newline character for emitting files. */
+    // "stripInternal": true,                            /* Disable emitting declarations that have `@internal` in their JSDoc comments. */
+    // "noEmitHelpers": true,                            /* Disable generating custom helper functions like `__extends` in compiled output. */
+    // "noEmitOnError": true,                            /* Disable emitting files if any type checking errors are reported. */
+    // "preserveConstEnums": true,                       /* Disable erasing `const enum` declarations in generated code. */
+    // "declarationDir": "./",                           /* Specify the output directory for generated declaration files. */
+    // "preserveValueImports": true,                     /* Preserve unused imported values in the JavaScript output that would otherwise be removed. */
+
+    /* Interop Constraints */
+    "isolatedModules": true /* Ensure that each file can be safely transpiled without relying on other imports. */,
+    "allowSyntheticDefaultImports": true /* Allow 'import x from y' when a module doesn't have a default export. */,
+    // "esModuleInterop": true /* Emit additional JavaScript to ease support for importing CommonJS modules. This enables `allowSyntheticDefaultImports` for type compatibility. */,
+    // "preserveSymlinks": true,                         /* Disable resolving symlinks to their realpath. This correlates to the same flag in node. */
+    "forceConsistentCasingInFileNames": true /* Ensure that casing is correct in imports. */,
+
+    /* Type Checking */
+    "strict": true /* Enable all strict type-checking options. */,
+    // "noImplicitAny": true,                            /* Enable error reporting for expressions and declarations with an implied `any` type.. */
+    // "strictNullChecks": true,                         /* When type checking, take into account `null` and `undefined`. */
+    // "strictFunctionTypes": true,                      /* When assigning functions, check to ensure parameters and the return values are subtype-compatible. */
+    // "strictBindCallApply": true,                      /* Check that the arguments for `bind`, `call`, and `apply` methods match the original function. */
+    // "strictPropertyInitialization": true,             /* Check for class properties that are declared but not set in the constructor. */
+    // "noImplicitThis": true,                           /* Enable error reporting when `this` is given the type `any`. */
+    // "useUnknownInCatchVariables": true,               /* Type catch clause variables as 'unknown' instead of 'any'. */
+    // "alwaysStrict": true,                             /* Ensure 'use strict' is always emitted. */
+    // "noUnusedLocals": true,                           /* Enable error reporting when a local variables aren't read. */
+    // "noUnusedParameters": true,                       /* Raise an error when a function parameter isn't read */
+    // "exactOptionalPropertyTypes": true,               /* Interpret optional property types as written, rather than adding 'undefined'. */
+    // "noImplicitReturns": true,                        /* Enable error reporting for codepaths that do not explicitly return in a function. */
+    // "noFallthroughCasesInSwitch": true,               /* Enable error reporting for fallthrough cases in switch statements. */
+    // "noUncheckedIndexedAccess": true,                 /* Include 'undefined' in index signature results */
+    // "noImplicitOverride": true,                       /* Ensure overriding members in derived classes are marked with an override modifier. */
+    // "noPropertyAccessFromIndexSignature": true,       /* Enforces using indexed accessors for keys declared using an indexed type */
+    // "allowUnusedLabels": true,                        /* Disable error reporting for unused labels. */
+    // "allowUnreachableCode": true,                     /* Disable error reporting for unreachable code. */
+
+    /* Completeness */
+    // "skipDefaultLibCheck": true,                      /* Skip type checking .d.ts files that are included with TypeScript. */
+    "skipLibCheck": true /* Skip type checking all .d.ts files. */
+  }
+}
diff --git a/wrangler.toml b/wrangler.toml
new file mode 100644
index 0000000..9d8f8d6
--- /dev/null
+++ b/wrangler.toml
@@ -0,0 +1,11 @@
+name = "paste"
+main = "src/index.ts"
+compatibility_date = "2022-05-30"
+kv_namespaces = [
+    { binding = "PASTE_INDEX", id = "a578863da0564cd7beadd9ce4a2d53e8", preview_id = "66d9440e13124099a5e508fe1ff0a489" }
+]
+
+# [secret]
+# AWS_ACCESS_KEY_ID
+# AWS_SECRET_ACCESS_KEY
+# ENDPOINT
\ No newline at end of file