[WIP] Collections support

.gitignore

@@ -45,6 +45,7 @@ native/windows/BlockstackBrowser/Resources/node.exe
 native/windows/BlockstackBrowser/Resources/cors-proxy/corsproxy.js
 native/windows/BlockstackSetup/obj/
 native/windows/BlockstackSetup/bin/
+native/windows/BlockstackSetup/*.msi
 native/macos/Blockstack/Blockstack/server/corsproxy.js
 native/macos/Blockstack/Blockstack/server/blockstackProxy.js
 native/macos/Blockstack/Blockstack/server/node

app/js/account/store/account/actions.js

@@ -11,7 +11,7 @@ import {
 } from '@utils'
 import { isCoreEndpointDisabled } from '@utils/window-utils'
 import { transactions, config, network } from 'blockstack'
-
+import { fetchIdentitySettings } from '../../../account/utils'
 import roundTo from 'round-to'
 import * as types from './types'
 import log4js from 'log4js'
@@ -41,7 +41,8 @@ function createAccount(
     bitcoinPublicKeychain,
     firstBitcoinAddress,
     identityAddresses,
-    identityKeypairs
+    identityKeypairs,
+    identitySettings
   } = getBlockchainIdentities(masterKeychain, identitiesToGenerate)
 
   return {
@@ -51,7 +52,8 @@ function createAccount(
     bitcoinPublicKeychain,
     firstBitcoinAddress,
     identityAddresses,
-    identityKeypairs
+    identityKeypairs,
+    identitySettings
   }
 }
 
@@ -547,6 +549,74 @@ function usedIdentityAddress() {
   }
 }
 
+function refreshAllIdentitySettings(
+  api: { gaiaHubConfig: GaiaHubConfig },
+  ownerAddresses: Array<string>,
+  identityKeyPairs: Array<object>
+) {
+  return dispatch => {
+    const promises: Array<Promise<*>> = ownerAddresses.map((address, index) => {
+      const promise: Promise<*> = new Promise((resolve, reject) => {
+        const keyPair = identityKeyPairs[index]
+        return fetchIdentitySettings(api, address, keyPair)
+          .then((settings) => {
+            resolve(settings)
+          })
+          .catch(error => reject(error))
+      })
+      return promise
+    })
+
+    return Promise.all(promises)
+      .then(settings => {
+        return dispatch(updateAllIdentitySettings(settings))
+      })
+      .catch((error) => {
+        logger.error(
+          'refreshIdentitySettings: error refreshing identity settings',
+          error
+        )
+        return Promise.reject(error)
+      })
+  }
+}
+
+function refreshIdentitySettings(
+  api: { gaiaHubConfig: GaiaHubConfig },
+  identityIndex: int,
+  ownerAddress: string,
+  identityKeyPair: { key: string }
+) {
+  return dispatch => fetchIdentitySettings(api, ownerAddress, identityKeyPair)
+    .then((settings) => {
+      return dispatch(updateIdentitySettings(identityIndex, settings))
+    })
+}
+
+function updateAllIdentitySettings(settings) {
+  return {
+    type: types.UPDATE_ALL_IDENTITY_SETTINGS,
+    settings
+  }
+}
+
+function updateIdentitySettings(identityIndex, settings) {
+  return {
+    type: types.UPDATE_IDENTITY_SETTINGS,
+    identityIndex,
+    settings
+  }
+}
+
+function setIdentityCollectionSetting(identityIndex, collectionName, collectionSettings) {
+  return {
+    type: types.SET_IDENTITY_COLLECTION_SETTINGS,
+    identityIndex,
+    collectionName,
+    collectionSettings
+  }
+}
+
 const AccountActions = {
   createAccount,
   updateBackupPhrase,
@@ -569,7 +639,12 @@ const AccountActions = {
   usedIdentityAddress,
   displayedRecoveryCode,
   newIdentityAddress,
-  updateEmail
+  updateEmail,
+  refreshAllIdentitySettings,
+  refreshIdentitySettings,
+  updateAllIdentitySettings,
+  updateIdentitySettings,
+  setIdentityCollectionSetting
 }
 
 export default AccountActions

app/js/account/store/account/reducer.js

@@ -9,7 +9,8 @@ const initialState = {
   encryptedBackupPhrase: null, // persist
   identityAccount: {
     addresses: [],
-    keypairs: []
+    keypairs: [],
+    settings: []
   },
   bitcoinAccount: {
     addresses: [],
@@ -43,6 +44,7 @@ function AccountReducer(state = initialState, action) {
           publicKeychain: action.identityPublicKeychain,
           addresses: action.identityAddresses,
           keypairs: action.identityKeypairs,
+          settings: action.identitySettings,
           addressIndex: 0
         },
         bitcoinAccount: {
@@ -258,13 +260,42 @@ function AccountReducer(state = initialState, action) {
             ...state.identityAccount.addresses,
             action.keypair.address
           ],
-          keypairs: [...state.identityAccount.keypairs, action.keypair]
+          keypairs: [...state.identityAccount.keypairs, action.keypair],
+          settings: [...state.identityAccount.settings, {}]
         })
       })
     case types.CONNECTED_STORAGE:
       return Object.assign({}, state, {
         connectedStorageAtLeastOnce: true
       })
+    case types.UPDATE_ALL_IDENTITY_SETTINGS:
+      return Object.assign({}, state, {
+        identityAccount: Object.assign({}, state.identityAccount, {
+          settings: action.settings
+        })
+      })
+    case types.UPDATE_IDENTITY_SETTINGS:
+      return Object.assign({}, state, {
+        identityAccount: Object.assign({}, state.identityAccount, {
+          settings: state.identityAccount.settings.map(
+            (settingsRow, i) => i === action.identityIndex ? action.settings : settingsRow
+          )
+        })
+      })
+    case types.SET_IDENTITY_COLLECTION_SETTINGS:
+      const newIdentitySettings = Object.assign({}, state.identityAccount.settings)
+
+      const identitySettingsAtIndex = newIdentitySettings[action.identityIndex]
+      if (!identitySettingsAtIndex.collections) {
+        identitySettingsAtIndex.collections = {}
+      }
+      identitySettingsAtIndex.collections[action.collectionName] = action.collectionSettings
+
+      return Object.assign({}, state, {
+        identityAccount: Object.assign({}, state.identityAccount, {
+          settings: newIdentitySettings
+        })
+      })
     default:
       return state
   }

app/js/account/store/account/types.js

@@ -23,3 +23,6 @@ export const RECOVERY_CODE_VERIFIED = 'account/RECOVERY_CODE_VERIFIED'
 export const INCREMENT_IDENTITY_ADDRESS_INDEX = 'account/INCREMENT_IDENTITY_ADDRESS_INDEX'
 export const CONNECTED_STORAGE = 'account/CONNECTED_STORAGE'
 export const UPDATE_EMAIL_ADDRESS = 'account/UPDATE_EMAIL_ADDRESS'
+export const UPDATE_ALL_IDENTITY_SETTINGS = 'account/UPDATE_ALL_IDENTITY_SETTINGS'
+export const UPDATE_IDENTITY_SETTINGS = 'account/UPDATE_IDENTITY_SETTINGS'
+export const SET_IDENTITY_COLLECTION_SETTINGS = 'account/SET_IDENTITY_COLLECTION_SETTINGS'

app/js/account/utils/index.js

@@ -4,13 +4,15 @@ import { parseZoneFile } from 'zone-file'
 import type { GaiaHubConfig } from './blockstack-inc'
 import { connectToGaiaHub, uploadToGaiaHub } from './blockstack-inc'
 
+import { encryptContent, decryptContent } from 'blockstack'
 import { getTokenFileUrlFromZoneFile } from '@utils/zone-utils'
 
 import log4js from 'log4js'
 const logger = log4js.getLogger(__filename)
 
 export const BLOCKSTACK_INC = 'gaia-hub'
 const DEFAULT_PROFILE_FILE_NAME = 'profile.json'
+const DEFAULT_IDENTITY_SETTINGS_FILE_NAME = 'settings.json'
 
 function getProfileUploadLocation(identity: any, hubConfig: GaiaHubConfig) {
   if (identity.zoneFile) {
@@ -23,6 +25,10 @@ function getProfileUploadLocation(identity: any, hubConfig: GaiaHubConfig) {
   }
 }
 
+function getSettingsUploadLocation(hubConfig: GaiaHubConfig) {
+  return `${hubConfig.url_prefix}${hubConfig.address}/${DEFAULT_IDENTITY_SETTINGS_FILE_NAME}`
+}
+
 // aaron-debt: this should be moved into blockstack.js
 function canWriteUrl(url: string, hubConfig: GaiaHubConfig): ?string {
   const readPrefix = `${hubConfig.url_prefix}${hubConfig.address}/`
@@ -116,3 +122,43 @@ export function uploadProfile(
     return uploadAttempt
   })
 }
+
+export function uploadIdentitySettings(
+  api: { gaiaHubConfig: GaiaHubConfig, gaiaHubUrl: string},
+  identityKeyPair: { key: string, keyID: string },
+  settingsData: string
+) {
+  const publicKey = identityKeyPair.keyID
+  const encryptedSettingsData = encryptContent(settingsData, { publicKey })
+  return connectToGaiaHub(api.gaiaHubUrl, identityKeyPair.key).then(identityHubConfig => {
+    const urlToWrite = getSettingsUploadLocation(identityHubConfig)
+    return tryUpload(
+      urlToWrite,
+      encryptedSettingsData,
+      identityHubConfig,
+      'application/json'
+    )
+  })
+}
+
+export function fetchIdentitySettings(
+  api: { gaiaHubConfig: GaiaHubConfig },
+  ownerAddress: string,
+  identityKeyPair: { key: string }
+) {
+  const privateKey = identityKeyPair.key
+  const hubConfig = api.gaiaHubConfig
+  const url = `${hubConfig.url_prefix}${ownerAddress}/${DEFAULT_IDENTITY_SETTINGS_FILE_NAME}`
+  return fetch(url)
+    .then(response => {
+      if (response.ok) {
+        return response.text()
+          .then(encryptedSettingsData => decryptContent(encryptedSettingsData, { privateKey }))
+          .then(decryptedSettingsData => JSON.parse(decryptedSettingsData))
+      } else if (response.status == 404) {
+        return {}
+      } else {
+        return Promise.reject('Could not fetch identity settings')
+      }
+    })
+}