Polling Endpoints

import { AutoConfigConsumer } from "svix";
 
const consumer = new AutoConfigConsumer(AUTO_CONFIG_TOKEN, {
  filterTypes: ["invoice.paid", "user.created"],
});
 
// Create or update the polling endpoint when your code changes
await consumer.subscribe();
 
// Inside a worker loop
const msgs = await consumer.receive("my-consumer");
// ... process msgs.data
await consumer.commit("my-consumer", msgs.data.at(-1).offset);

from svix import AutoConfigConsumer
from svix.models import SinkInCommon
 
consumer = AutoConfigConsumer(
    AUTO_CONFIG_TOKEN,
    SinkInCommon(
        filter_types=["invoice.paid", "user.created"],
    ),
)
 
# Create or update the polling endpoint when your code changes
consumer.subscribe()
 
# Inside a worker loop
msgs = consumer.receive("my-consumer")
# ... process msgs.data
consumer.commit("my-consumer", msgs.data[-1].offset)

let consumer = svix::AutoConfigConsumer::new(
    AUTO_CONFIG_TOKEN.to_string(),
    svix::SinkInCommon {
        filter_types: Some(vec![
            "invoice.paid".to_string(),
            "user.created".to_string(),
        ]),
        ..Default::default()
    },
)?;
 
// Create or update the polling endpoint when your code changes
consumer.subscribe().await?;
 
// Inside a worker loop
let msgs = consumer.receive("my-consumer".to_string(), None).await?;
// ... process msgs.data
let offset = msgs.data.last().unwrap().offset;
consumer.commit("my-consumer".to_string(), offset, None).await?;

import (
	"context"
	svix "github.com/svix/svix-webhooks/go"
	"github.com/svix/svix-webhooks/go/models"
)
 
consumer, err := svix.NewAutoConfigConsumer(AUTO_CONFIG_TOKEN, models.SinkInCommon{
	FilterTypes: []string{"invoice.paid", "user.created"},
})
if err != nil {
	panic(err)
}
 
// Create or update the polling endpoint when your code changes
if _, err := consumer.Subscribe(ctx); err != nil {
	panic(err)
}
 
// Inside a worker loop
msgs, err := consumer.Receive(ctx, "my-consumer", nil)
if err != nil {
	panic(err)
}
// ... process msgs.Data
offset := msgs.Data[len(msgs.Data)-1].Offset
if err := consumer.Commit(ctx, "my-consumer", offset, nil); err != nil {
	panic(err)
}

import com.svix.AutoConfigConsumer;
import com.svix.models.SinkInCommon;
import java.util.Set;
 
AutoConfigConsumer consumer = new AutoConfigConsumer(
    AUTO_CONFIG_TOKEN,
    new SinkInCommon()
        .filterTypes(Set.of("invoice.paid", "user.created")));
 
// Create or update the polling endpoint when your code changes
consumer.subscribe();
 
// Inside a worker loop
var msgs = consumer.receive("my-consumer");
// ... process msgs.getData()
long offset = msgs.getData().get(msgs.getData().size() - 1).getOffset();
consumer.commit("my-consumer", offset);

import com.svix.kotlin.AutoConfigConsumer
import com.svix.kotlin.models.SinkInCommon
 
val consumer = AutoConfigConsumer(
    AUTO_CONFIG_TOKEN,
    SinkInCommon(
        filterTypes = setOf("invoice.paid", "user.created"),
    ),
)
 
// Create or update the polling endpoint when your code changes
consumer.subscribe()
 
// Inside a worker loop
val msgs = consumer.receive("my-consumer")
// ... process msgs.data
val offset = msgs.data.last().offset
consumer.commit("my-consumer", offset)

require "svix"
 
sink = Svix::SinkInCommon.new(
  "filter_types" => ["invoice.paid", "user.created"],
)
 
consumer = Svix::AutoConfigConsumer.new(AUTO_CONFIG_TOKEN, sink)
 
# Create or update the polling endpoint when your code changes
consumer.subscribe
 
# Inside a worker loop
msgs = consumer.receive("my-consumer")
# ... process msgs.data
offset = msgs.data.last.offset
consumer.commit("my-consumer", offset)

using Svix;
using Svix.Models;
 
var consumer = new AutoConfigConsumer(
    AUTO_CONFIG_TOKEN,
    new SinkInCommon
    {
        FilterTypes = new[] { "invoice.paid", "user.created" },
    });
 
// Create or update the polling endpoint when your code changes
await consumer.SubscribeAsync();
 
// Inside a worker loop
var msgs = await consumer.ReceiveAsync("my-consumer");
// ... process msgs.Data
var offset = msgs.Data[^1].Offset;
await consumer.CommitAsync("my-consumer", offset);

use Svix\AutoConfigConsumer;
use Svix\Models\SinkInCommon;
 
$consumer = new AutoConfigConsumer(
    AUTO_CONFIG_TOKEN,
    SinkInCommon::create()
        ->withFilterTypes(['invoice.paid', 'user.created']),
);
 
// Create or update the polling endpoint when your code changes
$consumer->subscribe();
 
// Inside a worker loop
$msgs = $consumer->receive('my-consumer');
// ... process $msgs->data
$offset = end($msgs->data)->offset;
$consumer->commit('my-consumer', $offset);