mirror
/
tile38
mirror of https://github.com/tidwall/tile38.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Allow for all command types for roaming event 

Prior to this commit roaming geofences only registered changes to
the SET command. Now it will work for SET/DEL/FSET, just like
non-roaming geofences.

To opt out of these events, explicitly choose which event you
would like to register when you create the geofences.

For example:

  NEARBY fleet FENCE COMMANDS set,del ROAM fleet * 5000

Will only fire off events from SET and DEL command.

Closes #597
This commit is contained in:
tidwall 2021-04-01 14:59:12 -07:00
parent 5a1275bac2
commit d37ce505f5
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/server/fence.go
View File

@ -99,10 +99,10 @@ func fenceMatch(
roamNearbys, roamFaraways = roamNearbys, roamFaraways =
fenceMatchRoam(sw.s, fence, details.id, fenceMatchRoam(sw.s, fence, details.id,
details.oldObj, details.obj) details.oldObj, details.obj)
}
if len(roamNearbys) == 0 && len(roamFaraways) == 0 { if len(roamNearbys) == 0 && len(roamFaraways) == 0 {
return nil return nil
} }
}
detect = "roam" detect = "roam"
} else { } else {
// not using roaming // not using roaming
@ -235,6 +235,12 @@ func fenceMatch(
case "roam": case "roam":
if len(msgs) > 0 { if len(msgs) > 0 {
var nmsgs []string var nmsgs []string
for _, msg := range msgs {
cmd := gjson.Get(msg, "command")
if cmd.Exists() && cmd.String() != "set" {
nmsgs = append(nmsgs, msg)
}
}
for i := range roamNearbys { for i := range roamNearbys {
nmsg := extendRoamMessage(sw, fence, nmsg := extendRoamMessage(sw, fence,
"nearby", msgs[0], roamNearbys[i]) "nearby", msgs[0], roamNearbys[i])