Skip to content

test(federation): refactor tests to create users on synapse #40112

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

Draft
sampaiodiego wants to merge 3 commits into
base: develop
Choose a base branch
from
Draft

test(federation): refactor tests to create users on synapse #40112

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
9e13cda
test(federation): refactor tests to create users on synapse
sampaiodiego Apr 10, 2026
15d2bc9
reverse dm join names
sampaiodiego Apr 10, 2026
203ee05
fix tests
sampaiodiego Apr 10, 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
3 changes: 0 additions & 3 deletions ee/packages/federation-matrix/docker-compose.test.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,6 @@ services:
echo '';
echo '=====> Running register_new_matrix_user...';
register_new_matrix_user -u admin -p admin --admin http://localhost:8008 -c /data/homeserver.yaml | sed 's/^/=======> /';
register_new_matrix_user -u alice -p alice --admin http://localhost:8008 -c /data/homeserver.yaml | sed 's/^/=======> /';
register_new_matrix_user -u bob -p bob --admin http://localhost:8008 -c /data/homeserver.yaml | sed 's/^/=======> /';
register_new_matrix_user -u cleiton -p cleiton --admin http://localhost:8008 -c /data/homeserver.yaml | sed 's/^/=======> /';
echo '=====> Finished register_new_matrix_user.';
wait"
volumes:
Expand Down
42 changes: 29 additions & 13 deletions ee/packages/federation-matrix/tests/end-to-end/ban.spec.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@ import { SynapseClient } from '../helper/synapse-client';
let rc1AdminRequestConfig: IRequestConfig;
let rc1User1RequestConfig: IRequestConfig;
let hs1AdminApp: SynapseClient;
let hs1PrimaryApp: SynapseClient;
let hs1PrimaryMatrixUserId: string;

beforeAll(async () => {
rc1AdminRequestConfig = await getRequestConfig(
Expand All @@ -40,9 +42,23 @@ import { SynapseClient } from '../helper/synapse-client';

hs1AdminApp = new SynapseClient(federationConfig.hs1.url, federationConfig.hs1.adminUser, federationConfig.hs1.adminPassword);
await hs1AdminApp.initialize();

const primaryUser = await SynapseClient.createAndInitializeUser(federationConfig.hs1.url, federationConfig.hs1.domain, {
sharedSecret: federationConfig.hs1.registrationSharedSecret,
admin: true,
});
hs1PrimaryApp = primaryUser.client;
hs1PrimaryMatrixUserId = primaryUser.matrixUserId;
});

afterAll(async () => {
const adminAccessToken = hs1AdminApp?.matrixClient?.getAccessToken();
if (hs1PrimaryApp) {
await hs1PrimaryApp.close();
}
if (hs1PrimaryMatrixUserId && adminAccessToken) {
await SynapseClient.deactivateUser(federationConfig.hs1.url, hs1PrimaryMatrixUserId, adminAccessToken);
}
if (hs1AdminApp) {
await hs1AdminApp.close();
}
Expand All @@ -58,15 +74,15 @@ import { SynapseClient } from '../helper/synapse-client';
const createResponse = await createRoom({
type: 'p',
name: channelName,
members: [federationConfig.hs1.adminMatrixUserId, federationConfig.rc1.additionalUser1.username],
members: [hs1PrimaryMatrixUserId, federationConfig.rc1.additionalUser1.username],
extraData: { federated: true },
config: rc1AdminRequestConfig,
});

federatedChannelId = createResponse.body.group._id;

// Accept invitation on Synapse side
await hs1AdminApp.acceptInvitationForRoomName(channelName);
await hs1PrimaryApp.acceptInvitationForRoomName(channelName);

// Accept invitation for the local RC user
await acceptRoomInvite(federatedChannelId, rc1User1RequestConfig);
Expand All @@ -75,7 +91,7 @@ import { SynapseClient } from '../helper/synapse-client';
await retry(
'wait for RC user on Synapse',
async () => {
const member = await hs1AdminApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
const member = await hs1PrimaryApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
expect(member).not.toBeNull();
expect(member!.membership).toBe('join');
},
Expand Down Expand Up @@ -110,7 +126,7 @@ import { SynapseClient } from '../helper/synapse-client';
await retry(
'wait for ban on Synapse',
async () => {
const member = await hs1AdminApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
const member = await hs1PrimaryApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
expect(member).not.toBeNull();
expect(member!.membership).toBe('ban');
},
Expand Down Expand Up @@ -149,7 +165,7 @@ import { SynapseClient } from '../helper/synapse-client';
await retry(
'wait for unban on Synapse',
async () => {
const member = await hs1AdminApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
const member = await hs1PrimaryApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
expect(member).not.toBeNull();
expect(member!.membership).not.toBe('ban');
},
Expand All @@ -168,15 +184,15 @@ import { SynapseClient } from '../helper/synapse-client';
const createResponse = await createRoom({
type: 'p',
name: channelName,
members: [federationConfig.hs1.adminMatrixUserId, federationConfig.rc1.additionalUser1.username],
members: [hs1PrimaryMatrixUserId, federationConfig.rc1.additionalUser1.username],
extraData: { federated: true },
config: rc1AdminRequestConfig,
});

federatedChannelId = createResponse.body.group._id;

// Accept invitation on Synapse side only — RC user stays as INVITED
await hs1AdminApp.acceptInvitationForRoomName(channelName);
await hs1PrimaryApp.acceptInvitationForRoomName(channelName);
}, 30000);

it('should ban the invited user before they accept', async () => {
Expand Down Expand Up @@ -228,10 +244,10 @@ import { SynapseClient } from '../helper/synapse-client';

beforeAll(async () => {
channelName = `fed-ban-synapse-${Date.now()}`;
synapseRoomId = await hs1AdminApp.createRoom(channelName, Visibility.Private);
synapseRoomId = await hs1PrimaryApp.createRoom(channelName, Visibility.Private);

await hs1AdminApp.inviteUserToRoom(synapseRoomId, federationConfig.rc1.additionalUser1.matrixUserId);
await hs1AdminApp.inviteUserToRoom(synapseRoomId, federationConfig.rc1.adminMatrixUserId);
await hs1PrimaryApp.inviteUserToRoom(synapseRoomId, federationConfig.rc1.additionalUser1.matrixUserId);
await hs1PrimaryApp.inviteUserToRoom(synapseRoomId, federationConfig.rc1.adminMatrixUserId);

const roomsResponse = await rc1AdminRequestConfig.request.get(api('rooms.get')).set(rc1AdminRequestConfig.credentials).expect(200);

Expand All @@ -254,7 +270,7 @@ import { SynapseClient } from '../helper/synapse-client';
await retry(
'wait for RC user on Synapse',
async () => {
const member = await hs1AdminApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
const member = await hs1PrimaryApp.findRoomMember(channelName, federationConfig.rc1.additionalUser1.matrixUserId);
expect(member).not.toBeNull();
expect(member!.membership).toBe('join');
},
Expand All @@ -263,7 +279,7 @@ import { SynapseClient } from '../helper/synapse-client';
}, 30000);

it('should ban the RC user from Synapse', async () => {
await hs1AdminApp.banUser(synapseRoomId, federationConfig.rc1.additionalUser1.matrixUserId, 'federation ban test');
await hs1PrimaryApp.banUser(synapseRoomId, federationConfig.rc1.additionalUser1.matrixUserId, 'federation ban test');
});

it('should reflect ban on RC side', async () => {
Expand Down Expand Up @@ -291,7 +307,7 @@ import { SynapseClient } from '../helper/synapse-client';
});

it('should unban the RC user from Synapse', async () => {
await hs1AdminApp.unbanUser(synapseRoomId, federationConfig.rc1.additionalUser1.matrixUserId);
await hs1PrimaryApp.unbanUser(synapseRoomId, federationConfig.rc1.additionalUser1.matrixUserId);
});

it('should reflect unban on RC side', async () => {
Expand Down
Loading
Loading