WIP

Author: jobelenus

bin/si/deno.lock

@@ -40,6 +40,7 @@ import { type ComponentGetOptions } from "./component/get.ts";
 import { type ComponentUpdateOptions } from "./component/update.ts";
 import { type ComponentDeleteOptions } from "./component/delete.ts";
 import { type ComponentSearchOptions } from "./component/search.ts";
+import { callTui } from "./command/tui.ts";
 
 /** Current version of the SI CLI */
 const VERSION = "0.1.0";
@@ -175,7 +176,9 @@ function buildCommand() {
     // deno-lint-ignore no-explicit-any
     .command("template", buildTemplateCommand() as any)
     // deno-lint-ignore no-explicit-any
-    .command("whoami", buildWhoamiCommand() as any);
+    .command("whoami", buildWhoamiCommand() as any)
+    // deno-lint-ignore no-explicit-any
+    .command("tui", buildTuiCommand() as any);
 }
 
 /**
@@ -267,7 +270,7 @@ function buildRemoteSchemaCommand() {
           "--builtins",
           "Include builtin schemas (schemas you don't own). By default, builtins are skipped.",
         )
-        .action(async ({ root, apiBaseUrl, apiToken, builtins }, ...schemaNames) => {
+        .action(async ({ root, apiBaseUrl, apiToken }, ...schemaNames) => {
           const project = createProject(root);
           const apiCtx = await createApiContext(apiBaseUrl, apiToken);
           let finalSchemaNames;
@@ -282,7 +285,6 @@ function buildRemoteSchemaCommand() {
             project,
             apiCtx,
             finalSchemaNames,
-            builtins ?? false,
           );
         }),
     )
@@ -355,6 +357,22 @@ function buildWhoamiCommand() {
     });
 }
 
+/**
+ * Builds the tui command.
+ *
+ * @returns A SubCommand to start the TUI
+ * @internal
+ */
+function buildTuiCommand() {
+  return createSubCommand()
+    .description("Starts the TUI")
+    .action(async ({ apiBaseUrl, apiToken }) => {
+      const apiCtx = await createApiContext(apiBaseUrl, apiToken);
+
+      await callTui(Context.instance(), apiCtx);
+    });
+}
+
 /**
  * Builds the project init subcommands.
  *

bin/si/src/cli.ts

@@ -0,0 +1,71 @@
+import { Context } from "../context.ts";
+import { ApiContext } from "../api.ts";
+import * as p from 'npm:@clack/prompts';
+import color from 'npm:picocolors';
+import { apiConfig } from "../si_client.ts";
+import { ChangeSetsApi, ChangeSetViewV1 } from "https://jsr.io/@systeminit/api-client/1.9.0/api.ts";
+
+const EXIT = "-1";
+
+export async function callTui(ctx: Context, _apiCtx: ApiContext) {
+  const changeSetsApi = new ChangeSetsApi(apiConfig);
+  const workspaceId = ctx.workspaceId;
+  if (!workspaceId) throw new Error("No Workspace");
+
+  p.updateSettings({
+		aliases: {
+			w: 'up',
+			s: 'down',
+			a: 'left',
+			d: 'right',
+		},
+	});
+
+  p.intro("Welcome! Let's review propsed changes in your workspace")
+
+  const cs = p.spinner({
+    onCancel: () => {
+      process.exit(0);
+    }
+  });
+  cs.start("Retrieving change sets");
+  const response = await changeSetsApi.listChangeSets({ workspaceId });
+  const changeSets = response.data.changeSets as ChangeSetViewV1[];
+  cs.stop();
+
+  const options = changeSets.map((c) => {
+    return {
+      value: c.id,
+      label: c.name,
+    }
+  })
+  const csId = await p.select({
+    message: "Choose a change set:",
+    options,
+  });
+
+  if (p.isCancel(csId)) {
+    p.cancel("Cancelled, exiting...")
+    process.exit(0);
+  }
+
+  const c = p.spinner();
+  c.start("Retrieving components");
+  c.stop();
+
+  while (true) {
+    const componentId = await p.select({
+      message: "Choose a component to review:",
+      options: [
+        {value: EXIT, label: "[quit]"}
+      ],
+    });
+    if (p.isCancel(componentId)) {
+      p.cancel("Cancelled, exiting...")
+      process.exit(0);
+    }
+    if (componentId === EXIT) break;
+  }
+
+  p.outro("Goodbye");
+}

bin/si/src/command/tui.ts

@@ -10,6 +10,7 @@ mod components;
 mod debug_funcs;
 mod funcs;
 mod management_funcs;
+mod mv;
 mod schemas;
 mod search;
 mod secrets;
@@ -132,6 +133,7 @@ pub use management_funcs::{
     ManagementFuncsResult,
     get_management_func_run_state::GetManagementFuncJobStateV1Response,
 };
+pub use mv::get::MvResponse;
 pub use schemas::{
     DetachFuncBindingV1Response,
     GetSchemaV1Response,
@@ -266,6 +268,7 @@ pub use crate::api_types::func_run::v1::{
         secrets::update_secret::update_secret,
         secrets::get_secrets::get_secrets,
         search::search,
+        mv::get::get,
     ),
     components(
         schemas(
@@ -364,6 +367,7 @@ pub use crate::api_types::func_run::v1::{
             ExecDebugFuncV1Request,
             ExecDebugFuncV1Response,
             GetDebugFuncJobStateV1Response,
+            MvResponse,
         )
     ),
     tags(
@@ -375,7 +379,8 @@ pub use crate::api_types::func_run::v1::{
         (name = "secrets", description = "Secret management endpoints"),
         (name = "funcs", description = "Functions management endpoints"),
         (name = "debug_funcs", description = "Debug function endpoints"),
-        (name = "management_funcs", description = "Management functions endpoints")
+        (name = "management_funcs", description = "Management functions endpoints"),
+        (name = "mv", description = "Materialized view endpoints"),
     )
 )]
 pub struct V1ApiDoc;

lib/luminork-server/src/service/v1.rs

@@ -0,0 +1,87 @@
+use axum::{
+    Json,
+    extract::Query,
+};
+use sdf_extract::FriggStore;
+use serde::{
+    Deserialize,
+    Serialize,
+};
+use si_frontend_mv_types::object::FrontendObject;
+use utoipa::{
+    IntoParams,
+    ToSchema,
+};
+
+use super::{
+    MvError,
+    MvResult,
+};
+use crate::extract::change_set::ChangeSetDalContext;
+
+#[derive(Deserialize, Serialize, ToSchema, IntoParams, Debug, Clone)]
+#[serde(rename_all = "camelCase")]
+pub struct GetParams {
+    #[schema(example = "01H9ZQD35JPMBGHH69BT0Q79VY", nullable = false, value_type = String)]
+    pub entity_id: String,
+    #[schema(example = "ComponentList", nullable = false, value_type = String)]
+    pub kind: String,
+}
+
+#[derive(Deserialize, Serialize, Debug, ToSchema, Clone)]
+#[serde(rename_all = "camelCase")]
+pub struct MvResponse {
+    #[schema(example = "ComponentList")]
+    pub kind: String,
+    #[schema(example = "")]
+    pub id: String,
+    #[schema(example = "")]
+    pub checksum: String,
+    #[schema(example = "{}")]
+    pub data: serde_json::Value,
+}
+
+#[utoipa::path(
+    get,
+    path = "/v1/{workspace_id}/change-sets/{change_set_id}/mv",
+    params(
+        ("workspace_id" = String, Path, description = "Workspace identifier"),
+        ("change_set_id" = String, Path, description = "Change Set identifier"),
+        GetParams,
+    ),
+    tag = "mv",
+    summary = "Identifiers for a materialized view",
+    responses(
+        (status = 200, description = "Mv retrieved successfully", body = MvResponse),
+        (status = 404, description = "Mv not found"),
+        (status = 500, description = "Internal server error", body = crate::service::v1::common::ApiError)
+    )
+)]
+pub async fn get(
+    ChangeSetDalContext(ref ctx): ChangeSetDalContext,
+    Query(params): Query<GetParams>,
+    FriggStore(frigg): FriggStore,
+) -> MvResult<Json<MvResponse>> {
+    let obj = frigg
+        .get_current_workspace_object(
+            ctx.workspace_pk()?,
+            ctx.change_set_id(),
+            &params.kind,
+            &params.entity_id,
+        )
+        .await?;
+    match obj {
+        Some(FrontendObject {
+            kind,
+            id,
+            checksum,
+            data,
+        }) => Ok(Json(MvResponse {
+            kind,
+            id,
+            checksum,
+            data,
+        })),
+        None => Err(MvError::NotFound(params.kind, params.entity_id)),
+    }
+}

lib/luminork-server/src/service/v1/mv/get.rs

@@ -0,0 +1,54 @@
+use axum::{
+    Router,
+    http::StatusCode,
+    response::IntoResponse,
+    routing::get,
+};
+use dal::TransactionsError;
+use frigg::FriggError;
+use thiserror::Error;
+
+use crate::AppState;
+
+pub mod get;
+
+#[remain::sorted]
+#[derive(Debug, Error)]
+pub enum MvError {
+    #[error("decode error: {0}")]
+    Decode(#[from] ulid::DecodeError),
+    #[error("frigg error: {0}")]
+    Frigg(#[from] FriggError),
+    #[error("join error: {0}")]
+    Join(#[from] tokio::task::JoinError),
+    #[error("MV not found error: {0} {1}")]
+    NotFound(String, String),
+    #[error("slow runtime error: {0}")]
+    SlowRuntime(#[from] dal::slow_rt::SlowRuntimeError),
+    #[error("transactions error: {0}")]
+    Transactions(#[from] TransactionsError),
+    #[error("workspace snapshot error: {0}")]
+    WorkspaceSnapshot(#[from] dal::WorkspaceSnapshotError),
+}
+
+impl IntoResponse for MvError {
+    fn into_response(self) -> axum::response::Response {
+        use crate::service::v1::common::ErrorIntoResponse;
+        self.to_api_response()
+    }
+}
+
+impl crate::service::v1::common::ErrorIntoResponse for MvError {
+    fn status_and_message(&self) -> (StatusCode, String) {
+        match self {
+            MvError::NotFound(_kind, _id) => (StatusCode::NOT_FOUND, self.to_string()),
+            _ => (StatusCode::INTERNAL_SERVER_ERROR, self.to_string()),
+        }
+    }
+}
+
+pub fn routes() -> Router<AppState> {
+    Router::new().route("/", get(get::get))
+}
+
+pub type MvResult<T> = Result<T, MvError>;

lib/luminork-server/src/service/v1/mv/mod.rs

@@ -74,6 +74,7 @@ pub fn routes(state: AppState) -> Router<AppState> {
                             .nest("/actions", super::actions::routes())
                             .nest("/secrets", super::secrets::routes())
                             .nest("/management-funcs", super::management_funcs::routes())
+                            .nest("/mv", super::mv::routes())
                             .nest("/debug-funcs", super::debug_funcs::routes())
                             .route(
                                 "/request_approval",