go/libkb/net_context.go - master - githubmirror/client

go/libkb/net_context.go
86 строк2 KB
chrisnojima-zoom
Version 670 - clean2 (#29122)
08 июн 2026, 19:31
08 июн 2026, 19:311943197
package libkb

import (
	"context"
	"fmt"
	"strings"

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

type withLogTagKey string

func WithLogTag(ctx context.Context, k string) context.Context {
	return WithLogTagWithValue(ctx, k, RandStringB64(3))
}

func WithLogTagWithValue(ctx context.Context, k, v string) context.Context {
	ctx = logger.ConvertRPCTagsToLogTags(ctx)

	addLogTags := true
	tagKey := withLogTagKey(k)

	if tags, ok := logger.LogTagsFromContext(ctx); ok {
		if _, found := tags[tagKey]; found {
			addLogTags = false
		}
	}

	if addLogTags {
		newTags := make(logger.CtxLogTags)
		newTags[tagKey] = k
		ctx = logger.NewContextWithLogTags(ctx, newTags)
	}

	// Only add a new FOO=abcdDE333EX log tag if one didn't
	// already exist in this context.
	if _, found := ctx.Value(tagKey).(string); !found {
		ctx = context.WithValue(ctx, tagKey, v)
	}
	return ctx
}

func LogTagsToString(ctx context.Context) string {
	if ctx == nil {
		return ""
	}

	tags, ok := logger.LogTagsFromContext(ctx)
	if !ok || len(tags) == 0 {
		return ""
	}
	var out []string
	for key, tag := range tags {
		if v := ctx.Value(key); v != nil {
			out = append(out, fmt.Sprintf("%s=%s", tag, v))
		}
	}
	return strings.Join(out, ",")
}

func LogTagsFromString(tags string) map[string]string {
	tagMap := make(map[string]string)
	for tag := range strings.SplitSeq(tags, ",") {
		parsedTag := strings.Split(tag, "=")
		if len(parsedTag) != 2 {
			continue
		}
		tagMap[parsedTag[0]] = parsedTag[1]
	}
	return tagMap
}

func CopyTagsToBackground(ctx context.Context) context.Context {
	ret := context.Background()
	if tags, ok := logger.LogTagsFromContext(ctx); ok {
		ret = logger.NewContextWithLogTags(ret, tags)
		for key := range tags {
			if ctxKey, ok := key.(withLogTagKey); ok {
				if val, ok := ctx.Value(ctxKey).(string); ok && len(val) > 0 {
					ret = context.WithValue(ret, ctxKey, val)
				}
			}
		}
	}
	return ret
}