Goblinlordx

import { parse } from "csv-parse/sync"
import Dbc from "dbc-can"
import { Message } from "dbc-can/lib/dbc/Dbc"
import fs from "fs"

const INDEPENDENT_SIGNALS = parseInt("c0000000", 16)
const EXTENDED_FLAG = parseInt('80000000', 16)
const MAX_ID = parseInt('7FF', 16)
const MAX_EXTENDED_ID = parseInt('1fffffff', 16)
const parseId = (s: string) => {

Goblinlordx

package trackrelay

import (
	"context"

	"github.com/pion/rtcp"
	"github.com/pion/rtp"
	"github.com/pion/webrtc/v4"
)

Goblinlordx

function* range(max: number = Infinity, start: number = 0) {
  for (let i = start; i < max; i++) yield i;
}

async function* asyncify<T>(items: Iterable<T>) {
  for (const item of items) yield item;
}

class AlreadyProcessedError extends Error {}

Goblinlordx

export class RateLimiter {
  private maxCalls: number
  private interval: number
  private tokens: number
  private lastRefill: number
  private callQueue: Array<() => void>

  constructor(callsPerSecond: number, initialTokens: number = 0) {
    this.maxCalls = callsPerSecond
    this.interval = 1000 / this.maxCalls

Goblinlordx

export function chunk(arr, size) {
    const output = [];
    for (let i = 0; i < arr.length; i += size) {
        output.push(arr.slice(i, i + size));
    }
    return output;
}

Goblinlordx

version: "3.3"

services:
  traefik:
    image: traefik:v2.5
    container_name: traefik
    restart: unless-stopped
    ports:
      - "80:80"     # The HTTP port
      - "443:443"   # The HTTPS port

Goblinlordx

export const min = (a: number, b: number) => a < b
export const max = (a: number, b: number) => a > b

type Comparetor<T> = (a: T, b: T) => boolean

export class Heap<T = number> {
  private heap: T[] = []
  constructor(private comp: Comparetor<T>) {}

  private parent(i: number) {

Goblinlordx

Basic task initiation and monitoring

1. Client calls BE and initiates a Task. BE responds with a task ID or an error. The task ID can optionally be used by client.
2. Client can establish a channel to receive task updates and maintain a local cache of the current task states. When client initializes, it can retrieve a list of active tasks on the backend for the given user.

A more detailed flow showing the Client, BE, DB, and ExternalServices [![](https://mermaid.ink/img/pako:

Goblinlordx

package main

import (
	"flag"
	"fmt"
	"io/fs"
	"log"
	"os"
	"path/filepath"
)

Goblinlordx

// Standalone queue
const AsyncQueue = () => {
  let p = Promise.resolve();
  return (...args) => {
      p = p.then(createTask(...args));
      return p;
  };
}

// With existing queue data (q is existing data)