Fixup Channel Setting and Timeouts for Tests
continuous-integration/drone/pr Build is passing Details

This commit is contained in:
Sarah Jamie Lewis 2024-06-10 14:04:34 -07:00
parent 4bce08dc00
commit 74d2aec96a
Signed by: sarah
GPG Key ID: F27FD21A270837EF
3 changed files with 7 additions and 5 deletions

View File

@ -58,7 +58,7 @@ func (soe SendWhenOnlineExtension) OnEvent(ev event.Event, profile peer.CwtchPee
ev := event.NewEvent(event.SendMessageToPeer, map[event.Field]string{event.ConversationID: strconv.Itoa(ci.ID), event.RemotePeer: ci.Handle, event.Data: body})
ev.EventID = message.Signature // we need this ensure that we correctly ack this in the db when it comes back
// TODO: The EventBus is becoming very noisy...we may want to consider a one-way shortcut to Engine i.e. profile.Engine.SendMessageToPeer
log.Debugf("resending message that was sent when peer was offline")
log.Infof("resending message that was sent when peer was offline")
profile.PublishEvent(ev)
}
}

View File

@ -144,9 +144,11 @@ func (f *GroupManagerFunctionality) handleNewMessageEvent(profile peer.CwtchPeer
for _, ci := range allConversations {
// NOTE: This check works for Open Groups too as CheckACL will return the default ACL
// for the group....
if acl, err := CheckACL(hgm.Author, group); err == nil && acl.Read {
log.Infof("forwarding group message to: %v", ci.Handle)
profile.SendMessage(ci.ID, original)
if ci.Handle != MANAGED_GROUP_HANDLE { // don't send to ourselves...
if acl, err := CheckACL(hgm.Author, group); err == nil && acl.Read {
log.Infof("forwarding group message to: %v", ci.Handle)
profile.SendMessage(ci.ID, original)
}
}
}
}

View File

@ -178,7 +178,7 @@ func TestFileSharing(t *testing.T) {
// testBobDownloadFile(t, bob, filesharingFunctionality, queueOracle)
// Wait for say...
time.Sleep(10 * time.Second)
time.Sleep(30 * time.Second)
if _, err := os.Stat(path.Join(settings.DownloadPath, "cwtch.png")); errors.Is(err, os.ErrNotExist) {
// path/to/whatever does not exist