survivor-trackerqueries.ts1 match
2import { crypto } from "https://deno.land/std/crypto/mod.ts";
34// Types for database models
5export interface PersonalStatus {
6id?: number;
survivor-trackerseeder.ts7 matches
1/**
2* Database seeder - populates the database with initial data
3*/
45import { crypto } from "https://deno.land/std/crypto/mod.ts";
6import { parseSurvivalPlan, getCurrentDay, getCurrentWeek, formatDate } from "../../shared/utils.ts";
7import { initializeDatabase } from "./migrations.ts";
8import {
9saveTask,
13} from "./queries.ts";
1415// Main seeder function - initializes the database and populates it with tasks
16export const seedDatabase = async (importMetaUrl: string): Promise<void> => {
17// Initialize the database schema
18await initializeDatabase();
19
20// Seed track statuses
30await seedDailyNonNegotiables(dailyNonNegotiables);
31
32console.log("Database seeded successfully!");
33};
34
survivor-trackerprocessor.ts1 match
45import { parseTrackPrompts } from "../../shared/utils.ts";
6import { PersonalStatus, DailyLog, Task, TrackStatus } from "../database/queries.ts";
78// Interface for OpenAI response
vt-blogget-old-posts.ts1 match
46"slug": "codegen",
47"link": "/blog/codegen",
48"description": "Like Claude Artifacts, but with a backend and database",
49"pubDate": "Thu, 22 Aug 2024 00:00:00 GMT",
50"author": "JP Posma",
1---
2title: "Post-mortem: A Backward Incompatible Database Migration"
3description: Val runs failed due to a database migration that was not backward compatible
4pubDate: 2025-04-02T00:00:00.000Z
5author: Sophie Houser
6---
78Today at 10:11am we experienced a 12-minute outage, which caused HTTP vals to return 503 errors and other types of vals to fail. In the end, the root cause was a deployment timing issue where database migrations were deployed successfully, but our application code deployment hung for several minutes. The new database migrations were incompatible with the old application code and crashed the process.
910We aim to make all database migrations maintain backward compatibility, but in this case, we only discovered through the delayed deployment feedback that the new migrations were not compatible with previous versions.
1112## Timeline
27## Next Steps
2829Reliability is important to us and weβve taken steps to make sure this doesnβt happen again. Weβve added a test to ensure database migrations are backward compatible, which weβll run before we deploy any new code that includes database migrations.
ValTownForNotionexample-database-page.ts31 matches
20const data = payload?.data;
21const pageId = data?.id;
22const databaseId = data?.parent?.database_id;
2324// this endpoint is for a specific database page and is triggered by a button in that database page
2526// the button that calls this endpoint sends a payload with the id of the database page, and the id of the parent database
27// (e.g., pageId and databaseId from the payload)
2829// different than other endpoints, this one does not get called by a reset button or the cron reset
30// instead, the reset button and the reset cron target the database, not the page
31// so, we don't have a reset call coming in with the x-blob-key custom header to this enpoint
32// nor do we have a x-container-title header that holds the title of the target object coming from the button payload
3334// both the reset button and the reset cron delete all database pages, and then add back fresh pages
35// the endpoint for that is /example-database-pages (note the "s" at the end)
3637// different than other endpoints, we get the id of the block to modify (ie, the database page) from the button payload
38// so, we don't need to do the things we do at other endpoints to get the id of target block
39// (e.g., search the blob cache, or traverse notion page objects)
4041// but, we do need to set the blob for the resets
42// and for that we'll need the id of the page in which this database lives
43// and an identifier for the database
4445// can that idenfifier be the databaseId rather than the database title?
46// the reset button sends the database title to the .../pages endpoint in order to find the id of the database
47// but the matching there will traverse the notion page database objects looking for a title match
48// which has nothing to do with the database title in the blob
4950// note: if you're wondering why none of the notion buttons have hard-coded ids for the targeting
53// as is, i can clone a page with examples for a guest and everything will work without anyone needing to edit button settings
5455// when a user adds a favicon to a database page, we need to capture in the blob cache that a page in this database has been updated
56// so that resets know which database to reset
57// but the payload of the favicon button in this page does _not_ send the id of the page in which the database lives
58// nor does it send the database title
59// so we'll need to get those to make the blob key
6067for (const item of items) {
68const blobData = await blob.getJSON(item.key);
69if (blobData?.id === databaseId) {
70// console.log(item.key, blobData);
71blobData.key = item.key;
8283// blob for cache
84// get the parent page id of this child_database
85// this is the user's page and we need it for the blob key
86const parentPageId = blobject?.user
87? blobject?.user?.page_id
88: await notionHelpers.getDatabaseParentPageId(databaseId);
8990// we also need the database title
91// even though we have the database id and it's tempting to use it here
92// we need the title in the blob key so that the reset button can work
93// b/c the reset button can only send the title in the x-container-title header
94// with no other way to tie the button to the database
9596// const databaseTitle = blobject?.key
97// ? (blobject?.key).split("--").pop()
98// : await notionHelpers.getDatabaseTitle(databaseId);
99const databaseTitle = await notionHelpers.getDatabaseTitle(databaseId);
100101console.log("databaseTitle:", databaseTitle);
102103// store webhook data in blob storage for resets
105"slug": slug,
106"clientPageId": parentPageId,
107// "containerId": databaseId, // slugify databaseTitle here?
108"containerId": await helpers.slugify(databaseTitle),
109});
110await blob.setJSON(blobKey, {
113page_id: parentPageId,
114},
115id: databaseId,
116date: new Date(),
117content: askingFor,
16const slug = await c.req.url.replace("https://", "");
17const askingFor = c.req.headers.get("x-asking-for") || "default"; // val.town or default
18const containerTitle = c.req.headers.get("x-container-title") || "good web sites"; // should map to the database title
19const payload = await c.req.json();
20const pageId = payload?.data?.id;
3839// when the reset button is clicked, it sends the x-container-title header
40// we use this header to a) find a blob or b) if no blob, find a database with a title that matches it
41// a) find a blob
42// b) find a database with a title that matches it
4344// blob
64// console.log("blockId:", blockId);
6566const databaseId = blobject?.id || (await notionHelpers.findChildDatabaseBlocks(pageId, containerTitle))[0].id;
67// console.log("databaseId:", databaseId);
6869// actions
70await notionHelpers.deleteAllDatabasePagesParallel(databaseId);
71// add back pages; fresh start for the next person to add favicons
72// create new database pages from default object
73await notionHelpers.createDatabasePagesParallel(databaseId, defaults);
74// store webhook data in blob storage for resets
75await blob.setJSON(blobKey, {
78page_id: pageId,
79},
80id: databaseId,
81date: new Date(),
82content: askingFor,
ValTownForNotionnotionHelpers.ts23 matches
7});
89export async function createDatabasePagesParallel(databaseId: string, pages: []) {
10const creations = pages.map((page) =>
11notion.pages.create({
12parent: { database_id: databaseId },
13properties: {
14"Website": {
42}
4344// delete all database rows
45export async function deleteAllDatabasePagesParallel(databaseId: string) {
46const pageIds = await notion.databases.query({
47database_id: databaseId,
48});
49// Step 2: Delete all pages in parallel
59}
6061export async function getDatabaseId(databaseTitle: string) {
62// getDatabaseId(databaseTitle)
63const database = await notion.databases
64.query({ filter: { property: "title", title: { equals: databaseTitle } } });
65return database.results[0].id;
66}
6768export async function getDatabaseTitle(databaseId: string) {
69// getDatabaseTitle(databaseId)
70const database = await notion.databases.retrieve({ database_id: databaseId });
71// console.log(database.title[0].plain_text);
72return database.title[0].plain_text;
73}
7475export async function getDatabaseParentPageId(databaseId: string) {
76let currentBlockId = databaseId;
7778while (true) {
121}
122123export async function findChildDatabaseBlocks(rootBlockId: string, blockIdentifier: string) {
124const matchingBlocks = [];
125140// }
141if (
142block.type === "child_database" && block.child_database?.title && (!block.archived || !block.in_trash)
143) {
144const databaseTitle = await helpers.slugify(block.child_database?.title.toLowerCase()) || "";
145const identifier = await helpers.slugify(blockIdentifier?.toLowerCase());
146147if (databaseTitle === identifier) {
148console.log(databaseTitle, identifier);
149matchingBlocks.push(block);
150}
OpenTowniethink.ts1 match
7export const thinkTool = tool({
8description:
9"Use the tool to think about something. It will not obtain new information or change the database, but just append the thought to the log. Use it when complex reasoning or some cache memory is needed.",
10parameters: z.object({
11thought: z.string().describe("A thought to think about."),
OpenTowniesystem_prompt.txt2 matches
192```
193βββ backend/
194β βββ database/
195β β βββ migrations.ts # Schema definitions
196β β βββ queries.ts # DB query functions
251```
252253### Database Patterns
254- Run migrations on startup or comment out for performance
255- Change table names when modifying schemas rather than altering