From c40f10539d02e49a6313054469753a5542bcd034 Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Thu, 7 Sep 2023 19:22:28 -0500
Subject: [PATCH] ipfs: make API URL configurable, reorganize config

---
 src/config.ts         | 51 +++++++++++++++++++++++++++----------------
 src/uploaders/ipfs.ts |  5 ++++-
 2 files changed, 36 insertions(+), 20 deletions(-)

diff --git a/src/config.ts b/src/config.ts
index b1af464..64a356b 100644
--- a/src/config.ts
+++ b/src/config.ts
@@ -7,16 +7,6 @@ await dotenv.load({
   examplePath: null,
 });
 
-const optionalBooleanSchema = z
-  .enum(['true', 'false'])
-  .optional()
-  .transform((value) => value !== undefined ? value === 'true' : undefined);
-
-const optionalNumberSchema = z
-  .string()
-  .optional()
-  .transform((value) => value !== undefined ? Number(value) : undefined);
-
 /** Application-wide configuration. */
 const Conf = {
   /** Ditto admin secret key in nip19 format. This is the way it's configured by an admin. */
@@ -98,22 +88,45 @@ const Conf = {
       return optionalBooleanSchema.parse(Deno.env.get('S3_USE_SSL'));
     },
   },
+  ipfs: {
+    /** Base URL for private IPFS API calls. */
+    get apiUrl() {
+      return Deno.env.get('IPFS_API_URL') || 'http://localhost:5001';
+    },
+  },
   /** Domain of the Ditto server as a `URL` object, for easily grabbing the `hostname`, etc. */
   get url() {
     return new URL(Conf.localDomain);
   },
   /** Merges the path with the localDomain. */
   local(path: string): string {
-    const url = new URL(path.startsWith('/') ? path : new URL(path).pathname, Conf.localDomain);
-
-    if (!path.startsWith('/')) {
-      // Copy query parameters from the original URL to the new URL
-      const originalUrl = new URL(path);
-      url.search = originalUrl.search;
-    }
-
-    return url.toString();
+    return mergePaths(Conf.localDomain, path);
   },
 };
 
+const optionalBooleanSchema = z
+  .enum(['true', 'false'])
+  .optional()
+  .transform((value) => value !== undefined ? value === 'true' : undefined);
+
+const optionalNumberSchema = z
+  .string()
+  .optional()
+  .transform((value) => value !== undefined ? Number(value) : undefined);
+
+function mergePaths(base: string, path: string) {
+  const url = new URL(
+    path.startsWith('/') ? path : new URL(path).pathname,
+    base,
+  );
+
+  if (!path.startsWith('/')) {
+    // Copy query parameters from the original URL to the new URL
+    const originalUrl = new URL(path);
+    url.search = originalUrl.search;
+  }
+
+  return url.toString();
+}
+
 export { Conf };
diff --git a/src/uploaders/ipfs.ts b/src/uploaders/ipfs.ts
index c391df9..d31a36f 100644
--- a/src/uploaders/ipfs.ts
+++ b/src/uploaders/ipfs.ts
@@ -1,3 +1,4 @@
+import { Conf } from '@/config.ts';
 import { z } from '@/deps.ts';
 
 import type { Uploader } from './types.ts';
@@ -9,10 +10,12 @@ const ipfsAddResultSchema = z.object({
 });
 
 const ipfsUploader: Uploader = async (file) => {
+  const url = new URL('/api/v0/add', Conf.ipfs.apiUrl);
+
   const formData = new FormData();
   formData.append('file', file);
 
-  const response = await fetch('http://localhost:5001/api/v0/add', {
+  const response = await fetch(url, {
     method: 'POST',
     body: formData,
   });