qwtel

// import { TransformStream } from 'node:stream/web';
import { Buffer } from 'node:buffer';
import { Packr, Unpackr, Options } from 'msgpackr';

export class PackrTransformStream extends TransformStream<any, Uint8Array> {
  constructor(options: Options & { packr?: Packr } = {}) {
    options = { ...options, sequential: true };
    const packr = options.packr || new Packr(options);

    super({

qwtel

export async function* streamToAsyncIterable<T>(stream: ReadableStream<T>): AsyncIterableIterator<T> {
  const reader = stream.getReader();
  try {
    while (true) {
      const { done, value } = await reader.read();
      if (done) return;
      yield value;
    }
  } finally { reader.releaseLock() }
}

qwtel

import { Base64Encoder, Base64Decoder } from 'base64-encoding';

const PREFIX = 'data:application/octet-stream;base64,';

const b64e = new Base64Encoder();
const b64d = new Base64Decoder();

const encodeKey = (key: string | BufferSource) => typeof key !== 'string' ? PREFIX + b64e.encode(key) : key;
const decodeKey = (key: string) => key.startsWith(PREFIX) ? b64d.decode(key.substr(PREFIX.length)) : key;

qwtel

type Resolver<T> = (value: T | PromiseLike<T>) => void;
type Rejector = (reason?: any) => void;
type ResolvablePromise<T> = Promise<T> & { resolve: Resolver<T>, reject: Rejector }
export function createResolvablePromise<T>(): ResolvablePromise<T> {
  let res: Resolver<T>
  let rej: Rejector;
  const promise = new Promise((r, s) => (res = r, rej = s)) as ResolvablePromise<T>;
  promise.resolve = res;
  promise.reject = rej;
  return promise;

qwtel

const nearestAsteroidsByAngle = pipe(
  asteroids.filter(mkNe(laserPos)),
  groupBy(mkCalcAngle(laserPos)),
  mapValues(ps => ps.sort((p1, p2) => distToLaser(p1) - distToLaser(p2))),
  intoMap(),
);

pipe(
  cycle([...nearestAsteroidsByAngle.keys()].sort((a, b) => a - b)),
  skipWhile(a => a < -Math.PI/2),

qwtel

export class ParamsURL extends URL {
  constructor(href, params, origin = globalThis.location) {
    super(href, origin);
    if (params) {
      this.search = new URLSearchParams([...this.searchParams, ...Object.entries(params)]);
    }
  }
}

qwtel

export const urlWithParams = (url, params) => {
  const u = new URL(url, global.location.origin)
  if (params) {
    u.search = new URLSearchParams([...u.searchParams, ...Object.entries(params)])
  }
  return u.href
}

qwtel

Main difference to regular Response and Request types is that no manual JSON.stringify and headers.set('Content-Type', ...) is required.

In my opinion, JSONRequest is the most lightweight way of fixing the biggest issue of the Fetch API when dealing with JSON APIs, without resorting to full alternatives such as superagent or axios.

Example:

const response = await fetch(new JSONRequest('/comments', {
  method: 'POST',
 body: { text: 'Usage example: ...' },

qwtel

const NEVER = new Promise(() => {});

async function raceTruthy(iterable) {
  const ps = [...iterable].map(_ => Promise.resolve(_));
  let { length } = ps;
  const continueWhenNullish = value => value != null
    ? value
    : --length > 0
      ? NEVER
      : undefined;

qwtel

import md5 from "js-md5";

import { base64ToUint8Array, splitUint8Array, concatUint8Arrays } from "./utils";

const HEAD_SIZE_DWORD = 2;
const SALT_SIZE_DWORD = 2;

export async function decryptCryptoJSCipherBase64(
  cryptoJSCipherBase64,
  password,