Discord Message Post Points Integration

const discordId = inputData.user_discord_id || '';
const bearerToken = '******'; //CHANGE THIS TO YOUR API KEY
const graphqlEndpoint = 'https://gql3.absinthe.network/v1/graphql';

const formatDate = (date) => date.toISOString();
const now = new Date();
const twentyFourHoursAgo = new Date(now - 24 * 60 * 60 * 1000);
const dailyPointThreshold = 100; //CHANGE THIS TO YOUR DESIRED VALUE
const pointsToIssue = 10; //CHANGE THIS TO YOUR DESIRED VALUE
const eventName = "message_posted"; //CHANGE THIS TO YOUR EVENT NAME YOU REGISTERED
const accountType = "DISCORD_USERNAME";

const aggregateQuery = `
query GetAllEvents {
    api_points_aggregate(
    where: {
        account_id: { _eq: "${discordId}" }
        event_name: { _eq: "${eventName}" }
        created_at: { 
        _gte: "${formatDate(twentyFourHoursAgo)}", 
        _lt: "${formatDate(now)}"
        }
    }
    ) {
    aggregate {
        sum {
        amount
        }
    }
    }
}
`;

const issueMutation = `
mutation IssueOffChainPoints {
    insert_api_points_one(object: {
    account_id: "${discordId}",
    amount: ${pointsToIssue},
    event_name: "${eventName}",
    identity_type: ${accountType},
    }) {
    id
    }
}
`;

const url = 'https://gql3.absinthe.network/v1/graphql';
const headers = {
'Content-Type': 'application/json',
'Accept': 'application/json',
'Authorization': `Bearer ${bearerToken}`
};

const makeRequest = (query, callback) => {
fetch(url, {
    method: 'POST',
    headers: headers,
    body: JSON.stringify({ query: query })
})
    .then(response => response.json())
    .then(data => callback(null, data))
    .catch(error => callback(error));
};

makeRequest(aggregateQuery, (error, data) => {
if (error) {
    callback(error);
    return;
}

const pointsIn24Hours = data.data.api_points_aggregate.aggregate.sum.amount || 0;
console.log(`Points in last 24 hours: ${pointsIn24Hours}`);

if (pointsIn24Hours < dailyPointThreshold) {
    console.log("Less than point threshold in 24 hours. Issuing new points...");
    makeRequest(issueMutation, (error, data) => {
    if (error) {
        callback(error);
        return;
    }
    console.log("Points issued successfully:", data);
    callback(null, { success: true, response: data });
    });
} else {
    console.log("too many points in 24 hours. Not issuing new points.");
    callback(null, { success: true, message: "No new points issued due to threshold" });
}
});

    mutation RegisterOffChainEvent {
    insert_points_config_registered_events_one(object: {event_name: "my_points_event", 
      description: "This is a sample points event."}) {
        uuid_id
        created_at
        added_by
      }
    }

    {
    "Authorization": "Bearer <YOUR_API_KEY_HERE>"
    }