Function resolveHubClient

packages/memos-core/src/client/hub.ts:13–41

(store: SqliteStore, ctx: PluginContext, overrides?: { hubAddress?: string; userToken?: string })

}

export async function resolveHubClient(store: SqliteStore, ctx: PluginContext, overrides?: { hubAddress?: string; userToken?: string }): Promise<ResolvedHubClient> {
  const persisted = store.getClientHubConnection() as any;
  if (persisted?.hubUrl && persisted?.userToken) {
    return {
      hubUrl: normalizeHubUrl(String(persisted.hubUrl)),
      userToken: String(persisted.userToken),
      userId: String(persisted.userId),
      username: String(persisted.username ?? ""),
      role: String(persisted.role ?? "member"),
    };
  }

  const hubAddress = overrides?.hubAddress ?? ctx.config.sharing?.client?.hubAddress ?? "";
  const userToken = overrides?.userToken ?? ctx.config.sharing?.client?.userToken ?? "";
  if (!hubAddress || !userToken) {
    throw new Error("hub client connection is not configured");
  }

  const hubUrl = normalizeHubUrl(hubAddress);
  const me = await hubRequestJson(hubUrl, userToken, "/api/v1/hub/me", { method: "GET" }) as any;

  return {
    hubUrl,
    userToken,
    userId: String(me.id),
    username: String(me.username ?? ""),
    role: String(me.role ?? "member"),
  };
}

export async function hubListMemories(
  store: SqliteStore,