t1p-event-client v1.5.29

t1-event-client client sdk

Install via npm dependencies

include t1-event-client into package.json

// in package.json
...
dependencies: {
  ...
  "t1-event-client": "https://gitlab+deploy-token-70589:onnEWpzU-AwSm2XsR1mm@gitlab.com/centralonline/t1-event-client.git#releases",
  ...
},

Setup Config

Config

• accessKeyId - required,
• secretAccessKey - required,
• region - required,
• steamName - required

include module code

const { client } = require("t1-event-client");

connect on steam

const stream_info = await client.connect({
    accessKeyId: 'AKIAVR3U4ZCZDGC45AVX',
    secretAccessKey: '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',
    region: 'ap-southeast-1',
    steamName: 't1-pre-activation'
})

push message to steam

const steamData = {
    id: "<event-id>", 
    scope: "<scope>",
    type: "<type>",
    name: "<name>",
    aggregateID: "<ggregate-id>",
    payloads: {},
    version: "<version>",
    createdBy: "<createdBy>",
    createdAt: new Date()
}
const record_info = await client.putRecord(steamData)
/*response
{ 
    ShardId: 'shardId-000000000002',
    SequenceNumber: '49596121340608871984751132596318841144943020200958099490' 
}
*/

subscribe for get message from steam

const consumer = client.subscribe.consumer.create({
    queueUrl: 'https://sqs.ap-southeast-1.amazonaws.com/381960374450/t1-pre-activation.fifo',
    handleMessage: async (message) => {
        let msg_body = JSON.parse(message.Body)
    },
    batchSize: 10,
    waitTimeSeconds: 0
});
consumer.on('error', (err) => {
    console.error(err.message);
});

consumer.on('processing_error', (err) => {
    console.error(err.message);
});

consumer.start();

delete message for queue

const deleteParams = {
    QueueUrl: 'https://sqs.ap-southeast-1.amazonaws.com/381960374450/t1-pre-activation.fifo',
    ReceiptHandle: '<ReceiptHandle>'
};

const reeceipt_handle = await client.deleteMessage(deleteParams)