Serverless functions for Pinata SDK + Slate

dashboard/.gitignore

@@ -23,3 +23,6 @@ yarn-error.log*
 
 .vercel
 /test
+
+# Local Netlify folder
+.netlify

dashboard/netlify.toml

@@ -1,3 +1,10 @@
+[build]
+  # This will be your default build command.
+  command = "npm run build"
+  # This is where Netlify will look for your lambda functions.
+  functions = "functions"
+  # This is the directory that you are publishing from.
+  publish = "dist"
 [[redirects]]
   from = "/*"
   to = "/index.html"

dashboard/package.json

@@ -4,10 +4,11 @@
   "private": true,
   "scripts": {
     "serve": "vue-cli-service serve",
-    "build": "vue-cli-service build",
+    "build": "netlify-lambda build src-functions && vue-cli-service build",
     "lint": "vue-cli-service lint",
     "i18n:report": "vue-cli-service i18n:report --src './src/**/*.?(js|vue)' --locales './src/locales/**/*.json'",
-    "start": "vue-cli-service serve"
+    "start": "vue-cli-service serve",
+    "lambda": "netlify-lambda serve src-functions"
   },
   "dependencies": {
     "@fortawesome/fontawesome-svg-core": "^1.2.34",
@@ -33,6 +34,7 @@
     "lazysizes": "^5.3.0",
     "markdown-it-vue": "^1.1.6",
     "mingo": "^4.1.2",
+    "netlify-lambda": "^2.0.4",
     "register-service-worker": "^1.7.1",
     "setimmediate": "^1.0.5",
     "slugify": "^1.4.6",

dashboard/src-functions/pinHash.js

@@ -0,0 +1,35 @@
+import axios from "axios"
+
+exports.handler = async (event, context) => {
+
+
+  // const location = event.queryStringParameters.location || "home";
+  const BASE_URL = 'https://api.pinata.cloud/pinning/pinByHash';
+  const object = event.body;
+
+  try {
+    const { status, data } = await axios.post(BASE_URL, object, {
+      headers: {
+        'Content-Type': 'application/json',
+        pinata_api_key: process.env.PINATA_API_KEY,
+        pinata_secret_api_key: process.env.PINATA_SECRET_API_KEY
+      },
+    });
+    console.log('[PINATA] Pin HASH', status, data);
+
+    return {
+      statusCode: status,
+      body: JSON.stringify(data),
+    };
+
+
+  } catch (e) {
+    console.log('Error', e.message)
+    return {
+      statusCode: 500,
+      body: e.message,
+    };
+  }
+
+};
+

dashboard/src-functions/pinJson.js

@@ -0,0 +1,43 @@
+import axios from "axios"
+
+exports.handler = async (event, context) => {
+
+
+  // const location = event.queryStringParameters.location || "home";
+  const BASE_URL = 'https://api.pinata.cloud/pinning/pinJSONToIPFS';
+  const object = event.body;
+
+  try {
+    const { status, data } = await axios.post(BASE_URL, object, {
+      headers: {
+        'Content-Type': 'application/json',
+        pinata_api_key: process.env.PINATA_API_KEY,
+        pinata_secret_api_key: process.env.PINATA_SECRET_API_KEY
+      },
+    });
+    console.log('[PINATA] Pin JSON', status, data);
+
+    if (status < 400) {
+      return {
+        statusCode: status,
+        body: JSON.stringify(data),
+      };
+    }
+
+
+  } catch (e) {
+    console.log('Error', e.message)
+    return {
+      statusCode: 500,
+      body: e.message,
+    };
+  }
+
+  return {
+    statusCode: status,
+    body: JSON.stringify({}),
+  };
+
+
+};
+

dashboard/src-functions/test.js

@@ -0,0 +1,34 @@
+import axios from "axios"
+
+exports.handler = async (event, context) => {
+
+  const BASE_URL = `https://api.pinata.cloud/data/testAuthentication`;
+  const { PINATA_API_KEY, PINATA_SECRET_API_KEY } = process.env;
+
+  console.log(PINATA_API_KEY, PINATA_SECRET_API_KEY)
+
+  try {
+    const { status, data } = await axios.get(BASE_URL, {
+      headers: {
+        pinata_api_key: PINATA_API_KEY || '1132c4704eda6c83a876',
+        pinata_secret_api_key: PINATA_SECRET_API_KEY || '684571ddca0c3e2ba69876a0d339c6d64bc88446a5eee5182ceccfaad8e12e7b'
+      },
+    });
+    console.log('[PINATA] TEST', status, data);
+
+    return {
+      statusCode: status,
+      body: JSON.stringify(data),
+    };
+
+
+  } catch (e) {
+    console.log('Error', e.message)
+    return {
+      statusCode: 500,
+      body: e.message,
+    };
+  }
+
+};
+

dashboard/src-functions/unpin.js

@@ -0,0 +1,42 @@
+import axios from "axios"
+
+exports.handler = async (event, context) => {
+
+
+  const hash = event.queryStringParameters.hash;
+
+  if (!hash) {
+    return {
+      statusCode: 403,
+      body: `Cannot unpin without hash`,
+    };
+  }
+
+  const BASE_URL = `https://api.pinata.cloud/pinning/unpin/${hash}`;
+
+  try {
+    const { status, data } = await axios.delete(BASE_URL, {
+      headers: {
+        'Content-Type': 'application/json',
+        pinata_api_key: process.env.PINATA_API_KEY,
+        pinata_secret_api_key: process.env.PINATA_SECRET_API_KEY
+      },
+    });
+    console.log('[PINATA] Pin HASH', status, data);
+
+    return {
+      statusCode: status,
+      body: JSON.stringify(data),
+    };
+
+
+  } catch (e) {
+    console.log('Error', e.message)
+    return {
+      statusCode: 500,
+      body: e.message,
+    };
+  }
+
+};
+

dashboard/src/components/rmrk/Create/CreateCollection.vue

@@ -91,7 +91,8 @@ import RmrkVersionMixin from '@/utils/mixins/rmrkVersionMixin';
 
 import { getInstance, RmrkType } from '../service/RmrkService';
 import { Collection, CollectionMetadata } from '../service/scheme';
-import { pinFile, pinJson, unSanitizeIpfsUrl } from '@/pinata';
+import { unSanitizeIpfsUrl } from '@/utils/ipfs';
+import { pinFile, pinJson } from '@/proxy';
 import { decodeAddress } from '@polkadot/keyring';
 import { u8aToHex } from '@polkadot/util';
 import { generateId } from '@/components/rmrk/service/Consolidator'

dashboard/src/components/rmrk/Create/CreateToken.vue

@@ -80,7 +80,8 @@ import {
   NFT,
   NFTMetadata,
 } from '../service/scheme';
-import { pinFile, pinJson, unSanitizeIpfsUrl } from '@/pinata';
+import { pinFile, pinJson } from '@/proxy';
+import { unSanitizeIpfsUrl } from '@/utils/ipfs';
 import PasswordInput from '@/components/shared/PasswordInput.vue';
 import slugify from 'slugify'
 import { fetchCollectionMetadata } from '../utils';

dashboard/src/components/rmrk/Gallery/AvailableActions.vue

@@ -36,7 +36,7 @@ import Connector from '@vue-polkadot/vue-api';
 import exec, { execResultValue } from '@/utils/transactionExecutor';
 import { notificationTypes, showNotification } from '@/utils/notification';
 import { getInstance, RmrkType } from '../service/RmrkService';
-import { unpin } from '@/pinata';
+import { unpin } from '@/proxy';
 import Consolidator from '../service/Consolidator';
 import RmrkVersionMixin from '@/utils/mixins/rmrkVersionMixin';
 import { somePercentFromTX } from '@/utils/support';

dashboard/src/components/rmrk/Gallery/Item/Facts.vue

@@ -45,7 +45,7 @@
 
 <script lang="ts" >
 import { Component, Prop, Vue, Watch } from 'vue-property-decorator';
-import { extractCid } from '@/pinata';
+import { extractCid } from '@/utils/ipfs';
 import { NFTWithMeta } from '../../service/scheme';
 import { emptyObject } from '@/utils/empty';
 const components = {

dashboard/src/components/rmrk/service/RmrkService.ts

@@ -8,7 +8,7 @@ import Consolidator, { generateId } from './Consolidator';
 import { keyInfo as keysToTheKingdom } from '@/textile'
 import slugify from 'slugify';
 import { fetchCollectionMetadata, fetchNFTMetadata } from '../utils';
-import { ipfsToArweave } from '@/pinata'
+import { ipfsToArweave } from '@/utils/ipfs'
 import { fetchMimeType } from '@/fetch';
 
 export type RmrkType = RmrkWithMetaType | Emotion | Pack

dashboard/src/main.ts

@@ -31,6 +31,7 @@ import i18n from './i18n'
 import mingo from 'mingo'
 import api from './fetch'
 import { baseIpfsPrice, cost,  getFileSize, supportTx } from './utils/support'
+import axios from 'axios'
 
 
 import { useOperators, OperatorType } from 'mingo/core'
@@ -52,6 +53,7 @@ Vue.filter('shortAddress', shortAddress);
 (window as any).mingo = mingo;
 (window as any).api = api;
 (window as any).P = { baseIpfsPrice, cost, getFileSize, supportTx};
+(window as any).axios = axios;
 // (window as any).migrateCollection = migrateCollection;
 // (window as any).migrateNFT = migrateNFT;
 

dashboard/src/pinata.ts

@@ -1,4 +1,5 @@
 import Axios from 'axios';
+import { extractCid, justHash } from './utils/ipfs';
 
 export const BASE_URL = 'https://api.pinata.cloud/pinning/';
 
@@ -58,47 +59,7 @@ export const unpin = async (ipfsLink: string) => {
   }
 };
 
-export const unSanitizeIpfsUrl = (url: string) => {
-  return `ipfs://ipfs/${url}`;
-};
-
-export const justHash = (ipfsLink?: string): boolean => {
-  return /^[a-zA-Z0-9]+$/.test(ipfsLink || '');
-};
-
-const cidRegex: RegExp = /ipfs\/([a-zA-Z0-9]+)\/?$/;
-export const extractCid = (ipfsLink?: string): string => {
-  if (!ipfsLink) {
-    return '';
-  }
-
-  const match = ipfsLink.match(cidRegex);
-
-  return match ? match[1] : '';
-};
-
-type IpfsToArweaveType = {
-  arweaveId: string;
-  ipfsHash: string;
-  statusCode: number;
-}
-
-const IPFS2AR = 'https://ipfs2arweave.com/permapin/'
-export const ipfsToArweave = async (ipfsLink: string): Promise<string> => {
-  const hash = justHash(ipfsLink) ? ipfsLink : extractCid(ipfsLink)
-  try {
-    const res = await fetch(IPFS2AR + hash, {method: 'POST'})
-    if (res.ok) {
-      return (await res.json()).arweaveId
-    }
-
-    return ''
-  } catch (e) {
-    console.error(`[IPFS2AR] Unable to Arweave ${e.message}`)
-    return ''
-  }
 
-}
 
 export default api;
 // QmYt2FydonvVMsEqe2q3hvm38WDq21xM8Z5ZSHZw19PwjF;

dashboard/src/proxy.ts

@@ -0,0 +1,62 @@
+import Axios from 'axios';
+import { extractCid, justHash } from './utils/ipfs';
+
+export const BASE_URL = `${window.location.origin}/.netlify/functions/`;
+
+const api = Axios.create({
+  baseURL: BASE_URL
+});
+
+export const pinJson = async (object: any) => {
+  try {
+    const { status, data } = await api.post('pinJson', object);
+    console.log('[PROXY] Pin JSON', status, data);
+    if (status < 400) {
+      return data.IpfsHash;
+    }
+  } catch (e) {
+    throw e;
+  }
+};
+
+export const pinFile = async (file: Blob): Promise<string> => {
+  const formData = new FormData();
+  formData.append('file', file);
+
+  const SLATE_URL = 'https://uploads.slate.host/api/public'
+
+  try {
+    const { status, data } = await Axios.post(SLATE_URL, formData, {
+      headers: {
+        'Content-Type': `multipart/form-data`,
+        Authorization: `Basic ${process.env.VUE_APP_SLATE_KEY}`
+      }
+    });
+    console.log('[PROXY] SLATE Image', status, data);
+    if (status < 400) {
+      await api.post('pinHash', { hashToPin: data.data.cid })
+      return data.data.cid;
+    } else {
+      throw new Error('Unable to PIN for reasons');
+    }
+  } catch (e) {
+    throw e;
+  }
+};
+
+export const unpin = async (ipfsLink: string) => {
+  const hash = justHash(ipfsLink) ? ipfsLink : extractCid(ipfsLink)
+  try {
+    const { status, data } = await api.delete(`unpin/?hash=${hash}`);
+    console.log('[PROXY] Unpin whatever', status, data);
+    if (status < 400) {
+      return data;
+    }
+  } catch (e) {
+    throw e;
+  }
+};
+
+
+export default api;
+// QmYt2FydonvVMsEqe2q3hvm38WDq21xM8Z5ZSHZw19PwjF;