Method runExtensionOnSync

server/sync_watcher.go:331–344

Run extension on sync

(response *gohan_sync.Event, env extension.Environment)

//Run extension on sync
func (watcher *SyncWatcher) runExtensionOnSync(response *gohan_sync.Event, env extension.Environment) {
	defer watcher.measureSyncTime(time.Now(), response.Action)

	context := map[string]interface{}{
		"action": response.Action,
		"data":   response.Data,
		"key":    response.Key,
	}
	if err := env.HandleEvent("notification", context); err != nil {
		log.Warning(fmt.Sprintf("extension error: %s", err))
		return
	}
	return
}