go/engine/contact_sync_background.go - master - githubmirror/client

go/engine/contact_sync_background.go
95 строк3 KB
heronhaye
Surya/y2 k 460/service driven contact syncs (#19023)
04 сен 2019, 23:05
04 сен 2019, 23:0517a45d7
// Copyright 2019 Keybase, Inc. All rights reserved. Use of
// this source code is governed by the included BSD license.

package engine

import (
	"sync"
	"time"

	"github.com/keybase/client/go/libkb"
)

var ContactSyncBackgroundSettings = BackgroundTaskSettings{
	Start: 5 * time.Second,
	// in case we are foregrounding all the time, wait some more time because
	// this sync is heavy, and the timer is reset so it could run more than
	// once an hour if the mobile OS kills the app. But don't do this in
	// background active mode, or we might not run before we are
	// background passive'd.
	MobileForegroundStartAddition: 1 * time.Minute,
	StartStagger:                  5 * time.Second,
	WakeUp:                        15 * time.Second,
	Interval:                      1 * time.Hour,
	Limit:                         5 * time.Minute,
}

type ContactSyncBackground struct {
	libkb.Contextified
	sync.Mutex

	task *BackgroundTask
}

func NewContactSyncBackground(g *libkb.GlobalContext) *ContactSyncBackground {
	task := NewBackgroundTask(g, &BackgroundTaskArgs{
		Name:     "ContactSyncBackground",
		F:        ContactSyncBackgroundRound,
		Settings: ContactSyncBackgroundSettings,
	})
	return &ContactSyncBackground{
		Contextified: libkb.NewContextified(g),
		// Install the task early so that Shutdown can be called before RunEngine.
		task: task,
	}
}

func (e *ContactSyncBackground) Name() string {
	return "ContactSyncBackground"
}

func (e *ContactSyncBackground) Prereqs() Prereqs {
	return Prereqs{}
}

func (e *ContactSyncBackground) RequiredUIs() []libkb.UIKind {
	return []libkb.UIKind{}
}

func (e *ContactSyncBackground) SubConsumers() []libkb.UIConsumer {
	return []libkb.UIConsumer{}
}

// Run starts the engine.
// Returns immediately, kicks off a background goroutine.
func (e *ContactSyncBackground) Run(m libkb.MetaContext) (err error) {
	return RunEngine2(m, e.task)
}

func (e *ContactSyncBackground) Shutdown() {
	e.task.Shutdown()
}

func ContactSyncBackgroundRound(mctx libkb.MetaContext) error {
	g := mctx.G()
	if !g.ActiveDevice.Valid() {
		mctx.Debug("ContactSyncBackgroundRound; not logged in")
		return nil
	}

	if mctx.G().IsMobileAppType() {
		netState := mctx.G().MobileNetState.State()
		if netState.IsLimited() {
			mctx.Debug("ContactSyncBackgroundRound: not running; network state: %v", netState)
			return nil
		}
	}

	ui, err := mctx.G().UIRouter.GetChatUI()
	if err != nil || ui == nil {
		mctx.Debug("ContactSyncBackgroundRound: no chat UI found; err: %s", err)
		return nil
	}

	return ui.TriggerContactSync(mctx.Ctx())
}