go/ephemeral/handler.go - master - githubmirror/client

go/ephemeral/handler.go
70 строк2 KB
zoom-ua
gofumpt (#28710)
17 дек 2025, 17:16
17 дек 2025, 17:16cda510b
package ephemeral

import (
	"fmt"

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

func HandleNewTeamEK(mctx libkb.MetaContext, teamID keybase1.TeamID, generation keybase1.EkGeneration) (err error) {
	defer mctx.Trace("HandleNewTeamEK", &err)()

	ekLib := mctx.G().GetEKLib()
	if ekLib == nil {
		return fmt.Errorf("ekLib not found")
	}
	ekLib.PurgeTeamEKCachesForTeamIDAndGeneration(mctx, teamID, generation)
	mctx.G().NotifyRouter.HandleNewTeamEK(mctx.Ctx(), teamID, generation)
	return nil
}

func HandleNewTeambotEK(mctx libkb.MetaContext, teamID keybase1.TeamID, generation keybase1.EkGeneration) (err error) {
	defer mctx.Trace("HandleNewTeambotEK", &err)()

	ekLib := mctx.G().GetEKLib()
	if ekLib == nil {
		return fmt.Errorf("ekLib not found")
	}
	ekLib.PurgeTeambotEKCachesForTeamIDAndGeneration(mctx, teamID, generation)
	mctx.G().NotifyRouter.HandleNewTeambotEK(mctx.Ctx(), teamID, generation)
	return nil
}

// HandleTeambotEKNeeded forces a teambot ek to be generated since the bot does
// not have access. All team members are notified and race to publish the
// requested key.
func HandleTeambotEKNeeded(mctx libkb.MetaContext, teamID keybase1.TeamID, botUID keybase1.UID,
	generation keybase1.EkGeneration, forceCreateGen *keybase1.EkGeneration,
) (err error) {
	defer mctx.Trace("HandleTeambotEKNeeded", &err)()
	defer func() {
		mctx.G().NotifyRouter.HandleTeambotEKNeeded(mctx.Ctx(), teamID, botUID, generation, forceCreateGen)
	}()

	ekLib := mctx.G().GetEKLib()
	if ekLib == nil {
		return fmt.Errorf("ekLib not found")
	}

	// Bot user needs the latest key
	if forceCreateGen != nil {
		// clear our caches here so we can force publish a key
		ekLib.PurgeTeamEKCachesForTeamID(mctx, teamID)
		ekLib.PurgeAllTeambotMetadataCaches(mctx)
		_, _, err = ekLib.ForceCreateTeambotEK(mctx, teamID, botUID.ToBytes(), *forceCreateGen)
		return err
	} else if generation == 0 {
		// clear our caches here so we can force publish a key
		ekLib.PurgeTeamEKCachesForTeamID(mctx, teamID)
		ekLib.PurgeAllTeambotMetadataCaches(mctx)
		_, _, err = ekLib.GetOrCreateLatestTeambotEK(mctx, teamID, botUID.ToBytes())
		return err
	}

	// Bot needs a specific generation
	ekLib.PurgeTeamEKCachesForTeamIDAndGeneration(mctx, teamID, generation)
	ekLib.PurgeTeambotMetadataCache(mctx, teamID, botUID, generation)
	_, err = ekLib.GetTeambotEK(mctx, teamID, botUID.ToBytes(), generation, nil)
	return err
}