SQS

{
  "Sid": "AllowStreamProdAccount",
  "Effect": "Allow",
  "Principal": {
    "AWS": "arn:aws:iam::185583345998:root"
  },
  "Action": "SQS:SendMessage",
  "Resource": "arn:aws:sqs:us-west-2:1111111111:customer-sqs-for-stream"
}

// Note: Any previously existing hooks not included in event_hooks array will be deleted.
// Get current settings first to preserve your existing configuration.

// STEP 1: Get current app settings to preserve existing hooks
const response = await client.getAppSettings();
console.log("Current event hooks:", response.event_hooks);

// STEP 2: Add SQS hook while preserving existing hooks
const existingHooks = response.event_hooks || [];
const newSQSHook = {
  enabled: true,
  hook_type: "sqs",
  sqs_queue_url: "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
  sqs_region: "us-east-1",
  sqs_auth_type: "keys", // or "resource" for role-based auth
  sqs_key: "yourkey",
  sqs_secret: "yoursecret",
  event_types: [], // empty array = all events
};

// STEP 3: Update with complete array including existing hooks
await client.updateAppSettings({
  event_hooks: [...existingHooks, newSQSHook],
});

// Test the SQS connection
await client.testSQSSettings();

from getstream.models import EventHook

# Note: Any previously existing hooks not included in event_hooks array will be deleted.
# Get current settings first to preserve your existing configuration.

# STEP 1: Get current app settings to preserve existing hooks
response = client.get_app()
existing_hooks = response.data.app.event_hooks or []
print("Current event hooks:", existing_hooks)

# STEP 2: Add SQS hook while preserving existing hooks
new_sqs_hook = EventHook(
    enabled=True,
    hook_type="sqs",
    sqs_queue_url="https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
    sqs_region="us-east-1",
    sqs_auth_type="keys",  # or "resource" for role-based auth
    sqs_key="yourkey",
    sqs_secret="yoursecret",
    event_types=[],  # empty array = all events
)

# STEP 3: Update with complete array including existing hooks
client.update_app(
    event_hooks=existing_hooks + [new_sqs_hook]
)

# Test the SQS connection
client.check_sqs(sqs_key="yourkey", sqs_secret="yoursecret", sqs_url="https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue")

require 'getstream_ruby'
Models = GetStream::Generated::Models

# Note: Any previously existing hooks not included in event_hooks array will be deleted.
# Get current settings first to preserve your existing configuration.

# STEP 1: Get current app settings to preserve existing hooks
response = client.common.get_app
existing_hooks = response.app.event_hooks || []
puts "Current event hooks:", existing_hooks

# STEP 2: Add SQS hook while preserving existing hooks
new_sqs_hook = {
  'enabled' => true,
  'hook_type' => 'sqs',
  'sqs_queue_url' => 'https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue',
  'sqs_region' => 'us-east-1',
  'sqs_auth_type' => 'keys', # or "resource" for role-based auth
  'sqs_key' => 'yourkey',
  'sqs_secret' => 'yoursecret',
  'event_types' => [] # empty array = all events
}

# STEP 3: Update with complete array including existing hooks
client.common.update_app(Models::UpdateAppRequest.new(
  event_hooks: existing_hooks + [new_sqs_hook]
))

# Test the SQS connection
client.common.check_sqs(Models::CheckSQSRequest.new(
  sqs_key: 'yourkey',
  sqs_secret: 'yoursecret',
  sqs_url: 'https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue'
))

// Note: Any previously existing hooks not included in event_hooks array will be deleted.
// Get current settings first to preserve your existing configuration.

// STEP 1: Get current app settings to preserve existing hooks
$response = $client->getApp();
$existingHooks = $response->getData()->app->eventHooks ?? [];

// STEP 2: Add SQS hook while preserving existing hooks
$newSQSHook = new Models\EventHook(
    enabled: true,
    hookType: "sqs",
    sqsQueueUrl: "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
    sqsRegion: "us-east-1",
    sqsAuthType: "keys", // or "resource" for role-based auth
    sqsKey: "yourkey",
    sqsSecret: "yoursecret",
    eventTypes: [], // empty array = all events
);

// STEP 3: Update with complete array including existing hooks
$client->updateApp(new Models\UpdateAppRequest(
    eventHooks: array_merge($existingHooks, [$newSQSHook]),
));

// Test the SQS connection
$client->checkSQS(new Models\CheckSQSRequest(
    sqsUrl: "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
    sqsKey: "yourkey",
    sqsSecret: "yoursecret",
));

// Note: Any previously existing hooks not included in event_hooks array will be deleted.
// Get current settings first to preserve your existing configuration.

// STEP 1: Get current app settings to preserve existing hooks
settings, err := client.GetApp(ctx, &getstream.GetAppRequest{})
if err != nil {
    log.Fatal(err)
}
existingHooks := settings.Data.App.EventHooks
fmt.Printf("Current event hooks: %+v\n", existingHooks)

// STEP 2: Add SQS hook while preserving existing hooks
newSQSHook := getstream.EventHook{
    HookType:    getstream.PtrTo("sqs"),
    Enabled:     getstream.PtrTo(true),
    EventTypes:  []string{}, // empty slice = all events
    SqsQueueUrl: getstream.PtrTo("https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue"),
    SqsRegion:   getstream.PtrTo("us-east-1"),
    SqsAuthType: getstream.PtrTo("keys"), // or "resource" for role-based auth
    SqsKey:      getstream.PtrTo("yourkey"),
    SqsSecret:   getstream.PtrTo("yoursecret"),
}

// STEP 3: Update with complete array including existing hooks
allHooks := append(existingHooks, newSQSHook)
_, err = client.UpdateApp(ctx, &getstream.UpdateAppRequest{
    EventHooks: allHooks,
})
if err != nil {
    log.Fatal(err)
}

// Test the SQS connection
client.CheckSQS(ctx, &getstream.CheckSQSRequest{
    SqsUrl:    getstream.PtrTo("https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue"),
    SqsKey:    getstream.PtrTo("yourkey"),
    SqsSecret: getstream.PtrTo("yoursecret"),
})

// Note: Any previously existing hooks not included in event_hooks array will be deleted.
// Get current settings first to preserve your existing configuration.

// STEP 1: Get current app settings to preserve existing hooks
var response = client.getApp(GetAppRequest.builder().build()).execute().getData();
var existingHooks = response.getApp().getEventHooks();
System.out.println("Current event hooks: " + existingHooks);

// STEP 2: Add SQS hook while preserving existing hooks
var newSQSHook = EventHook.builder()
    .hookType("sqs")
    .enabled(true)
    .eventTypes(Collections.emptyList()) // empty list = all events
    .sqsQueueUrl("https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue")
    .sqsRegion("us-east-1")
    .sqsAuthType("keys") // or "resource" for role-based auth
    .sqsKey("yourkey")
    .sqsSecret("yoursecret")
    .build();

// STEP 3: Update with complete array including existing hooks
var allHooks = new ArrayList<>(existingHooks);
allHooks.add(newSQSHook);
client.updateApp(UpdateAppRequest.builder()
    .eventHooks(allHooks)
    .build()).execute();

// Test the SQS connection
client.checkSQS(CheckSQSRequest.builder()
    .sqsKey("yourkey")
    .sqsSecret("yoursecret")
    .sqsUrl("https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue")
    .build()).execute();

// Note: Any previously existing hooks not included in event_hooks array will be deleted.
// Get current settings first to preserve your existing configuration.

// STEP 1: Get current app settings to preserve existing hooks
var settings = await client.GetAppAsync();
var existingHooks = settings.Data.App.EventHooks ?? new List<EventHook>();
Console.WriteLine($"Current event hooks: {existingHooks}");

// STEP 2: Add SQS hook while preserving existing hooks
var newSQSHook = new EventHook
{
    HookType = "sqs",
    Enabled = true,
    EventTypes = new List<string>(), // empty list = all events
    SqsQueueUrl = "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
    SqsRegion = "us-east-1",
    SqsAuthType = "keys", // or "resource" for role-based auth
    SqsKey = "yourkey",
    SqsSecret = "yoursecret",
};

// STEP 3: Update with complete array including existing hooks
var allHooks = new List<EventHook>(existingHooks) { newSQSHook };
await client.UpdateAppAsync(new UpdateAppRequest
{
    EventHooks = allHooks,
});

// Test the SQS connection
await client.CheckSQSAsync(new CheckSQSRequest
{
    SqsKey = "yourkey",
    SqsSecret = "yoursecret",
    SqsUrl = "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
});

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Sid": "Stmt1459523779000",
      "Effect": "Allow",
      "Action": [
        "sqs:GetQueueUrl",
        "sqs:SendMessage",
        "sqs:SendMessageBatch",
        "sqs:GetQueueAttributes"
      ],
      "Resource": ["arn:aws:sqs:region:acc_id:queue_name"]
    }
  ]
}