Skip to content

Commit

Permalink
Adapt James after migrate - Adapt JAMES-2182 MailboxManager new API
Browse files Browse the repository at this point in the history
- ref commit: 316522363b679d53fb2cc9e7b1561f6d75f2414e
  • Loading branch information
vttranlina committed Nov 4, 2024
1 parent 203b5f0 commit 18167ae
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -127,14 +127,9 @@ class TeamMailboxRepositoryImpl @Inject()(mailboxManager: MailboxManager,
private def createSession(teamMailbox: TeamMailbox): MailboxSession =
mailboxManager.createSystemSession(teamMailbox.owner)

private def createSession(domain: Domain): MailboxSession =
mailboxManager.createSystemSession(Username.fromLocalPartWithDomain("team-mailbox", domain))

override def listTeamMailboxes(domain: Domain): Publisher[TeamMailbox] =
SFlux.fromPublisher(mailboxManager.search(TEAM_MAILBOX_QUERY, createSession(domain)))
.filter(mailboxMetaData => mailboxMetaData.getPath.getUser.getDomainPart
.filter(domain.equals(_)).isPresent)
.flatMapIterable(mailboxMetaData => TeamMailbox.from(mailboxMetaData.getPath))
listTeamMailboxes()
.filter(teamMailbox => teamMailbox.domain.equals(domain))
.distinct()

override def listTeamMailboxes(username: Username): Publisher[TeamMailbox] =
Expand Down Expand Up @@ -211,7 +206,7 @@ class TeamMailboxRepositoryImpl @Inject()(mailboxManager: MailboxManager,
.`then`()
}

override def listTeamMailboxes(): Publisher[TeamMailbox] = {
override def listTeamMailboxes(): SFlux[TeamMailbox] = {
val session = mailboxManager.createSystemSession(Username.of("team-mailboxes"))
SFlux.fromIterable(mailboxManager.list(session)
.asScala
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -210,6 +210,7 @@ void getTeamMailboxesByDomainShouldReturnListEntryWhenHasMultipleElement() {
.body()
.asString();
assertThatJson(response)
.withOptions(Option.IGNORING_ARRAY_ORDER)
.isEqualTo("[" +
" {" +
" \"name\": \"marketing\"," +
Expand Down

0 comments on commit 18167ae

Please sign in to comment.