-
+
+
Siguiente
{next?.title || "-"}
-
-
+
+
+
+
\ No newline at end of file
diff --git a/src/layouts/Layout.astro b/src/layouts/Layout.astro
index d0d2c3a..54a6344 100644
--- a/src/layouts/Layout.astro
+++ b/src/layouts/Layout.astro
@@ -18,120 +18,6 @@ const {
-
void) | null = null
+ private onOutputCallback: ((stderr: string, stdout: string) => void) | null = null
+ private onCompleteCallback: ((success: boolean) => void) | null = null
+ private scheduled = false
constructor() {
this.ws = new WebSocket(WS_URL)
@@ -46,22 +48,34 @@ class RustPlaygroundClient {
const data = JSON.parse(event.data)
const messageSeq = data.meta?.sequenceNumber
- if (messageSeq !== undefined && messageSeq < this.latestSequenceNumber) {
- // Ignorar mensajes de ejecuciones antiguas
- return
- }
+ if (messageSeq !== this.latestSequenceNumber) return
if (data.type === "output/execute/wsExecuteStderr") {
this.stderr += data.payload
- this.onOutputCallback?.(this.stderr, this.stdout, false)
+ this.scheduleUpdate()
} else if (data.type === "output/execute/wsExecuteStdout") {
this.stdout += data.payload
- this.onOutputCallback?.(this.stderr, this.stdout, false)
+ this.scheduleUpdate()
} else if (data.type === "output/execute/wsExecuteEnd") {
- this.onOutputCallback?.(this.stderr, this.stdout, true)
+ this.flushUpdate()
+ this.onCompleteCallback?.(data.payload?.success ?? false)
}
}
+ private scheduleUpdate(): void {
+ if (this.scheduled) return
+ this.scheduled = true
+
+ requestAnimationFrame(() => {
+ this.flushUpdate()
+ })
+ }
+
+ private flushUpdate(): void {
+ this.scheduled = false
+ this.onOutputCallback?.(this.stderr, this.stdout)
+ }
+
private reconnect(): void {
if (this.ws.readyState === WebSocket.CLOSED) {
setTimeout(() => {
@@ -76,12 +90,14 @@ class RustPlaygroundClient {
execute(
code: string,
- onOutput: (stderr: string, stdout: string, done: boolean) => void,
+ onOutput: (stderr: string, stdout: string) => void,
+ onComplete: (success: boolean) => void,
config: Partial = {},
): void {
this.stderr = ""
this.stdout = ""
this.onOutputCallback = onOutput
+ this.onCompleteCallback = onComplete
this.latestSequenceNumber = this.sequenceNumber++
diff --git a/src/lib/stores/editor-store.ts b/src/lib/stores/editor-store.ts
index d819a5b..9e241f1 100644
--- a/src/lib/stores/editor-store.ts
+++ b/src/lib/stores/editor-store.ts
@@ -44,7 +44,20 @@ class RustlingsDB {
private async set(store: string, key: string, value: unknown): Promise {
const db = await this.initDB()
- db.transaction(store, "readwrite").objectStore(store).put(value, key)
+ return new Promise((resolve, reject) => {
+ const request = db.transaction(store, "readwrite").objectStore(store).put(value, key)
+ request.onsuccess = () => resolve()
+ request.onerror = () => reject(request.error)
+ })
+ }
+
+ private async delete(store: string, key: string): Promise {
+ const db = await this.initDB()
+ return new Promise((resolve, reject) => {
+ const request = db.transaction(store, "readwrite").objectStore(store).delete(key)
+ request.onsuccess = () => resolve()
+ request.onerror = () => reject(request.error)
+ })
}
async saveCode(slug: string, val: string) {
@@ -55,6 +68,10 @@ class RustlingsDB {
return this.get(this.STORE_CODE, slug)
}
+ async reset(slug: string) {
+ await Promise.all([this.delete(this.STORE_CODE, slug), this.delete(this.STORE_PROGRESS, slug)])
+ }
+
async markCompleted(slug: string) {
await this.set(this.STORE_PROGRESS, slug, true)
}
diff --git a/src/pages/[slug].astro b/src/pages/[slug].astro
index d623410..0d8b739 100644
--- a/src/pages/[slug].astro
+++ b/src/pages/[slug].astro
@@ -55,11 +55,11 @@ const { lesson, previousLesson, nextLesson } = Astro.props
>
-
-
+
+