For ADS Publishers

npm install @agentdatashuttle/adsjs dotenv

pip install agentdatashuttle_adspy python-dotenv

import { types, publisher } from "@agentdatashuttle/adsjs";
 
async function publishSupportTicketExample() {
  const clientParams = {
    host: process.env.RABBITMQ_HOST || "localhost",
    username: process.env.RABBITMQ_USERNAME || "ads_user",
    password: process.env.RABBITMQ_PASSWORD || "ads_password",
    port: parseInt(process.env.RABBITMQ_PORT) || 5672
  };
 
  const adsPublisher = new publisher.ADSPublisher("SupportTicketProcessor", clientParams);
 
  // Support ticket event payload - typically from webhook triggers like Zendesk, Intercom, etc.
  const ticketPayload = {
    event_name: "new_support_ticket_created",
    event_description: "New support ticket has been created by user 'John Doe' in 'Payment related issues' category.",
    event_data: {
      ticket_id: "TICK-67890",
      customer_id: "cust_456",
      subject: "Unable to process payment for premium subscription",
      description: "Customer experiencing issues with credit card processing during checkout",
      priority: "high",
      status: "open",
      created_at: Date.now(),
      customer_email: "[email protected]"
    }
  };
 
  try {
    await adsPublisher.publishEvent(ticketPayload);
    console.log(`Support ticket event published successfully for ticket: ${ticketPayload.event_data.ticket_id}`);
  } catch (error) {
    console.error("Support ticket event publishing failed:", error.message);
  }
}
 
publishSupportTicketExample();

import os
import time
from agentdatashuttle_adspy.core.client import ADSRabbitMQClientParams
from agentdatashuttle_adspy.core.publisher import ADSPublisher
from agentdatashuttle_adspy.models.models import ADSDataPayload
from dotenv import load_dotenv
 
load_dotenv()
 
# Step 1: Create ADSRabbitMQClientParams
client_params = ADSRabbitMQClientParams(
    host=os.getenv("RABBITMQ_HOST", "localhost"),
    username=os.getenv("RABBITMQ_USERNAME", "ads_user"),
    password=os.getenv("RABBITMQ_PASSWORD", "ads_password"),
    port=int(os.getenv("RABBITMQ_PORT", 5672)),
)
 
# Step 2: Create a ADSPublisher instance
# Example: ADSPublisher for Support Ticket system
publisher = ADSPublisher("SupportTicketProcessor", client_params)
 
# Step 3: Create a sample ADSDataPayload
payload = ADSDataPayload(
    event_name="new_support_ticket_created",
    event_description="New support ticket has been created by user 'John Doe' in 'Payment related issues' category.",
    event_data={
        "ticket_id": "TICK-67890",
        "customer_id": "cust_456",
        "subject": "Unable to process payment for premium subscription",
        "description": "Customer experiencing issues with credit card processing during checkout",
        "priority": "high",
        "status": "open",
        "created_at": int(time.time() * 1000),  # Current timestamp in milliseconds
        "customer_email": "[email protected]",
    },
)
 
time.sleep(2)  # Simulate some delay before publishing
 
# Publish the payload
publisher.publish_event(payload)
 
print("Event published successfully.")