Referral software for B2C, FinTech, and SaaS. Our customers see 312% ROI, 30% new leads, 15% ARR growth from referrals.
Create a new document in a collection of your choice. See the docs here
Execute an aggregation pipeline on a MongoDB collection. See the documentation
GrowSurf is a referral platform that can amplify your growth efforts by incentivizing word-of-mouth marketing. By harnessing the GrowSurf API on Pipedream, you can automate campaign management, track participant performance, reward achievements, and sync referral data across your marketing stack. This seamless integration enables personalized engagement with your audience, targeted follow-ups, and real-time analytics for informed decision-making.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
growsurf: {
type: "app",
app: "growsurf",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://api.growsurf.com/v2/campaigns`,
headers: {
Authorization: `Bearer ${this.growsurf.$auth.api_key}`,
},
})
},
})
The MongoDB API provides powerful capabilities to interact with a MongoDB database, allowing you to perform CRUD (Create, Read, Update, Delete) operations, manage databases, and execute sophisticated queries. With Pipedream, you can harness these abilities to automate tasks, sync data across various apps, and react to events in real-time. It’s a combo that’s particularly potent for managing data workflows, syncing application states, or triggering actions based on changes to your data.
import mongodb from 'mongodb'
export default defineComponent({
props: {
mongodb: {
type: "app",
app: "mongodb",
},
collection: {
type: "string"
},
filter: {
type: "object"
}
},
async run({steps, $}) {
const MongoClient = mongodb.MongoClient
const {
database,
hostname,
username,
password,
} = this.mongodb.$auth
const url = `mongodb+srv://${username}:${password}@${hostname}/test?retryWrites=true&w=majority`
const client = await MongoClient.connect(url, {
useNewUrlParser: true,
useUnifiedTopology: true
})
const db = client.db(database)
const results = await db.collection(this.collection).find(this.filter).toArray();
$.export('results', results);
await client.close()
},
})