Function resolveDBFromPayload

server-source-code/internal/queue/workers.go:34–46

resolveDBFromPayload returns the DB to use: from poolCache when host is in payload, else defaultDB.

(ctx context.Context, payload []byte, defaultDB *database.DB, poolCache *hostctx.PoolCache)

// resolveDBFromPayload returns the DB to use: from poolCache when host is in payload, else defaultDB.
func resolveDBFromPayload(ctx context.Context, payload []byte, defaultDB *database.DB, poolCache *hostctx.PoolCache) *database.DB {
	db := defaultDB
	if len(payload) == 0 || poolCache == nil {
		return db
	}
	var p AutomationPayload
	if err := json.Unmarshal(payload, &p); err == nil && strings.TrimSpace(p.Host) != "" {
		if resolved, err := poolCache.GetOrCreate(ctx, p.Host); err == nil && resolved != nil {
			db = resolved
		}
	}
	return db
}

// workerTenantKey prefixes a Redis key with the context domain for multi-context isolation.
// Mirrors hostctx.TenantKey but works in worker context where only the host string