fixed types

src/_db/commands/reindex/postgres.ts

@@ -94,11 +94,8 @@ export const handler = async (argv) => {
   if (!aliasesBlob) {
     logger.error({ msg: "no aliasesBlob for index " + esTargetIndex });
   } else {
-    aliasesBlob.body.split("\n").forEach((aliasDesc) => {
-      const parts = aliasDesc.split(" ");
-      if (parts.length >= 2) {
-        currentIndices.push(parts[1]);
-      }
+    aliasesBlob.body.forEach((aliasRec) => {
+      currentIndicesWrite.push(aliasRec.alias!);
     });
     logger.info({ msg: "found current read indices", count: currentIndices.length });
   }
@@ -108,11 +105,8 @@ export const handler = async (argv) => {
   if (!aliasesBlobWrite.body) {
     logger.error({ msg: "no aliasesBlobWrite" });
   } else {
-    aliasesBlobWrite.body.split("\n").forEach((aliasDesc) => {
-      const parts = aliasDesc.split(" ");
-      if (parts.length >= 2) {
-        currentIndicesWrite.push(parts[1]);
-      }
+    aliasesBlobWrite.body.forEach((aliasRec) => {
+      currentIndicesWrite.push(aliasRec.alias!);
     });
   }
 

src/_processor/test/workers/ElasticsearchSaverTest.ts

@@ -124,10 +124,7 @@ class ElasticsearchSaverTest {
         })
       )
     )
-      .returns(
-        () =>
-          Promise.resolve({ body: {} }) as TransportRequestPromise<ApiResponse<Record<string, any>, unknown>>
-      )
+      .returns(() => Promise.resolve({ body: {} }) as TransportRequestPromise<ApiResponse>)
       .verifiable(TypeMoq.Times.once());
 
     clock

src/models/environment/delete.ts

@@ -88,14 +88,14 @@ export default async function (opts: Options) {
           const indexName = resp.body[0].index;
 
           // Delete all aliases attached to the soon-to-be-deleted index
-          es.indices.deleteAlias({ index: indexName, name: "_all" }, (err2) => {
+          es.indices.deleteAlias({ index: indexName!, name: "_all" }, (err2) => {
             if (err2) {
               reject(err2);
               return;
             }
 
             // Finally, delete the index itself
-            es.indices.delete({ index: indexName }, (err3) => {
+            es.indices.delete({ index: indexName! }, (err3) => {
               if (err3) {
                 reject(err3);
                 return;

src/models/event/query.ts

@@ -1,7 +1,7 @@
 import _ from "lodash";
 import searchQueryParser from "search-query-parser";
 import moment from "moment";
-import { ApiResponse, RequestParams } from "@opensearch-project/opensearch";
+import { ApiResponse, type API } from "@opensearch-project/opensearch";
 
 import { Scope } from "../../security/scope";
 import { scope, getESWithRetry, ClientWithRetry } from "../../persistence/elasticsearch";
@@ -294,7 +294,7 @@ export function parse(searchQuery: string): any {
   return q;
 }
 
-export function searchParams(opts: Options): RequestParams.Search {
+export function searchParams(opts: Options): API.Search_Request {
   const searchQuery = parse(opts.query);
   const [index, securityFilters] = scope(opts.scope);
 
@@ -366,7 +366,7 @@ export function searchParams(opts: Options): RequestParams.Search {
   // };
 }
 
-export function searchParamsPaginated(opts: OptionsPaginated): RequestParams.Search {
+export function searchParamsPaginated(opts: OptionsPaginated): API.Search_Request {
   const searchQuery = parse(opts.query);
   const [index, securityFilters] = scope(opts.scope);
 

src/test/models/event/countBy.ts

@@ -20,7 +20,7 @@ class EventsCountByTest {
           },
         },
       },
-    } as ApiResponse<any>;
+    } as ApiResponse;
 
     es.setup((x) => x.search(TypeMoq.It.isAny())).returns((params): any => {
       assert.deepEqual(params.body.query.bool.filter, [

src/test/models/event/query.ts

@@ -1,7 +1,7 @@
 import { suite, test } from "@testdeck/mocha";
 
 import { parse, searchParams, Options } from "../../../models/event/query";
-import { RequestParams } from "@opensearch-project/opensearch";
+import { type API } from "@opensearch-project/opensearch";
 import assert from "assert";
 
 @suite
@@ -164,7 +164,7 @@ class QueryEventsTest {
       cursor: [1492060162148, "abc123"],
     };
     const output = searchParams(input);
-    const answer: RequestParams.Search = {
+    const answer: API.Search_Request = {
       index: "retraced.p1.e1.current",
       _source: "true",
       size: 10,