From 9cacef61daba83d5eee522844bcae047b95edbbc Mon Sep 17 00:00:00 2001 From: Khushraj Rathod Date: Tue, 27 Oct 2020 23:07:26 +0530 Subject: [PATCH] Closes #1, add separate endpoint for uploading files --- api/new.ts | 60 ++++++++++++++++-------------------------------- api/newSingle.ts | 47 +++++++++++++++++++++++++++++++++++++ 2 files changed, 67 insertions(+), 40 deletions(-) create mode 100644 api/newSingle.ts diff --git a/api/new.ts b/api/new.ts index 78d1036..be596ce 100644 --- a/api/new.ts +++ b/api/new.ts @@ -1,6 +1,4 @@ -import { ServerRequest } from 'https://deno.land/std@0.61.0/http/server.ts' -import { Hash } from "https://deno.land/x/checksum@1.4.0/mod.ts" -import { urlParse } from 'https://deno.land/x/url_parse/mod.ts'; +import { ServerRequest } from 'https://deno.land/std@0.75.0/http/server.ts' const endpoint = (path: string) => { // https://vercel.com/docs/api#api-basics/authentication/accessing-resources-owned-by-a-team @@ -11,36 +9,7 @@ const endpoint = (path: string) => { return url } -// Vercel protects against env tokens starting with `VERCEL_`, so we're calling -// it the ZEIT_TOKEN - -const uploadFile = async (url: string, index: number) => { - const req = await fetch(url) - const data = new Uint8Array(await req.arrayBuffer()) - const sha = new Hash('sha1').digest(data).hex() - const size = data.byteLength - const { pathname } = urlParse(url) - const filename = index + pathname.substr(pathname.lastIndexOf('/') + 1) - - const uploadedFile = await fetch(endpoint('v2/now/files'), { - method: 'POST', - headers: { - 'Content-Length': size.toString(), - 'x-now-digest': sha, - 'Authorization': `Bearer ${Deno.env.get('ZEIT_TOKEN')}` - }, - body: data.buffer, - }) - - return { - sha, - size, - file: 'public/' + filename, - path: filename - } -} - -const deploy = async (files: {sha: string, file: string, path: string, size: number}[]) => { +const deploy = async (files: { sha: string, file: string, path: string, size: number }[]) => { const req = await fetch(endpoint('v12/now/deployments'), { method: 'POST', headers: { @@ -68,26 +37,37 @@ const deploy = async (files: {sha: string, file: string, path: string, size: num export default async (req: ServerRequest) => { if (req.method == 'OPTIONS') { - return req.respond({status: 204, body: JSON.stringify({ status: "YIPPE YAY. YOU HAVE CLEARANCE TO PROCEED." })}) + return req.respond({ status: 204, body: JSON.stringify({ status: "YIPPE YAY. YOU HAVE CLEARANCE TO PROCEED." }) }) } if (req.method == 'GET') { - return req.respond({status: 405, body: JSON.stringify({ error: '*GET outta here!* (Method not allowed, use POST)' })}) + return req.respond({ status: 405, body: JSON.stringify({ error: '*GET outta here!* (Method not allowed, use POST)' }) }) } if (req.method == 'PUT') { - return req.respond({status: 405, body: JSON.stringify({ error: '*PUT that request away!* (Method not allowed, use POST)' })}) + return req.respond({ status: 405, body: JSON.stringify({ error: '*PUT that request away!* (Method not allowed, use POST)' }) }) } if (req.method != 'POST') { - return req.respond({status: 405, body: JSON.stringify({ error: 'Method not allowed, use POST' })}) + return req.respond({ status: 405, body: JSON.stringify({ error: 'Method not allowed, use POST' }) }) } const decoder = new TextDecoder() const buf = await Deno.readAll(req.body) const fileURLs = JSON.parse(decoder.decode(buf)) if (!Array.isArray(fileURLs) || fileURLs.length < 1) { - return req.respond({status: 422, body: JSON.stringify({ error: 'Empty file array' })}) + return req.respond({ status: 422, body: JSON.stringify({ error: 'Empty file array' }) }) } - const uploadedFiles = await Promise.all(fileURLs.map(uploadFile)) - const result = await deploy(uploadedFiles) + + let uploadedURLs = await Promise.all(fileURLs.map(async (url) => { + const res = await fetch("https://cdn.hackclub.com/api/newSingle", { + method: 'POST', + headers: { + 'Content-Type': 'application/json' + }, + body: url + }) + return JSON.parse(await res.json()) + })) + + const result = await deploy(uploadedURLs) req.respond({ status: result.status, diff --git a/api/newSingle.ts b/api/newSingle.ts new file mode 100644 index 0000000..9ef85e7 --- /dev/null +++ b/api/newSingle.ts @@ -0,0 +1,47 @@ +import { ServerRequest } from 'https://deno.land/std@0.75.0/http/server.ts' +import { Hash } from "https://deno.land/x/checksum@1.4.0/mod.ts" +import { urlParse } from 'https://deno.land/x/url_parse/mod.ts'; + +const uploadFile = async (url: string) => { + const req = await fetch(url) + const data = new Uint8Array(await req.arrayBuffer()) + const sha = new Hash('sha1').digest(data).hex() + const size = data.byteLength + const { pathname } = urlParse(url) + const filename = pathname.substr(pathname.lastIndexOf('/') + 1) + + await fetch(endpoint('v2/now/files'), { + method: 'POST', + headers: { + 'Content-Length': size.toString(), + 'x-now-digest': sha, + 'Authorization': `Bearer ${Deno.env.get('ZEIT_TOKEN')}` + }, + body: data.buffer, + }) + + return { + sha, + size, + file: 'public/' + filename, + path: filename + } +} + +export default async (req: ServerRequest) => { + if (req.method != 'POST') { + return req.respond({ status: 405, body: JSON.stringify({ error: 'Method not allowed, use POST' }) }) + } + + const decoder = new TextDecoder() + const buf = await Deno.readAll(req.body) + const singleFileURL = JSON.parse(decoder.decode(buf)) + if (typeof singleFileURL != 'string') { + return req.respond({ status: 422, body: JSON.stringify({ error: 'newSingle only accepts a single URL' }) }) + } + const uploadedFileURL = await uploadFile(singleFileURL) + + req.respond({ + body: JSON.stringify(uploadedFileURL) + }) +}