Val Town Code SearchReturn to Val Town

3import { newRSSItems } from "https://esm.town/v/stevekrouse/newRSSItems";
4
5export async function pollRSSFeeds({ lastRunAt }: Interval) {
6  return Promise.all(
7    Object.entries(rssFeeds).map(async ([name, url]) => {

2import { renderToString } from "npm:react-dom/server";
3
4export default async function(req: Request) {
5  return new Response(
6    renderToString(

22const MAX_ROWS_PER_CHUNK = 10000;
23
24export default async function(req: Request): Promise<Response> {
25  console.log("Received request");
26  let requestBody: QueryRequest;
99}
100
101async function executePostgresQuery(url: string, query: string): Promise<any[]> {
102  console.log("Connecting to PostgreSQL");
103  const client = new pg.Client({
136}
137
138async function executeMysqlQuery(url: string, query: string): Promise<any[]> {
139  console.log("Connecting to MySQL");
140  const connection = await mysql.createConnection(url);
163}
164
165async function introspectPostgresSchema(url: string): Promise<any[]> {
166  const query = `
167    SELECT 
181}
182
183async function introspectMysqlSchema(url: string): Promise<any[]> {
184  const query = `
185    SELECT 
199}
200
201function splitIntoChunks(results: any[], maxRowsPerChunk: number): any[][] {
202  console.log(`Splitting ${results.length} rows into chunks of ${maxRowsPerChunk}`);
203  const chunks = [];
209}
210
211async function createGzipFile(chunk: any[], index: number, shouldGzip: boolean, introspection: boolean): Promise<any> {
212  console.log(`Creating ${shouldGzip ? "gzip" : ""} file for chunk ${index + 1}`);
213  const csv = parse(chunk);

37// });
38
39function parseResultSet<T>(row: ResultSet): T[] {
40  return row.rows.map((r) => Object.fromEntries(r.map((c, i) => [row.columns[i], c]))) as T[];
41}
51};
52
53function diffCircles(array1: Circle[], array2: Circle[]): Circle[] {
54  const changes: Circle[] = [];
55
74
75  const drag = (() => {
76    function dragstarted() {
77      d3.select(this).attr("stroke", "black");
78    }
79
80    function dragged(event, d) {
81      d3.select(this).raise().attr("cx", d.x = event.x).attr("cy", d.y = event.y);
82    }
83
84    function dragended() {
85      const x = d3.select(this).attr("cx");
86      const y = d3.select(this).attr("cy");
105    .call(drag)
106    .on("click", clicked);
107  function clicked(event, d) {
108    if (event.defaultPrevented) return; // dragged
109

11`);
12
13export function publicKey(data: Uint8Array, offset: number) {
14  return base58.encode(data.subarray(offset, offset + 32));
15}
16
17export function u64(view: DataView, offset: number) {
18  return view.getBigUint64(offset, true);
19}
20
21export function parseSwapEvent(data: Uint8Array) {
22  const view = new DataView(data.buffer, data.byteOffset, data.byteLength);
23  return {
32console.log(parseSwapEvent(input));
33
34function bytes(str: string): Uint8Array {
35  return base16.decode(str.replaceAll(/\s/g, "").toUpperCase());
36}

1import { email } from "https://esm.town/v/std/email?v=11";
2
3export function forwarder(e: {
4  from: string;
5  to: string[];

2import { renderToString } from "npm:react-dom/server";
3
4export default async function(req: Request) {
5  const description = "social meta test";
6  const title = "JGB Test";

57### Utilities
58
59Our Blob SDK also includes some utility functions to make working with blobs easier.
60
61##### Copy

4
5/**
6 * Provides functions for interacting with your account's blob storage.
7 * Blobs can store any data type (text, JSON, images, etc.) and allow
8 * retrieval across different vals using the same key.
80};
81
82async function list(prefix?: string): Promise<{ key: string; size: number; lastModified: string }[]> {
83  let querystring = prefix ? `?prefix=${encodeURIComponent(prefix)}` : "";
84  const res = await fetch(`${API_URL}/v1/blob${querystring}`, {
94}
95
96async function delete_(key: string) {
97  const res = await fetch(`${API_URL}/v1/blob/${encodeURIComponent(key)}`, {
98    method: "DELETE",
107}
108
109async function get(key: string) {
110  const res = await fetch(`${API_URL}/v1/blob/${encodeURIComponent(key)}`, {
111    headers: {
123}
124
125async function set(key: string, value: BodyInit) {
126  const res = await fetch(`${API_URL}/v1/blob/${encodeURIComponent(key)}`, {
127    method: "POST",
137}
138
139async function copy(previous: string, next: string) {
140  const res = await get(previous);
141  await set(next, res.body);
142}
143
144async function move(previous: string, next: string) {
145  await copy(previous, next);
146  await delete_(previous);
147}
148
149async function getJSON(key: string) {
150  try {
151    const res = await get(key);
159}
160
161async function setJSON(key: string, value: any) {
162  return set(key, JSON.stringify(value));
163}

6});
7
8export default async function(req: Request): Promise<Response> {
9  const { shortLink } = await dub.links.upsert({
10    url: "https://www.val.town/v/steventey/dubLinksUpsert",