feat: add 22 zero-dependency CLI tools for marketing platforms
Single-file Node.js scripts for every tool in the registry that lacked
a CLI. All follow the same pattern: env var auth, JSON output, consistent
`{tool} <resource> <action>` command structure, zero npm dependencies.
CLIs added: resend, sendgrid, mailchimp, kit, customer-io, ahrefs,
semrush, google-search-console, ga4, mixpanel, amplitude, segment,
adobe-analytics, rewardful, tolt, mention-me, dub, google-ads,
meta-ads, linkedin-ads, tiktok-ads, zapier.
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
Corey Haines
Executable
+227
@@ -0,0 +1,227 @@
|
||||
#!/usr/bin/env node
|
||||
|
||||
const TOKEN = process.env.MIXPANEL_TOKEN
|
||||
const API_KEY = process.env.MIXPANEL_API_KEY
|
||||
const SECRET = process.env.MIXPANEL_SECRET
|
||||
const INGESTION_URL = 'https://api.mixpanel.com'
|
||||
const QUERY_URL = 'https://mixpanel.com/api/2.0'
|
||||
const EXPORT_URL = 'https://data.mixpanel.com/api/2.0'
|
||||
|
||||
if (!TOKEN && !API_KEY) {
|
||||
console.error(JSON.stringify({ error: 'MIXPANEL_TOKEN (for ingestion) or MIXPANEL_API_KEY + MIXPANEL_SECRET (for query/export) environment variables required' }))
|
||||
process.exit(1)
|
||||
}
|
||||
|
||||
async function ingestApi(method, path, body) {
|
||||
const res = await fetch(`${INGESTION_URL}${path}`, {
|
||||
method,
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
body: body ? JSON.stringify(body) : undefined,
|
||||
})
|
||||
const text = await res.text()
|
||||
try {
|
||||
return JSON.parse(text)
|
||||
} catch {
|
||||
return { status: res.status, body: text }
|
||||
}
|
||||
}
|
||||
|
||||
async function queryApi(method, baseUrl, path, params) {
|
||||
if (!API_KEY || !SECRET) {
|
||||
return { error: 'MIXPANEL_API_KEY and MIXPANEL_SECRET required for query/export operations' }
|
||||
}
|
||||
const auth = Buffer.from(`${API_KEY}:${SECRET}`).toString('base64')
|
||||
const url = params ? `${baseUrl}${path}?${params}` : `${baseUrl}${path}`
|
||||
const res = await fetch(url, {
|
||||
method,
|
||||
headers: {
|
||||
'Authorization': `Basic ${auth}`,
|
||||
'Content-Type': 'application/json',
|
||||
},
|
||||
})
|
||||
const text = await res.text()
|
||||
try {
|
||||
return JSON.parse(text)
|
||||
} catch {
|
||||
return { status: res.status, body: text }
|
||||
}
|
||||
}
|
||||
|
||||
async function queryApiPost(path, body) {
|
||||
if (!API_KEY || !SECRET) {
|
||||
return { error: 'MIXPANEL_API_KEY and MIXPANEL_SECRET required for query/export operations' }
|
||||
}
|
||||
const auth = Buffer.from(`${API_KEY}:${SECRET}`).toString('base64')
|
||||
const res = await fetch(`${QUERY_URL}${path}`, {
|
||||
method: 'POST',
|
||||
headers: {
|
||||
'Authorization': `Basic ${auth}`,
|
||||
'Content-Type': 'application/json',
|
||||
},
|
||||
body: JSON.stringify(body),
|
||||
})
|
||||
const text = await res.text()
|
||||
try {
|
||||
return JSON.parse(text)
|
||||
} catch {
|
||||
return { status: res.status, body: text }
|
||||
}
|
||||
}
|
||||
|
||||
function parseArgs(args) {
|
||||
const result = { _: [] }
|
||||
for (let i = 0; i < args.length; i++) {
|
||||
const arg = args[i]
|
||||
if (arg.startsWith('--')) {
|
||||
const key = arg.slice(2)
|
||||
const next = args[i + 1]
|
||||
if (next && !next.startsWith('--')) {
|
||||
result[key] = next
|
||||
i++
|
||||
} else {
|
||||
result[key] = true
|
||||
}
|
||||
} else {
|
||||
result._.push(arg)
|
||||
}
|
||||
}
|
||||
return result
|
||||
}
|
||||
|
||||
const args = parseArgs(process.argv.slice(2))
|
||||
const [cmd, sub, ...rest] = args._
|
||||
|
||||
async function main() {
|
||||
let result
|
||||
|
||||
switch (cmd) {
|
||||
case 'track':
|
||||
switch (sub) {
|
||||
case 'event': {
|
||||
if (!TOKEN) { result = { error: 'MIXPANEL_TOKEN required for tracking' }; break }
|
||||
if (!args['distinct-id']) { result = { error: '--distinct-id required' }; break }
|
||||
if (!args.event) { result = { error: '--event required' }; break }
|
||||
const properties = args.properties ? JSON.parse(args.properties) : {}
|
||||
properties.token = TOKEN
|
||||
properties.distinct_id = args['distinct-id']
|
||||
result = await ingestApi('POST', '/track', [{
|
||||
event: args.event,
|
||||
properties,
|
||||
}])
|
||||
break
|
||||
}
|
||||
default:
|
||||
result = { error: 'Unknown track subcommand. Use: event' }
|
||||
}
|
||||
break
|
||||
|
||||
case 'profiles':
|
||||
switch (sub) {
|
||||
case 'set': {
|
||||
if (!TOKEN) { result = { error: 'MIXPANEL_TOKEN required for profiles' }; break }
|
||||
if (!args['distinct-id']) { result = { error: '--distinct-id required' }; break }
|
||||
const properties = args.properties ? JSON.parse(args.properties) : {}
|
||||
result = await ingestApi('POST', '/engage', [{
|
||||
$token: TOKEN,
|
||||
$distinct_id: args['distinct-id'],
|
||||
$set: properties,
|
||||
}])
|
||||
break
|
||||
}
|
||||
default:
|
||||
result = { error: 'Unknown profiles subcommand. Use: set' }
|
||||
}
|
||||
break
|
||||
|
||||
case 'query':
|
||||
switch (sub) {
|
||||
case 'events': {
|
||||
if (!args['project-id']) { result = { error: '--project-id required' }; break }
|
||||
const body = {
|
||||
project_id: parseInt(args['project-id']),
|
||||
bookmark_id: null,
|
||||
params: {
|
||||
events: [{ event: args.event || 'all' }],
|
||||
time_range: {
|
||||
from_date: args['from-date'] || '30daysAgo',
|
||||
to_date: args['to-date'] || 'today',
|
||||
},
|
||||
},
|
||||
}
|
||||
result = await queryApiPost('/insights', body)
|
||||
break
|
||||
}
|
||||
default:
|
||||
result = { error: 'Unknown query subcommand. Use: events' }
|
||||
}
|
||||
break
|
||||
|
||||
case 'funnels':
|
||||
switch (sub) {
|
||||
case 'get': {
|
||||
if (!args['funnel-id']) { result = { error: '--funnel-id required' }; break }
|
||||
const params = new URLSearchParams()
|
||||
params.set('funnel_id', args['funnel-id'])
|
||||
if (args['from-date']) params.set('from_date', args['from-date'])
|
||||
if (args['to-date']) params.set('to_date', args['to-date'])
|
||||
result = await queryApi('GET', QUERY_URL, '/funnels', params)
|
||||
break
|
||||
}
|
||||
default:
|
||||
result = { error: 'Unknown funnels subcommand. Use: get' }
|
||||
}
|
||||
break
|
||||
|
||||
case 'retention':
|
||||
switch (sub) {
|
||||
case 'get': {
|
||||
const params = new URLSearchParams()
|
||||
if (args['from-date']) params.set('from_date', args['from-date'])
|
||||
if (args['to-date']) params.set('to_date', args['to-date'])
|
||||
params.set('retention_type', 'birth')
|
||||
if (args['born-event']) params.set('born_event', args['born-event'])
|
||||
result = await queryApi('GET', QUERY_URL, '/retention', params)
|
||||
break
|
||||
}
|
||||
default:
|
||||
result = { error: 'Unknown retention subcommand. Use: get' }
|
||||
}
|
||||
break
|
||||
|
||||
case 'export':
|
||||
switch (sub) {
|
||||
case 'events': {
|
||||
if (!args['from-date']) { result = { error: '--from-date required' }; break }
|
||||
if (!args['to-date']) { result = { error: '--to-date required' }; break }
|
||||
const params = new URLSearchParams()
|
||||
params.set('from_date', args['from-date'])
|
||||
params.set('to_date', args['to-date'])
|
||||
result = await queryApi('GET', EXPORT_URL, '/export', params)
|
||||
break
|
||||
}
|
||||
default:
|
||||
result = { error: 'Unknown export subcommand. Use: events' }
|
||||
}
|
||||
break
|
||||
|
||||
default:
|
||||
result = {
|
||||
error: 'Unknown command',
|
||||
usage: {
|
||||
track: 'track event --distinct-id <id> --event <name> [--properties <json>]',
|
||||
profiles: 'profiles set --distinct-id <id> [--properties <json>]',
|
||||
query: 'query events --project-id <id> [--event <name>] [--from-date <date>] [--to-date <date>]',
|
||||
funnels: 'funnels get --funnel-id <id> [--from-date <date>] [--to-date <date>]',
|
||||
retention: 'retention get [--from-date <date>] [--to-date <date>] [--born-event <event>]',
|
||||
export: 'export events --from-date <date> --to-date <date>',
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
console.log(JSON.stringify(result, null, 2))
|
||||
}
|
||||
|
||||
main().catch(err => {
|
||||
console.error(JSON.stringify({ error: err.message }))
|
||||
process.exit(1)
|
||||
})
|
||||
Reference in New Issue
Block a user