All perguntas(coding)

Tenho dois modelos:

public class HouseDto 
{
    public DateTime[] ProductionDates { get; set; }
}

e

public class House
{
    public string PeriodStart { get; set; }
    
    public string PeriodEnd { get; set; }
}

Quero pegar o PeriodStarte PeriodEnde mesclá-los em um único array ProductionDates. Algo assim:

CreateMap<HouseDto, House>()
    .ForMember(d => d.ProductionDates, e => e.MapFrom(s => s.PeriodStart))
    .ForMember(d => d.ProductionDates, e => e.MapFrom(s => s.PeriodEnd));

O problema é que isso PeriodStartsobrescreverá PeriodEnd. Dei uma olhada na documentação e usei o Stack Overflow, mas não encontrei uma maneira de unir vários arrays em um único array. Isso é possível com o AutoMapper?

No CMS de carga útil, muitos campos de relacionamento polimórfico têm um tipo como o seguinte:

interface TypeA { a: 1 }
interface TypeB { b: 2 }
interface TypeC { c: 3 }

type Example = {
  items:
    | (
      | {
          relationTo: 'type-a';
          value: number | TypeA;
        }
      | {
          relationTo: 'type-b';
          value: number | TypeB;
        }
      | {
          relationTo: 'type-c';
          value: number | TypeC;
        }
      /* ... any number of these types ... */
    )[]
}

Os números podem ser retornados da API se a permissão para ler o valor for negada ou se a solicitação atingir a profundidade máxima permitida.

Estou com dificuldades para escrever um guarda de tipos reutilizável/genérico que filtre os numbercampos value. Idealmente, gostaria de uma função que, dado qualquer campo de relacionamento polimórfico, retorne o mesmo array, mas com o número de itens filtrados e os tipos atualizados (ou seja, valor, mas sem number).

Uma solução como essa não funciona, porque o TypeScript espera que todos os TypeA, TypeB, TypeC, etc sejam do mesmo tipo genérico T.

function numberGuard<T>(
  item: {
    relationTo: string,
    value: number | T
  }
): item is {
  relationTo: string,
  value: T
} {
  return typeof item.value !== "number"
}

function polyRelationshipMany<T>(
  items: {
    relationTo: string,
    value: number | T
  }[]
) {
  return items.filter(numberGuard);
}

declare const e: Example
const z = polyRelationshipMany(e.items)[0] // error!
// Note the error:
/*
Argument of type '({ relationTo: "type-a"; value: number | TypeA; } | { relationTo: "type-b"; value: number | TypeB; } | { relationTo: "type-c"; value: number | TypeC; })[]' is not assignable to parameter of type '{ relationTo: string; value: number | TypeA; }[]'.
  Type '{ relationTo: "type-a"; value: number | TypeA; } | { relationTo: "type-b"; value: number | TypeB; } | { relationTo: "type-c"; value: number | TypeC; }' is not assignable to type '{ relationTo: string; value: number | TypeA; }'.
    Type '{ relationTo: "type-b"; value: number | TypeB; }' is not assignable to type '{ relationTo: string; value: number | TypeA; }'.
      Types of property 'value' are incompatible.
        Type 'number | TypeB' is not assignable to type 'number | TypeA'.
          Type 'TypeB' is not assignable to type 'number | TypeA'.
*/

Exemplo de playground datilografado

Estou executando uma consulta JPA não nativa, que retorna um objeto personalizado.

@Query("""
    SELECT
    new path.to.CustomObject(
        t,
        (select id from users where name = :param1)
        (select id from departments where name IN (:param2))
    )
    FROM timesheets t
    WHERE status = :param3
)
Page<CustomObject> getAll(
    @Param("param1") String param1,
    @Param("param2") List<String> param2,
    @Param("param3") String param3,
    Pageable pageable
)

Quando executo a consulta com paginação padrão (tamanho = 10, página = 0), o registrador imprimirá:

o.s.d.j.r.q.QueryParameterSetter$ErrorHandling: Silently ignoring
java.lang.IllegalArgumentException: Could not locate named parameter [param1], expecting one of [param3]
java.lang.IllegalArgumentException: Could not locate named parameter [param2], expecting one of [param3]

Mas a consulta funciona perfeitamente e retorna os valores corretos, incluindo os das subconsultas. Se eu executar a mesma consulta com um tamanho de página maior (tamanho 30, página = 0), a consulta ainda funciona bem e sem erros. Se eu adicionar uma condição where simples abaixo, por exemplo:

[...]
FROM timesheets t
WHERE status = :param3
AND :param1 = :param1
AND :param2 = :param2

O erro só será gerado param2porque é uma lista. Parece que os parâmetros usados ​​dentro de uma subconsulta são ignorados, mas não consigo entender por que esse truque simples não funciona também para listas.

Gostaria de evitar imprimir exceções "falsas" no registro (já que elas não bloqueiam a execução), então estou procurando uma solução alternativa (como colocá-las em uma condição WHERE sempre verdadeira) ou uma maneira de impedir que o Spring registre as exceções ignoradas silenciosamente.

Tenho um conjunto de dados no seguinte formato:

2024-10-27T00:00    1   A
2024-10-27T00:15    2   B
2024-10-27T00:30    3   C
2024-10-27T00:45    4   D
2024-10-27T01:00    5   E
2024-10-27T01:15    6   F
2024-10-27T01:30    7   G
2024-10-27T01:45    8   H
2024-10-27T02:00    9   I
2024-10-27T02:00    10  J
2024-10-27T02:15    11  K
2024-10-27T02:15    12  L
2024-10-27T02:30    13  M
2024-10-27T02:30    14  N
2024-10-27T02:45    15  O
2024-10-27T02:45    16  P
2024-10-27T03:00    17  Q
2024-10-27T03:15    18  R
2024-10-27T03:30    19  S
2024-10-27T03:45    20  T

Isso está no horário local CE(S)T, então quero que o Pandas deduza a mudança de horário de verão. No entanto, ele gera um erro informando que há 4 mudanças de horário de verão, quando esperava apenas uma.

Curiosamente, o código abaixo funciona:

import pandas as pd

data = [
    ["2024-10-27T00:00", 1, "A"],
    ["2024-10-27T00:15", 2, "B"],
    ["2024-10-27T00:30", 3, "C"],
    ["2024-10-27T00:45", 4, "D"],
    ["2024-10-27T01:00", 5, "E"],
    ["2024-10-27T01:15", 6, "F"],
    ["2024-10-27T01:30", 7, "G"],
    ["2024-10-27T01:45", 8, "H"],
    ["2024-10-27T02:00", 9, "I"],
    ["2024-10-27T02:15", 10, "J"],
    ["2024-10-27T02:30", 11, "K"],
    ["2024-10-27T02:45", 12, "L"],
    ["2024-10-27T02:00", 13, "M"],
    ["2024-10-27T02:15", 14, "N"],
    ["2024-10-27T02:30", 15, "O"],
    ["2024-10-27T02:45", 16, "P"],
    ["2024-10-27T03:00", 17, "Q"],
    ["2024-10-27T03:15", 18, "R"],
    ["2024-10-27T03:30", 19, "S"],
    ["2024-10-27T03:45", 20, "T"],
]

df = pd.DataFrame(data, columns=["timestamp", "number", "letter"])
df.set_index("timestamp", inplace=True)
df.index=pd.to_datetime(df.index)

df.index=df.index.tz_localize('Europe/Amsterdam',ambiguous='infer')

No último exemplo, o Pandas parece interpretar (corretamente) que a primeira ocorrência é de fato o verão e a segunda, o inverno. Existe uma maneira de lidar com isso (facilmente)? ​​Codificar a reordenação seria uma maneira, mas parece trabalhoso (honestamente, nem saberia como, algo como filtrar por duplicatas e depois fazer um loop e trocar as linhas?).

Alguém tem alguma ideia sobre isso?

Tenho uma ListView que redimensionamos para mover o lado direito e deixar espaço para diferentes controles, dependendo das entradas do usuário. Depois do redimensionamento, eu faço...

lvProps.AutoResizeColumns(ColumnHeaderAutoResizeStyle.ColumnContent)
lvProps.AutoResizeColumns(ColumnHeaderAutoResizeStyle.HeaderSize)

Funciona, os tamanhos das colunas estão corretos e a aparência é boa, mas enquanto o código está em execução, você pode ver as larguras diminuindo e aumentando novamente. Isso é muito perturbador.

Tenho certeza de que isso é algo simples, mas qual é a melhor maneira de interromper a exibição durante o breve período em que esses itens estão sendo redimensionados?

Estou com problemas para acessar um servidor NodeJS que está rodando localmente na porta 4000. Consigo acessar o servidor pelo Chrome como http://localhost:4000, mas não consigo acessar pelo IP http://192.168.30.30:4000 . Também estou tentando acessar o servidor web local a partir de um simulador Android, mas não consigo.

Permiti que o Chrome e o Android Studio acessassem as redes locais em Configurações -> Privacidade -> Rede local. Após permitir esse acesso, reiniciei o Chrome e o Android Studio. Também reiniciei meu Mac. Além disso, limpei as permissões de rede para que possam ser redefinidas seguindo https://forums.macrumors.com/threads/local-network-access-nightmare.2448144/?post=33698401#post-33698401 .

Para redefinir as permissões da rede local, no Terminal em Recuperação, exclua /Library/Preferences/com.apple.networkextension.plist

rm "/Volumes/Macintosh HD/Library/Preferences/com.apple.networkextension.plist"

Isso redefiniu as permissões para que eu pudesse concedê-las novamente, mas ainda não consigo acessar o servidor via IP.

Li vários posts sobre o Sequoia e não tive acesso aos servidores locais via IP, mas ainda não tive sucesso em resolver esse problema.

Alguém tem alguma outra ideia que eu possa tentar?

EDITAR:

Tentei iniciar meu servidor de nó de algumas maneiras:

server.listen(4000, 0.0.0.0, () => {...

E

server.listen(4000, 127.0.0.1, () => {...

Entendo que a sintaxe para excluir o arquivo plist não é perfeita, só sei que consegui excluir e fui promovido adequadamente para acesso à rede local no Chrome e no Android e aceitei

Agradeço a todos que dedicaram seu tempo para me ajudar com isso. Estou escrevendo um pequeno programa para operar uma aeronave multirrotor via mensagens mavlink. O drone, com seu piloto automático, transmite dados de telemetria via UDP e eu, como cliente, preciso ouvir suas mensagens e enviar algumas minhas. O problema é que, em cerca de metade das vezes, meu programa parece não receber nenhum pacote do drone. Tenho certeza de que o problema está no meu código, pois consigo ver todas as mensagens enviadas pelo piloto automático via UDP usando o Wireshark. Outros softwares funcionam sem problemas com o mesmo piloto automático no mesmo computador. O problema está em algum lugar do meu aplicativo.

Tenho uma classe BaseUDP que gerencia toda a comunicação UDP.

class UDPBase
{
public:
    using IoContext = boost::asio::io_service; // backwards compatibility forces me to use an older boost
    using UDP = boost::asio::ip::udp;
    using Socket = UDP::socket;
    using Endpoint = UDP::endpoint;
    using Address = boost::asio::ip::address;
    using ErrorCode = boost::system::error_code;

public:
    UDPBase(IoContext &ioContext);
    UDPBase(IoContext &ioContext, unsigned short int listenPort);
    virtual ~UDPBase();

    virtual void startListening();

    void startIoContext();
    void stopIoContext();

protected:
    void init();
    virtual void close();
    void doListen();
    virtual void onDataReceived(const ErrorCode &ec, unsigned char *buffer, size_t bufferSize);

private:

    IoContext &ioContext;
    Socket socket;
    Endpoint listeningEndpoint;
    Endpoint destinationEndpoint;
};

listeningEndpointestá configurado com a porta em que eu escuto. Editei alguns setters e getters para reduzir o tamanho do código.

UDPBase::UDPBase(IoContext &ioContext) : ioContext(ioContext), socket(ioContext)
{
    init();
}

UDPBase::UDPBase(IoContext &ioContext, unsigned short int listenPort) : ioContext(ioContext), socket(ioContext)
{
// set listenEndpoint based on the port
   init();
}

UDPBase::~UDPBase()
{
    // close();
}

void UDPBase::startListening(unsigned short int listenPort)
{
    init();
    doListen();
}

void UDPBase::close()
{
    socket.close();
}

void UDPBase::startIoContext()
{
    ioContext.run();
}

void UDPBase::stopIoContext()
{
    ioContext.post([this]()
    {
        if (socket.is_open())
        {
            socket.close();
        } 
    });

    ioContext.stop();
}

void UDPBase::doListen()
{
    socket.async_receive_from(
        boost::asio::buffer(receiveBuffer, maxBufferSize), listeningEndpoint,
        [this](ErrorCode ec, std::size_t bytesRecvd)
        {
            // std::cout << "Received from IP: " << listeningEndpoint.address().to_string() << " and Port: " << listeningEndpoint.port() << std::endl;
            handleListen(ec);
            onDataReceived(ec, receiveBuffer.data(), bytesRecvd);
            doListen();
        });
}

void UDPBase::onDataReceived(const ErrorCode &ec, unsigned char *buffer, size_t bufferSize)
{
    if (ec)
    {
        std::cout << "! Receive error: " << ec.message() << std::endl;
        return;
    }

    if (bufferSize)
    {
        // decode buffer
    }
    else
    {
        std::cout << "# No data received" << std::endl;
    }
}

void UDPBase::init()
{
    close();
    socket.open(UDP::v4());
    boost::asio::socket_base::reuse_address option(true);
    socket.set_option(option);
    boost::system::error_code ec;
    socket.bind(listeningEndpoint, ec);
    if (ec)
    {
        std::cerr << "Failed to bind socket: " << ec.message() << std::endl;
        throw std::runtime_error("Socket bind failed");
    }
}

Eu herdei UDPBase em outra classe que lida com a decodificação de mensagens e inicia um thread executando o ioContext.

void MavlinkWrapper::start()
{
    mAppThread = std::thread([this]()
                             { startIoContext(); });
}

void MavlinkWrapper::stop()
{
    stopIoContext();
    if (mAppThread.joinable()) 
    {
        mAppThread.join();
    }
}

main.cpp

#include "MavlinkWrapper/MavlinkWrapper.hpp"

int main()
{
    boost::asio::io_service ioContext;
    MavlinkWrapper mavlinkWrapper(ioContext, 14550); // listen port is forwarded to UDPBase to bind the socket to it

    mavlinkWrapper.start();
    std::this_thread::sleep_for(std::chrono::seconds(20)); // wait for the messages that the autopilot broadcasts and print some data
    mavlinkWrapper.stop();

    return 0;
}

Suspeito que possa haver uma falha na maneira como fecho o socket ou entro na thread no final. Ou talvez eu não esteja interrompendo o ioContext corretamente e o socket esteja em um estado estranho. Estou usando o Windows 10.

Estou usando o Kafka Streams para agrupar e reduzir um tópico do Kafka.

Quero gerar uma saída para uma chave, se a chave e o valor forem iguais para todos os valores de uma determinada chave; caso contrário, não gere nada para essa chave.

Para fazer isso, no entanto, preciso acessar o key, e os .reducemétodos só dão acesso aos valores agregados/atuais.

É possível obter a chave ao chamar .reduce? Ou existe outra maneira de fazer isso?

Tenho um intervalo de dados com células mescladas. As células mescladas contêm o nome do funcionário que realizou determinadas operações.

Como você pode ver na imagem: cada dia tem seu funcionário.

Preciso manter estatísticas dessas operações por um mês.

Preciso manter estatísticas sobre eficiência e produtividade. Para isso, produzo a seguinte fórmula em uma planilha separada.

Tabela do Google

="{"&JOIN(";";ARRAYFORMULA("'March'!"&ADRESS(4;FILTER(COLUMN('March'!$A$2:$FA$24)+2;'March'!A2:FA2=A3))&":"&ADRESS(1000;FILTER(Column('March'!$A$2:$FA$24)+2;'March'!A2:FA2=A3))))&"}"

A fórmula retorna o resultado "{'March'!$DU$4:$DU$1000;'March'!$EO$4:$EO$1000}" e é um texto! A função indireta não funciona porque é uma matriz de dados, e outras fórmulas, como a consulta, não aceitam essa matriz como resultado.

Pergunta: Como posso converter este texto em uma matriz/fórmula?

Gosto dos fluxos do Redis porque, com eles, o Redis se torna um banco de dados IoT. O principal comando do Redis para adicionar algo ao fluxo é XADD:

XADD log * name Some_name_to_write text Some_text_to_write

Funciona bem.

Então tento usar o Redigo para fazer a mesma operação:

type LogEntry struct {
    Name string `json:"name"`
    Text string `json:"text"`
}

func (l *LogEntry) Push() error {
    var args []string // XADD arguments

    log.Printf("Log Entry: %+v\n", l)
    args = make([]string, 6)
    args = append(args, "log") // Stream key
    args = append(args, "*")   // Auto-generated stream ID
    args = append(args, "name", l.Name)
    args = append(args, "text", l.Text)
    log.Printf("Args for XADD: %+v\n", args)

    new := make([]any, len(args))
    for index, value := range args {
        new[index] = value
    }

    _, err := connection.Do("XADD", new...)
    if err != nil {
        log.Println("XADD error", err)
        return err
    }

    return nil
}

connectionaqui está redis.Conn.

Este código produz a seguinte saída:

2025-04-08 16:03:08 2025/04/08 13:03:08 Log Entry: &{Name:Some_name_to_write Text:Some_text_to_write}
2025-04-08 16:03:08 2025/04/08 13:03:08 Args for XADD: [      log * name Some_name_to_write text Some_text_to_write]
2025-04-08 16:03:08 2025/04/08 13:03:08 XADD error ERR Invalid stream ID specified as stream command argument

Então, vejo que os argumentos são conn.Doexatamente os mesmos que usei antes na CLI.

O que há de errado aqui?