import { coss } from '@coss';

coss.notifications.init({
  apiKey: process.env.COSS_KEY,
  environment: 'production', // or 'sandbox'
});

// Create a subscriber
await coss.notifications.subscribers.create({
  subscriberId: 'user_abc123',
  email: '[email protected]',
  phone: '+15551234567',
  firstName: 'Jane',
  lastName: 'Doe',
});

// Retrieve a subscriber
await coss.notifications.subscribers.retrieve('user_abc123');

// Trigger a notification workflow
await coss.notifications.workflows.trigger({
  name: 'welcome_message',
  to: {
    subscriberId: 'user_abc123',
  },
  payload: {
    customMessage: 'Welcome to our service!',
  },
});

// Validate webhook signature
const isValid = coss.notifications.utils.verifySignature({
  payload: req.body,
  signature: req.headers['x-coss-signature'],
  secret: 'whsec_notifications_123',
});