Merge branch 'dev' into mainnet

api/src/controllers/model.js

@@ -1,5 +1,5 @@
 import { createClient } from "redis";
-import { indexNewModel } from "../libs/composedb.js";
+import { indexNewModel, stopIndexingModels } from "../libs/composedb.js";
 
 export const info = async (req, res) => {
   const runtimeDefinition = req.app.get("runtimeDefinition");
@@ -26,3 +26,19 @@ export const deploy = async (req, res, next) => {
   }
   res.json(indexResult);
 };
+
+export const remove = async (req, res, next) => {
+  const pubClient = createClient({
+    url: process.env.REDIS_CONNECTION_STRING,
+  });
+  await pubClient.connect();
+  const indexResult = await stopIndexingModels(
+    req.app,
+    req.params.id,
+    req.headers.authorization,
+  );
+  if (indexResult) {
+    pubClient.publish("newModel", req.params.id);
+  }
+  res.json(indexResult);
+};

api/src/libs/composedb.js

@@ -380,6 +380,33 @@ export const indexNewModel = async (app, modelId, ceramicAdminPrivateKey) => {
 
   return true;
 };
+
+export const stopIndexingModels = async (
+  app,
+  modelId,
+  ceramicAdminPrivateKey,
+) => {
+  const indexerCeramic = new CeramicClient(process.env.CERAMIC_HOST);
+  if (!ceramicAdminPrivateKey) {
+    return false;
+  }
+  const key = fromString(ceramicAdminPrivateKey, "base16");
+  const did = new DID({
+    resolver: getResolver(),
+    provider: new Ed25519Provider(key),
+  });
+  await did.authenticate();
+  if (!did.authenticated) {
+    return false;
+  }
+  indexerCeramic.did = did;
+
+  const models = await indexerCeramic.admin.stopIndexingModels([modelId]);
+
+  await setIndexedModelParams(app);
+
+  return models;
+};
 export const setIndexedModelParams = async (app) => {
   await authenticateAdmin();
   const models = await ceramic.admin.getIndexedModels();

api/src/packages/api.js

@@ -504,6 +504,16 @@ app.post(
   modelController.deploy,
 );
 
+app.delete(
+  "/model/index/:id",
+  validator.params(
+    Joi.object({
+      id: Joi.custom(isStreamID, "Model ID").required(),
+    }),
+  ),
+  modelController.remove,
+);
+
 // Validators
 app.use(errorMiddleware);