2019-06-21 21:50:43 +00:00
|
|
|
package utils
|
|
|
|
|
|
|
|
import (
|
|
|
|
app2 "cwtch.im/cwtch/app"
|
2021-05-03 23:32:48 +00:00
|
|
|
"cwtch.im/cwtch/model/attr"
|
2019-06-21 21:50:43 +00:00
|
|
|
"cwtch.im/cwtch/peer"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
2019-07-22 20:49:23 +00:00
|
|
|
// WaitGetPeer is a helper function for utility apps not written using the event bus
|
2019-06-21 21:50:43 +00:00
|
|
|
// Proper use of an App is to call CreatePeer and then process the NewPeer event
|
|
|
|
// however for small utility use, this function which polls the app until the peer is created
|
|
|
|
// may fill that usecase better
|
|
|
|
func WaitGetPeer(app app2.Application, name string) peer.CwtchPeer {
|
2021-06-02 18:34:57 +00:00
|
|
|
for {
|
2021-05-03 23:32:48 +00:00
|
|
|
for id := range app.ListPeers() {
|
|
|
|
peer := app.GetPeer(id)
|
|
|
|
localName, _ := peer.GetAttribute(attr.GetLocalScope("name"))
|
|
|
|
if localName == name {
|
|
|
|
return peer
|
2019-06-21 21:50:43 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
|
|
}
|
|
|
|
}
|