mirror of
https://github.com/moltbot/moltbot.git
synced 2026-04-20 13:13:06 +00:00
fix(check): repair latest command and stream type drift
This commit is contained in:
@@ -23,6 +23,7 @@ type DiscordWebhookMessageLike = {
|
||||
|
||||
type DiscordMemberLike = {
|
||||
nickname?: string | null;
|
||||
nick?: string | null;
|
||||
};
|
||||
|
||||
export function resolveDiscordWebhookId(message: DiscordWebhookMessageLike): string | null {
|
||||
@@ -61,7 +62,10 @@ export function resolveDiscordSenderIdentity(params: {
|
||||
|
||||
const senderTag = formatDiscordUserTag(params.author);
|
||||
const senderDisplay =
|
||||
params.member?.nickname ?? params.author.globalName ?? params.author.username;
|
||||
params.member?.nickname ??
|
||||
params.member?.nick ??
|
||||
params.author.globalName ??
|
||||
params.author.username;
|
||||
const senderLabel =
|
||||
senderDisplay && senderTag && senderDisplay !== senderTag
|
||||
? `${senderDisplay} (${senderTag})`
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
import { randomUUID } from "node:crypto";
|
||||
import { Readable } from "node:stream";
|
||||
import type { ReadableStream as WebReadableStream } from "node:stream/web";
|
||||
import type { LookupFn, SsrFPolicy } from "../../api.js";
|
||||
import { ensureUrbitChannelOpen, pokeUrbitChannel, scryUrbitPath } from "./channel-ops.js";
|
||||
import { getUrbitContext, normalizeUrbitCookie } from "./context.js";
|
||||
@@ -206,7 +207,11 @@ export class UrbitSSEClient {
|
||||
if (!body) {
|
||||
return;
|
||||
}
|
||||
const stream = body instanceof ReadableStream ? Readable.fromWeb(body) : body;
|
||||
// Bridge DOM fetch stream types to Node's stream/web declaration on newer TS/node combos.
|
||||
const stream =
|
||||
body instanceof ReadableStream
|
||||
? Readable.fromWeb(body as unknown as WebReadableStream)
|
||||
: body;
|
||||
let buffer = "";
|
||||
|
||||
try {
|
||||
|
||||
@@ -35,7 +35,7 @@ function createParsedRoute(params: {
|
||||
if (!args) {
|
||||
return false;
|
||||
}
|
||||
await params.definition.runParsedArgs(args);
|
||||
await params.definition.runParsedArgs(args as never);
|
||||
return true;
|
||||
},
|
||||
};
|
||||
|
||||
@@ -20,7 +20,10 @@ export type RoutedCommandDefinition<TParse extends RouteArgParser<unknown>> = {
|
||||
runParsedArgs: (args: ParsedRouteArgs<TParse>) => Promise<void>;
|
||||
};
|
||||
|
||||
export type AnyRoutedCommandDefinition = RoutedCommandDefinition<RouteArgParser<unknown>>;
|
||||
export type AnyRoutedCommandDefinition = {
|
||||
parseArgs: RouteArgParser<unknown>;
|
||||
runParsedArgs: (args: never) => Promise<void>;
|
||||
};
|
||||
|
||||
function defineRoutedCommand<TParse extends RouteArgParser<unknown>>(
|
||||
definition: RoutedCommandDefinition<TParse>,
|
||||
|
||||
Reference in New Issue
Block a user