Серверные SDK и примеры

curl -X POST https://api.pushdata.ru/api/v1/notifications \
  -H "Authorization: ApiKey pd_ВАШ_СЕКРЕТНЫЙ_КЛЮЧ" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: order-123-placed" \
  -d '{"title":"Заказ оформлен","body":"Собираем заказ №123.","target":{"user_ids":["user-123"]},"data":{"orderId":"123"},"click_action":"myapp://orders/123"}'

import { PushData } from '@pushdata/node'

const pushdata = new PushData({ apiKey: process.env.PUSHDATA_API_KEY! })
const { id } = await pushdata.sendNotification({
  title: 'Заказ оформлен',
  body: 'Собираем заказ №123.',
  target: { user_ids: ['user-123'] },
  data: { orderId: '123' },
  click_action: 'myapp://orders/123',
}, { idempotencyKey: 'order-123-placed' })

// То же письмом: адрес берётся из контакта user-123
await pushdata.sendNotification({
  channel_type: 'email',
  category: 'orders',
  title: 'Заказ №123 оформлен',
  body: 'Собираем заказ, курьер позвонит перед доставкой.',
  target: { user_ids: ['user-123'] },
}, { idempotencyKey: 'order-123-placed-email' })

from pushdata import PushData

pushdata = PushData(api_key=os.environ["PUSHDATA_API_KEY"])
created = pushdata.send_notification(
    title="Заказ оформлен", body="Собираем заказ №123.",
    target={"user_ids": ["user-123"]}, data={"orderId": "123"}, click_action="myapp://orders/123",
    idempotency_key="order-123-placed",
)

use PushData\PushData;

$pushdata = new PushData($_ENV['PUSHDATA_API_KEY']);
$created = $pushdata->sendNotification([
    'title' => 'Заказ оформлен', 'body' => 'Собираем заказ №123.',
    'target' => ['user_ids' => ['user-123']], 'data' => ['orderId' => '123'], 'click_action' => 'myapp://orders/123',
], 'order-123-placed');

client := pushdata.New(os.Getenv("PUSHDATA_API_KEY"))
created, err := client.SendNotification(ctx, pushdata.SendNotificationRequest{
    Title: "Заказ оформлен", Body: "Собираем заказ №123.",
    Target: pushdata.Target{UserIDs: []string{"user-123"}},
    Data: map[string]any{"orderId": "123"}, ClickAction: "myapp://orders/123",
    IdempotencyKey: "order-123-placed",
})

PushData pushdata = new PushData(System.getenv("PUSHDATA_API_KEY"));
Map<String, Object> created = pushdata.sendNotification(Map.of(
    "title", "Заказ оформлен", "body", "Собираем заказ №123.",
    "target", Map.of("user_ids", List.of("user-123")),
    "data", Map.of("orderId", "123"), "click_action", "myapp://orders/123"), "order-123-placed");

val pushdata = PushData(System.getenv("PUSHDATA_API_KEY"))
val created = pushdata.sendNotification(mapOf(
    "title" to "Заказ оформлен", "body" to "Собираем заказ №123.",
    "target" to mapOf("user_ids" to listOf("user-123")),
    "data" to mapOf("orderId" to "123"), "click_action" to "myapp://orders/123",
), "order-123-placed")

var pushdata = new PushDataClient(Environment.GetEnvironmentVariable("PUSHDATA_API_KEY")!);
var created = await pushdata.SendNotificationAsync(new JsonObject
{
    ["title"] = "Заказ оформлен", ["body"] = "Собираем заказ №123.",
    ["target"] = new JsonObject { ["user_ids"] = new JsonArray("user-123") },
    ["data"] = new JsonObject { ["orderId"] = "123" }, ["click_action"] = "myapp://orders/123",
}, "order-123-placed");

pushdata = PushData::Client.new(api_key: ENV.fetch("PUSHDATA_API_KEY"))
created = pushdata.send_notification(
  title: "Заказ оформлен", body: "Собираем заказ №123.",
  target: { user_ids: ["user-123"] }, data: { orderId: "123" }, click_action: "myapp://orders/123",
  idempotency_key: "order-123-placed"
)

var request = URLRequest(url: URL(string: "https://api.pushdata.ru/api/v1/notifications")!)
request.httpMethod = "POST"
request.setValue("ApiKey \(apiKey)", forHTTPHeaderField: "Authorization")
request.setValue("application/json", forHTTPHeaderField: "Content-Type")
request.setValue("order-123-placed", forHTTPHeaderField: "Idempotency-Key")
request.httpBody = try JSONSerialization.data(withJSONObject: [
    "title": "Заказ оформлен", "body": "Собираем заказ №123.",
    "target": ["user_ids": ["user-123"]], "data": ["orderId": "123"], "click_action": "myapp://orders/123",
])
let (data, _) = try await URLSession.shared.data(for: request)
let created = try JSONSerialization.jsonObject(with: data) as? [String: Any]   // ["id": …, "status": …]

final response = await http.post(
  Uri.parse('https://api.pushdata.ru/api/v1/notifications'),
  headers: {'Authorization': 'ApiKey $apiKey', 'Content-Type': 'application/json', 'Idempotency-Key': 'order-123-placed'},
  body: jsonEncode({
    'title': 'Заказ оформлен', 'body': 'Собираем заказ №123.',
    'target': {'user_ids': ['user-123']}, 'data': {'orderId': '123'}, 'click_action': 'myapp://orders/123',
  }),
);
final created = jsonDecode(response.body); // {id, status}

await pushdata.upsertContact({ external_id: 'user-123', email: 'user@example.com', phone: '+79990000000', name: 'Иван', locale: 'ru' })
await pushdata.triggerWorkflow('WORKFLOW_ID', { contact_external_id: 'user-123', payload: { orderId: '123' }, idempotency_key: 'order-123-welcome' })
const contact = await pushdata.getContact('user-123')
await pushdata.deleteContact('user-123') // стирание вместе с устройствами и inbox (152-ФЗ)

pushdata.upsert_contact("user-123", email="user@example.com", name="Иван")
pushdata.trigger_workflow("WORKFLOW_ID", contact_external_id="user-123", payload={"orderId": "123"})

const { data, total } = await pushdata.listDevices({ user_id: 'user-123', status: 'active' })
await pushdata.updateDeviceTags(data[0].id, ['vip'])
await pushdata.unregisterDeviceByToken('fcm-registration-token') // выход пользователя со стороны сервера

import { identityHash, verifyWebhookSignature } from '@pushdata/node'

app.get('/api/pushdata-identity', auth, (req, res) => res.send(identityHash(process.env.PUSHDATA_IDENTITY_SECRET!, req.user.id)))

app.post('/webhooks/pushdata', express.raw({ type: '*/*' }), (req, res) => {
  if (!verifyWebhookSignature(req.body, req.header('X-PushData-Signature'), process.env.PUSHDATA_WEBHOOK_SECRET!))
    return res.sendStatus(401)
  const event = JSON.parse(req.body.toString()) // { event: 'notification.sent', ... }
  res.sendStatus(204)
})