Encrypted device sync

api/resolvers/index.js

@@ -19,6 +19,7 @@ import chainFee from './chainFee'
 import { GraphQLScalarType, Kind } from 'graphql'
 import { createIntScalar } from 'graphql-scalar'
 import paidAction from './paidAction'
+import vault from './vault'
 
 const date = new GraphQLScalarType({
   name: 'Date',
@@ -55,4 +56,4 @@ const limit = createIntScalar({
 
 export default [user, item, message, wallet, lnurl, notifications, invite, sub,
   upload, search, growth, rewards, referrals, price, admin, blockHeight, chainFee,
-  { JSONObject }, { Date: date }, { Limit: limit }, paidAction]
+  { JSONObject }, { Date: date }, { Limit: limit }, paidAction, vault]

api/resolvers/vault.js

@@ -0,0 +1,115 @@
+import { E_VAULT_KEY_EXISTS, GqlAuthenticationError, GqlInputError } from '@/lib/error'
+
+export default {
+  Query: {
+    getVaultEntry: async (parent, { key }, { me, models }) => {
+      if (!me) {
+        throw new GqlAuthenticationError()
+      }
+      if (!key) {
+        throw new GqlInputError('must have key')
+      }
+      const k = await models.vault.findUnique({
+        where: {
+          userId_key: {
+            key,
+            userId: me.id
+          }
+        }
+      })
+      return k
+    }
+  },
+
+  Mutation: {
+    setVaultKeyHash: async (parent, { hash }, { me, models }) => {
+      if (!me) {
+        throw new GqlAuthenticationError()
+      }
+      if (!hash) {
+        throw new GqlInputError('hash required')
+      }
+      const { vaultKeyHash: oldKeyHash } = await models.user.findUnique({ where: { id: me.id } })
+      if (oldKeyHash) {
+        if (oldKeyHash !== hash) {
+          throw new GqlInputError('vault key already set', E_VAULT_KEY_EXISTS)
+        } else {
+          return true
+        }
+      } else {
+        await models.user.update({
+          where: { id: me.id },
+          data: { vaultKeyHash: hash }
+        })
+      }
+      return true
+    },
+    setVaultEntry: async (parent, { key, value, skipIfSet }, { me, models }) => {
+      if (!me) {
+        throw new GqlAuthenticationError()
+      }
+      if (!key) {
+        throw new GqlInputError('must have key')
+      }
+      if (!value) {
+        throw new GqlInputError('must have value')
+      }
+      if (skipIfSet) {
+        const existing = await models.vault.findUnique({
+          where: {
+            userId_key: {
+              userId: me.id,
+              key
+            }
+          }
+        })
+        if (existing) {
+          return false
+        }
+      }
+      await models.vault.upsert({
+        where: {
+          userId_key: {
+            userId: me.id,
+            key
+          }
+        },
+        update: {
+          value
+        },
+        create: {
+          key,
+          value,
+          userId: me.id
+        }
+      })
+      return true
+    },
+    unsetVaultEntry: async (parent, { key }, { me, models }) => {
+      if (!me) {
+        throw new GqlAuthenticationError()
+      }
+      if (!key) {
+        throw new GqlInputError('must have key')
+      }
+      await models.vault.deleteMany({
+        where: {
+          userId: me.id,
+          key
+        }
+      })
+      return true
+    },
+    clearVault: async (parent, args, { me, models }) => {
+      if (!me) {
+        throw new GqlAuthenticationError()
+      }
+      await models.user.update({
+        where: { id: me.id },
+        data: { vaultKeyHash: '' }
+      })
+      await models.vault.deleteMany({ where: { userId: me.id } })
+      return true
+    }
+  }
+}

api/typeDefs/index.js

@@ -18,6 +18,7 @@ import admin from './admin'
 import blockHeight from './blockHeight'
 import chainFee from './chainFee'
 import paidAction from './paidAction'
+import vault from './vault'
 
 const common = gql`
   type Query {
@@ -38,4 +39,4 @@ const common = gql`
 `
 
 export default [common, user, item, itemForward, message, wallet, lnurl, notifications, invite,
-  sub, upload, growth, rewards, referrals, price, admin, blockHeight, chainFee, paidAction]
+  sub, upload, growth, rewards, referrals, price, admin, blockHeight, chainFee, paidAction, vault]

api/typeDefs/user.js

@@ -182,6 +182,7 @@ export default gql`
     withdrawMaxFeeDefault: Int!
     autoWithdrawThreshold: Int
     autoWithdrawMaxFeePercent: Float
+    vaultKeyHash: String
   }
 
   type UserOptional {

api/typeDefs/vault.js

@@ -0,0 +1,22 @@
+import { gql } from 'graphql-tag'
+
+export default gql`
+  type Vault {
+    id: ID!
+    key: String!
+    value: String!
+    createdAt: Date!
+    updatedAt: Date!
+  }
+
+  extend type Query {
+    getVaultEntry(key: String!): Vault
+  }
+
+  extend type Mutation {
+    setVaultEntry(key: String!, value: String!, skipIfSet: Boolean): Boolean
+    unsetVaultEntry(key: String!): Boolean
+    clearVault: Boolean
+    setVaultKeyHash(hash: String!): String
+  }
+`

components/cancel-button.js

@@ -4,6 +4,6 @@ import Button from 'react-bootstrap/Button'
 export default function CancelButton ({ onClick }) {
   const router = useRouter()
   return (
-    <Button className='me-4 text-muted nav-link fw-bold' variant='link' onClick={onClick || (() => router.back())}>cancel</Button>
+    <Button className='me-2 text-muted nav-link fw-bold' variant='link' onClick={onClick || (() => router.back())}>cancel</Button>
   )
 }