Merge pull request #7 from oceanprotocol/feature/curation

get curation and curation utils

src/hooks/useMetadata/useMetadata.ts

@@ -1,6 +1,6 @@
 import { useState, useEffect } from 'react'
 import axios from 'axios'
-import { DID, DDO, MetaData } from '@oceanprotocol/squid'
+import { DID, DDO, MetaData, Curation } from '@oceanprotocol/squid'
 import { useOcean } from '../../providers'
 
 interface UseMetadata {
@@ -9,6 +9,7 @@ interface UseMetadata {
   title: string
   getDDO: (did: DID | string) => Promise<DDO>
   getMetadata: (did: DID | string) => Promise<MetaData>
+  getCuration: (did: DID | string) => Promise<Curation>
   getTitle: (did: DID | string) => Promise<string>
   getAllDIDs: () => Promise<DID[]>
 }
@@ -30,6 +31,11 @@ function useMetadata(did?: DID | string): UseMetadata {
     return metadata.attributes
   }
 
+  async function getCuration(did: DID | string): Promise<Curation> {
+    const metadata = await getMetadata(did)
+    return metadata.curation
+  }
+
   async function getTitle(did: DID | string): Promise<string> {
     const metadata = await getMetadata(did)
     return metadata.main.name
@@ -52,7 +58,16 @@ function useMetadata(did?: DID | string): UseMetadata {
     init()
   }, [])
 
-  return { ddo, metadata, title, getDDO, getMetadata, getTitle, getAllDIDs }
+  return {
+    ddo,
+    metadata,
+    title,
+    getDDO,
+    getMetadata,
+    getCuration,
+    getTitle,
+    getAllDIDs
+  }
 }
 
 export { useMetadata, UseMetadata }

src/index.ts

@@ -2,4 +2,5 @@ export * from './providers'
 export * from './hooks'
 // export * from './components'
 
+export * from './utils/curationUtils'
 export * from './utils'

src/utils/curationUtils.ts

@@ -0,0 +1,84 @@
+import axios, { AxiosResponse } from 'axios'
+import Web3 from 'web3'
+import { DID } from '@oceanprotocol/squid'
+
+export declare type RatingResponse = [string, number]
+export declare type GetRatingResponse = {
+  comment: string
+  datePublished: string
+  vote: number
+}
+
+export function gethash(message: string) {
+  let hex = ''
+  for (let i = 0; i < message.length; i++) {
+    hex += '' + message.charCodeAt(i).toString(16)
+  }
+  const hexMessage = '0x' + hex
+  return hexMessage
+}
+
+export async function rateAsset({
+  did,
+  web3,
+  value,
+  configUrl
+}: {
+  did: DID | string
+  web3: Web3
+  value: number
+  configUrl: string
+}): Promise<RatingResponse | string> {
+  try {
+    const timestamp = Math.floor(+new Date() / 1000)
+    const accounts = await web3.eth.getAccounts()
+    const signature = await web3.eth.personal.sign(
+      gethash(`${timestamp}`),
+      accounts ? accounts[0] : '',
+      ''
+    )
+    const ratingBody = {
+      did,
+      vote: value,
+      comment: '',
+      address: accounts[0],
+      timestamp: timestamp,
+      signature: signature
+    }
+
+    const response: AxiosResponse = await axios.post(configUrl, ratingBody)
+    if (!response) return 'No Response'
+    return response.data
+  } catch (error) {
+    console.error(error.message)
+    return `Error: ${error.message}`
+  }
+}
+
+export async function getAssetRating({
+  did,
+  account,
+  configUrl
+}: {
+  did: DID | string
+  account: string
+  configUrl: string
+}): Promise<GetRatingResponse | undefined> {
+  try {
+    if (!account) return
+
+    const response = await axios.get(configUrl, {
+      params: {
+        did: did,
+        address: account
+      }
+    })
+    const votesLength = response.data.length
+
+    if (votesLength > 0) {
+      return response.data[votesLength - 1]
+    }
+  } catch (error) {
+    console.error(error.message)
+  }
+}