use getFederatorMsg()

This commit is contained in:
kim 2024-04-26 12:29:56 +01:00
parent 2e5c93fdba
commit 2560915163
1 changed files with 2 additions and 2 deletions

View File

@ -80,7 +80,7 @@ func (suite *CreateTestSuite) TestCreateNoteForward() {
suite.NoError(err)
// should be a message heading to the processor now, which we can intercept here
msg, _ := suite.state.Workers.Federator.Queue.Pop()
msg, _ := suite.getFederatorMsg(5 * time.Second)
suite.Equal(ap.ObjectNote, msg.APObjectType)
suite.Equal(ap.ActivityCreate, msg.APActivityType)
@ -121,7 +121,7 @@ func (suite *CreateTestSuite) TestCreateFlag1() {
}
// should be a message heading to the processor now, which we can intercept here
msg, _ := suite.state.Workers.Federator.Queue.Pop()
msg, _ := suite.getFederatorMsg(5 * time.Second)
suite.Equal(ap.ActivityFlag, msg.APObjectType)
suite.Equal(ap.ActivityCreate, msg.APActivityType)