WIP: weProfileApi makes zome calls using WeServices

Author: weswalla

web/src/api/weProfilesApi.ts

@@ -0,0 +1,125 @@
+import { AppWebsocket, CellId } from '@holochain/client'
+import { WeServices } from '@lightningrodlabs/we-applet'
+import { ObjectFlags } from 'typescript'
+import { PROFILES_ZOME_NAME } from '../holochainConfig'
+import { Profile, WhoAmIOutput } from '../types'
+import { AgentPubKeyB64, UpdateInput } from '../types/shared'
+import callZome from './callZome'
+import { WireRecord } from './hdkCrud'
+
+const ZOME_FN_NAMES = {
+  CREATE_WHOAMI: 'create_whoami',
+  CREATE_IMPORTED_PROFILE: 'create_imported_profile',
+  UPDATE_WHOAMI: 'update_whoami',
+  WHOAMI: 'whoami',
+  FETCH_AGENTS: 'fetch_agents',
+  FETCH_AGENT_ADDRESS: 'fetch_agent_address',
+}
+function weToAcornProfile(weProfile: WeProfile): Profile {
+    let acornProfile: Profile
+    Object.keys(weProfile.fields).forEach((key) => {
+        if (key === 'isImported') {
+            acornProfile[key] = JSON.parse(weProfile.fields[key])
+        }
+        else {
+            acornProfile[key] = weProfile.fields[key]
+        }
+    })
+    return acornProfile
+}
+function acornToWeProfile(acornProfile: Profile, nickname: string): WeProfile {
+    let weProfile: WeProfile = { nickname: '', fields: {} }
+    Object.keys(acornProfile).forEach((key) => {
+        if (key === 'isImported') {
+            weProfile.fields[key] = JSON.stringify(acornProfile[key])
+        }
+        else {
+            weProfile.fields[key] = acornProfile[key]
+        }
+    })
+    return weProfile
+}
+async function getMyNickname(weServices: WeServices): Promise<string> {
+    let myWeProfile: WeProfile
+    (await weServices.profilesStore.fetchMyProfile()).subscribe((profile) => {myWeProfile = profile})
+    return myWeProfile.nickname
+}
+export interface WeProfile {
+    nickname: string;
+    fields: Record<string, string>;
+}
+const WeProfilesApi = (appWebsocket: AppWebsocket, weServices: WeServices) => {
+  return {
+    createWhoami: async (cellId: CellId, payload: Profile): Promise<WireRecord<Profile>> => {
+        const profile = acornToWeProfile(payload, await getMyNickname(weServices))
+        await weServices.profilesStore.updateProfile(profile)
+        return {
+            actionHash: null,
+            entryHash: null,
+            entry: payload,
+            createdAt: null,
+            updatedAt: null,
+        }
+    },
+    createImportedProfile: async (cellId: CellId, payload: Profile): Promise<WireRecord<Profile>> => {
+        const profile = acornToWeProfile(payload, await getMyNickname(weServices))
+        await weServices.profilesStore.updateProfile(profile)
+        return {
+            actionHash: null,
+            entryHash: null,
+            entry: payload,
+            createdAt: null,
+            updatedAt: null,
+        }
+    },
+    updateWhoami: async (cellId: CellId, payload: UpdateInput<Profile>): Promise<WireRecord<Profile>> => {
+        const profile = acornToWeProfile(payload.entry, await getMyNickname(weServices))
+        await weServices.profilesStore.updateProfile(profile)
+        return {
+            actionHash: null,
+            entryHash: null,
+            entry: payload.entry,
+            createdAt: null,
+            updatedAt: null,
+        }
+    },
+    whoami: async (cellId: CellId): Promise<WhoAmIOutput> => {
+        let myWeProfile
+        (await weServices.profilesStore.fetchMyProfile()).subscribe((profile) => {myWeProfile = profile})
+        return {
+            actionHash: null,
+            entryHash: null,
+            entry: weToAcornProfile(myWeProfile),
+            createdAt: null,
+            updatedAt: null,
+        }
+    },
+    fetchAgents: async (cellId: CellId): Promise<Array<Profile>> => {
+      return callZome(
+        appWebsocket,
+        cellId,
+        PROFILES_ZOME_NAME,
+        ZOME_FN_NAMES.FETCH_AGENTS,
+        null
+      )
+    },
+    fetchAgentAddress: async (cellId: CellId): Promise<AgentPubKeyB64> => {
+      return callZome(
+        appWebsocket,
+        cellId,
+        PROFILES_ZOME_NAME,
+        ZOME_FN_NAMES.FETCH_AGENT_ADDRESS,
+        null
+      )
+    },
+  }
+}
+
+export default class WeProfilesZomeApi {
+  appWebsocket: AppWebsocket
+  profile: ReturnType<typeof WeProfilesApi>
+  constructor(appWebsocket: AppWebsocket, weServices: WeServices) {
+    this.appWebsocket = appWebsocket
+    this.profile = WeProfilesApi(appWebsocket, weServices)
+  }
+}