refactor: Upgrade to obelisk 0.38.0-rc.2

Author: tomasol

dev-deps.txt

@@ -1,15 +1,15 @@
-cargo-binstall 1.18.0
-cargo-edit-upgrade 0.13.9
+cargo-binstall 1.19.1
+cargo-edit-upgrade 0.13.10
 cargo-expand 1.0.121
-cargo generate 0.23.8
-cargo-nextest 0.9.132
-just 1.49.0
-obelisk 0.37.7
+cargo generate 0.23.9
+cargo-nextest 0.9.136
+just 1.51.0
+obelisk 0.38.0-rc.2
 pkg-config 0.29.2
 rustc 1.95.0 (59807616e 2026-04-14)
-wasm-tools 1.246.2
-wasmtime 43.0.1
-node.js v22.22.2
+wasm-tools 1.249.0
+wasmtime 44.0.1
+node.js v22.22.3
 wizer 10.0.0
 tinygo version 0.40.1 linux/amd64 (using go version go1.25.7 and LLVM version 20.1.8)
 wit-bindgen-go-cli 0.7.0

flake.lock

@@ -10,7 +10,7 @@
       };
     };
     obelisk = {
-      url = "github:obeli-sk/obelisk/latest";
+      url = "github:obeli-sk/obelisk/prerelease";
       inputs = {
         nixpkgs.follows = "nixpkgs";
         flake-utils.follows = "flake-utils";

flake.nix

@@ -4,6 +4,9 @@
 // Set the environment variable GITHUB_WEBHOOK_SECRET to the webhook secret,
 // or set GITHUB_WEBHOOK_INSECURE=true to skip verification (development only).
 
+import { starAddedSchedule, starRemovedSchedule } from 'stargazers:workflow-obelisk-schedule/workflow';
+import { listStargazers } from 'stargazers:db/user';
+
 const HTTP_HEADER_SIGNATURE = 'X-Hub-Signature-256';
 const ENV_GITHUB_WEBHOOK_INSECURE = 'GITHUB_WEBHOOK_INSECURE';
 const ENV_GITHUB_WEBHOOK_SECRET = 'GITHUB_WEBHOOK_SECRET';
@@ -123,14 +126,10 @@ async function handlePost(request) {
     let execId;
     if (event.action === 'created') {
         console.info(`Scheduling star_added for ${senderLogin} on ${repoFullName}`);
-        execId = obelisk.executionIdGenerate();
-        obelisk.schedule(execId, 'stargazers:workflow/workflow.star-added',
-            [senderLogin, repoFullName]);
+        execId = starAddedSchedule(null, senderLogin, repoFullName);
     } else if (event.action === 'deleted') {
         console.info(`Scheduling star_removed for ${senderLogin} on ${repoFullName}`);
-        execId = obelisk.executionIdGenerate();
-        obelisk.schedule(execId, 'stargazers:workflow/workflow.star-removed',
-            [senderLogin, repoFullName]);
+        execId = starRemovedSchedule(null, senderLogin, repoFullName);
     } else {
         console.error(`Unknown action: ${event.action}`);
         return new Response(`Unknown action: ${event.action}`, { status: 400 });
@@ -179,6 +178,6 @@ function handleGet(request) {
 
     // list-stargazers: func(last: u8, repo: option<string>, ordering: ordering)
     //                  -> result<list<stargazer>, string>
-    const list = obelisk.call('stargazers:db/user.list-stargazers', [limit, repo, ordering]);
+    const list = listStargazers(limit, repo, ordering);
     return Response.json(list);
 }

webhook/webhook-native/webhook.js

@@ -83,7 +83,7 @@ the user, repo, their relation, and the user should have a generated description
 
 To obtain a list of 5 last updated stargazers, run
 ```sh
-curl -v http://127.0.0.1:9090
+curl -v http://127.0.0.1:9090?repo=obeli-sk/obelisk
 ```
 
 For testing the hash signature see the script in the next section.

webhook/webhook-rs/README.md

@@ -2,14 +2,16 @@
 // Pages through all stargazers and submits star-added-parallel for each login
 // concurrently within each page.
 
+import { listStargazers } from 'stargazers:github/account';
+import { starAddedParallelSubmit } from 'stargazers:workflow-obelisk-ext/workflow';
+
 export default function backfill_parallel(repo) {
     console.log(`Starting parallel backfill for ${repo}...`);
     const pageSize = 5;
     let cursor = null;
 
     while (true) {
-        const resp = obelisk.call(
-            'stargazers:github/account.list-stargazers', [repo, pageSize, cursor]);
+        const resp = listStargazers(repo, pageSize, cursor);
 
         if (!resp) {
             console.log('No more stargazers found.');
@@ -24,7 +26,7 @@ export default function backfill_parallel(repo) {
         for (const login of resp.logins) {
             console.log(`Submitting task for ${login}...`);
             const js = obelisk.createJoinSet({ name: login });
-            js.submit('stargazers:workflow/workflow.star-added-parallel', [login, repo]);
+            starAddedParallelSubmit(js, login, repo);
             joinSets.push(js);
         }
 

workflow/stargazers/workflow-native/backfill-parallel.js

@@ -1,6 +1,9 @@
 // Native JS implementation of stargazers:workflow/workflow.backfill
 // Pages through all stargazers of a repo and calls star-added for each.
 
+import { listStargazers } from 'stargazers:github/account';
+import { starAdded } from 'stargazers:workflow/workflow';
+
 export default function backfill(repo) {
     console.log(`Starting backfill for ${repo}...`);
     const pageSize = 5;
@@ -10,8 +13,7 @@ export default function backfill(repo) {
         // list-stargazers: func(repo: string, page-size: u8, cursor: option<string>)
         //                  -> result<option<stargazers>, string>
         // Returns null (option None) when there are no more pages.
-        const resp = obelisk.call(
-            'stargazers:github/account.list-stargazers', [repo, pageSize, cursor]);
+        const resp = listStargazers(repo, pageSize, cursor);
 
         if (!resp) {
             console.log('No more stargazers found.');
@@ -23,8 +25,7 @@ export default function backfill(repo) {
 
         for (const login of resp.logins) {
             console.log(`Processing ${login}...`);
-            // star-added: func(login: string, repo: string) -> result<_, string>
-            obelisk.call('stargazers:workflow/workflow.star-added', [login, repo]);
+            starAdded(login, repo);
         }
 
         if (!gotWholePage) {

workflow/stargazers/workflow-native/backfill.js

@@ -1,9 +1,13 @@
 // Native JS implementation of stargazers:workflow/workflow.star-added-parallel
 // Fetches account info and LLM settings concurrently using join sets.
 
+import { accountInfoSubmit, accountInfoAwaitNext } from 'stargazers:github-obelisk-ext/account';
+import { getSettingsJsonSubmit, getSettingsJsonAwaitNext } from 'stargazers:db-obelisk-ext/llm';
+import { addStarGetDescription, updateUserDescription } from 'stargazers:db/user';
+import { respond as llmRespond } from 'stargazers:llm/llm';
+
 export default function star_added_parallel(login, repo) {
-    const existingDescription = obelisk.call(
-        'stargazers:db/user.add-star-get-description', [login, repo]);
+    const existingDescription = addStarGetDescription(login, repo);
 
     if (existingDescription !== null && existingDescription !== undefined) {
         console.log(`Description already exists for ${login} on ${repo}.`);
@@ -14,27 +18,22 @@ export default function star_added_parallel(login, repo) {
 
     // Submit account-info and get-settings-json concurrently.
     const jsInfo = obelisk.createJoinSet({ name: `info_${login}` });
-    const infoExecId = jsInfo.submit('stargazers:github/account.account-info', [login]);
+    accountInfoSubmit(jsInfo, login);
 
     const jsSettings = obelisk.createJoinSet({ name: `settings_${login}` });
-    const settingsExecId = jsSettings.submit('stargazers:db/llm.get-settings-json', []);
+    getSettingsJsonSubmit(jsSettings);
 
     // Await account info.
-    jsInfo.joinNext();
-    const infoResult = obelisk.getResult(infoExecId);
-    if (infoResult.err !== undefined) throw infoResult.err;
+    const infoResult = accountInfoAwaitNext(jsInfo);
 
     // Await settings.
-    jsSettings.joinNext();
-    const settingsResult = obelisk.getResult(settingsExecId);
-    if (settingsResult.err !== undefined) throw settingsResult.err;
+    const settingsResult = getSettingsJsonAwaitNext(jsSettings);
 
     console.log(`Got info and settings for ${login}, generating description...`);
 
     // Generate and persist the description sequentially.
-    const description = obelisk.call('stargazers:llm/llm.respond',
-        [infoResult.ok, settingsResult.ok]);
-    obelisk.call('stargazers:db/user.update-user-description', [login, description]);
+    const description = llmRespond(infoResult, settingsResult);
+    updateUserDescription(login, description);
 
     console.log(`Generated and saved description in parallel for ${login}`);
 }

workflow/stargazers/workflow-native/star-added-parallel.js

@@ -1,11 +1,14 @@
 // Native JS implementation of stargazers:workflow/workflow.star-added
 
+import { accountInfo } from 'stargazers:github/account';
+import { getSettingsJson } from 'stargazers:db/llm';
+import { addStarGetDescription, updateUserDescription } from 'stargazers:db/user';
+import { respond as llmRespond } from 'stargazers:llm/llm';
+
 export default function star_added(login, repo) {
     // 1. Persist the star and check whether a description already exists.
     // add-star-get-description: func(login: string, repo: string) -> result<option<string>, string>
-    // obelisk.call unwraps the result: returns the ok value or throws the err string.
-    const existingDescription = obelisk.call(
-        'stargazers:db/user.add-star-get-description', [login, repo]);
+    const existingDescription = addStarGetDescription(login, repo);
 
     if (existingDescription !== null && existingDescription !== undefined) {
         console.log(`Description already exists for ${login} on ${repo}.`);
@@ -15,16 +18,16 @@ export default function star_added(login, repo) {
     console.log(`No description for ${login} on ${repo}, generating...`);
 
     // 2. Fetch the account info from GitHub.
-    const info = obelisk.call('stargazers:github/account.account-info', [login]);
+    const info = accountInfo(login);
 
     // 3. Fetch the LLM prompt settings from the database.
-    const settingsJson = obelisk.call('stargazers:db/llm.get-settings-json', []);
+    const settingsJson = getSettingsJson();
 
     // 4. Generate the user's description using the LLM.
-    const description = obelisk.call('stargazers:llm/llm.respond', [info, settingsJson]);
+    const description = llmRespond(info, settingsJson);
 
     // 5. Persist the generated description.
-    obelisk.call('stargazers:db/user.update-user-description', [login, description]);
+    updateUserDescription(login, description);
 
     console.log(`Generated and saved description for ${login}`);
 }

workflow/stargazers/workflow-native/star-added.js

@@ -1,7 +1,9 @@
 // Native JS implementation of stargazers:workflow/workflow.star-removed
 
+import { removeStar } from 'stargazers:db/user';
+
 export default function star_removed(login, repo) {
     // remove-star: func(login: string, repo: string) -> result<_, string>
-    obelisk.call('stargazers:db/user.remove-star', [login, repo]);
+    removeStar(login, repo);
     console.log(`Removed star for ${login} on ${repo}.`);
 }