version 0.2.7

codegen.yml

@@ -0,0 +1,5 @@
+schema: http://localhost:8000/subgraphs/name/daostack
+generates:
+  ./src/types.d.ts:
+    plugins:
+      - typescript

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@daostack/client",
-  "version": "0.2.6",
+  "version": "0.2.7",
   "description": "",
   "keywords": [],
   "main": "dist/lib/index.js",

src/arc.ts

@@ -55,7 +55,7 @@ export class Arc extends GraphNodeObserver {
     ipfsProvider?: IPFSProvider
     web3Provider?: string
     web3ProviderRead?: string
-}) {
+  }) {
     super({
       graphqlHttpProvider: options.graphqlHttpProvider,
       graphqlWsProvider: options.graphqlWsProvider

test/cache.spec.ts

@@ -0,0 +1,78 @@
+import { first } from 'rxjs/operators'
+// import { ApolloClient } from 'apollo-client'
+// import gql from 'graphql-tag'
+// import { Observable, Observer } from 'rxjs'
+import { Arc } from '../src/arc'
+// import { createApolloClient } from '../src/graphnode'
+import { getContractAddressesFromMigration } from '../src/utils'
+import { graphqlHttpProvider, graphqlWsProvider
+  // , mintSomeReputation, waitUntilTrue
+} from './utils'
+
+// function getClient() {
+//   const apolloClient = createApolloClient({
+//     graphqlHttpProvider,
+//     graphqlWsProvider
+//   })
+//   return apolloClient
+// }
+
+jest.setTimeout(20000)
+/**
+ * Token test
+ */
+describe('apolloClient', () => {
+  // let client: any
+
+  it('pre-fetching DAOs works', async () => {
+    const arc = new Arc({
+      contractInfos: getContractAddressesFromMigration('private'),
+      graphqlHttpProvider,
+      graphqlWsProvider,
+      ipfsProvider: '',
+      web3Provider: 'ws://127.0.0.1:8545'
+    })
+
+    const client = arc.apolloClient
+    // get all DAOs
+    const daos = await arc.daos().pipe(first()).toPromise()
+    // @ts-ignore
+    console.log(client.cache.data.data)
+    // we should now be able to get data of individual DAOs without hitting the server
+    const p = arc.dao(daos[0].id).state({ fetchPolicy: 'cache-only'}).pipe(first()).toPromise()
+    expect(p).rejects.toThrow()
+
+    // now get all the DAOs with defailed data
+    await arc.daos({}, { fetchAllData: true }).pipe(first()).toPromise()
+    const dao = await arc.dao(daos[0].id).state({ fetchPolicy: 'cache-only'}).pipe(first()).toPromise()
+    // @ts-ignore
+    // console.log(client.cache.data.data)
+    console.log(dao.address)
+
+    //
+    const result = await arc.daos({ where: { name: dao.name}}, { fetchPolicy: 'cache-only'}).pipe(first()).toPromise()
+    console.log(result)
+
+    // const observable = arc.getObservable(query)
+    //
+    // const returnedData: object[] = []
+    //
+    // const subscription = observable.subscribe(
+    //   (eventData: any) => {
+    //     // Do something on receipt of the event
+    //     returnedData.push(eventData.data)
+    //   },
+    //   (err: any) => {
+    //     throw err
+    //   }
+    // )
+    //
+    // await mintSomeReputation()
+    // await mintSomeReputation()
+    //
+    // await waitUntilTrue(() => returnedData.length >= 2 )
+    // expect(cntr).toEqual(3)
+    // subscription.unsubscribe()
+  })
+
+})