Val Town Code SearchReturn to Val Town

4import { createRoot } from "https://esm.sh/react-dom/client";
5
6function createTypewriterMachine() {
7  const messages = ["The bsky has you...", "Follow the blue butterfly", "made with val.town"];
8
89}
90
91function MatrixBlueskyStream() {
92  const [posts, setPosts] = useState([]);
93  const canvasRef = useRef(null);
102  const [machineState, setMachineState] = useState(typewriterMachine.current.initialState);
103
104  // Wrapper function to update state
105  const updateMachineState = useCallback((event) => {
106    const newState = typewriterMachine.current.transition(machineState, event);
135    const agent = new BskyAgent({ service: "https://bsky.social" });
136
137    async function streamPosts() {
138      try {
139        await agent.login({
208    }));
209
210    function draw() {
211      try {
212        ctx.fillStyle = "rgba(0, 0, 0, 0.05)";
248    const animationFrame = setInterval(draw, 33);
249
250    // Cleanup function
251    return () => {
252      clearInterval(animationFrame);
355}
356
357function App() {
358  return <MatrixBlueskyStream />;
359}
360
361function client() {
362  createRoot(document.getElementById("root")).render(<App />);
363}
365if (typeof document !== "undefined") { client(); }
366
367export default async function server(request: Request): Promise<Response> {
368  return new Response(
369    `

2
3// Fetches a random joke.
4async function fetchRandomJoke() {
5  const response = await fetch(
6    "https://official-joke-api.appspot.com/random_joke",

1export default async function (req: Request): Promise<Response> {
2  return Response.json({ ok: true })
3}

5const schemaVersion = 3;
6
7function _client() {
8  return createClient({
9    url: Deno.env.get("WIDE_CLICKHOUSE_URL"),
13}
14
15export async function runMigrations() {
16  for (
17    const migration of [
53  }
54}
55export function parseRows(rows: any[]) {
56  const processedRows = rows.map(row => {
57    const paths: {
65    };
66
67    function processObject(obj: any, currentPath = "") {
68      for (const [key, value] of Object.entries(obj)) {
69        const newPath = currentPath ? `${currentPath}.${key}` : key;
166 * write!
167 */
168export async function write(userId: string, data: any[]) {
169  return await writeRowsToClickhouse(userId, parseRows(data));
170}
182 * values!
183 */
184export async function values(
185  userId: string,
186  { field_name, field_type }: { field_name: string; field_type: FieldType },
218 * fields!
219 */
220export async function fields(userId: string, search: string = "") {
221  return (await (await _client().query({
222    query: `
296 * Get the ClickHouse comparison expression for the given operator
297 */
298function getComparisonExpression(
299  operator: TStringOperator | TNumberOperator | TBooleanOperator,
300  valueRef: string,
325
326/**
327 * Enhanced search function supporting multiple conditions with different operators
328 */
329export async function search(userId: string, {
330  filters,
331  start,
412
413
414function formatDate(date: Date) {
415  return String(getUnixTime(date) + (date.getMilliseconds() / 1000))
416}
425}
426
427function reconstructObjects(
428  results: LogRow[],
429) {

2
3// Fetches a random joke.
4async function fetchRandomJoke() {
5  const response = await fetch(
6    "https://official-joke-api.appspot.com/random_joke",

5};
6
7export default async function(req: Request): Promise<Response> {
8  const url =
9    "https://public.api.bsky.app/xrpc/app.bsky.feed.getAuthorFeed?actor=stevekrouse.com&filter=posts_no_replies";

5
6// Fetches a random joke.
7function fetchRandomJoke() {
8  const SAMPLE_JOKE = {
9    "setup": "What do you call a group of disorganized cats?",

20`;
21
22async function newSession(valTownToken: string) {
23  const privateKeyPem = `
24-----BEGIN PRIVATE KEY-----
38}
39
40function validate(token: string) {
41  const decoded = jwt.verify(token, publicKeyPem, { algorithms: ["RS256"] }) as
42    & Awaited<

1import { sqlite } from "https://esm.town/v/std/sqlite?v=4";
2
3export async function getSubscribers() {
4  const subs = await sqlite.execute(`
5    SELECT *
11await getSubscribers();
12
13export async function getNewsletters() {
14  const newsletters = await sqlite.execute(`
15    SELECT id, subject, web_url, target_send_date 
20}
21
22export async function getEmailLogs() {
23  const logs = await sqlite.execute(`
24    SELECT id, newsletter_id, subscriber_id, sent_at

5};
6
7export default async function(req: Request): Promise<Response> {
8  const url = "https://public.api.bsky.app/xrpc/app.bsky.feed.getAuthorFeed?actor=wilb.me&filter=posts_no_replies";
9