import type {
    RxError,
    RxTypeError
} from 'nxdb-old/src/types';
import { errorToPlainJson } from 'nxdb-old/src/plugins/utils';
import type {
    MessageFromRemote,
    MessageToRemote
} from 'nxdb-old/src/plugins/storage-remote/storage-remote-types';

export function createErrorAnswer(
    msg: MessageToRemote,
    error: Error | TypeError | RxError | RxTypeError
): MessageFromRemote {
    return {
        connectionId: msg.connectionId,
        answerTo: msg.requestId,
        method: msg.method,
        error: errorToPlainJson(error)
    };
}

export function createAnswer(
    msg: MessageToRemote,
    ret: any
): MessageFromRemote {
    return {
        connectionId: msg.connectionId,
        answerTo: msg.requestId,
        method: msg.method,
        return: ret
    };
}