Skip to content

feat(transit-gateway): add dynamic_route_server connection support #333

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
anaghajoshiibm wants to merge 2 commits into
base: master
Choose a base branch
from
+814 −104
Open

feat(transit-gateway): add dynamic_route_server connection support #333

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
e104109
feat(transit-gateway): add dynamic_route_server connection support
anaghajoshiibm Aug 15, 2026
0a60d42
feat(transit-gateway): regenerate SDK with sdkgen 3.112.0
anaghajoshiibm Aug 15, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
210 changes: 194 additions & 16 deletions test/integration/transit-gateway.v1.test.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,13 +51,15 @@ let GRE_CONN_INSTANCE_ID;
let UNBOUND_GRE_CONN_INSTANCE_ID;
let CLASSIC_CONN_INSTANCE_ID;
let VPN_CONN_INSTANCE_ID;
let DRS_CONN_INSTANCE_ID;

let DL_CONN_INSTANCE_NAME;
let VPC_CONN_INSTANCE_NAME;
let GRE_CONN_INSTANCE_NAME;
let UNBOUND_GRE_CONN_INSTANCE_NAME;
let CLASSIC_CONN_INSTANCE_NAME;
let VPN_CONN_INSTANCE_NAME;
let DRS_CONN_INSTANCE_NAME;

const poll = async (fn, fnCondition, sec) => {
let result;
Expand Down Expand Up @@ -140,30 +142,51 @@ describe.skip('TransitGatewayApisV1', () => {
const { result } = response || {};
const connections = result.connections;
if (connections.length > 0) {
const connIDs = [];
const greIDs = [];
const drsIDs = [];
const otherIDs = [];
for (let j = 0; j < connections.length; j++) {
if (connections[j].status.includes('delet') === false) {
const connID = connections[j].id;
// Delete GRE Connections first.
if (
connections[j].networkType === 'gre_tunnel' ||
connections[j].networkType === 'unbound_gre_tunnel'
) {
const response = await transitGateway.deleteTransitGateway({
id: connID,
});
expect(response.status).toBe(204);
const connType = connections[j].network_type;
if (connType === 'gre_tunnel' || connType === 'unbound_gre_tunnel') {
greIDs.push(connID);
} else if (connType === 'dynamic_route_server') {
drsIDs.push(connID);
} else {
connIDs.push(connID);
otherIDs.push(connID);
}
}
}
// Delete Connections from other types.
for (let k = 0; k < connIDs.length; k++) {
const response = await transitGateway.deleteTransitGateway({
id: connIDs[k],
});
expect(response.status).toBe(204);
for (const id of greIDs) {
try {
const response = await transitGateway.deleteTransitGatewayConnection({
transitGatewayId: gateways[i].id,
id,
});
expect(response.status).toBe(204);
} catch (e) {}
}
// Delete DRS before VPC
for (const id of drsIDs) {
try {
const response = await transitGateway.deleteTransitGatewayConnection({
transitGatewayId: gateways[i].id,
id,
});
expect(response.status).toBe(204);
} catch (e) {}
}
// Delete everything else (VPC, classic, DL, VPN...).
for (const id of otherIDs) {
try {
const response = await transitGateway.deleteTransitGatewayConnection({
transitGatewayId: gateways[i].id,
id,
});
expect(response.status).toBe(204);
} catch (e) {}
}
}
// Remove empty gateways
Expand Down Expand Up @@ -603,6 +626,62 @@ describe.skip('TransitGatewayApisV1', () => {
}
});

test('successfully creates DRS connection', async done => {
const type = 'dynamic_route_server';
const crn = config.DRS_CRN;
const stamp = Math.floor(Math.random() * 1000);
const connectionName = 'DRS-' + config.GATEWAY_CONNECTION_NAME + '_' + stamp;
const cidr = '192.168.200.0/24';

try {
const response = await transitGateway.createTransitGatewayConnection({
transitGatewayId: GATEWAY_INSTANCE_ID,
networkType: type,
name: connectionName,
networkId: crn,
cidr,
});
expect(response).toBeDefined();
expect(response.status).toEqual(201);

const { result } = response || {};

expect(result).toBeDefined();
expect(result.name).toEqual(connectionName);
expect(result.network_id).toEqual(crn);
expect(result.network_type).toEqual(type);
expect(result.cidr).toEqual(cidr);

DRS_CONN_INSTANCE_ID = result.id;
DRS_CONN_INSTANCE_NAME = result.name;

done();
} catch (err) {
done(err);
}
});

test('successfully wait for the DRS connection to report as attached', async done => {
try {
const result = await poll(
() =>
transitGateway.getTransitGatewayConnection({
transitGatewayId: GATEWAY_INSTANCE_ID,
id: DRS_CONN_INSTANCE_ID,
}),
result => result.status === 'attached',
100
);

expect(result).toBeDefined();
expect(result.status).toEqual('attached');

done();
} catch (err) {
done(err);
}
});

test('successfully creates GRE connection', async done => {
const type = 'gre_tunnel';
const testZone = { name: 'us-south-1' };
Expand Down Expand Up @@ -675,6 +754,23 @@ describe.skip('TransitGatewayApisV1', () => {

done();
});

test('fail to create a DRS connection with bad CRN', async done => {
try {
await transitGateway.createTransitGatewayConnection({
transitGatewayId: GATEWAY_INSTANCE_ID,
networkType: 'dynamic_route_server',
name: config.GATEWAY_CONNECTION_NAME,
networkId: 'bad_crn',
});
done();
} catch (err) {
expect(err.status).toEqual(400);
done();
}

done();
});
});

test('successfully creates Unbound GRE connection', async done => {
Expand Down Expand Up @@ -850,6 +946,28 @@ describe.skip('TransitGatewayApisV1', () => {
}
});

test('sucessfully get DRS connection by id', async done => {
try {
const response = await transitGateway.getTransitGatewayConnection({
transitGatewayId: GATEWAY_INSTANCE_ID,
id: DRS_CONN_INSTANCE_ID,
});

expect(response.status).toBe(200);

const { result } = response || {};
expect(result.id).toEqual(DRS_CONN_INSTANCE_ID);
expect(result.name).toEqual(DRS_CONN_INSTANCE_NAME);
expect(result.network_id).toEqual(config.DRS_CRN);
expect(result.network_type).toEqual('dynamic_route_server');
expect(result.cidr).toEqual('192.168.200.0/24');

done();
} catch (err) {
done(err);
}
});

test('fail to get connection by instanceID', async done => {
try {
await transitGateway.getTransitGatewayConnection({
Expand Down Expand Up @@ -987,6 +1105,26 @@ describe.skip('TransitGatewayApisV1', () => {
}
});

test('successfully update a DRS connection name by instance id', async done => {
DRS_CONN_INSTANCE_NAME = 'UPDATED-' + DRS_CONN_INSTANCE_NAME;
try {
const response = await transitGateway.updateTransitGatewayConnection({
transitGatewayId: GATEWAY_INSTANCE_ID,
id: DRS_CONN_INSTANCE_ID,
name: DRS_CONN_INSTANCE_NAME,
});
expect(response.status).toBe(200);

const { result } = response || {};
expect(result.id).toEqual(DRS_CONN_INSTANCE_ID);
expect(result.name).toEqual(DRS_CONN_INSTANCE_NAME);

done();
} catch (err) {
done(err);
}
});

test('fail to update Connection by instance id', async done => {
try {
await transitGateway.updateTransitGatewayConnection({
Expand Down Expand Up @@ -1022,6 +1160,7 @@ describe.skip('TransitGatewayApisV1', () => {
let foundGRE = false;
let foundUnboundGRE = false;
let foundClassic = false;
let foundDRS = false;
for (let i = 0; i < connections.length; i++) {
if (connections[i].id === CLASSIC_CONN_INSTANCE_ID) {
expect(connections[i].name).toEqual(CLASSIC_CONN_INSTANCE_NAME);
Expand All @@ -1041,6 +1180,10 @@ describe.skip('TransitGatewayApisV1', () => {
} else if (connections[i].id === UNBOUND_GRE_CONN_INSTANCE_ID) {
expect(connections[i].name).toEqual(UNBOUND_GRE_CONN_INSTANCE_NAME);
foundUnboundGRE = true;
} else if (connections[i].id === DRS_CONN_INSTANCE_ID) {
expect(connections[i].name).toEqual(DRS_CONN_INSTANCE_NAME);
expect(connections[i].network_type).toEqual('dynamic_route_server');
foundDRS = true;
}
}
expect(foundVPN).toEqual(true);
Expand All @@ -1049,6 +1192,7 @@ describe.skip('TransitGatewayApisV1', () => {
expect(foundGRE).toEqual(true);
expect(foundClassic).toEqual(true);
expect(foundUnboundGRE).toEqual(true);
expect(foundDRS).toEqual(true);

done();
} catch (err) {
Expand Down Expand Up @@ -1353,6 +1497,40 @@ describe.skip('TransitGatewayApisV1', () => {
}
});

test('successfully delete DRS connection by instanceID', async done => {
try {
const response = await transitGateway.deleteTransitGatewayConnection({
transitGatewayId: GATEWAY_INSTANCE_ID,
id: DRS_CONN_INSTANCE_ID,
});

expect(response.status).toBe(204);
done();
} catch (err) {
done(err);
}
});

test('successfully waits for the DRS connection to report as deleted', async done => {
try {
const result = await poll(
() =>
transitGateway.getTransitGatewayConnection({
transitGatewayId: GATEWAY_INSTANCE_ID,
id: DRS_CONN_INSTANCE_ID,
}),
result => result.status === 404,
200
);

expect(result).toBeDefined();
expect(result.status).toBe(404);
done();
} catch (err) {
done(err);
}
});

test('successfully delete VPC connection by instanceID', async done => {
try {
const response = await transitGateway.deleteTransitGatewayConnection({
Expand Down
Loading