Hi I tried to clone the project from
and pasted the cloud functions into my server but it doesn’t seem to work
getting the following err in dashboard logs
Error: Invalid function: “watchEthAddress”
at handleCloudFunction (/moralis-server/lib/Routers/FunctionsRouter.js:119:13)
at /moralis-server/lib/PromiseRouter.js:85:20
at processTicksAndRejections (internal/process/task_queues.js:95:5)
My cloud func is setup identical to the cloud-query.js file in the repo
Moralis.Cloud.define("searchEthAddress", async function (request) {
const { address } = request.params;
if (!address) {
return null;
}
// find out if address is already watched
const query = new Moralis.Query("WatchedEthAddress");
query.equalTo("address", address);
const watchCount = await query.count();
if (watchCount > 0) {
// already watched don't sync again
return null;
}
return Moralis.Cloud.run("watchEthAddress", { address });
});
Moralis.Cloud.define("getTransactions", function (request) {
const { userAddress, pageSize, pageNum } = request.params;
const offset = (pageNum - 1) * pageSize;
const query = new Moralis.Query("EthTransactions");
query.equalTo("from_address", userAddress);
query.descending("block_number");
query.withCount();
query.skip(offset);
query.limit(pageSize);
return query.find();
});
Moralis.Cloud.define("getTokenTranfers", async (request) => {
const { userAddress, pageSize, pageNum } = request.params;
const offset = (pageNum - 1) * pageSize;
const output = {
results: [],
count: 0,
};
// count results
const matchPipeline = {
match: {
$expr: {
$or: [
{ $eq: ["$from_address", userAddress] },
{ $eq: ["$to_address", userAddress] },
],
},
},
sort: { block_number: -1 },
count: "count",
};
const query = new Moralis.Query("EthTokenTransfers");
const countResult = await query.aggregate(matchPipeline);
output.count = countResult[0].count;
// get page results
const lookupPipeline = {
...matchPipeline,
skip: offset,
limit: pageSize,
lookup: {
from: "EthTokenBalance",
let: { tokenAddress: "$token_address", userAddress },
pipeline: [
{
$match: {
$expr: {
$and: [
{ $eq: ["$token_address", "$$tokenAddress"] },
{ $eq: ["$address", "$$userAddress"] },
],
},
},
},
],
as: "EthTokenBalance",
},
unwind: "$EthTokenBalance",
};
delete lookupPipeline.count;
output.results = await query.aggregate(lookupPipeline);
return output;
});
Moralis.Cloud.define("getTokenBalances", async (request) => {
const { userAddress, pageSize, pageNum } = request.params;
const offset = (pageNum - 1) * pageSize;
// count results
const query = new Moralis.Query("EthTokenBalance");
const matchPipeline = {
match: {
address: userAddress,
contract_type: "ERC20",
balance: { $ne: "0" },
},
};
const countPipeline = { ...matchPipeline, count: "count" };
const countResult = await query.aggregate(countPipeline);
// get page
const pagePipeline = {
...matchPipeline,
addFields: {
adjBal: {
$divide: [
{ $toDouble: "$balance" },
{ $pow: [10, { $toDouble: "$decimals" }] },
],
},
},
sort: { adjBal: -1 },
skip: offset,
limit: pageSize,
};
const pageResults = await query.aggregate(pagePipeline);
const output = {
results: pageResults,
count: countResult[0].count,
};
return output;
});
