stronk/RandomChad
1
0
Fork 0
mirror of https://github.com/stronk-dev/RandomChad.git synced 2025-07-05 10:35:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

🐛 fix address case bug

Browse Source
This commit is contained in:
Mentor 2022-07-18 15:48:38 +02:00
parent aa5f2275ee
commit 63a08dcc2f
2 changed files with 28 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
functions/integrations/changingroom.js
View File

@ -214,8 +214,9 @@ exports.notify_holders_of_changing_room_updates = async context => {
try { try {
// Get all Rocketeers with outfits available // Get all Rocketeers with outfits available
const network = dev ? `rinkeby` : `mainnet` // const network = dev ? `rinkeby` : `mainnet`
const limit = dev ? 5 : 5000 // max supply 3475 const network = 'mainnet'
const limit = dev ? 5000 : 5000 // max supply 3475
console.log( `Getting ${ limit } rocketeers on ${ network }` ) console.log( `Getting ${ limit } rocketeers on ${ network }` )
let all_rocketeers = await db.collection( `${ network }Rocketeers` ).limit( limit ).get().then( dataFromSnap ) let all_rocketeers = await db.collection( `${ network }Rocketeers` ).limit( limit ).get().then( dataFromSnap )
console.log( `Got ${ all_rocketeers.length } Rocketeers` ) console.log( `Got ${ all_rocketeers.length } Rocketeers` )
@ -239,15 +240,32 @@ exports.notify_holders_of_changing_room_updates = async context => {
} ) } )
// Get owner cache
const one_day_in_ms = 1000 * 60 * 60 * 24
const owner_cache = await db.collection( `rocketeer_owner_cache` ).where( 'updated', '>', Date.now() - one_day_in_ms ).get().then( dataFromSnap )
// Get the owning wallets of available outfits // Get the owning wallets of available outfits
const owner_getting_queue = has_outfit_available.map( ( { uid } ) => async () => { const owner_getting_queue = has_outfit_available.map( ( { uid } ) => async () => {
log( `Getting owner of ${ uid }` )
// Try for cached owner
const cached_owner = owner_cache.find( ( { tokenId } ) => uid == tokenId )
if( cached_owner ) return cached_owner
// Ask infura for owner
const owning_address = await getOwingAddressOfTokenId( uid ) const owning_address = await getOwingAddressOfTokenId( uid )
return { uid, owning_address } return { uid, owning_address }
} ) } )
let owners = await throttle_and_retry( owner_getting_queue, 10, `get owners`, 2, 5 ) let owners = await throttle_and_retry( owner_getting_queue, 50, `get owners`, 2, 5 )
console.log( `${ owners.length } Rocketeer owners found` ) console.log( `${ owners.length } Rocketeer owners found` )
// Set owner cache to spare infura
const owner_cache_writing_queue = owners.map( ( { uid, owning_address } ) => () => {
return db.collection( `rocketeer_owner_cache` ).doc( uid ).set( { tokenId: uid, owning_address, updated: Date.now(), updated_human: new Date().toString() }, { merge: true } )
} )
await throttle_and_retry( owner_cache_writing_queue, 50, `writing owner cache`, 2, 10 )
// Get the owners we have already emailed recently // Get the owners we have already emailed recently
const owner_meta = await db.collection( `meta` ).get().then( dataFromSnap ) const owner_meta = await db.collection( `meta` ).get().then( dataFromSnap )
const owners_emailed_recently = owner_meta const owners_emailed_recently = owner_meta
@ -260,7 +278,7 @@ exports.notify_holders_of_changing_room_updates = async context => {
// Check which owners have signer.is emails // Check which owners have signer.is emails
const owners_with_signer_email = await ask_signer_is_for_available_emails( owners.map( ( { owning_address } ) => owning_address ) ) const owners_with_signer_email = await ask_signer_is_for_available_emails( owners.map( ( { owning_address } ) => owning_address ) )
console.log( `Owners with signer emails ${ owners_with_signer_email.length }` ) console.log( `Owners with signer emails ${ owners_with_signer_email.length }: ` )
// Format rocketeers by address // Format rocketeers by address
const rocketeers_by_address = has_outfit_available.reduce( ( wallets, rocketeer ) => { const rocketeers_by_address = has_outfit_available.reduce( ( wallets, rocketeer ) => {
@ -269,7 +287,7 @@ exports.notify_holders_of_changing_room_updates = async context => {
const { owning_address } = owners.find( ( { uid } ) => uid == rocketeer.uid ) const { owning_address } = owners.find( ( { uid } ) => uid == rocketeer.uid )
// If this owner has no email, ignore it // If this owner has no email, ignore it
if( !owners_with_signer_email.includes( owning_address ) ) return new_wallet_list if( !owners_with_signer_email.includes( owning_address.toLowerCase() ) ) return new_wallet_list
// If the wallet object does now have this one yet, add an empty array // If the wallet object does now have this one yet, add an empty array
if( !new_wallet_list[ owning_address ] ) new_wallet_list[owning_address] = [] if( !new_wallet_list[ owning_address ] ) new_wallet_list[owning_address] = []
@ -285,9 +303,7 @@ exports.notify_holders_of_changing_room_updates = async context => {
// Take note of who we emailed so as to not spam them // Take note of who we emailed so as to not spam them
const meta_writing_queue = owners_to_email.map( ( address ) => () => { const meta_writing_queue = owners_to_email.map( ( address ) => () => {
return db.collection( `meta` ).doc( address ).set( { last_emailed_about_outfit: Date.now(), updated: Date.now(), updated_human: new Date().toString() }, { merge: true } ) return db.collection( `meta` ).doc( address ).set( { last_emailed_about_outfit: Date.now(), updated: Date.now(), updated_human: new Date().toString() }, { merge: true } )
} ) } )
await throttle_and_retry( meta_writing_queue, 50, `keep track of who we emailed`, 2, 10 ) await throttle_and_retry( meta_writing_queue, 50, `keep track of who we emailed`, 2, 10 )
@ -305,7 +321,7 @@ exports.notify_holders_of_changing_room_updates = async context => {
console.log( `Sent ${ owners_to_email.length } emails for ${ network } outfits` ) console.log( `Sent ${ owners_to_email.length } emails for ${ network } outfits` )
// Notify Discord too // Notify Discord too
await notify_discord_of_outfit_notifications( owners_to_email.length ) await notify_discord_of_outfit_notifications( owners_to_email.length, owners.length )
} catch( e ) { } catch( e ) {

6
functions/integrations/discord.js
View File

@ -37,16 +37,16 @@ exports.notify_discord_of_new_outfit = async function( username, content, avatar
} }
exports.notify_discord_of_outfit_notifications = async function( amount=0 ) { exports.notify_discord_of_outfit_notifications = async function( amount_notified=0, amount_with_available=0 ) {
if( !dev && amount == 0 ) return console.log( `Not sending Discord message for 0 updates` ) if( !dev && amount_with_available == 0 ) return console.log( `Not sending Discord message for 0 updates` )
try { try {
// Construct discord webhook message // Construct discord webhook message
const message = { const message = {
username: "Gretal Marchall Alon of Jupiter", username: "Gretal Marchall Alon of Jupiter",
content: `I emailed ${ amount } Rocketeer holders to tell them they have new outfits available in the changing room at https://mint.rocketeer.fans/#/outfits. Want to get email notifications too? Create an email address for your wallet at: https://signer.is/#/email, you'll get a monthly email when your Rocketeers have outfits available.`, content: `${ amount_with_available } Rocketeers have outfits available. I emailed ${ amount_notified } holders to tell them they have new outfits available in the changing room at https://mint.rocketeer.fans/#/outfits. Want to get email notifications too? Create an email address for your wallet at: https://signer.is/#/email, you'll get a monthly email when your Rocketeers have outfits available.`,
avatar_url: "https://storage.googleapis.com/rocketeer-nft.appspot.com/mainnetRocketeers/1.jpg" avatar_url: "https://storage.googleapis.com/rocketeer-nft.appspot.com/mainnetRocketeers/1.jpg"
} }