👍 Add Projector to compose Source/Curator

Author: lambdalisue

deno.jsonc

@@ -3,6 +3,7 @@
   "version": "0.0.0",
   "exports": {
     ".": "./denops/@fall/mod.ts",
+    "./action": "./denops/@fall/action.ts",
     "./builtin": "./denops/@fall/builtin/mod.ts",
     "./builtin/action": "./denops/@fall/builtin/action/mod.ts",
     "./builtin/action/cmd": "./denops/@fall/builtin/action/cmd.ts",
@@ -49,18 +50,18 @@
     "./builtin/theme/double": "./denops/@fall/builtin/theme/double.ts",
     "./builtin/theme/modern": "./denops/@fall/builtin/theme/modern.ts",
     "./builtin/theme/single": "./denops/@fall/builtin/theme/single.ts",
-    "./util/testutil": "./denops/@fall/util/testutil.ts",
-    "./action": "./denops/@fall/action.ts",
     "./config": "./denops/@fall/config.ts",
     "./curator": "./denops/@fall/curator.ts",
     "./item": "./denops/@fall/item.ts",
     "./layout": "./denops/@fall/layout.ts",
     "./matcher": "./denops/@fall/matcher.ts",
     "./previewer": "./denops/@fall/previewer.ts",
+    "./projector": "./denops/@fall/projector.ts",
     "./renderer": "./denops/@fall/renderer.ts",
     "./sorter": "./denops/@fall/sorter.ts",
     "./source": "./denops/@fall/source.ts",
-    "./theme": "./denops/@fall/theme.ts"
+    "./theme": "./denops/@fall/theme.ts",
+    "./util/testutil": "./denops/@fall/util/testutil.ts"
   },
   "publish": {
     "include": [

denops/@fall/_typeutil.ts

@@ -1,3 +1,6 @@
 export type FlatType<T> = T extends Record<PropertyKey, unknown>
   ? { [K in keyof T]: FlatType<T[K]> }
   : T;
+
+export type LastType<T extends unknown[]> = T extends [...infer _, infer L] ? L
+  : never;

denops/@fall/builtin/filter/cwd_filter.ts

@@ -0,0 +1,26 @@
+import type { Denops } from "jsr:@denops/std@^7.3.0";
+import * as fn from "jsr:@denops/std@^7.0.0/function";
+
+import type { IdItem } from "../../item.ts";
+import type { Projector, ProjectParams } from "../../projector.ts";
+
+type Detail = {
+  path: string;
+};
+
+export class CwdFilter<T extends Detail> implements Projector<T> {
+  async *project(
+    denops: Denops,
+    { items }: ProjectParams<T>,
+    { signal }: { signal?: AbortSignal },
+  ): AsyncIterableIterator<IdItem<T>> {
+    const cwd = await fn.getcwd(denops);
+    signal?.throwIfAborted();
+    for await (const item of items) {
+      signal?.throwIfAborted();
+      if (item.detail.path.startsWith(cwd)) {
+        yield item;
+      }
+    }
+  }
+}

denops/@fall/builtin/filter/exist_filter.ts

@@ -0,0 +1,24 @@
+import type { Denops } from "jsr:@denops/std@^7.3.0";
+import { exists } from "jsr:@std/fs@^1.0.0/exists";
+
+import type { IdItem } from "../../item.ts";
+import type { Projector, ProjectParams } from "../../projector.ts";
+
+type Detail = {
+  path: string;
+};
+
+export class ExistFilter<T extends Detail> implements Projector<T> {
+  async *project(
+    _denops: Denops,
+    { items }: ProjectParams<T>,
+    { signal }: { signal?: AbortSignal },
+  ): AsyncIterableIterator<IdItem<T>> {
+    for await (const item of items) {
+      if (await exists(item.detail.path)) {
+        yield item;
+      }
+      signal?.throwIfAborted();
+    }
+  }
+}

denops/@fall/builtin/filter/mod.ts

@@ -0,0 +1,3 @@
+export * from "./cwd_filter.ts";
+export * from "./exist_filter.ts";
+export * from "./regexp_filter.ts";

denops/@fall/builtin/filter/regexp_filter.ts

@@ -0,0 +1,41 @@
+import type { Denops } from "jsr:@denops/std@^7.3.0";
+
+import type { IdItem } from "../../item.ts";
+import type { Projector, ProjectParams } from "../../projector.ts";
+
+type Options = {
+  includes?: RegExp[];
+  excludes?: RegExp[];
+};
+
+type Detail = {
+  path: string;
+};
+
+export class RegexpFilter<T extends Detail> implements Projector<T> {
+  #includes?: RegExp[];
+  #excludes?: RegExp[];
+
+  constructor({ includes, excludes }: Options) {
+    this.#includes = includes;
+    this.#excludes = excludes;
+  }
+
+  async *project(
+    _denops: Denops,
+    { items }: ProjectParams<T>,
+    { signal }: { signal?: AbortSignal },
+  ): AsyncIterableIterator<IdItem<T>> {
+    signal?.throwIfAborted();
+    for await (const item of items) {
+      signal?.throwIfAborted();
+      if (this.#includes && !this.#includes.some((r) => r.test(item.value))) {
+        continue;
+      }
+      if (this.#excludes && this.#excludes.some((r) => r.test(item.value))) {
+        continue;
+      }
+      yield item;
+    }
+  }
+}

denops/@fall/builtin/mod.ts

@@ -1,7 +1,9 @@
 export * as action from "./action/mod.ts";
 export * as curator from "./curator/mod.ts";
+export * as filter from "./filter/mod.ts";
 export * as layout from "./layout/mod.ts";
 export * as matcher from "./matcher/mod.ts";
+export * as modifier from "./modifier/mod.ts";
 export * as previewer from "./previewer/mod.ts";
 export * as renderer from "./renderer/mod.ts";
 export * as sorter from "./sorter/mod.ts";

denops/@fall/builtin/modifier/mod.ts

@@ -0,0 +1 @@
+export * from "./relative_path.ts";

denops/@fall/builtin/modifier/relative_path.ts

@@ -0,0 +1,39 @@
+import type { Denops } from "jsr:@denops/std@^7.3.0";
+import * as fn from "jsr:@denops/std@^7.0.0/function";
+import { relative } from "jsr:@std/path@^1.0.0/relative";
+
+import type { IdItem } from "../../item.ts";
+import type { Projector, ProjectParams } from "../../projector.ts";
+
+type Detail = {
+  path: string;
+};
+
+type DetailAfter = {
+  abspath: string;
+};
+
+export class RelativePathModifier<T extends Detail, U extends T & DetailAfter>
+  implements Projector<T, U> {
+  async *project(
+    denops: Denops,
+    { items }: ProjectParams<T>,
+    { signal }: { signal?: AbortSignal },
+  ): AsyncIterableIterator<IdItem<U>> {
+    const cwd = await fn.getcwd(denops);
+    signal?.throwIfAborted();
+    for await (const item of items) {
+      const relpath = relative(cwd, item.detail.path);
+      const value = item.value.replace(item.detail.path, relpath);
+      yield {
+        ...item,
+        value,
+        detail: {
+          ...item.detail,
+          path: relpath,
+          abspath: item.detail.path,
+        },
+      } as IdItem<U>;
+    }
+  }
+}

denops/@fall/builtin/source/buffer.ts

@@ -1,7 +1,7 @@
 import type { Denops } from "jsr:@denops/std@^7.3.0";
 import * as fn from "jsr:@denops/std@^7.0.0/function";
 
-import type { Item } from "../../item.ts";
+import type { IdItem } from "../../item.ts";
 import type { CollectParams, Source } from "../../source.ts";
 
 type Filter = "buflisted" | "bufloaded" | "bufmodified";
@@ -33,7 +33,7 @@ export class BufferSource implements Source<Detail> {
     denops: Denops,
     _params: CollectParams,
     { signal }: { signal?: AbortSignal },
-  ): AsyncIterableIterator<Item<Detail>> {
+  ): AsyncIterableIterator<IdItem<Detail>> {
     const bufinfo = await fn.getbufinfo(denops);
     signal?.throwIfAborted();
     const items = bufinfo
@@ -48,7 +48,8 @@ export class BufferSource implements Source<Detail> {
         }
         return true;
       })
-      .map((v) => ({
+      .map((v, i) => ({
+        id: i,
         value: v.name,
         detail: {
           bufnr: v.bufnr,