test-message.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const client_sqs_1 = require("@aws-sdk/client-sqs");
const QUEUE_URL = process.env.QUEUE_URL;
if (!QUEUE_URL) {
    console.error('Please set QUEUE_URL environment variable');
    console.error('You can get this from the CDK output after deployment');
    process.exit(1);
}
const client = new client_sqs_1.SQSClient({});
async function sendTestMessage() {
    const testMessage = {
        id: Date.now().toString(),
        timestamp: new Date().toISOString(),
        data: {
            event: 'test-event',
            source: 'test-script',
            message: 'This is a test message from SQS to Step Functions via EventBridge Pipe'
        }
    };
    const command = new client_sqs_1.SendMessageCommand({
        QueueUrl: QUEUE_URL,
        MessageBody: JSON.stringify(testMessage),
        MessageAttributes: {
            Source: {
                DataType: 'String',
                StringValue: 'test-script'
            },
            Type: {
                DataType: 'String',
                StringValue: 'test-message'
            }
        }
    });
    try {
        const response = await client.send(command);
        console.log('Message sent successfully!');
        console.log('MessageId:', response.MessageId);
        console.log('Message Body:', JSON.stringify(testMessage, null, 2));
    }
    catch (error) {
        console.error('Error sending message:', error);
    }
}
sendTestMessage();
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC1tZXNzYWdlLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsidGVzdC1tZXNzYWdlLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsb0RBQW9FO0FBRXBFLE1BQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxHQUFHLENBQUMsU0FBUyxDQUFDO0FBRXhDLElBQUksQ0FBQyxTQUFTLEVBQUUsQ0FBQztJQUNmLE9BQU8sQ0FBQyxLQUFLLENBQUMsMkNBQTJDLENBQUMsQ0FBQztJQUMzRCxPQUFPLENBQUMsS0FBSyxDQUFDLHVEQUF1RCxDQUFDLENBQUM7SUFDdkUsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUMsQ0FBQztBQUNsQixDQUFDO0FBRUQsTUFBTSxNQUFNLEdBQUcsSUFBSSxzQkFBUyxDQUFDLEVBQUUsQ0FBQyxDQUFDO0FBRWpDLEtBQUssVUFBVSxlQUFlO0lBQzVCLE1BQU0sV0FBVyxHQUFHO1FBQ2xCLEVBQUUsRUFBRSxJQUFJLENBQUMsR0FBRyxFQUFFLENBQUMsUUFBUSxFQUFFO1FBQ3pCLFNBQVMsRUFBRSxJQUFJLElBQUksRUFBRSxDQUFDLFdBQVcsRUFBRTtRQUNuQyxJQUFJLEVBQUU7WUFDSixLQUFLLEVBQUUsWUFBWTtZQUNuQixNQUFNLEVBQUUsYUFBYTtZQUNyQixPQUFPLEVBQUUsd0VBQXdFO1NBQ2xGO0tBQ0YsQ0FBQztJQUVGLE1BQU0sT0FBTyxHQUFHLElBQUksK0JBQWtCLENBQUM7UUFDckMsUUFBUSxFQUFFLFNBQVM7UUFDbkIsV0FBVyxFQUFFLElBQUksQ0FBQyxTQUFTLENBQUMsV0FBVyxDQUFDO1FBQ3hDLGlCQUFpQixFQUFFO1lBQ2pCLE1BQU0sRUFBRTtnQkFDTixRQUFRLEVBQUUsUUFBUTtnQkFDbEIsV0FBVyxFQUFFLGFBQWE7YUFDM0I7WUFDRCxJQUFJLEVBQUU7Z0JBQ0osUUFBUSxFQUFFLFFBQVE7Z0JBQ2xCLFdBQVcsRUFBRSxjQUFjO2FBQzVCO1NBQ0Y7S0FDRixDQUFDLENBQUM7SUFFSCxJQUFJLENBQUM7UUFDSCxNQUFNLFFBQVEsR0FBRyxNQUFNLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUM7UUFDNUMsT0FBTyxDQUFDLEdBQUcsQ0FBQyw0QkFBNEIsQ0FBQyxDQUFDO1FBQzFDLE9BQU8sQ0FBQyxHQUFHLENBQUMsWUFBWSxFQUFFLFFBQVEsQ0FBQyxTQUFTLENBQUMsQ0FBQztRQUM5QyxPQUFPLENBQUMsR0FBRyxDQUFDLGVBQWUsRUFBRSxJQUFJLENBQUMsU0FBUyxDQUFDLFdBQVcsRUFBRSxJQUFJLEVBQUUsQ0FBQyxDQUFDLENBQUMsQ0FBQztJQUNyRSxDQUFDO0lBQUMsT0FBTyxLQUFLLEVBQUUsQ0FBQztRQUNmLE9BQU8sQ0FBQyxLQUFLLENBQUMsd0JBQXdCLEVBQUUsS0FBSyxDQUFDLENBQUM7SUFDakQsQ0FBQztBQUNILENBQUM7QUFFRCxlQUFlLEVBQUUsQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IFNRU0NsaWVudCwgU2VuZE1lc3NhZ2VDb21tYW5kIH0gZnJvbSAnQGF3cy1zZGsvY2xpZW50LXNxcyc7XG5cbmNvbnN0IFFVRVVFX1VSTCA9IHByb2Nlc3MuZW52LlFVRVVFX1VSTDtcblxuaWYgKCFRVUVVRV9VUkwpIHtcbiAgY29uc29sZS5lcnJvcignUGxlYXNlIHNldCBRVUVVRV9VUkwgZW52aXJvbm1lbnQgdmFyaWFibGUnKTtcbiAgY29uc29sZS5lcnJvcignWW91IGNhbiBnZXQgdGhpcyBmcm9tIHRoZSBDREsgb3V0cHV0IGFmdGVyIGRlcGxveW1lbnQnKTtcbiAgcHJvY2Vzcy5leGl0KDEpO1xufVxuXG5jb25zdCBjbGllbnQgPSBuZXcgU1FTQ2xpZW50KHt9KTtcblxuYXN5bmMgZnVuY3Rpb24gc2VuZFRlc3RNZXNzYWdlKCkge1xuICBjb25zdCB0ZXN0TWVzc2FnZSA9IHtcbiAgICBpZDogRGF0ZS5ub3coKS50b1N0cmluZygpLFxuICAgIHRpbWVzdGFtcDogbmV3IERhdGUoKS50b0lTT1N0cmluZygpLFxuICAgIGRhdGE6IHtcbiAgICAgIGV2ZW50OiAndGVzdC1ldmVudCcsXG4gICAgICBzb3VyY2U6ICd0ZXN0LXNjcmlwdCcsXG4gICAgICBtZXNzYWdlOiAnVGhpcyBpcyBhIHRlc3QgbWVzc2FnZSBmcm9tIFNRUyB0byBTdGVwIEZ1bmN0aW9ucyB2aWEgRXZlbnRCcmlkZ2UgUGlwZSdcbiAgICB9XG4gIH07XG5cbiAgY29uc3QgY29tbWFuZCA9IG5ldyBTZW5kTWVzc2FnZUNvbW1hbmQoe1xuICAgIFF1ZXVlVXJsOiBRVUVVRV9VUkwsXG4gICAgTWVzc2FnZUJvZHk6IEpTT04uc3RyaW5naWZ5KHRlc3RNZXNzYWdlKSxcbiAgICBNZXNzYWdlQXR0cmlidXRlczoge1xuICAgICAgU291cmNlOiB7XG4gICAgICAgIERhdGFUeXBlOiAnU3RyaW5nJyxcbiAgICAgICAgU3RyaW5nVmFsdWU6ICd0ZXN0LXNjcmlwdCdcbiAgICAgIH0sXG4gICAgICBUeXBlOiB7XG4gICAgICAgIERhdGFUeXBlOiAnU3RyaW5nJyxcbiAgICAgICAgU3RyaW5nVmFsdWU6ICd0ZXN0LW1lc3NhZ2UnXG4gICAgICB9XG4gICAgfVxuICB9KTtcblxuICB0cnkge1xuICAgIGNvbnN0IHJlc3BvbnNlID0gYXdhaXQgY2xpZW50LnNlbmQoY29tbWFuZCk7XG4gICAgY29uc29sZS5sb2coJ01lc3NhZ2Ugc2VudCBzdWNjZXNzZnVsbHkhJyk7XG4gICAgY29uc29sZS5sb2coJ01lc3NhZ2VJZDonLCByZXNwb25zZS5NZXNzYWdlSWQpO1xuICAgIGNvbnNvbGUubG9nKCdNZXNzYWdlIEJvZHk6JywgSlNPTi5zdHJpbmdpZnkodGVzdE1lc3NhZ2UsIG51bGwsIDIpKTtcbiAgfSBjYXRjaCAoZXJyb3IpIHtcbiAgICBjb25zb2xlLmVycm9yKCdFcnJvciBzZW5kaW5nIG1lc3NhZ2U6JywgZXJyb3IpO1xuICB9XG59XG5cbnNlbmRUZXN0TWVzc2FnZSgpOyJdfQ==