@@ -11,15 +11,15 @@ const reducer = (accumulator, currentValue) => accumulator + currentValue;
1111const getIpfsHash = async ( ipfsHash ) => {
1212
1313 return await axios . get ( 'https://cloudflare-ipfs.com/ipfs/' + ipfsHash ) . then ( res => res . data )
14- /* const nftDetailJson = await nftDetails.json();
15-
16- const nftName = nftDetailJson.name;
17- const nftDescription = nftDetailJson.description;
18- const nftCreators = nftDetailJson.creators.join(', ');
19- const nftArtifact = `https://cloudflare-ipfs.com/ipfs/${nftDetailJson.formats[0].uri.toString().slice(7)}`;
20- const nftArtifactType = nftDetailJson.formats[0].mimeType.toString();
21-
22- return { name: nftName, description: nftDescription, creators: nftCreators, artifactUrl: nftArtifact, artifactType: nftArtifactType }; */
14+ /* const nftDetailJson = await nftDetails.json();
15+
16+ const nftName = nftDetailJson.name;
17+ const nftDescription = nftDetailJson.description;
18+ const nftCreators = nftDetailJson.creators.join(', ');
19+ const nftArtifact = `https://cloudflare-ipfs.com/ipfs/${nftDetailJson.formats[0].uri.toString().slice(7)}`;
20+ const nftArtifactType = nftDetailJson.formats[0].mimeType.toString();
21+
22+ return { name: nftName, description: nftDescription, creators: nftCreators, artifactUrl: nftArtifact, artifactType: nftArtifactType }; */
2323}
2424const getObjkts = async ( ) => {
2525 return await axios . get ( `https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens` ) . then ( res => res . data )
@@ -32,18 +32,21 @@ const getTokenHolders = async (tk_id) => {
3232const getTokenHoldersArr = async ( arr ) => {
3333
3434 return await arr . map ( async e => await axios . get ( 'https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens/holders?token_id=' + e ) . then ( res => res . data ) )
35- /* await axios.get('https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens/holders?token_id=' + arr[0]).then(res => console.log(res.data))
36- */ /* var result = arr.map(async e => {
37- return await axios.get('https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens/holders?token_id=' + e).then(res => res.data)
38- })
39-
40- console.log(result) */
35+ /* await axios.get('https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens/holders?token_id=' + arr[0]).then(res => console.log(res.data))
36+ */ /* var result = arr.map(async e => {
37+ return await axios.get('https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens/holders?token_id=' + e).then(res => res.data)
38+ })
39+
40+ console.log(result) */
4141}
4242
43- const totalAmount = async ( obj ) => {
43+ const owners = async ( obj ) => {
4444 var owners = await axios . get ( 'https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens/holders?token_id=' + obj . token_id ) . then ( res => res . data )
4545 var values_arr = ( _ . values ( owners ) )
46- obj . total_amount = ( values_arr . map ( e => parseInt ( e ) ) ) . reduce ( reducer )
46+ console . log ( owners )
47+ obj . owners = owners
48+ console . log ( obj )
49+ //obj.total_amount = (values_arr.map(e => parseInt(e))).reduce(reducer)
4750 return obj
4851}
4952
@@ -68,17 +71,17 @@ const objktOwners = async (arr) => {
6871
6972const getObjktLedger = async ( ) => await axios . get ( 'https://better-call.dev/v1/bigmap/mainnet/511/keys?size=6500' ) . then ( res => res . data . map ( e => ( { amount : parseInt ( e . data . value . value ) , tz : e . data . key . children [ 0 ] . value , tk_id : parseInt ( e . data . key . children [ 1 ] . value ) } ) ) )
7073const gethDAOLedger = async ( ) => await axios . get ( 'https://api.better-call.dev/v1/bigmap/mainnet/519/keys?size=4000' ) . then ( res => res . data . map ( e => {
71- return { token_id : parseInt ( e . data . key . value ) , hDAO_balance : parseInt ( e . data . value . children [ 0 ] . value ) }
74+ return { token_id : parseInt ( e . data . key . value ) , hDAO_balance : parseInt ( e . data . value . children [ 0 ] . value ) }
7275} ) )
7376
74- gethDAOLedger ( )
77+ // gethDAOLedger()
7578
7679
7780const getSwaps = async ( ) => {
7881 return await axios . get ( `https://api.better-call.dev/v1/bigmap/mainnet/523/keys?size=6000` ) . then ( res => {
7982 return ( res . data ) . map ( e => {
8083 var obj = { }
81-
84+
8285 obj [ 'swap_id' ] = e . data . key . value
8386 e . data . value != null ? e . data . value . children . map ( e => obj [ e . name ] = e . value ) : null
8487 return obj
@@ -111,44 +114,53 @@ const mergeSwaps = (arr, swaps) => {
111114 return arr
112115}
113116
114- const desc = arr => _ . sortBy ( arr , e => parseInt ( e . token_id ) ) . reverse ( )
115- const offset = ( arr , set ) => arr . slice ( set * 10 , set * 10 + 10 )
117+ const desc = arr => _ . sortBy ( arr , e => parseInt ( e . objectId ) ) . reverse ( )
118+ const offset = ( arr , set ) => arr . slice ( set * 30 , set * 30 + 30 )
116119
117120const filter = ( data , tz ) => _ . filter ( data , ( e ) => {
118121 if ( e . token_info != undefined ) {
119- return e . token_info . creators [ 0 ] === tz
122+ return e . token_info . creators [ 0 ] === tz
120123 }
121124} )
122125
123- const filterTz = ( data , tz ) => _ . filter ( data , { tz : tz } )
126+ const filterTz = ( data , tz ) => _ . filter ( data , { tz : tz } )
124127
125128const test = async ( ) => console . log ( desc ( await getObjkts ( ) ) )
126-
129+
127130const getFeed = async ( counter , res ) => {
128- var feed = offset ( desc ( await getObjkts ( ) ) , counter )
129- var swaps = await getSwaps ( )
130- var arr = await objktAmount ( mergeSwaps ( feed , swaps ) )
131- var promise = Promise . all ( arr . map ( e => e ) )
132-
133- promise . then ( ( results ) => {
131+ var arr = await conseilUtil . getArtisticUniverse ( 0 )
132+ var feed = offset ( desc ( arr ) , counter )
133+ console . log ( feed )
134+ feed = await feed . map ( async e => {
135+ e . token_info = await getIpfsHash ( e . ipfsHash )
136+ e . token_id = parseInt ( e . objectId )
137+ console . log ( e )
138+ return e
139+ } )
140+ //console.log(feed)
141+
142+ var promise = Promise . all ( feed . map ( e => e ) )
143+ promise . then ( async ( results ) => {
134144 var aux_arr = results . map ( e => e )
145+
135146 //console.log(aux_arr)
136- res . json ( { result : aux_arr } )
137- } ) . catch ( e => {
138- res . status ( 500 ) . json ( { error : 'downstream API failure' } )
147+ res . json ( { result : aux_arr } )
139148 } )
140149}
141150//getFeed(1)
142- const filterObjkts = ( arr , id_arr ) => _ . filter ( arr , { token_id : tk . id } )
151+ const filterObjkts = ( arr , id_arr ) => _ . filter ( arr , { token_id : tk . id } )
143152//console.log(_.find(ledger, { tz : 'KT1Hkg5qeNhfwpKW4fXvq7HGZB9z2EnmCCA9'}))
144153
145154const getTzLedger = async ( tz , res ) => {
146- /* var ledger = desc(await getObjktLedger())
147- var objkts = await getObjkts()
148- var tzLedger = _.map(filterTz(ledger, tz), (obj) => _.assign(obj, _.find(objkts, { token_id : obj.tk_id })))
149- */
155+ /* var ledger = desc(await getObjktLedger())
156+ var objkts = await getObjkts()
157+ var tzLedger = _.map(filterTz(ledger, tz), (obj) => _.assign(obj, _.find(objkts, { token_id : obj.tk_id })))
158+ */
150159 var collection = await conseilUtil . getCollectionForAddress ( tz )
151160 var creations = await conseilUtil . getArtisticOutputForAddress ( tz )
161+ var hdao = await conseilUtil . gethDaoBalanceForAddress ( tz )
162+
163+ console . log ( hdao )
152164
153165 var arr = [ ]
154166
@@ -165,14 +177,15 @@ const getTzLedger = async (tz, res) => {
165177 } )
166178
167179 var promise = Promise . all ( result . map ( e => e ) )
168- promise . then ( results => {
180+ promise . then ( async results => {
169181 var result = results . map ( e => e )
170182 console . log ( result )
171- res . json ( { result : _ . uniqBy ( result , ( e ) => {
172- return e . token_id
173- } ) } )
174- } ) . catch ( e => {
175- res . status ( 500 ) . json ( { error : 'downstream API failure' } )
183+ res . json ( {
184+ result : _ . uniqBy ( result , ( e ) => {
185+ return e . token_id
186+ } ) ,
187+ hdao : hdao
188+ } )
176189 } )
177190
178191 //return tzLedger
@@ -181,23 +194,24 @@ const getTzLedger = async (tz, res) => {
181194const getObjktById = async ( id , res ) => {
182195 var objkt = await conseilUtil . getObjectById ( id )
183196 objkt . token_id = objkt . objectId
184- objkt = await totalAmountIntegral ( objkt )
197+ objkt = await owners ( objkt )
185198 objkt . token_info = await getIpfsHash ( objkt . ipfsHash )
186- //console.log(objkt)
187- //return objkt
199+ console . log ( objkt )
200+
201+ return objkt
188202 //res.json({ result : objkt })
189203 //var objkts = await getObjkts()
190- var swaps = await getSwaps ( )
191- res . json ( { result : mergeSwaps ( [ objkt ] , swaps ) [ 0 ] } )
204+ // var swaps = await getSwaps()
205+ // res.json({ result : mergeSwaps([objkt], swaps)[0] })
192206 //console.log(_.filter(mergeSwaps(objkts, swaps), {token_id : id}))
193- // var arr = await objktOwners(_.filter(mergeSwaps(objkts, swaps), {token_id : id}))
194- // var promise = Promise.all(arr.map(e => e))
195-
196- /* promise.then((results) => {
197- var aux_arr = results.map(e => e)
198- console.log(aux_arr)
199- res.json({ result : aux_arr })
200- }) */
207+ // var arr = await objktOwners(_.filter(mergeSwaps(objkts, swaps), {token_id : id}))
208+ // var promise = Promise.all(arr.map(e => e))
209+
210+ /* promise.then((results) => {
211+ var aux_arr = results.map(e => e)
212+ console.log(aux_arr)
213+ res.json({ result : aux_arr })
214+ }) */
201215 //https://api.better-call.dev/v1/contract/mainnet/KT1RJ6PbjHpwc3M5rw5s2Nbmefwbuwbdxton/tokens/holders?token_id=842
202216}
203217
@@ -214,17 +228,17 @@ const hDAOFeed = async (counter, res) => {
214228 var promise = Promise . all ( objkts . map ( e => e ) )
215229 promise . then ( results => {
216230 var result = results . map ( e => e )
217- res . json ( { result : offset ( result , counter ) } )
218- } ) . catch ( e => {
219- res . status ( 500 ) . json ( { error : 'downstream API failure' } )
231+ res . json ( { result : offset ( result , counter ) } )
232+ } ) . catch ( e => {
233+ res . status ( 500 ) . json ( { error : 'downstream API failure' } )
220234 } )
221235}
222236
223237//getObjkts()
224238//testSwaps()
225239//getFeed(0)
226240//getTzLedger('tz1UBZUkXpKGhYsP5KtzDNqLLchwF4uHrGjw')
227- //getObjktById(4441 )
241+ //getObjktById(6246 )
228242//const test2 = async () => console.log(await getObjktLedger())
229243//test2()
230244
@@ -240,18 +254,18 @@ app.post('/feed', async (req, res) => {
240254app . post ( '/tz' , async ( req , res ) => {
241255 console . log ( req . body . tz )
242256 await getTzLedger ( req . body . tz , res )
243- //res.json({ result : await getTzLedger(req.body.tz) })
257+
244258} )
245259
246260app . post ( '/objkt' , async ( req , res ) => {
247- await getObjktById ( req . body . objkt_id , res )
261+ res . json ( { result : await getObjktById ( req . body . objkt_id ) } )
248262} )
249263
250264app . post ( '/hdao' , async ( req , res ) => {
251265 await hDAOFeed ( parseInt ( req . body . counter ) , res )
252266} )
253267
254- // app.listen(3001)
268+ app . listen ( 3001 )
255269module . exports . handler = serverless ( app )
256270
257271//testTkHolder([{'kt' : 2020}, {'kt' : 2021}])
0 commit comments