import { Ecodrix } from "@ecodrix/erix-api";

const ecod = new Ecodrix({
  apiKey: "your_api_key",
  clientCode: "YOUR_CLIENT_CODE", // Your tenant ID
});

// Send a WhatsApp message
await ecod.whatsapp.messages.send({
  to: "+919876543210",
  text: "Hello from ECODrIx!",
});

// Create a CRM lead
const lead = await ecod.crm.leads.create({
  firstName: "Jhon",
  phone: "+919876543210",
  source: "website",
});

console.log(lead.data.id);

const ecod = new Ecodrix({
  apiKey: process.env.ECOD_API_KEY!,
  clientCode: process.env.ECOD_CLIENT_CODE,
  baseUrl: "http://localhost:4000", // For local development
});

await ecod.whatsapp.messages.send({
  to: "+919876543210",
  text: "Your appointment is confirmed!",
});

await ecod.whatsapp.messages.send({
  to: "+919876543210",
  mediaUrl: "https://cdn.ecodrix.com/invoice.pdf",
  mediaType: "document",
  filename: "invoice.pdf",
});

await ecod.whatsapp.messages.sendTemplate({
  to: "+919876543210",
  templateName: "appointment_reminder",
  language: "en_US",
  variables: ["Dhanesh", "Tomorrow 10AM"],
});

const { messageId } = await ecod.whatsapp.sendTemplate({
  phone: "+919876543210",
  templateName: "payment_confirmation",
  variables: {
    name: "Dhanesh",
    amount: "₹1,500",
  },
});

await ecod.whatsapp.messages.markRead("conversation_id");

// List conversations (cursor-based pagination)
const { data } = await ecod.whatsapp.conversations.list({ limit: 20 });

// Get a specific conversation
const conv = await ecod.whatsapp.conversations.retrieve("conversation_id");

// Archive a conversation
await ecod.whatsapp.conversations.delete("conversation_id");

const { data: lead } = await ecod.crm.leads.create({
  firstName: "Dhanesh",
  lastName: "Kumar",
  phone: "+919876543210",
  email: "dhanesh@example.com",
  source: "website", // 'website' | 'whatsapp' | 'direct' | ...
  metadata: {
    utmSource: "google",
  },
});

const { data: leads } = await ecod.crm.leads.list({
  status: "new", // filter by status
  source: "whatsapp",
  page: 1,
  limit: 25,
});

const { data: lead } = await ecod.crm.leads.retrieve("lead_id");

await ecod.crm.leads.update("lead_id", {
  email: "new@email.com",
  metadata: { score: 95 },
});

await ecod.crm.leads.delete("lead_id");

const { data: meeting } = await ecod.meet.create({
  leadId: "lead_id",
  participantName: "Dhanesh Kumar",
  participantPhone: "+919876543210",
  startTime: "2026-04-10T10:00:00.000Z",
  endTime: "2026-04-10T10:30:00.000Z",
});

console.log(meeting.meetLink); // → https://meet.google.com/abc-defg-hij

const { data: meetings } = await ecod.meet.list({ status: "scheduled" });

const { data } = await ecod.meet.retrieve("meeting_id");

await ecod.meet.update("meeting_id", {
  startTime: "2026-04-11T11:00:00.000Z",
  endTime: "2026-04-11T11:30:00.000Z",
});

await ecod.meet.delete("meeting_id");

// Node.js: from a Buffer
import { readFileSync } from "fs";

const fileBuffer = readFileSync("./contract.pdf");
const { data } = await ecod.storage.upload(fileBuffer, {
  folder: "customer_documents",
  filename: "contract.pdf",
  contentType: "application/pdf",
});

console.log(data.url); // → https://cdn.ecodrix.com/customer_documents/contract.pdf

// Browser: from an <input> file
const file = document.getElementById("file-input").files[0];
const { data } = await ecod.storage.upload(file, {
  folder: "avatars",
  filename: file.name,
  contentType: file.type,
});
  filename: "dhanesh.png",
  contentType: "image/png"
});

console.log(data.url);
// -> https://cdn.ecodrix.com/avatars/dhanesh.png

const { success } = await ecod.email.sendEmailCampaign({
  subject: "Summer Subscription Discount!",
  recipients: ["user@example.com", "lead@example.com"],
  html: "<h1>Get 20% off all plans today!</h1>",
});

const { success } = await ecod.email.sendTestEmail("admin@example.com");

const { data: triggers } = await ecod.events.list();

await ecod.events.assign({
  name: "cart_abandoned",
  displayName: "Shopping Cart Abandoned",
  pipelineId: "pipeline_123" /* Auto map leads to this pipeline */,
});

await ecod.events.trigger({
  trigger: "cart_abandoned",
  phone: "+919876543210", // Primary matching key
  variables: { items: "T-Shirt, Mug", total: "₹850" },
  createLeadIfMissing: true, // Upsert lead if it's a new customer
});

const { data: logs } = await ecod.notifications.listLogs({
  trigger: "lead_created",
  status: "failed", // filter to only failed automations
  startDate: "2026-04-01",
  endDate: "2026-04-30",
  limit: 50,
});

const { data: log } = await ecod.notifications.retrieveLog("log_id");

const { data: stats } = await ecod.notifications.getStats({
  startDate: "2026-04-01",
  endDate: "2026-04-30",
});

const { data: callbacks } = await ecod.notifications.listCallbacks({
  limit: 20,
});

// Look how beautiful this developer experience is:
for await (const lead of ecod.crm.leads.listAutoPaging({ status: "won" })) {
  await syncToMyDatabase(lead);
}

// The users array chunked into safe parallel batched requests
const results = await ecod.crm.leads.createMany(massiveArrayOfLeads, 100);
console.log(`Successfully ingested ${results.length} leads.`);

await ecod.email.sendEmailCampaign(
  { subject: "Promo", recipients: ["user@example.com"] },
  { idempotencyKey: "promo_campaign_uuid_123_abc" },
);

app.post(
  "/api/webhooks",
  express.raw({ type: "application/json" }),
  async (req, res) => {
    try {
      const event = await ecod.webhooks.constructEvent(
        req.body.toString(),
        req.headers["x-ecodrix-signature"],
        "whsec_your_secret_key",
      );
      console.log("Verified event received:", event);
    } catch (err) {
      return res.status(400).send(`Invalid signature: ${err.message}`);
    }
  },
);

// Bypass strictly typed resources with full network resiliency
const customData = await ecod.request("POST", "/api/saas/beta-feature-route", {
  experimentalFlag: true,
});

const ecod = new Ecodrix({ apiKey: "...", clientCode: "..." });

// New incoming WhatsApp message
ecod.on("whatsapp.message_received", (data) => {
  console.log(`New message from ${data.from}: ${data.body}`);
});

// Lead stage changed in CRM
ecod.on("crm.lead_updated", (data) => {
  console.log(`Lead ${data.leadId} moved to stage: ${data.stageName}`);
});

// Automation or event failed — for alert pipelines
ecod.on("automation.failed", (data) => {
  console.error(`Automation failed: ${data.trigger} — ${data.reason}`);
});

// Storage upload completed
ecod.on("storage.upload_confirmed", (data) => {
  console.log(`File available at: ${data.url}`);
});

// Disconnect when done (e.g. server shutdown)
ecod.disconnect();

import {
  Ecodrix,
  APIError,
  AuthenticationError,
  RateLimitError,
} from "@ecodrix/erix-api";

try {
  const { data } = await ecod.crm.leads.retrieve("non_existent_id");
} catch (err) {
  if (err instanceof AuthenticationError) {
    // 401 — invalid API key or client code
    console.error("Check your credentials.");
  } else if (err instanceof RateLimitError) {
    // 429 — slow down requests
    console.warn("Rate limit hit. Retrying after delay...");
  } else if (err instanceof APIError) {
    // Other HTTP errors from the API
    console.error(`API Error [${err.status}]: ${err.message}`);
  } else {
    throw err; // re-throw unknown errors
  }
}