status-go/protocol/messenger_settings.go

package protocol

import (
	"context"

	"github.com/status-im/status-go/nodecfg"
	"github.com/status-im/status-go/protocol/requests"
	"github.com/status-im/status-go/timesource"
)

func (m *Messenger) SetLightClient(request *requests.SetLightClient) error {
	return nodecfg.SetLightClient(m.database, request.Enabled)
}

func (m *Messenger) SetStoreConfirmationForMessagesSent(request *requests.SetStoreConfirmationForMessagesSent) error {
	return nodecfg.SetStoreConfirmationForMessagesSent(m.database, request.Enabled)
}

func (m *Messenger) SetSyncingOnMobileNetwork(request *requests.SetSyncingOnMobileNetwork) error {
	if err := request.Validate(); err != nil {
		return err
	}
	err := m.settings.SetSyncingOnMobileNetwork(request.Enabled)
	if err != nil {
		return err
	}
	if request.Enabled {
		m.asyncRequestAllHistoricMessages()
	}
	return nil
}

func (m *Messenger) SetLogLevel(request *requests.SetLogLevel) error {
	if err := request.Validate(); err != nil {
		return err
	}

	return nodecfg.SetLogLevel(m.database, request.LogLevel)
}

func (m *Messenger) SetMaxLogBackups(request *requests.SetMaxLogBackups) error {
	return nodecfg.SetMaxLogBackups(m.database, request.MaxLogBackups)
}

func (m *Messenger) SetCustomNodes(request *requests.SetCustomNodes) error {
	return nodecfg.SetWakuV2CustomNodes(m.database, request.CustomNodes)
}

func (m *Messenger) SaveNewWakuNode(request *requests.SaveNewWakuNode) error {
	if err := request.Validate(); err != nil {
		return err
	}
	return nodecfg.SaveNewWakuNode(m.database, request.NodeAddress)
}

func (m *Messenger) SetCustomizationColor(ctx context.Context, request *requests.SetCustomizationColor) error {
	if err := request.Validate(); err != nil {
		return err
	}

	acc, err := m.multiAccounts.GetAccount(request.KeyUID)
	if err != nil {
		return err
	}

	acc.CustomizationColor = request.CustomizationColor

	if m.account != nil {
		m.account.CustomizationColor = request.CustomizationColor
	}

	//Use a combination of wall clock + lamport timestamp, just like Chat#NextClockAndTimestamp
	tNow := timesource.GetCurrentTimeInMillis()
	if acc.CustomizationColorClock >= tNow {
		acc.CustomizationColorClock++
	} else {
		acc.CustomizationColorClock = tNow
	}

	affected, err := m.multiAccounts.UpdateAccountCustomizationColor(request.KeyUID, string(acc.CustomizationColor), acc.CustomizationColorClock)
	if err != nil {
		return err
	}

	if affected > 0 {
		err = m.syncAccountCustomizationColor(ctx, acc)
		if err != nil {
			return err
		}

		err = m.resetLastPublishedTimeForChatIdentity()
		if err != nil {
			return err
		}

		return m.publishContactCode()
	}
	return nil
}

func (m *Messenger) TogglePeerSyncing(request *requests.TogglePeerSyncingRequest) error {
	if err := request.Validate(); err != nil {
		return err
	}

	err := m.settings.SetPeerSyncingEnabled(request.Enabled)
	if err != nil {
		return err
	}
	return nil
}