fix: update Schema service to use new API endpoint

devbox.json

@@ -54,6 +54,7 @@
         "make build-hway"
       ],
       "gen:proto": [
+        "rm -rf ./pkg/nebula/node_modules",
         "make proto-gen"
       ],
       "gen:pkl": [

pkg/nebula/nebula.go

@@ -1,22 +1,16 @@
 package nebula
 
 import (
-	"context"
 	"embed"
 	"io/fs"
 	"net/http"
 
 	"github.com/labstack/echo/v4"
-
-	"github.com/onsonr/sonr/pkg/nebula/models"
 )
 
 //go:embed assets
 var embeddedFiles embed.FS
 
-//go:embed nebula.pkl
-var config []byte
-
 func getHTTPFS() (http.FileSystem, error) {
 	fsys, err := fs.Sub(embeddedFiles, "assets")
 	if err != nil {
@@ -27,21 +21,12 @@ func getHTTPFS() (http.FileSystem, error) {
 
 // UseAssets is a middleware that serves static files from the embedded assets
 func UseAssets(e *echo.Echo) error {
-	err := models.LoadFromString(context.Background(), string(config))
-	if err != nil {
-		return err
-	}
 	fsys, err := getHTTPFS()
 	if err != nil {
 		return err
 	}
 	assets := http.FileServer(fsys)
 	e.GET("/", echo.WrapHandler(assets))
 	e.GET("/assets/*", echo.WrapHandler(http.StripPrefix("/assets/", assets)))
-	e.GET("/_nebula/config", handleGetConfig)
 	return nil
 }
-
-func handleGetConfig(c echo.Context) error {
-	return c.Blob(http.StatusOK, "application/octet-stream", config)
-}

proto/vault/v1/query.proto

@@ -18,6 +18,12 @@ service Query {
     option (google.api.http).post = "/vault/v1/buildtx";
   }
 
+  // Schema queries the DID document by its id. And returns the required PKL
+  // information
+  rpc Schema(QuerySchemaRequest) returns (QuerySchemaResponse) {
+    option (google.api.http).get = "/vault/v1/schema";
+  }
+
   // Sync queries the DID document by its id. And returns the required PKL
   // information
   rpc Sync(SyncRequest) returns (SyncResponse) {
@@ -43,6 +49,15 @@ message QueryIPFSResponse {
   bool ipfs = 1;
 }
 
+// QuerySchemaRequest is the request type for the Query/Schema RPC method.
+message QuerySchemaRequest {}
+
+// QuerySchemaResponse is the response type for the Query/Schema RPC method.
+message QuerySchemaResponse {
+  // Schema is the DID document.
+  Schema schema = 1;
+}
+
 // SyncRequest is the request type for the Sync RPC method.
 message SyncRequest {
   string did = 1;

x/vault/keeper/querier.go

@@ -40,3 +40,16 @@ func (k Querier) BuildTx(goCtx context.Context, req *types.BuildTxRequest) (*typ
 	// ctx := sdk.UnwrapSDKContext(goCtx)
 	return &types.BuildTxResponse{}, nil
 }
+
+// Schema implements types.QueryServer.
+func (k Querier) Schema(goCtx context.Context, req *types.QuerySchemaRequest) (*types.QuerySchemaResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	p, err := k.Keeper.Params.Get(ctx)
+	if err != nil {
+		return nil, err
+	}
+	return &types.QuerySchemaResponse{
+		Schema: p.Schema,
+	}, nil
+}