(ctx context.Context, arg ListAIBridgeModelsParams, prepared rbac.PreparedAuthorized)
| 1023 | } |
| 1024 | |
| 1025 | func (q *sqlQuerier) ListAuthorizedAIBridgeModels(ctx context.Context, arg ListAIBridgeModelsParams, prepared rbac.PreparedAuthorized) ([]string, error) { |
| 1026 | authorizedFilter, err := prepared.CompileToSQL(ctx, regosql.ConvertConfig{ |
| 1027 | VariableConverter: regosql.AIBridgeInterceptionConverter(), |
| 1028 | }) |
| 1029 | if err != nil { |
| 1030 | return nil, xerrors.Errorf("compile authorized filter: %w", err) |
| 1031 | } |
| 1032 | filtered, err := insertAuthorizedFilter(listAIBridgeModels, fmt.Sprintf(" AND %s", authorizedFilter)) |
| 1033 | if err != nil { |
| 1034 | return nil, xerrors.Errorf("insert authorized filter: %w", err) |
| 1035 | } |
| 1036 | |
| 1037 | query := fmt.Sprintf("-- name: ListAIBridgeModels :many\n%s", filtered) |
| 1038 | rows, err := q.db.QueryContext(ctx, query, arg.Model, arg.Offset, arg.Limit) |
| 1039 | if err != nil { |
| 1040 | return nil, err |
| 1041 | } |
| 1042 | defer rows.Close() |
| 1043 | var items []string |
| 1044 | for rows.Next() { |
| 1045 | var model string |
| 1046 | if err := rows.Scan(&model); err != nil { |
| 1047 | return nil, err |
| 1048 | } |
| 1049 | items = append(items, model) |
| 1050 | } |
| 1051 | return items, nil |
| 1052 | } |
| 1053 | |
| 1054 | func (q *sqlQuerier) ListAuthorizedAIBridgeClients(ctx context.Context, arg ListAIBridgeClientsParams, prepared rbac.PreparedAuthorized) ([]string, error) { |
| 1055 | authorizedFilter, err := prepared.CompileToSQL(ctx, regosql.ConvertConfig{ |
nothing calls this directly
no test coverage detected