colelawrence

/* eslint-disable @typescript-eslint/explicit-member-accessibility */
import * as Y from "yjs";

export interface ZodLikeParser<T> {
  _type: T;
  parse: (value: unknown) => T;
}

// eslint-disable-next-line @typescript-eslint/no-explicit-any
type AnyValueDesign = ZodLikeParser<any> | CollectionDef<any> | RecordDef<any>;

colelawrence

/**
 * Add items with a throttled effect of applying the items.
 * We might use this to collect items and then apply them in batches like for
 * search results and timeline items.
 */
export function collectAndFlush<T>(
  then: (items: T[]) => void,
  // 60 fps
  throttleMs: number = 17,
): {

colelawrence

import { createTRPCProxyClient, httpLink } from "@trpc/client";
import { AnyRouter, initTRPC, MaybePromise, Router } from "@trpc/server";
import { fetchRequestHandler } from "@trpc/server/adapters/fetch";
import type { ParserWithInputOutput, ParserWithoutInput } from "@trpc/server/dist/core/parser";
import type { AnyRouterDef } from "@trpc/server/dist/core/router";
import type { ResponseMetaFn } from "@trpc/server/dist/http/internals/types";
import { getParseFn } from "./getParseFn";

export type TrpcDurableObjectRouter<Router extends AnyRouter> = {
  router: Router,

colelawrence

/**
 * As a proof of concept,
 * JSON'infy the args, and parse them into a new Request Init,
 * Make the fetch request with the new Request Init
 * JSONify the response and use the jsonified response data
 * to recreate the response object and return that
 *
 */
const fetchProxyProofOfConcept: typeof fetch = async (...args) => {

colelawrence

import type { Component, DevJSX, JSXNode, JSXOutput } from "@builder.io/qwik";
import { useSignal, useVisibleTask$ } from "@builder.io/qwik";
const QWIK_DATA_ATTR = "data-qwik-inspector";

interface HackedProps {
  "data-qwik-inspector"?: DevJSX;
  "p:where"?: DevJSX;
}

function createLinkFromDevJSX(dev: DevJSX) {

colelawrence

const warned = new Set<string>();
export function warnOnce(message: string) {
  if (!warned.has(message)) {
    warned.add(message);
    console.warn(message);
  }
}

colelawrence

/** Improve preview of union types in autocomplete. */
export type Prettify<T> = { [K in keyof T]: T[K] } & {};

colelawrence

#!/usr/bin/env node

// Required parameters:
// @raycast.schemaVersion 1
// @raycast.title Obfuscate
// @raycast.mode compact

// Optional parameters:
// @raycast.icon 🤖
// @raycast.argument1 { "type": "text", "placeholder": "Original" }

colelawrence

export interface IDisposable {
  dispose(): void;
}

export class DisposePool implements IDisposable {
  #fns: null | (() => void)[] = [];
  #pool: null | IDisposable[] = [];
  get disposed() {
    return this.#pool === null;
  }

colelawrence

const MINUTE = 1000 * 60;

function asyncCachedFn<Args extends any[], Result>(options: {
  fn: (...args: Args) => Promise<Result>;
  key: (...args: Args) => string;
}) {
  const cache: Map<
    string,
    { computedAt: number; evict: any; result: Promise<Result> }